From e9426287b9eae8c5c62f8c7f82224ea0c1ef83c8 Mon Sep 17 00:00:00 2001
From: Sonic <sonic@dexon.org>
Date: Mon, 18 Mar 2019 08:43:39 +0800
Subject: p2p, dex: add debug log (#269)

---
 p2p/peer.go | 4 ++++
 1 file changed, 4 insertions(+)

(limited to 'p2p/peer.go')

diff --git a/p2p/peer.go b/p2p/peer.go
index 9183082a1..cb6a7e484 100644
--- a/p2p/peer.go
+++ b/p2p/peer.go
@@ -249,6 +249,7 @@ loop:
 
 	close(p.closed)
 	p.rw.close(reason)
+	p.Log().Debug("wait for close")
 	p.wg.Wait()
 	return remoteRequested, err
 }
@@ -257,6 +258,7 @@ func (p *Peer) pingLoop() {
 	ping := time.NewTimer(pingInterval)
 	defer p.wg.Done()
 	defer ping.Stop()
+	defer p.Log().Debug("pingLoop stopped")
 	for {
 		select {
 		case <-ping.C:
@@ -273,6 +275,7 @@ func (p *Peer) pingLoop() {
 
 func (p *Peer) readLoop(errc chan<- error) {
 	defer p.wg.Done()
+	defer p.Log().Debug("readLoop stopped")
 	for {
 		msg, err := p.rw.ReadMsg()
 		if err != nil {
@@ -317,6 +320,7 @@ func (p *Peer) handle(msg Msg) error {
 		case proto.in <- msg:
 			return nil
 		case <-p.closed:
+			p.Log().Debug("peer handle closed return EOF")
 			return io.EOF
 		}
 	}
-- 
cgit v1.2.3