Home
last modified time | relevance | path

Searched refs:pickResult (Results 1 – 5 of 5) sorted by relevance

/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DGrpcUtilTest.java232 PickResult pickResult = PickResult.withError(status); in getTransportFromPickResult_errorPickResult_waitForReady() local
233 ClientTransport transport = GrpcUtil.getTransportFromPickResult(pickResult, true); in getTransportFromPickResult_errorPickResult_waitForReady()
241 PickResult pickResult = PickResult.withError(status); in getTransportFromPickResult_errorPickResult_failFast() local
242 ClientTransport transport = GrpcUtil.getTransportFromPickResult(pickResult, false); in getTransportFromPickResult_errorPickResult_failFast()
257 PickResult pickResult = PickResult.withDrop(status); in getTransportFromPickResult_dropPickResult_waitForReady() local
258 ClientTransport transport = GrpcUtil.getTransportFromPickResult(pickResult, true); in getTransportFromPickResult_dropPickResult_waitForReady()
273 PickResult pickResult = PickResult.withDrop(status); in getTransportFromPickResult_dropPickResult_failFast() local
274 ClientTransport transport = GrpcUtil.getTransportFromPickResult(pickResult, false); in getTransportFromPickResult_dropPickResult_failFast()
/external/grpc-grpc-java/core/src/test/java/io/grpc/
DPickFirstLoadBalancerTest.java192 PickResult pickResult = pickerCaptor.getValue().pickSubchannel(mockArgs); in nameResolutionError() local
193 assertEquals(null, pickResult.getSubchannel()); in nameResolutionError()
194 assertEquals(error, pickResult.getStatus()); in nameResolutionError()
232 PickResult pickResult = pickerCaptor.getValue().pickSubchannel(mockArgs); in nameResolutionErrorWithStateChanges() local
233 assertEquals(null, pickResult.getSubchannel()); in nameResolutionErrorWithStateChanges()
234 assertEquals(error, pickResult.getStatus()); in nameResolutionErrorWithStateChanges()
241 pickResult = pickerCaptor.getValue().pickSubchannel(mockArgs); in nameResolutionErrorWithStateChanges()
242 assertEquals(null, pickResult.getSubchannel()); in nameResolutionErrorWithStateChanges()
243 assertEquals(error2, pickResult.getStatus()); in nameResolutionErrorWithStateChanges()
/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DDelayedClientTransport.java149 PickResult pickResult = picker.pickSubchannel(args); in newStream() local
150 ClientTransport transport = GrpcUtil.getTransportFromPickResult(pickResult, in newStream()
289 PickResult pickResult = picker.pickSubchannel(stream.args); in reprocess() local
291 final ClientTransport transport = GrpcUtil.getTransportFromPickResult(pickResult, in reprocess()
DManagedChannelImpl.java494 PickResult pickResult = pickerCopy.pickSubchannel(args);
496 pickResult, args.getCallOptions().isWaitForReady());
/external/grpc-grpc-java/core/src/test/java/io/grpc/util/
DRoundRobinLoadBalancerTest.java326 LoadBalancer.PickResult pickResult = pickerCaptor.getValue().pickSubchannel(mockArgs); in nameResolutionErrorWithNoChannels() local
327 assertNull(pickResult.getSubchannel()); in nameResolutionErrorWithNoChannels()
328 assertEquals(error, pickResult.getStatus()); in nameResolutionErrorWithNoChannels()
349 LoadBalancer.PickResult pickResult = pickerCaptor.getValue().pickSubchannel(mockArgs); in nameResolutionErrorWithActiveChannels() local
350 assertEquals(readySubchannel, pickResult.getSubchannel()); in nameResolutionErrorWithActiveChannels()
351 assertEquals(Status.OK.getCode(), pickResult.getStatus().getCode()); in nameResolutionErrorWithActiveChannels()