summaryrefslogtreecommitdiffstats
path: root/bitbake/lib/bb/runqueue.py
diff options
context:
space:
mode:
Diffstat (limited to 'bitbake/lib/bb/runqueue.py')
-rw-r--r--bitbake/lib/bb/runqueue.py22
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")