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

Merge "Implement some of the deprecated method in StorageProxy" from Amnon

Browse Source
This commit is contained in:
Pekka Enberg 2015-08-10 14:58:51 +03:00
commit 35e5b22746
1 changed files with 9 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
src/main/java/org/apache/cassandra/service/StorageProxy.java
View File

@ -86,7 +86,7 @@ public class StorageProxy implements StorageProxyMBean {
@Deprecated @Deprecated
public long getReadOperations() { public long getReadOperations() {
log(" getReadOperations()"); log(" getReadOperations()");
return c.getLongValue(""); return readMetrics.latency.count();
} }
/** /**
@ -95,7 +95,7 @@ public class StorageProxy implements StorageProxyMBean {
@Deprecated @Deprecated
public long getTotalReadLatencyMicros() { public long getTotalReadLatencyMicros() {
log(" getTotalReadLatencyMicros()"); log(" getTotalReadLatencyMicros()");
return c.getLongValue(""); return readMetrics.totalLatency.count();
} }
/** /**
@ -104,7 +104,7 @@ public class StorageProxy implements StorageProxyMBean {
@Deprecated @Deprecated
public double getRecentReadLatencyMicros() { public double getRecentReadLatencyMicros() {
log(" getRecentReadLatencyMicros()"); log(" getRecentReadLatencyMicros()");
return c.getDoubleValue(""); return readMetrics.getRecentLatency();
} }
/** /**
@ -128,19 +128,19 @@ public class StorageProxy implements StorageProxyMBean {
@Deprecated @Deprecated
public long getRangeOperations() { public long getRangeOperations() {
log(" getRangeOperations()"); log(" getRangeOperations()");
return c.getLongValue(""); return rangeMetrics.latency.count();
} }
@Deprecated @Deprecated
public long getTotalRangeLatencyMicros() { public long getTotalRangeLatencyMicros() {
log(" getTotalRangeLatencyMicros()"); log(" getTotalRangeLatencyMicros()");
return c.getLongValue(""); return rangeMetrics.totalLatency.count();
} }
@Deprecated @Deprecated
public double getRecentRangeLatencyMicros() { public double getRecentRangeLatencyMicros() {
log(" getRecentRangeLatencyMicros()"); log(" getRecentRangeLatencyMicros()");
return c.getDoubleValue(""); return rangeMetrics.getRecentLatency();
} }
@Deprecated @Deprecated
@ -158,19 +158,19 @@ public class StorageProxy implements StorageProxyMBean {
@Deprecated @Deprecated
public long getWriteOperations() { public long getWriteOperations() {
log(" getWriteOperations()"); log(" getWriteOperations()");
return c.getLongValue(""); return writeMetrics.latency.count();
} }
@Deprecated @Deprecated
public long getTotalWriteLatencyMicros() { public long getTotalWriteLatencyMicros() {
log(" getTotalWriteLatencyMicros()"); log(" getTotalWriteLatencyMicros()");
return c.getLongValue(""); return writeMetrics.totalLatency.count();
} }
@Deprecated @Deprecated
public double getRecentWriteLatencyMicros() { public double getRecentWriteLatencyMicros() {
log(" getRecentWriteLatencyMicros()"); log(" getRecentWriteLatencyMicros()");
return c.getDoubleValue(""); return writeMetrics.getRecentLatency();
} }
@Deprecated @Deprecated