jleony/nanoreth
1
0
Fork 0
mirror of https://github.com/hl-archive-node/nanoreth.git synced 2025-12-06 19:09:54 +00:00
Code Issues Packages Projects Releases Wiki Activity

feat(cli): integrate max tracing requests in cli (#2914)

Browse Source
This commit is contained in:
Matthias Seitz
2023-05-30 16:19:21 +02:00
committed by GitHub
parent 9d7b3de646
commit c481b8717b
3 changed files with 18 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
crates/rpc/rpc-builder/src/eth.rs
View File

@ -11,7 +11,7 @@ use serde::{Deserialize, Serialize};
pub(crate) const DEFAULT_MAX_LOGS_IN_RESPONSE: usize = 10_000;
/// The default maximum number of concurrently executed tracing calls
pub(crate) const DEFAULT_MAX_TRACING_REQUESTS: usize = 10;
pub(crate) const DEFAULT_MAX_TRACING_REQUESTS: u32 = 25;
/// All handlers for the `eth` namespace
#[derive(Debug, Clone)]
@ -34,7 +34,7 @@ pub struct EthConfig {
/// Settings for the gas price oracle
pub gas_oracle: GasPriceOracleConfig,
/// The maximum number of tracing calls that can be executed in concurrently.
pub max_tracing_requests: usize,
pub max_tracing_requests: u32,
/// Maximum number of logs that can be returned in a single response in `eth_getLogs` calls.
pub max_logs_per_response: usize,
}
@ -52,25 +52,25 @@ impl Default for EthConfig {
impl EthConfig {
/// Configures the caching layer settings
pub fn with_state_cache(mut self, cache: EthStateCacheConfig) -> Self {
pub fn state_cache(mut self, cache: EthStateCacheConfig) -> Self {
self.cache = cache;
self
}
/// Configures the gas price oracle settings
pub fn with_gpo_config(mut self, gas_oracle_config: GasPriceOracleConfig) -> Self {
pub fn gpo_config(mut self, gas_oracle_config: GasPriceOracleConfig) -> Self {
self.gas_oracle = gas_oracle_config;
self
}
/// Configures the maximum number of tracing requests
pub fn with_max_tracing_requests(mut self, max_requests: usize) -> Self {
pub fn max_tracing_requests(mut self, max_requests: u32) -> Self {
self.max_tracing_requests = max_requests;
self
}
/// Configures the maximum number of logs per response
pub fn with_max_logs_per_response(mut self, max_logs: usize) -> Self {
pub fn max_logs_per_response(mut self, max_logs: usize) -> Self {
self.max_logs_per_response = max_logs;
self
}

6
crates/rpc/rpc/src/call_guard.rs
View File

@ -4,14 +4,14 @@ use tokio::sync::{AcquireError, OwnedSemaphorePermit, Semaphore};
/// RPC Tracing call guard semaphore.
///
/// This is used to restrict the number of concurrent RPC requests to tracing methods like
/// `debug_traceTransaction` because they can consume a lot of memory.
/// `debug_traceTransaction` because they can consume a lot of memory and CPU.
#[derive(Clone, Debug)]
pub struct TracingCallGuard(Arc<Semaphore>);
impl TracingCallGuard {
/// Create a new `TracingCallGuard` with the given maximum number of tracing calls in parallel.
pub fn new(max_tracing_requests: usize) -> Self {
Self(Arc::new(Semaphore::new(max_tracing_requests)))
pub fn new(max_tracing_requests: u32) -> Self {
Self(Arc::new(Semaphore::new(max_tracing_requests as usize)))
}
/// See also [Semaphore::acquire_owned]