From 10157d108fe20e8c26475854169a21e823486920 Mon Sep 17 00:00:00 2001 From: Chris Stewart Date: Wed, 13 Apr 2022 09:18:32 -0500 Subject: [PATCH] Reduce parallelism when fetches txs in mempool for bitcoind backend (#4257) --- .../main/scala/org/bitcoins/server/BitcoindRpcBackendUtil.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/app/server/src/main/scala/org/bitcoins/server/BitcoindRpcBackendUtil.scala b/app/server/src/main/scala/org/bitcoins/server/BitcoindRpcBackendUtil.scala index 1f58f43394..12f714616a 100644 --- a/app/server/src/main/scala/org/bitcoins/server/BitcoindRpcBackendUtil.scala +++ b/app/server/src/main/scala/org/bitcoins/server/BitcoindRpcBackendUtil.scala @@ -389,7 +389,7 @@ object BitcoindRpcBackendUtil extends Logging { { if (processing.compareAndSet(false, true)) { logger.debug("Polling bitcoind for mempool") - val numParallelism = Runtime.getRuntime.availableProcessors() * 2 + val numParallelism = Runtime.getRuntime.availableProcessors() //don't want to execute these in parallel val processTxFlow = Sink.foreachAsync[Transaction](1)(processTx)