Merge branch 'pro-74-run-node-ci-benchmark-tests' of github.com:radixdlt/babylon-node into pro-74-run-node-ci-benchmark-tests

Author: les-sheppard

core/src/main/java/com/radixdlt/environment/rx/RxEnvironmentModule.java

@@ -82,7 +82,6 @@
 import com.radixdlt.ledger.LedgerUpdate;
 import com.radixdlt.modules.ModuleRunner;
 import com.radixdlt.p2p.NodeId;
-import com.radixdlt.utils.ThreadFactories;
 import io.reactivex.rxjava3.core.BackpressureOverflowStrategy;
 import io.reactivex.rxjava3.core.BackpressureStrategy;
 import io.reactivex.rxjava3.core.Flowable;
@@ -98,8 +97,7 @@
 public final class RxEnvironmentModule extends AbstractModule {
   @Override
   public void configure() {
-    ScheduledExecutorService ses =
-        Executors.newSingleThreadScheduledExecutor(ThreadFactories.daemonThreads("TimeoutSender"));
+    ScheduledExecutorService ses = Executors.newScheduledThreadPool(4);
     bind(Environment.class).to(RxEnvironment.class);
     bind(ScheduledExecutorService.class).toInstance(ses);
 

core/src/main/java/com/radixdlt/rev2/REv2StateComputer.java

@@ -154,6 +154,7 @@ public void addToMempool(MempoolAdd mempoolAdd, NodeId origin) {
         .forEach(
             transaction -> {
               try {
+                log.info("Attempt to add transaction to mempool: origin = " + origin);
                 mempool.addTransaction(transaction);
                 // Please note that a `MempoolAddSuccess` event is only dispatched when the above
                 // call does not throw. This is deliberate: we do not want to propagate the
@@ -162,11 +163,13 @@ public void addToMempool(MempoolAdd mempoolAdd, NodeId origin) {
                 var success =
                     new MempoolAddSuccess(
                         RawNotarizedTransaction.create(transaction.getPayload()), origin);
+                log.info("Add transaction success");
                 mempoolAddSuccessEventDispatcher.dispatch(success);
               } catch (MempoolDuplicateException ignored) {
+                log.info("Duplicate transaction");
                 // Ignore these specific subclass of the `MempoolRejectedException` logged below
               } catch (MempoolRejectedException e) {
-                log.debug(e);
+                log.info("Transaction rejected: " + e.getMessage());
               }
             });
   }