Home
last modified time | relevance | path

Searched refs:withSubchannel (Results 1 – 9 of 9) sorted by relevance

/external/grpc-grpc-java/core/src/test/java/io/grpc/
DLoadBalancerTest.java49 PickResult result = PickResult.withSubchannel(subchannel); in pickResult_withSubchannel()
58 PickResult result = PickResult.withSubchannel(subchannel, tracerFactory); in pickResult_withSubchannelAndTracer()
94 PickResult sc1 = PickResult.withSubchannel(subchannel); in pickResult_equals()
95 PickResult sc2 = PickResult.withSubchannel(subchannel); in pickResult_equals()
96 PickResult sc3 = PickResult.withSubchannel(subchannel, tracerFactory); in pickResult_equals()
97 PickResult sc4 = PickResult.withSubchannel(subchannel2); in pickResult_equals()
/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DDelayedClientTransportTest.java109 .thenReturn(PickResult.withSubchannel(mockSubchannel)); in setUp()
349 PickResult.withSubchannel(subchannel1), // ff1: proceed in reprocessSemantics()
351 PickResult.withSubchannel(subchannel3), // ff3: stay in reprocessSemantics()
354 PickResult.withSubchannel(subchannel2), // wfr1: proceed in reprocessSemantics()
356 PickResult.withSubchannel(subchannel3)); // wfr3: stay in reprocessSemantics()
395 PickResult.withSubchannel(subchannel1), // ff3 in reprocessSemantics()
396 PickResult.withSubchannel(subchannel2), // ff4 in reprocessSemantics()
397 PickResult.withSubchannel(subchannel2), // wfr2 in reprocessSemantics()
398 PickResult.withSubchannel(subchannel1), // wfr3 in reprocessSemantics()
399 PickResult.withSubchannel(subchannel2), // wfr4 in reprocessSemantics()
[all …]
DManagedChannelImplTest.java455 PickResult.withSubchannel(subchannel)); in subtestCallsAndShutdown()
513 .thenReturn(PickResult.withSubchannel(subchannel)); in subtestCallsAndShutdown()
649 .thenReturn(PickResult.withSubchannel(subchannel)); in callOptionsExecutor()
854 .thenReturn(PickResult.withSubchannel(subchannel)); in firstResolvedServerFailedToConnect()
999 .thenReturn(PickResult.withSubchannel(subchannel)); in allServersFailedToConnect()
1443 .thenReturn(PickResult.withSubchannel(subchannel)); in informationPropagatedToNewStreamAndCallCredentials()
1506 PickResult.withSubchannel(subchannel, factory2)); in pickerReturnsStreamTracer_noDelay()
1543 PickResult.withSubchannel(subchannel, factory2)); in pickerReturnsStreamTracer_delayed()
1907 .thenReturn(PickResult.withSubchannel(subchannel)); in idleMode_resetsDelayedTransportPicker()
1975 .thenReturn(PickResult.withSubchannel(subchannel)); in enterIdle_exitsIdleIfDelayedStreamPending()
[all …]
DManagedChannelImplIdlenessTest.java272 .thenReturn(PickResult.withSubchannel(subchannel)); in realTransportsHoldsOffIdleness()
/external/grpc-grpc-java/core/src/main/java/io/grpc/
DLoadBalancer.java328 public static PickResult withSubchannel( in withSubchannel() method in LoadBalancer.PickResult
340 public static PickResult withSubchannel(Subchannel subchannel) { in withSubchannel() method in LoadBalancer.PickResult
341 return withSubchannel(subchannel, null); in withSubchannel()
DPickFirstBalancerFactory.java73 helper.updateBalancingState(CONNECTING, new Picker(PickResult.withSubchannel(subchannel))); in handleResolvedAddressGroups()
109 picker = new Picker(PickResult.withSubchannel(subchannel)); in handleSubchannelState()
/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DOobChannel.java178 final PickResult result = PickResult.withSubchannel(subchannelImpl); in setSubchannel()
/external/grpc-grpc-java/grpclb/src/main/java/io/grpc/grpclb/
DGrpclbState.java817 this.result = PickResult.withSubchannel(subchannel, loadRecorder); in BackendEntry()
826 this.result = PickResult.withSubchannel(subchannel); in BackendEntry()
/external/grpc-grpc-java/core/src/main/java/io/grpc/util/
DRoundRobinLoadBalancerFactory.java440 return PickResult.withSubchannel(subchannel != null ? subchannel : nextSubchannel()); in pickSubchannel()