Handle PeerNotConnected exceptions when sending wire keep alives. (#918)

PegaSysEng · Feb 20, 2019 · 38edb0f · 38edb0f
1 parent f73b4e8
commit 38edb0f
Showing 1 changed file with 8 additions and 3 deletions.
diff --git a/ethereum/p2p/src/main/java/tech/pegasys/pantheon/ethereum/p2p/netty/WireKeepAlive.java b/ethereum/p2p/src/main/java/tech/pegasys/pantheon/ethereum/p2p/netty/WireKeepAlive.java
@@ -13,6 +13,7 @@
 package tech.pegasys.pantheon.ethereum.p2p.netty;
 
 import tech.pegasys.pantheon.ethereum.p2p.api.PeerConnection;
+import tech.pegasys.pantheon.ethereum.p2p.api.PeerConnection.PeerNotConnected;
 import tech.pegasys.pantheon.ethereum.p2p.wire.messages.DisconnectMessage.DisconnectReason;
 import tech.pegasys.pantheon.ethereum.p2p.wire.messages.PingMessage;
 
@@ -54,8 +55,12 @@ public void userEventTriggered(final ChannelHandlerContext ctx, final Object evt
       return;
     }
 
-    LOG.debug("Idle connection detected, sending Wire PING to peer.");
-    connection.send(null, PingMessage.get());
-    waitingForPong.set(true);
+    try {
+      LOG.debug("Idle connection detected, sending Wire PING to peer.");
+      connection.send(null, PingMessage.get());
+      waitingForPong.set(true);
+    } catch (final PeerNotConnected ignored) {
+      LOG.trace("PING not sent because peer is already disconnected");
+    }
   }
 }