lib/bb/runqueue.py

236 …           self.skip_maxthread[rtaskname] = self.rq.cfgData.getVarFlag(rtaskname, "number_threads")
436     def __init__(self, rq, cooker, cfgData, dataCaches, taskData, targets):  argument
444         self.multi_provider_allowed = (cfgData.getVar("BB_MULTI_PROVIDER_ALLOWED") or "").split()
445         self.setscene_ignore_tasks = get_setscene_enforce_ignore_tasks(cfgData, targets)
447         self.setscene_enforce = (cfgData.getVar('BB_SETSCENE_ENFORCE') == "1")
1268     def __init__(self, cooker, cfgData, dataCaches, taskData, targets):  argument
1271         self.cfgData = cfgData
1272         self.rqdata = RunQueueData(self, cooker, cfgData, dataCaches, taskData, targets)
1274         self.hashvalidate = cfgData.getVar("BB_HASHCHECK_FUNCTION") or None
1275         self.depvalidate = cfgData.getVar("BB_SETSCENE_DEPVALID") or None
1285         self.dm = monitordisk.diskMonitor(cfgData)
1311 …workerpipe = runQueuePipe(worker.stdout, None, self.cfgData, self, rqexec, fakerootlogs=fakerootlo…
1324             "buildname" : self.cfgData.getVar("BUILDNAME"),
1325             "date" : self.cfgData.getVar("DATE"),
1326             "time" : self.cfgData.getVar("TIME"),
1328             "umask" : self.cfgData.getVar("BB_DEFAULT_UMASK"),
1516                                          ('bb.event.HeartbeatEvent',), data=self.cfgData)
1555             bb.event.remove(self.dm_event_handler_name, None, data=self.cfgData)
1628         max_process = int(self.cfgData.getVar("BB_NUMBER_PARSE_THREADS") or os.cpu_count() or 1)
1717             hashfiles = bb.siggen.find_siginfo(key, None, hashes, self.cfgData)
1753         self.cfgData = rq.cfgData
1756         self.number_tasks = int(self.cfgData.getVar("BB_NUMBER_THREADS") or 1)
1757         self.scheduler = self.cfgData.getVar("BB_SCHEDULER") or "speed"
1758         self.max_cpu_pressure = self.cfgData.getVar("BB_PRESSURE_MAX_CPU")
1759         self.max_io_pressure = self.cfgData.getVar("BB_PRESSURE_MAX_IO")
1760         self.max_memory_pressure = self.cfgData.getVar("BB_PRESSURE_MAX_MEMORY")
1895             bb.event.fire(runQueueExitWait(active), self.cfgData)
1935         user_schedulers = self.cfgData.getVar("BB_SCHEDULERS")
1985         bb.event.fire(runQueueTaskCompleted(task, self.stats, self.rq), self.cfgData)
2012 …d(task, self.stats, exitcode, self.rq, fakeroot_log=("".join(fakeroot_log) or None)), self.cfgData)
2020         bb.event.fire(runQueueTaskSkipped(task, self.stats, self.rq, reason), self.cfgData)
2030             bb.event.fire(completeevent, self.cfgData)
2141             bb.event.fire(startevent, self.cfgData)
2213                 bb.event.fire(startevent, self.cfgData)
2222                 bb.event.fire(startevent, self.cfgData)
2604         bb.event.fire(sceneQueueTaskCompleted(task, self.stats, self.rq), self.cfgData)
2608         bb.event.fire(sceneQueueTaskFailed(task, self.stats, result, self), self.cfgData)