Home
last modified time | relevance | path

Searched defs:wait_for_ready (Results 1 – 21 of 21) sorted by relevance

/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
42 async def _perform_unary_stream(stub, wait_for_ready): argument
57 async def _perform_stream_unary(stub, wait_for_ready): argument
70 async def _perform_stream_stream(stub, wait_for_ready): argument
106 async def _connection_fails_fast(self, wait_for_ready): argument
/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
117 def perform_unary_unary_with_call(channel, wait_for_ready=None): argument
124 def perform_unary_unary_future(channel, wait_for_ready=None): argument
132 def perform_unary_stream_call(channel, wait_for_ready=None): argument
141 def perform_stream_unary_call(channel, wait_for_ready=None): argument
148 def perform_stream_unary_with_call(channel, wait_for_ready=None): argument
155 def perform_stream_unary_future(channel, wait_for_ready=None): argument
163 def perform_stream_stream_call(channel, wait_for_ready=None): argument
182 def check_connection_does_failfast(self, fn, channel, wait_for_ready=None): argument
/third_party/grpc/src/python/grpcio/grpc/
D_interceptor.py214 wait_for_ready=None, argument
229 wait_for_ready=None, argument
264 wait_for_ready=None, argument
278 wait_for_ready=None, argument
316 wait_for_ready=None, argument
353 wait_for_ready=None, argument
368 wait_for_ready=None, argument
403 wait_for_ready=None, argument
417 wait_for_ready=None, argument
455 wait_for_ready=None, argument
D_channel.py874 def _prepare(self, request, timeout, metadata, wait_for_ready, compression): argument
896 def _blocking(self, request, timeout, metadata, credentials, wait_for_ready, argument
919 wait_for_ready=None, argument
930 wait_for_ready=None, argument
941 wait_for_ready=None, argument
976 wait_for_ready=None, argument
1027 wait_for_ready=None, argument
1075 wait_for_ready, compression): argument
1104 wait_for_ready=None, argument
1115 wait_for_ready=None, argument
[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/core/ext/filters/client_channel/
Dresolver_result_parsing.h93 const absl::optional<bool>& 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
/third_party/grpc/examples/python/wait_for_ready/
Dwait_for_ready_example.py58 def process(stub, wait_for_ready=None): argument
/third_party/grpc/src/python/grpcio/grpc/_cython/_cygrpc/
Dmetadata.pyx.pxi20 wait_for_ready = GRPC_INITIAL_METADATA_WAIT_FOR_READY variable in InitialMetadataFlags
/third_party/grpc/test/core/end2end/
Dno_server_test.cc32 void run_test(bool wait_for_ready) { in run_test()
Dconnection_refused_test.cc38 static void run_test(bool wait_for_ready, bool use_service_config) { in run_test()
/third_party/grpc/src/python/grpcio/grpc/_cython/_cygrpc/aio/
Dcall.pyx.pxi33 cdef int _get_send_initial_metadata_flags(object wait_for_ready) except *:
48 bytes method, CallCredentials call_credentials, object wait_for_ready):
Dchannel.pyx.pxi116 object wait_for_ready):
/third_party/gstreamer/gstplugins_bad/tests/check/libs/
Dvkimage.c158 wait_for_ready (GstHarnessThread * thread, struct view_stress *stress) in wait_for_ready() function
/third_party/grpc/include/grpcpp/impl/codegen/
Dclient_context_impl.h281 void set_wait_for_ready(bool wait_for_ready) { in set_wait_for_ready()
Dclient_context.h289 void set_wait_for_ready(bool wait_for_ready) { in set_wait_for_ready()
/third_party/grpc/test/cpp/end2end/
Dservice_config_end2end_test.cc260 Status* result = nullptr, bool wait_for_ready = false) { in SendRpc()
276 const grpc_core::DebugLocation& location, bool wait_for_ready = false) { in CheckRpcSendOk()
Dflaky_network_test.cc208 int timeout_ms = 0, bool wait_for_ready = false) { in SendRpc()
Dgrpclb_end2end_test.cc631 bool wait_for_ready = false, in SendRpc()
651 bool wait_for_ready = false) { in CheckRpcSendOk()
Dclient_lb_end2end_test.cc293 Status* result = nullptr, bool wait_for_ready = false) { in SendRpc()
313 const grpc_core::DebugLocation& location, bool wait_for_ready = false) { in CheckRpcSendOk()
Dxds_end2end_test.cc1244 bool wait_for_ready = false; member