Searched refs:result_queue (Results 1 – 6 of 6) sorted by relevance
/external/toolchain-utils/bestflags/ |
D | pipeline_worker.py | 21 def Helper(stage, done_dict, helper_queue, completed_queue, result_queue): argument 72 result_queue.put(task) 78 result_queue) 83 result_queue) 87 result_queue): argument 117 result_queue.put(duplicate_task) 121 def Worker(stage, task, helper_queue, result_queue): argument 142 result_queue.put(task)
|
D | steering_test.py | 109 result_queue = manager.Queue() 113 args=(set(), [current_generation], input_queue, result_queue)) 124 task = result_queue.get() 131 task = result_queue.get() 156 result_queue = manager.Queue() 160 args=(steering_tasks, [current_generation], input_queue, result_queue)) 165 assert result_queue.get() == pipeline_process.POISONPILL
|
D | steering.py | 14 def Steering(cache, generations, input_queue, result_queue): argument 56 result_queue.put(task) 63 result_queue.put(pipeline_process.POISONPILL) 111 result_queue.put(new_task) 116 result_queue.put(pipeline_process.POISONPILL)
|
D | pipeline_worker_test.py | 48 result_queue = manager.Queue() 54 args=(TEST_STAGE, {}, helper_queue, completed_queue, result_queue)) 82 task = result_queue.get() 97 result_queue = manager.Queue() 111 result_queue) 116 output = result_queue.get()
|
D | pipeline_process_test.py | 23 def MockHelper(stage, done_dict, helper_queue, _, result_queue): argument 36 result_queue.put(ERROR) 38 result_queue.put(('helper', task.GetIdentifier(TEST_STAGE))) 41 def MockWorker(stage, task, _, result_queue): argument 43 result_queue.put(('worker', task.GetIdentifier(TEST_STAGE)))
|
D | pipeline_process.py | 41 worker, result_queue): argument 65 self._result_queue = result_queue
|