correctly decrement buf_cost for apply queue

superfly · Nov 29, 2024 · c666551 · c666551
1 parent 7d4512f
commit c666551
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/crates/corro-agent/src/agent/handlers.rs b/crates/corro-agent/src/agent/handlers.rs
@@ -899,8 +899,9 @@ pub async fn handle_changes(
                             entry.remove_entry();
                         }
                     };
-                    buf_cost -= dropped_change.processing_cost();
                 }
+
+                buf_cost -= dropped_change.processing_cost();
             }
 
             log_at_pow_10("dropped old change from queue", &mut drop_log_count);