Searched refs:PickSubchannelArgs (Results 1 – 16 of 16) sorted by relevance
27 import io.grpc.LoadBalancer.PickSubchannelArgs;135 PickSubchannelArgs args = new PickSubchannelArgsImpl(method, headers, callOptions); in newStream()179 private PendingStream createPendingStream(PickSubchannelArgs args) { in createPendingStream()347 private final PickSubchannelArgs args;350 private PendingStream(PickSubchannelArgs args) { in PendingStream()
23 import io.grpc.LoadBalancer.PickSubchannelArgs;27 final class PickSubchannelArgsImpl extends PickSubchannelArgs {
27 import io.grpc.LoadBalancer.PickSubchannelArgs;209 public PickResult pickSubchannel(PickSubchannelArgs args) { in pickSubchannel()222 public PickResult pickSubchannel(PickSubchannelArgs args) { in pickSubchannel()
41 import io.grpc.LoadBalancer.PickSubchannelArgs;89 public ClientTransport get(PickSubchannelArgs args) {181 public PickResult pickSubchannel(PickSubchannelArgs args) { in setSubchannel()263 public PickResult pickSubchannel(PickSubchannelArgs args) { in handleSubchannelStateChange()
44 import io.grpc.LoadBalancer.PickSubchannelArgs;129 ClientTransport get(PickSubchannelArgs args); in get()
55 import io.grpc.LoadBalancer.PickSubchannelArgs;468 public ClientTransport get(PickSubchannelArgs args) {753 public PickResult pickSubchannel(PickSubchannelArgs args) { in panic()
26 import io.grpc.LoadBalancer.PickSubchannelArgs;141 public PickResult pickSubchannel(PickSubchannelArgs args) { in pickSubchannel()155 public PickResult pickSubchannel(PickSubchannelArgs args) { in pickSubchannel()
171 public abstract PickResult pickSubchannel(PickSubchannelArgs args); in pickSubchannel()190 public abstract static class PickSubchannelArgs { class in LoadBalancer
59 import io.grpc.LoadBalancer.PickSubchannelArgs;308 PickSubchannelArgs args1 = mock(PickSubchannelArgs.class); in roundRobinPickerNoDrop()317 PickSubchannelArgs args2 = mock(PickSubchannelArgs.class); in roundRobinPickerNoDrop()324 PickSubchannelArgs args3 = mock(PickSubchannelArgs.class); in roundRobinPickerNoDrop()350 PickSubchannelArgs args1 = mock(PickSubchannelArgs.class); in roundRobinPickerWithDrop()359 PickSubchannelArgs args2 = mock(PickSubchannelArgs.class); in roundRobinPickerWithDrop()366 PickSubchannelArgs args3 = mock(PickSubchannelArgs.class); in roundRobinPickerWithDrop()374 PickSubchannelArgs args4 = mock(PickSubchannelArgs.class); in roundRobinPickerWithDrop()381 PickSubchannelArgs args5 = mock(PickSubchannelArgs.class); in roundRobinPickerWithDrop()394 PickSubchannelArgs args = mock(PickSubchannelArgs.class); in loadReporting()[all …]
39 import io.grpc.LoadBalancer.PickSubchannelArgs;108 when(mockPicker.pickSubchannel(any(PickSubchannelArgs.class))) in setUp()347 when(picker.pickSubchannel(any(PickSubchannelArgs.class))).thenReturn( in reprocessSemantics()394 when(picker.pickSubchannel(any(PickSubchannelArgs.class))).thenReturn( in reprocessSemantics()441 when(picker.pickSubchannel(any(PickSubchannelArgs.class))).thenReturn( in reprocessSemantics()457 when(picker.pickSubchannel(any(PickSubchannelArgs.class))).thenReturn( in reprocess_NoPendingStream()493 }).when(picker).pickSubchannel(any(PickSubchannelArgs.class)); in reprocess_newStreamRacesWithReprocess()497 verify(picker, never()).pickSubchannel(any(PickSubchannelArgs.class)); in reprocess_newStreamRacesWithReprocess()547 when(picker2.pickSubchannel(any(PickSubchannelArgs.class))) in reprocess_newStreamRacesWithReprocess()
79 import io.grpc.LoadBalancer.PickSubchannelArgs;649 when(mockPicker.pickSubchannel(any(PickSubchannelArgs.class))) in callOptionsExecutor()751 when(picker.pickSubchannel(any(PickSubchannelArgs.class))) in nameResolutionFailed_delayedTransportShutdownCancelsBackoff()854 when(mockPicker.pickSubchannel(any(PickSubchannelArgs.class))) in firstResolvedServerFailedToConnect()933 when(picker.pickSubchannel(any(PickSubchannelArgs.class))) in subtestFailRpcFromBalancer()999 when(mockPicker.pickSubchannel(any(PickSubchannelArgs.class))) in allServersFailedToConnect()1031 when(picker2.pickSubchannel(any(PickSubchannelArgs.class))) in allServersFailedToConnect()1442 when(mockPicker.pickSubchannel(any(PickSubchannelArgs.class))) in informationPropagatedToNewStreamAndCallCredentials()1504 when(mockPicker.pickSubchannel(any(PickSubchannelArgs.class))).thenReturn( in pickerReturnsStreamTracer_noDelay()1512 verify(mockPicker).pickSubchannel(any(PickSubchannelArgs.class)); in pickerReturnsStreamTracer_noDelay()[all …]
44 import io.grpc.LoadBalancer.PickSubchannelArgs;271 when(mockPicker.pickSubchannel(any(PickSubchannelArgs.class))) in realTransportsHoldsOffIdleness()351 when(failingPicker.pickSubchannel(any(PickSubchannelArgs.class))) in oobTransportDoesNotAffectIdleness()
37 import io.grpc.LoadBalancer.PickSubchannelArgs;428 public PickResult pickSubchannel(PickSubchannelArgs args) { in pickSubchannel()482 public PickResult pickSubchannel(PickSubchannelArgs args) { in pickSubchannel()
39 import io.grpc.LoadBalancer.PickSubchannelArgs;76 private PickSubchannelArgs mockArgs;
39 import io.grpc.LoadBalancer.PickSubchannelArgs;924 public PickResult pickSubchannel(PickSubchannelArgs args) { in pickSubchannel()
56 import io.grpc.LoadBalancer.PickSubchannelArgs;108 private PickSubchannelArgs mockArgs;