aboutsummaryrefslogtreecommitdiffstats
path: root/log_db/src/log_reader_forward.rs
diff options
context:
space:
mode:
Diffstat (limited to 'log_db/src/log_reader_forward.rs')
-rw-r--r--log_db/src/log_reader_forward.rs9
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))