Lines Matching refs:rqdata
79 def pending_hash_index(tid, rqdata): argument
81 pn = rqdata.dataCaches[mc].pkg_fn[taskfn]
82 h = rqdata.runtaskentries[tid].unihash
142 def __init__(self, runqueue, rqdata): argument
148 self.rqdata = rqdata
149 self.numTasks = len(self.rqdata.runtaskentries)
151 self.prio_map = [self.rqdata.runtaskentries.keys()]
156 for tid in self.rqdata.runtaskentries:
158 … self.stamps[tid] = bb.build.stampfile(taskname, self.rqdata.dataCaches[mc], taskfn, noextra=True)
255 for tid in self.rqdata.runtaskentries:
306 def __init__(self, runqueue, rqdata): argument
310 RunQueueScheduler.__init__(self, runqueue, rqdata)
313 for tid in self.rqdata.runtaskentries:
314 weight = self.rqdata.runtaskentries[tid].weight
337 def __init__(self, runqueue, rqdata): argument
338 super(RunQueueSchedulerCompletion, self).__init__(runqueue, rqdata)
1272 self.rqdata = RunQueueData(self, cooker, cfgData, dataCaches, taskData, targets)
1307 fakerootlogs = self.rqdata.dataCaches[mc].fakerootlogs
1314 "taskdeps" : self.rqdata.dataCaches[mc].task_deps,
1315 "fakerootenv" : self.rqdata.dataCaches[mc].fakerootenv,
1316 "fakerootdirs" : self.rqdata.dataCaches[mc].fakerootdirs,
1317 "fakerootnoenv" : self.rqdata.dataCaches[mc].fakerootnoenv,
1359 for mc in self.rqdata.dataCaches:
1402 stampfile = bb.build.stampfile(taskname, self.rqdata.dataCaches[mc], taskfn)
1409 taskdep = self.rqdata.dataCaches[mc].task_deps[taskfn]
1422 for dep in self.rqdata.runtaskentries[tid].depends:
1425 stampfile2 = bb.build.stampfile(taskname2, self.rqdata.dataCaches[mc2], taskfn2)
1426 … stampfile3 = bb.build.stampfile(taskname2 + "_setscene", self.rqdata.dataCaches[mc2], taskfn2)
1463 sq_data['hash'][tid] = self.rqdata.runtaskentries[tid].hash
1464 sq_data['hashfn'][tid] = self.rqdata.dataCaches[mc].hashfn[taskfn]
1465 sq_data['unihash'][tid] = self.rqdata.runtaskentries[tid].unihash
1495 …self.rqdata.init_progress_reporter = bb.progress.MultiStageProcessProgressReporter(self.cooker.dat…
1498 if self.rqdata.prepare() == 0:
1505 self.rqdata.init_progress_reporter.next_stage()
1509 depgraph = self.cooker.buildDependTree(self, self.rqdata.taskData)
1510 self.rqdata.init_progress_reporter.next_stage()
1521 self.rqdata.init_progress_reporter.finish()
1530 self.rqdata.init_progress_reporter.next_stage()
1532 self.rqdata.init_progress_reporter.next_stage()
1536 if not self.rqdata.runq_setscene_tids:
1538 for tid in self.rqdata.runtaskentries:
1539 if not self.rqdata.runtaskentries[tid].depends:
1617 dataCaches = self.rqdata.dataCaches
1624 for tid in self.rqdata.runtaskentries:
1644 bb.parse.siggen.dump_sigs(self.rqdata.dataCaches, options)
1653 for tid in self.rqdata.runtaskentries:
1655 taskdep = self.rqdata.dataCaches[mc].task_deps[taskfn]
1669 if tid not in self.rqdata.runq_setscene_tids:
1671 for dep in self.rqdata.runtaskentries[tid].depends:
1673 for dep2 in self.rqdata.runtaskentries[dep].revdeps:
1674 if dep2 in self.rqdata.runq_setscene_tids and dep2 in noexec:
1682 for tid in self.rqdata.runtaskentries:
1693 for dep in self.rqdata.runtaskentries[t].depends:
1731 pn = self.rqdata.dataCaches[mc].pkg_fn[taskfn]
1732 h = self.rqdata.runtaskentries[tid].hash
1754 self.rqdata = rq.rqdata
1785 … self.stats = RunQueueStats(len(self.rqdata.runtaskentries), len(self.rqdata.runq_setscene_tids))
1828 self.cantskip = set(self.rqdata.target_tids)
1829 self.cantskip.difference_update(self.rqdata.runq_setscene_tids)
1830 self.cantskip.intersection_update(self.rqdata.runtaskentries)
1835 self.sched = scheduler(self, self.rqdata)
1844 build_scenequeue_data(self.sqdata, self.rqdata, self.rq, self.cooker, self.stampcache, self)
1918 pn = self.rqdata.dataCaches[mc].pkg_fn[taskfn]
1963 for revdep in self.rqdata.runtaskentries[task].revdeps:
1969 for dep in self.rqdata.runtaskentries[revdep].depends:
1981 …update_scenequeue_data([t], self.sqdata, self.rqdata, self.rq, self.cooker, self.stampcache, self,…
2014 if self.rqdata.taskData[''].halt:
2045 for tid in self.rqdata.runq_setscene_tids:
2056 for x in self.rqdata.runtaskentries:
2063 if not self.rqdata.runtaskentries[x].depends and x not in self.runq_buildable:
2080 self.sorted_setscene_tids = sorted(self.rqdata.runq_setscene_tids)
2088 if nexttask not in self.rqdata.target_tids:
2126 if task in self.rqdata.target_tids:
2145 taskdep = self.rqdata.dataCaches[mc].task_deps[taskfn]
2146 taskhash = self.rqdata.get_task_hash(task)
2147 unihash = self.rqdata.get_task_unihash(task)
2157 …self.build_stamps[task] = bb.build.stampfile(taskname, self.rqdata.dataCaches[mc], taskfn, noextra…
2192 if self.rqdata.setscene_ignore_tasks is not None:
2209 taskdep = self.rqdata.dataCaches[mc].task_deps[taskfn]
2216 if not (self.cooker.configuration.dry_run or self.rqdata.setscene_enforce):
2217 bb.build.make_stamp(taskname, self.rqdata.dataCaches[mc], taskfn)
2226 taskdep = self.rqdata.dataCaches[mc].task_deps[taskfn]
2227 taskhash = self.rqdata.get_task_hash(task)
2228 unihash = self.rqdata.get_task_unihash(task)
2229 …in taskdep['fakeroot'] and not (self.cooker.configuration.dry_run or self.rqdata.setscene_enforce):
2238 … self.cooker.collections[mc].get_file_appends(taskfn), taskdepdata, self.rqdata.setscene_enforce))…
2241 … self.cooker.collections[mc].get_file_appends(taskfn), taskdepdata, self.rqdata.setscene_enforce))…
2244 …self.build_stamps[task] = bb.build.stampfile(taskname, self.rqdata.dataCaches[mc], taskfn, noextra…
2268 for task in self.rqdata.runtaskentries:
2300 next = self.rqdata.runtaskentries[task].depends.copy()
2307 pn = self.rqdata.dataCaches[mc].pkg_fn[taskfn]
2308 deps = self.rqdata.runtaskentries[revdep].depends
2309 provides = self.rqdata.dataCaches[mc].fn_provides[taskfn]
2310 taskhash = self.rqdata.runtaskentries[revdep].hash
2311 unihash = self.rqdata.runtaskentries[revdep].unihash
2331 notcovered |= self.sqdata.unskippable.difference(self.rqdata.runq_setscene_tids)
2341 if not self.rqdata.runtaskentries[tid].depends:
2343 elif self.rqdata.runtaskentries[tid].depends.issubset(self.runq_complete):
2351 for tid in self.rqdata.runq_setscene_tids:
2372 if unihash != self.rqdata.runtaskentries[tid].unihash:
2380 self.rqdata.runtaskentries[hashtid].unihash = unihash
2391 next |= self.rqdata.runtaskentries[p].revdeps
2397 next |= self.rqdata.runtaskentries[ntid].revdeps
2403 if not self.rqdata.runtaskentries[p].depends:
2405 elif self.rqdata.runtaskentries[p].depends.isdisjoint(total):
2413 …if self.rqdata.runtaskentries[p].depends and not self.rqdata.runtaskentries[tid].depends.isdisjoin…
2415 orighash = self.rqdata.runtaskentries[tid].hash
2416 dc = bb.parse.siggen.get_data_caches(self.rqdata.dataCaches, mc_from_tid(tid))
2417 … newhash = bb.parse.siggen.get_taskhash(tid, self.rqdata.runtaskentries[tid].depends, dc)
2418 origuni = self.rqdata.runtaskentries[tid].unihash
2427 … bb.parse.siggen.report_unihash_equiv(tid, newhash, origuni, newuni, self.rqdata.dataCaches)
2433 self.rqdata.runtaskentries[tid].hash = newhash
2434 self.rqdata.runtaskentries[tid].unihash = newuni
2437 next |= self.rqdata.runtaskentries[tid].revdeps
2450 if tid not in self.rqdata.runq_setscene_tids:
2502 …self.sqdata.stamps[tid] = bb.build.stampfile(taskname + "_setscene", self.rqdata.dataCaches[mc], t…
2533 h = pending_hash_index(tid, self.rqdata)
2537 …update_scenequeue_data([t[0] for t in update_tasks2], self.sqdata, self.rqdata, self.rq, self.cook…
2556 … noexec, stamppresent = check_setscene_stamps(dep, self.rqdata, self.rq, self.stampcache)
2573 for dep in self.rqdata.runtaskentries[t].depends:
2574 if dep in self.rqdata.runq_setscene_tids or dep in self.tasks_scenequeue_done:
2576 if self.rqdata.runtaskentries[dep].revdeps.issubset(self.tasks_scenequeue_done):
2595 if self.rqdata.setscene_ignore_tasks is not None:
2598 pn = self.rqdata.dataCaches[mc].pkg_fn[taskfn]
2599 … if not check_setscene_enforce_ignore_tasks(pn, taskname, self.rqdata.setscene_ignore_tasks):
2629 idepends = self.rqdata.taskData[mc].taskentries[realtid].idepends
2631 if depname not in self.rqdata.taskData[mc].build_targets:
2634 depfn = self.rqdata.taskData[mc].build_targets[depname][0]
2648 pn = self.rqdata.dataCaches[mc].pkg_fn[taskfn]
2650 provides = self.rqdata.dataCaches[mc].fn_provides[taskfn]
2651 taskhash = self.rqdata.runtaskentries[revdep].hash
2652 unihash = self.rqdata.runtaskentries[revdep].unihash
2672 taskdep = self.rqdata.dataCaches[mc].task_deps[taskfn]
2676 pn = self.rqdata.dataCaches[mc].pkg_fn[taskfn]
2677 if not check_setscene_enforce_ignore_tasks(pn, taskname, self.rqdata.setscene_ignore_tasks):
2678 if tid in self.rqdata.runq_setscene_tids:
2683 …ppend("\nTask %s, unihash %s, taskhash %s" % (t, self.rqdata.runtaskentries[t].unihash, self.rqdat…
2706 def build_scenequeue_data(sqdata, rqdata, rq, cooker, stampcache, sqrq): argument
2717 rqdata.init_progress_reporter.next_stage()
2721 for tid in rqdata.runtaskentries:
2722 sq_revdeps[tid] = copy.copy(rqdata.runtaskentries[tid].revdeps)
2724 if not sq_revdeps[tid] and tid not in rqdata.runq_setscene_tids:
2728 rqdata.init_progress_reporter.next_stage()
2731 for tid in rqdata.runq_setscene_tids:
2734 for dep in rqdata.runtaskentries[tid].depends:
2742 rqdata.init_progress_reporter.next_stage()
2752 if point not in rqdata.runq_setscene_tids:
2756 if point in rqdata.runq_setscene_tids:
2759 for dep in rqdata.runtaskentries[point].depends:
2764 if not sq_revdeps[dep] and dep not in rqdata.runq_setscene_tids:
2771 rqdata.init_progress_reporter.next_stage()
2777 for tid in rqdata.runtaskentries:
2778 if not rqdata.runtaskentries[tid].revdeps:
2785 if tid in rqdata.runq_setscene_tids:
2787 if not rqdata.runtaskentries[tid].depends:
2790 sqdata.unskippable |= rqdata.runtaskentries[tid].depends
2794 sqrq.tasks_scenequeue_done |= sqdata.unskippable.difference(rqdata.runq_setscene_tids)
2796 rqdata.init_progress_reporter.next_stage(len(rqdata.runtaskentries))
2799 for taskcounter, tid in enumerate(rqdata.runtaskentries):
2800 if tid in rqdata.runq_setscene_tids:
2806 rqdata.init_progress_reporter.update(taskcounter)
2808 rqdata.init_progress_reporter.next_stage()
2813 for tid in rqdata.runq_setscene_tids:
2816 idepends = rqdata.taskData[mc].taskentries[realtid].idepends
2817 …sqdata.stamps[tid] = bb.build.stampfile(taskname + "_setscene", rqdata.dataCaches[mc], taskfn, noe…
2820 if depname not in rqdata.taskData[mc].build_targets:
2823 depfn = rqdata.taskData[mc].build_targets[depname][0]
2827 if deptid not in rqdata.runtaskentries:
2838 rqdata.init_progress_reporter.next_stage()
2844 rqdata.init_progress_reporter.next_stage()
2862 rqdata.init_progress_reporter.next_stage()
2870 rqdata.init_progress_reporter.finish()
2882 h = pending_hash_index(tid, rqdata)
2889 …update_scenequeue_data(sqdata.sq_revdeps, sqdata, rqdata, rq, cooker, stampcache, sqrq, summary=Tr…
2894 for tid in rqdata.runq_setscene_tids:
2896 stamps = bb.build.find_stale_stamps(taskname, rqdata.dataCaches[mc], taskfn)
2905 def check_setscene_stamps(tid, rqdata, rq, stampcache, noexecstamp=False): argument
2909 taskdep = rqdata.dataCaches[mc].task_deps[taskfn]
2912 bb.build.make_stamp(taskname + "_setscene", rqdata.dataCaches[mc], taskfn)
2925 def update_scenequeue_data(tids, sqdata, rqdata, rq, cooker, stampcache, sqrq, summary=True): argument
2937 noexec, stamppresent = check_setscene_stamps(tid, rqdata, rq, stampcache, noexecstamp=True)
2995 self.taskhash = rq.rqdata.get_task_hash(task)
3008 self.taskhash = rq.rqdata.get_task_hash(task)