From c666551577b7f52de974689560f425b60837d428 Mon Sep 17 00:00:00 2001 From: Somtochi Onyekwere Date: Fri, 29 Nov 2024 20:02:57 +0100 Subject: [PATCH] correctly decrement buf_cost for apply queue --- crates/corro-agent/src/agent/handlers.rs | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/crates/corro-agent/src/agent/handlers.rs b/crates/corro-agent/src/agent/handlers.rs index 66b42d5f..69a6521c 100644 --- 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);