databendlabs / openraft / 18915819467

88%

Build Type

push

github

Committed by xp-trumpet

Commit Message

change: migrate API and notification channels to bounded channels

Migrated both API and notification channels from unbounded to bounded with
configurable sizes to provide backpressure control and prevent unbounded
memory growth.

Changes:
- Added `api_channel_size` config (default: 65536)
- Added `notification_channel_size` config (default: 65536)
- Changed `RaftCore` to use bounded MPSC channels for both API and notifications
- Made `external_request()` and `external_state_machine_request()` async and return `Result`
- Made `IOFlushed::io_completed()` async to support bounded channel send
- Use `.ok()` instead of `let _ =` to explicitly ignore send errors

Upgrade tip:

- `external_request()` now returns `Result<(), Fatal<C>>`. Change:
  `raft.external_request(|state| { ... }).await;`
  to:
  `raft.external_request(|state| { ... }).await?;`

- `external_state_machine_request()` now returns `Result<(), Fatal<C>>`. Change:
  `raft.external_state_machine_request(|sm| { ... }).await;`
  to:
  `raft.external_state_machine_request(|sm| { ... }).await?;`

- `IOFlushed::io_completed()` is now async. Change:
  `callback.io_completed(result);`
  to:
  `callback.io_completed(result).await;`

Run Details

136 of 152 new or added lines in 13 files covered. (89.47%)

10 existing lines in 4 files now uncovered.

12313 of 13465 relevant lines covered (91.44%)

137138.27 hits per line