Home
last modified time | relevance | path

Searched refs:subchannel3 (Results 1 – 3 of 3) sorted by relevance

/external/grpc-grpc-java/grpclb/src/test/java/io/grpc/grpclb/
DCachedSubchannelPoolTest.java187 Subchannel subchannel3 = pool.takeOrCreateSubchannel(EAG2, ATTRS1); in returnDuplicateAddressSubchannel() local
201 pool.returnSubchannel(subchannel3); in returnDuplicateAddressSubchannel()
204 pool.returnSubchannel(subchannel3); in returnDuplicateAddressSubchannel()
208 verify(subchannel3, never()).shutdown(); in returnDuplicateAddressSubchannel()
216 Subchannel subchannel3 = pool.takeOrCreateSubchannel(EAG2, ATTRS2); in clear() local
227 verify(subchannel3, never()).shutdown(); in clear()
DGrpclbLoadBalancerTest.java962 Subchannel subchannel3 = mockSubchannels.poll(); in grpclbWorking() local
963 verify(subchannel3).requestConnection(); in grpclbWorking()
966 subchannel3.getAddresses()); in grpclbWorking()
984 deliverSubchannelState(subchannel3, ConnectivityStateInfo.forNonError(READY)); in grpclbWorking()
995 new BackendEntry(subchannel3, getLoadRecorder(), "token0003"), in grpclbWorking()
996 new BackendEntry(subchannel3, getLoadRecorder(), "token0005")).inOrder(); in grpclbWorking()
1008 new BackendEntry(subchannel3, getLoadRecorder(), "token0003"), in grpclbWorking()
1010 new BackendEntry(subchannel3, getLoadRecorder(), "token0005")).inOrder(); in grpclbWorking()
1011 verify(subchannelPool, never()).returnSubchannel(same(subchannel3)); in grpclbWorking()
1016 verify(subchannelPool).returnSubchannel(same(subchannel3)); in grpclbWorking()
/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DDelayedClientTransportTest.java294 AbstractSubchannel subchannel3 = mock(AbstractSubchannel.class); in reprocessSemantics() local
301 when(subchannel3.obtainActiveTransport()).thenReturn(null); in reprocessSemantics()
351 PickResult.withSubchannel(subchannel3), // ff3: stay in reprocessSemantics()
356 PickResult.withSubchannel(subchannel3)); // wfr3: stay in reprocessSemantics()