Lines Matching full:mc
42 if tid.startswith('mc:') and tid.count(':') >= 2:
47 (mc, fn, taskname, _) = split_tid_mcfn(tid)
48 return (mc, fn, taskname)
51 if n.startswith("mc:") and n.count(':') >= 2:
52 _, mc, n = n.split(":", 2)
53 return (mc, n)
57 if tid.startswith('mc:') and tid.count(':') >= 2:
59 mc = elems[1]
62 mcfn = "mc:" + mc + ":" + fn
65 mc = ""
70 return (mc, fn, taskname, mcfn)
72 def build_tid(mc, fn, taskname): argument
73 if mc:
74 return "mc:" + mc + ":" + fn + ":" + taskname
80 (mc, fn, taskname, taskfn) = split_tid_mcfn(tid)
81 pn = rqdata.dataCaches[mc].pkg_fn[taskfn]
157 (mc, fn, taskname, taskfn) = split_tid_mcfn(tid)
158 … self.stamps[tid] = bb.build.stampfile(taskname, self.rqdata.dataCaches[mc], taskfn, noextra=True)
474 (mc, fn, taskname, taskfn) = split_tid_mcfn(task)
475 pn = self.dataCaches[mc].pkg_fn[taskfn]
646 for mc in self.taskData:
647 if taskData[mc].taskentries:
668 def add_build_dependencies(depids, tasknames, depends, mc): argument
671 … if depname not in taskData[mc].build_targets or not taskData[mc].build_targets[depname]:
673 depdata = taskData[mc].build_targets[depname][0]
678 if t in taskData[mc].taskentries:
681 def add_runtime_dependencies(depids, tasknames, depends, mc): argument
683 if depname not in taskData[mc].run_targets or not taskData[mc].run_targets[depname]:
685 depdata = taskData[mc].run_targets[depname][0]
690 if t in taskData[mc].taskentries:
693 def add_mc_dependencies(mc, tid): argument
694 mcdeps = taskData[mc].get_mcdepends()
701 if mc == frommc:
704 taskData[mc].taskentries[tid].tdepends.append(newdep)
706 for mc in taskData:
707 for tid in taskData[mc].taskentries:
709 (mc, fn, taskname, taskfn) = split_tid_mcfn(tid)
710 #runtid = build_tid(mc, fn, taskname)
712 #logger.debug2("Processing %s,%s:%s", mc, fn, taskname)
715 task_deps = self.dataCaches[mc].task_deps[taskfn]
719 if fn in taskData[mc].failed_fns:
724 add_mc_dependencies(mc, tid)
729 for t in taskData[mc].taskentries[tid].tdepends:
739 add_build_dependencies(taskData[mc].depids[taskfn], tasknames, depends, mc)
747 add_runtime_dependencies(taskData[mc].rdepids[taskfn], tasknames, depends, mc)
753 idepends = taskData[mc].taskentries[tid].idepends
755 …if depname in taskData[mc].build_targets and taskData[mc].build_targets[depname] and not depname i…
757 depdata = taskData[mc].build_targets[depname][0]
761 if t not in taskData[mc].taskentries:
763 irdepends = taskData[mc].taskentries[tid].irdepends
765 if depname in taskData[mc].run_targets:
767 if not taskData[mc].run_targets[depname]:
769 depdata = taskData[mc].run_targets[depname][0]
773 if t not in taskData[mc].taskentries:
784 add_build_dependencies(taskData[mc].depids[taskfn], tasknames, depends, mc)
785 add_runtime_dependencies(taskData[mc].rdepids[taskfn], tasknames, depends, mc)
792 newdep = build_tid(mc, fn, t)
925 (mc, fn, taskname, taskfn) = split_tid_mcfn(tid)
926 taskdep = self.dataCaches[mc].task_deps[taskfn]
927 if fn + ":" + taskname not in taskData[mc].taskentries:
936 bb.parse.siggen.invalidate_task(taskname, self.dataCaches[mc], taskfn)
939 for (mc, target, task, fn) in self.targets:
941 if target not in taskData[mc].build_targets or not taskData[mc].build_targets[target]:
944 if target in taskData[mc].failed_deps:
952 if fn in taskData[mc].failed_fns:
955 # fn already has mc prefix
958 if tid not in taskData[mc].taskentries:
961 for x in taskData[mc].taskentries:
1089 for mc in self.dataCaches:
1096 if mc != tidmc:
1099 for prov in self.dataCaches[mc].fn_provides[taskfn]:
1112 pn = self.dataCaches[mc].pkg_fn[fn]
1153 provides = set(self.dataCaches[mc].fn_provides[provfn])
1155 for rprovide in self.dataCaches[mc].rproviders:
1156 if provfn in self.dataCaches[mc].rproviders[rprovide]:
1158 for package in self.dataCaches[mc].packages:
1159 if provfn in self.dataCaches[mc].packages[package]:
1161 for package in self.dataCaches[mc].packages_dynamic:
1162 if provfn in self.dataCaches[mc].packages_dynamic[package]:
1192 (mc, fn, taskname, _) = split_tid_mcfn(tid)
1194 if setscenetid not in taskData[mc].taskentries:
1217 for mc in taskData:
1218 virtmap = taskData[mc].get_providermap(prefix="virtual/")
1221 virtpnmap[v] = self.dataCaches[mc].pkg_fn[virtmap[v]]
1224 bb.parse.siggen.tasks_resolved(virtmap, virtpnmap, self.dataCaches[mc])
1292 def _start_worker(self, mc, fakeroot = False, rqexec = None): argument
1300 mcdata = self.cooker.databuilder.mcdata[mc]
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:
1360 self.worker[mc] = self._start_worker(mc)
1362 def start_fakeworker(self, rqexec, mc): argument
1363 if not mc in self.fakeworker:
1364 self.fakeworker[mc] = self._start_worker(mc, True, rqexec)
1368 for mc in self.worker:
1369 self._teardown_worker(self.worker[mc])
1371 for mc in self.fakeworker:
1372 self._teardown_worker(self.fakeworker[mc])
1376 for mc in self.worker:
1377 self.worker[mc].pipe.read()
1378 for mc in self.fakeworker:
1379 self.fakeworker[mc].pipe.read()
1383 for mc in self.worker:
1384 fds.append(self.worker[mc].pipe.input)
1385 for mc in self.fakeworker:
1386 fds.append(self.fakeworker[mc].pipe.input)
1398 (mc, fn, tn, taskfn) = split_tid_mcfn(tid)
1402 stampfile = bb.build.stampfile(taskname, self.rqdata.dataCaches[mc], taskfn)
1409 taskdep = self.rqdata.dataCaches[mc].task_deps[taskfn]
1462 (mc, fn, taskname, taskfn) = split_tid_mcfn(tid)
1464 sq_data['hashfn'][tid] = self.rqdata.dataCaches[mc].hashfn[taskfn]
1614 mc = bb.runqueue.mc_from_tid(fn)
1615 the_data = bb_cache.loadDataFull(fn, self.cooker.collections[mc].get_file_appends(fn))
1654 (mc, fn, taskname, taskfn) = split_tid_mcfn(tid)
1655 taskdep = self.rqdata.dataCaches[mc].task_deps[taskfn]
1730 (mc, fn, taskname, taskfn) = split_tid_mcfn(tid)
1731 pn = self.rqdata.dataCaches[mc].pkg_fn[taskfn]
1733 matches = bb.siggen.find_siginfo(pn, taskname, [], self.cooker.databuilder.mcdata[mc])
1787 for mc in rq.worker:
1788 rq.worker[mc].pipe.setrunqueueexec(self)
1789 for mc in rq.fakeworker:
1790 rq.fakeworker[mc].pipe.setrunqueueexec(self)
1868 for mc in self.rq.worker:
1870 self.rq.worker[mc].process.stdin.write(b"<finishnow></finishnow>")
1871 self.rq.worker[mc].process.stdin.flush()
1875 for mc in self.rq.fakeworker:
1877 self.rq.fakeworker[mc].process.stdin.write(b"<finishnow></finishnow>")
1878 self.rq.fakeworker[mc].process.stdin.flush()
1917 (mc, fn, taskname, taskfn) = split_tid_mcfn(dep)
1918 pn = self.rqdata.dataCaches[mc].pkg_fn[taskfn]
2118 (mc, fn, taskname, taskfn) = split_tid_mcfn(task)
2145 taskdep = self.rqdata.dataCaches[mc].task_deps[taskfn]
2149 if not mc in self.rq.fakeworker:
2150 self.rq.start_fakeworker(self, mc)
2151 ….fakeworker[mc].process.stdin.write(b"<runtask>" + pickle.dumps((taskfn, task, taskname, taskhash,…
2152 self.rq.fakeworker[mc].process.stdin.flush()
2154 …f.rq.worker[mc].process.stdin.write(b"<runtask>" + pickle.dumps((taskfn, task, taskname, taskhash,…
2155 self.rq.worker[mc].process.stdin.flush()
2157 …self.build_stamps[task] = bb.build.stampfile(taskname, self.rqdata.dataCaches[mc], taskfn, noextra…
2190 (mc, fn, taskname, taskfn) = split_tid_mcfn(task)
2209 taskdep = self.rqdata.dataCaches[mc].task_deps[taskfn]
2217 bb.build.make_stamp(taskname, self.rqdata.dataCaches[mc], taskfn)
2226 taskdep = self.rqdata.dataCaches[mc].task_deps[taskfn]
2230 if not mc in self.rq.fakeworker:
2232 self.rq.start_fakeworker(self, mc)
2238 ….fakeworker[mc].process.stdin.write(b"<runtask>" + pickle.dumps((taskfn, task, taskname, taskhash,…
2239 self.rq.fakeworker[mc].process.stdin.flush()
2241 …f.rq.worker[mc].process.stdin.write(b"<runtask>" + pickle.dumps((taskfn, task, taskname, taskhash,…
2242 self.rq.worker[mc].process.stdin.flush()
2244 …self.build_stamps[task] = bb.build.stampfile(taskname, self.rqdata.dataCaches[mc], taskfn, noextra…
2286 def filtermcdeps(self, task, mc, deps): argument
2290 if thismc != mc:
2299 mc = mc_from_tid(task)
2302 next = self.filtermcdeps(task, mc, next)
2306 (mc, fn, taskname, taskfn) = split_tid_mcfn(revdep)
2307 pn = self.rqdata.dataCaches[mc].pkg_fn[taskfn]
2309 provides = self.rqdata.dataCaches[mc].fn_provides[taskfn]
2312 deps = self.filtermcdeps(task, mc, deps)
2442 for mc in self.rq.worker:
2443 …self.rq.worker[mc].process.stdin.write(b"<newtaskhashes>" + pickle.dumps(bb.parse.siggen.get_taskh…
2444 for mc in self.rq.fakeworker:
2445 …self.rq.fakeworker[mc].process.stdin.write(b"<newtaskhashes>" + pickle.dumps(bb.parse.siggen.get_t…
2501 (mc, fn, taskname, taskfn) = split_tid_mcfn(tid)
2502 …s[tid] = bb.build.stampfile(taskname + "_setscene", self.rqdata.dataCaches[mc], taskfn, noextra=Tr…
2529 for mc in sorted(self.sqdata.multiconfigs):
2531 if mc_from_tid(tid) != mc:
2597 (mc, fn, taskname, taskfn) = split_tid_mcfn(realtask)
2598 pn = self.rqdata.dataCaches[mc].pkg_fn[taskfn]
2627 (mc, fn, taskname, _) = split_tid_mcfn(tid)
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]
2647 (mc, fn, taskname, taskfn) = split_tid_mcfn(revdep)
2648 pn = self.rqdata.dataCaches[mc].pkg_fn[taskfn]
2650 provides = self.rqdata.dataCaches[mc].fn_provides[taskfn]
2664 (mc, fn, taskname, taskfn) = split_tid_mcfn(tid)
2672 taskdep = self.rqdata.dataCaches[mc].task_deps[taskfn]
2676 pn = self.rqdata.dataCaches[mc].pkg_fn[taskfn]
2814 (mc, fn, taskname, taskfn) = split_tid_mcfn(tid)
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]
2878 for mc in sorted(sqdata.multiconfigs):
2880 if mc_from_tid(tid) != mc:
2895 (mc, fn, taskname, taskfn) = split_tid_mcfn(tid)
2896 stamps = bb.build.find_stale_stamps(taskname, rqdata.dataCaches[mc], taskfn)
2898 if mc not in found:
2899 found[mc] = {}
2900 found[mc][tid] = stamps
2901 for mc in found:
2902 event = bb.event.StaleSetSceneTasks(found[mc])
2903 bb.event.fire(event, cooker.databuilder.mcdata[mc])
2907 (mc, fn, taskname, taskfn) = split_tid_mcfn(tid)
2909 taskdep = rqdata.dataCaches[mc].task_deps[taskfn]
2912 bb.build.make_stamp(taskname + "_setscene", rqdata.dataCaches[mc], taskfn)
3170 for (mc, target, task, fn) in targets: