| /external/grpc-grpc/src/php/lib/Grpc/Internal/ |
| InterceptorChannel.php | 67 public function getConnectivityState($try_to_connect = false)
69 return $this->getNext()->getConnectivityState($try_to_connect);
|
| /external/grpc-grpc/src/core/ext/filters/client_channel/ |
| client_channel.h | 48 grpc_channel_element* elem, int try_to_connect);
|
| channel_connectivity.cc | 34 grpc_channel* channel, int try_to_connect) {
41 "grpc_channel_check_connectivity_state(channel=%p, try_to_connect=%d)", 2,
42 (channel, try_to_connect));
45 try_to_connect);
|
| client_channel.cc | [all...] |
| /external/grpc-grpc/src/python/grpcio_tests/tests/unit/ |
| _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)
96 # Wait for a connection that will never happen because try_to_connect=True
100 channel.subscribe(second_callback.update, try_to_connect=True)
134 channel.subscribe(callback.update, try_to_connect=True)
|
| _exit_scenarios.py | 186 channel.subscribe(connectivity_callback, try_to_connect=True)
198 channel.subscribe(connectivity_callback, try_to_connect=True)
|
| /external/grpc-grpc/include/grpcpp/ |
| channel.h | 50 /// \a try_to_connect is set to true, try to connect.
51 grpc_connectivity_state GetState(bool try_to_connect) override;
|
| /external/grpc-grpc/src/python/grpcio/grpc/ |
| _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:
[all...] |
| _utilities.py | 155 self._channel.subscribe(self._update, try_to_connect=True)
|
| _interceptor.py | 400 def subscribe(self, callback, try_to_connect=False):
401 self._channel.subscribe(callback, try_to_connect=try_to_connect)
|
| __init__.py | 823 def subscribe(self, callback, try_to_connect=False):
837 try_to_connect: A boolean indicating whether or not this Channel
[all...] |
| /external/grpc-grpc/src/python/grpcio_testing/grpc_testing/_channel/ |
| _channel.py | 29 def subscribe(self, callback, try_to_connect=False):
|
| /external/grpc-grpc/src/python/grpcio/grpc/beta/ |
| implementations.py | 77 def subscribe(self, callback, try_to_connect=None):
86 try_to_connect: A boolean indicating whether or not this Channel should
90 self._channel.subscribe(callback, try_to_connect=try_to_connect)
|
| utilities.py | 124 self._channel.subscribe(self._update, try_to_connect=True)
|
| /external/grpc-grpc/include/grpcpp/impl/codegen/ |
| channel_interface.h | 61 /// \a try_to_connect is set to true, try to connect.
62 virtual grpc_connectivity_state GetState(bool try_to_connect) = 0;
|
| /external/grpc-grpc/src/cpp/client/ |
| channel_cc.cc | 154 grpc_connectivity_state Channel::GetState(bool try_to_connect) {
155 return grpc_channel_check_connectivity_state(c_channel_, try_to_connect);
|
| /external/grpc-grpc/src/php/ext/grpc/ |
| channel.c | 460 * @param bool $try_to_connect Try to connect on the channel (optional)
473 bool try_to_connect = false; local
475 if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "|b", &try_to_connect)
483 (int)try_to_connect);
707 ZEND_ARG_INFO(0, try_to_connect)
|
| /external/grpc-grpc/src/php/lib/Grpc/ |
| BaseStub.php | 128 * @param bool $try_to_connect (optional)
132 public function getConnectivityState($try_to_connect = false)
134 return $this->channel->getConnectivityState($try_to_connect);
|
| /external/grpc-grpc/src/ruby/ext/grpc/ |
| rb_channel.c | 267 int try_to_connect; member in struct:get_state_stack
280 stack->try_to_connect);
302 /* "01" == 0 mandatory args, 1 (try_to_connect) is optional */
312 stack.try_to_connect = RTEST(try_to_connect_param) ? 1 : 0;
|
| rb_grpc_imports.generated.h | 134 typedef grpc_connectivity_state(*grpc_channel_check_connectivity_state_type)(grpc_channel* channel, int try_to_connect);
[all...] |
| /external/grpc-grpc/include/grpc/ |
| grpc.h | 185 grpc_channel* channel, int try_to_connect);
|
| /external/grpc-grpc/test/core/end2end/fuzzers/ |
| api_fuzzer.cc | 874 uint8_t try_to_connect = grpc_fuzzer_get_next_byte(&inp); local
875 if (try_to_connect == 0 || try_to_connect == 1) {
876 grpc_channel_check_connectivity_state(g_channel, try_to_connect);
[all...] |
| /external/grpc-grpc/src/python/grpcio/grpc/_cython/_cygrpc/ |
| channel.pyx.pxi | 469 def check_connectivity_state(self, bint try_to_connect):
473 self._state.c_channel, try_to_connect)
|
| /external/grpc-grpc/src/csharp/ext/ |
| grpc_csharp_ext.c | 420 int32_t try_to_connect) {
421 return grpc_channel_check_connectivity_state(channel, try_to_connect);
[all...] |
