databendlabs / openraft / 19954335022

88%

Build Type

push

github

Committed by drmingdrmer

Commit Message

refactor: use watch channel for communication between core and replication task

Replace unbounded MPSC channel with watch channel for broadcasting
committed log id to replication tasks. This simplifies the replication
event handling by using an EventWatcher that monitors both entries and
committed updates.

Changes:
- Add `EventWatcher` to receive events from entries and committed watch channels
- Rename `Replicate` to `Data` for log entries replication data
- Add `committed_tx`/`committed_rx` watch channel pair in `RaftCore`
- Use `send_if_greater()` for committed log id updates
- Remove per-replication MPSC sender in favor of shared watch channel

Run Details

55 of 55 new or added lines in 7 files covered. (100.0%)

23 existing lines in 5 files now uncovered.

14209 of 15332 relevant lines covered (92.68%)

153672.0 hits per line