| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | ConnectivityStateManagerTest.java | 19 import static io.grpc.ConnectivityState.CONNECTING;
50 state.gotoState(CONNECTING); in noCallback()
51 assertEquals(CONNECTING, state.getState()); in noCallback()
58 state.gotoState(CONNECTING); in registerCallbackBeforeStateChanged()
59 assertEquals(CONNECTING, state.getState()); in registerCallbackBeforeStateChanged()
66 }, executor.getScheduledExecutorService(), CONNECTING); in registerCallbackBeforeStateChanged()
80 state.gotoState(CONNECTING); in registerCallbackAfterStateChanged()
81 assertEquals(CONNECTING, state.getState()); in registerCallbackAfterStateChanged()
95 assertEquals(CONNECTING, sink.poll()); in registerCallbackAfterStateChanged()
123 state.gotoState(CONNECTING); in callbacksAreOneShot()
[all …]
|
| D | InternalSubchannelTest.java | 20 import static io.grpc.ConnectivityState.CONNECTING;
161 assertEquals(CONNECTING, internalSubchannel.getState()); in eagAttribute_propagatesToTransport()
182 assertEquals(CONNECTING, internalSubchannel.getState()); in singleAddressReconnect()
206 assertEquals(CONNECTING, internalSubchannel.getState()); in singleAddressReconnect()
229 assertEquals(CONNECTING, internalSubchannel.getState()); in singleAddressReconnect()
251 assertEquals(CONNECTING, internalSubchannel.getState()); in singleAddressReconnect()
279 assertEquals(CONNECTING, internalSubchannel.getState()); in twoAddressesReconnect()
288 assertEquals(CONNECTING, internalSubchannel.getState()); in twoAddressesReconnect()
318 assertEquals(CONNECTING, internalSubchannel.getState()); in twoAddressesReconnect()
323 assertEquals(CONNECTING, internalSubchannel.getState()); in twoAddressesReconnect()
[all …]
|
| D | ManagedChannelImplTest.java | 21 import static io.grpc.ConnectivityState.CONNECTING;
583 assertSame(CONNECTING, stateInfoCaptor.getAllValues().get(0).getState()); in noMoreCallbackAfterLoadBalancerShutdown()
588 assertSame(CONNECTING, stateInfoCaptor.getValue().getState()); in noMoreCallbackAfterLoadBalancerShutdown()
858 assertEquals(CONNECTING, stateInfoCaptor.getValue().getState()); in firstResolvedServerFailedToConnect()
1004 assertEquals(CONNECTING, stateInfoCaptor.getValue().getState()); in allServersFailedToConnect()
1585 helper.updateBalancingState(CONNECTING, mockPicker); in getState_withRequestConnect()
1586 assertEquals(CONNECTING, channel.getState(false)); in getState_withRequestConnect()
1587 assertEquals(CONNECTING, channel.getState(true)); in getState_withRequestConnect()
1625 helper.updateBalancingState(CONNECTING, mockPicker); in notifyWhenStateChanged()
1663 helper.updateBalancingState(CONNECTING, mockPicker); in channelStateWhenChannelShutdown()
[all …]
|
| /external/autotest/client/cros/cellular/ |
| D | cellular.py | 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/doc/ |
| D | connectivity-semantics-and-api.md | 21 CONNECTING: The channel is trying to establish a connection and is waiting to
32 switch to the CONNECTING state and try to establish a connection again. Since
45 period, channels that are READY or CONNECTING switch to IDLE. Additionaly,
64 <th>CONNECTING</th>
71 <th>CONNECTING</th>
120 transition to CONNECTING if the channel is currently IDLE. The boolean should
146 transition, require a transition from CONNECTING to TRANSIENT_FAILURE and back
147 to CONNECTING for every recoverable failure, even if the corresponding
150 e.g., an application waiting for state changes on a channel that is CONNECTING
152 CONNECTING state on polling for current state because the channel may have
|
| D | wait-for-ready.md | 8 channel being in other states (`CONNECTING`, `READY`, or `IDLE`).
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/ |
| D | PickFirstBalancerFactory.java | 20 import static io.grpc.ConnectivityState.CONNECTING;
73 helper.updateBalancingState(CONNECTING, new Picker(PickResult.withSubchannel(subchannel))); in handleResolvedAddressGroups()
103 case CONNECTING: in handleSubchannelState()
|
| D | ConnectivityState.java | 32 CONNECTING, enumConstant
|
| /external/google-breakpad/src/client/windows/crash_generation/ |
| D | ReadMe.txt | 15 | go into CONNECTING state.
20 CONNECTING | Get the result of async connection request.
21 | If I/O is still incomplete, remain in the CONNECTING
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/ |
| D | PickFirstLoadBalancerTest.java | 19 import static io.grpc.ConnectivityState.CONNECTING;
106 verify(mockHelper).updateBalancingState(eq(CONNECTING), pickerCaptor.capture()); in pickAfterResolved()
143 inOrder.verify(mockHelper).updateBalancingState(eq(CONNECTING), pickerCaptor.capture()); in pickAfterResolvedAndChanged()
164 verify(mockHelper).updateBalancingState(eq(CONNECTING), pickerCaptor.capture()); in pickAfterStateChangeAfterResolution()
210 inOrder.verify(mockHelper).updateBalancingState(eq(CONNECTING), pickerCaptor.capture()); in nameResolutionSuccessAfterError()
|
| D | ConnectivityStateInfoTest.java | 19 import static io.grpc.ConnectivityState.CONNECTING;
61 ConnectivityStateInfo info2 = ConnectivityStateInfo.forNonError(CONNECTING); in equality()
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | InternalSubchannel.java | 19 import static io.grpc.ConnectivityState.CONNECTING;
208 gotoNonErrorState(CONNECTING); in obtainActiveTransport()
273 gotoNonErrorState(CONNECTING); in scheduleBackoff()
312 gotoNonErrorState(CONNECTING); in resetConnectBackoff()
360 if (state.getState() == READY || state.getState() == CONNECTING) { in updateAddresses()
595 Preconditions.checkState(state.getState() == CONNECTING, in transportShutdown()
|
| D | AutoConfiguredLoadBalancerFactory.java | 124 helper.updateBalancingState(ConnectivityState.CONNECTING, new EmptyPicker()); in handleResolvedAddressGroups()
|
| /external/grpc-grpc/src/python/grpcio_tests/tests/unit/beta/ |
| D | _connectivity_channel_test.py | 25 self.assertIsNotNone(interfaces.ChannelConnectivity.CONNECTING)
|
| /external/grpc-grpc/src/python/grpcio_tests/tests/unit/ |
| D | _api_test.py | 90 grpc.ChannelConnectivity.CONNECTING,
|
| /external/autotest/server/site_tests/cellular_StaleModemReboot/ |
| D | control | 57 MODEM STATE CONNECTING = 10
60 GOBI MODEM STATE CONNECTING = 80
|
| /external/grpc-grpc-java/grpclb/src/test/java/io/grpc/grpclb/ |
| D | GrpclbLoadBalancerTest.java | 20 import static io.grpc.ConnectivityState.CONNECTING;
436 deliverSubchannelState(subchannel1, ConnectivityStateInfo.forNonError(CONNECTING)); in loadReporting()
437 deliverSubchannelState(subchannel2, ConnectivityStateInfo.forNonError(CONNECTING)); in loadReporting()
886 deliverSubchannelState(subchannel1, ConnectivityStateInfo.forNonError(CONNECTING)); in grpclbWorking()
887 deliverSubchannelState(subchannel2, ConnectivityStateInfo.forNonError(CONNECTING)); in grpclbWorking()
888 inOrder.verify(helper).updateBalancingState(eq(CONNECTING), pickerCaptor.capture()); in grpclbWorking()
922 deliverSubchannelState(subchannel1, ConnectivityStateInfo.forNonError(CONNECTING)); in grpclbWorking()
934 inOrder.verify(helper).updateBalancingState(eq(CONNECTING), pickerCaptor.capture()); in grpclbWorking()
967 inOrder.verify(helper).updateBalancingState(eq(CONNECTING), pickerCaptor.capture()); in grpclbWorking()
1017 inOrder.verify(helper).updateBalancingState(eq(CONNECTING), pickerCaptor.capture()); in grpclbWorking()
[all …]
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/util/ |
| D | RoundRobinLoadBalancerFactory.java | 20 import static io.grpc.ConnectivityState.CONNECTING;
244 if (stateInfo.getState() == CONNECTING || stateInfo.getState() == IDLE) { in updateBalancingState()
251 updateBalancingState(isConnecting ? CONNECTING : TRANSIENT_FAILURE, in updateBalancingState()
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/util/ |
| D | RoundRobinLoadBalancerTest.java | 20 import static io.grpc.ConnectivityState.CONNECTING;
161 assertEquals(CONNECTING, stateCaptor.getAllValues().get(0)); in pickAfterResolved()
261 inOrder.verify(mockHelper).updateBalancingState(eq(CONNECTING), isA(EmptyPicker.class)); in pickAfterStateChange()
276 inOrder.verify(mockHelper).updateBalancingState(eq(CONNECTING), pickerCaptor.capture()); in pickAfterStateChange()
345 assertEquals(CONNECTING, stateIterator.next()); in nameResolutionErrorWithActiveChannels()
382 assertEquals(CONNECTING, stateIterator.next()); in subchannelStateIsolation()
|
| /external/webrtc/sdk/android/api/org/webrtc/ |
| D | DataChannel.java | 94 CONNECTING, enumConstant
|
| /external/wpa_supplicant_8/src/eapol_supp/ |
| D | eapol_supp_sm.c | 256 SM_STATE(SUPP_PAE, CONNECTING) in SM_STATE() argument
260 SM_ENTRY(SUPP_PAE, CONNECTING); in SM_STATE()
390 SM_ENTER(SUPP_PAE, CONNECTING); in SM_STEP()
394 SM_ENTER(SUPP_PAE, CONNECTING); in SM_STEP()
424 SM_ENTER(SUPP_PAE, CONNECTING); in SM_STEP()
426 SM_ENTER(SUPP_PAE, CONNECTING); in SM_STEP()
430 SM_ENTER(SUPP_PAE, CONNECTING); in SM_STEP()
|
| /external/robolectric-shadows/shadows/framework/src/main/java/org/robolectric/shadows/ |
| D | ShadowNetworkInfo.java | 62 return isConnected() || state == NetworkInfo.State.CONNECTING; in isConnectedOrConnecting()
|
| /external/grpc-grpc/src/python/grpcio/grpc/ |
| D | _common.py | 30 grpc.ChannelConnectivity.CONNECTING,
|
| /external/webrtc/sdk/android/instrumentationtests/src/org/webrtc/ |
| D | PeerConnectionEndToEndTest.java | 321 assertEquals(DataChannel.State.CONNECTING, dataChannel.state()); in onDataChannel()
753 answeringExpectations.expectConnectionChange(PeerConnectionState.CONNECTING); in testCompleteSession()
760 offeringExpectations.expectConnectionChange(PeerConnectionState.CONNECTING); in testCompleteSession()
994 answeringExpectations.expectConnectionChange(PeerConnectionState.CONNECTING); in testDataChannelOnlySession()
1001 offeringExpectations.expectConnectionChange(PeerConnectionState.CONNECTING); in testDataChannelOnlySession()
1218 offeringExpectations.expectConnectionChange(PeerConnectionState.CONNECTING); in testTrackRemovalAndAddition()
1250 answeringExpectations.expectConnectionChange(PeerConnectionState.CONNECTING); in testTrackRemovalAndAddition()
|
| /external/grpc-grpc-java/services/src/generated/main/java/io/grpc/channelz/v1/ |
| D | ChannelConnectivityState.java | 104 CONNECTING(2), enumConstant
166 case 2: return CONNECTING; in forNumber()
|