| /external/grpc-grpc-java/grpclb/src/test/java/io/grpc/grpclb/ |
| CachedSubchannelPoolTest.java | 110 Subchannel subchannel1 = pool.takeOrCreateSubchannel(EAG1, ATTRS1); local
111 assertThat(subchannel1).isNotNull();
116 assertThat(subchannel2).isNotSameAs(subchannel1);
119 pool.returnSubchannel(subchannel1);
121 // subchannel1 is 1ms away from expiration.
123 verify(subchannel1, never()).shutdown();
127 // subchannel1 expires. subchannel2 is (SHUTDOWN_TIMEOUT_MS - 1) away from expiration.
129 verify(subchannel1).shutdown();
141 Subchannel subchannel1 = pool.takeOrCreateSubchannel(EAG1, ATTRS1); local
142 assertThat(subchannel1).isNotNull()
185 Subchannel subchannel1 = pool.takeOrCreateSubchannel(EAG1, ATTRS1); local
214 Subchannel subchannel1 = pool.takeOrCreateSubchannel(EAG1, ATTRS1); local
[all...] |
| GrpclbLoadBalancerTest.java | 435 Subchannel subchannel1 = mockSubchannels.poll(); local
437 deliverSubchannelState(subchannel1, ConnectivityStateInfo.forNonError(CONNECTING));
439 deliverSubchannelState(subchannel1, ConnectivityStateInfo.forNonError(READY));
451 new BackendEntry(subchannel1, getLoadRecorder(), "token0001"),
460 assertSame(subchannel1, pick1.getSubchannel());
526 assertSame(subchannel1, pick1.getSubchannel());
602 assertSame(subchannel1, pick1p.getSubchannel());
876 Subchannel subchannel1 = mockSubchannels.poll(); local
[all...] |
| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| DelayedClientTransportTest.java | 292 AbstractSubchannel subchannel1 = mock(AbstractSubchannel.class); local
299 when(subchannel1.obtainActiveTransport()).thenReturn(mockRealTransport);
349 PickResult.withSubchannel(subchannel1), // ff1: proceed
395 PickResult.withSubchannel(subchannel1), // ff3
398 PickResult.withSubchannel(subchannel1), // wfr3
442 PickResult.withSubchannel(subchannel1));
|
| ManagedChannelImplTest.java | 571 Subchannel subchannel1 = helper.createSubchannel(addressGroup, Attributes.EMPTY); local
573 subchannel1.requestConnection();
583 .handleSubchannelState(same(subchannel1), stateInfoCaptor.capture());
1993 Subchannel subchannel1 = helper.createSubchannel(addressGroup, Attributes.EMPTY); local
[all...] |
| /external/grpc-grpc-java/services/src/test/java/io/grpc/services/ |
| ChannelzProtoUtilTest.java | 638 TestChannel subchannel1 = new TestChannel(); local
640 .setSubchannels(ImmutableList.<InternalWithLogId>of(subchannel1))
644 .addSubchannelRef(ChannelzProtoUtil.toSubchannelRef(subchannel1))
650 .setSubchannels(ImmutableList.<InternalWithLogId>of(subchannel1, subchannel2))
655 .addSubchannelRef(ChannelzProtoUtil.toSubchannelRef(subchannel1))
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/util/ |
| RoundRobinLoadBalancerTest.java | 297 Subchannel subchannel1 = mock(Subchannel.class); local
301 Lists.<Subchannel>newArrayList(subchannel, subchannel1, subchannel2)),
304 assertThat(picker.getList()).containsExactly(subchannel, subchannel1, subchannel2);
307 assertEquals(subchannel1, picker.pickSubchannel(mockArgs).getSubchannel());
[all...] |
