IbftProcessor logs when a throwable terminates mining (#1427)

PegaSysEng · May 13, 2019 · 81c9a42 · 81c9a42
1 parent a453610
commit 81c9a42
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/consensus/ibft/src/main/java/tech/pegasys/pantheon/consensus/ibft/IbftProcessor.java b/consensus/ibft/src/main/java/tech/pegasys/pantheon/consensus/ibft/IbftProcessor.java
@@ -48,8 +48,12 @@ public void stop() {
 
   @Override
   public void run() {
-    while (!shutdown) {
-      nextIbftEvent().ifPresent(event -> eventMultiplexer.handleIbftEvent(event));
+    try {
+      while (!shutdown) {
+        nextIbftEvent().ifPresent(eventMultiplexer::handleIbftEvent);
+      }
+    } catch (final Throwable t) {
+      LOG.error("IBFT Mining thread has suffered a fatal error, mining has been halted", t);
     }
     // Clean up the executor service the round timer has been utilising
     LOG.info("Shutting down IBFT event processor");