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

Gossiper: update to c3 compat

Browse Source
This commit is contained in:
Calle Wilund 2016-08-17 08:33:00 +00:00
parent b7a6554ee9
commit 68ce437b03
2 changed files with 6 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/main/java/org/apache/cassandra/gms/Gossiper.java
View File

@ -77,17 +77,20 @@ public class Gossiper implements GossiperMBean {
}
}
@Override
public long getEndpointDowntime(String address) throws UnknownHostException {
log(" getEndpointDowntime(String address) throws UnknownHostException");
return c.getLongValue("gossiper/downtime/" + address);
}
@Override
public int getCurrentGenerationNumber(String address)
throws UnknownHostException {
log(" getCurrentGenerationNumber(String address) throws UnknownHostException");
return c.getIntValue("gossiper/generation_number/" + address);
}
@Override
public void unsafeAssassinateEndpoint(String address)
throws UnknownHostException {
log(" unsafeAssassinateEndpoint(String address) throws UnknownHostException");
@ -96,6 +99,7 @@ public class Gossiper implements GossiperMBean {
c.post("gossiper/assassinate/" + address, queryParams);
}
@Override
public void assassinateEndpoint(String address) throws UnknownHostException {
log(" assassinateEndpoint(String address) throws UnknownHostException");
c.post("gossiper/assassinate/" + address, null);

2
src/main/java/org/apache/cassandra/gms/GossiperMBean.java
View File

@ -27,4 +27,6 @@ public interface GossiperMBean
public void unsafeAssassinateEndpoint(String address) throws UnknownHostException;
public void assassinateEndpoint(String address) throws UnknownHostException;
}