forks/go-ethereum
1
0
Fork 1
mirror of https://github.com/ethereum/go-ethereum.git synced 2026-07-19 03:10:48 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

eth/connman: fixup log levels

Browse source
This commit is contained in:
Csaba Kiraly 2025-03-25 22:25:32 +01:00
parent c41569d62a
commit 61b26a93c5
1 changed files with 3 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
eth/connmanager.go
View file

@ -139,7 +139,7 @@ func (cm *connManager) dropRandomPeer() bool {
droppable := slices.DeleteFunc(peers, selectDoNotDrop) droppable := slices.DeleteFunc(peers, selectDoNotDrop)
if len(droppable) > 0 { if len(droppable) > 0 {
p := droppable[cm.rand.Intn(len(droppable))] p := droppable[cm.rand.Intn(len(droppable))]
cm.log.Info("dropping random peer", "id", p.ID(), "duration", common.PrettyDuration(p.Lifetime()), "peercountbefore", len(peers)) cm.log.Debug("dropping random peer", "id", p.ID(), "duration", common.PrettyDuration(p.Lifetime()), "peercountbefore", len(peers))
p.Disconnect(p2p.DiscTooManyPeers) p.Disconnect(p2p.DiscTooManyPeers)
return true return true
} }
@ -158,7 +158,7 @@ func (cm *connManager) loop() {
// check and start timer for peer drop // check and start timer for peer drop
// If a drop was already scheduled, Schedule does nothing. // If a drop was already scheduled, Schedule does nothing.
numpeers, out, in := cm.numPeers() numpeers, out, in := cm.numPeers()
cm.log.Info("addPeerCh", "peers", numpeers, "out", out, "in", in, "maxout", cm.maxDialPeers) cm.log.Trace("addPeerCh", "peers", numpeers, "out", out, "in", in, "maxout", cm.maxDialPeers)
if cm.maxDialPeers-cm.numDialPeers() <= peerDropThreshold { if cm.maxDialPeers-cm.numDialPeers() <= peerDropThreshold {
cm.peerDropTimer.Schedule(cm.clock.Now().Add(peerDropInterval)) cm.peerDropTimer.Schedule(cm.clock.Now().Add(peerDropInterval))
} }
@ -166,7 +166,7 @@ func (cm *connManager) loop() {
case p2p.PeerEventTypeDrop: case p2p.PeerEventTypeDrop:
// check and stop timer for peer drop // check and stop timer for peer drop
numpeers, out, in := cm.numPeers() numpeers, out, in := cm.numPeers()
cm.log.Info("remPeerCh", "peers", numpeers, "out", out, "in", in, "maxout", cm.maxDialPeers) cm.log.Trace("remPeerCh", "peers", numpeers, "out", out, "in", in, "maxout", cm.maxDialPeers)
if cm.maxDialPeers-cm.numDialPeers() > peerDropThreshold { if cm.maxDialPeers-cm.numDialPeers() > peerDropThreshold {
cm.peerDropTimer.Stop() cm.peerDropTimer.Stop()
} }