Insert into map for tracking requested needs to prevent duplication

superfly · Aug 28, 2024 · 7847fa9 · 7847fa9
1 parent 589ce3c
commit 7847fa9
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/crates/corro-agent/src/api/peer.rs b/crates/corro-agent/src/api/peer.rs
@@ -1293,7 +1293,7 @@ pub async fn parallel_sync(
                             new_versions
                                 .into_iter()
                                 .map(|versions| {
-                                    range.remove(versions.clone());
+                                    range.insert(versions.clone());
                                     SyncNeedV1::Full { versions }
                                 })
                                 .collect()
@@ -1318,7 +1318,7 @@ pub async fn parallel_sync(
                                 seqs: new_seqs
                                     .into_iter()
                                     .map(|seqs| {
-                                        range.remove(seqs.clone());
+                                        range.insert(seqs.clone());
                                         seqs
                                     })
                                     .collect(),

diff --git a/crates/corro-types/src/config.rs b/crates/corro-types/src/config.rs
@@ -15,7 +15,7 @@ const fn default_wal_threshold() -> usize {
     10
 }
 const fn default_processing_queue() -> usize {
-    100000
+    5000000
 }
 
 /// Used for the apply channel