Home
last modified time | relevance | path

Searched refs:internalSubchannel (Results 1 – 2 of 2) sorted by relevance

/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DInternalSubchannelTest.java102 assertSame(internalSubchannel, is);
108 assertSame(internalSubchannel, is);
114 assertSame(internalSubchannel, is);
120 assertSame(internalSubchannel, is);
125 private InternalSubchannel internalSubchannel; field in InternalSubchannelTest
160 assertNull(internalSubchannel.obtainActiveTransport()); in eagAttribute_propagatesToTransport()
161 assertEquals(CONNECTING, internalSubchannel.getState()); in eagAttribute_propagatesToTransport()
169 assertEquals(IDLE, internalSubchannel.getState()); in singleAddressReconnect()
178 assertEquals(IDLE, internalSubchannel.getState()); in singleAddressReconnect()
180 assertNull(internalSubchannel.obtainActiveTransport()); in singleAddressReconnect()
[all …]
/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DManagedChannelImpl.java1056 final InternalSubchannel internalSubchannel = new InternalSubchannel( in createSubchannel() local
1075 .setSubchannelRef(internalSubchannel) in createSubchannel()
1078 channelz.addSubchannel(internalSubchannel); in createSubchannel()
1079 subchannel.subchannel = internalSubchannel; in createSubchannel()
1081 new Object[] {getLogId(), internalSubchannel.getLogId(), addressGroups}); in createSubchannel()
1092 internalSubchannel.shutdown(SHUTDOWN_STATUS); in createSubchannel()
1097 subchannels.add(internalSubchannel); in createSubchannel()
1183 final InternalSubchannel internalSubchannel = new InternalSubchannel( in createOobChannel() local
1198 .setSubchannelRef(internalSubchannel) in createOobChannel()
1202 channelz.addSubchannel(internalSubchannel); in createOobChannel()
[all …]