Repository: cassandra Updated Branches: refs/heads/cassandra-2.1 a16adba9b -> 2c7622a65
Post-CASSANDRA-7058 fix Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/b9324e1b Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/b9324e1b Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/b9324e1b Branch: refs/heads/cassandra-2.1 Commit: b9324e1b94f67f3d89096fcef4d157f9505364e9 Parents: 3a73e39 Author: Aleksey Yeschenko <alek...@apache.org> Authored: Tue Apr 22 22:13:57 2014 +0300 Committer: Aleksey Yeschenko <alek...@apache.org> Committed: Tue Apr 22 22:13:57 2014 +0300 ---------------------------------------------------------------------- src/java/org/apache/cassandra/service/StorageProxy.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/cassandra/blob/b9324e1b/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 fc6ee3a..8196352 100644 --- a/src/java/org/apache/cassandra/service/StorageProxy.java +++ b/src/java/org/apache/cassandra/service/StorageProxy.java @@ -635,7 +635,7 @@ public class StorageProxy implements StorageProxyMBean { MessageOut<RowMutation> message = rm.createMessage(); for (InetAddress target : endpoints) - MessagingService.instance().sendRR(message, target, handler); + MessagingService.instance().sendRR(message, target, handler, false); } } @@ -814,7 +814,7 @@ public class StorageProxy implements StorageProxyMBean // (1.1 knows how to forward old-style String message IDs; updated to int in 2.0) if (localDataCenter.equals(dc) || MessagingService.instance().getVersion(destination) < MessagingService.VERSION_20) { - MessagingService.instance().sendRR(message, destination, responseHandler); + MessagingService.instance().sendRR(message, destination, responseHandler, true); } else { @@ -937,7 +937,7 @@ public class StorageProxy implements StorageProxyMBean } message = message.withParameter(RowMutation.FORWARD_TO, out.getData()); // send the combined message + forward headers - int id = MessagingService.instance().sendRR(message, target, handler); + int id = MessagingService.instance().sendRR(message, target, handler, true); logger.trace("Sending message to {}@{}", id, target); } catch (IOException e) @@ -1000,7 +1000,7 @@ public class StorageProxy implements StorageProxyMBean AbstractWriteResponseHandler responseHandler = new WriteResponseHandler(endpoint, WriteType.COUNTER); Tracing.trace("Enqueuing counter update to {}", endpoint); - MessagingService.instance().sendRR(cm.makeMutationMessage(), endpoint, responseHandler); + MessagingService.instance().sendRR(cm.makeMutationMessage(), endpoint, responseHandler, false); return responseHandler; } }