enable multi-punctuation processing

.gitignore

@@ -48,3 +48,9 @@ _install/
 logs
 scripts/draw/results*
 scripts/*.jar
+
+target/
+results/
+*.lock
+*.nolock
+dependency-reduced-pom.xml

common/src/main/java/common/Runner.java

@@ -91,7 +91,7 @@ public abstract class Runner implements IRunner {
     @Parameter(names = {"--isRuntime"}, description = "Collect runtime information")
     public boolean isRuntime = false;
     @Parameter(names = {"--isDynamic"}, description = "Dynamic Workload")
-    public boolean isDynamic = true;
+    public boolean isDynamic = false;
     @Parameter(names = {"--schedulerPool"}, description = "Schedulers in the SchedulerPool[OG_DFS,OP_DFS]")
     public String schedulerPools = "OP_NS_A,OP_BFS_A,OP_BFS,OG_BFS";
     @Parameter(names = {"--defaultScheduler"}, description = "Default scheduler")
@@ -220,7 +220,7 @@ public void initializeCfg(HashMap<String, Object> config) {
 
         config.put("checkpoint", checkpoint_interval);
 
-        assert totalEvents / tthread == checkpoint_interval;
+        assert totalEvents % tthread == 0;
 
         config.put("COMPUTE_COMPLEXITY", COMPUTE_COMPLEXITY);
         config.put("POST_COMPUTE", POST_COMPUTE);

state-engine/src/main/java/scheduler/struct/og/OperationChain.java

@@ -278,6 +278,7 @@ public void clear() {
         operations.clear();
         ocParents.clear();
         ocChildren.clear();
+        isExecuted = false;
         // Non-structured data structure clearance
         needAbortHandling = false;
         failedOperations.clear();

state-engine/src/main/java/scheduler/struct/og/TaskPrecedenceGraph.java

@@ -61,10 +61,13 @@ public void reset(Context context) {
             operationChains.get("goods").threadOCsMap.get(context.thisThreadId).holder_v1.clear();
         }
 //        threadToOCs.get(context.thisThreadId).clear();
+//        for (OperationChain oc : threadToOCs.get(context.thisThreadId)) {
+//            oc.clear();
+//        }
+//        this.setOCs(context);
         for (OperationChain oc : threadToOCs.get(context.thisThreadId)) {
             oc.clear();
         }
-//        this.setOCs(context);
     }
 
     /**

state-engine/src/main/java/scheduler/struct/op/OperationChain.java

@@ -157,6 +157,11 @@ public int compareTo(PotentialDependencyInfo o) {
     public void clear() {
         potentialChldrenInfo.clear();
         operations.clear();
+        ocParents.clear();
+        isExecuted = false;
+        // Structured data structure clearance
+        isDependencyLevelCalculated = false;
+        dependencyLevel = -1;
     }
 
 

state-engine/src/main/java/scheduler/struct/op/TaskPrecedenceGraph.java

@@ -55,10 +55,13 @@ public void reset(Context context) {
             operationChains.get("goods").threadOCsMap.get(context.thisThreadId).holder_v1.clear();
         }
 //        threadToOCs.get(context.thisThreadId).clear();
+//        for (OperationChain oc : threadToOCs.get(context.thisThreadId)) {
+//            oc.clear();
+//        }
+//        this.setOCs(context); // TODO: the short cut should be reset, but will take some time.
         for (OperationChain oc : threadToOCs.get(context.thisThreadId)) {
             oc.clear();
         }
-//        this.setOCs(context); // TODO: the short cut should be reset, but will take some time.
     }
 
     /**

stream-engine/src/main/java/execution/ExecutionManager.java

@@ -66,15 +66,15 @@ public void distributeTasks(Configuration conf,
                 int numberOfStates = conf.getInt("NUM_ITEMS");
                 String schedulerType = conf.getString("scheduler");
                 int app = conf.getInt("app");
-                if(conf.getBoolean("isDynamic")){
+                if (conf.getBoolean("isDynamic")) {
                     String schedulers=conf.getString("schedulersPool");
-                    TxnManager.initSchedulerPool(conf.getString("defaultScheduler"),schedulers, totalThread,numberOfStates,app);
+                    TxnManager.initSchedulerPool(conf.getString("defaultScheduler"), schedulers, totalThread, numberOfStates,app);
                     //Configure the bottom line for triggering scheduler switching in Collector(include the isRuntime and when to switch)
                     TxnManager.setBottomLine(conf.getString("bottomLine"));
-                    if(!conf.getBoolean("isRuntime")){
+                    if (!conf.getBoolean("isRuntime")) {
                         TxnManager.setWorkloadConfig(conf.getString("WorkloadConfig"));
                     }
-                }else{
+                } else {
                     TxnManager.CreateScheduler(schedulerType, totalThread, numberOfStates, app);
                 }
             }