Home
last modified time | relevance | path

Searched refs:subchannel1 (Results 1 – 6 of 6) sorted by relevance

/external/grpc-grpc-java/grpclb/src/test/java/io/grpc/grpclb/
DCachedSubchannelPoolTest.java110 Subchannel subchannel1 = pool.takeOrCreateSubchannel(EAG1, ATTRS1); in subchannelExpireAfterReturned() local
111 assertThat(subchannel1).isNotNull(); in subchannelExpireAfterReturned()
116 assertThat(subchannel2).isNotSameAs(subchannel1); in subchannelExpireAfterReturned()
119 pool.returnSubchannel(subchannel1); in subchannelExpireAfterReturned()
123 verify(subchannel1, never()).shutdown(); in subchannelExpireAfterReturned()
129 verify(subchannel1).shutdown(); in subchannelExpireAfterReturned()
141 Subchannel subchannel1 = pool.takeOrCreateSubchannel(EAG1, ATTRS1); in subchannelReused() local
142 assertThat(subchannel1).isNotNull(); in subchannelReused()
147 assertThat(subchannel2).isNotSameAs(subchannel1); in subchannelReused()
150 pool.returnSubchannel(subchannel1); in subchannelReused()
[all …]
DGrpclbLoadBalancerTest.java435 Subchannel subchannel1 = mockSubchannels.poll(); in loadReporting() local
437 deliverSubchannelState(subchannel1, ConnectivityStateInfo.forNonError(CONNECTING)); in loadReporting()
439 deliverSubchannelState(subchannel1, ConnectivityStateInfo.forNonError(READY)); in loadReporting()
451 new BackendEntry(subchannel1, getLoadRecorder(), "token0001"), in loadReporting()
460 assertSame(subchannel1, pick1.getSubchannel()); in loadReporting()
526 assertSame(subchannel1, pick1.getSubchannel()); in loadReporting()
602 assertSame(subchannel1, pick1p.getSubchannel()); in loadReporting()
876 Subchannel subchannel1 = mockSubchannels.poll(); in grpclbWorking() local
878 verify(subchannel1).requestConnection(); in grpclbWorking()
882 subchannel1.getAddresses()); in grpclbWorking()
[all …]
/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DDelayedClientTransportTest.java292 AbstractSubchannel subchannel1 = mock(AbstractSubchannel.class); in reprocessSemantics() local
299 when(subchannel1.obtainActiveTransport()).thenReturn(mockRealTransport); in reprocessSemantics()
349 PickResult.withSubchannel(subchannel1), // ff1: proceed in reprocessSemantics()
395 PickResult.withSubchannel(subchannel1), // ff3 in reprocessSemantics()
398 PickResult.withSubchannel(subchannel1), // wfr3 in reprocessSemantics()
442 PickResult.withSubchannel(subchannel1)); in reprocessSemantics()
DManagedChannelImplTest.java571 Subchannel subchannel1 = helper.createSubchannel(addressGroup, Attributes.EMPTY); in noMoreCallbackAfterLoadBalancerShutdown() local
573 subchannel1.requestConnection(); in noMoreCallbackAfterLoadBalancerShutdown()
583 .handleSubchannelState(same(subchannel1), stateInfoCaptor.capture()); in noMoreCallbackAfterLoadBalancerShutdown()
1993 Subchannel subchannel1 = helper.createSubchannel(addressGroup, Attributes.EMPTY); in updateBalancingStateDoesUpdatePicker() local
2005 .thenReturn(PickResult.withSubchannel(subchannel1)); in updateBalancingStateDoesUpdatePicker()
/external/grpc-grpc-java/services/src/test/java/io/grpc/services/
DChannelzProtoUtilTest.java638 TestChannel subchannel1 = new TestChannel(); in toSubchannel_subchannelChildren() local
640 .setSubchannels(ImmutableList.<InternalWithLogId>of(subchannel1)) in toSubchannel_subchannelChildren()
644 .addSubchannelRef(ChannelzProtoUtil.toSubchannelRef(subchannel1)) in toSubchannel_subchannelChildren()
650 .setSubchannels(ImmutableList.<InternalWithLogId>of(subchannel1, subchannel2)) in toSubchannel_subchannelChildren()
655 .addSubchannelRef(ChannelzProtoUtil.toSubchannelRef(subchannel1)) in toSubchannel_subchannelChildren()
/external/grpc-grpc-java/core/src/test/java/io/grpc/util/
DRoundRobinLoadBalancerTest.java297 Subchannel subchannel1 = 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()
307 assertEquals(subchannel1, picker.pickSubchannel(mockArgs).getSubchannel()); in pickerRoundRobin()