You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by pa...@apache.org on 2017/01/16 01:18:46 UTC
[2/6] cassandra git commit: Send ACK for non-local hints
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/cassandra-3.X
Commit: db2c50d8113c10da7b6a31de5c979a41eb3d9a1d
Parents: 9c2ab25
Author: Stefan Podkowinski <s....@gmail.com>
Authored: Mon Jan 9 12:16:16 2017 +0100
Committer: Paulo Motta <pa...@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
{