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

les: fixed clientPool.setLimits

Browse source
This commit is contained in:
Zsolt Felfoldi 2019-09-14 03:28:59 +02:00
parent 0cbf1d89af
commit a094623a10
1 changed files with 8 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
les/clientpool.go
View file

@ -366,6 +366,7 @@ func (f *clientPool) setLimits(count int, totalCap uint64) {
f.countLimit = count f.countLimit = count
f.capacityLimit = totalCap f.capacityLimit = totalCap
if f.connectedCapacity > f.capacityLimit || f.connectedQueue.Size() > f.countLimit {
now := mclock.Now() now := mclock.Now()
f.connectedQueue.MultiPop(func(data interface{}, priority int64) bool { f.connectedQueue.MultiPop(func(data interface{}, priority int64) bool {
c := data.(*clientInfo) c := data.(*clientInfo)
@ -373,6 +374,7 @@ func (f *clientPool) setLimits(count int, totalCap uint64) {
return f.connectedCapacity > f.capacityLimit || f.connectedQueue.Size() > f.countLimit return f.connectedCapacity > f.capacityLimit || f.connectedQueue.Size() > f.countLimit
}) })
} }
}
// requestCost feeds request cost after serving a request from the given peer. // requestCost feeds request cost after serving a request from the given peer.
func (f *clientPool) requestCost(p *peer, cost uint64) { func (f *clientPool) requestCost(p *peer, cost uint64) {