Home
last modified time | relevance | path

Searched refs:subchannel2 (Results 1 – 7 of 7) sorted by relevance

/external/grpc-grpc-java/grpclb/src/test/java/io/grpc/grpclb/
DCachedSubchannelPoolTest.java114 Subchannel subchannel2 = pool.takeOrCreateSubchannel(EAG2, ATTRS2); in subchannelExpireAfterReturned() local
115 assertThat(subchannel2).isNotNull(); in subchannelExpireAfterReturned()
116 assertThat(subchannel2).isNotSameAs(subchannel1); in subchannelExpireAfterReturned()
125 pool.returnSubchannel(subchannel2); in subchannelExpireAfterReturned()
133 verify(subchannel2).shutdown(); in subchannelExpireAfterReturned()
145 Subchannel subchannel2 = pool.takeOrCreateSubchannel(EAG2, ATTRS2); in subchannelReused() local
146 assertThat(subchannel2).isNotNull(); in subchannelReused()
147 assertThat(subchannel2).isNotSameAs(subchannel1); in subchannelReused()
159 pool.returnSubchannel(subchannel2); in subchannelReused()
163 verify(subchannel2, never()).shutdown(); in subchannelReused()
[all …]
DGrpclbLoadBalancerTest.java436 Subchannel subchannel2 = mockSubchannels.poll(); in loadReporting() local
438 deliverSubchannelState(subchannel2, ConnectivityStateInfo.forNonError(CONNECTING)); in loadReporting()
440 deliverSubchannelState(subchannel2, ConnectivityStateInfo.forNonError(READY)); in loadReporting()
452 new BackendEntry(subchannel2, getLoadRecorder(), "token0002")).inOrder(); in loadReporting()
489 assertSame(subchannel2, pick3.getSubchannel()); in loadReporting()
877 Subchannel subchannel2 = mockSubchannels.poll(); in grpclbWorking() local
879 verify(subchannel2).requestConnection(); in grpclbWorking()
885 subchannel2.getAddresses()); in grpclbWorking()
888 deliverSubchannelState(subchannel2, ConnectivityStateInfo.forNonError(CONNECTING)); in grpclbWorking()
896 deliverSubchannelState(subchannel2, ConnectivityStateInfo.forNonError(READY)); in grpclbWorking()
[all …]
/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DDelayedClientTransportTest.java293 AbstractSubchannel subchannel2 = mock(AbstractSubchannel.class); in reprocessSemantics() local
300 when(subchannel2.obtainActiveTransport()).thenReturn(mockRealTransport2); in reprocessSemantics()
354 PickResult.withSubchannel(subchannel2), // wfr1: proceed in reprocessSemantics()
396 PickResult.withSubchannel(subchannel2), // ff4 in reprocessSemantics()
397 PickResult.withSubchannel(subchannel2), // wfr2 in reprocessSemantics()
399 PickResult.withSubchannel(subchannel2), // wfr4 in reprocessSemantics()
DManagedChannelImplTest.java572 Subchannel subchannel2 = helper.createSubchannel(addressGroup, Attributes.EMPTY); in noMoreCallbackAfterLoadBalancerShutdown() local
574 subchannel2.requestConnection(); in noMoreCallbackAfterLoadBalancerShutdown()
588 .handleSubchannelState(same(subchannel2), stateInfoCaptor.capture()); in noMoreCallbackAfterLoadBalancerShutdown()
1994 Subchannel subchannel2 = helper.createSubchannel(addressGroup, Attributes.EMPTY); in updateBalancingStateDoesUpdatePicker() local
1995 subchannel2.requestConnection(); in updateBalancingStateDoesUpdatePicker()
2015 .thenReturn(PickResult.withSubchannel(subchannel2)); in updateBalancingStateDoesUpdatePicker()
/external/grpc-grpc-java/core/src/test/java/io/grpc/
DLoadBalancerTest.java37 private final Subchannel subchannel2 = mock(Subchannel.class); field in LoadBalancerTest
97 PickResult sc4 = PickResult.withSubchannel(subchannel2); in pickResult_equals()
/external/grpc-grpc-java/core/src/test/java/io/grpc/util/
DRoundRobinLoadBalancerTest.java298 Subchannel subchannel2 = mock(Subchannel.class); in pickerRoundRobin() local
301 Lists.<Subchannel>newArrayList(subchannel, subchannel1, subchannel2)), in pickerRoundRobin()
304 assertThat(picker.getList()).containsExactly(subchannel, subchannel1, subchannel2); in pickerRoundRobin()
308 assertEquals(subchannel2, picker.pickSubchannel(mockArgs).getSubchannel()); in pickerRoundRobin()
/external/grpc-grpc-java/services/src/test/java/io/grpc/services/
DChannelzProtoUtilTest.java648 TestChannel subchannel2 = new TestChannel(); in toSubchannel_subchannelChildren() local
650 .setSubchannels(ImmutableList.<InternalWithLogId>of(subchannel1, subchannel2)) in toSubchannel_subchannelChildren()
656 .addSubchannelRef(ChannelzProtoUtil.toSubchannelRef(subchannel2)) in toSubchannel_subchannelChildren()