Github user ifesdjeen commented on a diff in the pull request:
https://github.com/apache/cassandra/pull/224#discussion_r197149200
--- Diff: src/java/org/apache/cassandra/service/StorageProxy.java ---
@@ -1275,36 +1272,38 @@ private static WriteResponseHandlerWrapper
wrapViewBatchResponseHandler(Mutation
*
* @throws OverloadedException if the hints cannot be written/enqueued
*/
- public static void sendToHintedEndpoints(final Mutation mutation,
- Iterable<InetAddressAndPort>
targets,
-
AbstractWriteResponseHandler<IMutation> responseHandler,
- String localDataCenter,
- Stage stage)
+ public static void sendToHintedReplicas(final Mutation mutation,
+ Iterable<Replica> targets,
+
AbstractWriteResponseHandler<IMutation> responseHandler,
+ String localDataCenter,
+ Stage stage)
throws OverloadedException
{
int targetsSize = Iterables.size(targets);
// this dc replicas:
- Collection<InetAddressAndPort> localDc = null;
+ Collection<Replica> localDc = null;
--- End diff --
We can use `Replicas` here
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
