databendlabs / openraft / 20413023863

88%

Build Type

push

github

Committed by drmingdrmer

Commit Message

refactor: add `BatchRaftMsgReceiver` to batch consecutive client writes

Introduce a receiver wrapper that merges consecutive `RaftMsg::ClientWrite`
messages with the same `expected_leader` into a single batched message.
This reduces per-message overhead and improves write throughput.

Changes:
- Add `BatchRaftMsgReceiver` that buffers and merges up to 4096 consecutive client writes
- Update `RaftCore` to use `BatchRaftMsgReceiver` instead of raw mpsc receiver
- Refactor main loop to use `ensure_buffered()` + `try_recv()` pattern for message processing

Run Details

77 of 91 new or added lines in 2 files covered. (84.62%)

15 existing lines in 4 files now uncovered.

15719 of 17085 relevant lines covered (92.0%)

160749.09 hits per line