summaryrefslogtreecommitdiffstats
path: root/pym/_emerge/PollScheduler.py
diff options
context:
space:
mode:
authorZac Medico <zmedico@gentoo.org>2012-02-11 12:05:17 -0800
committerZac Medico <zmedico@gentoo.org>2012-02-11 12:05:17 -0800
commit0f55a5a75c410d73779f7090784d06e40e03a1c9 (patch)
treef9836eb6035fe5f86608d21df62c4a3dcacd08dd /pym/_emerge/PollScheduler.py
parent78ccc379fb914d7604603e08ca4ac9fc30fcfc26 (diff)
downloadportage-0f55a5a75c410d73779f7090784d06e40e03a1c9.tar.gz
portage-0f55a5a75c410d73779f7090784d06e40e03a1c9.tar.bz2
portage-0f55a5a75c410d73779f7090784d06e40e03a1c9.zip
PollScheduler: return None from _schedule_tasks
The _keep_scheduling() template method is used instead.
Diffstat (limited to 'pym/_emerge/PollScheduler.py')
-rw-r--r--pym/_emerge/PollScheduler.py15
1 files changed, 10 insertions, 5 deletions
diff --git a/pym/_emerge/PollScheduler.py b/pym/_emerge/PollScheduler.py
index 3b3ef67df..e270e6ad0 100644
--- a/pym/_emerge/PollScheduler.py
+++ b/pym/_emerge/PollScheduler.py
@@ -70,6 +70,14 @@ class PollScheduler(object):
"""
raise NotImplementedError()
+ def _keep_scheduling(self):
+ """
+ @rtype: bool
+ @returns: True if there may be remaining tasks to schedule,
+ False otherwise.
+ """
+ return False
+
def _schedule_tasks(self):
"""
This is called from inside the _schedule() method, which
@@ -83,7 +91,7 @@ class PollScheduler(object):
Unless this method is used to perform user interface updates,
or something like that, the first thing it should do is check
the state of _terminated_tasks and if that is True then it
- should return False immediately (since there's no need to
+ should return immediately (since there's no need to
schedule anything after _terminate_tasks() has been called).
"""
pass
@@ -105,7 +113,7 @@ class PollScheduler(object):
self._terminated_tasks = True
self._terminate_tasks()
- return self._schedule_tasks()
+ self._schedule_tasks()
finally:
self._scheduling = False
@@ -125,9 +133,6 @@ class PollScheduler(object):
while self._is_work_scheduled():
self.sched_iface.iteration()
- def _keep_scheduling(self):
- return False
-
def _is_work_scheduled(self):
return bool(self._running_job_count())