aboutsummaryrefslogtreecommitdiff
path: root/spark-common/src
diff options
context:
space:
mode:
authorLuck <git@lucko.me>2018-11-02 20:02:58 +0000
committerLuck <git@lucko.me>2018-11-02 20:02:58 +0000
commitbd5056787953c0d59a3bab133d1c4eba7e2d398e (patch)
treee9cfff1647f61549e502eec9f964e6daaba4dfca /spark-common/src
parent61f5addbb996f43d2044a4de12a8241584b8b65f (diff)
downloadspark-bd5056787953c0d59a3bab133d1c4eba7e2d398e.tar.gz
spark-bd5056787953c0d59a3bab133d1c4eba7e2d398e.tar.bz2
spark-bd5056787953c0d59a3bab133d1c4eba7e2d398e.zip
Add --without-gc flag (#7)
Diffstat (limited to 'spark-common/src')
-rw-r--r--spark-common/src/main/java/me/lucko/spark/common/command/modules/MonitoringModule.java7
-rw-r--r--spark-common/src/main/java/me/lucko/spark/monitor/TickMonitor.java8
2 files changed, 9 insertions, 6 deletions
diff --git a/spark-common/src/main/java/me/lucko/spark/common/command/modules/MonitoringModule.java b/spark-common/src/main/java/me/lucko/spark/common/command/modules/MonitoringModule.java
index a6a227f..5d4d84c 100644
--- a/spark-common/src/main/java/me/lucko/spark/common/command/modules/MonitoringModule.java
+++ b/spark-common/src/main/java/me/lucko/spark/common/command/modules/MonitoringModule.java
@@ -43,6 +43,7 @@ public class MonitoringModule<S> implements CommandModule<S> {
consumer.accept(Command.<S>builder()
.aliases("monitoring")
.argumentUsage("threshold", "percentage increase")
+ .argumentUsage("without-gc", null)
.executor((platform, sender, arguments) -> {
if (this.activeTickMonitor == null) {
@@ -53,7 +54,7 @@ public class MonitoringModule<S> implements CommandModule<S> {
try {
TickCounter tickCounter = platform.newTickCounter();
- this.activeTickMonitor = new ReportingTickMonitor(platform, tickCounter, threshold);
+ this.activeTickMonitor = new ReportingTickMonitor(platform, tickCounter, threshold, !arguments.boolFlag("without-gc"));
} catch (UnsupportedOperationException e) {
platform.sendPrefixedMessage(sender, "&cNot supported!");
}
@@ -78,8 +79,8 @@ public class MonitoringModule<S> implements CommandModule<S> {
private class ReportingTickMonitor extends TickMonitor {
private final SparkPlatform<S> platform;
- ReportingTickMonitor(SparkPlatform<S> platform, TickCounter tickCounter, int percentageChangeThreshold) {
- super(tickCounter, percentageChangeThreshold);
+ ReportingTickMonitor(SparkPlatform<S> platform, TickCounter tickCounter, int percentageChangeThreshold, boolean monitorGc) {
+ super(tickCounter, percentageChangeThreshold, monitorGc);
this.platform = platform;
}
diff --git a/spark-common/src/main/java/me/lucko/spark/monitor/TickMonitor.java b/spark-common/src/main/java/me/lucko/spark/monitor/TickMonitor.java
index a7dd4a8..f3eb441 100644
--- a/spark-common/src/main/java/me/lucko/spark/monitor/TickMonitor.java
+++ b/spark-common/src/main/java/me/lucko/spark/monitor/TickMonitor.java
@@ -40,14 +40,14 @@ public abstract class TickMonitor implements Runnable, AutoCloseable {
private DoubleSummaryStatistics averageTickTime = new DoubleSummaryStatistics();
private double avg;
- public TickMonitor(TickCounter tickCounter, int percentageChangeThreshold) {
+ public TickMonitor(TickCounter tickCounter, int percentageChangeThreshold, boolean monitorGc) {
this.tickCounter = tickCounter;
this.percentageChangeThreshold = percentageChangeThreshold;
this.tickCounter.start();
this.tickCounter.addTickTask(this);
- this.garbageCollectionMonitor = new GarbageCollectionMonitor(this);
+ this.garbageCollectionMonitor = monitorGc ? new GarbageCollectionMonitor(this) : null;
}
protected abstract void sendMessage(String message);
@@ -55,7 +55,9 @@ public abstract class TickMonitor implements Runnable, AutoCloseable {
@Override
public void close() {
this.tickCounter.close();
- this.garbageCollectionMonitor.close();
+ if (this.garbageCollectionMonitor != null) {
+ this.garbageCollectionMonitor.close();
+ }
}
@Override