Revert resetting the next array

cwida · Dec 18, 2024 · b7b4754 · b7b4754
1 parent 7c85657
commit b7b4754
Showing 1 changed file with 5 additions and 5 deletions.
diff --git a/src/core/operator/task/shortest_path_task.cpp b/src/core/operator/task/shortest_path_task.cpp
@@ -22,11 +22,6 @@ TaskExecutionResult ShortestPathTask::ExecuteTask(TaskExecutionMode mode) {
     }
     barrier->Wait();
     do {
-      if (worker_id == 0) {
-        for (auto & i : state->iter & 1 ? state->visit2 : state->visit1) {
-          i.reset();
-        }
-      }
       IterativePath();
 
       // Synchronize after IterativePath
@@ -84,7 +79,12 @@ void ShortestPathTask::IterativePath() {
 
   // Attempt to get a task range
   bool has_tasks = SetTaskRange();
+  for (auto i = left; i < right; i++) {
+    next[i] = 0;
+  }
 
+  // Synchronize after clearing
+  barrier->Wait();
   // Main processing loop
   while (has_tasks) {