cassandra-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From pa...@apache.org
Subject [3/6] cassandra git commit: Send ACK for non-local hints
Date Mon, 16 Jan 2017 01:18:47 GMT
Send ACK for non-local hints

patch by Stefan Podkowinski; reviewed by Paulo Motta for CASSANDRA-13058


Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/db2c50d8
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/db2c50d8
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/db2c50d8

Branch: refs/heads/trunk
Commit: db2c50d8113c10da7b6a31de5c979a41eb3d9a1d
Parents: 9c2ab25
Author: Stefan Podkowinski <s.podkowinski@gmail.com>
Authored: Mon Jan 9 12:16:16 2017 +0100
Committer: Paulo Motta <paulo@apache.org>
Committed: Sun Jan 15 22:34:23 2017 -0200

----------------------------------------------------------------------
 CHANGES.txt                                              | 1 +
 src/java/org/apache/cassandra/hints/HintVerbHandler.java | 2 ++
 2 files changed, 3 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/cassandra/blob/db2c50d8/CHANGES.txt
----------------------------------------------------------------------
diff --git a/CHANGES.txt b/CHANGES.txt
index b8250ab..c7e4114 100644
--- a/CHANGES.txt
+++ b/CHANGES.txt
@@ -1,4 +1,5 @@
 3.10
+ * Fix TestHintedHandoff.hintedhandoff_decom_test (CASSANDRA-13058)
  * Fixed query monitoring for range queries (CASSANDRA-13050)
  * Remove outboundBindAny configuration property (CASSANDRA-12673)
  * Use correct bounds for all-data range when filtering (CASSANDRA-12666)

http://git-wip-us.apache.org/repos/asf/cassandra/blob/db2c50d8/src/java/org/apache/cassandra/hints/HintVerbHandler.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/hints/HintVerbHandler.java b/src/java/org/apache/cassandra/hints/HintVerbHandler.java
index 2344715..84abc90 100644
--- a/src/java/org/apache/cassandra/hints/HintVerbHandler.java
+++ b/src/java/org/apache/cassandra/hints/HintVerbHandler.java
@@ -78,12 +78,14 @@ public final class HintVerbHandler implements IVerbHandler<HintMessage>
             // the node is not the final destination of the hint (must have gotten it from
a decommissioning node),
             // so just store it locally, to be delivered later.
             HintsService.instance.write(hostId, hint);
+            reply(id, message.from);
         }
         else if (!StorageProxy.instance.appliesLocally(hint.mutation))
         {
             // the topology has changed, and we are no longer a replica of the mutation -
since we don't know which node(s)
             // it has been handed over to, re-address the hint to all replicas; see CASSANDRA-5902.
             HintsService.instance.writeForAllReplicas(hint);
+            reply(id, message.from);
         }
         else
         {


Mime
View raw message