diff options
| author | Zac Medico <zmedico@gentoo.org> | 2012-10-03 11:39:11 -0700 |
|---|---|---|
| committer | Zac Medico <zmedico@gentoo.org> | 2012-10-03 11:39:11 -0700 |
| commit | 3453c38128c8af3e0178dce7d2d64d7cfb899141 (patch) | |
| tree | 4f91cce98053706540036421853d0abd6b06810f | |
| parent | 359cf128a70f7153cb800d7a22c519ec7838f02b (diff) | |
| download | portage-3453c38128c8af3e0178dce7d2d64d7cfb899141.tar.gz portage-3453c38128c8af3e0178dce7d2d64d7cfb899141.tar.bz2 portage-3453c38128c8af3e0178dce7d2d64d7cfb899141.zip | |
AsyncScheduler: implement _poll
| -rw-r--r-- | pym/portage/util/_async/AsyncScheduler.py | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/pym/portage/util/_async/AsyncScheduler.py b/pym/portage/util/_async/AsyncScheduler.py index a452c0c37..3fb079c47 100644 --- a/pym/portage/util/_async/AsyncScheduler.py +++ b/pym/portage/util/_async/AsyncScheduler.py @@ -25,6 +25,11 @@ class AsyncScheduler(AsynchronousTask, PollScheduler): self._term_check_id = None self._loadavg_check_id = None + def _poll(self): + if not (self._is_work_scheduled() or self._keep_scheduling()): + self.wait() + return self.returncode + def _cancel(self): self._terminated.set() self._termination_check() |