bitbake: Update event queue handling to match upstream bitbake
Signed-off-by: Richard Purdie <richard.purdie@linuxfoundation.org>
This commit is contained in:
parent
9336ba1fd2
commit
2c2d160c88
|
@ -129,13 +129,11 @@ def fire(event, d):
|
|||
def worker_fire(event, d):
|
||||
data = "<event>" + pickle.dumps(event) + "</event>"
|
||||
worker_pipe.write(data)
|
||||
worker_pipe.flush()
|
||||
|
||||
def fire_from_worker(event, d):
|
||||
if not event.startswith("<event>") or not event.endswith("</event>"):
|
||||
print("Error, not an event %s" % event)
|
||||
return
|
||||
#print "Got event %s" % event
|
||||
event = pickle.loads(event[7:-8])
|
||||
fire_ui_handlers(event, d)
|
||||
|
||||
|
|
|
@ -1083,10 +1083,9 @@ class RunQueueExecute:
|
|||
sys.stdout.flush()
|
||||
sys.stderr.flush()
|
||||
try:
|
||||
pipeinfd, pipeoutfd = os.pipe()
|
||||
pipein = os.fdopen(pipeinfd, 'rb', 4096)
|
||||
pipeout = os.fdopen(pipeoutfd, 'wb', 4096)
|
||||
|
||||
pipein, pipeout = os.pipe()
|
||||
pipein = os.fdopen(pipein, 'rb', 4096)
|
||||
pipeout = os.fdopen(pipeout, 'wb', 0)
|
||||
pid = os.fork()
|
||||
except OSError as e:
|
||||
bb.msg.fatal(bb.msg.domain.RunQueue, "fork failed: %d (%s)" % (e.errno, e.strerror))
|
||||
|
|
Loading…
Reference in New Issue