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

p2p/simulations: Don't log errors for duplicate events

Browse source 
Signed-off-by: Lewis Marshall <lewis@lmars.net>
This commit is contained in:
Lewis Marshall 2017-06-14 11:06:32 +02:00
parent 8ac9af986c
commit e32197f998
1 changed files with 4 additions and 12 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

16
p2p/simulations/network.go
View file

@ -347,21 +347,13 @@ func (self *Network) watchPeerEvents(id discover.NodeID, events chan *p2p.PeerEv
peer := event.Peer peer := event.Peer
switch event.Type { switch event.Type {
case p2p.PeerEventTypeAdd: case p2p.PeerEventTypeAdd:
if err := self.DidConnect(id, peer); err != nil { self.DidConnect(id, peer)
log.Error(fmt.Sprintf("error generating connection up event %s => %s", id.TerminalString(), peer.TerminalString()), "err", err)
}
case p2p.PeerEventTypeDrop: case p2p.PeerEventTypeDrop:
if err := self.DidDisconnect(id, peer); err != nil { self.DidDisconnect(id, peer)
log.Error(fmt.Sprintf("error generating connection down event %s => %s", id.TerminalString(), peer.TerminalString()), "err", err)
}
case p2p.PeerEventTypeMsgSend: case p2p.PeerEventTypeMsgSend:
if err := self.DidSend(id, peer, *event.MsgCode); err != nil { self.DidSend(id, peer, *event.MsgCode)
log.Error(fmt.Sprintf("error generating msg send event %s => %s", id.TerminalString(), peer.TerminalString()), "err", err)
}
case p2p.PeerEventTypeMsgRecv: case p2p.PeerEventTypeMsgRecv:
if err := self.DidReceive(peer, id, *event.MsgCode); err != nil { self.DidReceive(peer, id, *event.MsgCode)
log.Error(fmt.Sprintf("error generating msg receive event %s => %s", peer.TerminalString(), id.TerminalString()), "err", err)
}
} }
case err := <-sub.Err(): case err := <-sub.Err():
if err != nil { if err != nil {