diff options
Diffstat (limited to 'bitbake/bin')
| -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 | ||
