Lock on bufferred amount low

kylecarbs · kylecarbs · commit f6b76a6e5fa1 · 2022-01-20T15:13:07.000Z
diff --git a/peer/channel.go b/peer/channel.go
@@ -105,6 +105,8 @@ 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
 		}

Original file line number	Diff line number	Diff line change
`@@ -105,6 +105,8 @@ func (c *Channel) init() {`
`105`	`105`	`// write operations to block once the threshold is set.`
`106`	`106`	`c.dc.SetBufferedAmountLowThreshold(bufferedAmountLowThreshold)`
`107`	`107`	`c.dc.OnBufferedAmountLow(func() {`
	`108`	`+ c.closeMutex.Lock()`
	`109`	`+ defer c.closeMutex.Unlock()`
`108`	`110`	`if c.isClosed() {`
`109`	`111`	`return`
`110`	`112`	`}`