Github user aweisberg commented on a diff in the pull request:
https://github.com/apache/cassandra/pull/224#discussion_r187672097
--- Diff: src/java/org/apache/cassandra/dht/RangeFetchMapCalculator.java ---
@@ -347,15 +349,16 @@ else if (vertex.isRangeVertex())
private boolean addEndpoints(MutableCapacityGraph<Vertex, Integer>
capacityGraph, RangeVertex rangeVertex, boolean localDCCheck)
{
boolean sourceFound = false;
- for (InetAddressAndPort endpoint :
rangesWithSources.get(rangeVertex.getRange()))
+ Replicas.checkFull(rangesWithSources.get(rangeVertex.getRange()));
+ for (Replica replica :
rangesWithSources.get(rangeVertex.getRange()))
{
- if (passFilters(endpoint, localDCCheck))
+ if (passFilters(replica, localDCCheck))
{
sourceFound = true;
// if we pass filters, it means that we don't filter away
localhost and we can count it as a source:
- if
(endpoint.equals(FBUtilities.getBroadcastAddressAndPort()))
+ if
(replica.getEndpoint().equals(FBUtilities.getBroadcastAddressAndPort()))
--- End diff --
Crazy thought, what if Replica had an isLocal or something?
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
