lib/bb/runqueue.py

1843         self.sqdata = SQData()
1844         build_scenequeue_data(self.sqdata, self.rqdata, self.rq, self.cooker, self.stampcache, self)
1981 …update_scenequeue_data([t], self.sqdata, self.rqdata, self.rq, self.cooker, self.stampcache, self,…
2086 …xttask in self.sq_buildable and nexttask not in self.sq_running and self.sqdata.stamps[nexttask] n…
2087 …sqdata.unskippable and self.sqdata.sq_revdeps[nexttask] and self.sqdata.sq_revdeps[nexttask].issub…
2096                     for t in self.sqdata.sq_covered_tasks[nexttask]:
2109                     if nexttask in self.sqdata.outrightfail:
2113                     if nexttask in self.sqdata.unskippable:
2330             notcovered |= self.sqdata.sq_covered_tasks[tid]
2331         notcovered |= self.sqdata.unskippable.difference(self.rqdata.runq_setscene_tids)
2336             covered |= self.sqdata.sq_covered_tasks[tid]
2356             for dep in self.sqdata.sq_covered_tasks[tid]:
2464             for dep in self.sqdata.sq_covered_tasks[tid]:
2477             for dep in self.sqdata.sq_covered_tasks[tid]:
2485                     if dep in self.tasks_scenequeue_done and dep not in self.sqdata.unskippable:
2492             if tid in self.sqdata.outrightfail:
2493                 self.sqdata.outrightfail.remove(tid)
2502 …self.sqdata.stamps[tid] = bb.build.stampfile(taskname + "_setscene", self.rqdata.dataCaches[mc], t…
2515             for t in self.sqdata.sq_harddeps:
2516                 if tid in self.sqdata.sq_harddeps[t] and t in self.scenequeue_notcovered:
2519 …if not harddepfail and self.sqdata.sq_revdeps[tid].issubset(self.scenequeue_covered | self.scenequ…
2522             if not self.sqdata.sq_revdeps[tid]:
2525             update_tasks2.append((tid, harddepfail, tid in self.sqdata.valid))
2529             for mc in sorted(self.sqdata.multiconfigs):
2534                     if h in self.sqdata.hashes and tid != self.sqdata.hashes[h]:
2535                         self.sq_deferred[tid] = self.sqdata.hashes[h]
2536                         bb.note("Deferring %s after %s" % (tid, self.sqdata.hashes[h]))
2537 …update_scenequeue_data([t[0] for t in update_tasks2], self.sqdata, self.rqdata, self.rq, self.cook…
2540             if tid in self.sqdata.valid and not origvalid:
2551         for dep in sorted(self.sqdata.sq_deps[task]):
2552             if fail and task in self.sqdata.sq_harddeps and dep in self.sqdata.sq_harddeps[task]:
2562 …     if self.sqdata.sq_revdeps[dep].issubset(self.scenequeue_covered | self.scenequeue_notcovered):
2706 def build_scenequeue_data(sqdata, rqdata, rq, cooker, stampcache, sqrq):  argument
2779             sqdata.unskippable.add(tid)
2780     sqdata.unskippable |= sqrq.cantskip
2783         orig = sqdata.unskippable.copy()
2790             sqdata.unskippable |= rqdata.runtaskentries[tid].depends
2791             if sqdata.unskippable != orig:
2794     sqrq.tasks_scenequeue_done |= sqdata.unskippable.difference(rqdata.runq_setscene_tids)
2817 …sqdata.stamps[tid] = bb.build.stampfile(taskname + "_setscene", rqdata.dataCaches[mc], taskfn, noe…
2830             if not deptid in sqdata.sq_harddeps:
2831                 sqdata.sq_harddeps[deptid] = set()
2832             sqdata.sq_harddeps[deptid].add(tid)
2840     for task in sqdata.sq_harddeps:
2841         for dep in sqdata.sq_harddeps[task]:
2852     sqdata.sq_revdeps = sq_revdeps_squash
2853     sqdata.sq_covered_tasks = sq_collated_deps
2856     for tid in sqdata.sq_revdeps:
2857         sqdata.sq_deps[tid] = set()
2858     for tid in sqdata.sq_revdeps:
2859         for dep in sqdata.sq_revdeps[tid]:
2860             sqdata.sq_deps[dep].add(tid)
2864     sqdata.multiconfigs = set()
2865     for tid in sqdata.sq_revdeps:
2866         sqdata.multiconfigs.add(mc_from_tid(tid))
2867         if not sqdata.sq_revdeps[tid]:
2872     sqdata.noexec = set()
2873     sqdata.stamppresent = set()
2874     sqdata.valid = set()
2876     sqdata.hashes = {}
2878     for mc in sorted(sqdata.multiconfigs):
2879         for tid in sorted(sqdata.sq_revdeps):
2883             if h not in sqdata.hashes:
2884                 sqdata.hashes[h] = tid
2886                 sqrq.sq_deferred[tid] = sqdata.hashes[h]
2887                 bb.note("Deferring %s after %s" % (tid, sqdata.hashes[h]))
2889 …update_scenequeue_data(sqdata.sq_revdeps, sqdata, rqdata, rq, cooker, stampcache, sqrq, summary=Tr…
2925 def update_scenequeue_data(tids, sqdata, rqdata, rq, cooker, stampcache, sqrq, summary=True):  argument
2930         if tid in sqdata.stamppresent:
2931             sqdata.stamppresent.remove(tid)
2932         if tid in sqdata.valid:
2933             sqdata.valid.remove(tid)
2934         if tid in sqdata.outrightfail:
2935             sqdata.outrightfail.remove(tid)
2940             sqdata.noexec.add(tid)
2945             sqdata.stamppresent.add(tid)
2951 …sqdata.valid |= rq.validate_hashes(tocheck, cooker.data, len(sqdata.stamppresent), False, summary=…
2954         if tid in sqdata.stamppresent:
2956         if tid in sqdata.valid:
2958         if tid in sqdata.noexec:
2966         sqdata.outrightfail.add(tid)