Skip to content

Commit 397eb4d

Browse files
committed
add CommitLog::next_offset
Signed-off-by: Abhik Jain <[email protected]>
1 parent 23a9a68 commit 397eb4d

File tree

1 file changed

+9
-0
lines changed

1 file changed

+9
-0
lines changed

src/lib.rs

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -87,6 +87,15 @@ impl CommitLog {
8787
})
8888
}
8989

90+
#[inline]
91+
pub fn next_offset(&self) -> (u64, u64) {
92+
if self.active_segment.len() >= self.max_segment_size {
93+
(self.tail + 1, 0)
94+
} else {
95+
(self.tail, self.active_segment.len())
96+
}
97+
}
98+
9099
/// Get the number of segment on the disk.
91100
#[inline]
92101
pub fn disk_len(&self) -> io::Result<u64> {

0 commit comments

Comments
 (0)