Repository: cassandra Updated Branches: refs/heads/trunk dd825a5f0 -> 3f8806d23
move strategy field to local Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/3f8806d2 Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/3f8806d2 Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/3f8806d2 Branch: refs/heads/trunk Commit: 3f8806d233e556ae224472b3a058c2ec71468b9a Parents: dd825a5 Author: Dave Brosius <dbros...@mebigfatguy.com> Authored: Tue Mar 3 22:04:24 2015 -0500 Committer: Dave Brosius <dbros...@mebigfatguy.com> Committed: Tue Mar 3 22:04:24 2015 -0500 ---------------------------------------------------------------------- .../cassandra/service/DatacenterSyncWriteResponseHandler.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/cassandra/blob/3f8806d2/src/java/org/apache/cassandra/service/DatacenterSyncWriteResponseHandler.java ---------------------------------------------------------------------- diff --git a/src/java/org/apache/cassandra/service/DatacenterSyncWriteResponseHandler.java b/src/java/org/apache/cassandra/service/DatacenterSyncWriteResponseHandler.java index 81ae1f3..511a122 100644 --- a/src/java/org/apache/cassandra/service/DatacenterSyncWriteResponseHandler.java +++ b/src/java/org/apache/cassandra/service/DatacenterSyncWriteResponseHandler.java @@ -20,6 +20,7 @@ package org.apache.cassandra.service; import java.net.InetAddress; import java.util.Collection; import java.util.HashMap; +import java.util.Map; import java.util.concurrent.atomic.AtomicInteger; import org.apache.cassandra.config.DatabaseDescriptor; @@ -37,8 +38,7 @@ public class DatacenterSyncWriteResponseHandler extends AbstractWriteResponseHan { private static final IEndpointSnitch snitch = DatabaseDescriptor.getEndpointSnitch(); - private final NetworkTopologyStrategy strategy; - private final HashMap<String, AtomicInteger> responses = new HashMap<String, AtomicInteger>(); + private final Map<String, AtomicInteger> responses = new HashMap<String, AtomicInteger>(); private final AtomicInteger acks = new AtomicInteger(0); public DatacenterSyncWriteResponseHandler(Collection<InetAddress> naturalEndpoints, @@ -52,7 +52,7 @@ public class DatacenterSyncWriteResponseHandler extends AbstractWriteResponseHan super(keyspace, naturalEndpoints, pendingEndpoints, consistencyLevel, callback, writeType); assert consistencyLevel == ConsistencyLevel.EACH_QUORUM; - strategy = (NetworkTopologyStrategy) keyspace.getReplicationStrategy(); + NetworkTopologyStrategy strategy = (NetworkTopologyStrategy) keyspace.getReplicationStrategy(); for (String dc : strategy.getDatacenters()) {
