diff options
| author | Felföldi Zsolt <zsfelfoldi@gmail.com> | 2018-09-15 04:14:29 +0800 |
|---|---|---|
| committer | Felix Lange <fjl@users.noreply.github.com> | 2018-09-15 04:14:29 +0800 |
| commit | d4a28a13ca4c36019d23da6342e7e55b1d406fb5 (patch) | |
| tree | 0e7bb5e89cbfb61cf34fbcae73fd13e5de57c4e5 /les | |
| parent | 86a03f97d30c11a5321fa2f0fd37cbc4c7f63a32 (diff) | |
| download | dexon-d4a28a13ca4c36019d23da6342e7e55b1d406fb5.tar dexon-d4a28a13ca4c36019d23da6342e7e55b1d406fb5.tar.gz dexon-d4a28a13ca4c36019d23da6342e7e55b1d406fb5.tar.bz2 dexon-d4a28a13ca4c36019d23da6342e7e55b1d406fb5.tar.lz dexon-d4a28a13ca4c36019d23da6342e7e55b1d406fb5.tar.xz dexon-d4a28a13ca4c36019d23da6342e7e55b1d406fb5.tar.zst dexon-d4a28a13ca4c36019d23da6342e7e55b1d406fb5.zip | |
les: fix distReq.sentChn double close bug (#17639)
Diffstat (limited to 'les')
| -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() |