Home
last modified time | relevance | path

Searched refs:THREAD_CONCURRENCY (Results 1 – 11 of 11) sorted by relevance

/third_party/grpc/src/python/grpcio_tests/tests/unit/
D_rpc_part_2_test.py193 pool = logging_pool.pool(test_constants.THREAD_CONCURRENCY)
199 ] * test_constants.THREAD_CONCURRENCY
200 response_futures = [None] * test_constants.THREAD_CONCURRENCY
203 for index in range(test_constants.THREAD_CONCURRENCY):
222 ] * test_constants.THREAD_CONCURRENCY
223 response_futures = [None] * test_constants.THREAD_CONCURRENCY
226 for index in range(test_constants.THREAD_CONCURRENCY):
238 pool = logging_pool.pool(test_constants.THREAD_CONCURRENCY)
241 response_futures = [None] * test_constants.THREAD_CONCURRENCY
259 for index in range(test_constants.THREAD_CONCURRENCY):
[all …]
D_resource_exhausted_test.py138 self._server_pool = logging_pool.pool(test_constants.THREAD_CONCURRENCY)
139 self._trigger = _TestTrigger(test_constants.THREAD_CONCURRENCY)
144 maximum_concurrent_rpcs=test_constants.THREAD_CONCURRENCY)
156 for _ in range(test_constants.THREAD_CONCURRENCY):
181 for _ in range(test_constants.THREAD_CONCURRENCY):
207 for _ in range(test_constants.THREAD_CONCURRENCY):
234 for _ in range(test_constants.THREAD_CONCURRENCY):
D_channel_close_test.py120 max_workers=test_constants.THREAD_CONCURRENCY)
166 for _ in range(test_constants.THREAD_CONCURRENCY))
191 for _ in range(test_constants.THREAD_CONCURRENCY):
D_rpc_test.py409 pool = logging_pool.pool(test_constants.THREAD_CONCURRENCY)
415 ] * test_constants.THREAD_CONCURRENCY
416 response_futures = [None] * test_constants.THREAD_CONCURRENCY
419 for index in range(test_constants.THREAD_CONCURRENCY):
438 ] * test_constants.THREAD_CONCURRENCY
439 response_futures = [None] * test_constants.THREAD_CONCURRENCY
442 for index in range(test_constants.THREAD_CONCURRENCY):
454 pool = logging_pool.pool(test_constants.THREAD_CONCURRENCY)
457 response_futures = [None] * test_constants.THREAD_CONCURRENCY
475 for index in range(test_constants.THREAD_CONCURRENCY):
[all …]
D_reconnect_test.py40 server_pool = logging_pool.pool(test_constants.THREAD_CONCURRENCY)
D_interceptor_test.py347 self._server_pool = logging_pool.pool(test_constants.THREAD_CONCURRENCY)
/third_party/grpc/src/python/grpcio_tests/tests/unit/_cython/
D_cancel_many_calls_test.py63 if self._state.parked_handlers == test_constants.THREAD_CONCURRENCY:
144 test_constants.THREAD_CONCURRENCY)
199 if state.parked_handlers < test_constants.THREAD_CONCURRENCY:
D_channel_test.py43 for _ in range(test_constants.THREAD_CONCURRENCY))
/third_party/grpc/src/python/grpcio_tests/tests/unit/framework/common/
Dtest_constants.py42 THREAD_CONCURRENCY = 25 variable
/third_party/grpc/src/python/grpcio_tests/tests/testing/
D_client_application.py155 for _ in range(test_constants.THREAD_CONCURRENCY))
D_client_test.py190 for _ in range(test_constants.THREAD_CONCURRENCY))