| /external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/ |
| D | ClientTransportLifecycleManager.java | 32 private boolean transportTerminated; field in ClientTransportLifecycleManager
65 if (transportTerminated) { in notifyTerminated()
68 transportTerminated = true; in notifyTerminated()
70 listener.transportTerminated(); in notifyTerminated()
|
| D | NettyServerTransport.java | 198 listener.transportTerminated(); in notifyTerminated()
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | DelayedClientTransportTest.java | 150 verify(transportListener).transportTerminated(); in newStreamThenAssignTransportThenShutdown()
160 verify(transportListener).transportTerminated(); in transportTerminatedThenAssignTransport()
169 verify(transportListener).transportTerminated(); in assignTransportThenShutdownThenNewStream()
181 verify(transportListener).transportTerminated(); in assignTransportThenShutdownNowThenNewStream()
216 verify(transportListener, times(0)).transportTerminated(); in newStreamThenShutdownTransportThenAssignTransport()
227 verify(transportListener).transportTerminated(); in newStreamThenShutdownTransportThenAssignTransport()
246 verify(transportListener, times(0)).transportTerminated(); in newStreamThenShutdownTransportThenCancelStream()
249 verify(transportListener).transportTerminated(); in newStreamThenShutdownTransportThenCancelStream()
258 verify(transportListener).transportTerminated(); in shutdownThenNewStream()
271 verify(transportListener).transportTerminated(); in startStreamThenShutdownNow()
[all …]
|
| D | ServerImplTest.java | 263 serverTransport.listener.transportTerminated(); in startStopImmediateWithChildTransport()
292 serverTransport.listener.transportTerminated(); in startShutdownNowImmediateWithChildTransport()
322 serverTransport.listener.transportTerminated(); in shutdownNowAfterShutdown()
358 serverTransport.listener.transportTerminated(); in shutdownNowAfterSlowShutdown()
590 public void transportTerminated(Attributes attrs) { in transportFilters()
611 public void transportTerminated(Attributes attrs) { in transportFilters()
837 transportListener.transportTerminated(); in testNoDeadlockOnTransportShutdown()
1312 listener.transportTerminated(); in channelz_transport_membershp()
1387 listener.transportTerminated(); in shutdown()
1392 listener.transportTerminated(); in shutdownNow()
|
| D | InternalSubchannelTest.java | 695 transportInfo.listener.transportTerminated(); in shutdownWhenReady()
713 transportInfo.listener.transportTerminated(); in shutdownBeforeTransportCreated()
770 transportInfo.listener.transportTerminated(); in shutdownBeforeTransportReady()
873 t0.listener.transportTerminated(); in transportTerminateWithoutExitingInUse()
983 t0.listener.transportTerminated(); in channelzMembership()
|
| D | ManagedChannelImplTest.java | 359 transportInfo.listener.transportTerminated(); in channelzMembership_subchannel()
396 transportInfo.listener.transportTerminated(); in channelzMembership_oob()
544 transportListener.transportTerminated(); in subtestCallsAndShutdown()
670 transportListener.transportTerminated(); in callOptionsExecutor()
1101 transportInfo1.listener.transportTerminated(); in subchannels()
1103 transportInfo2.listener.transportTerminated(); in subchannels()
1128 ti1.listener.transportTerminated(); in subchannelsWhenChannelShutdownNow()
1131 ti2.listener.transportTerminated(); in subchannelsWhenChannelShutdownNow()
1196 transportInfo.listener.transportTerminated(); in oobchannels()
1261 transportInfo.listener.transportTerminated(); in oobchannels()
[all …]
|
| /external/grpc-grpc-java/cronet/src/test/java/io/grpc/cronet/ |
| D | CronetClientTransportTest.java | 116 verify(clientTransportListener, times(0)).transportTerminated(); in shutdownTransport()
120 verify(clientTransportListener, times(0)).transportTerminated(); in shutdownTransport()
123 verify(clientTransportListener, times(1)).transportTerminated(); in shutdownTransport()
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/ |
| D | ServerTransportFilter.java | 55 public void transportTerminated(Attributes transportAttrs) { in transportTerminated() method in ServerTransportFilter
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | ServerTransportListener.java | 48 void transportTerminated(); in transportTerminated() method
|
| D | ManagedClientTransport.java | 92 void transportTerminated(); in transportTerminated() method
|
| D | ServerImpl.java | 406 public void transportTerminated() { in transportTerminated() method in ServerImpl.ServerTransportListenerImpl
412 filter.transportTerminated(attributes); in transportTerminated()
|
| D | DelayedClientTransport.java | 117 listener.transportTerminated(); in start()
|
| D | OobChannel.java | 122 public void transportTerminated() { in OobChannel()
|
| D | InternalSubchannel.java | 616 public void transportTerminated() { in transportTerminated() method in InternalSubchannel.TransportListener
|
| D | ManagedChannelImpl.java | 256 public void transportTerminated() {
|
| /external/grpc-grpc-java/okhttp/src/test/java/io/grpc/okhttp/ |
| D | OkHttpClientTransportTest.java | 297 verify(transportListener, timeout(TIME_OUT_MS)).transportTerminated(); in nextFrameThrowIoException()
323 verify(transportListener, timeout(TIME_OUT_MS)).transportTerminated(); in nextFrameThrowsError()
339 verify(transportListener, timeout(TIME_OUT_MS)).transportTerminated(); in nextFrameReturnFalse()
380 verify(transportListener, timeout(TIME_OUT_MS)).transportTerminated(); in receivedHeadersForInvalidStreamShouldKillConnection()
391 verify(transportListener, timeout(TIME_OUT_MS)).transportTerminated(); in receivedDataForInvalidStreamShouldKillConnection()
822 verify(transportListener, timeout(TIME_OUT_MS)).transportTerminated(); in stopNormally()
847 verify(transportListener, never()).transportTerminated(); in receiveGoAway()
882 verify(transportListener, timeout(TIME_OUT_MS)).transportTerminated(); in receiveGoAway()
918 verify(transportListener, timeout(TIME_OUT_MS)).transportTerminated(); in streamIdExhausted()
1225 verify(transportListener, timeout(TIME_OUT_MS)).transportTerminated(); in receiveDataForUnknownStreamUpdateConnectionWindow()
[all …]
|
| /external/grpc-grpc-java/testing/src/main/java/io/grpc/internal/testing/ |
| D | AbstractTransportTest.java | 296 verify(mockClientTransportListener, timeout(TIMEOUT_MS)).transportTerminated(); in serverNotListening()
300 inOrder.verify(mockClientTransportListener).transportTerminated(); in serverNotListening()
313 verify(mockClientTransportListener, timeout(TIMEOUT_MS)).transportTerminated(); in clientStartStop()
315 inOrder.verify(mockClientTransportListener).transportTerminated(); in clientStartStop()
329 verify(mockClientTransportListener, timeout(TIMEOUT_MS)).transportTerminated(); in clientStartAndStopOnceConnected()
331 inOrder.verify(mockClientTransportListener).transportTerminated(); in clientStartAndStopOnceConnected()
402 verify(mockClientTransportListener, never()).transportTerminated(); in openStreamPreventsTermination()
408 verify(mockClientTransportListener, timeout(TIMEOUT_MS)).transportTerminated(); in openStreamPreventsTermination()
435 verify(mockClientTransportListener, timeout(TIMEOUT_MS)).transportTerminated(); in shutdownNowKillsClientStream()
472 verify(mockClientTransportListener, timeout(TIMEOUT_MS)).transportTerminated(); in shutdownNowKillsServerStream()
[all …]
|
| /external/grpc-grpc-java/cronet/src/main/java/io/grpc/cronet/ |
| D | CronetClientTransport.java | 249 listener.transportTerminated();
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/inprocess/ |
| D | InProcessTransport.java | 263 clientTransportListener.transportTerminated();
265 serverTransportListener.transportTerminated();
|
| /external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/ |
| D | NettyClientTransportTest.java | 776 public void transportTerminated() {} in transportCreated() method in NettyClientTransportTest.EchoServerListener
|
| D | NettyServerHandlerTest.java | 156 public void transportTerminated() { in transportTerminated() method in NettyServerHandlerTest.ServerTransportListenerImpl
|
| /external/grpc-grpc-java/okhttp/src/main/java/io/grpc/okhttp/ |
| D | OkHttpClientTransport.java | 989 listener.transportTerminated(); in run()
|