commit ce207cba413381986324f2c8edad9e090e5be5b1
author Aleksey Yeschenko <aleksey@apache.org> Sat Jan 17 04:06:21 2015 +0300
committer Aleksey Yeschenko <aleksey@apache.org> Sat Jan 17 04:06:21 2015 +0300
tree 6f3418773b612e7ed33e5bc99c23e381d94372c3
parent 61bd68885e1a40a8c40522a73bf9d269b58868e9

Ninja-fix CASSANDRA-8640

src/java/org/apache/cassandra/service/StorageProxy.java

diff --git a/src/java/org/apache/cassandra/service/StorageProxy.java b/src/java/org/apache/cassandra/service/StorageProxy.java
index 1fd4079..fcc9665 100644
--- a/src/java/org/apache/cassandra/service/StorageProxy.java
+++ b/src/java/org/apache/cassandra/service/StorageProxy.java
@@ -314,7 +314,7 @@
             pendingEndpoints = ImmutableList.copyOf(Iterables.filter(pendingEndpoints, isLocalDc));
         }
         int participants = pendingEndpoints.size() + naturalEndpoints.size();
-        int requiredParticipants = (participants + 1) / 2; // See CASSANDRA-8346, CASSANDRA-833
+        int requiredParticipants = participants / 2 + 1; // See CASSANDRA-8346, CASSANDRA-833
         List<InetAddress> liveEndpoints = ImmutableList.copyOf(Iterables.filter(Iterables.concat(naturalEndpoints, pendingEndpoints), IAsyncCallback.isAlive));
         if (liveEndpoints.size() < requiredParticipants)
             throw new UnavailableException(consistencyForPaxos, requiredParticipants, liveEndpoints.size());