Merge pull request #431 from tronprotocol/p2p_msg_queue

modify P2pHandler and message queue

Author: zhaohong

src/main/java/org/tron/common/overlay/server/MessageQueue.java

@@ -173,7 +173,7 @@ private void sendToWire(MessageRoundtrip messageRoundtrip) {
 
     if (messageRoundtrip.getRetryTimes() > 0){
       logger.warn("send msg timeout. close channel {}.", ctx.channel().remoteAddress());
-      ctx.close();
+      close();
       return;
     }
 
@@ -193,6 +193,11 @@ private void sendToWire(MessageRoundtrip messageRoundtrip) {
 
   public void close() {
     sendMsgThread.interrupt();
-    timerTask.cancel(false);
+    timerTask.cancel(true);
+    if (ctx != null){
+      ctx.close();
+      ctx = null;
+    }
   }
+
 }

src/main/java/org/tron/common/overlay/server/P2pHandler.java

@@ -100,7 +100,7 @@ public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws E
 
   public void closeChannel(ChannelHandlerContext ctx) {
     ctx.close();
-    pingTask.cancel(false);
+    pingTask.cancel(true);
     msgQueue.close();
   }