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

MessagingService: Add dropped and timeout support

Browse Source 
This adds the implementation for dropped messages and timeout messages
counters in MessagingService.

Signed-off-by: Amnon Heiman <amnon@scylladb.com>
This commit is contained in:
Amnon Heiman 2015-11-11 09:48:49 +02:00
parent e530c13f87
commit b783a0d09a
1 changed files with 9 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/main/java/org/apache/cassandra/net/MessagingService.java
View File

@ -25,6 +25,7 @@ package org.apache.cassandra.net;
import java.lang.management.ManagementFactory;
import java.net.*;
import java.util.*;
import java.util.Map.Entry;
import javax.management.MBeanServer;
import javax.management.ObjectName;
@ -86,7 +87,7 @@ public final class MessagingService implements MessagingServiceMBean {
*/
public Map<String, Long> getCommandDroppedTasks() {
log(" getCommandDroppedTasks()");
return c.getMapStringLongValue("");
return c.getMapStringLongValue("/messaging_service/messages/dropped");
}
/**
@ -126,7 +127,12 @@ public final class MessagingService implements MessagingServiceMBean {
*/
public long getTotalTimeouts() {
log(" getTotalTimeouts()");
return c.getLongValue("");
Map<String, Long> timeouts = getTimeoutsPerHost();
long res = 0;
for (Entry<String, Long> t : timeouts.entrySet()) {
res += t.getValue();
}
return res;
}
/**
@ -134,7 +140,7 @@ public final class MessagingService implements MessagingServiceMBean {
*/
public Map<String, Long> getTimeoutsPerHost() {
log(" getTimeoutsPerHost()");
return c.getMapStringLongValue("");
return c.getMapStringLongValue("/messaging_service/messages/timeout");
}
/**