Commit 75f893db authored by Janoš Guljaš's avatar Janoš Guljaš Committed by GitHub

handle already connected peer gracefully in kadmelia connect (#232)

parent a589147d
......@@ -237,6 +237,9 @@ func (k *Kad) recalcDepth() uint8 {
func (k *Kad) connect(ctx context.Context, peer swarm.Address, ma ma.Multiaddr, po uint8) error {
_, err := k.p2p.Connect(ctx, ma)
if err != nil {
if errors.Is(err, p2p.ErrAlreadyConnected) {
return nil
}
k.logger.Debugf("error connecting to peer %s: %v", peer, err)
k.waitNextMu.Lock()
k.waitNext[peer.String()] = time.Now().Add(timeToRetry)
......
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