cassandra-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From slebre...@apache.org
Subject svn commit: r1162844 - in /cassandra/branches/cassandra-0.8: CHANGES.txt src/java/org/apache/cassandra/service/StorageProxy.java
Date Mon, 29 Aug 2011 15:04:57 GMT
Author: slebresne
Date: Mon Aug 29 15:04:57 2011
New Revision: 1162844

URL: http://svn.apache.org/viewvc?rev=1162844&view=rev
Log:
Always hint counters
patch by slebresne; reviewed by jbellis for CASSANDRA-3099

Modified:
    cassandra/branches/cassandra-0.8/CHANGES.txt
    cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/service/StorageProxy.java

Modified: cassandra/branches/cassandra-0.8/CHANGES.txt
URL: http://svn.apache.org/viewvc/cassandra/branches/cassandra-0.8/CHANGES.txt?rev=1162844&r1=1162843&r2=1162844&view=diff
==============================================================================
--- cassandra/branches/cassandra-0.8/CHANGES.txt (original)
+++ cassandra/branches/cassandra-0.8/CHANGES.txt Mon Aug 29 15:04:57 2011
@@ -37,6 +37,7 @@
  * fix UnavailableException with writes at CL.EACH_QUORM (CASSANDRA-3084)
  * fix parsing of the Keyspace and ColumnFamily names in numeric
    and string representations in CLI (CASSANDRA-3075)
+ * always hint counters (CASSANDRA-3099)
 
 0.8.4
  * include files-to-be-streamed in StreamInSession.getSources (CASSANDRA-2972)

Modified: cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/service/StorageProxy.java
URL: http://svn.apache.org/viewvc/cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/service/StorageProxy.java?rev=1162844&r1=1162843&r2=1162844&view=diff
==============================================================================
--- cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/service/StorageProxy.java
(original)
+++ cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/service/StorageProxy.java
Mon Aug 29 15:04:57 2011
@@ -446,7 +446,8 @@ public class StorageProxy implements Sto
                 responseHandler.response(null);
 
                 // then send to replicas, if any
-                hintedEndpoints.removeAll(FBUtilities.getLocalAddress());
+                InetAddress local = FBUtilities.getLocalAddress();
+                hintedEndpoints.remove(local, local);
                 if (cm.shouldReplicateOnWrite() && !hintedEndpoints.isEmpty())
                 {
                     // We do the replication on another stage because it involves a read
(see CM.makeReplicationMutation)



Mime
View raw message