| /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)
|
| /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/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/rust/crates/grpcio-sys/grpc/include/grpcpp/impl/codegen/ |
| D | intercepted_channel.h | 41 grpc_connectivity_state GetState(bool try_to_connect) override { in GetState() argument
42 return channel_->GetState(try_to_connect); in GetState()
|
| D | delegating_channel.h | 37 grpc_connectivity_state GetState(bool try_to_connect) override { in GetState() argument
38 return delegate_channel()->GetState(try_to_connect); in GetState()
|
| /external/rust/crates/grpcio-sys/grpc/spm-cpp-include/grpcpp/impl/codegen/ |
| D | intercepted_channel.h | 41 grpc_connectivity_state GetState(bool try_to_connect) override { in GetState() argument
42 return channel_->GetState(try_to_connect); in GetState()
|
| D | delegating_channel.h | 37 grpc_connectivity_state GetState(bool try_to_connect) override { in GetState() argument
38 return delegate_channel()->GetState(try_to_connect); in GetState()
|
| /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/rust/crates/grpcio-sys/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
43 (channel, try_to_connect)); in grpc_channel_check_connectivity_state()
46 try_to_connect); in grpc_channel_check_connectivity_state()
|
| D | client_channel.h | 44 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/rust/crates/grpcio-sys/grpc/src/cpp/client/ |
| D | channel_cc.cc | 167 grpc_connectivity_state Channel::GetState(bool try_to_connect) { in GetState() argument
168 return grpc_channel_check_connectivity_state(c_channel_, try_to_connect); in GetState()
|
| /external/rust/crates/grpcio/src/ |
| D | channel.rs | 546 fn check_connectivity_state(&self, try_to_connect: bool) -> ConnectivityState { in check_connectivity_state()
547 let should_try = if try_to_connect { 1 } else { 0 }; in check_connectivity_state()
597 pub fn check_connectivity_state(&self, try_to_connect: bool) -> ConnectivityState { in check_connectivity_state()
598 self.inner.check_connectivity_state(try_to_connect) in check_connectivity_state()
|
| /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/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/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()
|
| /external/rust/crates/grpcio-sys/grpc/include/grpcpp/ |
| D | channel.h | 63 grpc_connectivity_state GetState(bool try_to_connect) override;
|
| /external/rust/crates/grpcio-sys/grpc/spm-cpp-include/grpcpp/ |
| D | channel.h | 63 grpc_connectivity_state GetState(bool try_to_connect) override;
|