Author: brandonwilliams Date: Fri Jul 15 17:03:13 2011 New Revision: 1147248
URL: http://svn.apache.org/viewvc?rev=1147248&view=rev Log: Expose data_dir through JMX. Patch by Mike Bulman, reviewed by brandonwilliams for CASSANDRA-2770 Modified: cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/service/StorageService.java cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/service/StorageServiceMBean.java Modified: cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/service/StorageService.java URL: http://svn.apache.org/viewvc/cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/service/StorageService.java?rev=1147248&r1=1147247&r2=1147248&view=diff ============================================================================== --- cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/service/StorageService.java (original) +++ cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/service/StorageService.java Fri Jul 15 17:03:13 2011 @@ -1225,6 +1225,26 @@ public class StorageService implements I return stringify(Gossiper.instance.getUnreachableMembers()); } + public String[] getAllDataFileLocations() + { + return DatabaseDescriptor.getAllDataFileLocations(); + } + + public String[] getAllDataFileLocationsForTable(String table) + { + return DatabaseDescriptor.getAllDataFileLocationsForTable(table); + } + + public String getCommitLogLocation() + { + return DatabaseDescriptor.getCommitLogLocation(); + } + + public String getSavedCachesLocation() + { + return DatabaseDescriptor.getSavedCachesLocation(); + } + private List<String> stringify(Iterable<InetAddress> endpoints) { List<String> stringEndpoints = new ArrayList<String>(); Modified: cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/service/StorageServiceMBean.java URL: http://svn.apache.org/viewvc/cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/service/StorageServiceMBean.java?rev=1147248&r1=1147247&r2=1147248&view=diff ============================================================================== --- cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/service/StorageServiceMBean.java (original) +++ cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/service/StorageServiceMBean.java Fri Jul 15 17:03:13 2011 @@ -78,6 +78,31 @@ public interface StorageServiceMBean public String getReleaseVersion(); /** + * Get the list of all data file locations from conf + * @return String array of all locations + */ + public String[] getAllDataFileLocations(); + + /** + * Get the list of data file locations for a given keyspace + * @param keyspace the keyspace to get locatiosn for. + * @return String array of all locations + */ + public String[] getAllDataFileLocationsForTable(String table); + + /** + * Get location of the commit log + * @return a string path + */ + public String getCommitLogLocation(); + + /** + * Get location of the saved caches dir + * @return a string path + */ + public String getSavedCachesLocation(); + + /** * Retrieve a map of range to end points that describe the ring topology * of a Cassandra cluster. *
