Home
last modified time | relevance | path

Searched refs:oobChannel (Results 1 – 4 of 4) sorted by relevance

/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DManagedChannelImplIdlenessTest.java394 ManagedChannel oobChannel = helper.createOobChannel(servers.get(0), "localhost"); in updateOobChannelAddresses_newAddressConnects() local
396 oobChannel.newCall(method, CallOptions.DEFAULT).start(mockCallListener, new Metadata()); in updateOobChannelAddresses_newAddressConnects()
400 helper.updateOobChannelAddresses(oobChannel, servers.get(1)); in updateOobChannelAddresses_newAddressConnects()
402 oobChannel.newCall(method, CallOptions.DEFAULT).start(mockCallListener, new Metadata()); in updateOobChannelAddresses_newAddressConnects()
414 ManagedChannel oobChannel = helper.createOobChannel(servers.get(0), "localhost"); in updateOobChannelAddresses_existingAddressDoesNotConnect() local
416 oobChannel.newCall(method, CallOptions.DEFAULT).start(mockCallListener, new Metadata()); in updateOobChannelAddresses_existingAddressDoesNotConnect()
422 helper.updateOobChannelAddresses(oobChannel, new EquivalentAddressGroup(changedList)); in updateOobChannelAddresses_existingAddressDoesNotConnect()
424 oobChannel.newCall(method, CallOptions.DEFAULT).start(mockCallListener, new Metadata()); in updateOobChannelAddresses_existingAddressDoesNotConnect()
DManagedChannelImplTest.java1348 OobChannel oobChannel = (OobChannel) helper.createOobChannel(addressGroup, "oobAuthority"); in subtestRefreshNameResolutionWhenConnectionFailed() local
1349 oobChannel.getSubchannel().requestConnection(); in subtestRefreshNameResolutionWhenConnectionFailed()
2310 OobChannel oobChannel = (OobChannel) helper.createOobChannel(addressGroup, "authority"); in channelTracing_oobChannelStateChangeEvent() local
2312 oobChannel.handleSubchannelStateChange( in channelTracing_oobChannelStateChangeEvent()
2314 assertThat(getStats(oobChannel).channelTrace.events).contains(new ChannelTrace.Event.Builder() in channelTracing_oobChannelStateChangeEvent()
2326 OobChannel oobChannel = (OobChannel) helper.createOobChannel(addressGroup, "authority"); in channelTracing_oobChannelCreationEvents() local
2331 .setChannelRef(oobChannel) in channelTracing_oobChannelCreationEvents()
2333 assertThat(getStats(oobChannel).channelTrace.events).contains(new ChannelTrace.Event.Builder() in channelTracing_oobChannelCreationEvents()
2338 assertThat(getStats(oobChannel.getInternalSubchannel()).channelTrace.events).contains( in channelTracing_oobChannelCreationEvents()
2474 OobChannel oobChannel = (OobChannel) helper.createOobChannel(addressGroup, "oobauthority"); in channelsAndSubchannels_oob_instrumented0() local
[all …]
/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DManagedChannelImpl.java241 for (OobChannel oobChannel : oobChannels) { in maybeShutdownNowSubchannels()
242 oobChannel.getInternalSubchannel().shutdownNow(SHUTDOWN_NOW_STATUS); in maybeShutdownNowSubchannels()
890 for (OobChannel oobChannel : oobChannels) { in resetConnectBackoff()
891 oobChannel.resetConnectBackoff(); in resetConnectBackoff()
1155 final OobChannel oobChannel = new OobChannel( in createOobChannel() local
1163 .setChannelRef(oobChannel) in createOobChannel()
1170 oobChannels.remove(oobChannel); in createOobChannel()
1172 oobChannel.handleSubchannelTerminated(); in createOobChannel()
1179 oobChannel.handleSubchannelStateChange(newState); in createOobChannel()
1201 channelz.addSubchannel(oobChannel); in createOobChannel()
[all …]
/external/grpc-grpc-java/grpclb/src/test/java/io/grpc/grpclb/
DGrpclbLoadBalancerTest.java762 ManagedChannel oobChannel = fakeOobChannels.poll(); in grpclbThenNameResolutionFails() local
774 assertFalse(oobChannel.isShutdown()); in grpclbThenNameResolutionFails()
801 ManagedChannel oobChannel = fakeOobChannels.poll(); in grpclbUpdatedAddresses_avoidsReconnect() local
811 verify(helper).updateOobChannelAddresses(eq(oobChannel), eq(combinedEag)); in grpclbUpdatedAddresses_avoidsReconnect()
823 ManagedChannel oobChannel = fakeOobChannels.poll(); in grpclbUpdatedAddresses_reconnectOnAuthorityChange() local
832 assertTrue(oobChannel.isTerminated()); in grpclbUpdatedAddresses_reconnectOnAuthorityChange()
849 ManagedChannel oobChannel = fakeOobChannels.poll(); in grpclbWorking() local
1022 assertFalse(oobChannel.isShutdown()); in grpclbWorking()
1060 ManagedChannel oobChannel = fakeOobChannels.poll(); in subtestGrpclbFallbackInitialTimeout() local
1089 assertFalse(oobChannel.isShutdown()); in subtestGrpclbFallbackInitialTimeout()
[all …]