summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorRichard Purdie <rpurdie@linux.intel.com>2007-01-07 18:16:58 +0000
committerRichard Purdie <rpurdie@linux.intel.com>2007-01-07 18:16:58 +0000
commit1d8bea09757b1159b5b3ed0179c3bd006df12ba3 (patch)
tree9026c739448915f46a0bc4fd42edd96e790c0801
parent4304b6a876cecbaa762a130dad90de6074a584ee (diff)
downloadbitbake-1d8bea09757b1159b5b3ed0179c3bd006df12ba3.tar.gz
runqueue.py: Give the user some idea of the number of tasks involved
-rw-r--r--lib/bb/runqueue.py12
1 files changed, 10 insertions, 2 deletions
diff --git a/lib/bb/runqueue.py b/lib/bb/runqueue.py
index 606332866..2ef2670da 100644
--- a/lib/bb/runqueue.py
+++ b/lib/bb/runqueue.py
@@ -357,10 +357,13 @@ class RunQueue:
bb.msg.note(1, bb.msg.domain.RunQueue, "Executing runqueue")
+ active_builds = 0
+ tasks_completed = 0
+ tasks_skipped = 0
+
runq_buildable = []
runq_running = []
runq_complete = []
- active_builds = 0
build_pids = {}
failed_fnids = []
@@ -428,9 +431,11 @@ class RunQueue:
bb.msg.debug(2, bb.msg.domain.RunQueue, "Stamp current task %s (%s)" % (task, self.get_user_idstring(task, taskData)))
runq_running[task] = 1
task_complete(self, task)
+ tasks_completed = tasks_completed + 1
+ tasks_skipped = tasks_skipped + 1
continue
- bb.msg.debug(1, bb.msg.domain.RunQueue, "Running task %s (%s)" % (task, self.get_user_idstring(task, taskData)))
+ bb.msg.note(1, bb.msg.domain.RunQueue, "Running task %d of %d (ID: %s, %s)" % (tasks_completed + active_builds + 1, len(self.runq_fnid), task, self.get_user_idstring(task, taskData)))
try:
pid = os.fork()
except OSError, e:
@@ -468,6 +473,7 @@ class RunQueue:
failed_fnids.append(self.runq_fnid[task])
break
task_complete(self, task)
+ tasks_completed = tasks_completed + 1
del build_pids[result[0]]
continue
break
@@ -503,6 +509,8 @@ class RunQueue:
if runq_complete[task] == 0:
bb.msg.error(bb.msg.domain.RunQueue, "Task %s never completed!" % task)
+ bb.msg.note(1, bb.msg.domain.RunQueue, "Tasks Summary: Attempted %d tasks of which %d didn't need to be rerun and %d failed." % (tasks_completed, tasks_skipped, len(failed_fnids)))
+
return failed_fnids
def dump_data(self, taskQueue):