Skip to content

Commit 6bbf708

Browse files
authored
Merge branch 'master' into containedctx
2 parents afc0e8d + 9293016 commit 6bbf708

File tree

2 files changed

+7
-1
lines changed

2 files changed

+7
-1
lines changed

CHANGELOG.md

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,5 @@
11
* Refactored internals for enabling `containedctx` linter
2+
* Fixed the hanging semaphore issue on coordination session reconnect
23

34
## v3.65.3
45
* Fixed data race in `internal/conn.grpcClientStream`

internal/coordination/conversation/conversation.go

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -424,7 +424,12 @@ func (c *Controller) OnAttach() {
424424
delete(c.conflicts, req.conflictKey)
425425
}
426426

427-
req.requestSent = nil
427+
// If the request has been canceled, re-send the cancellation message, otherwise re-send the original one.
428+
if req.canceled {
429+
req.cancelRequestSent = nil
430+
} else {
431+
req.requestSent = nil
432+
}
428433
notify = true
429434
}
430435
}

0 commit comments

Comments
 (0)