| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | DelayedClientTransportTest.java | 108 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 …]
|
| D | ManagedChannelImplTest.java | 450 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 …]
|
| D | ManagedChannelImplIdlenessTest.java | 271 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/ |
| D | RoundRobinLoadBalancerTest.java | 248 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/ |
| D | PickFirstLoadBalancerTest.java | 109 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/ |
| D | PickFirstBalancerFactory.java | 141 public PickResult pickSubchannel(PickSubchannelArgs args) { in pickSubchannel() method in PickFirstBalancerFactory.Picker
155 public PickResult pickSubchannel(PickSubchannelArgs args) { in pickSubchannel() method in PickFirstBalancerFactory.RequestConnectionPicker
|
| D | LoadBalancer.java | 177 public abstract PickResult pickSubchannel(PickSubchannelArgs args); in pickSubchannel() method in LoadBalancer.SubchannelPicker
|
| /external/grpc-grpc-java/grpclb/src/test/java/io/grpc/grpclb/ |
| D | GrpclbLoadBalancerTest.java | 312 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/ |
| D | AutoConfiguredLoadBalancerFactory.java | 240 public PickResult pickSubchannel(PickSubchannelArgs args) { in pickSubchannel() method in AutoConfiguredLoadBalancerFactory.EmptyPicker
253 public PickResult pickSubchannel(PickSubchannelArgs args) { in pickSubchannel() method in AutoConfiguredLoadBalancerFactory.FailingPicker
|
| D | DelayedClientTransport.java | 149 PickResult pickResult = picker.pickSubchannel(args); in newStream()
289 PickResult pickResult = picker.pickSubchannel(stream.args); in reprocess()
|
| D | OobChannel.java | 181 public PickResult pickSubchannel(PickSubchannelArgs args) { in setSubchannel()
263 public PickResult pickSubchannel(PickSubchannelArgs args) { in handleSubchannelStateChange()
|
| D | ManagedChannelImpl.java | 451 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/ |
| D | RoundRobinLoadBalancerFactory.java | 428 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/ |
| D | GrpclbState.java | 918 public PickResult pickSubchannel(PickSubchannelArgs args) { in pickSubchannel() method in GrpclbState.RoundRobinPicker
|