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)
