chain: use mutex at stop

btcsuite · Dec 13, 2024 · 06b6f33 · 06b6f33
1 parent c492b75
commit 06b6f33
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/chain/bitcoind_conn.go b/chain/bitcoind_conn.go
@@ -238,7 +238,8 @@ func (c *BitcoindConn) Stop() {
 	if !atomic.CompareAndSwapInt32(&c.stopped, 0, 1) {
 		return
 	}
-
+	c.subscriptionsMtx.Lock()
+	defer c.subscriptionsMtx.Unlock()
 	for subscription := range c.subscriptions {
 		close(subscription.txNtfns)
 		close(subscription.blockNtfns)