From 35b964fc16122f36da645e335a6d9b3bbf8966ce Mon Sep 17 00:00:00 2001 From: Liam Date: Tue, 21 Jun 2022 00:11:06 +0200 Subject: [PATCH] revert change peer address change (#101) --- eth/handler.go | 10 ---------- 1 file changed, 10 deletions(-) diff --git a/eth/handler.go b/eth/handler.go index 33d59356f8..6f021a0ac3 100644 --- a/eth/handler.go +++ b/eth/handler.go @@ -856,9 +856,6 @@ func (pm *ProtocolManager) handleMsg(p *peer) error { if err := msg.Decode(&vote); err != nil { return errResp(ErrDecode, "msg %v: %v", msg, err) } - // Mark the peer as owning the vote and process it - // because peer has 2 address sender and receive, so use p.id to find the right address - p = pm.peers.Peer(p.id) p.MarkVote(vote.Hash()) exist, _ := pm.knownVotes.ContainsOrAdd(vote.Hash(), true) @@ -878,10 +875,6 @@ func (pm *ProtocolManager) handleMsg(p *peer) error { if err := msg.Decode(&timeout); err != nil { return errResp(ErrDecode, "msg %v: %v", msg, err) } - - // Mark the peer as owning the timeout and process it - // because peer has 2 address sender and receive, so use p.id to find the right address - p = pm.peers.Peer(p.id) p.MarkTimeout(timeout.Hash()) exist, _ := pm.knownTimeouts.ContainsOrAdd(timeout.Hash(), true) @@ -902,9 +895,6 @@ func (pm *ProtocolManager) handleMsg(p *peer) error { if err := msg.Decode(&syncInfo); err != nil { return errResp(ErrDecode, "msg %v: %v", msg, err) } - // Mark the peer as owning the syncInfo and process it - // because peer has 2 address sender and receive, so use p.id to find the right address - p = pm.peers.Peer(p.id) p.MarkSyncInfo(syncInfo.Hash()) exist, _ := pm.knownSyncInfos.ContainsOrAdd(syncInfo.Hash(), true)