diff options
| author | Viktor Trón <viktor.tron@gmail.com> | 2018-06-22 05:00:43 +0800 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2018-06-22 05:00:43 +0800 |
| commit | eaff89291ce998ba4bf9b9816ca8a15c8b85f440 (patch) | |
| tree | c77d7a06627a1a7f578d0fec8e39788e66672e53 /p2p/protocols | |
| parent | d926bf2c7e3182d694c15829a37a0ca7331cd03c (diff) | |
| parent | e187711c6545487d4cac3701f0f506bb536234e2 (diff) | |
| download | dexon-eaff89291ce998ba4bf9b9816ca8a15c8b85f440.tar dexon-eaff89291ce998ba4bf9b9816ca8a15c8b85f440.tar.gz dexon-eaff89291ce998ba4bf9b9816ca8a15c8b85f440.tar.bz2 dexon-eaff89291ce998ba4bf9b9816ca8a15c8b85f440.tar.lz dexon-eaff89291ce998ba4bf9b9816ca8a15c8b85f440.tar.xz dexon-eaff89291ce998ba4bf9b9816ca8a15c8b85f440.tar.zst dexon-eaff89291ce998ba4bf9b9816ca8a15c8b85f440.zip | |
Merge pull request #17041 from ethersphere/swarm-network-rewrite-merge
Swarm POC3 - happy solstice
Diffstat (limited to 'p2p/protocols')
| -rw-r--r-- | p2p/protocols/protocol.go | 7 |
1 files changed, 7 insertions, 0 deletions
diff --git a/p2p/protocols/protocol.go b/p2p/protocols/protocol.go index 849a7ef39..d5c0375ac 100644 --- a/p2p/protocols/protocol.go +++ b/p2p/protocols/protocol.go @@ -31,10 +31,12 @@ package protocols import ( "context" "fmt" + "io" "reflect" "sync" "time" + "github.com/ethereum/go-ethereum/log" "github.com/ethereum/go-ethereum/metrics" "github.com/ethereum/go-ethereum/p2p" ) @@ -202,6 +204,11 @@ func NewPeer(p *p2p.Peer, rw p2p.MsgReadWriter, spec *Spec) *Peer { func (p *Peer) Run(handler func(msg interface{}) error) error { for { if err := p.handleIncoming(handler); err != nil { + if err != io.EOF { + metrics.GetOrRegisterCounter("peer.handleincoming.error", nil).Inc(1) + log.Error("peer.handleIncoming", "err", err) + } + return err } } |