Home
last modified time | relevance | path

Searched refs:STREAM_LENGTH (Results 1 – 17 of 17) sorted by relevance

/third_party/grpc/src/python/grpcio_tests/tests/unit/
D_rpc_test_helpers.py88 for _ in range(test_constants.STREAM_LENGTH):
100 for _ in range(test_constants.STREAM_LENGTH):
266 for _ in range(test_constants.STREAM_LENGTH // 2):
272 b'\x67\x88' for _ in range(test_constants.STREAM_LENGTH))
279 for _ in range(test_constants.STREAM_LENGTH // 2):
284 b'\x67\x88' for _ in range(test_constants.STREAM_LENGTH))
291 for _ in range(test_constants.STREAM_LENGTH):
293 for _ in range(test_constants.STREAM_LENGTH):
323 b'\x07\x08' for _ in range(test_constants.STREAM_LENGTH))
357 b'\x67\x18' for _ in range(test_constants.STREAM_LENGTH))
[all …]
D_empty_message_test.py37 for _ in range(test_constants.STREAM_LENGTH):
107 self.assertSequenceEqual([_RESPONSE] * test_constants.STREAM_LENGTH,
112 [_REQUEST] * test_constants.STREAM_LENGTH))
117 [_REQUEST] * test_constants.STREAM_LENGTH))
118 self.assertSequenceEqual([_RESPONSE] * test_constants.STREAM_LENGTH,
D_rpc_test.py89 for _ in range(test_constants.STREAM_LENGTH):
101 for _ in range(test_constants.STREAM_LENGTH):
326 b'\x07\x08' for _ in range(test_constants.STREAM_LENGTH))
341 b'\x07\x08' for _ in range(test_constants.STREAM_LENGTH))
358 b'\x07\x08' for _ in range(test_constants.STREAM_LENGTH))
375 b'\x77\x58' for _ in range(test_constants.STREAM_LENGTH))
411 b'\x07\x08' for _ in range(test_constants.STREAM_LENGTH))
434 b'\x07\x08' for _ in range(test_constants.STREAM_LENGTH))
554 b'\x07\x08' for _ in range(test_constants.STREAM_LENGTH))
641 b'\x07\x08' for _ in range(test_constants.STREAM_LENGTH))
[all …]
D_invalid_metadata_test.py99 b'\x07\x08' for _ in range(test_constants.STREAM_LENGTH))
108 b'\x07\x08' for _ in range(test_constants.STREAM_LENGTH))
118 b'\x07\x08' for _ in range(test_constants.STREAM_LENGTH))
127 b'\x07\x08' for _ in range(test_constants.STREAM_LENGTH))
D_metadata_flags_test.py45 for _ in range(test_constants.STREAM_LENGTH):
143 iter([_REQUEST] * test_constants.STREAM_LENGTH),
150 iter([_REQUEST] * test_constants.STREAM_LENGTH),
157 iter([_REQUEST] * test_constants.STREAM_LENGTH),
165 iter([_REQUEST] * test_constants.STREAM_LENGTH),
D_rpc_part_1_test.py37 b'\x07\x08' for _ in range(test_constants.STREAM_LENGTH))
59 b'\x07\x18' for _ in range(test_constants.STREAM_LENGTH))
150 b'\x47\x58' for _ in range(test_constants.STREAM_LENGTH))
166 b'\x07\x18' for _ in range(test_constants.STREAM_LENGTH))
213 b'\x07\x18' for _ in range(test_constants.STREAM_LENGTH))
D_metadata_code_details_test.py101 for _ in range(test_constants.STREAM_LENGTH // 2):
141 for _ in range(test_constants.STREAM_LENGTH // 3):
278 iter([_SERIALIZED_REQUEST] * test_constants.STREAM_LENGTH),
296 [object()] * test_constants.STREAM_LENGTH),
379 test_constants.STREAM_LENGTH),
407 iter([object()] * test_constants.STREAM_LENGTH),
478 test_constants.STREAM_LENGTH),
500 [object()] * test_constants.STREAM_LENGTH),
572 test_constants.STREAM_LENGTH),
595 [object()] * test_constants.STREAM_LENGTH),
[all …]
D_interceptor_test.py87 for _ in range(test_constants.STREAM_LENGTH):
387 b'\x07\x08' for _ in range(test_constants.STREAM_LENGTH))
397 self.assertEqual(len(responses), 3 * test_constants.STREAM_LENGTH)
407 self.assertEqual(len(responses), test_constants.STREAM_LENGTH)
574 b'\x07\x08' for _ in range(test_constants.STREAM_LENGTH))
595 b'\x07\x08' for _ in range(test_constants.STREAM_LENGTH))
617 b'\x07\x08' for _ in range(test_constants.STREAM_LENGTH))
638 _EXCEPTION_REQUEST for _ in range(test_constants.STREAM_LENGTH))
662 b'\x77\x58' for _ in range(test_constants.STREAM_LENGTH))
683 _EXCEPTION_REQUEST for _ in range(test_constants.STREAM_LENGTH))
D_rpc_part_2_test.py110 b'\x07\x08' for _ in range(test_constants.STREAM_LENGTH))
125 b'\x07\x08' for _ in range(test_constants.STREAM_LENGTH))
142 b'\x07\x08' for _ in range(test_constants.STREAM_LENGTH))
159 b'\x77\x58' for _ in range(test_constants.STREAM_LENGTH))
195 b'\x07\x08' for _ in range(test_constants.STREAM_LENGTH))
218 b'\x07\x08' for _ in range(test_constants.STREAM_LENGTH))
338 b'\x07\x08' for _ in range(test_constants.STREAM_LENGTH))
D_exit_scenarios.py69 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):
230 iter([REQUEST] * test_constants.STREAM_LENGTH))
D_metadata_test.py113 for _ in range(test_constants.STREAM_LENGTH):
217 iter([_REQUEST] * test_constants.STREAM_LENGTH),
228 call = multi_callable(iter([_REQUEST] * test_constants.STREAM_LENGTH),
D_invocation_defects_test.py51 for _ in range(test_constants.STREAM_LENGTH):
238 test_constants.STREAM_LENGTH // 2, b'\x07\x08')
245 for _ in range(test_constants.STREAM_LENGTH // 2 + 1):
D_resource_exhausted_test.py75 for _ in range(test_constants.STREAM_LENGTH):
206 request = iter([_REQUEST] * test_constants.STREAM_LENGTH)
233 request = iter([_REQUEST] * test_constants.STREAM_LENGTH)
D_compression_test.py38 _STREAM_LENGTH = test_constants.STREAM_LENGTH // 16
/third_party/grpc/src/python/grpcio_tests/tests/unit/framework/common/
Dtest_constants.py31 STREAM_LENGTH = 200 variable
/third_party/grpc/src/python/grpcio_tests/tests/channelz/
D_channelz_servicer_test.py114 iter([_REQUEST] * test_constants.STREAM_LENGTH))
118 self.assertEqual(cnt, test_constants.STREAM_LENGTH)
383 test_constants.STREAM_LENGTH)
385 test_constants.STREAM_LENGTH)
/third_party/grpc/src/python/grpcio_tests/tests_aio/channelz/
Dchannelz_servicer_test.py166 [_REQUEST] * test_constants.STREAM_LENGTH))
170 self.assertEqual(cnt, test_constants.STREAM_LENGTH)
395 test_constants.STREAM_LENGTH)
397 test_constants.STREAM_LENGTH)