diff options
| author | Jan Tuomi <jan@jantuomi.fi> | 2024-11-21 18:49:12 +0200 |
|---|---|---|
| committer | Jan Tuomi <jan@jantuomi.fi> | 2024-11-21 18:49:12 +0200 |
| commit | 34730bbe58b77c7ee3d5e6344846a8a8e6595f17 (patch) | |
| tree | 5f1ee575dde374cffac59a4677fdf921f88b34b3 /log_db/src/log_reader_forward.rs | |
| parent | 1ee30efe415695e1b7d9b6390778a50e8168df04 (diff) | |
Refactor compact
Diffstat (limited to 'log_db/src/log_reader_forward.rs')
| -rw-r--r-- | log_db/src/log_reader_forward.rs | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/log_db/src/log_reader_forward.rs b/log_db/src/log_reader_forward.rs index 343d7ff..0e681b9 100644 --- a/log_db/src/log_reader_forward.rs +++ b/log_db/src/log_reader_forward.rs @@ -37,8 +37,8 @@ impl<'a> ForwardLogReader { // 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 seek_distance = entry_offset as i64 - self.data_reader.stream_position()? as i64; + self.data_reader.seek_relative(seek_distance)?; let mut result_buf = vec![0; entry_length as usize]; self.data_reader.read_exact(&mut result_buf)?; |
