Skip to content

Commit 6f3693b

Browse files
committed
stop when reset
1 parent ec1ffee commit 6f3693b

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

pkg/transport/nclprotocol/dispatcher/recovery.go

+2
Original file line numberDiff line numberDiff line change
@@ -137,6 +137,8 @@ func (r *recovery) recoveryLoop(ctx context.Context, failures int) {
137137

138138
// reset resets the recovery state
139139
func (r *recovery) reset() {
140+
r.stop() // Stop any existing recovery first
141+
140142
r.mu.Lock()
141143
defer r.mu.Unlock()
142144
r.isRecovering = false

0 commit comments

Comments
 (0)