From 9baefbe2ab8695952f3db5dca30b8b543b00bf38 Mon Sep 17 00:00:00 2001 From: PSeitz Date: Thu, 23 Jun 2022 09:24:49 +0200 Subject: [PATCH] Update src/store/writer.rs Co-authored-by: Paul Masurel --- src/store/writer.rs | 19 ++++++++----------- 1 file changed, 8 insertions(+), 11 deletions(-) diff --git a/src/store/writer.rs b/src/store/writer.rs index f15c5a8152..3327dd1e97 100644 --- a/src/store/writer.rs +++ b/src/store/writer.rs @@ -101,17 +101,20 @@ impl StoreWriter { /// Flushes current uncompressed block and sends to compressor. fn send_current_block_to_compressor(&mut self) -> io::Result<()> { + // We don't do anything if the current block is empty to begin with. + if self.current_block.is_empty() { + return Ok(()); + } let block = DocumentBlock { data: self.current_block.to_owned(), num_docs_in_block: self.num_docs_in_current_block, }; self.current_block.clear(); self.num_docs_in_current_block = 0; - if !block.is_empty() { - self.compressor_sender - .send(BlockCompressorMessage::AddBlock(block)) - .map_err(|err| io::Error::new(io::ErrorKind::Other, err))?; - } + self.compressor_sender + .send(BlockCompressorMessage::AddBlock(block)) + .map_err(|err| io::Error::new(io::ErrorKind::Other, err))?; + Ok(()) } @@ -191,12 +194,6 @@ struct DocumentBlock { num_docs_in_block: DocId, } -impl DocumentBlock { - fn is_empty(&self) -> bool { - self.data.is_empty() - } -} - impl BlockCompressor { fn new(compressor: Compressor, writer: WritePtr) -> Self { Self {