mirrors/poky
1
0
Fork 0
mirror of https://git.yoctoproject.org/poky synced 2026-09-16 00:49:32 +02:00
Code Issues Packages Projects Releases Wiki Activity

bitbake: event/runqueue: remove unused 'd' arg from check_for_interrupts

Browse Source 
(Bitbake rev: e0c5e94cc14dd6b1cbde491073c1f9407c97e428)

Signed-off-by: Chris Laplante <chris.laplante@agilent.com>
Signed-off-by: Richard Purdie <richard.purdie@linuxfoundation.org>
This commit is contained in:
Chris Laplante
2025-08-06 10:53:07 -04:00
committed by Richard Purdie
parent b25ebbc408
commit f4a8ddd6c8
2 changed files with 17 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
bitbake/lib/bb/event.py
View File

@@ -90,7 +90,7 @@ def disable_heartbeat():
# In long running code, this function should be called periodically # In long running code, this function should be called periodically
# to check if we should exit due to an interuption (.e.g Ctrl+C from the UI) # to check if we should exit due to an interuption (.e.g Ctrl+C from the UI)
# #
def check_for_interrupts(d): def check_for_interrupts():
global _should_exit global _should_exit
if _should_exit.is_set(): if _should_exit.is_set():
bb.warn("Exiting due to interrupt.") bb.warn("Exiting due to interrupt.")

32
bitbake/lib/bb/runqueue.py
View File

