cassandra-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jbel...@apache.org
Subject svn commit: r782182 - in /incubator/cassandra/trunk/src/java/org/apache/cassandra: dht/Range.java dht/Token.java service/StorageServiceMBean.java
Date Sat, 06 Jun 2009 02:45:21 GMT
Author: jbellis
Date: Sat Jun  6 02:45:20 2009
New Revision: 782182

URL: http://svn.apache.org/viewvc?rev=782182&view=rev
Log:
add getRangeToEndPointMap to JMX.  Requires making Token and Range Serializable.  Patch by
Eric Evans; reviewed by jbellis for CASSANDRA-211

Modified:
    incubator/cassandra/trunk/src/java/org/apache/cassandra/dht/Range.java
    incubator/cassandra/trunk/src/java/org/apache/cassandra/dht/Token.java
    incubator/cassandra/trunk/src/java/org/apache/cassandra/service/StorageServiceMBean.java

Modified: incubator/cassandra/trunk/src/java/org/apache/cassandra/dht/Range.java
URL: http://svn.apache.org/viewvc/incubator/cassandra/trunk/src/java/org/apache/cassandra/dht/Range.java?rev=782182&r1=782181&r2=782182&view=diff
==============================================================================
--- incubator/cassandra/trunk/src/java/org/apache/cassandra/dht/Range.java (original)
+++ incubator/cassandra/trunk/src/java/org/apache/cassandra/dht/Range.java Sat Jun  6 02:45:20
2009
@@ -21,6 +21,7 @@
 import java.io.DataInputStream;
 import java.io.DataOutputStream;
 import java.io.IOException;
+import java.io.Serializable;
 import java.util.List;
 import java.math.BigInteger;
 
@@ -33,7 +34,7 @@
  * Author : Avinash Lakshman ( alakshman@facebook.com) & Prashant Malik ( pmalik@facebook.com
)
  */
 
-public class Range implements Comparable<Range>
+public class Range implements Comparable<Range>, Serializable
 {
     private static ICompactSerializer<Range> serializer_;
     static

Modified: incubator/cassandra/trunk/src/java/org/apache/cassandra/dht/Token.java
URL: http://svn.apache.org/viewvc/incubator/cassandra/trunk/src/java/org/apache/cassandra/dht/Token.java?rev=782182&r1=782181&r2=782182&view=diff
==============================================================================
--- incubator/cassandra/trunk/src/java/org/apache/cassandra/dht/Token.java (original)
+++ incubator/cassandra/trunk/src/java/org/apache/cassandra/dht/Token.java Sat Jun  6 02:45:20
2009
@@ -21,11 +21,12 @@
 import java.io.DataInputStream;
 import java.io.DataOutputStream;
 import java.io.IOException;
+import java.io.Serializable;
 
 import org.apache.cassandra.io.ICompactSerializer;
 import org.apache.cassandra.service.StorageService;
 
-public abstract class Token<T extends Comparable> implements Comparable<Token<T>>
+public abstract class Token<T extends Comparable> implements Comparable<Token<T>>,
Serializable
 {
     private static final TokenSerializer serializer = new TokenSerializer();
     public static TokenSerializer serializer()

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=782182&r1=782181&r2=782182&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
Sat Jun  6 02:45:20 2009
@@ -19,6 +19,10 @@
 package org.apache.cassandra.service;
 
 import java.io.IOException;
+import java.util.List;
+import java.util.Map;
+import org.apache.cassandra.dht.Range;
+import org.apache.cassandra.net.EndPoint;
 
 
 /**
@@ -30,6 +34,7 @@
     public String getLiveNodes();
     public String getUnreachableNodes();
     public String getToken();
+    public Map<Range, List<EndPoint>> getRangeToEndPointMap();
     
     /**
      * This method will cause the local node initiate



Mime
View raw message