cassandra-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From brandonwilli...@apache.org
Subject [01/10] git commit: Display generation/heartbeat in gossipinfo
Date Thu, 12 Jun 2014 19:54:22 GMT
Repository: cassandra
Updated Branches:
  refs/heads/cassandra-1.2 29a89d818 -> d509fe1a5
  refs/heads/cassandra-2.0 daf6f68ec -> 3d81ac5ec
  refs/heads/cassandra-2.1 6c8271f60 -> b4b3d8012
  refs/heads/trunk 8fb393ec3 -> 7349ec2aa


Display generation/heartbeat in gossipinfo

Patch by brandonwilliams, reviewed by thobbs for CASSANDRA-7333


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

Branch: refs/heads/cassandra-1.2
Commit: d509fe1a5f8798f23f248fd0421fe15d04a53e32
Parents: 29a89d8
Author: Brandon Williams <brandonwilliams@apache.org>
Authored: Thu Jun 12 14:53:11 2014 -0500
Committer: Brandon Williams <brandonwilliams@apache.org>
Committed: Thu Jun 12 14:53:11 2014 -0500

----------------------------------------------------------------------
 src/java/org/apache/cassandra/gms/FailureDetector.java | 2 ++
 1 file changed, 2 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/cassandra/blob/d509fe1a/src/java/org/apache/cassandra/gms/FailureDetector.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/gms/FailureDetector.java b/src/java/org/apache/cassandra/gms/FailureDetector.java
index f5c500c..ac54414 100644
--- a/src/java/org/apache/cassandra/gms/FailureDetector.java
+++ b/src/java/org/apache/cassandra/gms/FailureDetector.java
@@ -141,6 +141,8 @@ public class FailureDetector implements IFailureDetector, FailureDetectorMBean
 
     private void appendEndpointState(StringBuilder sb, EndpointState endpointState)
     {
+        sb.append("  generation:").append(endpointState.getHeartBeatState().getGeneration()).append("\n");
+        sb.append("  heartbeat:").append(endpointState.getHeartBeatState().getHeartBeatVersion()).append("\n");
         for (Map.Entry<ApplicationState, VersionedValue> state : endpointState.applicationState.entrySet())
         {
             if (state.getKey() == ApplicationState.TOKENS)


Mime
View raw message