From 59baa078492e977c4b4a0285c6902c403fd67210 Mon Sep 17 00:00:00 2001 From: Zsolt Felfoldi Date: Wed, 1 May 2019 20:17:17 +0200 Subject: [PATCH] les: added warning for reduced capacity --- les/server.go | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/les/server.go b/les/server.go index fa4b53a823..bffc3c7430 100644 --- a/les/server.go +++ b/les/server.go @@ -202,6 +202,7 @@ func (s *LesServer) startEventLoop() { totalCapacity := s.fcManager.SubscribeTotalCapacity(totalCapacityCh) s.priorityClientPool.setLimits(s.maxPeers, totalCapacity) + var maxFreePeers uint64 go func() { for { select { @@ -211,6 +212,11 @@ func (s *LesServer) startEventLoop() { updateRecharge() case totalCapacity = <-totalCapacityCh: s.logTotalCap.Update(float64(totalCapacity)) + newFreePeers := totalCapacity / s.freeClientCap + if newFreePeers < maxFreePeers && newFreePeers < uint64(s.maxPeers) { + log.Warn("Reduced total capacity", "maxFreePeers", newFreePeers) + } + maxFreePeers = newFreePeers s.priorityClientPool.setLimits(s.maxPeers, totalCapacity) case <-s.protocolManager.quitSync: s.protocolManager.wg.Done()