| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | DelayedClientTransportTest.java | 69 @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 …]
|
| D | ServerImplTest.java | 409 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 …]
|
| D | ManagedChannelImplTest.java | 444 ManagedClientTransport.Listener transportListener = transportInfo.listener; in subtestCallsAndShutdown() local
449 transportListener.transportReady(); in subtestCallsAndShutdown()
540 transportListener.transportShutdown(Status.UNAVAILABLE); in subtestCallsAndShutdown()
543 transportListener.transportTerminated(); in subtestCallsAndShutdown()
644 ManagedClientTransport.Listener transportListener = transportInfo.listener; in callOptionsExecutor() local
647 transportListener.transportReady(); in callOptionsExecutor()
668 transportListener.transportShutdown(Status.UNAVAILABLE); in callOptionsExecutor()
669 transportListener.transportTerminated(); in callOptionsExecutor()
1901 ManagedClientTransport.Listener transportListener = transportInfo.listener; in idleMode_resetsDelayedTransportPicker() local
1904 transportListener.transportReady(); in idleMode_resetsDelayedTransportPicker()
[all …]
|
| /external/grpc-grpc-java/okhttp/src/test/java/io/grpc/okhttp/ |
| D | OkHttpClientTransportTest.java | 146 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/ |
| D | NettyServerHandler.java | 105 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()
|
| D | NettyServer.java | 209 ServerTransportListener transportListener; in start()
220 transportListener = listener.transportCreated(transport); in start()
238 transport.start(transportListener); in start()
|
| D | NettyServerTransport.java | 253 ServerTransportListener transportListener, ChannelPromise channelUnused) { in createHandler() argument
255 transportListener, in createHandler()
|
| D | NettyClientTransport.java | 186 public Runnable start(Listener transportListener) {
188 Preconditions.checkNotNull(transportListener, "listener"));
|
| /external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/ |
| D | NettyServerHandlerTest.java | 124 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()
|