Add lock to creation of pending transaction stream

Signed-off-by: Matthew Whitehead <[email protected]>
kaleido-io · Jun 20, 2023 · df3bf97 · df3bf97
1 parent 67db8de
commit df3bf97
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/...a/org/hyperledger/besu/ethereum/eth/transactions/sorter/PendingTransactionsForSender.java b/...a/org/hyperledger/besu/ethereum/eth/transactions/sorter/PendingTransactionsForSender.java
@@ -113,7 +113,9 @@ public List<PendingTransaction> getPendingTransactions(final long startingNonce)
   }
 
   public Stream<PendingTransaction> streamPendingTransactions() {
-    return pendingTransactions.values().stream();
+    synchronized (pendingTransactions) {
+      return List.copyOf(pendingTransactions.values()).stream();
+    }
   }
 
   public PendingTransaction getPendingTransactionForNonce(final long nonce) {