| /external/grpc-grpc/src/python/grpcio_tests/tests/unit/ |
| D | _channel_connectivity_test.py | 64 channel.subscribe(callback.update, try_to_connect=False)
66 channel.subscribe(callback.update, try_to_connect=True)
93 channel.subscribe(first_callback.update, try_to_connect=False)
100 channel.subscribe(second_callback.update, try_to_connect=True)
134 channel.subscribe(callback.update, try_to_connect=True)
|
| D | _exit_scenarios.py | 186 channel.subscribe(connectivity_callback, try_to_connect=True)
198 channel.subscribe(connectivity_callback, try_to_connect=True)
|
| /external/grpc-grpc/src/python/grpcio/grpc/ |
| D | _channel.py | 767 self.try_to_connect = False
774 self.try_to_connect = False
820 try_to_connect = initial_try_to_connect
821 connectivity = channel.check_connectivity_state(try_to_connect)
838 if not state.callbacks_and_connectivities and not state.try_to_connect:
842 try_to_connect = state.try_to_connect
843 state.try_to_connect = False
844 if event.success or try_to_connect:
845 connectivity = channel.check_connectivity_state(try_to_connect)
861 def _subscribe(state, callback, try_to_connect): argument
[all …]
|
| D | _interceptor.py | 400 def subscribe(self, callback, try_to_connect=False): argument
401 self._channel.subscribe(callback, try_to_connect=try_to_connect)
|
| D | _utilities.py | 155 self._channel.subscribe(self._update, try_to_connect=True)
|
| D | __init__.py | 823 def subscribe(self, callback, try_to_connect=False): argument
|
| /external/grpc-grpc/src/php/lib/Grpc/ |
| D | BaseStub.php | 128 * @param bool $try_to_connect (optional)
132 public function getConnectivityState($try_to_connect = false) argument
134 return $this->channel->getConnectivityState($try_to_connect);
|
| /external/grpc-grpc/src/php/lib/Grpc/Internal/ |
| D | InterceptorChannel.php | 67 public function getConnectivityState($try_to_connect = false) argument
69 return $this->getNext()->getConnectivityState($try_to_connect);
|
| /external/grpc-grpc/src/python/grpcio/grpc/beta/ |
| D | implementations.py | 77 def subscribe(self, callback, try_to_connect=None): argument
90 self._channel.subscribe(callback, try_to_connect=try_to_connect)
|
| D | utilities.py | 124 self._channel.subscribe(self._update, try_to_connect=True)
|
| /external/grpc-grpc/src/core/ext/filters/client_channel/ |
| D | channel_connectivity.cc | 34 grpc_channel* channel, int try_to_connect) { in grpc_channel_check_connectivity_state() argument
42 (channel, try_to_connect)); in grpc_channel_check_connectivity_state()
45 try_to_connect); in grpc_channel_check_connectivity_state()
|
| D | client_channel.h | 48 grpc_channel_element* elem, int try_to_connect);
|
| /external/grpc-grpc/src/cpp/client/ |
| D | channel_cc.cc | 154 grpc_connectivity_state Channel::GetState(bool try_to_connect) { in GetState() argument
155 return grpc_channel_check_connectivity_state(c_channel_, try_to_connect); in GetState()
|
| /external/grpc-grpc/src/php/ext/grpc/ |
| D | channel.c | 473 bool try_to_connect = false; in PHP_METHOD() local
475 if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "|b", &try_to_connect) in PHP_METHOD()
483 (int)try_to_connect); in PHP_METHOD()
707 ZEND_ARG_INFO(0, try_to_connect)
|
| /external/grpc-grpc/src/python/grpcio_testing/grpc_testing/_channel/ |
| D | _channel.py | 29 def subscribe(self, callback, try_to_connect=False): argument
|
| /external/grpc-grpc/include/grpcpp/ |
| D | channel.h | 51 grpc_connectivity_state GetState(bool try_to_connect) override;
|
| /external/grpc-grpc/src/ruby/ext/grpc/ |
| D | rb_channel.c | 267 int try_to_connect; member
280 stack->try_to_connect); in get_state_without_gil()
312 stack.try_to_connect = RTEST(try_to_connect_param) ? 1 : 0; in grpc_rb_channel_get_connectivity_state()
|
| D | rb_grpc_imports.generated.h | 134 …vity_state(*grpc_channel_check_connectivity_state_type)(grpc_channel* channel, int try_to_connect);
|
| /external/grpc-grpc/include/grpcpp/impl/codegen/ |
| D | channel_interface.h | 62 virtual grpc_connectivity_state GetState(bool try_to_connect) = 0;
|
| /external/grpc-grpc/test/core/end2end/fuzzers/ |
| D | api_fuzzer.cc | 874 uint8_t try_to_connect = grpc_fuzzer_get_next_byte(&inp); in LLVMFuzzerTestOneInput() local
875 if (try_to_connect == 0 || try_to_connect == 1) { in LLVMFuzzerTestOneInput()
876 grpc_channel_check_connectivity_state(g_channel, try_to_connect); in LLVMFuzzerTestOneInput()
|
| /external/grpc-grpc/include/grpc/ |
| D | grpc.h | 185 grpc_channel* channel, int try_to_connect);
|
| /external/grpc-grpc/doc/ |
| D | connectivity-semantics-and-api.md | 119 for one of the five legal states. It also accepts a boolean `try_to_connect` to
124 grpc_connectivity_state GetState(bool try_to_connect);
|
| /external/grpc-grpc/src/python/grpcio/grpc/_cython/_cygrpc/ |
| D | channel.pyx.pxi | 469 def check_connectivity_state(self, bint try_to_connect): argument
473 self._state.c_channel, try_to_connect)
|
| D | grpc.pxi | 365 grpc_channel *channel, int try_to_connect) nogil
|
| /external/grpc-grpc/src/csharp/ext/ |
| D | grpc_csharp_ext.c | 420 int32_t try_to_connect) { in grpcsharp_channel_check_connectivity_state() argument
421 return grpc_channel_check_connectivity_state(channel, try_to_connect); in grpcsharp_channel_check_connectivity_state()
|