Github user bdeggleston commented on a diff in the pull request:
https://github.com/apache/cassandra/pull/224#discussion_r189117046
--- Diff: src/java/org/apache/cassandra/service/WriteResponseHandler.java
---
@@ -42,26 +44,26 @@
private static final AtomicIntegerFieldUpdater<WriteResponseHandler>
responsesUpdater
=
AtomicIntegerFieldUpdater.newUpdater(WriteResponseHandler.class, "responses");
- public WriteResponseHandler(Collection<InetAddressAndPort>
writeEndpoints,
- Collection<InetAddressAndPort>
pendingEndpoints,
+ public WriteResponseHandler(Replicas writeReplicas,
+ Replicas pendingReplicas,
ConsistencyLevel consistencyLevel,
Keyspace keyspace,
Runnable callback,
WriteType writeType,
long queryStartNanoTime)
{
- super(keyspace, writeEndpoints, pendingEndpoints,
consistencyLevel, callback, writeType, queryStartNanoTime);
+ super(keyspace, writeReplicas, pendingReplicas, consistencyLevel,
callback, writeType, queryStartNanoTime);
responses = totalBlockFor();
}
- public WriteResponseHandler(InetAddressAndPort endpoint, WriteType
writeType, Runnable callback, long queryStartNanoTime)
+ public WriteResponseHandler(Replica replica, WriteType writeType,
Runnable callback, long queryStartNanoTime)
{
- this(Arrays.asList(endpoint),
Collections.<InetAddressAndPort>emptyList(), ConsistencyLevel.ONE, null,
callback, writeType, queryStartNanoTime);
+ this(new ReplicaList(Collections.singleton(replica)), new
ReplicaList(), ConsistencyLevel.ONE, null, callback, writeType,
queryStartNanoTime);
--- End diff --
fixed
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
