Fix mutex lock

kylecarbs · kylecarbs · commit 3ca4a35e72bb · 2022-01-20T15:20:36.000Z
diff --git a/peer/channel.go b/peer/channel.go
@@ -105,12 +105,12 @@ func (c *Channel) init() {
 	// write operations to block once the threshold is set.
 	c.dc.SetBufferedAmountLowThreshold(bufferedAmountLowThreshold)
 	c.dc.OnBufferedAmountLow(func() {
-		c.closeMutex.Lock()
-		defer c.closeMutex.Unlock()
 		if c.isClosed() {
 			return
 		}
 		select {
+		case <-c.closed:
+			return
 		case c.sendMore <- struct{}{}:
 		default:
 		}
