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.rs4
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)?;