From fea3d9c60e10a48d7dbd7c17e5037e5074777561 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?P=C3=A9ter=20Szil=C3=A1gyi?= Date: Thu, 28 May 2015 04:26:35 +0300 Subject: [PATCH] p2p: don't silence oridinal disconnect reason --- p2p/peer.go | 10 ++-------- 1 file changed, 2 insertions(+), 8 deletions(-) diff --git a/p2p/peer.go b/p2p/peer.go index cbe5ccc84a..b18ac32a82 100644 --- a/p2p/peer.go +++ b/p2p/peer.go @@ -123,10 +123,8 @@ func (p *Peer) run() DiscReason { p.startProtocols() // Wait for an error or disconnect. - var ( - reason DiscReason - requested bool - ) + var reason DiscReason + select { case err := <-readErr: if r, ok := err.(DiscReason); ok { @@ -140,15 +138,11 @@ func (p *Peer) run() DiscReason { case err := <-p.protoErr: reason = discReasonForError(err) case reason = <-p.disc: - requested = true } close(p.closed) p.rw.close(reason) p.wg.Wait() - if requested { - reason = DiscRequested - } glog.V(logger.Debug).Infof("%v: Disconnected: %v\n", p, reason) return reason }