summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorAlexandru DAMIAN <alexandru.damian@intel.com>2013-09-16 12:46:01 +0000
committerRichard Purdie <richard.purdie@linuxfoundation.org>2013-09-17 14:11:02 +0100
commita828c898228292c238e42e20d7e254a3f9847082 (patch)
treeb566d780479d10bf25d2a4ce0a3a3071a993f472
parent1181e691197ab223e325546185d0a991e5ccbf1c (diff)
downloadpoky-a828c898228292c238e42e20d7e254a3f9847082.tar.gz
bitbake: runqueue: add runQueueTaskSkipped event
Adding a runQueueTaskSkipped to notify that the tasks that are not run either because they are set-scened or they don't need an update (timestamp was ok). (Bitbake rev: cf4a0c7aa82090876ae652b611acfab3ce2688f7) Signed-off-by: Richard Purdie <richard.purdie@linuxfoundation.org>
-rw-r--r--bitbake/lib/bb/runqueue.py15
1 files changed, 12 insertions, 3 deletions
diff --git a/bitbake/lib/bb/runqueue.py b/bitbake/lib/bb/runqueue.py
index 25f1ab5ce5..6346c7711a 100644
--- a/bitbake/lib/bb/runqueue.py
+++ b/bitbake/lib/bb/runqueue.py
@@ -1325,9 +1325,10 @@ class RunQueueExecuteTasks(RunQueueExecute):
1325 if self.rqdata.taskData.abort: 1325 if self.rqdata.taskData.abort:
1326 self.rq.state = runQueueCleanUp 1326 self.rq.state = runQueueCleanUp
1327 1327
1328 def task_skip(self, task): 1328 def task_skip(self, task, reason):
1329 self.runq_running[task] = 1 1329 self.runq_running[task] = 1
1330 self.runq_buildable[task] = 1 1330 self.runq_buildable[task] = 1
1331 bb.event.fire(runQueueTaskSkipped(task, self.stats, self.rq, reason), self.cfgData)
1331 self.task_completeoutright(task) 1332 self.task_completeoutright(task)
1332 self.stats.taskCompleted() 1333 self.stats.taskCompleted()
1333 self.stats.taskSkipped() 1334 self.stats.taskSkipped()
@@ -1352,13 +1353,13 @@ class RunQueueExecuteTasks(RunQueueExecute):
1352 if task in self.rq.scenequeue_covered: 1353 if task in self.rq.scenequeue_covered:
1353 logger.debug(2, "Setscene covered task %s (%s)", task, 1354 logger.debug(2, "Setscene covered task %s (%s)", task,
1354 self.rqdata.get_user_idstring(task)) 1355 self.rqdata.get_user_idstring(task))
1355 self.task_skip(task) 1356 self.task_skip(task, "covered")
1356 return True 1357 return True
1357 1358
1358 if self.rq.check_stamp_task(task, taskname, cache=self.stampcache): 1359 if self.rq.check_stamp_task(task, taskname, cache=self.stampcache):
1359 logger.debug(2, "Stamp current task %s (%s)", task, 1360 logger.debug(2, "Stamp current task %s (%s)", task,
1360 self.rqdata.get_user_idstring(task)) 1361 self.rqdata.get_user_idstring(task))
1361 self.task_skip(task) 1362 self.task_skip(task, "existing")
1362 return True 1363 return True
1363 1364
1364 taskdep = self.rqdata.dataCache.task_deps[fn] 1365 taskdep = self.rqdata.dataCache.task_deps[fn]
@@ -1834,6 +1835,14 @@ class sceneQueueTaskCompleted(sceneQueueEvent):
1834 Event notifing a setscene task completed 1835 Event notifing a setscene task completed
1835 """ 1836 """
1836 1837
1838class runQueueTaskSkipped(runQueueEvent):
1839 """
1840 Event notifing a task was skipped
1841 """
1842 def __init__(self, task, stats, rq, reason):
1843 runQueueEvent.__init__(self, task, stats, rq)
1844 self.reason = reason
1845
1837class runQueuePipe(): 1846class runQueuePipe():
1838 """ 1847 """
1839 Abstraction for a pipe between a worker thread and the server 1848 Abstraction for a pipe between a worker thread and the server