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

Rework EnpointSnitchInfo

Browse Source
This commit is contained in:
elcallio 2016-10-11 14:06:15 +02:00 committed by Calle Wilund
parent 80762eb60a
commit 21a343d003
1 changed files with 13 additions and 28 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

41
src/main/java/org/apache/cassandra/locator/EndpointSnitchInfo.java
View File

@ -17,43 +17,28 @@
*/ */
package org.apache.cassandra.locator; package org.apache.cassandra.locator;
import java.lang.management.ManagementFactory;
import java.net.InetAddress; import java.net.InetAddress;
import java.net.UnknownHostException; import java.net.UnknownHostException;
import java.util.logging.Logger;
import javax.management.MBeanServer;
import javax.management.ObjectName;
import javax.ws.rs.core.MultivaluedHashMap; import javax.ws.rs.core.MultivaluedHashMap;
import javax.ws.rs.core.MultivaluedMap; import javax.ws.rs.core.MultivaluedMap;
import com.scylladb.jmx.api.APIClient; import com.scylladb.jmx.api.APIClient;
import com.scylladb.jmx.metrics.APIMBean;
public class EndpointSnitchInfo implements EndpointSnitchInfoMBean { public class EndpointSnitchInfo extends APIMBean implements EndpointSnitchInfoMBean {
private static final java.util.logging.Logger logger = java.util.logging.Logger public static final String MBEAN_NAME = "org.apache.cassandra.db:type=EndpointSnitchInfo";
.getLogger(EndpointSnitchInfo.class.getName()); private static final Logger logger = Logger.getLogger(EndpointSnitchInfo.class.getName());
private APIClient c = new APIClient(); public EndpointSnitchInfo(APIClient c) {
super(c);
}
public void log(String str) { public void log(String str) {
logger.finest(str); logger.finest(str);
} }
private static final EndpointSnitchInfo instance = new EndpointSnitchInfo();
public static EndpointSnitchInfo getInstance() {
return instance;
}
private EndpointSnitchInfo() {
MBeanServer mbs = ManagementFactory.getPlatformMBeanServer();
try {
mbs.registerMBean(this, new ObjectName(
"org.apache.cassandra.db:type=EndpointSnitchInfo"));
} catch (Exception e) {
throw new RuntimeException(e);
}
}
/** /**
* Provides the Rack name depending on the respective snitch used, given the * Provides the Rack name depending on the respective snitch used, given the
* host name/ip * host name/ip
@ -69,7 +54,7 @@ public class EndpointSnitchInfo implements EndpointSnitchInfoMBean {
host = InetAddress.getLoopbackAddress().getHostAddress(); host = InetAddress.getLoopbackAddress().getHostAddress();
} }
queryParams.add("host", host); queryParams.add("host", host);
return c.getStringValue("/snitch/rack", queryParams, 10000); return client.getStringValue("/snitch/rack", queryParams, 10000);
} }
/** /**
@ -87,7 +72,7 @@ public class EndpointSnitchInfo implements EndpointSnitchInfoMBean {
host = InetAddress.getLoopbackAddress().getHostAddress(); host = InetAddress.getLoopbackAddress().getHostAddress();
} }
queryParams.add("host", host); queryParams.add("host", host);
return c.getStringValue("/snitch/datacenter", queryParams, 10000); return client.getStringValue("/snitch/datacenter", queryParams, 10000);
} }
/** /**
@ -98,16 +83,16 @@ public class EndpointSnitchInfo implements EndpointSnitchInfoMBean {
@Override @Override
public String getSnitchName() { public String getSnitchName() {
log(" getSnitchName()"); log(" getSnitchName()");
return c.getStringValue("/snitch/name"); return client.getStringValue("/snitch/name");
} }
@Override @Override
public String getRack() { public String getRack() {
return c.getStringValue("/snitch/rack", null, 10000); return client.getStringValue("/snitch/rack", null, 10000);
} }
@Override @Override
public String getDatacenter() { public String getDatacenter() {
return c.getStringValue("/snitch/datacenter", null, 10000); return client.getStringValue("/snitch/datacenter", null, 10000);
} }
} }