Home
last modified time | relevance | path

Searched refs:oobChannel (Results 1 – 5 of 5) 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.java1349 OobChannel oobChannel = (OobChannel) helper.createOobChannel(addressGroup, "oobAuthority"); in subtestRefreshNameResolutionWhenConnectionFailed() local
1350 oobChannel.getSubchannel().requestConnection(); in subtestRefreshNameResolutionWhenConnectionFailed()
2309 OobChannel oobChannel = (OobChannel) helper.createOobChannel(addressGroup, "authority"); in channelTracing_oobChannelStateChangeEvent() local
2311 oobChannel.handleSubchannelStateChange( in channelTracing_oobChannelStateChangeEvent()
2313 assertThat(getStats(oobChannel).channelTrace.events).contains(new ChannelTrace.Event.Builder() in channelTracing_oobChannelStateChangeEvent()
2325 OobChannel oobChannel = (OobChannel) helper.createOobChannel(addressGroup, "authority"); in channelTracing_oobChannelCreationEvents() local
2330 .setChannelRef(oobChannel) in channelTracing_oobChannelCreationEvents()
2332 assertThat(getStats(oobChannel).channelTrace.events).contains(new ChannelTrace.Event.Builder() in channelTracing_oobChannelCreationEvents()
2337 assertThat(getStats(oobChannel.getInternalSubchannel()).channelTrace.events).contains( in channelTracing_oobChannelCreationEvents()
2473 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.java274 for (OobChannel oobChannel : oobChannels) { in maybeShutdownNowSubchannels()
275 oobChannel.getInternalSubchannel().shutdownNow(SHUTDOWN_NOW_STATUS); in maybeShutdownNowSubchannels()
902 for (OobChannel oobChannel : oobChannels) { in resetConnectBackoff()
903 oobChannel.resetConnectBackoff(); in resetConnectBackoff()
1160 final OobChannel oobChannel = new OobChannel( in createOobChannel() local
1168 .setChannelRef(oobChannel) in createOobChannel()
1180 oobChannels.remove(oobChannel); in createOobChannel()
1182 oobChannel.handleSubchannelTerminated(); in createOobChannel()
1189 oobChannel.handleSubchannelStateChange(newState); in createOobChannel()
1204 channelz.addSubchannel(oobChannel); in createOobChannel()
[all …]
/external/grpc-grpc-java/grpclb/src/test/java/io/grpc/grpclb/
DGrpclbLoadBalancerTest.java763 ManagedChannel oobChannel = fakeOobChannels.poll(); in grpclbThenNameResolutionFails() local
775 assertFalse(oobChannel.isShutdown()); in grpclbThenNameResolutionFails()
802 ManagedChannel oobChannel = fakeOobChannels.poll(); in grpclbUpdatedAddresses_avoidsReconnect() local
812 verify(helper).updateOobChannelAddresses(eq(oobChannel), eq(combinedEag)); in grpclbUpdatedAddresses_avoidsReconnect()
824 ManagedChannel oobChannel = fakeOobChannels.poll(); in grpclbUpdatedAddresses_reconnectOnAuthorityChange() local
833 assertTrue(oobChannel.isTerminated()); in grpclbUpdatedAddresses_reconnectOnAuthorityChange()
850 ManagedChannel oobChannel = fakeOobChannels.poll(); in grpclbWorking() local
1023 assertFalse(oobChannel.isShutdown()); in grpclbWorking()
1061 ManagedChannel oobChannel = fakeOobChannels.poll(); in subtestGrpclbFallbackInitialTimeout() local
1113 assertFalse(oobChannel.isShutdown()); in subtestGrpclbFallbackInitialTimeout()
[all …]
/external/grpc-grpc-java/core/
Dgrpc-core-1.14.0.jarMETA-INF/ META-INF/MANIFEST.MF io/ io/grpc/ io/ ...