You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by jb...@apache.org on 2009/06/08 15:59:52 UTC
svn commit: r782629 - in
/incubator/cassandra/trunk/src/java/org/apache/cassandra/service:
StorageService.java StorageServiceMBean.java
Author: jbellis
Date: Mon Jun 8 13:59:52 2009
New Revision: 782629
URL: http://svn.apache.org/viewvc?rev=782629&view=rev
Log:
To make available the Cassandra specific information available on the
node detail page:
- Exposed the existing StorageService.getLoadInfo()
- Created StorageService.getCurrentGenerationNumber() and added to
MBean interface.
patch by Eric Evans; reviewed by jbellis for CASSANDRA-211
Modified:
incubator/cassandra/trunk/src/java/org/apache/cassandra/service/StorageService.java
incubator/cassandra/trunk/src/java/org/apache/cassandra/service/StorageServiceMBean.java
Modified: incubator/cassandra/trunk/src/java/org/apache/cassandra/service/StorageService.java
URL: http://svn.apache.org/viewvc/incubator/cassandra/trunk/src/java/org/apache/cassandra/service/StorageService.java?rev=782629&r1=782628&r2=782629&view=diff
==============================================================================
--- incubator/cassandra/trunk/src/java/org/apache/cassandra/service/StorageService.java (original)
+++ incubator/cassandra/trunk/src/java/org/apache/cassandra/service/StorageService.java Mon Jun 8 13:59:52 2009
@@ -713,6 +713,11 @@
{
return stringify(Gossiper.instance().getUnreachableMembers());
}
+
+ public int getCurrentGenerationNumber()
+ {
+ return Gossiper.instance().getCurrentGenerationNumber(udpAddr_);
+ }
/* Helper for the MBean interface */
private String stringify(Set<EndPoint> eps)
Modified: incubator/cassandra/trunk/src/java/org/apache/cassandra/service/StorageServiceMBean.java
URL: http://svn.apache.org/viewvc/incubator/cassandra/trunk/src/java/org/apache/cassandra/service/StorageServiceMBean.java?rev=782629&r1=782628&r2=782629&view=diff
==============================================================================
--- incubator/cassandra/trunk/src/java/org/apache/cassandra/service/StorageServiceMBean.java (original)
+++ incubator/cassandra/trunk/src/java/org/apache/cassandra/service/StorageServiceMBean.java Mon Jun 8 13:59:52 2009
@@ -35,6 +35,8 @@
public String getUnreachableNodes();
public String getToken();
public Map<Range, List<EndPoint>> getRangeToEndPointMap();
+ public String getLoadInfo();
+ public int getCurrentGenerationNumber();
/**
* This method will cause the local node initiate