Chris Lu 7d147f238c avoid repeated reading disk (#7369) ...

* avoid repeated reading disk

* checks both flush time AND read position advancement

* wait on cond

* fix reading

Gap detection and skipping to earliest memory time
Time-based reads that include events at boundary times for first reads (offset ≤ 0)
Aggregated subscriber wake-up via ListenersWaits signaling

* address comments

2025-10-24 01:26:42 -07:00

20 KiB

Raw Permalink Blame History

View Raw