Searched refs:serverTransport (Results 1 – 2 of 2) sorted by relevance
255 DelayedShutdownServerTransport serverTransport = new DelayedShutdownServerTransport(); in startStopImmediateWithChildTransport() local256 transportServer.registerNewServerTransport(serverTransport); in startStopImmediateWithChildTransport()260 assertTrue(serverTransport.shutdown); in startStopImmediateWithChildTransport()263 serverTransport.listener.transportTerminated(); in startStopImmediateWithChildTransport()284 DelayedShutdownServerTransport serverTransport = new DelayedShutdownServerTransport(); in startShutdownNowImmediateWithChildTransport() local285 transportServer.registerNewServerTransport(serverTransport); in startShutdownNowImmediateWithChildTransport()289 assertTrue(serverTransport.shutdown); in startShutdownNowImmediateWithChildTransport()292 serverTransport.listener.transportTerminated(); in startShutdownNowImmediateWithChildTransport()313 DelayedShutdownServerTransport serverTransport = new DelayedShutdownServerTransport(); in shutdownNowAfterShutdown() local314 transportServer.registerNewServerTransport(serverTransport); in shutdownNowAfterShutdown()[all …]
148 private ServerTransport serverTransport; field in AbstractTransportTest199 if (serverTransport != null) { in tearDown()200 serverTransport.shutdownNow(Status.UNKNOWN.withDescription("teardown")); in tearDown()246 serverTransport = serverTransportListener.transport; in frameAfterRstStreamShouldNotBreakClientChannel()368 serverTransport = serverTransportListener.transport; in openStreamPreventsTermination()382 serverTransport.shutdown(); in openStreamPreventsTermination()383 serverTransport = null; in openStreamPreventsTermination()420 serverTransport = serverTransportListener.transport; in shutdownNowKillsClientStream()457 serverTransport = serverTransportListener.transport; in shutdownNowKillsServerStream()468 serverTransport.shutdownNow(shutdownStatus); in shutdownNowKillsServerStream()[all …]