databendlabs / openraft / 28315527545

push

github

fix: avoid blocking RaftCore on closed replication

# Summary

Removed replication tasks are now signaled and joined asynchronously, so
a hung follower RPC cannot stop RaftCore from processing membership
changes or new writes.

# Details

Replication progress notifications now carry the stream id at the
notification level. RaftCore forwards that id to the replication
handler, which ignores stale progress from detached tasks after a stream
has been replaced.

The replication response loop now also watches the close signal while
waiting for responses, allowing cooperative shutdown when the transport
future is still polling.

- Fix: #1810

40 of 41 new or added lines in 6 files covered. (97.56%)

17042 of 19590 relevant lines covered (86.99%)

161502.28 hits per line