OpenGrok
Home
Sort by relevance
Sort by last modified time
Full Search
Definition
Symbol
File Path
History
|
|
Help
Searched
refs:result_queue
(Results
1 - 6
of
6
) sorted by null
/external/toolchain-utils/bestflags/
pipeline_worker.py
21
def Helper(stage, done_dict, helper_queue, completed_queue,
result_queue
):
42
result_queue
: After the results of the duplicate tasks have been resolved,
72
result_queue
.put(task)
78
result_queue
)
83
result_queue
)
87
result_queue
):
101
result_queue
: After the results of the duplicate tasks have been resolved,
117
result_queue
.put(duplicate_task)
121
def Worker(stage, task, helper_queue,
result_queue
):
133
result_queue
: Queue that holds the completed tasks and the results. This i
[
all
...]
pipeline_process_test.py
23
def MockHelper(stage, done_dict, helper_queue, _,
result_queue
):
36
result_queue
.put(ERROR)
38
result_queue
.put(('helper', task.GetIdentifier(TEST_STAGE)))
41
def MockWorker(stage, task, _,
result_queue
):
43
result_queue
.put(('worker', task.GetIdentifier(TEST_STAGE)))
steering.py
14
def Steering(cache, generations, input_queue,
result_queue
):
36
result_queue
: The output task queue for this pipeline stage. The new tasks
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)
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
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()
pipeline_process.py
41
worker,
result_queue
):
58
result_queue
: The output task queue for this pipeline stage.
65
self._result_queue =
result_queue
Completed in 58 milliseconds