[PEx] Cleanup disk tasks on exit, change defaults

Cleanup tasks/ directory on exiting

Change default for schedules-per-task to 500

Change report wait time to 10 sec.

Author: aman-goel

Src/PRuntimes/PExplicitRuntime/pom.xml

@@ -103,7 +103,6 @@
             <groupId>commons-io</groupId>
             <artifactId>commons-io</artifactId>
             <version>2.11.0</version>
-            <scope>test</scope>
         </dependency>
         <dependency>
             <groupId>org.apache.commons</groupId>

Src/PRuntimes/PExplicitRuntime/src/main/java/pexplicit/PExplicit.java

@@ -8,6 +8,7 @@
 import pexplicit.runtime.logger.PExplicitLogger;
 import pexplicit.runtime.logger.StatWriter;
 import pexplicit.runtime.machine.PTestDriver;
+import pexplicit.runtime.scheduler.explicit.strategy.SearchTask;
 import pexplicit.utils.exceptions.BugFoundException;
 import pexplicit.utils.monitor.MemoryMonitor;
 import pexplicit.utils.monitor.TimeMonitor;
@@ -34,6 +35,7 @@ public static void main(String[] args) {
         PExplicitGlobal.setConfig(PExplicitOptions.ParseCommandlineArgs(args));
         PExplicitLogger.Initialize(PExplicitGlobal.getConfig().getVerbosity());
         ComputeHash.Initialize();
+        SearchTask.Initialize();
 
         // get reflections corresponding to the model
         Reflections reflections = new Reflections("pexplicit.model");

Src/PRuntimes/PExplicitRuntime/src/main/java/pexplicit/RuntimeExecutor.java

@@ -5,6 +5,7 @@
 import pexplicit.runtime.logger.PExplicitLogger;
 import pexplicit.runtime.logger.StatWriter;
 import pexplicit.runtime.scheduler.explicit.ExplicitSearchScheduler;
+import pexplicit.runtime.scheduler.explicit.strategy.SearchTask;
 import pexplicit.runtime.scheduler.replay.ReplayScheduler;
 import pexplicit.utils.exceptions.BugFoundException;
 import pexplicit.utils.exceptions.MemoutException;
@@ -124,6 +125,7 @@ private static void process(boolean resume) throws Exception {
             future.cancel(true);
             executor.shutdownNow();
             scheduler.updateResult();
+            SearchTask.Cleanup();
             printStats();
             PExplicitLogger.logEndOfRun(scheduler, Duration.between(TimeMonitor.getStart(), Instant.now()).getSeconds());
         }

Src/PRuntimes/PExplicitRuntime/src/main/java/pexplicit/commandline/PExplicitConfig.java

@@ -61,7 +61,7 @@ public class PExplicitConfig {
     SearchStrategyMode searchStrategyMode = SearchStrategyMode.Random;
     // max number of schedules per search task
     @Setter
-    int maxSchedulesPerTask = 10;
+    int maxSchedulesPerTask = 500;
     //max number of children search tasks
     @Setter
     int maxChildrenPerTask = 2;

Src/PRuntimes/PExplicitRuntime/src/main/java/pexplicit/runtime/scheduler/explicit/ExplicitSearchScheduler.java

@@ -659,7 +659,7 @@ private void printProgressHeader(boolean consolePrint) {
     }
 
     protected void printProgress(boolean forcePrint) {
-        if (forcePrint || (TimeMonitor.findInterval(getLastReportTime()) > 5)) {
+        if (forcePrint || (TimeMonitor.findInterval(getLastReportTime()) > 10)) {
             setLastReportTime(Instant.now());
             double newRuntime = TimeMonitor.getRuntime();
             printCurrentStatus(newRuntime);

Src/PRuntimes/PExplicitRuntime/src/main/java/pexplicit/runtime/scheduler/explicit/strategy/SearchTask.java

@@ -1,6 +1,7 @@
 package pexplicit.runtime.scheduler.explicit.strategy;
 
 import lombok.Getter;
+import org.apache.commons.io.FileUtils;
 import pexplicit.runtime.PExplicitGlobal;
 import pexplicit.runtime.logger.PExplicitLogger;
 import pexplicit.runtime.machine.PMachineId;
@@ -220,14 +221,31 @@ public void clearSearchUnit(int choiceNum) {
         searchUnits.remove(choiceNum);
     }
 
+    public static void Initialize() {
+        String taskPath = PExplicitGlobal.getConfig().getOutputFolder() + "/tasks/";
+        try {
+            Files.createDirectories(Paths.get(taskPath));
+        } catch (IOException e) {
+            throw new RuntimeException("Failed to initialize tasks at " + taskPath, e);
+        }
+    }
+
+    public static void Cleanup() {
+        String taskPath = PExplicitGlobal.getConfig().getOutputFolder() + "/tasks/";
+        try {
+            FileUtils.deleteDirectory(new File(taskPath));
+        } catch (IOException e) {
+            throw new RuntimeException("Failed to cleanup tasks at " + taskPath, e);
+        }
+    }
+
     public void serializeTask() {
         assert (serializeFile == null);
         assert (prefixChoices != null);
         assert (searchUnits != null);
 
         serializeFile = PExplicitGlobal.getConfig().getOutputFolder() + "/tasks/" + this + ".ser";
         try {
-            Files.createDirectories(Paths.get(PExplicitGlobal.getConfig().getOutputFolder() + "/tasks/"));
             FileOutputStream fos = new FileOutputStream(serializeFile);
             ObjectOutputStream oos = new ObjectOutputStream(fos);
             oos.writeObject(this.prefixChoices);