wip perf(fuzz): parallel stateless fuzzing

crates/cheatcodes/Cargo.toml

@@ -60,6 +60,7 @@ revm-inspectors.workspace = true
 semver.workspace = true
 serde_json.workspace = true
 thiserror.workspace = true
+tokio.workspace = true
 toml = { workspace = true, features = ["preserve_order"] }
 tracing.workspace = true
 walkdir.workspace = true

crates/cheatcodes/src/test/expect.rs

@@ -1094,8 +1094,12 @@ fn decode_event(
         return None;
     }
     let t0 = topics[0]; // event sig
-    // Try to identify the event
-    let event = foundry_common::block_on(identifier.identify_event(t0))?;
+    // Try to identify the event - detect if we're in a Tokio runtime and use appropriate method
+    let event = if tokio::runtime::Handle::try_current().is_ok() {
+        foundry_common::block_on(identifier.identify_event(t0))?
+    } else {
+        identifier.identify_event_sync(t0)?
+    };
 
     // Check if event already has indexed information from signatures
     let has_indexed_info = event.inputs.iter().any(|p| p.indexed);

crates/config/src/fuzz.rs

@@ -34,6 +34,10 @@ pub struct FuzzConfig {
     pub show_logs: bool,
     /// Optional timeout (in seconds) for each property test
     pub timeout: Option<u32>,
+    /// Number of threads to use for parallel fuzz runs
+    ///
+    /// This is set by passing `-j` or `--jobs`
+    pub threads: Option<usize>,
 }
 
 impl Default for FuzzConfig {
@@ -49,6 +53,7 @@ impl Default for FuzzConfig {
             failure_persist_dir: None,
             show_logs: false,
             timeout: None,
+            threads: None,
         }
     }
 }

crates/evm/evm/Cargo.toml

@@ -56,3 +56,4 @@ indicatif.workspace = true
 serde_json.workspace = true
 serde.workspace = true
 uuid.workspace = true
+rayon.workspace = true

crates/evm/evm/src/executors/corpus.rs

@@ -770,7 +770,6 @@ impl WorkerCorpus {
             };
 
             if timestamp <= self.last_sync_timestamp {
-                // TODO: Delete synced file
                 continue;
             }
 
@@ -891,7 +890,7 @@ impl WorkerCorpus {
 
     /// To be run by the master worker (id = 0) to distribute the global corpus to sync/ directories
     /// of other workers.
-    fn distribute(&mut self, num_workers: usize) -> eyre::Result<()> {
+    fn distribute(&mut self, num_workers: u32) -> eyre::Result<()> {
         if self.id != 0 || self.worker_dir.is_none() {
             return Ok(());
         }
@@ -946,7 +945,7 @@ impl WorkerCorpus {
     /// Syncs the workers in_memory_corpus and history_map with the findings from other workers.
     pub fn sync(
         &mut self,
-        num_workers: usize,
+        num_workers: u32,
         executor: &Executor,
         fuzzed_function: Option<&Function>,
         fuzzed_contracts: Option<&FuzzRunIdentifiedContracts>,