| /external/grpc-grpc-java/core/src/main/java/io/grpc/ |
| ConnectivityState.java | 32 CONNECTING,
43 * error). Channels in this state will eventually switch to the CONNECTING state and try to
55 * RPC on the channel will push the channel out of this state to connecting. When there has been
57 * RPCs for this period, channels that are READY or CONNECTING switch to IDLE. Additionaly,
68 * (while connecting or communicating) that are classified as non-recoverable) Channels that
|
| PickFirstBalancerFactory.java | 20 import static io.grpc.ConnectivityState.CONNECTING;
73 helper.updateBalancingState(CONNECTING, new Picker(PickResult.withSubchannel(subchannel)));
103 case CONNECTING:
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| ConnectivityStateManagerTest.java | 19 import static io.grpc.ConnectivityState.CONNECTING;
50 state.gotoState(CONNECTING);
51 assertEquals(CONNECTING, state.getState());
58 state.gotoState(CONNECTING);
59 assertEquals(CONNECTING, state.getState());
66 }, executor.getScheduledExecutorService(), CONNECTING);
80 state.gotoState(CONNECTING);
81 assertEquals(CONNECTING, state.getState());
95 assertEquals(CONNECTING, sink.poll());
123 state.gotoState(CONNECTING);
[all...] |
| InternalSubchannelTest.java | 20 import static io.grpc.ConnectivityState.CONNECTING;
161 assertEquals(CONNECTING, internalSubchannel.getState());
181 assertExactCallbackInvokes("onStateChange:CONNECTING");
182 assertEquals(CONNECTING, internalSubchannel.getState());
205 assertExactCallbackInvokes("onStateChange:CONNECTING");
206 assertEquals(CONNECTING, internalSubchannel.getState());
229 assertEquals(CONNECTING, internalSubchannel.getState());
230 assertExactCallbackInvokes("onStateChange:CONNECTING");
251 assertEquals(CONNECTING, internalSubchannel.getState());
252 assertExactCallbackInvokes("onStateChange:CONNECTING");
[all...] |
| ManagedChannelImplTest.java | 21 import static io.grpc.ConnectivityState.CONNECTING;
584 assertSame(CONNECTING, stateInfoCaptor.getAllValues().get(0).getState());
589 assertSame(CONNECTING, stateInfoCaptor.getValue().getState());
[all...] |
| /cts/tests/tests/net/src/android/net/cts/ |
| NetworkInfo_StateTest.java | 26 assertEquals(State.CONNECTING, State.valueOf("CONNECTING"));
36 assertEquals(State.CONNECTING, expected[0]);
|
| NetworkInfoTest.java | 62 assertTrue(State.CONNECTING == netInfo.getState()
65 || DetailedState.CONNECTING == netInfo.getDetailedState()
|
| NetworkInfo_DetailedStateTest.java | 28 assertEquals(DetailedState.CONNECTING, DetailedState.valueOf("CONNECTING"));
43 assertEquals(DetailedState.CONNECTING, expected[2]);
|
| /external/grpc-grpc/src/python/grpcio_tests/tests/unit/beta/ |
| _connectivity_channel_test.py | 25 self.assertIsNotNone(interfaces.ChannelConnectivity.CONNECTING)
|
| /external/autotest/client/cros/cellular/ |
| cellular.py | 108 # TODO(rochberg): Do we need connecting/disconnecting for this level of test?
113 'CONNECTING',
124 UeGsmDataStatus.PDP_ACTIVATING: UeGenericDataStatus.CONNECTING,
133 UeEvdoDataStatus.CONNECTION_NEGOTIATE: UeGenericDataStatus.CONNECTING,
134 UeEvdoDataStatus.CONNECTION_REQUEST: UeGenericDataStatus.CONNECTING,
137 UeEvdoDataStatus.HANDOFF: UeGenericDataStatus.CONNECTING,
141 UeEvdoDataStatus.SESSION_NEGOTIATE: UeGenericDataStatus.CONNECTING,
|
| /external/grpc-grpc/src/python/grpcio_tests/tests/unit/ |
| _api_test.py | 90 grpc.ChannelConnectivity.CONNECTING,
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/ |
| ConnectivityStateInfoTest.java | 19 import static io.grpc.ConnectivityState.CONNECTING;
61 ConnectivityStateInfo info2 = ConnectivityStateInfo.forNonError(CONNECTING);
|
| PickFirstLoadBalancerTest.java | 19 import static io.grpc.ConnectivityState.CONNECTING;
106 verify(mockHelper).updateBalancingState(eq(CONNECTING), pickerCaptor.capture());
143 inOrder.verify(mockHelper).updateBalancingState(eq(CONNECTING), pickerCaptor.capture());
164 verify(mockHelper).updateBalancingState(eq(CONNECTING), pickerCaptor.capture());
210 inOrder.verify(mockHelper).updateBalancingState(eq(CONNECTING), pickerCaptor.capture());
|
| /external/webrtc/talk/app/webrtc/java/src/org/webrtc/ |
| DataChannel.java | 93 public enum State { CONNECTING, OPEN, CLOSING, CLOSED };
|
| /external/robolectric-shadows/shadows/framework/src/main/java/org/robolectric/shadows/ |
| ShadowNetworkInfo.java | 62 return isConnected() || state == NetworkInfo.State.CONNECTING;
|
| /external/autotest/client/site_tests/cellular_GobiDormancyDance/ |
| cellular_GobiDormancyDance.py | 21 CONNECTING = 2
54 print 'Connecting...'
55 self.state = State.CONNECTING
118 if self.state != State.CONNECTING:
119 raise error.TestFail('Connected while not in state Connecting')
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| InternalSubchannel.java | 19 import static io.grpc.ConnectivityState.CONNECTING;
110 * Timer monitoring duration since entering CONNECTING state.
208 gotoNonErrorState(CONNECTING);
273 gotoNonErrorState(CONNECTING);
312 gotoNonErrorState(CONNECTING);
360 if (state.getState() == READY || state.getState() == CONNECTING) {
595 Preconditions.checkState(state.getState() == CONNECTING,
596 "Expected state is CONNECTING, actual state is %s", state.getState());
|
| /external/grpc-grpc/src/python/grpcio/grpc/ |
| _common.py | 29 cygrpc.ConnectivityState.connecting:
30 grpc.ChannelConnectivity.CONNECTING,
|
| /frameworks/av/media/libmediaplayer2/nuplayer2/ |
| RTSPSource2.h | 77 CONNECTING,
|
| /frameworks/av/media/libmediaplayerservice/nuplayer/ |
| RTSPSource.h | 78 CONNECTING,
|
| /frameworks/av/media/libstagefright/rtsp/ |
| ARTSPConnection.h | 56 CONNECTING,
|
| /external/grpc-grpc/src/ruby/spec/ |
| channel_spec.rb | 190 GRPC::Core::ConnectivityStates::CONNECTING,
204 GRPC::Core::ConnectivityStates::CONNECTING,
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/util/ |
| RoundRobinLoadBalancerFactory.java | 20 import static io.grpc.ConnectivityState.CONNECTING;
244 if (stateInfo.getState() == CONNECTING || stateInfo.getState() == IDLE) {
251 updateBalancingState(isConnecting ? CONNECTING : TRANSIENT_FAILURE,
|
| /external/grpc-grpc-java/grpclb/src/test/java/io/grpc/grpclb/ |
| GrpclbLoadBalancerTest.java | 20 import static io.grpc.ConnectivityState.CONNECTING;
437 deliverSubchannelState(subchannel1, ConnectivityStateInfo.forNonError(CONNECTING));
438 deliverSubchannelState(subchannel2, ConnectivityStateInfo.forNonError(CONNECTING));
[all...] |
| /external/grpc-grpc-java/core/src/test/java/io/grpc/util/ |
| RoundRobinLoadBalancerTest.java | 20 import static io.grpc.ConnectivityState.CONNECTING;
161 assertEquals(CONNECTING, stateCaptor.getAllValues().get(0));
261 inOrder.verify(mockHelper).updateBalancingState(eq(CONNECTING), isA(EmptyPicker.class));
276 inOrder.verify(mockHelper).updateBalancingState(eq(CONNECTING), pickerCaptor.capture());
345 assertEquals(CONNECTING, stateIterator.next());
382 assertEquals(CONNECTING, stateIterator.next());
[all...] |
