Home
last modified time | relevance | path

Searched refs:_REQUEST (Results 1 – 25 of 30) sorted by relevance

12

/third_party/grpc/src/python/grpcio_tests/tests_aio/unit/
Dserver_test.py46 _REQUEST = b'\x00\x00\x00' variable
129 assert _REQUEST == request
136 assert _REQUEST == await context.read()
140 assert _REQUEST == await context.read()
143 assert _REQUEST == request
151 assert _REQUEST == request
160 assert _REQUEST == await context.read()
165 assert _REQUEST == await context.read()
168 assert _REQUEST == request
178 assert _REQUEST == request
[all …]
Dtimeout_test.py36 _REQUEST = b'\x00\x00\x00' variable
52 assert _REQUEST == await context.read()
54 assert _REQUEST == await context.read()
59 assert _REQUEST == await context.read()
106 call = multicallable(_REQUEST, timeout=2 * _SLEEP_TIME_UNIT_S)
112 call = multicallable(_REQUEST, timeout=0.5 * _SLEEP_TIME_UNIT_S)
122 call = multicallable(_REQUEST, timeout=2 * _SLEEP_TIME_UNIT_S)
129 call = multicallable(_REQUEST, timeout=0.5 * _SLEEP_TIME_UNIT_S)
141 await call.write(_REQUEST)
142 await call.write(_REQUEST)
[all …]
Dmetadata_test.py37 _REQUEST = b'\x00\x00\x00' variable
102 assert _REQUEST == request
109 assert _REQUEST == request
116 assert _REQUEST == request
122 assert _REQUEST == request
138 assert _REQUEST == request
151 assert _REQUEST == request
164 assert _REQUEST == request
196 call = multicallable(_REQUEST,
203 call = multicallable(_REQUEST)
[all …]
Dcompression_test.py39 _REQUEST = b'\x01' * 100 variable
48 assert _REQUEST == await context.read()
65 assert _REQUEST == request
72 assert _REQUEST == await context.read()
122 call = multicallable(_REQUEST)
133 call = multicallable(_REQUEST)
140 call = multicallable(_REQUEST, compression=grpc.Compression.Gzip)
150 call = multicallable(_REQUEST, compression=grpc.Compression.Deflate)
156 await call.write(_REQUEST)
164 call = multicallable(_REQUEST)
[all …]
Dcompatibility_test.py37 _REQUEST = b'\x03\x07' variable
243 response = await self._async_channel.unary_unary(_ADHOC_METHOD)(_REQUEST
245 self.assertEqual(_REQUEST, response)
256 call = self._async_channel.unary_unary(_ADHOC_METHOD)(_REQUEST)
269 await self._async_channel.unary_unary(_ADHOC_METHOD)(_REQUEST)
281 await self._async_channel.unary_unary(_ADHOC_METHOD)(_REQUEST)
293 call = self._async_channel.unary_stream(_ADHOC_METHOD)(_REQUEST)
295 self.assertEqual(_REQUEST, response)
306 call = self._async_channel.unary_stream(_ADHOC_METHOD)(_REQUEST)
309 self.assertEqual(_REQUEST, response)
[all …]
Dcontext_peer_test.py31 _REQUEST = b'\x03\x07' variable
42 self.assertEqual(_REQUEST, request)
57 response = await channel.unary_unary(_TEST_METHOD)(_REQUEST)
58 self.assertEqual(_REQUEST, response)
Dabort_test.py31 _REQUEST = b'\x00\x00\x00' variable
99 call = method(_REQUEST)
113 call = method(_REQUEST)
124 call = method(_REQUEST)
135 call = method(_REQUEST)
Dauth_context_test.py28 _REQUEST = b'\x00\x00\x00' variable
76 response = await channel.unary_unary(_UNARY_UNARY)(_REQUEST)
100 response = await channel.unary_unary(_UNARY_UNARY)(_REQUEST)
136 response = await channel.unary_unary(_UNARY_UNARY)(_REQUEST)
153 response = await channel.unary_unary(_UNARY_UNARY)(_REQUEST)
Dwait_for_connection_test.py31 _REQUEST = b'\x01\x02\x03' variable
125 call = self._dummy_channel.unary_unary(_TEST_METHOD)(_REQUEST)
133 call = self._dummy_channel.unary_stream(_TEST_METHOD)(_REQUEST)
/third_party/grpc/src/python/grpcio_tests/tests_py3_only/unit/
D_simple_stubs_test.py44 _REQUEST = b"0000" variable
187 _REQUEST,
193 self.assertEqual(_REQUEST, response)
199 _REQUEST,
204 self.assertEqual(_REQUEST, response)
210 args = (_REQUEST, target, _UNARY_UNARY)
224 _REQUEST,
243 _REQUEST,
259 _REQUEST,
263 self.assertEqual(_REQUEST, response)
[all …]
D_leak_test.py31 _REQUEST = b'\x23\x33' variable
72 response = multicallable(_REQUEST)
73 assert _REQUEST == response
/third_party/grpc/examples/python/data_transmission/
Ddemo_pb2.py29 _REQUEST = _descriptor.Descriptor( variable
104 DESCRIPTOR.message_types_by_name['Request'] = _REQUEST
109 'DESCRIPTOR' : _REQUEST,
138 input_type=_REQUEST,
147 input_type=_REQUEST,
156 input_type=_REQUEST,
165 input_type=_REQUEST,
/third_party/grpc/src/python/grpcio_tests/tests/unit/
D_resource_exhausted_test.py27 _REQUEST = b'\x00\x00\x00' variable
157 futures.append(multi_callable.future(_REQUEST))
162 multi_callable(_REQUEST)
167 future_exception = multi_callable.future(_REQUEST)
176 self.assertEqual(_RESPONSE, multi_callable(_REQUEST))
182 calls.append(multi_callable(_REQUEST))
187 next(multi_callable(_REQUEST))
199 new_call = multi_callable(_REQUEST)
206 request = iter([_REQUEST] * test_constants.STREAM_LENGTH)
233 request = iter([_REQUEST] * test_constants.STREAM_LENGTH)
D_metadata_flags_test.py36 _REQUEST = b'\x00\x00\x00' variable
112 _REQUEST,
119 _REQUEST,
126 _REQUEST,
134 _REQUEST,
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_empty_message_test.py23 _REQUEST = b'' variable
102 response = self._channel.unary_unary(_UNARY_UNARY)(_REQUEST)
106 response_iterator = self._channel.unary_stream(_UNARY_STREAM)(_REQUEST)
112 [_REQUEST] * test_constants.STREAM_LENGTH))
117 [_REQUEST] * test_constants.STREAM_LENGTH))
D_abort_test.py31 _REQUEST = b'\x00\x00\x00' variable
109 self._channel.unary_unary(_ABORT)(_REQUEST)
126 self._channel.unary_unary(_ABORT)(_REQUEST)
136 self._channel.unary_unary(_ABORT_WITH_STATUS)(_REQUEST)
145 self._channel.unary_unary(_INVALID_CODE)(_REQUEST)
D_dns_resolver_test.py25 _REQUEST = b'\x00\x00\x00' variable
26 _RESPONSE = _REQUEST
56 _REQUEST,
D_auth_context_test.py28 _REQUEST = b'\x00\x00\x00' variable
75 response = channel.unary_unary(_UNARY_UNARY)(_REQUEST)
99 response = channel.unary_unary(_UNARY_UNARY)(_REQUEST)
135 response = channel.unary_unary(_UNARY_UNARY)(_REQUEST)
152 response = channel.unary_unary(_UNARY_UNARY)(_REQUEST)
D_reconnect_test.py27 _REQUEST = b'\x00\x00\x00' variable
53 self.assertEqual(_RESPONSE, multi_callable(_REQUEST))
62 self.assertEqual(_RESPONSE, multi_callable(_REQUEST))
D_metadata_test.py29 _REQUEST = b'\x00\x00\x00' variable
194 _REQUEST, metadata=_INVOCATION_METADATA)
204 call = multi_callable(_REQUEST, metadata=_INVOCATION_METADATA)
217 iter([_REQUEST] * test_constants.STREAM_LENGTH),
228 call = multi_callable(iter([_REQUEST] * test_constants.STREAM_LENGTH),
D_contextvars_propagation_test.py27 _REQUEST = b"0000" variable
112 response = stub(_REQUEST, wait_for_ready=True)
113 self.assertEqual(_REQUEST, response)
D_compression_test.py42 _REQUEST = b'\x00' * 100 variable
244 requests = (_REQUEST for _ in range(_STREAM_LENGTH))
309 multicallable_kwargs, server_kwargs, server_handler, _REQUEST)
327 server_kwargs, _GenericHandler(disable_next_compression), _REQUEST)
336 server_kwargs, _GenericHandler(disable_first_compression), _REQUEST)
/third_party/grpc/src/python/grpcio_tests/tests_aio/status/
Dgrpc_status_test.py34 _REQUEST = b'\x00\x00\x00' variable
119 call = self._channel.unary_unary(_STATUS_OK)(_REQUEST)
126 call = self._channel.unary_unary(_STATUS_NOT_OK)(_REQUEST)
137 call = self._channel.unary_unary(_ERROR_DETAILS)(_REQUEST)
154 call = self._channel.unary_unary(_INCONSISTENT)(_REQUEST)
166 await self._channel.unary_unary(_INVALID_CODE)(_REQUEST)
/third_party/grpc/src/python/grpcio_tests/tests/status/
D_grpc_status_test.py43 _REQUEST = b'\x00\x00\x00' variable
128 _, call = self._channel.unary_unary(_STATUS_OK).with_call(_REQUEST)
136 self._channel.unary_unary(_STATUS_NOT_OK).with_call(_REQUEST)
146 self._channel.unary_unary(_ERROR_DETAILS).with_call(_REQUEST)
162 self._channel.unary_unary(_INCONSISTENT).with_call(_REQUEST)
171 self._channel.unary_unary(_INVALID_CODE).with_call(_REQUEST)
/third_party/grpc/src/python/grpcio_tests/tests/unit/beta/
D_beta_features_test.py38 _REQUEST = b'abc' variable
195 _UNARY_UNARY)(_REQUEST,
212 _REQUEST,
228 request_iterator = _BlockingIterator(iter((_REQUEST,)))
251 request_iterator = _BlockingIterator(iter((_REQUEST,)))
328 _UNARY_UNARY)(_REQUEST,

12