From be4fb5757ab219961224119c4cd7d16c7df163d2 Mon Sep 17 00:00:00 2001 From: Zsolt Felfoldi Date: Mon, 25 Nov 2019 11:39:41 +0100 Subject: [PATCH] les: fixed nexClientPool balance iterator --- les/clientpool.go | 4 +++- les/server.go | 5 +++-- 2 files changed, 6 insertions(+), 3 deletions(-) diff --git a/les/clientpool.go b/les/clientpool.go index a5eb0e8a95..390ba36315 100644 --- a/les/clientpool.go +++ b/les/clientpool.go @@ -187,8 +187,10 @@ func newClientPool(db ethdb.Database, minCap, freeClientCap uint64, clock mclock var stop bool l := len(ids) if l == 1000 { - stop = true l-- + start = ids[l] + } else { + stop = true } for i := 0; i < l; i++ { pool.disconnectedBalances += pool.ndb.getOrNewPB(ids[i]).value diff --git a/les/server.go b/les/server.go index eadd9b94d8..636bedd922 100644 --- a/les/server.go +++ b/les/server.go @@ -176,7 +176,7 @@ func (s *LesServer) Start(srvr *p2p.Server) { go s.capacityManagement() if srvr.DiscV5 != nil { - srvr.DiscV5.RegisterTalkHandler("les", s.handler.talkRequestHandler) + srvr.DiscV5.RegisterTalkHandler("lespay", s.handler.talkRequestHandler) for _, topic := range s.lesTopics { topic := topic go func() { @@ -195,8 +195,9 @@ func (s *LesServer) Stop() { close(s.closeCh) if s.srvr.DiscV5 != nil { - s.srvr.DiscV5.RemoveTalkHandler("les") + s.srvr.DiscV5.RemoveTalkHandler("lespay") } + s.tokenSale.stop() // Disconnect existing sessions. // This also closes the gate for any new registrations on the peer set.