diff options
| -rw-r--r-- | les/distributor.go | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/les/distributor.go b/les/distributor.go index d3f6b21d1..f90765b62 100644 --- a/les/distributor.go +++ b/les/distributor.go @@ -114,7 +114,9 @@ func (d *requestDistributor) loop() { d.lock.Lock() elem := d.reqQueue.Front() for elem != nil { - close(elem.Value.(*distReq).sentChn) + req := elem.Value.(*distReq) + close(req.sentChn) + req.sentChn = nil elem = elem.Next() } d.lock.Unlock() |