aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
-rw-r--r--les/distributor.go4
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()