Home
last modified time | relevance | path

Searched refs:ClientTransport (Results 1 – 24 of 24) sorted by relevance

/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DHttp2Ping.java20 import io.grpc.internal.ClientTransport.PingCallback;
93 public void addCallback(final ClientTransport.PingCallback callback, Executor executor) { in addCallback()
124 Map<ClientTransport.PingCallback, Executor> callbacks; in complete()
135 for (Map.Entry<ClientTransport.PingCallback, Executor> entry : callbacks.entrySet()) { in complete()
148 Map<ClientTransport.PingCallback, Executor> callbacks; in failed()
158 for (Map.Entry<ClientTransport.PingCallback, Executor> entry : callbacks.entrySet()) { in failed()
190 private static Runnable asRunnable(final ClientTransport.PingCallback callback, in asRunnable()
205 private static Runnable asRunnable(final ClientTransport.PingCallback callback,
DMetadataApplierImpl.java33 private final ClientTransport transport;
53 ClientTransport transport, MethodDescriptor<?, ?> method, Metadata origHeaders, in MetadataApplierImpl()
DDelayedClientTransport.java150 ClientTransport transport = GrpcUtil.getTransportFromPickResult(pickResult, in newStream()
291 final ClientTransport transport = GrpcUtil.getTransportFromPickResult(pickResult, in reprocess()
354 private void createRealStream(ClientTransport transport) { in createRealStream()
DAbstractSubchannel.java35 abstract ClientTransport obtainActiveTransport(); in obtainActiveTransport()
DManagedClientTransport.java36 public interface ManagedClientTransport extends ClientTransport {
DClientTransport.java34 public interface ClientTransport extends InternalInstrumented<SocketStats> { interface
DFailingClientTransport.java35 class FailingClientTransport implements ClientTransport {
DOobChannel.java89 public ClientTransport get(PickSubchannelArgs args) {
152 ClientTransport obtainActiveTransport() { in setSubchannel()
DGrpcUtil.java665 static ClientTransport getTransportFromPickResult(PickResult result, boolean isWaitForReady) { in getTransportFromPickResult()
666 final ClientTransport transport; in getTransportFromPickResult()
678 return new ClientTransport() { in getTransportFromPickResult()
DKeepAliveManager.java268 transport.ping(new ClientTransport.PingCallback() { in ping()
DManagedChannelImpl.java423 public ClientTransport get(PickSubchannelArgs args) { in get()
452 ClientTransport transport = GrpcUtil.getTransportFromPickResult( in get()
495 ClientTransport transport = in newRetriableStream()
1386 ClientTransport obtainActiveTransport() { in obtainActiveTransport()
DClientCallImpl.java129 ClientTransport get(PickSubchannelArgs args); in get()
241 ClientTransport transport = clientTransportProvider.get( in start()
DInternalSubchannel.java195 ClientTransport obtainActiveTransport() { in obtainActiveTransport()
196 ClientTransport savedTransport = activeTransport; in obtainActiveTransport()
/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DGrpcUtilTest.java233 ClientTransport transport = GrpcUtil.getTransportFromPickResult(pickResult, true); in getTransportFromPickResult_errorPickResult_waitForReady()
242 ClientTransport transport = GrpcUtil.getTransportFromPickResult(pickResult, false); in getTransportFromPickResult_errorPickResult_failFast()
258 ClientTransport transport = GrpcUtil.getTransportFromPickResult(pickResult, true); in getTransportFromPickResult_dropPickResult_waitForReady()
274 ClientTransport transport = GrpcUtil.getTransportFromPickResult(pickResult, false); in getTransportFromPickResult_dropPickResult_failFast()
DKeepAliveManagerTest.java125 verify(transport, times(0)).ping(isA(ClientTransport.PingCallback.class), in keepAlivePingDelayedByIncomingData()
152 ArgumentCaptor<ClientTransport.PingCallback> pingCallbackCaptor = in clientKeepAlivePinger_pingFailure()
153 ArgumentCaptor.forClass(ClientTransport.PingCallback.class); in clientKeepAlivePinger_pingFailure()
155 ClientTransport.PingCallback pingCallback = pingCallbackCaptor.getValue(); in clientKeepAlivePinger_pingFailure()
240 verify(transport, times(0)).ping(isA(ClientTransport.PingCallback.class), isA(Executor.class)); in transportGoesIdle()
DDelayedClientTransportTest.java72 @Mock private ClientTransport mockRealTransport;
73 @Mock private ClientTransport mockRealTransport2;
DClientCallImplTest.java102 @Mock private ClientTransport clientTransport;
109 private ClientTransport transport;
DManagedChannelImplTest.java1500 ClientTransport mockTransport = transportInfo.transport; in pickerReturnsStreamTracer_noDelay()
1538 ClientTransport mockTransport = transportInfo.transport; in pickerReturnsStreamTracer_delayed()
2417 ClientTransport mockTransport = transportInfo.transport; in channelsAndSubchannels_instrumented0()
/external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/
DSendPingCommand.java19 import io.grpc.internal.ClientTransport.PingCallback;
DNettyClientHandler.java32 import io.grpc.internal.ClientTransport.PingCallback;
/external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/
DNettyClientHandlerTest.java61 import io.grpc.internal.ClientTransport;
62 import io.grpc.internal.ClientTransport.PingCallback;
739 private static class PingCallbackImpl implements ClientTransport.PingCallback {
DNettyClientTransportTest.java53 import io.grpc.internal.ClientTransport;
443 ClientTransport.PingCallback pingCallback = new ClientTransport.PingCallback() { in failingToConstructChannelShouldFailGracefully()
/external/grpc-grpc-java/testing/src/main/java/io/grpc/internal/testing/
DAbstractTransportTest.java59 import io.grpc.internal.ClientTransport;
496 ClientTransport.PingCallback mockPingCallback = mock(ClientTransport.PingCallback.class); in ping()
518 ClientTransport.PingCallback mockPingCallback = mock(ClientTransport.PingCallback.class); in ping_duringShutdown()
538 ClientTransport.PingCallback mockPingCallback = mock(ClientTransport.PingCallback.class); in ping_afterTermination()
/external/grpc-grpc-java/okhttp/src/test/java/io/grpc/okhttp/
DOkHttpClientTransportTest.java71 import io.grpc.internal.ClientTransport;
2029 static class PingCallbackImpl implements ClientTransport.PingCallback {