fluencelabs/go-libp2p-kad-dht
1
0
Fork 0
mirror of https://github.com/fluencelabs/go-libp2p-kad-dht synced 2025-07-31 20:12:00 +00:00
Code Issues Projects Releases Wiki Activity

fix a race in dial queue.

Browse Source
This commit is contained in:
Raúl Kripalani
2019-02-01 19:20:32 +00:00
parent ebcfcd46a6
commit 94682b4df2
1 changed files with 5 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
dial_queue.go
View File

@@ -208,9 +208,11 @@ func (dq *dialQueue) Consume() <-chan peer.ID {
ch := make(chan peer.ID, 1)
select {
case p := <-dq.out.DeqChan:
// short circuit and return a dialled peer if it's immediately available.
ch <- p
case p, ok := <-dq.out.DeqChan:
// short circuit and return a dialled peer if it's immediately available, or abort if DeqChan is closed.
if ok {
ch <- p
}
close(ch)
return ch
case <-dq.ctx.Done():