coosld/ceremonyclient
1
0
Fork 0
mirror of https://github.com/QuilibriumNetwork/ceremonyclient.git synced 2026-03-06 00:37:42 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

adjust blossomsub to background discovery

Browse Source
This commit is contained in:
Cassandra Heart 2024-10-27 01:51:00 -05:00
parent 448ee56b46
commit 6b6ca48fca
No known key found for this signature in database
GPG Key ID: 6352152859385958
1 changed files with 23 additions and 21 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

44
node/p2p/blossomsub.go
View File

@ -854,33 +854,35 @@ func discoverPeers(
return
}
count := 12
count := 36
for peer := range peerChan {
if count == 0 {
break
}
peer := peer
if peer.ID == h.ID() ||
h.Network().Connectedness(peer.ID) == network.Connected ||
h.Network().Connectedness(peer.ID) == network.Limited {
continue
}
count--
go func() {
if peer.ID == h.ID() ||
h.Network().Connectedness(peer.ID) == network.Connected ||
h.Network().Connectedness(peer.ID) == network.Limited {
return
}
logger.Debug("found peer", zap.String("peer_id", peer.ID.String()))
err := h.Connect(ctx, peer)
if err != nil {
logger.Debug(
"error while connecting to blossomsub peer",
zap.String("peer_id", peer.ID.String()),
zap.Error(err),
)
} else {
count--
logger.Debug(
"connected to peer",
zap.String("peer_id", peer.ID.String()),
)
}
logger.Debug("found peer", zap.String("peer_id", peer.ID.String()))
err := h.Connect(ctx, peer)
if err != nil {
logger.Debug(
"error while connecting to blossomsub peer",
zap.String("peer_id", peer.ID.String()),
zap.Error(err),
)
} else {
logger.Debug(
"connected to peer",
zap.String("peer_id", peer.ID.String()),
)
}
}()
}
}