andreacavalli/scylla-jmx
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

JMX API: Adding the CommitLog implementation

Browse Source 
This adds two of the supported CommitLog method, the
getActiveSegmentNames and the getArchivingSegmentNames.

The API for both returns full path, so the JMX API takes the file name
from the path and remove duplicates.

Signed-off-by: Amnon Heiman <amnon@cloudius-systems.com>
This commit is contained in:
Amnon Heiman 2015-05-19 17:53:00 +03:00
parent b11acd15b3
commit b7e1f5a979
1 changed files with 15 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
src/main/java/org/apache/cassandra/db/commitlog/CommitLog.java
View File

@ -43,7 +43,6 @@ public class CommitLog implements CommitLogMBean {
private APIClient c = new APIClient();
public void log(String str) {
System.out.println(str);
logger.info(str);
}
@ -52,6 +51,7 @@ public class CommitLog implements CommitLogMBean {
public static CommitLog getInstance() {
return instance;
}
private CommitLog() {
MBeanServer mbs = ManagementFactory.getPlatformMBeanServer();
try {
@ -108,7 +108,13 @@ public class CommitLog implements CommitLogMBean {
*/
public List<String> getActiveSegmentNames() {
log(" getActiveSegmentNames()");
return c.getListStrValue("");
List<String> lst = c.getListStrValue("/commitlog/segments/active");
Set<String> set = new HashSet<String>();
for (String l : lst) {
String name = l.substring(l.lastIndexOf("/") + 1, l.length());
set.add(name);
}
return new ArrayList<String>(set);
}
/**
@ -117,7 +123,13 @@ public class CommitLog implements CommitLogMBean {
*/
public List<String> getArchivingSegmentNames() {
log(" getArchivingSegmentNames()");
return c.getListStrValue("");
List<String> lst = c.getListStrValue("/commitlog/segments/archiving");
Set<String> set = new HashSet<String>();
for (String l : lst) {
String name = l.substring(l.lastIndexOf("/") + 1, l.length());
set.add(name);
}
return new ArrayList<String>(set);
}
}