unistack-org/micro
4
0
Fork 3
Code Issues 19 Pull Requests 1 Actions Packages Projects Releases 266 Wiki Activity

Updated debug logs to make them less verbose

Browse Source
This commit is contained in:
Milos Gajdos 2020-01-17 12:14:56 +00:00
parent bac1bbfd97
commit 607a226e34
No known key found for this signature in database
GPG Key ID: 8B31058CC55DFD4F
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
network/default.go
View File

@ -1190,6 +1190,7 @@ func (n *network) manage() {
links[peer.link] = time.Now() links[peer.link] = time.Now()
} }
case <-prune.C: case <-prune.C:
log.Debugf("Network node %s pruning stale peers", n.id)
pruned := n.PruneStalePeers(PruneTime) pruned := n.PruneStalePeers(PruneTime)
for id, peer := range pruned { for id, peer := range pruned {
@ -1332,12 +1333,11 @@ func (n *network) sendTo(method, channel string, peer *node, msg proto.Message)
c, err := n.tunnel.Dial(channel, tunnel.DialWait(false), tunnel.DialLink(peer.link)) c, err := n.tunnel.Dial(channel, tunnel.DialWait(false), tunnel.DialLink(peer.link))
if err != nil { if err != nil {
if peerNode := n.GetPeerNode(peer.id); peerNode != nil { if peerNode := n.GetPeerNode(peer.id); peerNode != nil {
log.Debugf("Network found peer %s: %v", peer.id, peerNode)
// update node status when error happens // update node status when error happens
peerNode.status.err.Update(err) peerNode.status.err.Update(err)
log.Debugf("Network increment node peer %p %v count to: %d", peerNode, peerNode, peerNode.status.Error().Count()) log.Debugf("Network increment peer %v error count to: %d", peerNode, peerNode, peerNode.status.Error().Count())
if count := peerNode.status.Error().Count(); count == MaxPeerErrors { if count := peerNode.status.Error().Count(); count == MaxPeerErrors {
log.Debugf("Network node peer %v count exceeded %d: %d", peerNode, MaxPeerErrors, peerNode.status.Error().Count()) log.Debugf("Network peer %v error count exceeded %d. Prunning.", peerNode, MaxPeerErrors)
n.PrunePeer(peerNode.id) n.PrunePeer(peerNode.id)
} }
} }