Github user ifesdjeen commented on a diff in the pull request:
https://github.com/apache/cassandra/pull/224#discussion_r197124923
--- Diff: src/java/org/apache/cassandra/db/ConsistencyLevel.java ---
@@ -148,40 +150,45 @@ public boolean isLocal(InetAddressAndPort endpoint)
return
DatabaseDescriptor.getLocalDataCenter().equals(DatabaseDescriptor.getEndpointSnitch().getDatacenter(endpoint));
}
- public int countLocalEndpoints(Iterable<InetAddressAndPort>
liveEndpoints)
+ public boolean isLocal(Replica replica)
+ {
+ return isLocal(replica.getEndpoint());
+ }
+
+ public int countLocalEndpoints(Iterable<Replica> liveReplicas)
{
int count = 0;
- for (InetAddressAndPort endpoint : liveEndpoints)
- if (isLocal(endpoint))
+ for (Replica replica : liveReplicas)
+ if (isLocal(replica))
count++;
return count;
}
- private Map<String, Integer> countPerDCEndpoints(Keyspace keyspace,
Iterable<InetAddressAndPort> liveEndpoints)
+ private Map<String, Integer> countPerDCEndpoints(Keyspace keyspace,
Iterable<Replica> liveReplicas)
--- End diff --
This can be just `Replicas`
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
