Home
last modified time | relevance | path

Searched refs:ManagedClientTransport (Results 1 – 18 of 18) sorted by relevance

/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DTestUtils.java49 final ManagedClientTransport.Listener listener;
52 ManagedClientTransport.Listener listener) { in MockClientTransportInfo()
87 mockTransport, (ManagedClientTransport.Listener) invocation.getArguments()[0])); in captureTransports()
90 }).when(mockTransport).start(any(ManagedClientTransport.Listener.class)); in captureTransports()
DManagedChannelImplTest.java443 verify(mockTransport).start(any(ManagedClientTransport.Listener.class)); in subtestCallsAndShutdown()
444 ManagedClientTransport.Listener transportListener = transportInfo.listener; in subtestCallsAndShutdown()
644 ManagedClientTransport.Listener transportListener = transportInfo.listener; in callOptionsExecutor()
1901 ManagedClientTransport.Listener transportListener = transportInfo.listener; in idleMode_resetsDelayedTransportPicker()
1970 ManagedClientTransport.Listener transportListener = transportInfo.listener; in enterIdle_exitsIdleIfDelayedStreamPending()
2000 ManagedClientTransport.Listener transportListener = transportInfo.listener; in updateBalancingStateDoesUpdatePicker()
2489 ManagedClientTransport.Listener transportListener = transportInfo.listener; in channelsAndSubchannels_oob_instrumented0()
2551 ManagedClientTransport.Listener transportListener = transportInfo.listener; in channelsAndSubchannels_oob_instrumented_state()
DDelayedClientTransportTest.java69 @Mock private ManagedClientTransport.Listener transportListener;
/external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/
DClientTransportLifecycleManager.java20 import io.grpc.internal.ManagedClientTransport;
24 private final ManagedClientTransport.Listener listener;
34 public ClientTransportLifecycleManager(ManagedClientTransport.Listener listener) { in ClientTransportLifecycleManager()
/external/grpc-grpc-java/core/src/test/java/io/grpc/inprocess/
DInProcessTransportTest.java22 import io.grpc.internal.ManagedClientTransport;
57 protected ManagedClientTransport newClientTransport(InternalServer server) { in newClientTransport()
/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DInternalSubchannel.java156 private volatile ManagedClientTransport activeTransport;
355 ManagedClientTransport savedTransport = null; in updateAddresses()
388 ManagedClientTransport savedActiveTransport; in shutdown()
457 Collection<ManagedClientTransport> transportsCopy; in shutdownNow()
460 transportsCopy = new ArrayList<ManagedClientTransport>(transports); in shutdownNow()
465 for (ManagedClientTransport transport : transportsCopy) { in shutdownNow()
536 private class TransportListener implements ManagedClientTransport.Listener {
DConnectionClientTransport.java26 public interface ConnectionClientTransport extends ManagedClientTransport {
DManagedClientTransport.java36 public interface ManagedClientTransport extends ClientTransport { interface
DDelayedClientTransport.java50 final class DelayedClientTransport implements ManagedClientTransport {
DOobChannel.java115 this.delayedTransport.start(new ManagedClientTransport.Listener() { in OobChannel()
DManagedChannelImpl.java232 private final ManagedClientTransport.Listener delayedTransportListener =
1478 private final class DelayedTransportListener implements ManagedClientTransport.Listener {
/external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/
DNettyTransportTest.java23 import io.grpc.internal.ManagedClientTransport;
93 protected ManagedClientTransport newClientTransport(InternalServer server) { in newClientTransport()
DNettyClientTransportTest.java56 import io.grpc.internal.ManagedClientTransport;
109 private ManagedClientTransport.Listener clientTransportListener;
/external/grpc-grpc-java/okhttp/src/test/java/io/grpc/okhttp/
DOkHttpTransportTest.java24 import io.grpc.internal.ManagedClientTransport;
79 protected ManagedClientTransport newClientTransport(InternalServer server) { in newClientTransport()
DOkHttpClientTransportTest.java73 import io.grpc.internal.ManagedClientTransport;
146 private ManagedClientTransport.Listener transportListener;
1519 ManagedClientTransport.Listener listener = mock(ManagedClientTransport.Listener.class); in unreachableServer()
/external/grpc-grpc-java/cronet/src/test/java/io/grpc/cronet/
DCronetClientTransportTest.java37 import io.grpc.internal.ManagedClientTransport;
60 @Mock private ManagedClientTransport.Listener clientTransportListener;
/external/grpc-grpc-java/core/src/main/java/io/grpc/inprocess/
DInProcessTransport.java45 import io.grpc.internal.ManagedClientTransport;
82 private ManagedClientTransport.Listener clientTransportListener;
105 public synchronized Runnable start(ManagedClientTransport.Listener listener) { in start()
/external/grpc-grpc-java/testing/src/main/java/io/grpc/internal/testing/
DAbstractTransportTest.java64 import io.grpc.internal.ManagedClientTransport;
128 protected abstract ManagedClientTransport newClientTransport(InternalServer server); in newClientTransport()
149 private ManagedClientTransport client;
164 private ManagedClientTransport.Listener mockClientTransportListener
165 = mock(ManagedClientTransport.Listener.class);
1707 ManagedClientTransport client = newClientTransport(server); in socketStats()
1744 ManagedClientTransport client = newClientTransport(server); in doPingPong()
1745 ManagedClientTransport.Listener listener = mock(ManagedClientTransport.Listener.class); in doPingPong()
1812 ManagedClientTransport clientTransport, in startTransport()
1813 ManagedClientTransport.Listener listener) { in startTransport()