From dfd557d98d6b53ea1a8e35e85331620bb5e62df3 Mon Sep 17 00:00:00 2001 From: Piotr Jastrzebski Date: Thu, 19 Dec 2024 11:41:06 +0100 Subject: [PATCH] Small code refactoring Signed-off-by: Piotr Jastrzebski --- .../src/replication/primary/replication_logger_wal.rs | 11 ++++++----- 1 file changed, 6 insertions(+), 5 deletions(-) diff --git a/libsql-server/src/replication/primary/replication_logger_wal.rs b/libsql-server/src/replication/primary/replication_logger_wal.rs index defd8abf87..79e1fcc580 100644 --- a/libsql-server/src/replication/primary/replication_logger_wal.rs +++ b/libsql-server/src/replication/primary/replication_logger_wal.rs @@ -100,11 +100,12 @@ impl ReplicationLoggerWalWrapper { /// write buffered pages to the logger, without committing. fn flush(&mut self, size_after: u32) -> anyhow::Result<()> { - if !self.buffer.is_empty() { - self.buffer.last_mut().unwrap().size_after = size_after; - self.logger.write_pages(&self.buffer)?; - self.buffer.clear(); - } + let Some(last_page) = self.buffer.last_mut() else { + return Ok(()); + }; + last_page.size_after = size_after; + self.logger.write_pages(&self.buffer)?; + self.buffer.clear(); Ok(()) }