fix: Potential send on closed channel

mafredri · mafredri · commit 5b5dde93e97e · 2022-07-21T12:32:34.000+03:00
diff --git a/peer/channel.go b/peer/channel.go
@@ -106,6 +106,10 @@ func (c *Channel) init() {
 	// write operations to block once the threshold is set.
 	c.dc.SetBufferedAmountLowThreshold(bufferedAmountLowThreshold)
 	c.dc.OnBufferedAmountLow(func() {
+		// Grab the lock to protect the sendMore channel from being
+		// closed in between the isClosed check and the send.
+		c.closeMutex.Lock()
+		defer c.closeMutex.Unlock()
 		if c.isClosed() {
 			return
 		}
