Raise fdlimit

CHANGELOG.md

@@ -2,6 +2,7 @@
 
 ## Next release
 
+- feat: raise file-descriptor limit
 - fix: docker
 - fix: pending storage & sequencer_provider
 - refactor: support pending blocks & db crate

Cargo.toml

@@ -143,6 +143,7 @@ rayon = "1.10"
 crossbeam-skiplist = "0.1"
 bincode = "1.3"
 prometheus = "0.13.4"
+fdlimit = "0.3.0"
 
 [patch.crates-io]
 starknet-core = { git = "https://github.com/kasarlabs/starknet-rs.git", branch = "fork" }

crates/node/Cargo.toml

@@ -33,6 +33,7 @@ anyhow.workspace = true
 chrono = "0.4.38"
 clap = { workspace = true, features = ["derive"] }
 env_logger = "0.11.3"
+fdlimit.workspace = true
 forwarded-header-value = "0.1.1"
 futures = { workspace = true, features = ["thread-pool"] }
 governor.workspace = true

crates/node/src/main.rs

@@ -21,8 +21,9 @@ const GREET_AUTHORS: &[&str] = &["KasarLabs <https://kasar.io>"];
 
 #[tokio::main]
 async fn main() -> anyhow::Result<()> {
-    crate::util::setup_rayon_threadpool()?;
     crate::util::setup_logging()?;
+    crate::util::setup_rayon_threadpool()?;
+    crate::util::raise_fdlimit();
 
     let mut run_cmd: RunCmd = RunCmd::parse();
     let node_name = run_cmd.node_name_or_provide().await.to_string();

crates/node/src/util.rs

@@ -12,6 +12,29 @@ pub fn setup_rayon_threadpool() -> anyhow::Result<()> {
     Ok(())
 }
 
+pub fn raise_fdlimit() {
+    use fdlimit::Outcome;
+    let recommended = 10000;
+    match fdlimit::raise_fd_limit() {
+        Ok(Outcome::LimitRaised { to, .. }) if to < recommended => {
+            log::warn!(
+                    "The file-descriptor limit for the current process is {to}, which is lower than the recommended {recommended}."
+                );
+        }
+        Ok(Outcome::LimitRaised { to, .. }) => {
+            log::debug!("File-descriptor limit was raised to {to}.");
+        }
+        Err(error) => {
+            log::warn!(
+                "Error while trying to raise the file-descriptor limit for the process: {error:#}. The recommended file-descriptor limit is {recommended}."
+            );
+        }
+        Ok(Outcome::Unsupported) => {
+            log::debug!("Unsupported platform for raising file-descriptor limit.");
+        }
+    }
+}
+
 // Todo: Setup tracing
 pub fn setup_logging() -> anyhow::Result<()> {
     env_logger::Builder::from_env(env_logger::Env::default().default_filter_or("info"))