diff options
| -rw-r--r-- | bitbake/lib/bb/runqueue.py | 22 |
1 files changed, 22 insertions, 0 deletions
diff --git a/bitbake/lib/bb/runqueue.py b/bitbake/lib/bb/runqueue.py index bc7e18175d..beec1e0465 100644 --- a/bitbake/lib/bb/runqueue.py +++ b/bitbake/lib/bb/runqueue.py | |||
| @@ -1273,6 +1273,9 @@ class RunQueueData: | |||
| 1273 | 1273 | ||
| 1274 | bb.parse.siggen.set_setscene_tasks(self.runq_setscene_tids) | 1274 | bb.parse.siggen.set_setscene_tasks(self.runq_setscene_tids) |
| 1275 | 1275 | ||
| 1276 | starttime = time.time() | ||
| 1277 | lasttime = starttime | ||
| 1278 | |||
| 1276 | # Iterate over the task list and call into the siggen code | 1279 | # Iterate over the task list and call into the siggen code |
| 1277 | dealtwith = set() | 1280 | dealtwith = set() |
| 1278 | todeal = set(self.runtaskentries) | 1281 | todeal = set(self.runtaskentries) |
| @@ -1284,6 +1287,14 @@ class RunQueueData: | |||
| 1284 | self.prepare_task_hash(tid) | 1287 | self.prepare_task_hash(tid) |
| 1285 | bb.event.check_for_interrupts(self.cooker.data) | 1288 | bb.event.check_for_interrupts(self.cooker.data) |
| 1286 | 1289 | ||
| 1290 | if time.time() > (lasttime + 30): | ||
| 1291 | lasttime = time.time() | ||
| 1292 | hashequiv_logger.verbose("Initial setup loop progress: %s of %s in %s" % (len(todeal), len(self.runtaskentries), lasttime - starttime)) | ||
| 1293 | |||
| 1294 | endtime = time.time() | ||
| 1295 | if (endtime-starttime > 60): | ||
| 1296 | hashequiv_logger.verbose("Initial setup loop took: %s" % (endtime-starttime)) | ||
| 1297 | |||
| 1287 | bb.parse.siggen.writeout_file_checksum_cache() | 1298 | bb.parse.siggen.writeout_file_checksum_cache() |
| 1288 | 1299 | ||
| 1289 | #self.dump_data() | 1300 | #self.dump_data() |
| @@ -2556,6 +2567,9 @@ class RunQueueExecute: | |||
| 2556 | elif self.rqdata.runtaskentries[p].depends.isdisjoint(total): | 2567 | elif self.rqdata.runtaskentries[p].depends.isdisjoint(total): |
| 2557 | next.add(p) | 2568 | next.add(p) |
| 2558 | 2569 | ||
| 2570 | starttime = time.time() | ||
| 2571 | lasttime = starttime | ||
| 2572 | |||
| 2559 | # When an item doesn't have dependencies in total, we can process it. Drop items from total when handled | 2573 | # When an item doesn't have dependencies in total, we can process it. Drop items from total when handled |
| 2560 | while next: | 2574 | while next: |
| 2561 | current = next.copy() | 2575 | current = next.copy() |
| @@ -2588,6 +2602,14 @@ class RunQueueExecute: | |||
| 2588 | total.remove(tid) | 2602 | total.remove(tid) |
| 2589 | next.intersection_update(total) | 2603 | next.intersection_update(total) |
| 2590 | 2604 | ||
| 2605 | if time.time() > (lasttime + 30): | ||
| 2606 | lasttime = time.time() | ||
| 2607 | hashequiv_logger.verbose("Rehash loop slow progress: %s in %s" % (len(total), lasttime - starttime)) | ||
| 2608 | |||
| 2609 | endtime = time.time() | ||
| 2610 | if (endtime-starttime > 60): | ||
| 2611 | hashequiv_logger.verbose("Rehash loop took more than 60s: %s" % (endtime-starttime)) | ||
| 2612 | |||
| 2591 | if changed: | 2613 | if changed: |
| 2592 | for mc in self.rq.worker: | 2614 | for mc in self.rq.worker: |
| 2593 | RunQueue.send_pickled_data(self.rq.worker[mc].process, bb.parse.siggen.get_taskhashes(), "newtaskhashes") | 2615 | RunQueue.send_pickled_data(self.rq.worker[mc].process, bb.parse.siggen.get_taskhashes(), "newtaskhashes") |
