coosld/ceremonyclient
1
0
Fork 0
mirror of https://github.com/QuilibriumNetwork/ceremonyclient.git synced 2026-02-21 10:27:26 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

a little more logic around connection management

Browse Source
This commit is contained in:
Cassandra Heart 2024-10-28 18:22:09 -05:00
parent 48a23448c4
commit ad55d280f8
No known key found for this signature in database
GPG Key ID: 6352152859385958
1 changed files with 21 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

36
node/p2p/blossomsub.go
View File

@ -316,8 +316,11 @@ func NewBlossomSub(
verifyReachability(p2pConfig)
discoverPeers(p2pConfig, ctx, logger, h, routingDiscovery, true)
<<<<<<< HEAD
go monitorPeers(ctx, logger, h)
=======
>>>>>>> 7eaf8e0 (a little more logic around connection management)
// TODO: turn into an option flag for console logging, this is too noisy for
// default logging behavior
@ -392,6 +395,7 @@ func NewBlossomSub(
for {
time.Sleep(30 * time.Second)
for _, b := range bs.bitmaskMap {
<<<<<<< HEAD
bitmaskPeers := b.ListPeers()
peerCount := len(bitmaskPeers)
for _, p := range bitmaskPeers {
@ -400,6 +404,9 @@ func NewBlossomSub(
}
}
if peerCount < 4 {
=======
if len(b.ListPeers()) < 4 {
>>>>>>> 7eaf8e0 (a little more logic around connection management)
discoverPeers(p2pConfig, bs.ctx, logger, bs.h, routingDiscovery, false)
break
}
@ -1060,21 +1067,20 @@ func discoverPeers(
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 {
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()),
)
}
}
}