sysmo-bts
/
generic-poky
9
0
Fork 0
Code Pull Requests Releases Activity

bitbake-dev: Include the worker's PID in events 

When the runqueue forks off we save the pid inside the event module for that
thread. When we next fire an event then that PID gets included in the events.
This commit is contained in:
Rob Bradford 2008-10-21 15:33:38 +01:00
parent e1155bcd79
commit f51afdc7b6
2 changed files with 15 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
bitbake-dev/lib/bb/event.py
View File

@ -25,12 +25,17 @@ BitBake build tools.
import os, re
import bb.utils
# This is the pid for which we should generate the event. This is set when
# the runqueue forks off.
worker_pid = 0
class Event:
"""Base class for events"""
type = "Event"
def __init__(self, d):
self._data = d
self.pid = worker_pid
def getData(self):
return self._data

12
bitbake-dev/lib/bb/runqueue.py
View File

@ -971,8 +971,6 @@ class RunQueue:
self.stats.taskSkipped()
continue
bb.event.fire(runQueueTaskStarted(task, self.stats, self, self.cfgData))
bb.msg.note(1, bb.msg.domain.RunQueue, "Running task %d of %d (ID: %s, %s)" % (self.stats.completed + self.stats.active + 1, self.stats.total, task, self.get_user_idstring(task)))
sys.stdout.flush()
sys.stderr.flush()
try:
@ -980,6 +978,16 @@ class RunQueue:
except OSError, e:
bb.msg.fatal(bb.msg.domain.RunQueue, "fork failed: %d (%s)" % (e.errno, e.strerror))
if pid == 0:
# Save out the PID so that the event can include it the
# events
bb.event.worker_pid = os.getpid()
bb.event.fire(runQueueTaskStarted(task, self.stats, self, self.cfgData))
bb.msg.note(1, bb.msg.domain.RunQueue,
"Running task %d of %d (ID: %s, %s)" % (self.stats.completed + self.stats.active + 1,
self.stats.total,
task,
self.get_user_idstring(task)))
self.state = runQueueChildProcess
# Make the child the process group leader
os.setpgid(0, 0)