summaryrefslogtreecommitdiffstats
path: root/bitbake/bin
diff options
context:
space:
mode:
Diffstat (limited to 'bitbake/bin')
-rwxr-xr-xbitbake/bin/bitbake-worker6
1 files changed, 6 insertions, 0 deletions
diff --git a/bitbake/bin/bitbake-worker b/bitbake/bin/bitbake-worker
index f63f060c57..3e502d5ca9 100755
--- a/bitbake/bin/bitbake-worker
+++ b/bitbake/bin/bitbake-worker
@@ -234,6 +234,8 @@ def fork_off_task(cfg, data, databuilder, workerdata, fn, task, taskname, taskha
234 the_data.setVar(varname, value) 234 the_data.setVar(varname, value)
235 235
236 bb.parse.siggen.set_taskdata(workerdata["sigdata"]) 236 bb.parse.siggen.set_taskdata(workerdata["sigdata"])
237 if "newhashes" in workerdata:
238 bb.parse.siggen.set_taskhashes(workerdata["newhashes"])
237 ret = 0 239 ret = 0
238 240
239 the_data = bb_cache.loadDataFull(fn, appends) 241 the_data = bb_cache.loadDataFull(fn, appends)
@@ -377,6 +379,7 @@ class BitbakeWorker(object):
377 self.handle_item(b"cookerconfig", self.handle_cookercfg) 379 self.handle_item(b"cookerconfig", self.handle_cookercfg)
378 self.handle_item(b"extraconfigdata", self.handle_extraconfigdata) 380 self.handle_item(b"extraconfigdata", self.handle_extraconfigdata)
379 self.handle_item(b"workerdata", self.handle_workerdata) 381 self.handle_item(b"workerdata", self.handle_workerdata)
382 self.handle_item(b"newtaskhashes", self.handle_newtaskhashes)
380 self.handle_item(b"runtask", self.handle_runtask) 383 self.handle_item(b"runtask", self.handle_runtask)
381 self.handle_item(b"finishnow", self.handle_finishnow) 384 self.handle_item(b"finishnow", self.handle_finishnow)
382 self.handle_item(b"ping", self.handle_ping) 385 self.handle_item(b"ping", self.handle_ping)
@@ -416,6 +419,9 @@ class BitbakeWorker(object):
416 for mc in self.databuilder.mcdata: 419 for mc in self.databuilder.mcdata:
417 self.databuilder.mcdata[mc].setVar("PRSERV_HOST", self.workerdata["prhost"]) 420 self.databuilder.mcdata[mc].setVar("PRSERV_HOST", self.workerdata["prhost"])
418 421
422 def handle_newtaskhashes(self, data):
423 self.workerdata["newhashes"] = pickle.loads(data)
424
419 def handle_ping(self, _): 425 def handle_ping(self, _):
420 workerlog_write("Handling ping\n") 426 workerlog_write("Handling ping\n")
421 427