Home
last modified time | relevance | path

Searched refs:pickSubchannel (Results 1 – 14 of 14) sorted by relevance

/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DDelayedClientTransportTest.java108 when(mockPicker.pickSubchannel(any(PickSubchannelArgs.class))) in setUp()
347 when(picker.pickSubchannel(any(PickSubchannelArgs.class))).thenReturn( in reprocessSemantics()
361 inOrder.verify(picker).pickSubchannel(ff1args); in reprocessSemantics()
362 inOrder.verify(picker).pickSubchannel(ff2args); in reprocessSemantics()
363 inOrder.verify(picker).pickSubchannel(ff3args); in reprocessSemantics()
364 inOrder.verify(picker).pickSubchannel(ff4args); in reprocessSemantics()
365 inOrder.verify(picker).pickSubchannel(wfr1args); in reprocessSemantics()
366 inOrder.verify(picker).pickSubchannel(wfr2args); in reprocessSemantics()
367 inOrder.verify(picker).pickSubchannel(wfr3args); in reprocessSemantics()
368 inOrder.verify(picker).pickSubchannel(wfr4args); in reprocessSemantics()
[all …]
DManagedChannelImplTest.java450 when(mockPicker.pickSubchannel( in subtestCallsAndShutdown()
453 when(mockPicker.pickSubchannel( in subtestCallsAndShutdown()
512 when(picker2.pickSubchannel(new PickSubchannelArgsImpl(method, headers, CallOptions.DEFAULT))) in subtestCallsAndShutdown()
648 when(mockPicker.pickSubchannel(any(PickSubchannelArgs.class))) in callOptionsExecutor()
750 when(picker.pickSubchannel(any(PickSubchannelArgs.class))) in nameResolutionFailed_delayedTransportShutdownCancelsBackoff()
853 when(mockPicker.pickSubchannel(any(PickSubchannelArgs.class))) in firstResolvedServerFailedToConnect()
932 when(picker.pickSubchannel(any(PickSubchannelArgs.class))) in subtestFailRpcFromBalancer()
998 when(mockPicker.pickSubchannel(any(PickSubchannelArgs.class))) in allServersFailedToConnect()
1030 when(picker2.pickSubchannel(any(PickSubchannelArgs.class))) in allServersFailedToConnect()
1442 when(mockPicker.pickSubchannel(any(PickSubchannelArgs.class))) in informationPropagatedToNewStreamAndCallCredentials()
[all …]
DManagedChannelImplIdlenessTest.java271 when(mockPicker.pickSubchannel(any(PickSubchannelArgs.class))) in realTransportsHoldsOffIdleness()
351 when(failingPicker.pickSubchannel(any(PickSubchannelArgs.class))) in oobTransportDoesNotAffectIdleness()
/external/grpc-grpc-java/core/src/test/java/io/grpc/util/
DRoundRobinLoadBalancerTest.java248 assertEquals(PickResult.withNoResult(), pickerCaptor.getValue().pickSubchannel(mockArgs)); in pickAfterResolvedUpdatedHosts()
306 assertEquals(subchannel, picker.pickSubchannel(mockArgs).getSubchannel()); in pickerRoundRobin()
307 assertEquals(subchannel1, picker.pickSubchannel(mockArgs).getSubchannel()); in pickerRoundRobin()
308 assertEquals(subchannel2, picker.pickSubchannel(mockArgs).getSubchannel()); in pickerRoundRobin()
309 assertEquals(subchannel, picker.pickSubchannel(mockArgs).getSubchannel()); in pickerRoundRobin()
316 assertEquals(null, picker.pickSubchannel(mockArgs).getSubchannel()); in pickerEmptyList()
318 picker.pickSubchannel(mockArgs).getStatus()); in pickerEmptyList()
326 LoadBalancer.PickResult pickResult = pickerCaptor.getValue().pickSubchannel(mockArgs); in nameResolutionErrorWithNoChannels()
349 LoadBalancer.PickResult pickResult = pickerCaptor.getValue().pickSubchannel(mockArgs); in nameResolutionErrorWithActiveChannels()
353 LoadBalancer.PickResult pickResult2 = pickerCaptor.getValue().pickSubchannel(mockArgs); in nameResolutionErrorWithActiveChannels()
[all …]
/external/grpc-grpc-java/core/src/test/java/io/grpc/
DPickFirstLoadBalancerTest.java109 assertEquals(pickerCaptor.getValue().pickSubchannel(mockArgs), in pickAfterResolved()
110 pickerCaptor.getValue().pickSubchannel(mockArgs)); in pickAfterResolved()
145 assertEquals(mockSubchannel, pickerCaptor.getValue().pickSubchannel(mockArgs).getSubchannel()); in pickAfterResolvedAndChanged()
165 Subchannel subchannel = pickerCaptor.getValue().pickSubchannel(mockArgs).getSubchannel(); in pickAfterStateChangeAfterResolution()
174 assertEquals(error, pickerCaptor.getValue().pickSubchannel(mockArgs).getStatus()); in pickAfterStateChangeAfterResolution()
178 assertEquals(Status.OK, pickerCaptor.getValue().pickSubchannel(mockArgs).getStatus()); in pickAfterStateChangeAfterResolution()
182 assertEquals(subchannel, pickerCaptor.getValue().pickSubchannel(mockArgs).getSubchannel()); in pickAfterStateChangeAfterResolution()
192 PickResult pickResult = pickerCaptor.getValue().pickSubchannel(mockArgs); in nameResolutionError()
213 assertEquals(mockSubchannel, pickerCaptor.getValue().pickSubchannel(mockArgs) in nameResolutionSuccessAfterError()
216 assertEquals(pickerCaptor.getValue().pickSubchannel(mockArgs), in nameResolutionSuccessAfterError()
[all …]
/external/grpc-grpc-java/core/src/main/java/io/grpc/
DPickFirstBalancerFactory.java141 public PickResult pickSubchannel(PickSubchannelArgs args) { in pickSubchannel() method in PickFirstBalancerFactory.Picker
155 public PickResult pickSubchannel(PickSubchannelArgs args) { in pickSubchannel() method in PickFirstBalancerFactory.RequestConnectionPicker
DLoadBalancer.java177 public abstract PickResult pickSubchannel(PickSubchannelArgs args); in pickSubchannel() method in LoadBalancer.SubchannelPicker
/external/grpc-grpc-java/grpclb/src/test/java/io/grpc/grpclb/
DGrpclbLoadBalancerTest.java312 assertSame(b1.result, picker.pickSubchannel(args1)); in roundRobinPickerNoDrop()
319 assertSame(b2.result, picker.pickSubchannel(args2)); in roundRobinPickerNoDrop()
326 assertSame(b1.result, picker.pickSubchannel(args3)); in roundRobinPickerNoDrop()
353 assertSame(b1.result, picker.pickSubchannel(args1)); in roundRobinPickerWithDrop()
361 assertSame(DROP_PICK_RESULT, picker.pickSubchannel(args2)); in roundRobinPickerWithDrop()
368 assertSame(b2.result, picker.pickSubchannel(args3)); in roundRobinPickerWithDrop()
376 assertSame(DROP_PICK_RESULT, picker.pickSubchannel(args4)); in roundRobinPickerWithDrop()
383 assertSame(b1.result, picker.pickSubchannel(args5)); in roundRobinPickerWithDrop()
458 PickResult pick1 = picker.pickSubchannel(args); in loadReporting()
470 PickResult pick2 = picker.pickSubchannel(args); in loadReporting()
[all …]
/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DAutoConfiguredLoadBalancerFactory.java240 public PickResult pickSubchannel(PickSubchannelArgs args) { in pickSubchannel() method in AutoConfiguredLoadBalancerFactory.EmptyPicker
253 public PickResult pickSubchannel(PickSubchannelArgs args) { in pickSubchannel() method in AutoConfiguredLoadBalancerFactory.FailingPicker
DDelayedClientTransport.java149 PickResult pickResult = picker.pickSubchannel(args); in newStream()
289 PickResult pickResult = picker.pickSubchannel(stream.args); in reprocess()
DOobChannel.java181 public PickResult pickSubchannel(PickSubchannelArgs args) { in setSubchannel()
263 public PickResult pickSubchannel(PickSubchannelArgs args) { in handleSubchannelStateChange()
DManagedChannelImpl.java451 PickResult pickResult = pickerCopy.pickSubchannel(args); in get()
733 public PickResult pickSubchannel(PickSubchannelArgs args) { in panic() method in ManagedChannelImpl.PanicSubchannelPicker
/external/grpc-grpc-java/core/src/main/java/io/grpc/util/
DRoundRobinLoadBalancerFactory.java428 public PickResult pickSubchannel(PickSubchannelArgs args) { in pickSubchannel() method in RoundRobinLoadBalancerFactory.ReadyPicker
482 public PickResult pickSubchannel(PickSubchannelArgs args) { in pickSubchannel() method in RoundRobinLoadBalancerFactory.EmptyPicker
/external/grpc-grpc-java/grpclb/src/main/java/io/grpc/grpclb/
DGrpclbState.java918 public PickResult pickSubchannel(PickSubchannelArgs args) { in pickSubchannel() method in GrpclbState.RoundRobinPicker