Searched refs:transportInfo (Results 1 – 2 of 2) sorted by relevance
353 MockClientTransportInfo transportInfo = transports.poll(); in channelzMembership_subchannel() local354 assertNotNull(transportInfo); in channelzMembership_subchannel()355 assertTrue(channelz.containsClientSocket(transportInfo.transport.getLogId())); in channelzMembership_subchannel()358 transportInfo.listener.transportTerminated(); in channelzMembership_subchannel()359 assertFalse(channelz.containsClientSocket(transportInfo.transport.getLogId())); in channelzMembership_subchannel()390 MockClientTransportInfo transportInfo = transports.poll(); in channelzMembership_oob() local391 assertNotNull(transportInfo); in channelzMembership_oob()392 assertTrue(channelz.containsClientSocket(transportInfo.transport.getLogId())); in channelzMembership_oob()395 transportInfo.listener.transportTerminated(); in channelzMembership_oob()396 assertFalse(channelz.containsClientSocket(transportInfo.transport.getLogId())); in channelzMembership_oob()[all …]
687 MockClientTransportInfo transportInfo = transports.poll(); in shutdownWhenReady() local688 transportInfo.listener.transportReady(); in shutdownWhenReady()692 verify(transportInfo.transport).shutdown(same(SHUTDOWN_REASON)); in shutdownWhenReady()695 transportInfo.listener.transportTerminated(); in shutdownWhenReady()697 verify(transportInfo.transport, never()).shutdownNow(any(Status.class)); in shutdownWhenReady()711 MockClientTransportInfo transportInfo = transports.poll(); in shutdownBeforeTransportCreated() local712 transportInfo.listener.transportShutdown(Status.UNAVAILABLE); in shutdownBeforeTransportCreated()713 transportInfo.listener.transportTerminated(); in shutdownBeforeTransportCreated()759 MockClientTransportInfo transportInfo = transports.poll(); in shutdownBeforeTransportReady() local767 verify(transportInfo.transport).shutdown(same(SHUTDOWN_REASON)); in shutdownBeforeTransportReady()[all …]