Home
last modified time | relevance | path

Searched refs:PickSubchannelArgs (Results 1 – 16 of 16) sorted by relevance

/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DDelayedClientTransport.java27 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()
DPickSubchannelArgsImpl.java23 import io.grpc.LoadBalancer.PickSubchannelArgs;
27 final class PickSubchannelArgsImpl extends PickSubchannelArgs {
DAutoConfiguredLoadBalancerFactory.java27 import io.grpc.LoadBalancer.PickSubchannelArgs;
209 public PickResult pickSubchannel(PickSubchannelArgs args) { in pickSubchannel()
222 public PickResult pickSubchannel(PickSubchannelArgs args) { in pickSubchannel()
DOobChannel.java41 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()
DClientCallImpl.java44 import io.grpc.LoadBalancer.PickSubchannelArgs;
129 ClientTransport get(PickSubchannelArgs args); in get()
DManagedChannelImpl.java55 import io.grpc.LoadBalancer.PickSubchannelArgs;
468 public ClientTransport get(PickSubchannelArgs args) {
753 public PickResult pickSubchannel(PickSubchannelArgs args) { in panic()
/external/grpc-grpc-java/core/src/main/java/io/grpc/
DPickFirstBalancerFactory.java26 import io.grpc.LoadBalancer.PickSubchannelArgs;
141 public PickResult pickSubchannel(PickSubchannelArgs args) { in pickSubchannel()
155 public PickResult pickSubchannel(PickSubchannelArgs args) { in pickSubchannel()
DLoadBalancer.java171 public abstract PickResult pickSubchannel(PickSubchannelArgs args); in pickSubchannel()
190 public abstract static class PickSubchannelArgs { class in LoadBalancer
/external/grpc-grpc-java/grpclb/src/test/java/io/grpc/grpclb/
DGrpclbLoadBalancerTest.java59 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 …]
/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DDelayedClientTransportTest.java39 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()
DManagedChannelImplTest.java79 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 …]
DManagedChannelImplIdlenessTest.java44 import io.grpc.LoadBalancer.PickSubchannelArgs;
271 when(mockPicker.pickSubchannel(any(PickSubchannelArgs.class))) in realTransportsHoldsOffIdleness()
351 when(failingPicker.pickSubchannel(any(PickSubchannelArgs.class))) in oobTransportDoesNotAffectIdleness()
/external/grpc-grpc-java/core/src/main/java/io/grpc/util/
DRoundRobinLoadBalancerFactory.java37 import io.grpc.LoadBalancer.PickSubchannelArgs;
428 public PickResult pickSubchannel(PickSubchannelArgs args) { in pickSubchannel()
482 public PickResult pickSubchannel(PickSubchannelArgs args) { in pickSubchannel()
/external/grpc-grpc-java/core/src/test/java/io/grpc/
DPickFirstLoadBalancerTest.java39 import io.grpc.LoadBalancer.PickSubchannelArgs;
76 private PickSubchannelArgs mockArgs;
/external/grpc-grpc-java/grpclb/src/main/java/io/grpc/grpclb/
DGrpclbState.java39 import io.grpc.LoadBalancer.PickSubchannelArgs;
924 public PickResult pickSubchannel(PickSubchannelArgs args) { in pickSubchannel()
/external/grpc-grpc-java/core/src/test/java/io/grpc/util/
DRoundRobinLoadBalancerTest.java56 import io.grpc.LoadBalancer.PickSubchannelArgs;
108 private PickSubchannelArgs mockArgs;