Lines Matching refs:tid
114 def get_cached_unihash(self, tid): argument
117 def get_unihash(self, tid): argument
118 unihash = self.get_cached_unihash(tid)
121 return self.taskhash[tid]
124 return {tid: self.get_unihash(tid) for tid in tids}
126 def prep_taskhash(self, tid, deps, dataCaches): argument
129 def get_taskhash(self, tid, deps, dataCaches): argument
130 self.taskhash[tid] = hashlib.sha256(tid.encode("utf-8")).hexdigest()
131 return self.taskhash[tid]
261 tid = mcfn + ":" + task
262 if not ignore_mismatch and tid in self.basehash and self.basehash[tid] != basehash[tid]:
263 …adata is not deterministic and this needs to be fixed." % (tid, self.basehash[tid], basehash[tid]))
270 self.basehash[tid] = basehash[tid]
336 def prep_taskhash(self, tid, deps, dataCaches): argument
338 (mc, _, task, mcfn) = bb.runqueue.split_tid_mcfn(tid)
340 self.basehash[tid] = dataCaches[mc].basetaskhash[tid]
341 self.runtaskdeps[tid] = []
342 self.file_checksum_values[tid] = []
345 self.tidtopn[tid] = recipename
358 self.runtaskdeps[tid].append((dep_pnid, dep))
366 self.file_checksum_values[tid].append((f,cs))
371 if tid in self.taints and self.taints[tid].startswith("nostamp:"):
377 self.taints[tid] = "nostamp:" + taint
381 self.taints[tid] = taint
382 logger.warning("%s is tainted from a forced run" % tid)
386 def get_taskhash(self, tid, deps, dataCaches): argument
388 data = self.basehash[tid]
389 for dep in sorted(self.runtaskdeps[tid]):
392 for (f, cs) in sorted(self.file_checksum_values[tid], key=clean_checksum_file_path):
398 if tid in self.taints:
399 if self.taints[tid].startswith("nostamp:"):
400 data += self.taints[tid][8:]
402 data += self.taints[tid]
405 self.taskhash[tid] = h
425 tid = mcfn + ":" + task
431 elif runtime and tid in self.taskhash:
432 sigfile = stampbase + "." + task + ".sigdata" + "." + self.get_unihash(tid)
434 sigfile = stampbase + "." + task + ".sigbasedata" + "." + self.basehash[tid]
444 data['basehash'] = self.basehash[tid]
454 if runtime and tid in self.taskhash:
455 data['runtaskdeps'] = [dep[0] for dep in sorted(self.runtaskdeps[tid])]
457 for f,cs in sorted(self.file_checksum_values[tid], key=clean_checksum_file_path):
463 for dep in self.runtaskdeps[tid]:
465 data['taskhash'] = self.taskhash[tid]
466 data['unihash'] = self.get_unihash(tid)
472 if runtime and tid in self.taints:
473 if 'nostamp:' in self.taints[tid]:
474 data['taint'] = self.taints[tid]
477 if computed_basehash != self.basehash[tid]:
478 … bb.error("Basehash mismatch %s versus %s for %s" % (computed_basehash, self.basehash[tid], tid))
479 if runtime and tid in self.taskhash:
481 if computed_taskhash != self.taskhash[tid]:
482 … bb.error("Taskhash mismatch %s versus %s for %s" % (computed_taskhash, self.taskhash[tid], tid))
483 sigfile = sigfile.replace(self.taskhash[tid], computed_taskhash)
502 def get_stampfile_hash(self, tid): argument
503 if tid in self.taskhash:
504 return self.taskhash[tid]
507 return self.basehash[tid]
511 tid = mcfn + ":" + taskname[:-9]
513 tid = mcfn + ":" + taskname
517 h = self.get_stampfile_hash(tid)
622 def get_stampfile_hash(self, tid): argument
623 if tid in self.taskhash:
627 unihash = self._get_unihash(tid)
631 return super().get_stampfile_hash(tid)
633 def set_unihash(self, tid, unihash): argument
634 (mc, fn, taskname, taskfn) = bb.runqueue.split_tid_mcfn(tid)
635 key = mc + ":" + self.tidtopn[tid] + ":" + taskname
636 self.unitaskhashes[key] = (self.taskhash[tid], unihash)
637 self.unihash[tid] = unihash
639 def _get_unihash(self, tid, checkkey=None): argument
640 if tid not in self.tidtopn:
642 (mc, fn, taskname, taskfn) = bb.runqueue.split_tid_mcfn(tid)
643 key = mc + ":" + self.tidtopn[tid] + ":" + taskname
647 checkkey = self.taskhash[tid]
653 def get_cached_unihash(self, tid): argument
654 taskhash = self.taskhash[tid]
657 if self.setscenetasks and tid not in self.setscenetasks:
658 self.unihash[tid] = None
663 unihash = self._get_unihash(tid)
665 self.unihash[tid] = unihash
670 def _get_method(self, tid): argument
672 if tid in self.extramethod:
673 method = method + self.extramethod[tid]
706 def get_unihash(self, tid): argument
707 return self.get_unihashes([tid])[tid]
718 for tid in tids:
719 unihash = self.get_cached_unihash(tid)
721 result[tid] = unihash
723 queries[tid] = (self._get_method(tid), self.taskhash[tid])
731 for tid, args in queries.items():
732 query_result[tid] = client.get_unihash(*args)
737 for tid, unihash in query_result.items():
751 taskhash = self.taskhash[tid]
756 …askhash], 'Found unihash %s in place of %s for %s from %s' % (unihash, taskhash, tid, self.server))
758 … hashequiv_logger.debug2('No reported unihash for %s:%s from %s' % (tid, taskhash, self.server))
762 self.set_unihash(tid, unihash)
763 self.unihash[tid] = unihash
764 result[tid] = unihash
776 tid = mcfn + ':do_' + task
777 key = tid + ':' + taskhash
779 if self.setscenetasks and tid not in self.setscenetasks:
783 if taskhash != self.taskhash[tid]:
787 cache_unihash = self._get_unihash(tid, checkkey=taskhash)
827 if tid in self.extramethod:
828 method = method + self.extramethod[tid]
838 self.set_unihash(tid, new_unihash)
856 def report_unihash_equiv(self, tid, taskhash, wanted_unihash, current_unihash, datacaches): argument
860 if tid in self.extramethod:
861 method = method + self.extramethod[tid]
866 …hashequiv_logger.verbose('Reported task %s as unihash %s to %s (%s)' % (tid, wanted_unihash, self.…
875 … hashequiv_logger.verbose('Task %s unihash %s unchanged by server' % (tid, finalunihash))
877 …hashequiv_logger.verbose('Task %s unihash changed %s -> %s as wanted' % (tid, current_unihash, fin…
878 self.set_unihash(tid, finalunihash)
882 … hashequiv_logger.verbose('Task %s unihash reported as unwanted hash %s' % (tid, finalunihash))