From 970917ca43ed965e530d3bb0ee17ec9e9656a39a Mon Sep 17 00:00:00 2001 From: Omar Abdulla Date: Sun, 5 Oct 2025 02:41:25 +0300 Subject: [PATCH] Update the concurrency limit --- crates/node/src/node_implementations/substrate.rs | 2 +- crates/node/src/provider_utils/concurrency_limiter.rs | 4 ++++ crates/node/src/provider_utils/provider.rs | 2 +- run_tests.sh | 10 ++++++++-- 4 files changed, 14 insertions(+), 4 deletions(-) diff --git a/crates/node/src/node_implementations/substrate.rs b/crates/node/src/node_implementations/substrate.rs index 359e2e6..a2d3d24 100644 --- a/crates/node/src/node_implementations/substrate.rs +++ b/crates/node/src/node_implementations/substrate.rs @@ -345,7 +345,7 @@ impl SubstrateNode { .get_or_try_init(|| async move { construct_concurrency_limited_provider::( self.rpc_url.as_str(), - FallbackGasFiller::default(), + FallbackGasFiller::new(250_000_000, 5_000_000_000, 1_000_000_000), ChainIdFiller::new(Some(CHAIN_ID)), NonceFiller::new(self.nonce_manager.clone()), self.wallet.clone(), diff --git a/crates/node/src/provider_utils/concurrency_limiter.rs b/crates/node/src/provider_utils/concurrency_limiter.rs index 585fd73..73878b9 100644 --- a/crates/node/src/provider_utils/concurrency_limiter.rs +++ b/crates/node/src/provider_utils/concurrency_limiter.rs @@ -59,6 +59,10 @@ where .acquire() .await .expect("Semaphore has been closed"); + tracing::debug!( + available_permits = semaphore.available_permits(), + "Acquired Semaphore Permit" + ); future.await }) } diff --git a/crates/node/src/provider_utils/provider.rs b/crates/node/src/provider_utils/provider.rs index 8eac1e3..e69ed20 100644 --- a/crates/node/src/provider_utils/provider.rs +++ b/crates/node/src/provider_utils/provider.rs @@ -42,7 +42,7 @@ where // requests at any point of time and no more than that. This is done in an effort to stabilize // the framework from some of the interment issues that we've been seeing related to RPC calls. static GLOBAL_CONCURRENCY_LIMITER_LAYER: LazyLock = - LazyLock::new(|| ConcurrencyLimiterLayer::new(500)); + LazyLock::new(|| ConcurrencyLimiterLayer::new(10)); let client = ClientBuilder::default() .layer(GLOBAL_CONCURRENCY_LIMITER_LAYER.clone()) diff --git a/run_tests.sh b/run_tests.sh index 14506cb..f569156 100755 --- a/run_tests.sh +++ b/run_tests.sh @@ -75,7 +75,11 @@ ABSOLUTE_PATH=$(realpath "$TEST_REPO_DIR/fixtures/solidity/") cat > "$CORPUS_FILE" << EOF { "name": "MatterLabs Solidity Simple, Complex, and Semantic Tests", - "path": "$ABSOLUTE_PATH" + "paths": [ + "$(realpath "$TEST_REPO_DIR/fixtures/solidity/translated_semantic_tests")", + "$(realpath "$TEST_REPO_DIR/fixtures/solidity/complex")", + "$(realpath "$TEST_REPO_DIR/fixtures/solidity/simple")" + ] } EOF @@ -89,7 +93,9 @@ echo "This may take a while..." echo "" # Run the tool -RUST_LOG="info,alloy_pubsub::service=error" cargo run --release -- test \ +cargo build --release; +RUST_LOG="info,alloy_pubsub::service=error" ./target/release/retester test \ + --platform geth-evm-solc \ --platform revive-dev-node-revm-solc \ --corpus "$CORPUS_FILE" \ --working-directory "$WORKDIR" \