forks/go-ethereum
1
0
Fork 1
mirror of https://github.com/ethereum/go-ethereum.git synced 2026-08-20 10:52:25 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

p2p/discover: wake from slowdown sleep when table is closed

Browse source
This commit is contained in:
Felix Lange 2019-11-26 10:06:24 +01:00
parent 88fe4b58f6
commit e277669ae1
1 changed files with 10 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

11
p2p/discover/lookup.go
View file

@ -111,7 +111,7 @@ func (it *lookup) startQueries() bool {
// for the table to fill in this case, but there is no good mechanism for that // for the table to fill in this case, but there is no good mechanism for that
// yet. // yet.
if len(closest.entries) == 0 { if len(closest.entries) == 0 {
time.Sleep(1 * time.Second) it.slowdown()
} }
it.queries = 1 it.queries = 1
it.replyCh <- closest.entries it.replyCh <- closest.entries
@ -131,6 +131,15 @@ func (it *lookup) startQueries() bool {
return it.queries > 0 return it.queries > 0
} }
func (it *lookup) slowdown() {
sleep := time.NewTimer(1 * time.Second)
defer sleep.Stop()
select {
case <-sleep.C:
case <-it.tab.closeReq:
}
}
func (it *lookup) query(n *node, reply chan<- []*node) { func (it *lookup) query(n *node, reply chan<- []*node) {
fails := it.tab.db.FindFails(n.ID(), n.IP()) fails := it.tab.db.FindFails(n.ID(), n.IP())
r, err := it.queryfunc(n) r, err := it.queryfunc(n)