Searched refs:exception_queue (Results 1 – 4 of 4) sorted by relevance
| /aosp_15_r20/external/grpc-grpc/src/python/grpcio_tests/tests/stress/ |
| H A D | client.py | 135 exception_queue = queue.Queue()
153 stub, test_cases, hist, exception_queue, stop_event
163 raise exception_queue.get(block=True, timeout=timeout_secs)
|
| H A D | test_runner.py | 36 def __init__(self, stub, test_cases, hist, exception_queue, stop_event): argument
38 self._exception_queue = exception_queue
|
| /aosp_15_r20/external/pytorch/torch/testing/_internal/ |
| H A D | common_distributed.py | 947 MultiThreadedTestCase.exception_queue.put((rank, sys.exc_info()))
990 exception_queue = queue.Queue() variable in MultiThreadedTestCase
1088 self.exception_queue.put((rank, sys.exc_info()))
1102 MultiThreadedTestCase.exception_queue.put(
1116 while not cls.exception_queue.empty():
1117 failure = cls.exception_queue.get()
|
| /aosp_15_r20/external/grpc-grpc/src/python/grpcio_tests/tests/unit/ |
| H A D | _contextvars_propagation_test.py | 143 def _run_on_thread(exception_queue): argument
158 exception_queue.put(e)
|