Skip to content

Commit

Permalink
Small code refactoring
Browse files Browse the repository at this point in the history
Signed-off-by: Piotr Jastrzebski <[email protected]>
  • Loading branch information
haaawk committed Dec 19, 2024
1 parent 58b016a commit dfd557d
Showing 1 changed file with 6 additions and 5 deletions.
11 changes: 6 additions & 5 deletions libsql-server/src/replication/primary/replication_logger_wal.rs
Original file line number Diff line number Diff line change
Expand Up @@ -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(())
}
Expand Down

0 comments on commit dfd557d

Please sign in to comment.