diff --git a/.github/workflows/pr-main_l1.yaml b/.github/workflows/pr-main_l1.yaml index 515c613cabb..5e2b79823c6 100644 --- a/.github/workflows/pr-main_l1.yaml +++ b/.github/workflows/pr-main_l1.yaml @@ -150,7 +150,7 @@ jobs: artifact_prefix: rpc_compat - name: "Devp2p tests" simulation: devp2p - limit: discv4|eth|snap/Ping|Amplification|Status|StorageRanges|ByteCodes|GetBlockHeaders|SimultaneousRequests|SameRequestID|ZeroRequestID|GetBlockBodies|MaliciousHandshake|MaliciousStatus|Transaction|NewPooledTxs|GetBlockReceipts|LargeTxRequest|InvalidTxs|BlockRangeUpdate|AccountRange|GetTrieNodes|GetByteCodes|GetStorageRanges|Findnode + limit: discv4|eth|snap/Ping|Amplification|Status|StorageRanges|ByteCodes|GetBlockHeaders|SimultaneousRequests|SameRequestID|ZeroRequestID|GetBlockBodies|MaliciousHandshake|MaliciousStatus|Transaction|NewPooledTxs|GetBlockReceipts|LargeTxRequest|InvalidTxs|BlockRangeUpdate|AccountRange|GetTrieNodes|GetByteCodes|GetStorageRanges|Findnode|BlobViolations artifact_prefix: devp2p - name: "Engine Auth and EC tests" simulation: ethereum/engine diff --git a/crates/networking/p2p/rlpx/connection/server.rs b/crates/networking/p2p/rlpx/connection/server.rs index d6486c6460b..8631cf1c6b2 100644 --- a/crates/networking/p2p/rlpx/connection/server.rs +++ b/crates/networking/p2p/rlpx/connection/server.rs @@ -992,8 +992,10 @@ async fn handle_incoming_message( Message::NewPooledTransactionHashes(new_pooled_transaction_hashes) if peer_supports_eth => { let hashes = new_pooled_transaction_hashes.get_transactions_to_request(&state.blockchain)?; - let request = GetPooledTransactions::new(random(), hashes); + state + .requested_pooled_txs + .insert(request.id, new_pooled_transaction_hashes); send(state, Message::GetPooledTransactions(request)).await?; } Message::GetPooledTransactions(msg) => {