You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by al...@apache.org on 2014/04/30 03:13:03 UTC
git commit: Fix StorageProxy#syncWriteToBatchlog()
Repository: cassandra
Updated Branches:
refs/heads/cassandra-2.1 a4664328c -> 02ffaff69
Fix StorageProxy#syncWriteToBatchlog()
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/02ffaff6
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/02ffaff6
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/02ffaff6
Branch: refs/heads/cassandra-2.1
Commit: 02ffaff69df86eab4f3f026732466b9eb1578314
Parents: a466432
Author: Aleksey Yeschenko <al...@apache.org>
Authored: Wed Apr 30 03:11:24 2014 +0200
Committer: Aleksey Yeschenko <al...@apache.org>
Committed: Wed Apr 30 03:11:24 2014 +0200
----------------------------------------------------------------------
src/java/org/apache/cassandra/service/StorageProxy.java | 5 +++--
1 file changed, 3 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/cassandra/blob/02ffaff6/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 269d68f..1a41aaa 100644
--- a/src/java/org/apache/cassandra/service/StorageProxy.java
+++ b/src/java/org/apache/cassandra/service/StorageProxy.java
@@ -619,14 +619,15 @@ public class StorageProxy implements StorageProxyMBean
}
else if (targetVersion == MessagingService.current_version)
{
- MessagingService.instance().sendRR(message, target, handler);
+ MessagingService.instance().sendRR(message, target, handler, false);
}
else
{
MessagingService.instance().sendRR(BatchlogManager.getBatchlogMutationFor(mutations, uuid, targetVersion)
.createMessage(),
target,
- handler);
+ handler,
+ false);
}
}