| /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
|
| /external/python/futures/concurrent/futures/ |
| D | process.py | 108 def _process_worker(call_queue, result_queue): argument
125 result_queue.put(None)
131 result_queue.put(_ResultItem(call_item.work_id,
134 result_queue.put(_ResultItem(call_item.work_id,
179 result_queue): argument
208 result_item = result_queue.get(block=True)
|
| /external/python/cpython3/Lib/concurrent/futures/ |
| D | process.py | 201 def _sendback_result(result_queue, work_id, result=None, exception=None): argument
204 result_queue.put(_ResultItem(work_id, result=result,
208 result_queue.put(_ResultItem(work_id, exception=exc))
211 def _process_worker(call_queue, result_queue, initializer, initargs): argument
236 result_queue.put(os.getpid())
242 _sendback_result(result_queue, call_item.work_id, exception=exc)
244 _sendback_result(result_queue, call_item.work_id, result=r)
295 result_queue, argument
347 result_reader = result_queue._reader
|
| /external/libvpx/libvpx/vpx_util/ |
| D | vpx_debug_util.c | 31 static int result_queue[QUEUE_MAX_SIZE]; variable
57 *result = result_queue[queue_r]; in bitstream_queue_pop()
65 result_queue[queue_w] = result; in bitstream_queue_push()
|
| /external/libaom/libaom/aom_util/ |
| D | debug_util.c | 35 static int result_queue[QUEUE_MAX_SIZE]; variable
63 *result = result_queue[queue_r]; in bitstream_queue_pop()
72 result_queue[queue_w] = result; in bitstream_queue_push()
|
| /external/avb/ |
| D | aftltool | 1533 preserve_icp_images, timeout, result_queue): argument
1580 result_queue.put((start_time, end_time, execution_time,
1628 result_queue = multiprocessing.Queue()
1637 preserve_icp_images, timeout, result_queue))
1645 result) = result_queue.get(timeout=1)
|
| D | aftltool.py | 1533 preserve_icp_images, timeout, result_queue): argument
1580 result_queue.put((start_time, end_time, execution_time,
1628 result_queue = multiprocessing.Queue()
1637 preserve_icp_images, timeout, result_queue))
1645 result) = result_queue.get(timeout=1)
|
| /external/autotest/client/common_lib/ |
| D | utils.py | 3048 t.result_queue = q
3049 t.get = t.result_queue.get
|