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

fix: dnsaddr -> dns4 for blossomsub

Browse Source
This commit is contained in:
Cassandra Heart 2026-02-24 06:35:23 -06:00
parent 72dfec697b
commit 7452df071a
No known key found for this signature in database
GPG Key ID: 371083BFA6C240AA
1 changed files with 22 additions and 22 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

44
node/p2p/blossomsub.go
View File

@ -90,18 +90,18 @@ type BlossomSub struct {
// with open subscriptions).
subscriptionsByBitmask map[string][]*blossomsub.Subscription
subscriptionMutex sync.RWMutex
h host.Host
signKey crypto.PrivKey
peerScore map[string]*appScore
peerScoreMx sync.Mutex
bootstrap internal.PeerConnector
discovery internal.PeerConnector
manualReachability atomic.Pointer[bool]
p2pConfig config.P2PConfig
dht *dht.IpfsDHT
routingDiscovery *routing.RoutingDiscovery
coreId uint
configDir ConfigDir
h host.Host
signKey crypto.PrivKey
peerScore map[string]*appScore
peerScoreMx sync.Mutex
bootstrap internal.PeerConnector
discovery internal.PeerConnector
manualReachability atomic.Pointer[bool]
p2pConfig config.P2PConfig
dht *dht.IpfsDHT
routingDiscovery *routing.RoutingDiscovery
coreId uint
configDir ConfigDir
}
var _ p2p.PubSub = (*BlossomSub)(nil)
@ -155,10 +155,10 @@ func NewBlossomSubWithHost(
}
bs := &BlossomSub{
ctx: ctx,
cancel: cancel,
logger: logger,
bitmaskMap: make(map[string]*blossomsub.Bitmask),
ctx: ctx,
cancel: cancel,
logger: logger,
bitmaskMap: make(map[string]*blossomsub.Bitmask),
subscriptionTracker: make(map[string][][]byte),
subscriptionsByBitmask: make(map[string][]*blossomsub.Subscription),
signKey: privKey,
@ -539,10 +539,10 @@ func NewBlossomSub(
ctx, cancel := context.WithCancel(ctx)
bs := &BlossomSub{
ctx: ctx,
cancel: cancel,
logger: logger,
bitmaskMap: make(map[string]*blossomsub.Bitmask),
ctx: ctx,
cancel: cancel,
logger: logger,
bitmaskMap: make(map[string]*blossomsub.Bitmask),
subscriptionTracker: make(map[string][][]byte),
subscriptionsByBitmask: make(map[string][]*blossomsub.Subscription),
signKey: privKey,
@ -1388,7 +1388,7 @@ func (b *BlossomSub) runConnectivityTest(
if info.ID == b.h.ID() {
continue
}
if strings.Contains(info.Addrs[0].String(), "dnsaddr") {
if strings.Contains(info.Addrs[0].String(), "dns4") {
candidates = append(candidates, info)
}
}
@ -1416,7 +1416,7 @@ func (b *BlossomSub) invokeConnectivityTest(
if err != nil {
host, err = addr.ValueForProtocol(ma.P_IP6)
if err != nil {
host, err = addr.ValueForProtocol(ma.P_DNSADDR)
host, err = addr.ValueForProtocol(ma.P_DNS4)
if err != nil {
continue
}