diff options
| author |   Zac Medico <zmedico@gentoo.org> | 2012-10-03 03:18:46 -0700 |
|---|---|---|
| committer | Zac Medico <zmedico@gentoo.org> | 2012-10-03 03:18:46 -0700 |
| commit | 117eeee2de26723a90ff072b7c795b1b0766898b (patch) | |
| tree | 15c9318c56289a6f351df4ae8ef027cfa39f4068 | |
| parent | EbuildFetcher/MergeProcess: inherit ForkProcess (diff) | |
| download | portage-117eeee2de26723a90ff072b7c795b1b0766898b.tar.gz portage-117eeee2de26723a90ff072b7c795b1b0766898b.tar.bz2 portage-117eeee2de26723a90ff072b7c795b1b0766898b.zip | |
AsyncScheduler: source_remove in _wait
| -rw-r--r-- | pym/portage/util/_async/AsyncScheduler.py | 8 |
1 files changed, 8 insertions, 0 deletions
diff --git a/pym/portage/util/_async/AsyncScheduler.py b/pym/portage/util/_async/AsyncScheduler.py index cae45fd90..130331ec5 100644 --- a/pym/portage/util/_async/AsyncScheduler.py +++ b/pym/portage/util/_async/AsyncScheduler.py @@ -80,6 +80,14 @@ class AsyncScheduler(AsynchronousTask, PollScheduler): while self._is_work_scheduled(): self.sched_iface.iteration() + if self._term_check_id is not None: + self.sched_iface.source_remove(self._term_check_id) + self._term_check_id = None + + if self._loadavg_check_id is not None: + self.sched_iface.source_remove(self._loadavg_check_id) + self._loadavg_check_id = None + if self._error_count > 0: self.returncode = 1 else: |