You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by ja...@apache.org on 2018/03/29 12:42:11 UTC
cassandra git commit: Move processing of EchoMessage response to
gossip stage
Repository: cassandra
Updated Branches:
refs/heads/trunk d38694afe -> 674addd03
Move processing of EchoMessage response to gossip stage
patch by jasobrown, reviewed by jkni for CASSANDRA-13713
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/674addd0
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/674addd0
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/674addd0
Branch: refs/heads/trunk
Commit: 674addd03701abf1bce7d6b47978761c00d0a431
Parents: d38694a
Author: Jason Brown <ja...@gmail.com>
Authored: Thu Mar 29 05:41:28 2018 -0700
Committer: Jason Brown <ja...@gmail.com>
Committed: Thu Mar 29 05:41:28 2018 -0700
----------------------------------------------------------------------
CHANGES.txt | 1 +
src/java/org/apache/cassandra/gms/Gossiper.java | 3 ++-
2 files changed, 3 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/cassandra/blob/674addd0/CHANGES.txt
----------------------------------------------------------------------
diff --git a/CHANGES.txt b/CHANGES.txt
index 5763720..5af348b 100644
--- a/CHANGES.txt
+++ b/CHANGES.txt
@@ -1,4 +1,5 @@
4.0
+ * Move processing of EchoMessage response to gossip stage (CASSANDRA-13713)
* Add coordinator write metric per CF (CASSANDRA-14232)
* Fix scheduling of speculative retry threshold recalculation (CASSANDRA-14338)
* Add support for hybrid MIN(), MAX() speculative retry policies (CASSANDRA-14293)
http://git-wip-us.apache.org/repos/asf/cassandra/blob/674addd0/src/java/org/apache/cassandra/gms/Gossiper.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/gms/Gossiper.java b/src/java/org/apache/cassandra/gms/Gossiper.java
index a4e46f2..24b659b 100644
--- a/src/java/org/apache/cassandra/gms/Gossiper.java
+++ b/src/java/org/apache/cassandra/gms/Gossiper.java
@@ -1015,7 +1015,8 @@ public class Gossiper implements IFailureDetectionEventListener, GossiperMBean
public void response(MessageIn msg)
{
- realMarkAlive(addr, localState);
+ // force processing of the echo response onto the gossip stage, as it comes in on the REQUEST_RESPONSE stage
+ StageManager.getStage(Stage.GOSSIP).submit(() -> realMarkAlive(addr, localState));
}
};
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@cassandra.apache.org
For additional commands, e-mail: commits-help@cassandra.apache.org