diff --git a/go-libp2p/p2p/protocol/identify/obsaddr.go b/go-libp2p/p2p/protocol/identify/obsaddr.go index acc8b17..6bfbc15 100644 --- a/go-libp2p/p2p/protocol/identify/obsaddr.go +++ b/go-libp2p/p2p/protocol/identify/obsaddr.go @@ -19,7 +19,7 @@ import ( // can be contacted on. The "seen" events expire by default after 40 minutes // (OwnObservedAddressTTL * ActivationThreshold). The are cleaned up during // the GC rounds set by GCInterval. -var ActivationThresh = 4 +var ActivationThresh = 1 // observedAddrManagerWorkerChannelSize defines how many addresses can be enqueued // for adding to an ObservedAddrManager. diff --git a/node/p2p/blossomsub.go b/node/p2p/blossomsub.go index 0250830..71d520b 100644 --- a/node/p2p/blossomsub.go +++ b/node/p2p/blossomsub.go @@ -1046,6 +1046,10 @@ func discoverPeers( wg := &sync.WaitGroup{} defer wg.Wait() for peer := range peerChan { + if len(h.Network().Peers()) >= 6 { + break + } + peer := peer wg.Add(1) go func() {