diff options
Diffstat (limited to 'bitbake/lib/bb/runqueue.py')
-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") |