mirror of
https://git.yoctoproject.org/poky
synced 2026-04-26 00:32:12 +02:00
bitbake: runqueue.py: Minor cleanup for RunQueueStats and users
The RunQueueStats:taskCompleted and RunQueueStats:taskSkipped can take multiple arguments. However, nowehere in bitbake are multiple arguments used. Change this to match the behavior of the other APIs where it needs to be called once for each task. Additionally, these two functions were usually called in tandem, however in the wrong order. It really doesn't matter as there is no specific preemption point between the calls. But the taskSkipped should be called first to increment the 'active' count, and then taskCompleted called to decrement it. (Bitbake rev: 26d5ea9bb892bd6a2e1fd29a9023e0b0644edc16) Signed-off-by: Mark Hatle <mark.hatle@windriver.com> Signed-off-by: Richard Purdie <richard.purdie@linuxfoundation.org>
This commit is contained in:
committed by
Richard Purdie
parent
7838294271
commit
27101e647f
@@ -94,13 +94,13 @@ class RunQueueStats:
|
||||
self.active = self.active - 1
|
||||
self.failed = self.failed + 1
|
||||
|
||||
def taskCompleted(self, number = 1):
|
||||
self.active = self.active - number
|
||||
self.completed = self.completed + number
|
||||
def taskCompleted(self):
|
||||
self.active = self.active - 1
|
||||
self.completed = self.completed + 1
|
||||
|
||||
def taskSkipped(self, number = 1):
|
||||
self.active = self.active + number
|
||||
self.skipped = self.skipped + number
|
||||
def taskSkipped(self):
|
||||
self.active = self.active + 1
|
||||
self.skipped = self.skipped + 1
|
||||
|
||||
def taskActive(self):
|
||||
self.active = self.active + 1
|
||||
@@ -1896,8 +1896,8 @@ class RunQueueExecuteTasks(RunQueueExecute):
|
||||
self.setbuildable(task)
|
||||
bb.event.fire(runQueueTaskSkipped(task, self.stats, self.rq, reason), self.cfgData)
|
||||
self.task_completeoutright(task)
|
||||
self.stats.taskCompleted()
|
||||
self.stats.taskSkipped()
|
||||
self.stats.taskCompleted()
|
||||
|
||||
def execute(self):
|
||||
"""
|
||||
@@ -2342,8 +2342,8 @@ class RunQueueExecuteScenequeue(RunQueueExecute):
|
||||
def task_failoutright(self, task):
|
||||
self.runq_running.add(task)
|
||||
self.runq_buildable.add(task)
|
||||
self.stats.taskCompleted()
|
||||
self.stats.taskSkipped()
|
||||
self.stats.taskCompleted()
|
||||
self.scenequeue_notcovered.add(task)
|
||||
self.scenequeue_updatecounters(task, True)
|
||||
|
||||
@@ -2351,8 +2351,8 @@ class RunQueueExecuteScenequeue(RunQueueExecute):
|
||||
self.runq_running.add(task)
|
||||
self.runq_buildable.add(task)
|
||||
self.task_completeoutright(task)
|
||||
self.stats.taskCompleted()
|
||||
self.stats.taskSkipped()
|
||||
self.stats.taskCompleted()
|
||||
|
||||
def execute(self):
|
||||
"""
|
||||
|
||||
Reference in New Issue
Block a user