forks/go-ethereum
1
0
Fork 1
mirror of https://github.com/ethereum/go-ethereum.git synced 2026-08-14 07:53:47 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

fix: replace assert to require

Browse source
This commit is contained in:
thinkAfCod 2024-10-23 17:10:31 +08:00 committed by Chen Kai
parent b44ca3c190
commit a75e981c5b
2 changed files with 3 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
p2p/discover/portal_protocol.go
View file

@ -1860,11 +1860,13 @@ func (p *PortalProtocol) Gossip(srcNodeId *enode.ID, contentKeys [][]byte, conte
maxClosestNodes := 4 maxClosestNodes := 4
maxFartherNodes := 4 maxFartherNodes := 4
closestLocalNodes := p.findNodesCloseToContent(contentId, 32) closestLocalNodes := p.findNodesCloseToContent(contentId, 32)
p.Log.Debug("closest local nodes", "count", len(closestLocalNodes))
gossipNodes := make([]*enode.Node, 0) gossipNodes := make([]*enode.Node, 0)
for _, n := range closestLocalNodes { for _, n := range closestLocalNodes {
radius, found := p.radiusCache.HasGet(nil, []byte(n.ID().String())) radius, found := p.radiusCache.HasGet(nil, []byte(n.ID().String()))
if found { if found {
p.Log.Debug("found closest local nodes", "nodeId", n.ID(), "addr", n.IPAddr().String())
nodeRadius := new(uint256.Int) nodeRadius := new(uint256.Int)
err := nodeRadius.UnmarshalSSZ(radius) err := nodeRadius.UnmarshalSSZ(radius)
if err != nil { if err != nil {

2
p2p/discover/portal_protocol_test.go
View file

@ -21,7 +21,7 @@ import (
"github.com/ethereum/go-ethereum/log" "github.com/ethereum/go-ethereum/log"
"github.com/ethereum/go-ethereum/p2p/discover/portalwire" "github.com/ethereum/go-ethereum/p2p/discover/portalwire"
"github.com/ethereum/go-ethereum/p2p/enode" "github.com/ethereum/go-ethereum/p2p/enode"
"github.com/stretchr/testify/assert" assert "github.com/stretchr/testify/require"
) )
func setupLocalPortalNode(addr string, bootNodes []*enode.Node) (*PortalProtocol, error) { func setupLocalPortalNode(addr string, bootNodes []*enode.Node) (*PortalProtocol, error) {