Searched refs:THREAD_CONCURRENCY (Results 1 – 10 of 10) sorted by relevance
137 self._server_pool = logging_pool.pool(test_constants.THREAD_CONCURRENCY)138 self._trigger = _TestTrigger(test_constants.THREAD_CONCURRENCY)143 maximum_concurrent_rpcs=test_constants.THREAD_CONCURRENCY)154 for _ in range(test_constants.THREAD_CONCURRENCY):179 for _ in range(test_constants.THREAD_CONCURRENCY):205 for _ in range(test_constants.THREAD_CONCURRENCY):232 for _ in range(test_constants.THREAD_CONCURRENCY):
341 pool = logging_pool.pool(test_constants.THREAD_CONCURRENCY)347 ] * test_constants.THREAD_CONCURRENCY348 response_futures = [None] * test_constants.THREAD_CONCURRENCY351 for index in range(test_constants.THREAD_CONCURRENCY):370 ] * test_constants.THREAD_CONCURRENCY371 response_futures = [None] * test_constants.THREAD_CONCURRENCY374 for index in range(test_constants.THREAD_CONCURRENCY):386 pool = logging_pool.pool(test_constants.THREAD_CONCURRENCY)389 response_futures = [None] * test_constants.THREAD_CONCURRENCY407 for index in range(test_constants.THREAD_CONCURRENCY):[all …]
100 max_workers=test_constants.THREAD_CONCURRENCY)146 for _ in range(test_constants.THREAD_CONCURRENCY))171 for _ in range(test_constants.THREAD_CONCURRENCY):
76 server_pool = logging_pool.pool(test_constants.THREAD_CONCURRENCY)
315 self._server_pool = logging_pool.pool(test_constants.THREAD_CONCURRENCY)
63 if self._state.parked_handlers == test_constants.THREAD_CONCURRENCY:144 test_constants.THREAD_CONCURRENCY)201 if state.parked_handlers < test_constants.THREAD_CONCURRENCY:
43 for _ in range(test_constants.THREAD_CONCURRENCY))
42 THREAD_CONCURRENCY = 25 variable
155 for _ in range(test_constants.THREAD_CONCURRENCY))
190 for _ in range(test_constants.THREAD_CONCURRENCY))