les: fix distReq.sentChn double close bug (#17639)

d4a28a13 · Felföldi Zsolt · Felix Lange · 86a03f97 · d4a28a13
Commit d4a28a13 authored Sep 14, 2018 by Felföldi Zsolt Committed by Felix Lange Sep 14, 2018
Hide whitespace changes
Inline Side-by-side

Showing with 3 additions and 1 deletion

distributor.go les/distributor.go +3 -1

No files found.
--- 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()