@@ -678,7 +678,7 @@ class RunQueueData:
self.init_progress_reporter.start() self.init_progress_reporter.start()
self.init_progress_reporter.next_stage() self.init_progress_reporter.next_stage()
bb.event.check_for_interrupts(self.cooker.data) bb.event.check_for_interrupts()
# Step A - Work out a list of tasks to run # Step A - Work out a list of tasks to run
# #
@@ -829,7 +829,7 @@ class RunQueueData:
#self.dump_data() #self.dump_data()
self.init_progress_reporter.next_stage() self.init_progress_reporter.next_stage()
bb.event.check_for_interrupts(self.cooker.data) bb.event.check_for_interrupts()
# Resolve recursive 'recrdeptask' dependencies (Part B) # Resolve recursive 'recrdeptask' dependencies (Part B)
# #
@@ -926,7 +926,7 @@ class RunQueueData:
self.runtaskentries[tid].depends.difference_update(recursivetasksselfref) self.runtaskentries[tid].depends.difference_update(recursivetasksselfref)
self.init_progress_reporter.next_stage() self.init_progress_reporter.next_stage()
bb.event.check_for_interrupts(self.cooker.data) bb.event.check_for_interrupts()
#self.dump_data() #self.dump_data()
@@ -1008,7 +1008,7 @@ class RunQueueData:
mark_active(tid, 1) mark_active(tid, 1)
self.init_progress_reporter.next_stage() self.init_progress_reporter.next_stage()
bb.event.check_for_interrupts(self.cooker.data) bb.event.check_for_interrupts()
# Step C - Prune all inactive tasks # Step C - Prune all inactive tasks
# #
@@ -1055,7 +1055,7 @@ class RunQueueData:
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))) 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)))
self.init_progress_reporter.next_stage() self.init_progress_reporter.next_stage()
bb.event.check_for_interrupts(self.cooker.data) bb.event.check_for_interrupts()
# Handle runonly # Handle runonly
if self.cooker.configuration.runonly: if self.cooker.configuration.runonly:
@@ -1096,7 +1096,7 @@ class RunQueueData:
logger.verbose("Assign Weightings") logger.verbose("Assign Weightings")
self.init_progress_reporter.next_stage() self.init_progress_reporter.next_stage()
bb.event.check_for_interrupts(self.cooker.data) bb.event.check_for_interrupts()
# Generate a list of reverse dependencies to ease future calculations # Generate a list of reverse dependencies to ease future calculations
for tid in self.runtaskentries: for tid in self.runtaskentries:
@@ -1104,7 +1104,7 @@ class RunQueueData:
self.runtaskentries[dep].revdeps.add(tid) self.runtaskentries[dep].revdeps.add(tid)
self.init_progress_reporter.next_stage() self.init_progress_reporter.next_stage()
bb.event.check_for_interrupts(self.cooker.data) bb.event.check_for_interrupts()
# Identify tasks at the end of dependency chains # Identify tasks at the end of dependency chains
# Error on circular dependency loops (length two) # Error on circular dependency loops (length two)
@@ -1121,14 +1121,14 @@ class RunQueueData:
logger.verbose("Compute totals (have %s endpoint(s))", len(endpoints)) logger.verbose("Compute totals (have %s endpoint(s))", len(endpoints))
self.init_progress_reporter.next_stage() self.init_progress_reporter.next_stage()
bb.event.check_for_interrupts(self.cooker.data) bb.event.check_for_interrupts()
# Calculate task weights # Calculate task weights
# Check of higher length circular dependencies # Check of higher length circular dependencies
self.runq_weight = self.calculate_task_weights(endpoints) self.runq_weight = self.calculate_task_weights(endpoints)
self.init_progress_reporter.next_stage() self.init_progress_reporter.next_stage()
bb.event.check_for_interrupts(self.cooker.data) bb.event.check_for_interrupts()
# Sanity Check - Check for multiple tasks building the same provider # Sanity Check - Check for multiple tasks building the same provider
for mc in self.dataCaches: for mc in self.dataCaches:
@@ -1229,7 +1229,7 @@ class RunQueueData:
self.init_progress_reporter.next_stage() self.init_progress_reporter.next_stage()
self.init_progress_reporter.next_stage() self.init_progress_reporter.next_stage()
bb.event.check_for_interrupts(self.cooker.data) bb.event.check_for_interrupts()
# Iterate over the task list looking for tasks with a 'setscene' function # Iterate over the task list looking for tasks with a 'setscene' function
self.runq_setscene_tids = set() self.runq_setscene_tids = set()
@@ -1242,7 +1242,7 @@ class RunQueueData:
self.runq_setscene_tids.add(tid) self.runq_setscene_tids.add(tid)
self.init_progress_reporter.next_stage() self.init_progress_reporter.next_stage()
bb.event.check_for_interrupts(self.cooker.data) bb.event.check_for_interrupts()
# Invalidate task if force mode active # Invalidate task if force mode active
if self.cooker.configuration.force: if self.cooker.configuration.force:
@@ -1259,7 +1259,7 @@ class RunQueueData:
invalidate_task(fn + ":" + st, True) invalidate_task(fn + ":" + st, True)
self.init_progress_reporter.next_stage() self.init_progress_reporter.next_stage()
bb.event.check_for_interrupts(self.cooker.data) bb.event.check_for_interrupts()
# Create and print to the logs a virtual/xxxx -> PN (fn) table # Create and print to the logs a virtual/xxxx -> PN (fn) table
for mc in taskData: for mc in taskData:
@@ -1272,7 +1272,7 @@ class RunQueueData:
bb.parse.siggen.tasks_resolved(virtmap, virtpnmap, self.dataCaches[mc]) bb.parse.siggen.tasks_resolved(virtmap, virtpnmap, self.dataCaches[mc])
self.init_progress_reporter.next_stage() self.init_progress_reporter.next_stage()
bb.event.check_for_interrupts(self.cooker.data) bb.event.check_for_interrupts()
bb.parse.siggen.set_setscene_tasks(self.runq_setscene_tids) bb.parse.siggen.set_setscene_tasks(self.runq_setscene_tids)
@@ -1296,7 +1296,7 @@ class RunQueueData:
todeal.remove(tid) todeal.remove(tid)
self.runtaskentries[tid].unihash = unihashes[tid] self.runtaskentries[tid].unihash = unihashes[tid]
bb.event.check_for_interrupts(self.cooker.data) bb.event.check_for_interrupts()
if time.time() > (lasttime + 30): if time.time() > (lasttime + 30):
lasttime = time.time() lasttime = time.time()
@@ -1555,7 +1555,7 @@ class RunQueue:
""" """
retval = True retval = True
bb.event.check_for_interrupts(self.cooker.data) bb.event.check_for_interrupts()
if self.state is runQueuePrepare: if self.state is runQueuePrepare:
# NOTE: if you add, remove or significantly refactor the stages of this # NOTE: if you add, remove or significantly refactor the stages of this
@@ -2638,7 +2638,7 @@ class RunQueueExecute:
next |= self.rqdata.runtaskentries[tid].revdeps next |= self.rqdata.runtaskentries[tid].revdeps
total.remove(tid) total.remove(tid)
next.intersection_update(total) next.intersection_update(total)
bb.event.check_for_interrupts(self.cooker.data) bb.event.check_for_interrupts()
if time.time() > (lasttime + 30): if time.time() > (lasttime + 30):
lasttime = time.time() lasttime = time.time()