summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
-rw-r--r--bitbake/lib/bb/runqueue.py21
-rw-r--r--bitbake/lib/bb/ui/knotty.py2
-rw-r--r--bitbake/lib/bb/ui/uihelper.py2
3 files changed, 20 insertions, 5 deletions
diff --git a/bitbake/lib/bb/runqueue.py b/bitbake/lib/bb/runqueue.py
index 6ce0ce80f6..10511a09dc 100644
--- a/bitbake/lib/bb/runqueue.py
+++ b/bitbake/lib/bb/runqueue.py
@@ -85,15 +85,19 @@ class RunQueueStats:
85 """ 85 """
86 Holds statistics on the tasks handled by the associated runQueue 86 Holds statistics on the tasks handled by the associated runQueue
87 """ 87 """
88 def __init__(self, total): 88 def __init__(self, total, setscene_total):
89 self.completed = 0 89 self.completed = 0
90 self.skipped = 0 90 self.skipped = 0
91 self.failed = 0 91 self.failed = 0
92 self.active = 0 92 self.active = 0
93 self.setscene_active = 0
94 self.setscene_covered = 0
95 self.setscene_notcovered = 0
96 self.setscene_total = setscene_total
93 self.total = total 97 self.total = total
94 98
95 def copy(self): 99 def copy(self):
96 obj = self.__class__(self.total) 100 obj = self.__class__(self.total, self.setscene_total)
97 obj.__dict__.update(self.__dict__) 101 obj.__dict__.update(self.__dict__)
98 return obj 102 return obj
99 103
@@ -112,6 +116,13 @@ class RunQueueStats:
112 def taskActive(self): 116 def taskActive(self):
113 self.active = self.active + 1 117 self.active = self.active + 1
114 118
119 def updateCovered(self, covered, notcovered):
120 self.setscene_covered = covered
121 self.setscene_notcovered = notcovered
122
123 def updateActiveSetscene(self, active):
124 self.setscene_active = active
125
115# These values indicate the next step due to be run in the 126# These values indicate the next step due to be run in the
116# runQueue state machine 127# runQueue state machine
117runQueuePrepare = 2 128runQueuePrepare = 2
@@ -1735,7 +1746,7 @@ class RunQueueExecute:
1735 self.holdoff_need_update = True 1746 self.holdoff_need_update = True
1736 self.sqdone = False 1747 self.sqdone = False
1737 1748
1738 self.stats = RunQueueStats(len(self.rqdata.runtaskentries)) 1749 self.stats = RunQueueStats(len(self.rqdata.runtaskentries), len(self.rqdata.runq_setscene_tids))
1739 1750
1740 for mc in rq.worker: 1751 for mc in rq.worker:
1741 rq.worker[mc].pipe.setrunqueueexec(self) 1752 rq.worker[mc].pipe.setrunqueueexec(self)
@@ -1786,6 +1797,7 @@ class RunQueueExecute:
1786 else: 1797 else:
1787 self.sq_task_complete(task) 1798 self.sq_task_complete(task)
1788 self.sq_live.remove(task) 1799 self.sq_live.remove(task)
1800 self.stats.updateActiveSetscene(len(self.sq_live))
1789 else: 1801 else:
1790 if status != 0: 1802 if status != 0:
1791 self.task_fail(task, status, fakerootlog=fakerootlog) 1803 self.task_fail(task, status, fakerootlog=fakerootlog)
@@ -2087,6 +2099,7 @@ class RunQueueExecute:
2087 self.build_stamps2.append(self.build_stamps[task]) 2099 self.build_stamps2.append(self.build_stamps[task])
2088 self.sq_running.add(task) 2100 self.sq_running.add(task)
2089 self.sq_live.add(task) 2101 self.sq_live.add(task)
2102 self.stats.updateActiveSetscene(len(self.sq_live))
2090 if self.can_start_task(): 2103 if self.can_start_task():
2091 return True 2104 return True
2092 2105
@@ -2462,6 +2475,7 @@ class RunQueueExecute:
2462 self.sq_task_failoutright(tid) 2475 self.sq_task_failoutright(tid)
2463 2476
2464 if changed: 2477 if changed:
2478 self.stats.updateCovered(len(self.scenequeue_covered), len(self.scenequeue_notcovered))
2465 self.holdoff_need_update = True 2479 self.holdoff_need_update = True
2466 2480
2467 def scenequeue_updatecounters(self, task, fail=False): 2481 def scenequeue_updatecounters(self, task, fail=False):
@@ -2495,6 +2509,7 @@ class RunQueueExecute:
2495 new.add(dep) 2509 new.add(dep)
2496 next = new 2510 next = new
2497 2511
2512 self.stats.updateCovered(len(self.scenequeue_covered), len(self.scenequeue_notcovered))
2498 self.holdoff_need_update = True 2513 self.holdoff_need_update = True
2499 2514
2500 def sq_task_completeoutright(self, task): 2515 def sq_task_completeoutright(self, task):
diff --git a/bitbake/lib/bb/ui/knotty.py b/bitbake/lib/bb/ui/knotty.py
index 0efa614dfc..04285eac67 100644
--- a/bitbake/lib/bb/ui/knotty.py
+++ b/bitbake/lib/bb/ui/knotty.py
@@ -745,7 +745,7 @@ def main(server, eventHandler, params, tf = TerminalFilter):
745 continue 745 continue
746 746
747 if isinstance(event, bb.runqueue.sceneQueueTaskStarted): 747 if isinstance(event, bb.runqueue.sceneQueueTaskStarted):
748 logger.info("Running setscene task %d of %d (%s)" % (event.stats.completed + event.stats.active + event.stats.failed + 1, event.stats.total, event.taskstring)) 748 logger.info("Running setscene task %d of %d (%s)" % (event.stats.setscene_covered + event.stats.setscene_active + event.stats.setscene_notcovered + 1, event.stats.setscene_total, event.taskstring))
749 continue 749 continue
750 750
751 if isinstance(event, bb.runqueue.runQueueTaskStarted): 751 if isinstance(event, bb.runqueue.runQueueTaskStarted):
diff --git a/bitbake/lib/bb/ui/uihelper.py b/bitbake/lib/bb/ui/uihelper.py
index 40c7c5a5ef..52fdae3fec 100644
--- a/bitbake/lib/bb/ui/uihelper.py
+++ b/bitbake/lib/bb/ui/uihelper.py
@@ -50,7 +50,7 @@ class BBUIHelper:
50 removetid(event.pid, tid) 50 removetid(event.pid, tid)
51 self.failed_tasks.append( { 'title' : "%s %s" % (event._package, event._task)}) 51 self.failed_tasks.append( { 'title' : "%s %s" % (event._package, event._task)})
52 elif isinstance(event, bb.runqueue.runQueueTaskStarted) or isinstance(event, bb.runqueue.sceneQueueTaskStarted): 52 elif isinstance(event, bb.runqueue.runQueueTaskStarted) or isinstance(event, bb.runqueue.sceneQueueTaskStarted):
53 self.tasknumber_current = event.stats.completed + event.stats.active + event.stats.failed + 1 53 self.tasknumber_current = event.stats.completed + event.stats.active + event.stats.failed + event.stats.setscene_active + 1
54 self.tasknumber_total = event.stats.total 54 self.tasknumber_total = event.stats.total
55 self.needUpdate = True 55 self.needUpdate = True
56 elif isinstance(event, bb.build.TaskProgress): 56 elif isinstance(event, bb.build.TaskProgress):