Lines Matching refs:pipeline
2305 def process(self, pipeline, done, message, lock, results): argument
2315 pipeline.put({"op": "report", "test": self.instance})
2319 pipeline.put({"op": "report", "test": self.instance})
2328 pipeline.put({"op": "report", "test": self.instance})
2330 pipeline.put({"op": "build", "test": self.instance})
2339 pipeline.put({"op": "report", "test": self.instance})
2348 pipeline.put({"op": "report", "test": self.instance})
2351 pipeline.put({"op": "run", "test": self.instance})
2353 pipeline.put({"op": "report", "test": self.instance})
2364 pipeline.put({
2379 pipeline.put({
2668 self.pipeline = None
3320 def add_tasks_to_queue(self, pipeline, build_only=False, test_only=False): argument
3329 pipeline.put({"op": "run", "test": instance})
3331 pipeline.put({"op": "cmake", "test": instance})
3334 pipeline.put({"op": "report", "test": instance})
3336 def pipeline_mgr(self, pipeline, done_queue, lock, results): argument
3339 task = pipeline.get_nowait()
3362 pb.process(pipeline, done_queue, task, lock, results)
3366 def execute(self, pipeline, done, results): argument
3369 self.add_tasks_to_queue(pipeline, self.build_only, self.test_only)
3375 p = Process(target=self.pipeline_mgr, args=(pipeline, done, lock, results, ))