Skip to content

Commit

Permalink
added param commenting to select network interface when interested in
Browse files Browse the repository at this point in the history
node load
  • Loading branch information
dtrihinas committed Nov 20, 2014
1 parent bcbb8eb commit da4751a
Showing 1 changed file with 5 additions and 5 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -67,8 +67,8 @@ public ProbeMetric collect() {
double r,w;
long b;
for(Entry<String, Integer> entry:keyspaces.entrySet()){
r = (temp.get(entry.getKey()+"_readLatency") != null) ? temp.get(entry.getKey()+"_readLatency") : 0.0;
w = (temp.get(entry.getKey()+"_writeLatency") != null) ? temp.get(entry.getKey()+"_writeLatency") : 0.0;
r = (temp.get(entry.getKey()+"_readLatency") != null) ? temp.get(entry.getKey()+"_readLatency") : Double.NaN;
w = (temp.get(entry.getKey()+"_writeLatency") != null) ? temp.get(entry.getKey()+"_writeLatency") : Double.NaN;
b = (temp.get(entry.getKey()+"_load") != null) ? temp.get(entry.getKey()+"_load").longValue() : 0;
values.put(entry.getValue(), r);
values.put(entry.getValue()+1, w);
Expand All @@ -81,9 +81,9 @@ public ProbeMetric collect() {
values.put(this.loadint, l);
}

for(Entry<Integer,Object> entry:values.entrySet()){
System.out.println(entry.getKey()+" "+entry.getValue());
}
// for(Entry<Integer,Object> entry:values.entrySet()){
// System.out.println(entry.getKey()+" "+entry.getValue());
// }

return new ProbeMetric(values);
}
Expand Down

0 comments on commit da4751a

Please sign in to comment.