Searched refs:transportInfo (Results 1 – 2 of 2) sorted by relevance
354 MockClientTransportInfo transportInfo = transports.poll(); in channelzMembership_subchannel() local355 assertNotNull(transportInfo); in channelzMembership_subchannel()356 assertTrue(channelz.containsClientSocket(transportInfo.transport.getLogId())); in channelzMembership_subchannel()359 transportInfo.listener.transportTerminated(); in channelzMembership_subchannel()360 assertFalse(channelz.containsClientSocket(transportInfo.transport.getLogId())); in channelzMembership_subchannel()391 MockClientTransportInfo transportInfo = transports.poll(); in channelzMembership_oob() local392 assertNotNull(transportInfo); in channelzMembership_oob()393 assertTrue(channelz.containsClientSocket(transportInfo.transport.getLogId())); in channelzMembership_oob()396 transportInfo.listener.transportTerminated(); in channelzMembership_oob()397 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 …]