Skip to content
Merged
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -132,7 +132,7 @@ public double p50() {
return lastSnapshot.p50;
}

private void snapshotAndReset() {
public SnapshotExt snapshotAndReset() {
synchronized (this) {
if (lastSnapshot == null || System.currentTimeMillis() - lastSnapshotTime > snapshotInterval) {
this.intervalHistogram = this.recorder.getIntervalHistogram(this.intervalHistogram);
Expand All @@ -159,9 +159,11 @@ private void snapshotAndReset() {
lastSnapshotTime = System.currentTimeMillis();
}
}

return lastSnapshot;
}

static class SnapshotExt {
public static class SnapshotExt {
final long min;
final long max;
final long count;
Expand All @@ -180,12 +182,40 @@ public SnapshotExt(long min, long max, long count, long sum, double p99, double
this.p95 = p95;
}

double mean() {
public double mean() {
if (count == 0) {
return 0;
} else {
return (double) sum / count;
}
}

public long getMin() {
return min;
}

public long getMax() {
return max;
}

public long getCount() {
return count;
}

public long getSum() {
return sum;
}

public double getP99() {
return p99;
}

public double getP95() {
return p95;
}

public double getP50() {
return p50;
}
}
}
Loading