diff options
| author | Jan Tuomi <jan@jantuomi.fi> | 2024-11-04 23:13:44 +0200 |
|---|---|---|
| committer | Jan Tuomi <jan@jantuomi.fi> | 2024-11-05 22:08:51 +0200 |
| commit | ae07cfa82a52abe007670dd52a418deaf5bf0efb (patch) | |
| tree | bf14226d6af2196b8593a97879e33a9429308706 /log_db/src/log_reader_forward.rs | |
| parent | 1086c414ebb6b8f30c3840ec73e3d48b0fd44339 (diff) | |
Rewrite compaction routine
Diffstat (limited to 'log_db/src/log_reader_forward.rs')
| -rw-r--r-- | log_db/src/log_reader_forward.rs | 9 |
1 files changed, 0 insertions, 9 deletions
diff --git a/log_db/src/log_reader_forward.rs b/log_db/src/log_reader_forward.rs index 1b34dfc..2d13f7a 100644 --- a/log_db/src/log_reader_forward.rs +++ b/log_db/src/log_reader_forward.rs @@ -31,26 +31,17 @@ impl<'a> ForwardLogReader { } } - debug!("Read 16 bytes from metadata file: {:?}", metadata_entry_buf); - // First u64 is the offset of the record in the data file, second is the length of the record let entry_offset = u64::from_be_bytes(metadata_entry_buf[0..8].try_into().unwrap()); let entry_length = u64::from_be_bytes(metadata_entry_buf[8..16].try_into().unwrap()); - debug!( - "Read offset {} and length {} from metadata file", - entry_offset, entry_length - ); - // Use .seek_relative instead of .seek to avoid dropping the BufReader internal buffer when // the seek distance is small let seek_distance = entry_offset - self.data_reader.stream_position()?; self.data_reader.seek_relative(seek_distance as i64)?; let mut result_buf = vec![0; entry_length as usize]; - debug!("Reading {} bytes from data file", entry_length); self.data_reader.read_exact(&mut result_buf)?; - debug!("Read {} bytes from data file", result_buf.len()); let record = Record::deserialize(&result_buf); Ok(Some(record)) |
