Commit 5587d466 authored by Janoš Guljaš's avatar Janoš Guljaš Committed by GitHub

suppress p2p.ErrAlreadyConnected log when connecting to bootnodes (#318)

* suppress p2p.ErrAlreadyConnected log when connecting to bootnodes, adjust debug log in kademlia
parent a63b6022
...@@ -149,7 +149,7 @@ func (k *Kad) manage() { ...@@ -149,7 +149,7 @@ func (k *Kad) manage() {
err = k.connect(ctx, peer, bzzAddr.Underlay, po) err = k.connect(ctx, peer, bzzAddr.Underlay, po)
if err != nil { if err != nil {
k.logger.Debugf("error connecting to peer from kademlia %s %s: %v", peer, bzzAddr, err) k.logger.Debugf("error connecting to peer from kademlia %s: %v", bzzAddr.String(), err)
k.logger.Errorf("connecting to peer %s: %v", bzzAddr.ShortString(), err) k.logger.Errorf("connecting to peer %s: %v", bzzAddr.ShortString(), err)
// continue to next // continue to next
return false, false, nil return false, false, nil
......
...@@ -6,6 +6,7 @@ package node ...@@ -6,6 +6,7 @@ package node
import ( import (
"context" "context"
"errors"
"fmt" "fmt"
"io" "io"
"log" "log"
...@@ -378,8 +379,10 @@ func NewBee(o Options) (*Bee, error) { ...@@ -378,8 +379,10 @@ func NewBee(o Options) (*Bee, error) {
logger.Tracef("connecting to peer %s", addr) logger.Tracef("connecting to peer %s", addr)
bzzAddr, err := p2ps.Connect(p2pCtx, addr) bzzAddr, err := p2ps.Connect(p2pCtx, addr)
if err != nil { if err != nil {
logger.Debugf("connect fail %s: %v", addr, err) if !errors.Is(err, p2p.ErrAlreadyConnected) {
logger.Errorf("connect to bootnode %s", addr) logger.Debugf("connect fail %s: %v", addr, err)
logger.Errorf("connect to bootnode %s", addr)
}
return false, nil return false, nil
} }
logger.Tracef("connected to peer %s", addr) logger.Tracef("connected to peer %s", addr)
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment