We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
2 parents 58b016a + dfd557d commit e10af22Copy full SHA for e10af22
libsql-server/src/replication/primary/replication_logger_wal.rs
@@ -100,11 +100,12 @@ impl ReplicationLoggerWalWrapper {
100
101
/// write buffered pages to the logger, without committing.
102
fn flush(&mut self, size_after: u32) -> anyhow::Result<()> {
103
- if !self.buffer.is_empty() {
104
- self.buffer.last_mut().unwrap().size_after = size_after;
105
- self.logger.write_pages(&self.buffer)?;
106
- self.buffer.clear();
107
- }
+ let Some(last_page) = self.buffer.last_mut() else {
+ return Ok(());
+ };
+ last_page.size_after = size_after;
+ self.logger.write_pages(&self.buffer)?;
108
+ self.buffer.clear();
109
110
Ok(())
111
}
0 commit comments