Skip to content

Commit

Permalink
Revert "broker: tear down a stale append pipeline before proxying"
Browse files Browse the repository at this point in the history
This reverts commit ad2a8c9.
  • Loading branch information
jgraettinger committed Jan 17, 2025
1 parent 9f78463 commit 41c8dbe
Showing 1 changed file with 1 addition and 5 deletions.
6 changes: 1 addition & 5 deletions broker/append_fsm.go
Original file line number Diff line number Diff line change
Expand Up @@ -154,11 +154,7 @@ func (b *appendFSM) onResolve() {
b.state = stateError
} else if b.resolved.ProcessId != b.resolved.localID {
// If we hold the pipeline from a previous resolution but are no longer
// primary, we must tear it down to release replica spools.
if b.pln != nil {
go b.pln.shutdown(false)
b.pln = nil
}
// primary, we must release it.
b.returnPipeline()
b.state = stateAwaitDesiredReplicas // We must proxy.
} else if b.plnReturnCh != nil {
Expand Down

0 comments on commit 41c8dbe

Please sign in to comment.