aboutsummaryrefslogtreecommitdiff
path: root/spark-common/src/main/java/me/lucko/spark/common/command
diff options
context:
space:
mode:
authorLuck <git@lucko.me>2019-05-24 18:54:33 +0100
committerLuck <git@lucko.me>2019-05-24 18:54:33 +0100
commit10a73b7ef7910fae0010ea7e06c6ed303a90dc29 (patch)
treee8e0ca75172ab61c24ff0634a4817297f0736c24 /spark-common/src/main/java/me/lucko/spark/common/command
parentfce29989563103fe8b36c60e3942a658ff62a9ce (diff)
downloadspark-10a73b7ef7910fae0010ea7e06c6ed303a90dc29.tar.gz
spark-10a73b7ef7910fae0010ea7e06c6ed303a90dc29.tar.bz2
spark-10a73b7ef7910fae0010ea7e06c6ed303a90dc29.zip
Send tick monitoring messages async
Diffstat (limited to 'spark-common/src/main/java/me/lucko/spark/common/command')
-rw-r--r--spark-common/src/main/java/me/lucko/spark/common/command/modules/TickMonitoringModule.java7
1 files changed, 4 insertions, 3 deletions
diff --git a/spark-common/src/main/java/me/lucko/spark/common/command/modules/TickMonitoringModule.java b/spark-common/src/main/java/me/lucko/spark/common/command/modules/TickMonitoringModule.java
index 75d5d36..da26dea 100644
--- a/spark-common/src/main/java/me/lucko/spark/common/command/modules/TickMonitoringModule.java
+++ b/spark-common/src/main/java/me/lucko/spark/common/command/modules/TickMonitoringModule.java
@@ -20,6 +20,7 @@
package me.lucko.spark.common.command.modules;
+import me.lucko.spark.common.SparkPlatform;
import me.lucko.spark.common.command.Command;
import me.lucko.spark.common.command.CommandModule;
import me.lucko.spark.common.command.CommandResponseHandler;
@@ -68,7 +69,7 @@ public class TickMonitoringModule implements CommandModule {
threshold = 100;
}
- this.activeTickMonitor = new ReportingTickMonitor(resp, this.tickCounter, threshold, !arguments.boolFlag("without-gc"));
+ this.activeTickMonitor = new ReportingTickMonitor(platform, resp, this.tickCounter, threshold, !arguments.boolFlag("without-gc"));
this.tickCounter.addTickTask(this.activeTickMonitor);
} else {
close();
@@ -83,8 +84,8 @@ public class TickMonitoringModule implements CommandModule {
private class ReportingTickMonitor extends TickMonitor {
private final CommandResponseHandler resp;
- ReportingTickMonitor(CommandResponseHandler resp, TickCounter tickCounter, int percentageChangeThreshold, boolean monitorGc) {
- super(tickCounter, percentageChangeThreshold, monitorGc);
+ ReportingTickMonitor(SparkPlatform platform, CommandResponseHandler resp, TickCounter tickCounter, int percentageChangeThreshold, boolean monitorGc) {
+ super(platform, tickCounter, percentageChangeThreshold, monitorGc);
this.resp = resp;
}