Home
last modified time | relevance | path

Searched refs:wait_for_ready (Results 1 – 25 of 50) sorted by relevance

12

/third_party/grpc/src/python/grpcio_tests/tests/unit/
D_metadata_flags_test.py110 def perform_unary_unary_call(channel, wait_for_ready=None): argument
114 wait_for_ready=wait_for_ready)
117 def perform_unary_unary_with_call(channel, wait_for_ready=None): argument
121 wait_for_ready=wait_for_ready)
124 def perform_unary_unary_future(channel, wait_for_ready=None): argument
128 wait_for_ready=wait_for_ready).result(
132 def perform_unary_stream_call(channel, wait_for_ready=None): argument
136 wait_for_ready=wait_for_ready)
141 def perform_stream_unary_call(channel, wait_for_ready=None): argument
145 wait_for_ready=wait_for_ready)
[all …]
D_signal_client.py59 wait_for_ready=True)
70 _MESSAGE, wait_for_ready=True)
80 channel.unary_unary(UNARY_UNARY)(_MESSAGE, wait_for_ready=True)
94 wait_for_ready=True):
D_local_credentials_test.py53 wait_for_ready=True))
72 wait_for_ready=True))
D_xds_credentials_test.py71 request, wait_for_ready=True)
86 request, wait_for_ready=True)
/third_party/grpc/src/python/grpcio/grpc/
D_interceptor.py76 wait_for_ready = call_details.wait_for_ready
78 wait_for_ready = default_details.wait_for_ready
85 return method, timeout, metadata, credentials, wait_for_ready, compression
214 wait_for_ready=None, argument
220 wait_for_ready=wait_for_ready,
229 wait_for_ready=None, argument
233 wait_for_ready, compression)
246 wait_for_ready=new_wait_for_ready,
264 wait_for_ready=None, argument
270 wait_for_ready=wait_for_ready,
[all …]
D_simple_stubs.py180 wait_for_ready: Optional[bool] = None,
241 wait_for_ready = wait_for_ready if wait_for_ready is not None else True
244 wait_for_ready=wait_for_ready,
261 wait_for_ready: Optional[bool] = None,
321 wait_for_ready = wait_for_ready if wait_for_ready is not None else True
324 wait_for_ready=wait_for_ready,
341 wait_for_ready: Optional[bool] = None,
401 wait_for_ready = wait_for_ready if wait_for_ready is not None else True
404 wait_for_ready=wait_for_ready,
421 wait_for_ready: Optional[bool] = None,
[all …]
D_channel.py874 def _prepare(self, request, timeout, metadata, wait_for_ready, compression): argument
878 wait_for_ready)
896 def _blocking(self, request, timeout, metadata, credentials, wait_for_ready, argument
899 request, timeout, metadata, wait_for_ready, compression)
919 wait_for_ready=None, argument
922 wait_for_ready, compression)
930 wait_for_ready=None, argument
933 wait_for_ready, compression)
941 wait_for_ready=None, argument
944 request, timeout, metadata, wait_for_ready, compression)
[all …]
D__init__.py680 wait_for_ready=None, argument
713 wait_for_ready=None, argument
746 wait_for_ready=None, argument
782 wait_for_ready=None, argument
817 wait_for_ready=None, argument
851 wait_for_ready=None, argument
885 wait_for_ready=None, argument
921 wait_for_ready=None, argument
/third_party/grpc/src/python/grpcio_tests/tests_aio/unit/
Dwait_for_ready_test.py36 async def _perform_unary_unary(stub, wait_for_ready): argument
39 wait_for_ready=wait_for_ready)
42 async def _perform_unary_stream(stub, wait_for_ready): argument
50 wait_for_ready=wait_for_ready)
57 async def _perform_stream_unary(stub, wait_for_ready): argument
67 wait_for_ready=wait_for_ready)
70 async def _perform_stream_stream(stub, wait_for_ready): argument
72 wait_for_ready=wait_for_ready)
106 async def _connection_fails_fast(self, wait_for_ready): argument
110 await action(self._stub, wait_for_ready)
Dclient_unary_unary_interceptor_test.py137 wait_for_ready=client_call_details.wait_for_ready)
179 wait_for_ready=client_call_details.wait_for_ready)
194 wait_for_ready=client_call_details.wait_for_ready)
562 wait_for_ready=client_call_details.wait_for_ready,
/third_party/grpc/examples/python/wait_for_ready/
Dwait_for_ready_example.py58 def process(stub, wait_for_ready=None): argument
61 wait_for_ready=wait_for_ready)
65 assert not wait_for_ready
68 assert wait_for_ready
70 "enabled" if wait_for_ready else "disabled", message)
/third_party/grpc/src/python/grpcio/grpc/experimental/aio/
D_interceptor.py88 wait_for_ready: Optional[bool]
562 wait_for_ready: Optional[bool], channel: cygrpc.AioChannel,
570 wait_for_ready, request, request_serializer,
579 wait_for_ready: Optional[bool], request: RequestType,
608 client_call_details.wait_for_ready, self._channel,
613 credentials, wait_for_ready)
634 wait_for_ready: Optional[bool], channel: cygrpc.AioChannel,
644 wait_for_ready, request, request_serializer,
653 wait_for_ready: Optional[bool], request: RequestType,
686 client_call_details.wait_for_ready, self._channel,
[all …]
D_channel.py114 wait_for_ready: Optional[bool] = None,
121 metadata, credentials, wait_for_ready,
128 wait_for_ready, self._channel, self._method,
144 wait_for_ready: Optional[bool] = None,
153 wait_for_ready, self._channel, self._method,
159 wait_for_ready, self._channel, self._method,
174 wait_for_ready: Optional[bool] = None,
183 credentials, wait_for_ready, self._channel,
189 credentials, wait_for_ready, self._channel, self._method,
204 wait_for_ready: Optional[bool] = None,
[all …]
D_base_channel.py37 wait_for_ready: Optional[bool] = None,
75 wait_for_ready: Optional[bool] = None,
112 wait_for_ready: Optional[bool] = None,
150 wait_for_ready: Optional[bool] = None,
D_call.py479 wait_for_ready: Optional[bool], channel: cygrpc.AioChannel,
484 channel.call(method, deadline, credentials, wait_for_ready),
528 wait_for_ready: Optional[bool], channel: cygrpc.AioChannel,
533 channel.call(method, deadline, credentials, wait_for_ready),
568 wait_for_ready: Optional[bool], channel: cygrpc.AioChannel,
573 channel.call(method, deadline, credentials, wait_for_ready),
606 wait_for_ready: Optional[bool], channel: cygrpc.AioChannel,
611 channel.call(method, deadline, credentials, wait_for_ready),
/third_party/grpc/src/python/grpcio/grpc/aio/
D_interceptor.py88 wait_for_ready: Optional[bool]
561 wait_for_ready: Optional[bool], channel: cygrpc.AioChannel,
569 wait_for_ready, request, request_serializer,
579 wait_for_ready: Optional[bool], request: RequestType,
607 client_call_details.wait_for_ready, self._channel,
612 credentials, wait_for_ready)
633 wait_for_ready: Optional[bool], channel: cygrpc.AioChannel,
643 wait_for_ready, request, request_serializer,
653 wait_for_ready: Optional[bool], request: RequestType,
685 client_call_details.wait_for_ready, self._channel,
[all …]
D_channel.py115 wait_for_ready: Optional[bool] = None,
122 metadata, credentials, wait_for_ready,
129 wait_for_ready, self._channel, self._method,
146 wait_for_ready: Optional[bool] = None,
155 wait_for_ready, self._channel, self._method,
161 wait_for_ready, self._channel, self._method,
177 wait_for_ready: Optional[bool] = None,
186 credentials, wait_for_ready, self._channel,
192 credentials, wait_for_ready, self._channel, self._method,
208 wait_for_ready: Optional[bool] = None,
[all …]
D_base_channel.py38 wait_for_ready: Optional[bool] = None,
77 wait_for_ready: Optional[bool] = None,
115 wait_for_ready: Optional[bool] = None,
154 wait_for_ready: Optional[bool] = None,
D_call.py478 wait_for_ready: Optional[bool], channel: cygrpc.AioChannel,
483 channel.call(method, deadline, credentials, wait_for_ready),
527 wait_for_ready: Optional[bool], channel: cygrpc.AioChannel,
532 channel.call(method, deadline, credentials, wait_for_ready),
567 wait_for_ready: Optional[bool], channel: cygrpc.AioChannel,
572 channel.call(method, deadline, credentials, wait_for_ready),
605 wait_for_ready: Optional[bool], channel: cygrpc.AioChannel,
610 channel.call(method, deadline, credentials, wait_for_ready),
/third_party/grpc/test/core/end2end/
Dconnection_refused_test.cc38 static void run_test(bool wait_for_ready, bool use_service_config) { in run_test() argument
50 wait_for_ready, use_service_config); in run_test()
62 GPR_ASSERT(wait_for_ready); in run_test()
94 op->flags = (wait_for_ready && !use_service_config) in run_test()
113 if (wait_for_ready) { in run_test()
Dno_server_test.cc32 void run_test(bool wait_for_ready) { in run_test() argument
33 gpr_log(GPR_INFO, "TEST: wait_for_ready=%d", wait_for_ready); in run_test()
60 op->flags = wait_for_ready ? GRPC_INITIAL_METADATA_WAIT_FOR_READY : 0; in run_test()
88 if (wait_for_ready) { in run_test()
/third_party/grpc/src/core/ext/filters/client_channel/
Dresolver_result_parsing.h93 const absl::optional<bool>& wait_for_ready, in ClientChannelMethodParsedConfig() argument
96 wait_for_ready_(wait_for_ready), in ClientChannelMethodParsedConfig()
101 absl::optional<bool> wait_for_ready() const { return wait_for_ready_; } in wait_for_ready() function
Dresolver_result_parsing.cc361 absl::optional<bool> wait_for_ready; in ParsePerMethodParams() local
368 wait_for_ready.emplace(true); in ParsePerMethodParams()
370 wait_for_ready.emplace(false); in ParsePerMethodParams()
391 timeout, wait_for_ready, std::move(retry_policy)); in ParsePerMethodParams()
/third_party/grpc/examples/python/cancellation/
Dclient.py39 wait_for_ready=True)
58 wait_for_ready=True)
/third_party/grpc/examples/python/wait_for_ready/test/
D_wait_for_ready_example_test.py19 from examples.python.wait_for_ready import wait_for_ready_example

12