github/prysm
1
1
Fork 0
mirror of https://github.com/OffchainLabs/prysm.git synced 2026-01-09 15:37:56 -05:00
Code Issues Packages Projects Releases Wiki Activity

remove pointer

Browse Source
This commit is contained in:
aarshkshah1992
2025-12-15 11:16:26 +04:00
parent e62fe66b0a
commit d2bf512f36
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
beacon-chain/p2p/gossip_peer_crawler.go
View File

@@ -209,7 +209,7 @@ func (cp *crawledPeers) updateTopicsUnlocked(pnode *peerNode, topics []string) {
pnode.topics = newTopics
}
func (cp *crawledPeers) getPeersForTopic(topic string, filter gossipcrawler.PeerFilterFunc) []*peerNode {
func (cp *crawledPeers) getPeersForTopic(topic string, filter gossipcrawler.PeerFilterFunc) []peerNode {
cp.mu.RLock()
defer cp.mu.RUnlock()
@@ -218,7 +218,7 @@ func (cp *crawledPeers) getPeersForTopic(topic string, filter gossipcrawler.Peer
return nil
}
var peerNodes []*peerNode
var peerNodes []peerNode
seen := make(map[enode.ID]bool)
for pnode := range peers {
if pnode.node == nil {
@@ -230,7 +230,7 @@ func (cp *crawledPeers) getPeersForTopic(topic string, filter gossipcrawler.Peer
continue
}
seen[pnode.node.ID()] = true
peerNodes = append(peerNodes, pnode)
peerNodes = append(peerNodes, *pnode)
}
}
return peerNodes
@@ -346,7 +346,7 @@ func NewGossipPeerCrawler(
func (g *GossipPeerCrawler) PeersForTopic(topic string) []*enode.Node {
peerNodes := g.crawledPeers.getPeersForTopic(topic, g.peerFilter)
slices.SortFunc(peerNodes, func(a, b *peerNode) int {
slices.SortFunc(peerNodes, func(a, b peerNode) int {
scoreA := g.scorer(a.peerID)
scoreB := g.scorer(b.peerID)
if scoreA > scoreB {