diff options
author | Alexandru DAMIAN <alexandru.damian@intel.com> | 2013-09-16 12:46:01 +0000 |
---|---|---|
committer | Richard Purdie <richard.purdie@linuxfoundation.org> | 2013-09-17 14:11:02 +0100 |
commit | a828c898228292c238e42e20d7e254a3f9847082 (patch) | |
tree | b566d780479d10bf25d2a4ce0a3a3071a993f472 | |
parent | 1181e691197ab223e325546185d0a991e5ccbf1c (diff) | |
download | poky-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.py | 15 |
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 | ||
1838 | class 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 | |||
1837 | class runQueuePipe(): | 1846 | class 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 |