/third_party/grpc/src/python/grpcio_tests/tests_aio/unit/ |
D | wait_for_ready_test.py | 36 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.py | 110 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.py | 214 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.py | 874 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__.py | 680 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/ |
D | resolver_result_parsing.h | 93 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
|
D | resolver_result_parsing.cc | 361 absl::optional<bool> wait_for_ready; in ParsePerMethodParams() local
|
/third_party/grpc/examples/python/wait_for_ready/ |
D | wait_for_ready_example.py | 58 def process(stub, wait_for_ready=None): argument
|
/third_party/grpc/src/python/grpcio/grpc/_cython/_cygrpc/ |
D | metadata.pyx.pxi | 20 wait_for_ready = GRPC_INITIAL_METADATA_WAIT_FOR_READY variable in InitialMetadataFlags
|
/third_party/grpc/test/core/end2end/ |
D | no_server_test.cc | 32 void run_test(bool wait_for_ready) { in run_test()
|
D | connection_refused_test.cc | 38 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/ |
D | call.pyx.pxi | 33 cdef int _get_send_initial_metadata_flags(object wait_for_ready) except *: 48 bytes method, CallCredentials call_credentials, object wait_for_ready):
|
D | channel.pyx.pxi | 116 object wait_for_ready):
|
/third_party/gstreamer/gstplugins_bad/tests/check/libs/ |
D | vkimage.c | 158 wait_for_ready (GstHarnessThread * thread, struct view_stress *stress) in wait_for_ready() function
|
/third_party/grpc/include/grpcpp/impl/codegen/ |
D | client_context_impl.h | 281 void set_wait_for_ready(bool wait_for_ready) { in set_wait_for_ready()
|
D | client_context.h | 289 void set_wait_for_ready(bool wait_for_ready) { in set_wait_for_ready()
|
/third_party/grpc/test/cpp/end2end/ |
D | service_config_end2end_test.cc | 260 Status* result = nullptr, bool wait_for_ready = false) { in SendRpc() 276 const grpc_core::DebugLocation& location, bool wait_for_ready = false) { in CheckRpcSendOk()
|
D | flaky_network_test.cc | 208 int timeout_ms = 0, bool wait_for_ready = false) { in SendRpc()
|
D | grpclb_end2end_test.cc | 631 bool wait_for_ready = false, in SendRpc() 651 bool wait_for_ready = false) { in CheckRpcSendOk()
|
D | client_lb_end2end_test.cc | 293 Status* result = nullptr, bool wait_for_ready = false) { in SendRpc() 313 const grpc_core::DebugLocation& location, bool wait_for_ready = false) { in CheckRpcSendOk()
|
D | xds_end2end_test.cc | 1244 bool wait_for_ready = false; member
|