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 {
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()
DAutoConfiguredLoadBalancerFactory.java30 import io.grpc.LoadBalancer.PickSubchannelArgs;
240 public PickResult pickSubchannel(PickSubchannelArgs args) { in pickSubchannel()
253 public PickResult pickSubchannel(PickSubchannelArgs args) { in pickSubchannel()
DClientCallImpl.java44 import io.grpc.LoadBalancer.PickSubchannelArgs;
129 ClientTransport get(PickSubchannelArgs args); in get()
DManagedChannelImpl.java55 import io.grpc.LoadBalancer.PickSubchannelArgs;
423 public ClientTransport get(PickSubchannelArgs args) { in get()
733 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.java177 public abstract PickResult pickSubchannel(PickSubchannelArgs args); in pickSubchannel()
196 public abstract static class PickSubchannelArgs { class in LoadBalancer
/external/grpc-grpc-java/grpclb/src/test/java/io/grpc/grpclb/
DGrpclbLoadBalancerTest.java58 import io.grpc.LoadBalancer.PickSubchannelArgs;
307 PickSubchannelArgs args1 = mock(PickSubchannelArgs.class); in roundRobinPickerNoDrop()
316 PickSubchannelArgs args2 = mock(PickSubchannelArgs.class); in roundRobinPickerNoDrop()
323 PickSubchannelArgs args3 = mock(PickSubchannelArgs.class); in roundRobinPickerNoDrop()
349 PickSubchannelArgs args1 = mock(PickSubchannelArgs.class); in roundRobinPickerWithDrop()
358 PickSubchannelArgs args2 = mock(PickSubchannelArgs.class); in roundRobinPickerWithDrop()
365 PickSubchannelArgs args3 = mock(PickSubchannelArgs.class); in roundRobinPickerWithDrop()
373 PickSubchannelArgs args4 = mock(PickSubchannelArgs.class); in roundRobinPickerWithDrop()
380 PickSubchannelArgs args5 = mock(PickSubchannelArgs.class); in roundRobinPickerWithDrop()
393 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.java78 import io.grpc.LoadBalancer.PickSubchannelArgs;
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()
1505 when(mockPicker.pickSubchannel(any(PickSubchannelArgs.class))).thenReturn( in pickerReturnsStreamTracer_noDelay()
1513 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;
918 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;