From a6f8042be5d5bab86d1fcdb0ae227862411c903b Mon Sep 17 00:00:00 2001
From: paladz <453256728@qq.com>
Date: Wed, 30 May 2018 17:04:18 +0800
Subject: [PATCH] edit for code review

---
 p2p/connection/connection.go | 7 +++++--
 1 file changed, 5 insertions(+), 2 deletions(-)

diff --git a/p2p/connection/connection.go b/p2p/connection/connection.go
index 09b28105..983fe221 100644
--- a/p2p/connection/connection.go
+++ b/p2p/connection/connection.go
@@ -118,7 +118,7 @@ func NewMConnectionWithConfig(conn net.Conn, chDescs []*ChannelDescriptor, onRec
 		sendMonitor: flow.New(0, 0),
 		recvMonitor: flow.New(0, 0),
 		send:        make(chan struct{}, 1),
-		pong:        make(chan struct{}),
+		pong:        make(chan struct{}, 1),
 		channelsIdx: map[byte]*channel{},
 		channels:    []*channel{},
 		onReceive:   onReceive,
@@ -268,7 +268,10 @@ func (c *MConnection) recvRoutine() {
 		switch pktType {
 		case packetTypePing:
 			log.Debug("receive Ping")
-			c.pong <- struct{}{}
+			select {
+			case c.pong <- struct{}{}:
+			default:
+			}
 
 		case packetTypePong:
 			log.Debug("receive Pong")
-- 
2.11.0