Suppress profiler logs when running in background

2 files changed, 9 insertions, 3 deletions

diff --git a/spark-common/src/main/java/me/lucko/spark/common/sampler/async/AsyncProfilerJob.java b/spark-common/src/main/java/me/lucko/spark/common/sampler/async/AsyncProfilerJob.java
index 7b123a7..8991e94 100644
--- a/spark-common/src/main/java/me/lucko/spark/common/sampler/async/AsyncProfilerJob.java
+++ b/spark-common/src/main/java/me/lucko/spark/common/sampler/async/AsyncProfilerJob.java
@@ -83,6 +83,8 @@ public class AsyncProfilerJob {
     private ThreadDumper threadDumper;
     /** The profiling window */
     private int window;
+    /** If the profiler should run in quiet mode */
+    private boolean quiet;
 
     /** The file used by async-profiler to output data */
     private Path outputFile;
@@ -116,11 +118,12 @@ public class AsyncProfilerJob {
     }
 
     // Initialise the job
-    public void init(SparkPlatform platform, int interval, ThreadDumper threadDumper, int window) {
+    public void init(SparkPlatform platform, int interval, ThreadDumper threadDumper, int window, boolean quiet) {
         this.platform = platform;
         this.interval = interval;
         this.threadDumper = threadDumper;
         this.window = window;
+        this.quiet = quiet;
     }
 
     /**
@@ -139,6 +142,9 @@ public class AsyncProfilerJob {
 
             // construct a command to send to async-profiler
             String command = "start,event=" + this.access.getProfilingEvent() + ",interval=" + this.interval + "us,threads,jfr,file=" + this.outputFile.toString();
+            if (this.quiet) {
+                command += ",loglevel=NONE";
+            }
             if (this.threadDumper instanceof ThreadDumper.Specific) {
                 command += ",filter";
             }
diff --git a/spark-common/src/main/java/me/lucko/spark/common/sampler/async/AsyncSampler.java b/spark-common/src/main/java/me/lucko/spark/common/sampler/async/AsyncSampler.java
index d6cfd4f..f2e7191 100644
--- a/spark-common/src/main/java/me/lucko/spark/common/sampler/async/AsyncSampler.java
+++ b/spark-common/src/main/java/me/lucko/spark/common/sampler/async/AsyncSampler.java
@@ -79,7 +79,7 @@ public class AsyncSampler extends AbstractSampler {
         int window = ProfilingWindowUtils.windowNow();
 
         AsyncProfilerJob job = this.profilerAccess.startNewProfilerJob();
-        job.init(this.platform, this.interval, this.threadDumper, window);
+        job.init(this.platform, this.interval, this.threadDumper, window, this.background);
         job.start();
         this.currentJob = job;
 
@@ -116,7 +116,7 @@ public class AsyncSampler extends AbstractSampler {
                 // start a new job
                 int window = previousJob.getWindow() + 1;
                 AsyncProfilerJob newJob = this.profilerAccess.startNewProfilerJob();
-                newJob.init(this.platform, this.interval, this.threadDumper, window);
+                newJob.init(this.platform, this.interval, this.threadDumper, window, this.background);
                 newJob.start();
                 this.currentJob = newJob;