Commit ccdf8043 authored by Petar Radovic's avatar Petar Radovic Committed by GitHub

error -> trace in connect calls (#363)

parent 89e665e3
...@@ -150,7 +150,7 @@ func (k *Kad) manage() { ...@@ -150,7 +150,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: %v", bzzAddr.String(), 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.Warningf("connecting to peer %s: %v", bzzAddr.ShortString(), err)
// continue to next // continue to next
return false, false, nil return false, false, nil
} }
......
...@@ -381,7 +381,7 @@ func NewBee(o Options) (*Bee, error) { ...@@ -381,7 +381,7 @@ func NewBee(o Options) (*Bee, error) {
defer wg.Done() defer wg.Done()
if err := topologyDriver.AddPeer(p2pCtx, overlay); err != nil { if err := topologyDriver.AddPeer(p2pCtx, overlay); err != nil {
logger.Debugf("topology add peer fail %s: %v", overlay, err) logger.Debugf("topology add peer fail %s: %v", overlay, err)
logger.Errorf("topology add peer %s", overlay) logger.Warningf("topology add peer %s", overlay)
return return
} }
...@@ -400,7 +400,7 @@ func NewBee(o Options) (*Bee, error) { ...@@ -400,7 +400,7 @@ func NewBee(o Options) (*Bee, error) {
addr, err := ma.NewMultiaddr(a) addr, err := ma.NewMultiaddr(a)
if err != nil { if err != nil {
logger.Debugf("multiaddress fail %s: %v", a, err) logger.Debugf("multiaddress fail %s: %v", a, err)
logger.Errorf("connect to bootnode %s", a) logger.Warningf("connect to bootnode %s", a)
return return
} }
var count int var count int
...@@ -410,7 +410,7 @@ func NewBee(o Options) (*Bee, error) { ...@@ -410,7 +410,7 @@ func NewBee(o Options) (*Bee, error) {
if err != nil { if err != nil {
if !errors.Is(err, p2p.ErrAlreadyConnected) { if !errors.Is(err, p2p.ErrAlreadyConnected) {
logger.Debugf("connect fail %s: %v", addr, err) logger.Debugf("connect fail %s: %v", addr, err)
logger.Errorf("connect to bootnode %s", addr) logger.Warningf("connect to bootnode %s", addr)
} }
return false, nil return false, nil
} }
...@@ -420,14 +420,14 @@ func NewBee(o Options) (*Bee, error) { ...@@ -420,14 +420,14 @@ func NewBee(o Options) (*Bee, error) {
if err != nil { if err != nil {
_ = p2ps.Disconnect(bzzAddr.Overlay) _ = p2ps.Disconnect(bzzAddr.Overlay)
logger.Debugf("addressbook error persisting %s %s: %v", addr, bzzAddr.Overlay, err) logger.Debugf("addressbook error persisting %s %s: %v", addr, bzzAddr.Overlay, err)
logger.Errorf("connect to bootnode %s", addr) logger.Warningf("connect to bootnode %s", addr)
return false, nil return false, nil
} }
if err := topologyDriver.Connected(p2pCtx, bzzAddr.Overlay); err != nil { if err := topologyDriver.Connected(p2pCtx, bzzAddr.Overlay); err != nil {
_ = p2ps.Disconnect(bzzAddr.Overlay) _ = p2ps.Disconnect(bzzAddr.Overlay)
logger.Debugf("topology connected fail %s %s: %v", addr, bzzAddr.Overlay, err) logger.Debugf("topology connected fail %s %s: %v", addr, bzzAddr.Overlay, err)
logger.Errorf("connect to bootnode %s", addr) logger.Warningf("connect to bootnode %s", addr)
return false, nil return false, nil
} }
count++ count++
...@@ -435,7 +435,7 @@ func NewBee(o Options) (*Bee, error) { ...@@ -435,7 +435,7 @@ func NewBee(o Options) (*Bee, error) {
return count > 3, nil return count > 3, nil
}); err != nil { }); err != nil {
logger.Debugf("discover fail %s: %v", a, err) logger.Debugf("discover fail %s: %v", a, err)
logger.Errorf("discover to bootnode %s", a) logger.Warningf("discover to bootnode %s", a)
return return
} }
}(a) }(a)
......
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