diff options
Diffstat (limited to 'bitbake/lib/bb/runqueue.py')
-rw-r--r-- | bitbake/lib/bb/runqueue.py | 32 |
1 files changed, 16 insertions, 16 deletions
diff --git a/bitbake/lib/bb/runqueue.py b/bitbake/lib/bb/runqueue.py index 80f3d3282f..f37a0a7062 100644 --- a/bitbake/lib/bb/runqueue.py +++ b/bitbake/lib/bb/runqueue.py | |||
@@ -678,7 +678,7 @@ class RunQueueData: | |||
678 | 678 | ||
679 | self.init_progress_reporter.start() | 679 | self.init_progress_reporter.start() |
680 | self.init_progress_reporter.next_stage() | 680 | self.init_progress_reporter.next_stage() |
681 | bb.event.check_for_interrupts(self.cooker.data) | 681 | bb.event.check_for_interrupts() |
682 | 682 | ||
683 | # Step A - Work out a list of tasks to run | 683 | # Step A - Work out a list of tasks to run |
684 | # | 684 | # |
@@ -829,7 +829,7 @@ class RunQueueData: | |||
829 | #self.dump_data() | 829 | #self.dump_data() |
830 | 830 | ||
831 | self.init_progress_reporter.next_stage() | 831 | self.init_progress_reporter.next_stage() |
832 | bb.event.check_for_interrupts(self.cooker.data) | 832 | bb.event.check_for_interrupts() |
833 | 833 | ||
834 | # Resolve recursive 'recrdeptask' dependencies (Part B) | 834 | # Resolve recursive 'recrdeptask' dependencies (Part B) |
835 | # | 835 | # |
@@ -926,7 +926,7 @@ class RunQueueData: | |||
926 | self.runtaskentries[tid].depends.difference_update(recursivetasksselfref) | 926 | self.runtaskentries[tid].depends.difference_update(recursivetasksselfref) |
927 | 927 | ||
928 | self.init_progress_reporter.next_stage() | 928 | self.init_progress_reporter.next_stage() |
929 | bb.event.check_for_interrupts(self.cooker.data) | 929 | bb.event.check_for_interrupts() |
930 | 930 | ||
931 | #self.dump_data() | 931 | #self.dump_data() |
932 | 932 | ||
@@ -1008,7 +1008,7 @@ class RunQueueData: | |||
1008 | mark_active(tid, 1) | 1008 | mark_active(tid, 1) |
1009 | 1009 | ||
1010 | self.init_progress_reporter.next_stage() | 1010 | self.init_progress_reporter.next_stage() |
1011 | bb.event.check_for_interrupts(self.cooker.data) | 1011 | bb.event.check_for_interrupts() |
1012 | 1012 | ||
1013 | # Step C - Prune all inactive tasks | 1013 | # Step C - Prune all inactive tasks |
1014 | # | 1014 | # |
@@ -1055,7 +1055,7 @@ class RunQueueData: | |||
1055 | bb.msg.fatal("RunQueue", "Could not find any tasks with the tasknames %s to run within the recipes of the taskgraphs of the targets %s" % (str(self.cooker.configuration.runall), str(self.targets))) | 1055 | bb.msg.fatal("RunQueue", "Could not find any tasks with the tasknames %s to run within the recipes of the taskgraphs of the targets %s" % (str(self.cooker.configuration.runall), str(self.targets))) |
1056 | 1056 | ||
1057 | self.init_progress_reporter.next_stage() | 1057 | self.init_progress_reporter.next_stage() |
1058 | bb.event.check_for_interrupts(self.cooker.data) | 1058 | bb.event.check_for_interrupts() |
1059 | 1059 | ||
1060 | # Handle runonly | 1060 | # Handle runonly |
1061 | if self.cooker.configuration.runonly: | 1061 | if self.cooker.configuration.runonly: |
@@ -1096,7 +1096,7 @@ class RunQueueData: | |||
1096 | logger.verbose("Assign Weightings") | 1096 | logger.verbose("Assign Weightings") |
1097 | 1097 | ||
1098 | self.init_progress_reporter.next_stage() | 1098 | self.init_progress_reporter.next_stage() |
1099 | bb.event.check_for_interrupts(self.cooker.data) | 1099 | bb.event.check_for_interrupts() |
1100 | 1100 | ||
1101 | # Generate a list of reverse dependencies to ease future calculations | 1101 | # Generate a list of reverse dependencies to ease future calculations |
1102 | for tid in self.runtaskentries: | 1102 | for tid in self.runtaskentries: |
@@ -1104,7 +1104,7 @@ class RunQueueData: | |||
1104 | self.runtaskentries[dep].revdeps.add(tid) | 1104 | self.runtaskentries[dep].revdeps.add(tid) |
1105 | 1105 | ||
1106 | self.init_progress_reporter.next_stage() | 1106 | self.init_progress_reporter.next_stage() |
1107 | bb.event.check_for_interrupts(self.cooker.data) | 1107 | bb.event.check_for_interrupts() |
1108 | 1108 | ||
1109 | # Identify tasks at the end of dependency chains | 1109 | # Identify tasks at the end of dependency chains |
1110 | # Error on circular dependency loops (length two) | 1110 | # Error on circular dependency loops (length two) |
@@ -1121,14 +1121,14 @@ class RunQueueData: | |||
1121 | logger.verbose("Compute totals (have %s endpoint(s))", len(endpoints)) | 1121 | logger.verbose("Compute totals (have %s endpoint(s))", len(endpoints)) |
1122 | 1122 | ||
1123 | self.init_progress_reporter.next_stage() | 1123 | self.init_progress_reporter.next_stage() |
1124 | bb.event.check_for_interrupts(self.cooker.data) | 1124 | bb.event.check_for_interrupts() |
1125 | 1125 | ||
1126 | # Calculate task weights | 1126 | # Calculate task weights |
1127 | # Check of higher length circular dependencies | 1127 | # Check of higher length circular dependencies |
1128 | self.runq_weight = self.calculate_task_weights(endpoints) | 1128 | self.runq_weight = self.calculate_task_weights(endpoints) |
1129 | 1129 | ||
1130 | self.init_progress_reporter.next_stage() | 1130 | self.init_progress_reporter.next_stage() |
1131 | bb.event.check_for_interrupts(self.cooker.data) | 1131 | bb.event.check_for_interrupts() |
1132 | 1132 | ||
1133 | # Sanity Check - Check for multiple tasks building the same provider | 1133 | # Sanity Check - Check for multiple tasks building the same provider |
1134 | for mc in self.dataCaches: | 1134 | for mc in self.dataCaches: |
@@ -1229,7 +1229,7 @@ class RunQueueData: | |||
1229 | 1229 | ||
1230 | self.init_progress_reporter.next_stage() | 1230 | self.init_progress_reporter.next_stage() |
1231 | self.init_progress_reporter.next_stage() | 1231 | self.init_progress_reporter.next_stage() |
1232 | bb.event.check_for_interrupts(self.cooker.data) | 1232 | bb.event.check_for_interrupts() |
1233 | 1233 | ||
1234 | # Iterate over the task list looking for tasks with a 'setscene' function | 1234 | # Iterate over the task list looking for tasks with a 'setscene' function |
1235 | self.runq_setscene_tids = set() | 1235 | self.runq_setscene_tids = set() |
@@ -1242,7 +1242,7 @@ class RunQueueData: | |||
1242 | self.runq_setscene_tids.add(tid) | 1242 | self.runq_setscene_tids.add(tid) |
1243 | 1243 | ||
1244 | self.init_progress_reporter.next_stage() | 1244 | self.init_progress_reporter.next_stage() |
1245 | bb.event.check_for_interrupts(self.cooker.data) | 1245 | bb.event.check_for_interrupts() |
1246 | 1246 | ||
1247 | # Invalidate task if force mode active | 1247 | # Invalidate task if force mode active |
1248 | if self.cooker.configuration.force: | 1248 | if self.cooker.configuration.force: |
@@ -1259,7 +1259,7 @@ class RunQueueData: | |||
1259 | invalidate_task(fn + ":" + st, True) | 1259 | invalidate_task(fn + ":" + st, True) |
1260 | 1260 | ||
1261 | self.init_progress_reporter.next_stage() | 1261 | self.init_progress_reporter.next_stage() |
1262 | bb.event.check_for_interrupts(self.cooker.data) | 1262 | bb.event.check_for_interrupts() |
1263 | 1263 | ||
1264 | # Create and print to the logs a virtual/xxxx -> PN (fn) table | 1264 | # Create and print to the logs a virtual/xxxx -> PN (fn) table |
1265 | for mc in taskData: | 1265 | for mc in taskData: |
@@ -1272,7 +1272,7 @@ class RunQueueData: | |||
1272 | bb.parse.siggen.tasks_resolved(virtmap, virtpnmap, self.dataCaches[mc]) | 1272 | bb.parse.siggen.tasks_resolved(virtmap, virtpnmap, self.dataCaches[mc]) |
1273 | 1273 | ||
1274 | self.init_progress_reporter.next_stage() | 1274 | self.init_progress_reporter.next_stage() |
1275 | bb.event.check_for_interrupts(self.cooker.data) | 1275 | bb.event.check_for_interrupts() |
1276 | 1276 | ||
1277 | bb.parse.siggen.set_setscene_tasks(self.runq_setscene_tids) | 1277 | bb.parse.siggen.set_setscene_tasks(self.runq_setscene_tids) |
1278 | 1278 | ||
@@ -1296,7 +1296,7 @@ class RunQueueData: | |||
1296 | todeal.remove(tid) | 1296 | todeal.remove(tid) |
1297 | self.runtaskentries[tid].unihash = unihashes[tid] | 1297 | self.runtaskentries[tid].unihash = unihashes[tid] |
1298 | 1298 | ||
1299 | bb.event.check_for_interrupts(self.cooker.data) | 1299 | bb.event.check_for_interrupts() |
1300 | 1300 | ||
1301 | if time.time() > (lasttime + 30): | 1301 | if time.time() > (lasttime + 30): |
1302 | lasttime = time.time() | 1302 | lasttime = time.time() |
@@ -1555,7 +1555,7 @@ class RunQueue: | |||
1555 | """ | 1555 | """ |
1556 | 1556 | ||
1557 | retval = True | 1557 | retval = True |
1558 | bb.event.check_for_interrupts(self.cooker.data) | 1558 | bb.event.check_for_interrupts() |
1559 | 1559 | ||
1560 | if self.state is runQueuePrepare: | 1560 | if self.state is runQueuePrepare: |
1561 | # NOTE: if you add, remove or significantly refactor the stages of this | 1561 | # NOTE: if you add, remove or significantly refactor the stages of this |
@@ -2638,7 +2638,7 @@ class RunQueueExecute: | |||
2638 | next |= self.rqdata.runtaskentries[tid].revdeps | 2638 | next |= self.rqdata.runtaskentries[tid].revdeps |
2639 | total.remove(tid) | 2639 | total.remove(tid) |
2640 | next.intersection_update(total) | 2640 | next.intersection_update(total) |
2641 | bb.event.check_for_interrupts(self.cooker.data) | 2641 | bb.event.check_for_interrupts() |
2642 | 2642 | ||
2643 | if time.time() > (lasttime + 30): | 2643 | if time.time() > (lasttime + 30): |
2644 | lasttime = time.time() | 2644 | lasttime = time.time() |