fix: break out of sync loop on shutdown

Fixes #220
blinklabs-io · Apr 3, 2023 · 0bf8687 · 0bf8687
1 parent a5e649b
commit 0bf8687
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/protocol/chainsync/client.go b/protocol/chainsync/client.go
@@ -146,7 +146,10 @@ func (c *Client) Sync(intersectPoints []common.Point) error {
 func (c *Client) syncLoop() {
 	for {
 		// Wait for a block to be received
-		<-c.readyForNextBlockChan
+		if _, ok := <-c.readyForNextBlockChan; !ok {
+			// Channel is closed, which means we're shutting down
+			return
+		}
 		c.busyMutex.Lock()
 		// Request the next block
 		// In practice we already have multiple block requests pipelined