diff options
Diffstat (limited to 'bitbake/bin/bitbake-worker')
-rwxr-xr-x | bitbake/bin/bitbake-worker | 6 |
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 | ||