fix: unlock mutex on error in chainsync client (#795)

agaffney · web-flow · commit bf6d8d758f53 · 2024-11-19T18:24:39.000-06:00
diff --git a/protocol/chainsync/client.go b/protocol/chainsync/client.go
@@ -447,6 +447,7 @@ func (c *Client) syncLoop() {
 		msg := NewMsgRequestNext()
 		if err := c.SendMessage(msg); err != nil {
 			c.SendError(err)
+			c.busyMutex.Unlock()
 			return
 		}
 		c.busyMutex.Unlock()

Original file line number	Diff line number	Diff line change
`@@ -447,6 +447,7 @@ func (c *Client) syncLoop() {`
`447`	`447`	`msg := NewMsgRequestNext()`
`448`	`448`	`if err := c.SendMessage(msg); err != nil {`
`449`	`449`	`c.SendError(err)`
	`450`	`+ c.busyMutex.Unlock()`
`450`	`451`	`return`
`451`	`452`	`}`
`452`	`453`	`c.busyMutex.Unlock()`