cargo fmt fixes

Author: marcofleon

fuzzor-cmds/src/bin/fuzz-project.rs

@@ -84,7 +84,10 @@ struct Options {
     repo: Option<String>,
     #[arg(long = "branch", help = "Overwrite the branch from the config")]
     branch: Option<String>,
-    #[arg(long = "pr", help = "PR number to fuzz (fetches from the upstream repo)")]
+    #[arg(
+        long = "pr",
+        help = "PR number to fuzz (fetches from the upstream repo)"
+    )]
     pr: Option<String>,
     #[arg(long = "name", help = "Overwrite the name from the config")]
     name: Option<String>,

fuzzor-docker/src/env.rs

@@ -439,7 +439,12 @@ impl Environment for DockerEnv {
 
         if let Some(entry) = tarball
             .entries()
-            .map_err(|e| format!("Could not get entries from covered functions tarball: {}", e))?
+            .map_err(|e| {
+                format!(
+                    "Could not get entries from covered functions tarball: {}",
+                    e
+                )
+            })?
             .next()
         {
             let mut contents = String::new();

fuzzor/src/project/harness.rs

@@ -210,7 +210,11 @@ impl HarnessState for PersistentHarnessState {
 
         let summary_path = campaign_dir.join("coverage-summary.json");
         if let Err(err) = tokio::fs::write(&summary_path, &summary).await {
-            log::error!("Could not write coverage summary to {:?}: {:?}", summary_path, err);
+            log::error!(
+                "Could not write coverage summary to {:?}: {:?}",
+                summary_path,
+                err
+            );
         }
     }
 
@@ -297,7 +301,10 @@ mod tests {
             .join("campaigns")
             .join("campaign-001")
             .join("startup_params.json");
-        assert!(params_path.exists(), "startup_params.json should be created");
+        assert!(
+            params_path.exists(),
+            "startup_params.json should be created"
+        );
 
         let content = tokio::fs::read_to_string(&params_path).await.unwrap();
         let loaded: CampaignStartupParams = serde_json::from_str(&content).unwrap();

fuzzor/src/project/mod.rs

@@ -590,9 +590,15 @@ where
             // Run the campaign in a separate task.
             let project_config = self.project_config.clone();
             let campaign_task = tokio::spawn(async move {
-                let mut campaign =
-                    Campaign::new(project_config, harness, env, event_sender, commit_hash, duration)
-                        .await;
+                let mut campaign = Campaign::new(
+                    project_config,
+                    harness,
+                    env,
+                    event_sender,
+                    commit_hash,
+                    duration,
+                )
+                .await;
                 campaign.run(quit_rx).await;
                 campaign
             });

infra/ensemble-fuzz/src/fuzzer/aflpp.rs

@@ -57,7 +57,8 @@ impl AflppFuzzer {
     }
 
     fn stderr_log_path(&self) -> PathBuf {
-        self.workspace.join(format!("aflpp_instance_{}.log", self.id))
+        self.workspace
+            .join(format!("aflpp_instance_{}.log", self.id))
     }
 
     fn queue_seed_count(&self) -> Option<u64> {
@@ -254,7 +255,11 @@ impl Fuzzer for AflppFuzzer {
         let log_path = self.stderr_log_path();
         let log_file = std::fs::File::create(&log_path).expect("Could not create AFL++ log file");
         if std::env::var("FUZZOR_AFL_DEBUG").is_ok() {
-            log::info!("AFL++ instance {} stderr is logged to {:?}", self.id, log_path);
+            log::info!(
+                "AFL++ instance {} stderr is logged to {:?}",
+                self.id,
+                log_path
+            );
         }
         command.stderr(Stdio::from(log_file));