svn commit: r996588 - in /cassandra/trunk/src/java/org/apache/cassandra/gms: FailureDetector.java FailureDetectorMBean.java

[gdusbabek]

Author: gdusbabek
Date: Mon Sep 13 16:10:40 2010
New Revision: 996588

URL: http://svn.apache.org/viewvc?rev=996588&view=rev
Log:
expose endpoint states to jmx. patch by gdusbabek, reviewed by jbellis. 
CASSANDRA-1467

Modified:
    cassandra/trunk/src/java/org/apache/cassandra/gms/FailureDetector.java
    cassandra/trunk/src/java/org/apache/cassandra/gms/FailureDetectorMBean.java

Modified: cassandra/trunk/src/java/org/apache/cassandra/gms/FailureDetector.java
URL: 
http://svn.apache.org/viewvc/cassandra/trunk/src/java/org/apache/cassandra/gms/FailureDetector.java?rev=996588&r1=996587&r2=996588&view=diff
==============================================================================
--- cassandra/trunk/src/java/org/apache/cassandra/gms/FailureDetector.java 
(original)
+++ cassandra/trunk/src/java/org/apache/cassandra/gms/FailureDetector.java Mon 
Sep 13 16:10:40 2010
@@ -70,6 +70,18 @@ public class FailureDetector implements 
         }
     }
     
+    public String getAllEndpointStates()
+    {
+        StringBuilder sb = new StringBuilder();
+        for (Map.Entry<InetAddress, EndpointState> entry : 
Gossiper.instance.endpointStateMap_.entrySet())
+        {
+            sb.append(entry.getKey()).append("\n");
+            for (Map.Entry<String, ApplicationState> state : 
entry.getValue().applicationState_.entrySet())
+                sb.append("  
").append(state.getKey()).append(":").append(state.getValue().getValue()).append("\n");
+        }
+        return sb.toString();
+    }
+
     /**
      * Dump the inter arrival times for examination if necessary.
      */

Modified: 
cassandra/trunk/src/java/org/apache/cassandra/gms/FailureDetectorMBean.java
URL: 
http://svn.apache.org/viewvc/cassandra/trunk/src/java/org/apache/cassandra/gms/FailureDetectorMBean.java?rev=996588&r1=996587&r2=996588&view=diff
==============================================================================
--- cassandra/trunk/src/java/org/apache/cassandra/gms/FailureDetectorMBean.java 
(original)
+++ cassandra/trunk/src/java/org/apache/cassandra/gms/FailureDetectorMBean.java 
Mon Sep 13 16:10:40 2010
@@ -25,4 +25,6 @@ public interface FailureDetectorMBean
     public void setPhiConvictThreshold(int phi);
 
     public int getPhiConvictThreshold();
+    
+    public String getAllEndpointStates();
 }