You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by jb...@apache.org on 2013/10/03 02:11:55 UTC
[3/6] git commit: comment
comment
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/c8f0e3a9
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/c8f0e3a9
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/c8f0e3a9
Branch: refs/heads/trunk
Commit: c8f0e3a9f94d81949cd62ec59c552fd0dfa2720c
Parents: 6b58745
Author: Jonathan Ellis <jb...@apache.org>
Authored: Wed Oct 2 19:11:33 2013 -0500
Committer: Jonathan Ellis <jb...@apache.org>
Committed: Wed Oct 2 19:11:33 2013 -0500
----------------------------------------------------------------------
src/java/org/apache/cassandra/service/StorageProxy.java | 3 +++
1 file changed, 3 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/cassandra/blob/c8f0e3a9/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 b23de1f..a81e5b4 100644
--- a/src/java/org/apache/cassandra/service/StorageProxy.java
+++ b/src/java/org/apache/cassandra/service/StorageProxy.java
@@ -201,6 +201,9 @@ public class StorageProxy implements StorageProxyMBean
{
if (consistency_level == ConsistencyLevel.ANY)
{
+ // hint all the mutations (except counters, which can't be safely retried). This means
+ // we'll re-hint any successful ones; doesn't seem worth it to track individual success
+ // just for this unusual case.
for (IMutation mutation : mutations)
{
if (mutation instanceof CounterMutation)