Home
last modified time | relevance | path

Searched defs:subchannels (Results 1 – 20 of 20) sorted by relevance

/external/grpc-grpc-java/core/src/main/java/io/grpc/util/
DRoundRobinLoadBalancer.java61 private final Map<EquivalentAddressGroup, Subchannel> subchannels = field in RoundRobinLoadBalancer
234 Collection<Subchannel> subchannels) { in filterNonFailingSubchannels()
DOutlierDetectionLoadBalancer.java455 private final Set<OutlierDetectionSubchannel> subchannels = new HashSet<>(); field in OutlierDetectionLoadBalancer.AddressTracker
/external/grpc-grpc-java/xds/src/main/java/io/grpc/xds/
DLeastRequestLoadBalancer.java73 private final Map<EquivalentAddressGroup, Subchannel> subchannels = field in LeastRequestLoadBalancer
245 Collection<Subchannel> subchannels) { in filterNonFailingSubchannels()
DRingHashLoadBalancer.java74 private final Map<EquivalentAddressGroup, Subchannel> subchannels = new HashMap<>(); field in RingHashLoadBalancer
434 Map<EquivalentAddressGroup, Subchannel> subchannels) { in RingHashPicker()
/external/grpc-grpc-java/xds/src/test/java/io/grpc/xds/
DLeastRequestLoadBalancerTest.java98 private final Map<List<EquivalentAddressGroup>, Subchannel> subchannels = Maps.newLinkedHashMap(); field in LeastRequestLoadBalancerTest
431 List<Subchannel> subchannels = Lists.newArrayList(loadBalancer.getSubchannels()); in pickerLeastRequest() local
DRingHashLoadBalancerTest.java99 private final Map<List<EquivalentAddressGroup>, Subchannel> subchannels = new HashMap<>(); field in RingHashLoadBalancerTest
DWeightedRoundRobinLoadBalancerTest.java103 private final Map<List<EquivalentAddressGroup>, Subchannel> subchannels = Maps.newLinkedHashMap(); field in WeightedRoundRobinLoadBalancerTest
/external/grpc-grpc-java/grpclb/src/main/java/io/grpc/grpclb/
DGrpclbState.java177 private Map<List<EquivalentAddressGroup>, Subchannel> subchannels = Collections.emptyMap(); field in GrpclbState
442 checkState(subchannels.size() == 1, "Excessive Subchannels: %s", subchannels); in shutdown() local
520 checkState(subchannels.size() <= 1, "Unexpected Subchannel count: %s", subchannels); in updateServerList() local
/external/grpc-grpc-java/api/src/main/java/io/grpc/
DInternalChannelz.java56 private final ConcurrentMap<Long, InternalInstrumented<ChannelStats>> subchannels field in InternalChannelz
377 public final List<InternalWithLogId> subchannels; field in InternalChannelz.ChannelStats
391 List<InternalWithLogId> subchannels, in ChannelStats()
416 private List<InternalWithLogId> subchannels = Collections.emptyList(); field in InternalChannelz.ChannelStats.Builder
455 public Builder setSubchannels(List<InternalWithLogId> subchannels) { in setSubchannels()
/external/grpc-grpc-java/rls/src/test/java/io/grpc/rls/
DRlsLoadBalancerTest.java112 private final Deque<FakeSubchannel> subchannels = new LinkedList<>(); field in RlsLoadBalancerTest
/external/grpc-grpc/test/core/client_channel/lb_policy/
Dlb_policy_test_lib.h1254 for (const auto& subchannels : endpoint_subchannels) { variable
1350 std::vector<SubchannelState*> subchannels; variable
Dpick_first_test.cc87 std::map<SubchannelState*, absl::string_view> subchannels; in GetOrderAddressesArePicked() local
/external/grpc-grpc-java/core/src/test/java/io/grpc/util/
DRoundRobinLoadBalancerTest.java92 private final Map<List<EquivalentAddressGroup>, Subchannel> subchannels = Maps.newLinkedHashMap(); field in RoundRobinLoadBalancerTest
DOutlierDetectionLoadBalancerTest.java142 private final Map<List<EquivalentAddressGroup>, Subchannel> subchannels = Maps.newLinkedHashMap(); field in OutlierDetectionLoadBalancerTest
/external/grpc-grpc/src/core/load_balancing/outlier_detection/
Doutlier_detection.cc282 explicit EndpointState(std::set<SubchannelState*> subchannels) in EndpointState()
681 std::set<SubchannelState*> subchannels; in UpdateLocked() local
/external/grpc-grpc-java/grpclb/src/test/java/io/grpc/grpclb/
DGrpclbLoadBalancerTest.java1557 List<Subchannel> subchannels = fallbackTestVerifyUseOfBalancerBackendLists(inOrder, serverList); in subtestGrpclbFallbackConnectionLost() local
1647 List<Subchannel> subchannels = fallbackTestVerifyUseOfBalancerBackendLists(inOrder, serverList); in grpclbFallback_allLost_failToFallback() local
1704 ArrayList<Subchannel> subchannels = new ArrayList<>(mockSubchannels); in fallbackTestVerifyUseOfBackendLists() local
/external/grpc-grpc-java/services/src/test/java/io/grpc/protobuf/services/
DHealthCheckingLoadBalancerFactoryTest.java120 private final FakeSubchannel[] subchannels = new FakeSubchannel[NUM_SUBCHANNELS]; field in HealthCheckingLoadBalancerFactoryTest
/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DManagedChannelImpl.java233 private final Set<InternalSubchannel> subchannels = new HashSet<>(16, .75f); field in ManagedChannelImpl
/external/grpc-grpc-java/xds/src/test/java/io/grpc/xds/orca/
DOrcaOobUtilTest.java138 private FakeSubchannel[] subchannels = new FakeSubchannel[NUM_SUBCHANNELS]; field in OrcaOobUtilTest
/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DManagedChannelImplTest.java1379 public void subchannels() { in subchannels() method in ManagedChannelImplTest