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

check bitmask for peers and keep alive

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

22
node/p2p/blossomsub.go
View File

@ -303,6 +303,17 @@ func NewBlossomSub(
bs.h = h
bs.signKey = privKey
go func() {
for {
time.Sleep(30 * time.Second)
for _, b := range bs.bitmaskMap {
if len(b.ListPeers()) < 4 {
discoverPeers(p2pConfig, bs.ctx, logger, bs.h, routingDiscovery)
}
}
}
}()
return bs
}
@ -874,16 +885,7 @@ func discoverPeers(
discover()
go func() {
for {
time.Sleep(5 * time.Second)
if len(h.Network().Peers()) < 6 {
discover()
}
}
}()
logger.Info("completed initial peer discovery")
logger.Info("completed peer discovery")
}
func mergeDefaults(p2pConfig *config.P2PConfig) blossomsub.BlossomSubParams {