Remove par iter from hot path (#1647)

Pometry · Jun 7, 2024 · 1e984cd · 1e984cd
1 parent 571723d
commit 1e984cd
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 5 deletions.
diff --git a/raphtory/src/core/entities/edges/edge_store.rs b/raphtory/src/core/entities/edges/edge_store.rs
@@ -246,15 +246,15 @@ impl EdgeStore {
             LayerIds::None => false,
             LayerIds::All => self
                 .additions
-                .par_iter()
+                .iter()
                 .any(|t_index| t_index.contains(w.clone())),
             LayerIds::One(l_id) => self
                 .additions
                 .get(*l_id)
                 .map(|t_index| t_index.contains(w))
                 .unwrap_or(false),
             LayerIds::Multiple(layers) => layers
-                .par_iter()
+                .iter()
                 .any(|l_id| self.active(&LayerIds::One(*l_id), w.clone())),
         }
     }

diff --git a/raphtory/src/db/api/storage/edges/edge_storage_ops.rs b/raphtory/src/db/api/storage/edges/edge_storage_ops.rs
@@ -251,7 +251,7 @@ impl<'a> EdgeStorageOps<'a> for &'a EdgeStore {
             LayerIds::None => false,
             LayerIds::All => true,
             LayerIds::One(id) => self.has_layer_inner(*id),
-            LayerIds::Multiple(ids) => ids.par_iter().any(|id| self.has_layer_inner(*id)),
+            LayerIds::Multiple(ids) => ids.iter().any(|id| self.has_layer_inner(*id)),
         }
     }
 

diff --git a/raphtory/src/db/graph/views/deletion_graph.rs b/raphtory/src/db/graph/views/deletion_graph.rs
@@ -97,13 +97,13 @@ fn alive_at<
 }
 
 fn edge_alive_at_end(e: EdgeStorageRef, t: i64, layer_ids: &LayerIds) -> bool {
-    e.updates_par_iter(layer_ids)
+    e.updates_iter(layer_ids)
         .any(|(_, additions, deletions)| alive_before(&additions, &deletions, t))
 }
 
 fn edge_alive_at_start(e: EdgeStorageRef, t: i64, layer_ids: &LayerIds) -> bool {
     // The semantics are tricky here, an edge is not alive at the start of the window if the first event at time t is a deletion
-    e.updates_par_iter(layer_ids)
+    e.updates_iter(layer_ids)
         .any(|(_, additions, deletions)| alive_at(&additions, &deletions, t))
 }