drop changes from back of the queue

superfly · Nov 1, 2024 · 8f2ddcf · 8f2ddcf
1 parent 0396633
commit 8f2ddcf
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 3 deletions.
diff --git a/crates/corro-agent/src/agent/handlers.rs b/crates/corro-agent/src/agent/handlers.rs
@@ -865,7 +865,7 @@ pub async fn handle_changes(
 
         // drop old items when the queue is full.
         if queue.len() > max_queue_len {
-            let change = queue.pop_front();
+            let change = queue.pop_back();
             if let Some(change) = change {
                 for v in change.0.versions() {
                     let _ = seen.remove(&(change.0.actor_id, v));

diff --git a/crates/corro-agent/src/api/peer.rs b/crates/corro-agent/src/api/peer.rs
@@ -1212,8 +1212,6 @@ pub async fn parallel_sync(
                             })
                             .collect();
 
-                        // NOTE: IMPORTANT! shuffle the vec so we don't keep looping over the same later on
-
                         needs
                             .into_iter()
                             .map(|need| (actor_id, need))