Home
last modified time | relevance | path

Searched refs:STATE_INFO (Results 1 – 3 of 3) sorted by relevance

/external/grpc-grpc-java/grpclb/src/main/java/io/grpc/grpclb/
DGrpclbState.java115 private static final Attributes.Key<AtomicReference<ConnectivityStateInfo>> STATE_INFO = field in GrpclbState
172 subchannel.getAttributes().get(STATE_INFO).set(newState); in handleSubchannelState()
223 if (subchannel.getAttributes().get(STATE_INFO).get().getState() == READY) { in maybeUseFallbackBackends()
360 .set(STATE_INFO, in useRoundRobinLists()
682 ConnectivityStateInfo stateInfo = attrs.get(STATE_INFO).get(); in maybeUpdatePicker()
/external/grpc-grpc-java/core/src/main/java/io/grpc/util/
DRoundRobinLoadBalancerFactory.java105 static final Attributes.Key<Ref<ConnectivityStateInfo>> STATE_INFO = field in RoundRobinLoadBalancerFactory.RoundRobinLoadBalancer
163 .set(STATE_INFO, in handleResolvedAddressGroups()
304 return checkNotNull(subchannel.getAttributes().get(STATE_INFO), "STATE_INFO"); in getSubchannelStateInfoRef()
/external/grpc-grpc-java/core/src/test/java/io/grpc/util/
DRoundRobinLoadBalancerTest.java25 import static io.grpc.util.RoundRobinLoadBalancerFactory.RoundRobinLoadBalancer.STATE_INFO;
176 when(subchannel.getAttributes()).thenReturn(Attributes.newBuilder().set(STATE_INFO, in pickAfterResolvedUpdatedHosts()
259 STATE_INFO); in pickAfterStateChange()