From 5cb8e874d0e9f0a12cb5dc3327af8aadd07a3592 Mon Sep 17 00:00:00 2001 From: Alexey Shekhirin Date: Thu, 3 Oct 2024 14:31:27 +0300 Subject: [PATCH] fix(exex): WAL size metric --- crates/exex/exex/src/wal/mod.rs | 8 +------- 1 file changed, 1 insertion(+), 7 deletions(-) diff --git a/crates/exex/exex/src/wal/mod.rs b/crates/exex/exex/src/wal/mod.rs index 94312bd71d0b..2341b56d1044 100644 --- a/crates/exex/exex/src/wal/mod.rs +++ b/crates/exex/exex/src/wal/mod.rs @@ -166,14 +166,8 @@ impl WalInner { } fn update_metrics(&self, block_cache: &BlockCache, size_delta: i64) { - if size_delta >= 0 { - self.metrics.size_bytes.increment(size_delta as f64); - } else { - self.metrics.size_bytes.decrement(size_delta as f64); - } - + self.metrics.size_bytes.increment(size_delta as f64); self.metrics.notifications_total.set(block_cache.notification_max_blocks.len() as f64); - self.metrics.committed_blocks_total.set(block_cache.committed_blocks.len() as f64); if let Some(lowest_committed_block_height) = block_cache.lowest_committed_block_height {