| /external/grpc-grpc-java/core/src/main/java/io/grpc/util/ |
| D | ForwardingLoadBalancerHelper.java | 61 public ManagedChannel createOobChannel(EquivalentAddressGroup eag, String authority) { in createOobChannel() method in ForwardingLoadBalancerHelper
62 return delegate().createOobChannel(eag, authority); in createOobChannel()
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | AutoConfiguredLoadBalancerFactoryTest.java | 288 public ManagedChannel createOobChannel(EquivalentAddressGroup eag, String authority) { in channelTracing_lbPolicyChanged()
390 public ManagedChannel createOobChannel(EquivalentAddressGroup eag, String authority) { in createOobChannel() method in AutoConfiguredLoadBalancerFactoryTest.ForwardingLoadBalancerHelper
391 return delegate().createOobChannel(eag, authority); in createOobChannel()
|
| D | ManagedChannelImplIdlenessTest.java | 361 ManagedChannel oob = helper.createOobChannel(servers.get(0), "oobauthority"); in oobTransportDoesNotAffectIdleness()
394 ManagedChannel oobChannel = helper.createOobChannel(servers.get(0), "localhost"); in updateOobChannelAddresses_newAddressConnects()
414 ManagedChannel oobChannel = helper.createOobChannel(servers.get(0), "localhost"); in updateOobChannelAddresses_existingAddressDoesNotConnect()
|
| D | ManagedChannelImplTest.java | 376 OobChannel oob = (OobChannel) helper.createOobChannel(addressGroup, AUTHORITY); in channelzMembership_oob()
1169 ManagedChannel oob1 = helper.createOobChannel(addressGroup, "oob1authority"); in oobchannels()
1170 ManagedChannel oob2 = helper.createOobChannel(addressGroup, "oob2authority"); in oobchannels()
1269 ManagedChannel oob1 = helper.createOobChannel(addressGroup, "oob1Authority"); in oobChannelsWhenChannelShutdownNow()
1270 ManagedChannel oob2 = helper.createOobChannel(addressGroup, "oob2Authority"); in oobChannelsWhenChannelShutdownNow()
1298 ManagedChannel oob1 = helper.createOobChannel(addressGroup, "oob1Authority"); in oobChannelsNoConnectionShutdown()
1299 ManagedChannel oob2 = helper.createOobChannel(addressGroup, "oob2Authority"); in oobChannelsNoConnectionShutdown()
1316 helper.createOobChannel(addressGroup, "oob1Authority"); in oobChannelsNoConnectionShutdownNow()
1317 helper.createOobChannel(addressGroup, "oob2Authority"); in oobChannelsNoConnectionShutdownNow()
1348 OobChannel oobChannel = (OobChannel) helper.createOobChannel(addressGroup, "oobAuthority"); in subtestRefreshNameResolutionWhenConnectionFailed()
[all …]
|
| /external/grpc-grpc-java/grpclb/src/test/java/io/grpc/grpclb/ |
| D | GrpclbLoadBalancerTest.java | 217 }).when(helper).createOobChannel(any(EquivalentAddressGroup.class), any(String.class)); in setUp()
748 verify(helper).createOobChannel(eq(eag), eq(lbAuthority(0))); in nameResolutionFailsThenRecoverToGrpclb()
760 verify(helper).createOobChannel(eq(grpclbResolutionList.get(0)), eq(lbAuthority(0))); in grpclbThenNameResolutionFails()
800 verify(helper).createOobChannel(eq(grpclbResolutionList.get(0)), eq(lbAuthority(0))); in grpclbUpdatedAddresses_avoidsReconnect()
822 verify(helper).createOobChannel(eq(grpclbResolutionList.get(0)), eq(lbAuthority(0))); in grpclbUpdatedAddresses_reconnectOnAuthorityChange()
833 verify(helper).createOobChannel(eq(grpclbResolutionList2.get(1)), eq(newAuthority)); in grpclbUpdatedAddresses_reconnectOnAuthorityChange()
847 verify(helper).createOobChannel(eq(grpclbResolutionList.get(0)), eq(lbAuthority(0))); in grpclbWorking()
1056 inOrder.verify(helper).createOobChannel(eq(resolutionList.get(1)), eq(lbAuthority(0))); in subtestGrpclbFallbackInitialTimeout()
1188 inOrder.verify(helper).createOobChannel(eq(resolutionList.get(1)), eq(lbAuthority(0))); in grpclbFallback_breakLbStreamBeforeFallbackTimerExpires()
1258 inOrder.verify(helper).createOobChannel(eq(resolutionList.get(1)), eq(lbAuthority(0))); in subtestGrpclbFallbackConnectionLost()
[all …]
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/ |
| D | LoadBalancer.java | 535 public abstract ManagedChannel createOobChannel(EquivalentAddressGroup eag, String authority); in createOobChannel() method in LoadBalancer.Helper
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/ |
| D | LoadBalancerTest.java | 204 public ManagedChannel createOobChannel(EquivalentAddressGroup eag, String authority) { in createOobChannel() method in LoadBalancerTest.NoopHelper
|
| /external/grpc-grpc-java/grpclb/src/main/java/io/grpc/grpclb/ |
| D | GrpclbState.java | 265 lbCommChannel = helper.createOobChannel( in startLbComm()
272 lbCommChannel = helper.createOobChannel( in startLbComm()
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | ManagedChannelImpl.java | 1146 public ManagedChannel createOobChannel(EquivalentAddressGroup addressGroup, String authority) { in createOobChannel() method in ManagedChannelImpl.LbHelperImpl
|