Searched refs:test_constants (Results 1 – 25 of 43) sorted by relevance
12
25 from tests.unit.framework.common import test_constants79 for _ in range(test_constants.STREAM_LENGTH):261 b'\x07\x08' for _ in range(test_constants.STREAM_LENGTH))276 b'\x07\x08' for _ in range(test_constants.STREAM_LENGTH))293 b'\x07\x08' for _ in range(test_constants.STREAM_LENGTH))310 b'\x77\x58' for _ in range(test_constants.STREAM_LENGTH))341 pool = logging_pool.pool(test_constants.THREAD_CONCURRENCY)343 b'\x07\x08' for _ in range(test_constants.STREAM_LENGTH))347 ] * test_constants.THREAD_CONCURRENCY348 response_futures = [None] * test_constants.THREAD_CONCURRENCY[all …]
24 from tests.unit.framework.common import test_constants74 for _ in range(test_constants.STREAM_LENGTH):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):204 request = iter([_REQUEST] * test_constants.STREAM_LENGTH)205 for _ in range(test_constants.THREAD_CONCURRENCY):231 request = iter([_REQUEST] * test_constants.STREAM_LENGTH)[all …]
20 from tests.unit.framework.common import test_constants36 for _ in range(test_constants.STREAM_LENGTH):105 self.assertSequenceEqual([_RESPONSE] * test_constants.STREAM_LENGTH,110 [_REQUEST] * test_constants.STREAM_LENGTH))115 [_REQUEST] * test_constants.STREAM_LENGTH))116 self.assertSequenceEqual([_RESPONSE] * test_constants.STREAM_LENGTH,
22 from tests.unit.framework.common import test_constants72 for _ in range(test_constants.STREAM_LENGTH):219 requests = [b'\x07\x08' for _ in range(test_constants.STREAM_LENGTH)]229 requests = [b'\x07\x08' for _ in range(test_constants.STREAM_LENGTH)]239 requests = [b'\x77\x58' for _ in range(test_constants.STREAM_LENGTH)]250 test_constants.STREAM_LENGTH // 2, b'\x07\x08')257 for _ in range(test_constants.STREAM_LENGTH // 2 + 1):
20 from tests.unit.framework.common import test_constants97 b'\x07\x08' for _ in range(test_constants.STREAM_LENGTH))106 b'\x07\x08' for _ in range(test_constants.STREAM_LENGTH))116 b'\x07\x08' for _ in range(test_constants.STREAM_LENGTH))125 b'\x07\x08' for _ in range(test_constants.STREAM_LENGTH))
26 from tests.unit.framework.common import test_constants75 for _ in range(test_constants.STREAM_LENGTH):315 self._server_pool = logging_pool.pool(test_constants.THREAD_CONCURRENCY)355 b'\x07\x08' for _ in range(test_constants.STREAM_LENGTH))365 self.assertEqual(len(responses), 3 * test_constants.STREAM_LENGTH)375 self.assertEqual(len(responses), test_constants.STREAM_LENGTH)508 b'\x07\x08' for _ in range(test_constants.STREAM_LENGTH))531 b'\x07\x08' for _ in range(test_constants.STREAM_LENGTH))555 b'\x07\x08' for _ in range(test_constants.STREAM_LENGTH))578 b'\x77\x58' for _ in range(test_constants.STREAM_LENGTH))
22 from tests.unit.framework.common import test_constants68 for _ in range(test_constants.STREAM_LENGTH // 2):78 for _ in range(test_constants.STREAM_LENGTH // 2):88 for _ in range(test_constants.STREAM_LENGTH // 2):227 iter([REQUEST] * test_constants.STREAM_LENGTH))
20 from tests.unit.framework.common import test_constants51 ready_future.result(timeout=test_constants.SHORT_TIMEOUT)73 ready_future.result(timeout=test_constants.LONG_TIMEOUT))
23 from tests.unit.framework.common import test_constants100 max_workers=test_constants.THREAD_CONCURRENCY)146 for _ in range(test_constants.THREAD_CONCURRENCY))171 for _ in range(test_constants.THREAD_CONCURRENCY):
22 from tests.unit.framework.common import test_constants100 for _ in range(test_constants.STREAM_LENGTH // 2):140 for _ in range(test_constants.STREAM_LENGTH // 3):273 iter([_SERIALIZED_REQUEST] * test_constants.STREAM_LENGTH),292 iter([object()] * test_constants.STREAM_LENGTH),376 iter([_SERIALIZED_REQUEST] * test_constants.STREAM_LENGTH),404 iter([object()] * test_constants.STREAM_LENGTH),475 iter([_SERIALIZED_REQUEST] * test_constants.STREAM_LENGTH),497 iter([object()] * test_constants.STREAM_LENGTH),569 iter([_SERIALIZED_REQUEST] * test_constants.STREAM_LENGTH),[all …]
23 from tests.unit.framework.common import test_constants112 for _ in range(test_constants.STREAM_LENGTH):215 iter([_REQUEST] * test_constants.STREAM_LENGTH),227 iter([_REQUEST] * test_constants.STREAM_LENGTH),
21 from tests.unit.framework.common import test_constants70 time.sleep(test_constants.SHORT_TIMEOUT)98 time.sleep(test_constants.SHORT_TIMEOUT)
23 from tests.unit.framework.common import test_constants76 server_pool = logging_pool.pool(test_constants.THREAD_CONCURRENCY)
22 from tests.unit.framework.common import test_constants114 call = multi_callable(iter([request] * test_constants.STREAM_LENGTH))
21 from tests.unit.framework.common import test_constants34 _SUCCESSFUL_CALLS = int(test_constants.RPC_CONCURRENCY * _SUCCESS_CALL_FRACTION)35 _UNSUCCESSFUL_CALLS = test_constants.RPC_CONCURRENCY - _SUCCESSFUL_CALLS63 if self._state.parked_handlers == test_constants.THREAD_CONCURRENCY:95 for _ in range(test_constants.RPC_CONCURRENCY):103 if test_constants.RPC_CONCURRENCY <= state.handled_rpcs:144 test_constants.THREAD_CONCURRENCY)175 for index in range(test_constants.RPC_CONCURRENCY):201 if state.parked_handlers < test_constants.THREAD_CONCURRENCY:203 elif state.handled_rpcs < test_constants.RPC_CONCURRENCY:
21 from tests.unit.framework.common import test_constants43 for _ in range(test_constants.THREAD_CONCURRENCY))
25 from tests.unit.framework.common import test_constants162 thread_pool_size=test_constants.POOL_SIZE)180 thread_pool_size=test_constants.POOL_SIZE)186 self._server.stop(test_constants.SHORT_TIMEOUT).wait()193 test_constants.LONG_TIMEOUT,210 test_constants.LONG_TIMEOUT,228 test_constants.LONG_TIMEOUT,251 test_constants.SHORT_TIMEOUT,293 thread_pool_size=test_constants.POOL_SIZE)303 thread_pool_size=test_constants.POOL_SIZE)[all …]
21 from tests.unit.framework.common import test_constants43 test_constants.LONG_TIMEOUT,50 'grupe', 'mevvod', iter([b'def']), test_constants.LONG_TIMEOUT)
23 from tests.unit.framework.common import test_constants54 ready_future.result(timeout=test_constants.SHORT_TIMEOUT)76 ready_future.result(timeout=test_constants.LONG_TIMEOUT))
33 from tests.unit.framework.common import test_constants363 stub.UnaryCall(request, test_constants.LONG_TIMEOUT)374 response = stub.UnaryCall(request, test_constants.LONG_TIMEOUT)387 request, test_constants.LONG_TIMEOUT)400 request, test_constants.SHORT_TIMEOUT)423 request, test_constants.LONG_TIMEOUT)433 test_constants.LONG_TIMEOUT)448 request, test_constants.SHORT_TIMEOUT)459 test_constants.LONG_TIMEOUT)485 test_constants.LONG_TIMEOUT)[all …]
31 from tests.unit.framework.common import test_constants277 request, timeout=test_constants.SHORT_TIMEOUT)320 request, timeout=test_constants.SHORT_TIMEOUT)375 timeout=test_constants.SHORT_TIMEOUT)420 request_iterator, timeout=test_constants.SHORT_TIMEOUT)496 timeout=test_constants.SHORT_TIMEOUT)
4 define void @test_constants() { ret void }7 name: test_constants8 # CHECK-LABEL: name: test_constants
22 from tests.unit.framework.common import test_constants155 for _ in range(test_constants.THREAD_CONCURRENCY))169 outcomes = [None] * test_constants.RPC_CONCURRENCY177 for index in range(test_constants.RPC_CONCURRENCY):
7 def test_constants(): function
53 public void test_constants() { in test_constants() method in ErrorManagerTest