bugfix for multi puncutation (#96)

intellistream · Mar 31, 2022 · ea8b3bb · ea8b3bb
1 parent 0fa57ee
commit ea8b3bb
Show file tree

Hide file tree

Showing 2 changed files with 14 additions and 14 deletions.
diff --git a/state-engine/src/main/java/scheduler/struct/og/TaskPrecedenceGraph.java b/state-engine/src/main/java/scheduler/struct/og/TaskPrecedenceGraph.java
@@ -48,25 +48,25 @@ public class TaskPrecedenceGraph<Context extends OGSchedulerContext> {
     private final int app;
 
     public void reset(Context context) {
-        //reset holder.
-        if (app == 0) {
-            operationChains.get("MicroTable").threadOCsMap.get(context.thisThreadId).holder_v1.clear();
-        } else if (app == 1) {
-            operationChains.get("accounts").threadOCsMap.get(context.thisThreadId).holder_v1.clear();
-            operationChains.get("bookEntries").threadOCsMap.get(context.thisThreadId).holder_v1.clear();
-        } else if (app == 2 ) {
-            operationChains.get("segment_speed").threadOCsMap.get(context.thisThreadId).holder_v1.clear();
-            operationChains.get("segment_cnt").threadOCsMap.get(context.thisThreadId).holder_v1.clear();
-        } else if (app == 3) {
-            operationChains.get("goods").threadOCsMap.get(context.thisThreadId).holder_v1.clear();
-        }
+//        //reset holder.
+//        if (app == 0) {
+//            operationChains.get("MicroTable").threadOCsMap.get(context.thisThreadId).holder_v1.clear();
+//        } else if (app == 1) {
+//            operationChains.get("accounts").threadOCsMap.get(context.thisThreadId).holder_v1.clear();
+//            operationChains.get("bookEntries").threadOCsMap.get(context.thisThreadId).holder_v1.clear();
+//        } else if (app == 2 ) {
+//            operationChains.get("segment_speed").threadOCsMap.get(context.thisThreadId).holder_v1.clear();
+//            operationChains.get("segment_cnt").threadOCsMap.get(context.thisThreadId).holder_v1.clear();
+//        } else if (app == 3) {
+//            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();
+            oc.clear(); // only need to clear all operations from all ocs
         }
     }
 

diff --git a/state-engine/src/main/java/scheduler/struct/op/TaskPrecedenceGraph.java b/state-engine/src/main/java/scheduler/struct/op/TaskPrecedenceGraph.java
@@ -60,7 +60,7 @@ public void reset(Context context) {
 //        }
 //        this.setOCs(context); // TODO: the short cut should be reset, but will take some time.
         for (OperationChain oc : threadToOCs.get(context.thisThreadId)) {
-            oc.clear();
+            oc.clear(); // only need to clear all operations from all ocs
         }
     }