Searched refs:test_constants (Results 1 – 25 of 62) sorted by relevance
123
29 from tests.unit.framework.common import test_constants45 for _ in range(test_constants.STREAM_LENGTH):118 timeout=test_constants.LONG_TIMEOUT,129 timeout=test_constants.LONG_TIMEOUT,140 timeout=test_constants.LONG_TIMEOUT,142 ).result(timeout=test_constants.LONG_TIMEOUT)151 timeout=test_constants.LONG_TIMEOUT,163 iter([_REQUEST] * test_constants.STREAM_LENGTH),164 timeout=test_constants.LONG_TIMEOUT,174 iter([_REQUEST] * test_constants.STREAM_LENGTH),[all …]
38 from tests.unit.framework.common import test_constants126 b"\x07\x08" for _ in range(test_constants.STREAM_LENGTH)145 b"\x07\x08" for _ in range(test_constants.STREAM_LENGTH)168 b"\x07\x08" for _ in range(test_constants.STREAM_LENGTH)188 b"\x77\x58" for _ in range(test_constants.STREAM_LENGTH)227 pool = logging_pool.pool(test_constants.THREAD_CONCURRENCY)229 b"\x07\x08" for _ in range(test_constants.STREAM_LENGTH)236 ] * test_constants.THREAD_CONCURRENCY237 response_futures = [None] * test_constants.THREAD_CONCURRENCY240 for index in range(test_constants.THREAD_CONCURRENCY):[all …]
24 from tests.unit.framework.common import test_constants94 for _ in range(test_constants.STREAM_LENGTH):111 for _ in range(test_constants.STREAM_LENGTH):364 for _ in range(test_constants.STREAM_LENGTH // 2):371 b"\x67\x88" for _ in range(test_constants.STREAM_LENGTH)381 for _ in range(test_constants.STREAM_LENGTH // 2):386 b"\x67\x88" for _ in range(test_constants.STREAM_LENGTH)396 for _ in range(test_constants.STREAM_LENGTH):398 for _ in range(test_constants.STREAM_LENGTH):430 b"\x07\x08" for _ in range(test_constants.STREAM_LENGTH)[all …]
25 from tests.unit.framework.common import test_constants74 for _ in range(test_constants.STREAM_LENGTH):135 self._server_pool = logging_pool.pool(test_constants.THREAD_CONCURRENCY)136 self._trigger = _TestTrigger(test_constants.THREAD_CONCURRENCY)141 maximum_concurrent_rpcs=test_constants.THREAD_CONCURRENCY,157 for _ in range(test_constants.THREAD_CONCURRENCY):189 for _ in range(test_constants.THREAD_CONCURRENCY):219 request = iter([_REQUEST] * test_constants.STREAM_LENGTH)220 for _ in range(test_constants.THREAD_CONCURRENCY):253 request = iter([_REQUEST] * test_constants.STREAM_LENGTH)[all …]
21 from tests.unit.framework.common import test_constants37 for _ in range(test_constants.STREAM_LENGTH):111 [_RESPONSE] * test_constants.STREAM_LENGTH, list(response_iterator)118 )(iter([_REQUEST] * test_constants.STREAM_LENGTH))125 )(iter([_REQUEST] * test_constants.STREAM_LENGTH))127 [_RESPONSE] * test_constants.STREAM_LENGTH, list(response_iterator)
25 from tests.unit.framework.common import test_constants53 termination_event.wait(timeout=test_constants.SHORT_TIMEOUT)73 termination_event.wait(timeout=test_constants.SHORT_TIMEOUT)85 test_constants.SHORT_TIMEOUT / 2,91 termination_event.wait(timeout=test_constants.SHORT_TIMEOUT)
21 from tests.unit.framework.common import test_constants107 b"\x07\x08" for _ in range(test_constants.STREAM_LENGTH)117 b"\x07\x08" for _ in range(test_constants.STREAM_LENGTH)128 b"\x07\x08" for _ in range(test_constants.STREAM_LENGTH)138 b"\x07\x08" for _ in range(test_constants.STREAM_LENGTH)
38 from tests.unit.framework.common import test_constants44 b"\x07\x08" for _ in range(test_constants.STREAM_LENGTH)71 b"\x07\x18" for _ in range(test_constants.STREAM_LENGTH)174 b"\x47\x58" for _ in range(test_constants.STREAM_LENGTH)194 b"\x07\x18" for _ in range(test_constants.STREAM_LENGTH)249 b"\x07\x18" for _ in range(test_constants.STREAM_LENGTH)
29 from tests.unit.framework.common import test_constants101 for _ in range(test_constants.STREAM_LENGTH):462 self._server_pool = logging_pool.pool(test_constants.THREAD_CONCURRENCY)504 b"\x07\x08" for _ in range(test_constants.STREAM_LENGTH)519 self.assertEqual(len(responses), 3 * test_constants.STREAM_LENGTH)533 self.assertEqual(len(responses), test_constants.STREAM_LENGTH)762 b"\x07\x08" for _ in range(test_constants.STREAM_LENGTH)794 b"\x07\x08" for _ in range(test_constants.STREAM_LENGTH)829 b"\x07\x08" for _ in range(test_constants.STREAM_LENGTH)860 _EXCEPTION_REQUEST for _ in range(test_constants.STREAM_LENGTH)[all …]
23 from tests.unit.framework.common import test_constants69 for _ in range(test_constants.STREAM_LENGTH // 2):79 for _ in range(test_constants.STREAM_LENGTH // 2):89 for _ in range(test_constants.STREAM_LENGTH // 2):240 iter([REQUEST] * test_constants.STREAM_LENGTH)
23 from tests.unit.framework.common import test_constants51 ready_future.result(timeout=test_constants.SHORT_TIMEOUT)79 ready_future.result(timeout=test_constants.LONG_TIMEOUT)
23 from tests.unit.framework.common import test_constants107 for _ in range(test_constants.STREAM_LENGTH // 2):147 for _ in range(test_constants.STREAM_LENGTH // 3):318 iter([_SERIALIZED_REQUEST] * test_constants.STREAM_LENGTH),343 iter([object()] * test_constants.STREAM_LENGTH),449 iter([_SERIALIZED_REQUEST] * test_constants.STREAM_LENGTH),485 iter([object()] * test_constants.STREAM_LENGTH),576 iter([_SERIALIZED_REQUEST] * test_constants.STREAM_LENGTH),605 iter([object()] * test_constants.STREAM_LENGTH),697 iter([_SERIALIZED_REQUEST] * test_constants.STREAM_LENGTH),[all …]
24 from tests.unit.framework.common import test_constants120 for _ in range(test_constants.STREAM_LENGTH):238 iter([_REQUEST] * test_constants.STREAM_LENGTH),257 iter([_REQUEST] * test_constants.STREAM_LENGTH),
25 from tests.unit.framework.common import test_constants115 max_workers=test_constants.THREAD_CONCURRENCY176 for _ in range(test_constants.THREAD_CONCURRENCY)205 for _ in range(test_constants.THREAD_CONCURRENCY):
23 from tests.unit.framework.common import test_constants35 _SUCCESSFUL_CALLS = int(test_constants.RPC_CONCURRENCY * _SUCCESS_CALL_FRACTION)36 _UNSUCCESSFUL_CALLS = test_constants.RPC_CONCURRENCY - _SUCCESSFUL_CALLS64 if self._state.parked_handlers == test_constants.THREAD_CONCURRENCY:103 for _ in range(test_constants.RPC_CONCURRENCY):112 if test_constants.RPC_CONCURRENCY <= state.handled_rpcs:150 test_constants.THREAD_CONCURRENCY186 for index in range(test_constants.RPC_CONCURRENCY):230 if state.parked_handlers < test_constants.THREAD_CONCURRENCY:232 elif state.handled_rpcs < test_constants.RPC_CONCURRENCY:
30 from tests.unit.framework.common import test_constants86 response = response_queue.get(timeout=test_constants.SHORT_TIMEOUT)107 response = response_queue.get(timeout=test_constants.SHORT_TIMEOUT)115 response = response_queue.get(timeout=test_constants.SHORT_TIMEOUT)123 response = response_queue.get(timeout=test_constants.SHORT_TIMEOUT)141 response = response_queue.get(timeout=test_constants.SHORT_TIMEOUT)150 response_queue.get(timeout=test_constants.SHORT_TIMEOUT)172 timeout=test_constants.SHORT_TIMEOUT175 timeout=test_constants.SHORT_TIMEOUT188 timeout=test_constants.SHORT_TIMEOUT[all …]
26 from tests.unit.framework.common import test_constants171 thread_pool_size=test_constants.POOL_SIZE196 thread_pool_size=test_constants.POOL_SIZE204 self._server.stop(test_constants.SHORT_TIMEOUT).wait()211 _REQUEST, test_constants.LONG_TIMEOUT, protocol_options=call_options232 _REQUEST, test_constants.LONG_TIMEOUT, protocol_options=call_options255 test_constants.LONG_TIMEOUT,284 test_constants.SHORT_TIMEOUT,334 thread_pool_size=test_constants.POOL_SIZE348 thread_pool_size=test_constants.POOL_SIZE[all …]
22 from tests.unit.framework.common import test_constants43 test_constants.LONG_TIMEOUT,53 "grupe", "mevvod", iter([b"def"]), test_constants.LONG_TIMEOUT
24 from tests.unit.framework.common import test_constants53 ready_future.result(timeout=test_constants.SHORT_TIMEOUT)75 ready_future.result(timeout=test_constants.LONG_TIMEOUT)
33 from tests.unit.framework.common import test_constants369 stub.UnaryCall(request, test_constants.LONG_TIMEOUT)382 response = stub.UnaryCall(request, test_constants.LONG_TIMEOUT)396 request, test_constants.LONG_TIMEOUT411 request, test_constants.SHORT_TIMEOUT437 request, test_constants.LONG_TIMEOUT449 request, test_constants.LONG_TIMEOUT468 request, test_constants.SHORT_TIMEOUT481 request, test_constants.LONG_TIMEOUT511 test_constants.LONG_TIMEOUT,[all …]
29 from tests.unit.framework.common import test_constants42 timeout=test_constants.LONG_TIMEOUT,56 timeout=test_constants.LONG_TIMEOUT,75 timeout=test_constants.LONG_TIMEOUT,82 timeout=test_constants.LONG_TIMEOUT, wait_for_ready=wait_for_ready
26 from tests.unit.framework.common import test_constants58 test_constants.SHORT_TIMEOUT,71 test_constants.SHORT_TIMEOUT,86 test_constants.SHORT_TIMEOUT,
24 from tests.unit.framework.common import test_constants118 await asyncio.sleep(test_constants.SHORT_TIMEOUT / 2)423 await self._server.stop(test_constants.SHORT_TIMEOUT)426 grace_period_length, test_constants.SHORT_TIMEOUT / 3437 await self._server.stop(test_constants.SHORT_TIMEOUT)452 self._server.stop(test_constants.LONG_TIMEOUT),453 self._server.stop(test_constants.SHORT_TIMEOUT),454 self._server.stop(test_constants.LONG_TIMEOUT),458 grace_period_length, test_constants.SHORT_TIMEOUT / 3470 self._server.stop(test_constants.LONG_TIMEOUT),[all …]
27 from tests.unit.framework.common import test_constants159 for _ in range(test_constants.THREAD_CONCURRENCY)174 outcomes = [None] * test_constants.RPC_CONCURRENCY182 for index in range(test_constants.RPC_CONCURRENCY):
49 test_constants(PyObject *Py_UNUSED(module), PyObject *Py_UNUSED(args)) in test_constants() function68 {"test_constants", test_constants, METH_NOARGS},