Home
last modified time | relevance | path

Searched refs:transportListener (Results 1 – 10 of 10) sorted by relevance

/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DDelayedClientTransportTest.java69 @Mock private ManagedClientTransport.Listener transportListener; field in DelayedClientTransportTest
115 delayedTransport.start(transportListener); in setUp()
149 verify(transportListener).transportShutdown(same(SHUTDOWN_STATUS)); in newStreamThenAssignTransportThenShutdown()
150 verify(transportListener).transportTerminated(); in newStreamThenAssignTransportThenShutdown()
159 verify(transportListener).transportShutdown(same(SHUTDOWN_STATUS)); in transportTerminatedThenAssignTransport()
160 verify(transportListener).transportTerminated(); in transportTerminatedThenAssignTransport()
162 verifyNoMoreInteractions(transportListener); in transportTerminatedThenAssignTransport()
168 verify(transportListener).transportShutdown(same(SHUTDOWN_STATUS)); in assignTransportThenShutdownThenNewStream()
169 verify(transportListener).transportTerminated(); in assignTransportThenShutdownThenNewStream()
180 verify(transportListener).transportShutdown(any(Status.class)); in assignTransportThenShutdownNowThenNewStream()
[all …]
DServerImplTest.java409 ServerTransportListener transportListener in methodNotFound() local
411 transportListener.transportReady(Attributes.EMPTY); in methodNotFound()
417 transportListener.streamCreated(stream, "Waiter/nonexist", requestHeaders); in methodNotFound()
436 ServerTransportListener transportListener in decompressorNotFound() local
438 transportListener.transportReady(Attributes.EMPTY); in decompressorNotFound()
446 transportListener.streamCreated(stream, "Waiter/nonexist", requestHeaders); in decompressorNotFound()
489 ServerTransportListener transportListener in basicExchangeHelper() local
491 transportListener.transportReady(Attributes.EMPTY); in basicExchangeHelper()
499 transportListener.streamCreated(stream, "Waiter/serve", requestHeaders); in basicExchangeHelper()
624 ServerTransportListener transportListener in transportFilters() local
[all …]
DManagedChannelImplTest.java445 ManagedClientTransport.Listener transportListener = transportInfo.listener; in subtestCallsAndShutdown() local
450 transportListener.transportReady(); in subtestCallsAndShutdown()
541 transportListener.transportShutdown(Status.UNAVAILABLE); in subtestCallsAndShutdown()
544 transportListener.transportTerminated(); in subtestCallsAndShutdown()
645 ManagedClientTransport.Listener transportListener = transportInfo.listener; in callOptionsExecutor() local
648 transportListener.transportReady(); in callOptionsExecutor()
669 transportListener.transportShutdown(Status.UNAVAILABLE); in callOptionsExecutor()
670 transportListener.transportTerminated(); in callOptionsExecutor()
1900 ManagedClientTransport.Listener transportListener = transportInfo.listener; in idleMode_resetsDelayedTransportPicker() local
1903 transportListener.transportReady(); in idleMode_resetsDelayedTransportPicker()
[all …]
/external/grpc-grpc-java/okhttp/src/test/java/io/grpc/okhttp/
DOkHttpClientTransportTest.java146 private ManagedClientTransport.Listener transportListener; field in OkHttpClientTransportTest
218 clientTransport.start(transportListener); in startTransport()
296 verify(transportListener, timeout(TIME_OUT_MS)).transportShutdown(isA(Status.class)); in nextFrameThrowIoException()
297 verify(transportListener, timeout(TIME_OUT_MS)).transportTerminated(); in nextFrameThrowIoException()
322 verify(transportListener, timeout(TIME_OUT_MS)).transportShutdown(isA(Status.class)); in nextFrameThrowsError()
323 verify(transportListener, timeout(TIME_OUT_MS)).transportTerminated(); in nextFrameThrowsError()
338 verify(transportListener, timeout(TIME_OUT_MS)).transportShutdown(isA(Status.class)); in nextFrameReturnFalse()
339 verify(transportListener, timeout(TIME_OUT_MS)).transportTerminated(); in nextFrameReturnFalse()
379 verify(transportListener).transportShutdown(isA(Status.class)); in receivedHeadersForInvalidStreamShouldKillConnection()
380 verify(transportListener, timeout(TIME_OUT_MS)).transportTerminated(); in receivedHeadersForInvalidStreamShouldKillConnection()
[all …]
/external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/
DNettyServerHandler.java105 private final ServerTransportListener transportListener; field in NettyServerHandler
133 ServerTransportListener transportListener, in newHandler() argument
159 transportListener, in newHandler()
180 ServerTransportListener transportListener, in newHandler() argument
224 transportListener, in newHandler()
238 ServerTransportListener transportListener, in NettyServerHandler() argument
301 this.transportListener = checkNotNull(transportListener, "transportListener"); in NettyServerHandler()
437 transportListener.streamCreated(stream, method, metadata); in onHeadersRead()
714 attributes = transportListener.transportReady(negotiationAttributes); in onSettingsRead()
DNettyServer.java209 ServerTransportListener transportListener; in start()
220 transportListener = listener.transportCreated(transport); in start()
238 transport.start(transportListener); in start()
DNettyServerTransport.java253 ServerTransportListener transportListener, ChannelPromise channelUnused) { in createHandler() argument
255 transportListener, in createHandler()
DNettyClientTransport.java182 public Runnable start(Listener transportListener) {
184 Preconditions.checkNotNull(transportListener, "listener"));
/external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/
DNettyServerHandlerTest.java124 private final ServerTransportListener transportListener = field in NettyServerHandlerTest
208 verify(transportListener, never()).transportReady(any(Attributes.class)); in transportReadyDelayedUntilConnectionPreface()
213 verify(transportListener).transportReady(any(Attributes.class)); in transportReadyDelayedUntilConnectionPreface()
501 verify(transportListener).streamCreated(streamCaptor.capture(), methodCaptor.capture(), in headersSupportExtensionContentType()
1045 verify(transportListener).streamCreated(streamCaptor.capture(), methodCaptor.capture(), in createStream()
1065 transportListener, in newHandler()
/external/grpc-grpc-java/netty/shaded/
Dgrpc-netty-shaded-1.14.0.jarMETA-INF/ META-INF/MANIFEST.MF io/ io/grpc/ io/ ...