Propagate new block messages to other clients in a separate thread, n…

…ot the netty processing thread. (#928)
PegaSysEng · Feb 20, 2019 · 1286ad3 · 1286ad3
1 parent 0cf066d
commit 1286ad3
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...um/eth/src/main/java/tech/pegasys/pantheon/ethereum/eth/sync/BlockPropagationManager.java b/...um/eth/src/main/java/tech/pegasys/pantheon/ethereum/eth/sync/BlockPropagationManager.java
@@ -293,7 +293,7 @@ CompletableFuture<Block> importOrSavePendingBlock(final Block block) {
       return CompletableFuture.completedFuture(block);
     }
 
-    validateAndBroadcastBlock(block);
+    ethContext.getScheduler().scheduleSyncWorkerTask(() -> validateAndBroadcastBlock(block));
 
     // Import block
     final PersistBlockTask<C> importTask =