objective categorical abstract machine language personal data server
Fix sequencer missing old messages
+8
-3
+8
-3
pegasus/lib/sequencer.ml
+8
-3
pegasus/lib/sequencer.ml
···
600
600
(* try backfill from buffer first *)
601
601
let ring = Bus.ring_after cursor in
602
602
let ring_covers =
603
-
match List.rev ring with
603
+
match ring with
604
604
| [] ->
605
605
false
606
-
| last :: _ ->
607
-
last.seq >= cutoff
606
+
| first :: _ -> (
607
+
match List.rev ring with
608
+
| [] ->
609
+
false
610
+
| last :: _ ->
611
+
(* ring covers if it goes from <= cursor all the way to >= cutoff *)
612
+
first.seq <= cursor && last.seq >= cutoff )
608
613
in
609
614
( if ring_covers then
610
615
Lwt_list.iter_s (fun (it : Bus.item) -> send it.bytes) ring