]> code.ossystems Code Review - openembedded-core.git/commitdiff
bitbake: Transfer noexec runqueue messages to the UI
authorRichard Purdie <rpurdie@linux.intel.com>
Sat, 1 Jan 2011 14:36:38 +0000 (14:36 +0000)
committerRichard Purdie <rpurdie@linux.intel.com>
Tue, 4 Jan 2011 14:46:49 +0000 (14:46 +0000)
Signed-off-by: Richard Purdie <rpurdie@linux.intel.com>
bitbake/lib/bb/runqueue.py
bitbake/lib/bb/ui/knotty.py

index 7f292290b222315accf1a00edb6551ea9ad2be3a..d4cea7d5d419967cf1ae40e7cdb7f74f25b01482 100644 (file)
@@ -1295,15 +1295,16 @@ class RunQueueExecuteTasks(RunQueueExecute):
 
             taskdep = self.rqdata.dataCache.task_deps[fn]
             if 'noexec' in taskdep and taskname in taskdep['noexec']:
-                logger.info("Noexec task %d of %d (ID: %s, %s)" % (self.stats.completed + self.stats.active + self.stats.failed + 1,
-                                                                self.stats.total,
-                                                                task,
-                                                                self.rqdata.get_user_idstring(task)))
+                startevent = runQueueTaskStarted(task, self.stats, self.rq, noexec=True)
+                bb.event.fire(startevent, self.cfgData)
                 self.runq_running[task] = 1
                 self.stats.taskActive()
                 bb.build.make_stamp(taskname, self.rqdata.dataCache, fn)
                 self.task_complete(task)
                 return True
+            else:
+                startevent = runQueueTaskStarted(task, self.stats, self.rq)
+                bb.event.fire(startevent, self.cfgData)
 
             pid, pipein, pipeout = self.fork_off_task(fn, task, taskname)
 
@@ -1610,9 +1611,9 @@ class runQueueTaskStarted(runQueueEvent):
     """
     Event notifing a task was started
     """
-    def __init__(self, task, stats, rq):
+    def __init__(self, task, stats, rq, noexec=False):
         runQueueEvent.__init__(self, task, stats, rq)
-        self.message = "Running task %s (%d of %d) (%s)" % (task, stats.completed + stats.active + 1, self.stats.total, self.taskstring)
+        self.noexec = noexec
 
 class runQueueTaskFailed(runQueueEvent):
     """
@@ -1621,15 +1622,11 @@ class runQueueTaskFailed(runQueueEvent):
     def __init__(self, task, stats, exitcode, rq):
         runQueueEvent.__init__(self, task, stats, rq)
         self.exitcode = exitcode
-        self.message = "Task %s failed (%s)" % (task, self.taskstring)
 
 class runQueueTaskCompleted(runQueueEvent):
     """
     Event notifing a task completed
     """
-    def __init__(self, task, stats, rq):
-        runQueueEvent.__init__(self, task, stats, rq)
-        self.message = "Task %s completed (%s)" % (task, self.taskstring)
 
 #def check_stamp_fn(fn, taskname, d):
 #    rq = bb.data.getVar("__RUNQUEUE_DO_NOT_USE_EXTERNALLY", d)
index b97c5a1b5e2db2707ecd7fba15e2fa5aa5a0b6a2..9f3ec41b5c6938cddb2213eed5acdfd4f9f1e6a7 100644 (file)
@@ -193,9 +193,16 @@ def main(server, eventHandler):
                 continue
 
             if isinstance(event, bb.runqueue.runQueueTaskStarted):
-                logger.info("Running task %s of %s (ID: %s, %s)",
-                            event.stats.completed + event.stats.active + event.stats.failed + 1,
+                if event.noexec:
+                    tasktype = 'noexec task'
+                else:
+                    tasktype = 'task'
+                logger.info("Running %s %s of %s (ID: %s, %s)",
+                            tasktype,
+                            event.stats.completed + event.stats.active +
+                                event.stats.failed + 1,
                             event.stats.total, event.taskid, event.taskstring)
+
                 continue
 
             if isinstance(event, bb.runqueue.runQueueTaskFailed):