| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | ConnectivityStateManagerTest.java | 23 import static io.grpc.ConnectivityState.TRANSIENT_FAILURE;
52 state.gotoState(TRANSIENT_FAILURE); in noCallback()
53 assertEquals(TRANSIENT_FAILURE, state.getState()); in noCallback()
69 state.gotoState(TRANSIENT_FAILURE); in registerCallbackBeforeStateChanged()
75 assertEquals(TRANSIENT_FAILURE, sink.poll()); in registerCallbackBeforeStateChanged()
130 state.gotoState(TRANSIENT_FAILURE); in callbacksAreOneShot()
136 callback, executor.getScheduledExecutorService(), TRANSIENT_FAILURE); in callbacksAreOneShot()
|
| D | InternalSubchannelTest.java | 24 import static io.grpc.ConnectivityState.TRANSIENT_FAILURE;
189 assertEquals(TRANSIENT_FAILURE, internalSubchannel.getState()); in singleAddressReconnect()
201 assertEquals(TRANSIENT_FAILURE, internalSubchannel.getState()); in singleAddressReconnect()
214 assertEquals(TRANSIENT_FAILURE, internalSubchannel.getState()); in singleAddressReconnect()
226 assertEquals(TRANSIENT_FAILURE, internalSubchannel.getState()); in singleAddressReconnect()
299 assertEquals(TRANSIENT_FAILURE, internalSubchannel.getState()); in twoAddressesReconnect()
308 assertEquals(TRANSIENT_FAILURE, internalSubchannel.getState()); in twoAddressesReconnect()
314 assertEquals(TRANSIENT_FAILURE, internalSubchannel.getState()); in twoAddressesReconnect()
336 assertEquals(TRANSIENT_FAILURE, internalSubchannel.getState()); in twoAddressesReconnect()
342 assertEquals(TRANSIENT_FAILURE, internalSubchannel.getState()); in twoAddressesReconnect()
[all …]
|
| D | ManagedChannelImplIdlenessTest.java | 20 import static io.grpc.ConnectivityState.TRANSIENT_FAILURE;
353 helper.updateBalancingState(TRANSIENT_FAILURE, failingPicker); in oobTransportDoesNotAffectIdleness()
|
| D | ManagedChannelImplTest.java | 25 import static io.grpc.ConnectivityState.TRANSIENT_FAILURE;
1026 assertEquals(TRANSIENT_FAILURE, stateInfoCaptor.getValue().getState()); in allServersFailedToConnect()
1033 helper.updateBalancingState(TRANSIENT_FAILURE, picker2); in allServersFailedToConnect()
1564 helper.updateBalancingState(TRANSIENT_FAILURE, mockPicker); in getState_loadBalancerSupportsChannelState()
1565 assertEquals(TRANSIENT_FAILURE, channel.getState(false)); in getState_loadBalancerSupportsChannelState()
1695 subtestPanic(TRANSIENT_FAILURE); in panic_whenTransientFailure()
1747 assertEquals(TRANSIENT_FAILURE, channel.getState(true)); in subtestPanic()
1748 assertEquals(TRANSIENT_FAILURE, channel.getState(true)); in subtestPanic()
1810 assertEquals(TRANSIENT_FAILURE, channel.getState(false)); in verifyPanicMode()
1875 helper.updateBalancingState(TRANSIENT_FAILURE, mockPicker); in idleMode_resetsDelayedTransportPicker()
[all …]
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/ |
| D | ConnectivityStateInfo.java | 19 import static io.grpc.ConnectivityState.TRANSIENT_FAILURE;
41 state != TRANSIENT_FAILURE, in forNonError()
51 return new ConnectivityStateInfo(TRANSIENT_FAILURE, error); in forTransientFailure()
|
| D | PickFirstBalancerFactory.java | 22 import static io.grpc.ConnectivityState.TRANSIENT_FAILURE;
88 helper.updateBalancingState(TRANSIENT_FAILURE, new Picker(PickResult.withError(error))); in handleNameResolutionError()
111 case TRANSIENT_FAILURE: in handleSubchannelState()
|
| D | ConnectivityState.java | 50 TRANSIENT_FAILURE, enumConstant
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/ |
| D | ConnectivityStateInfoTest.java | 21 import static io.grpc.ConnectivityState.TRANSIENT_FAILURE;
43 ConnectivityStateInfo.forNonError(TRANSIENT_FAILURE); in forNonErrorInvalid()
49 assertEquals(TRANSIENT_FAILURE, info.getState()); in forTransientFailure()
|
| D | PickFirstLoadBalancerTest.java | 22 import static io.grpc.ConnectivityState.TRANSIENT_FAILURE;
173 inOrder.verify(mockHelper).updateBalancingState(eq(TRANSIENT_FAILURE), pickerCaptor.capture()); in pickAfterStateChangeAfterResolution()
191 verify(mockHelper).updateBalancingState(eq(TRANSIENT_FAILURE), pickerCaptor.capture()); in nameResolutionError()
230 inOrder.verify(mockHelper).updateBalancingState(eq(TRANSIENT_FAILURE), pickerCaptor.capture()); in nameResolutionErrorWithStateChanges()
239 inOrder.verify(mockHelper).updateBalancingState(eq(TRANSIENT_FAILURE), pickerCaptor.capture()); in nameResolutionErrorWithStateChanges()
|
| /external/grpc-grpc/doc/ |
| D | wait-for-ready.md | 4 If an RPC is issued but the channel is in `TRANSIENT_FAILURE` or `SHUTDOWN`
11 of the channel being in `TRANSIENT_FAILURE` state. Instead, the implementation
|
| D | connectivity-semantics-and-api.md | 30 TRANSIENT_FAILURE: There has been some transient failure (such as a TCP 3-way
66 <th>TRANSIENT_FAILURE</th>
88 <th>TRANSIENT_FAILURE</th>
146 transition, require a transition from CONNECTING to TRANSIENT_FAILURE and back
153 spent infinitesimally small amount of time in the TRANSIENT_FAILURE state.
|
| /external/grpc-grpc/src/python/grpcio_tests/tests/unit/ |
| D | _channel_connectivity_test.py | 116 self.assertNotIn(grpc.ChannelConnectivity.TRANSIENT_FAILURE,
120 self.assertNotIn(grpc.ChannelConnectivity.TRANSIENT_FAILURE,
|
| D | _api_test.py | 92 grpc.ChannelConnectivity.TRANSIENT_FAILURE,
|
| /external/grpc-grpc/src/python/grpcio_tests/tests/unit/beta/ |
| D | _connectivity_channel_test.py | 27 self.assertIsNotNone(interfaces.ChannelConnectivity.TRANSIENT_FAILURE)
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/util/ |
| D | RoundRobinLoadBalancerFactory.java | 24 import static io.grpc.ConnectivityState.TRANSIENT_FAILURE;
192 updateBalancingState(TRANSIENT_FAILURE, in handleNameResolutionError()
251 updateBalancingState(isConnecting ? CONNECTING : TRANSIENT_FAILURE, in updateBalancingState()
|
| /external/grpc-grpc-java/grpclb/src/main/java/io/grpc/grpclb/ |
| D | GrpclbState.java | 26 import static io.grpc.ConnectivityState.TRANSIENT_FAILURE;
328 TRANSIENT_FAILURE, new RoundRobinPicker(dropList, Arrays.asList(new ErrorEntry(status)))); in propagateError()
685 } else if (stateInfo.getState() == TRANSIENT_FAILURE) { in maybeUpdatePicker()
697 state = TRANSIENT_FAILURE; in maybeUpdatePicker()
|
| /external/grpc-grpc/src/python/grpcio/grpc/ |
| D | _common.py | 34 grpc.ChannelConnectivity.TRANSIENT_FAILURE,
|
| D | __init__.py | 206 TRANSIENT_FAILURE = (_cygrpc.ConnectivityState.transient_failure, variable in ChannelConnectivity
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/util/ |
| D | RoundRobinLoadBalancerTest.java | 24 import static io.grpc.ConnectivityState.TRANSIENT_FAILURE;
247 inOrder.verify(mockHelper).updateBalancingState(eq(TRANSIENT_FAILURE), pickerCaptor.capture()); in pickAfterResolvedUpdatedHosts()
325 verify(mockHelper).updateBalancingState(eq(TRANSIENT_FAILURE), pickerCaptor.capture()); in nameResolutionErrorWithNoChannels()
347 assertEquals(TRANSIENT_FAILURE, stateIterator.next()); in nameResolutionErrorWithActiveChannels()
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | AutoConfiguredLoadBalancerFactory.java | 93 helper.updateBalancingState(ConnectivityState.TRANSIENT_FAILURE, new FailingPicker(s)); in handleResolvedAddressGroups()
|
| D | InternalSubchannel.java | 23 import static io.grpc.ConnectivityState.TRANSIENT_FAILURE;
308 if (state.getState() != TRANSIENT_FAILURE) { in resetConnectBackoff()
|
| D | ManagedChannelImpl.java | 24 import static io.grpc.ConnectivityState.TRANSIENT_FAILURE;
766 channelStateManager.gotoState(TRANSIENT_FAILURE); in panic()
1019 if (newState.getState() == TRANSIENT_FAILURE || newState.getState() == IDLE) { in handleInternalSubchannelState()
|
| D | OobChannel.java | 258 case TRANSIENT_FAILURE: in handleSubchannelStateChange()
|
| /external/grpc-grpc-java/services/src/generated/main/java/io/grpc/channelz/v1/ |
| D | ChannelConnectivityState.java | 112 TRANSIENT_FAILURE(4), enumConstant
168 case 4: return TRANSIENT_FAILURE; in forNumber()
|
| /external/grpc-grpc-java/grpclb/src/test/java/io/grpc/grpclb/ |
| D | GrpclbLoadBalancerTest.java | 24 import static io.grpc.ConnectivityState.TRANSIENT_FAILURE;
721 verify(helper).updateBalancingState(eq(TRANSIENT_FAILURE), pickerCaptor.capture()); in nameResolutionFailsThenRecoverToDelegate()
737 verify(helper).updateBalancingState(eq(TRANSIENT_FAILURE), pickerCaptor.capture()); in nameResolutionFailsThenRecoverToGrpclb()
771 inOrder.verify(helper).updateBalancingState(eq(TRANSIENT_FAILURE), pickerCaptor.capture()); in grpclbThenNameResolutionFails()
1086 verify(helper).updateBalancingState(eq(TRANSIENT_FAILURE), pickerCaptor.capture()); in subtestGrpclbFallbackInitialTimeout()
|