72         done := instances that reached report_out stage of the pipeline
80         # instances that go through the pipeline
107         # updated by report_out() in pipeline
125         # updated by report_out() in pipeline
937     def _add_to_pipeline(self, pipeline, op: str, additionals: dict=None):  argument
943                 pipeline.put(task)
944         # Only possible RuntimeError source here is a mutation of the pipeline during iteration.
945         # If that happens, we ought to consider the whole pipeline corrupted.
951     def process(self, pipeline, done, message, lock, results):  argument
983                 self._add_to_pipeline(pipeline, next_op)
1016                 self._add_to_pipeline(pipeline, next_op)
1065                 self._add_to_pipeline(pipeline, next_op)
1096                 self._add_to_pipeline(pipeline, next_op)
1123                 self._add_to_pipeline(pipeline, next_op, additionals)
1152                 self._add_to_pipeline(pipeline, next_op, additionals)
1764         self.pipeline = None
1784         pipeline = manager.LifoQueue()
1824             self.execute(pipeline, done_queue)
1851         Updating counting before pipeline is necessary because statically filterd
1852         test instance never enter the pipeline. While some pipeline output needs
1874         pipeline,  argument
1914                     pipeline.put({"op": "run", "test": instance})
1916                     pipeline.put({"op": "filter", "test": instance})
1920                         pipeline.put({"op": "build", "test": instance})
1922                         pipeline.put({"op": "cmake", "test": instance})
1925     def pipeline_mgr(self, pipeline, done_queue, lock, results):  argument
1931                             task = pipeline.get_nowait()
1938                             pb.process(pipeline, done_queue, task, lock, results)
1941                                 with pipeline.mutex:
1942                                     pipeline.queue.clear()
1949                         task = pipeline.get_nowait()
1956                         pb.process(pipeline, done_queue, task, lock, results)
1959                             with pipeline.mutex:
1960                                 pipeline.queue.clear()
1967     def execute(self, pipeline, done):  argument
1970         self.add_tasks_to_queue(pipeline, self.options.build_only, self.options.test_only,
1977             p = Process(target=self.pipeline_mgr, args=(pipeline, done, lock, self.results, ))