Searched defs:message_queue (Results 1 – 3 of 3) sorted by relevance
| /test/testfwk/xdevice/src/xdevice/_core/context/ |
| D | impl.py | 193 def peek_monitor(self, message_queue, test_drivers, current_driver_threads): argument
210 def _run(self, run_func, task, message_queue, test_drivers, current_driver_threads): argument
215 def _start_queue_monitor(message_queue, test_drivers, argument
|
| /test/testfwk/xdevice/src/xdevice/_core/executor/ |
| D | concurrent.py | 92 def __init__(self, test_driver, task, environment, message_queue): argument
552 def __init__(self, test_driver, task, environment, message_queue): argument
679 def __init__(self, message_queue, current_driver_threads, test_drivers): argument
758 def __init__(self, test_driver, task, environment, message_queue, lock): argument
|
| D | scheduler.py | 126 def run_host_test(self, task, test_drivers, current_driver_threads, message_queue): argument
288 def run_dynamic_concurrent(self, task, test_drivers, current_driver_threads, message_queue): argument
|