Commitlog stream range fix. (#2721)

Author: Shubham8287

crates/commitlog/src/stream/common.rs

@@ -92,15 +92,15 @@ impl RangeFromMaybeToInclusive {
         };
         let end = match b.end_bound() {
             Bound::Unbounded => None,
-            Bound::Included(end) => Some((*end).max(start)),
-            Bound::Excluded(end) => Some(end.saturating_sub(1).max(start)),
+            Bound::Included(end) => Some(*end),
+            Bound::Excluded(end) => Some(end.saturating_sub(1)),
         };
 
         Self { start, end }
     }
 
     pub fn is_empty(&self) -> bool {
-        self.end.is_some_and(|end| end <= self.start)
+        self.end.is_some_and(|end| end < self.start)
     }
 
     pub fn contains(&self, item: &u64) -> bool {

crates/commitlog/src/stream/reader.rs

@@ -157,6 +157,14 @@ mod tests {
         super::retain_range(offsets, RangeFromMaybeToInclusive::from_range_bounds(range))
     }
 
+    #[test]
+    fn test_slice_segments_on_single_commit() {
+        let offsets = vec![0, 10];
+
+        let retained = retain_range(&offsets, 19..=19);
+        assert_eq!(&retained, &[10]);
+    }
+
     #[test]
     fn test_slice_segments_on_boundary() {
         let offsets = vec![0, 10, 20, 30];