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

Add depricated implemention to the StorageProxy

Browse Source 
Some of the depricated function in StorgeProxy uses the Metrics object
to get the information.

This adds an implementation for the following:
getReadOperations
getTotalReadLatencyMicros
getRecentReadLatencyMicros
getTotalReadLatencyHistogramMicros
getRangeOperations
getTotalRangeLatencyMicros
getRecentRangeLatencyMicros
getWriteOperations
getTotalWriteLatencyMicros
getRecentWriteLatencyMicros

It uses the implementation in ClientRequestMetrics without adding new
functionality.

Signed-off-by: Amnon Heiman <amnon@cloudius-systems.com>
This commit is contained in:
Amnon Heiman 2015-08-09 14:45:24 +03:00
parent db71bf6f89
commit 631a6537d9
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
public long getReadOperations() {
log(" getReadOperations()");
return c.getLongValue("");
return readMetrics.latency.count();
}
/**
@ -95,7 +95,7 @@ public class StorageProxy implements StorageProxyMBean {
@Deprecated
public long getTotalReadLatencyMicros() {
log(" getTotalReadLatencyMicros()");
return c.getLongValue("");
return readMetrics.totalLatency.count();
}
/**
@ -104,7 +104,7 @@ public class StorageProxy implements StorageProxyMBean {
@Deprecated
public double getRecentReadLatencyMicros() {
log(" getRecentReadLatencyMicros()");
return c.getDoubleValue("");
return readMetrics.getRecentLatency();
}
/**
@ -128,19 +128,19 @@ public class StorageProxy implements StorageProxyMBean {
@Deprecated
public long getRangeOperations() {
log(" getRangeOperations()");
return c.getLongValue("");
return rangeMetrics.latency.count();
}
@Deprecated
public long getTotalRangeLatencyMicros() {
log(" getTotalRangeLatencyMicros()");
return c.getLongValue("");
return rangeMetrics.totalLatency.count();
}
@Deprecated
public double getRecentRangeLatencyMicros() {
log(" getRecentRangeLatencyMicros()");
return c.getDoubleValue("");
return rangeMetrics.getRecentLatency();
}
@Deprecated
@ -158,19 +158,19 @@ public class StorageProxy implements StorageProxyMBean {
@Deprecated
public long getWriteOperations() {
log(" getWriteOperations()");
return c.getLongValue("");
return writeMetrics.latency.count();
}
@Deprecated
public long getTotalWriteLatencyMicros() {
log(" getTotalWriteLatencyMicros()");
return c.getLongValue("");
return writeMetrics.totalLatency.count();
}
@Deprecated
public double getRecentWriteLatencyMicros() {
log(" getRecentWriteLatencyMicros()");
return c.getDoubleValue("");
return writeMetrics.getRecentLatency();
}
@Deprecated