| /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
|
| /external/cronet/components/cronet/android/java/src/org/chromium/net/impl/ |
| D | UrlRequestBase.java | 53 Status.RESOLVING_HOST, Status.CONNECTING, Status.SSL_HANDSHAKE, Status.SENDING_REQUEST,
97 case (LoadState.CONNECTING): in convertLoadState()
98 return Status.CONNECTING; in convertLoadState()
|
| /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/python/bumble/bumble/ |
| D | rfcomm.py | 335 CONNECTING = 0x01 variable in DLC
343 CONNECTING: 'CONNECTING',
388 if self.state != DLC.CONNECTING:
408 if self.state != DLC.CONNECTING:
484 self.change_state(DLC.CONNECTING)
504 self.change_state(DLC.CONNECTING)
578 CONNECTING = 0x01 variable in Multiplexer
587 CONNECTING: 'CONNECTING',
655 if self.state == Multiplexer.CONNECTING:
750 self.change_state(Multiplexer.CONNECTING)
|
| /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()
|
| /external/cronet/components/cronet/android/api/src/android/net/http/ |
| D | UrlRequest.java | 356 Status.CONNECTING,
435 public static final int CONNECTING = 10; field in UrlRequest.Status
|
| /external/cronet/net/websockets/ |
| D | websocket_channel.cc | 350 if (state_ == CONNECTING) { in StartClosingHandshake()
439 SetState(CONNECTING); in SendAddChannelRequestWithSuppliedCallback()
450 DCHECK_EQ(CONNECTING, state_); in OnConnectSuccess()
467 DCHECK_EQ(CONNECTING, state_); in OnConnectFailure()
526 DCHECK_NE(CONNECTING, state_); in OnWriteDone()
601 DCHECK_NE(CONNECTING, state_); in OnReadDone()
901 DCHECK_NE(CONNECTING, state_); in FailChannel()
|
| /external/cronet/net/base/ |
| D | load_states_list.h | 79 LOAD_STATE(CONNECTING, 11)
|
| /external/grpc-grpc/src/python/grpcio_tests/tests/unit/beta/ |
| D | _connectivity_channel_test.py | 25 self.assertIsNotNone(interfaces.ChannelConnectivity.CONNECTING)
|
| /external/cronet/net/quic/ |
| D | dedicated_web_transport_http3_client.cc | 310 TransitionToState(WebTransportState::CONNECTING); in Connect()
675 case WebTransportState::CONNECTING: in TransitionToState()
680 DCHECK_EQ(last_state, WebTransportState::CONNECTING); in TransitionToState()
694 if (last_state == WebTransportState::CONNECTING) { in TransitionToState()
841 if (state_ == WebTransportState::CONNECTING) { in OnConnectionClosed()
|
| /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.att | 57 MODEM STATE CONNECTING = 10
60 GOBI MODEM STATE CONNECTING = 80
|
| D | control.verizon | 57 MODEM STATE CONNECTING = 10
60 GOBI MODEM STATE CONNECTING = 80
|
| D | control | 56 MODEM STATE CONNECTING = 10
59 GOBI MODEM STATE CONNECTING = 80
|
| D | control.tmobile | 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()
|