summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--bitbake/lib/bb/runqueue.py10
1 files changed, 5 insertions, 5 deletions
diff --git a/bitbake/lib/bb/runqueue.py b/bitbake/lib/bb/runqueue.py
index 31978d49b..f9acd9ca2 100644
--- a/bitbake/lib/bb/runqueue.py
+++ b/bitbake/lib/bb/runqueue.py
@@ -956,7 +956,7 @@ class RunQueue:
self.build_pipes[pipe].read()
if self.stats.active > 0:
- if self.runqueue_process_waitpid() is None:
+ if self.runqueue_process_waitpid(self.task_complete, self.task_fail) is None:
return
continue
@@ -975,7 +975,7 @@ class RunQueue:
self.state = runQueueComplete
return
- def runqueue_process_waitpid(self):
+ def runqueue_process_waitpid(self, success, failure):
"""
Return none is there are no processes awaiting result collection, otherwise
collect the process exit codes and close the information pipe.
@@ -988,9 +988,9 @@ class RunQueue:
self.build_pipes[result[0]].close()
del self.build_pipes[result[0]]
if result[1] != 0:
- self.task_fail(task, result[1])
+ failure(task, result[1])
else:
- self.task_complete(task)
+ success(task)
self.stats.taskCompleted()
bb.event.fire(runQueueTaskCompleted(task, self.stats, self), self.cfgData)
@@ -1016,7 +1016,7 @@ class RunQueue:
try:
while self.stats.active > 0:
bb.event.fire(runQueueExitWait(self.stats.active), self.cfgData)
- if self.runqueue_process_waitpid() is None:
+ if self.runqueue_process_waitpid(self.task_complete, self.task_fail) is None:
return
except:
self.finish_runqueue_now()