From e32197f998dd18aa378ca75df891d3e8fe822925 Mon Sep 17 00:00:00 2001 From: Lewis Marshall Date: Wed, 14 Jun 2017 11:06:32 +0200 Subject: [PATCH] p2p/simulations: Don't log errors for duplicate events Signed-off-by: Lewis Marshall --- p2p/simulations/network.go | 16 ++++------------ 1 file changed, 4 insertions(+), 12 deletions(-) diff --git a/p2p/simulations/network.go b/p2p/simulations/network.go index 9040fcfec4..df08c41bcf 100644 --- a/p2p/simulations/network.go +++ b/p2p/simulations/network.go @@ -347,21 +347,13 @@ func (self *Network) watchPeerEvents(id discover.NodeID, events chan *p2p.PeerEv peer := event.Peer switch event.Type { case p2p.PeerEventTypeAdd: - if err := self.DidConnect(id, peer); err != nil { - log.Error(fmt.Sprintf("error generating connection up event %s => %s", id.TerminalString(), peer.TerminalString()), "err", err) - } + self.DidConnect(id, peer) case p2p.PeerEventTypeDrop: - if err := self.DidDisconnect(id, peer); err != nil { - log.Error(fmt.Sprintf("error generating connection down event %s => %s", id.TerminalString(), peer.TerminalString()), "err", err) - } + self.DidDisconnect(id, peer) case p2p.PeerEventTypeMsgSend: - if err := self.DidSend(id, peer, *event.MsgCode); err != nil { - log.Error(fmt.Sprintf("error generating msg send event %s => %s", id.TerminalString(), peer.TerminalString()), "err", err) - } + self.DidSend(id, peer, *event.MsgCode) case p2p.PeerEventTypeMsgRecv: - if err := self.DidReceive(peer, id, *event.MsgCode); err != nil { - log.Error(fmt.Sprintf("error generating msg receive event %s => %s", peer.TerminalString(), id.TerminalString()), "err", err) - } + self.DidReceive(peer, id, *event.MsgCode) } case err := <-sub.Err(): if err != nil {