summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorRichard Purdie <rpurdie@linux.intel.com>2010-09-13 16:57:13 +0100
committerRichard Purdie <rpurdie@linux.intel.com>2010-09-13 16:57:13 +0100
commit474c2a2817acbea8ae79dd28ce026ffa1294b120 (patch)
treef2f0a4cd50c307ca77ce14914bd7f2e5f69ffb26
parente88859663612984ec0955af8fe49d6d26543d5d3 (diff)
downloadopenembedded-core-474c2a2817acbea8ae79dd28ce026ffa1294b120.tar.gz
openembedded-core-474c2a2817acbea8ae79dd28ce026ffa1294b120.tar.bz2
openembedded-core-474c2a2817acbea8ae79dd28ce026ffa1294b120.tar.xz
openembedded-core-474c2a2817acbea8ae79dd28ce026ffa1294b120.zip
bitbake/runqueue.py: Optimise delay values to avoid unneeded delays
Signed-off-by: Richard Purdie <rpurdie@linux.intel.com>
-rw-r--r--bitbake/lib/bb/runqueue.py18
1 files changed, 9 insertions, 9 deletions
diff --git a/bitbake/lib/bb/runqueue.py b/bitbake/lib/bb/runqueue.py
index 4d1dc49d7..608deaed6 100644
--- a/bitbake/lib/bb/runqueue.py
+++ b/bitbake/lib/bb/runqueue.py
@@ -908,7 +908,7 @@ class RunQueue:
self.rqexe = RunQueueExecuteScenequeue(self)
if self.state is runQueueSceneRun:
- self.rqexe.execute()
+ retval = self.rqexe.execute()
if self.state is runQueueRunInit:
bb.msg.note(1, bb.msg.domain.RunQueue, "Executing runqueue")
@@ -916,7 +916,7 @@ class RunQueue:
self.state = runQueueRunning
if self.state is runQueueRunning:
- self.rqexe.execute()
+ retval = self.rqexe.execute()
if self.state is runQueueCleanUp:
self.rqexe.finish()
@@ -1177,7 +1177,7 @@ class RunQueueExecuteTasks(RunQueueExecute):
if self.rq.check_stamp_task(task, taskname):
bb.msg.debug(2, bb.msg.domain.RunQueue, "Stamp current task %s (%s)" % (task, self.rqdata.get_user_idstring(task)))
self.task_skip(task)
- continue
+ return True
bb.event.fire(runQueueTaskStarted(task, self.stats, self.rq), self.cfgData)
bb.msg.note(1, bb.msg.domain.RunQueue,
@@ -1194,19 +1194,19 @@ class RunQueueExecuteTasks(RunQueueExecute):
self.runq_running[task] = 1
self.stats.taskActive()
if self.stats.active < self.number_tasks:
- continue
+ return True
for pipe in self.build_pipes:
self.build_pipes[pipe].read()
if self.stats.active > 0:
if self.runqueue_process_waitpid() is None:
- return
- continue
+ return 0.5
+ return True
if len(self.failed_fnids) != 0:
self.rq.state = runQueueFailed
- return
+ return True
# Sanity Checks
for task in range(self.stats.total):
@@ -1217,7 +1217,7 @@ class RunQueueExecuteTasks(RunQueueExecute):
if self.runq_complete[task] == 0:
bb.msg.error(bb.msg.domain.RunQueue, "Task %s never completed!" % task)
self.rq.state = runQueueComplete
- return
+ return True
class RunQueueExecuteScenequeue(RunQueueExecute):
def __init__(self, rq):
@@ -1413,7 +1413,7 @@ class RunQueueExecuteScenequeue(RunQueueExecute):
if self.stats.active > 0:
if self.runqueue_process_waitpid() is None:
- return True
+ return 0.5
return True
# Convert scenequeue_covered task numbers into full taskgraph ids