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

fix:fix delete no lock

Browse source 
Signed-off-by: Chen Kai <281165273grape@gmail.com>
This commit is contained in:
Chen Kai 2024-06-18 08:28:24 +08:00
parent 6a01b9bd0b
commit 13e8f62b34
1 changed files with 0 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
p2p/discover/portal_protocol.go
View file

@ -433,7 +433,6 @@ func (p *PortalProtocol) pingInner(node *enode.Node) (*portalwire.Pong, error) {
talkResp, err := p.DiscV5.TalkRequest(node, p.protocolId, talkRequestBytes) talkResp, err := p.DiscV5.TalkRequest(node, p.protocolId, talkRequestBytes)
if err != nil { if err != nil {
p.deleteNode(node)
return nil, err return nil, err
} }
@ -787,7 +786,6 @@ func (p *PortalProtocol) processPong(target *enode.Node, resp []byte) (*portalwi
pong := &portalwire.Pong{} pong := &portalwire.Pong{}
err := pong.UnmarshalSSZ(resp[1:]) err := pong.UnmarshalSSZ(resp[1:])
if err != nil { if err != nil {
p.deleteNode(target)
return nil, err return nil, err
} }
@ -796,7 +794,6 @@ func (p *PortalProtocol) processPong(target *enode.Node, resp []byte) (*portalwi
customPayload := &portalwire.PingPongCustomData{} customPayload := &portalwire.PingPongCustomData{}
err = customPayload.UnmarshalSSZ(pong.CustomPayload) err = customPayload.UnmarshalSSZ(pong.CustomPayload)
if err != nil { if err != nil {
p.deleteNode(target)
return nil, err return nil, err
} }
@ -807,11 +804,6 @@ func (p *PortalProtocol) processPong(target *enode.Node, resp []byte) (*portalwi
return pong, nil return pong, nil
} }
func (p *PortalProtocol) deleteNode(target *enode.Node) {
b := p.table.bucket(target.ID())
p.table.deleteInBucket(b, target.ID())
}
func (p *PortalProtocol) handleUtpTalkRequest(id enode.ID, addr *net.UDPAddr, msg []byte) []byte { func (p *PortalProtocol) handleUtpTalkRequest(id enode.ID, addr *net.UDPAddr, msg []byte) []byte {
if n := p.DiscV5.getNode(id); n != nil { if n := p.DiscV5.getNode(id); n != nil {
p.table.addInboundNode(n) p.table.addInboundNode(n)