diff options
author | Zac Medico <zmedico@gentoo.org> | 2012-02-07 19:58:48 -0800 |
---|---|---|
committer | Zac Medico <zmedico@gentoo.org> | 2012-02-07 19:58:48 -0800 |
commit | f17ff92635818620ea0df156dee4796c353d954a (patch) | |
tree | e0fbec93a0d8fa07fe769d726d50be9ea9b872a8 /pym/_emerge/AbstractPollTask.py | |
parent | 082c908cd82426dfd45a2bf0ca9741213a7c7d5f (diff) | |
download | portage-f17ff92635818620ea0df156dee4796c353d954a.tar.gz portage-f17ff92635818620ea0df156dee4796c353d954a.tar.bz2 portage-f17ff92635818620ea0df156dee4796c353d954a.zip |
AbstractPollTask: add _wait_loop method
Diffstat (limited to 'pym/_emerge/AbstractPollTask.py')
-rw-r--r-- | pym/_emerge/AbstractPollTask.py | 23 |
1 files changed, 22 insertions, 1 deletions
diff --git a/pym/_emerge/AbstractPollTask.py b/pym/_emerge/AbstractPollTask.py index 13e3c23f9..b4728e7a2 100644 --- a/pym/_emerge/AbstractPollTask.py +++ b/pym/_emerge/AbstractPollTask.py @@ -1,10 +1,11 @@ -# Copyright 1999-2011 Gentoo Foundation +# Copyright 1999-2012 Gentoo Foundation # Distributed under the terms of the GNU General Public License v2 import array import errno import logging import os +import time from portage.util import writemsg_level from _emerge.AsynchronousTask import AsynchronousTask @@ -121,3 +122,23 @@ class AbstractPollTask(AsynchronousTask): self._unregister() self.wait() + def _wait_loop(self, timeout=None): + + if timeout is None: + while self._registered: + self.scheduler.iteration() + return + + remaining_timeout = timeout + start_time = time.time() + while self._registered: + self.scheduler.iteration() + elapsed_time = time.time() - start_time + if elapsed_time < 0: + # The system clock has changed such that start_time + # is now in the future, so just assume that the + # timeout has already elapsed. + break + remaining_timeout = timeout - 1000 * elapsed_time + if remaining_timeout <= 0: + break |