pezkuwichain/revive-differential-tests
1
0
Fork 0
mirror of https://github.com/pezkuwichain/revive-differential-tests.git synced 2026-07-20 01:45:48 +00:00
Code Issues Packages Projects Releases Wiki Activity

Update the concurrency limit

Browse Source
This commit is contained in:
Omar Abdulla
2025-10-04 23:05:56 +03:00
parent 2bb9594857
commit 9ffc04bf13
2 changed files with 2 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
crates/core/src/differential_tests/driver.rs
-1
View File
@@ -330,7 +330,6 @@ where
)] )]
pub async fn execute_next_step(&mut self) -> Option<Result<()>> { pub async fn execute_next_step(&mut self) -> Option<Result<()>> {
let (step_path, step) = self.steps_iterator.next()?; let (step_path, step) = self.steps_iterator.next()?;
info!(%step_path, "Executing Step"); info!(%step_path, "Executing Step");
Some( Some(
self.execute_step(&step_path, &step) self.execute_step(&step_path, &step)
crates/node/src/provider_utils/provider.rs
+2 -2
View File
@@ -38,11 +38,11 @@ where
WalletFiller<W>: TxFiller<N>, WalletFiller<W>: TxFiller<N>,
{ {
// This is a global limit on the RPC concurrency that applies to all of the providers created // This is a global limit on the RPC concurrency that applies to all of the providers created
// by the framework. With this limit, it means that we can have a maximum of 1500 concurrent // by the framework. With this limit, it means that we can have a maximum of N concurrent
// requests at any point of time and no more than that. This is done in an effort to stabilize // 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. // the framework from some of the interment issues that we've been seeing related to RPC calls.
static GLOBAL_CONCURRENCY_LIMITER_LAYER: LazyLock<ConcurrencyLimiterLayer> = static GLOBAL_CONCURRENCY_LIMITER_LAYER: LazyLock<ConcurrencyLimiterLayer> =
LazyLock::new(|| ConcurrencyLimiterLayer::new(1500)); LazyLock::new(|| ConcurrencyLimiterLayer::new(500));
let client = ClientBuilder::default() let client = ClientBuilder::default()
.layer(GLOBAL_CONCURRENCY_LIMITER_LAYER.clone()) .layer(GLOBAL_CONCURRENCY_LIMITER_LAYER.clone())