summaryrefslogtreecommitdiffstats
path: root/pym/_emerge/Scheduler.py
diff options
context:
space:
mode:
Diffstat (limited to 'pym/_emerge/Scheduler.py')
-rw-r--r--pym/_emerge/Scheduler.py16
1 files changed, 8 insertions, 8 deletions
diff --git a/pym/_emerge/Scheduler.py b/pym/_emerge/Scheduler.py
index d64468af0..40033c2c3 100644
--- a/pym/_emerge/Scheduler.py
+++ b/pym/_emerge/Scheduler.py
@@ -1337,12 +1337,12 @@ class Scheduler(PollScheduler):
blocker_db.discardBlocker(pkg)
def _main_loop(self):
- term_check_id = self.sched_iface.idle_add(self._termination_check)
+ term_check_id = self._event_loop.idle_add(self._termination_check)
loadavg_check_id = None
if self._max_load is not None:
# We have to schedule periodically, in case the load
# average has changed since the last call.
- loadavg_check_id = self.sched_iface.timeout_add(
+ loadavg_check_id = self._event_loop.timeout_add(
self._loadavg_latency, self._schedule)
try:
@@ -1354,17 +1354,17 @@ class Scheduler(PollScheduler):
# Loop while there are jobs to be scheduled.
while self._keep_scheduling():
- self.sched_iface.iteration()
+ self._event_loop.iteration()
# Clean shutdown of previously scheduled jobs. In the
# case of termination, this allows for basic cleanup
# such as flushing of buffered output to logs.
while self._is_work_scheduled():
- self.sched_iface.iteration()
+ self._event_loop.iteration()
finally:
- self.sched_iface.source_remove(term_check_id)
+ self._event_loop.source_remove(term_check_id)
if loadavg_check_id is not None:
- self.sched_iface.source_remove(loadavg_check_id)
+ self._event_loop.source_remove(loadavg_check_id)
def _merge(self):
@@ -1378,7 +1378,7 @@ class Scheduler(PollScheduler):
portage.elog.add_listener(self._elog_listener)
display_timeout_id = None
if self._status_display._isatty and not self._status_display.quiet:
- display_timeout_id = self.sched_iface.timeout_add(
+ display_timeout_id = self._event_loop.timeout_add(
self._max_display_latency, self._status_display.display)
rval = os.EX_OK
@@ -1389,7 +1389,7 @@ class Scheduler(PollScheduler):
portage.locks._quiet = False
portage.elog.remove_listener(self._elog_listener)
if display_timeout_id is not None:
- self.sched_iface.source_remove(display_timeout_id)
+ self._event_loop.source_remove(display_timeout_id)
if failed_pkgs:
rval = failed_pkgs[-1].returncode