Searched refs:completed_queue (Results 1 – 2 of 2) sorted by relevance
| /external/toolchain-utils/bestflags/ |
| D | pipeline_worker_test.py | 49 completed_queue = manager.Queue()
54 args=(TEST_STAGE, {}, helper_queue, completed_queue, result_queue))
64 completed_queue.put((9, mock_result[9]))
74 completed_queue.put((2, mock_result[2]))
75 completed_queue.put((1, mock_result[1]))
98 completed_queue = manager.Queue()
110 pipeline_worker.Worker(TEST_STAGE, mock_task, completed_queue,
123 helper_input = completed_queue.get()
|
| D | pipeline_worker.py | 21 def Helper(stage, done_dict, helper_queue, completed_queue, result_queue): argument
77 GetResultFromCompletedQueue(stage, completed_queue, done_dict, waiting_list,
82 GetResultFromCompletedQueue(stage, completed_queue, done_dict, waiting_list,
86 def GetResultFromCompletedQueue(stage, completed_queue, done_dict, waiting_list, argument
110 if not completed_queue.empty():
111 (identifier, result) = completed_queue.get()
|