bitswap: handle dialing to self

Author: hsanjuan

bitswap/network/ipfs_impl.go

@@ -359,6 +359,9 @@ func (bsnet *impl) Stop() {
 }
 
 func (bsnet *impl) Connect(ctx context.Context, p peer.AddrInfo) error {
+	if p.ID == bsnet.host.ID() {
+		return nil
+	}
 	return bsnet.host.Connect(ctx, p)
 }
 

routing/providerquerymanager/providerquerymanager.go

@@ -8,6 +8,7 @@ import (
 	"github.com/ipfs/go-cid"
 	logging "github.com/ipfs/go-log/v2"
 	peer "github.com/libp2p/go-libp2p/core/peer"
+	swarm "github.com/libp2p/go-libp2p/p2p/net/swarm"
 	"go.opentelemetry.io/otel"
 	"go.opentelemetry.io/otel/attribute"
 	"go.opentelemetry.io/otel/trace"
@@ -300,7 +301,7 @@ func (pqm *ProviderQueryManager) findProviderWorker() {
 					defer wg.Done()
 					span.AddEvent("FoundProvider", trace.WithAttributes(attribute.Stringer("peer", p.ID)))
 					err := pqm.dialer.Connect(findProviderCtx, p)
-					if err != nil {
+					if err != nil && err != swarm.ErrDialToSelf {
 						span.RecordError(err, trace.WithAttributes(attribute.Stringer("peer", p.ID)))
 						log.Debugf("failed to connect to provider %s: %s", p.ID, err)
 						return