aboutsummaryrefslogtreecommitdiff
path: root/spark-common/src/main/java/me/lucko/spark/common
diff options
context:
space:
mode:
authorLuck <git@lucko.me>2019-05-13 12:56:00 +0100
committerLuck <git@lucko.me>2019-05-13 12:56:00 +0100
commit4f1fa802c75efb6689c8d5cf1aef954eca7d1d0a (patch)
tree4ce1aa2b8a15774aa2e92ff0fe89f64149a5bca5 /spark-common/src/main/java/me/lucko/spark/common
parentb1bdc139b48517a8bcc88888147f5f1a65b48f93 (diff)
downloadspark-4f1fa802c75efb6689c8d5cf1aef954eca7d1d0a.tar.gz
spark-4f1fa802c75efb6689c8d5cf1aef954eca7d1d0a.tar.bz2
spark-4f1fa802c75efb6689c8d5cf1aef954eca7d1d0a.zip
Adjust tick monitoring counting technique
Diffstat (limited to 'spark-common/src/main/java/me/lucko/spark/common')
-rw-r--r--spark-common/src/main/java/me/lucko/spark/common/monitor/tick/TickMonitor.java10
1 files changed, 8 insertions, 2 deletions
diff --git a/spark-common/src/main/java/me/lucko/spark/common/monitor/tick/TickMonitor.java b/spark-common/src/main/java/me/lucko/spark/common/monitor/tick/TickMonitor.java
index e16ce49..77b6bcd 100644
--- a/spark-common/src/main/java/me/lucko/spark/common/monitor/tick/TickMonitor.java
+++ b/spark-common/src/main/java/me/lucko/spark/common/monitor/tick/TickMonitor.java
@@ -34,6 +34,7 @@ public abstract class TickMonitor implements TickCounter.TickTask, GarbageCollec
private static final DecimalFormat df = new DecimalFormat("#.##");
private final TickCounter tickCounter;
+ private final int zeroTick;
private final GarbageCollectionMonitor garbageCollectionMonitor;
private final int percentageChangeThreshold;
@@ -45,6 +46,7 @@ public abstract class TickMonitor implements TickCounter.TickTask, GarbageCollec
public TickMonitor(TickCounter tickCounter, int percentageChangeThreshold, boolean monitorGc) {
this.tickCounter = tickCounter;
+ this.zeroTick = tickCounter.getCurrentTick();
this.percentageChangeThreshold = percentageChangeThreshold;
if (monitorGc) {
@@ -55,6 +57,10 @@ public abstract class TickMonitor implements TickCounter.TickTask, GarbageCollec
}
}
+ public int getCurrentTick() {
+ return tickCounter.getCurrentTick() - zeroTick;
+ }
+
protected abstract void sendMessage(Component message);
@Override
@@ -136,7 +142,7 @@ public abstract class TickMonitor implements TickCounter.TickTask, GarbageCollec
if (percentageChange > this.percentageChangeThreshold) {
sendMessage(TextComponent.builder("").color(TextColor.GRAY)
.append(TextComponent.of("Tick "))
- .append(TextComponent.of("#" + counter.getCurrentTick(), TextColor.DARK_GRAY))
+ .append(TextComponent.of("#" + getCurrentTick(), TextColor.DARK_GRAY))
.append(TextComponent.of(" lasted "))
.append(TextComponent.of(df.format(diff), TextColor.GOLD))
.append(TextComponent.of(" ms. "))
@@ -166,7 +172,7 @@ public abstract class TickMonitor implements TickCounter.TickTask, GarbageCollec
sendMessage(TextComponent.builder("").color(TextColor.GRAY)
.append(TextComponent.of("Tick "))
- .append(TextComponent.of("#" + this.tickCounter.getCurrentTick(), TextColor.DARK_GRAY))
+ .append(TextComponent.of("#" + getCurrentTick(), TextColor.DARK_GRAY))
.append(TextComponent.of(" included "))
.append(TextComponent.of("GC", TextColor.RED))
.append(TextComponent.of(" lasting "))