diff --git a/src/agent/onefuzz-agent/src/local/tui.rs b/src/agent/onefuzz-agent/src/local/tui.rs index 3d09bcd7a52..83acdf3708b 100644 --- a/src/agent/onefuzz-agent/src/local/tui.rs +++ b/src/agent/onefuzz-agent/src/local/tui.rs @@ -67,13 +67,6 @@ const TICK_RATE: Duration = Duration::from_millis(250); const FILE_MONITOR_POLLING_PERIOD: Duration = Duration::from_secs(5); const EVENT_POLLING_PERIOD: Duration = Duration::from_secs(1); -#[derive(Debug, Default)] -struct CoverageData { - covered: Option, - features: Option, - rate: Option, -} - /// Event driving the refresh of the UI #[derive(Debug)] enum TerminalEvent { diff --git a/src/agent/onefuzz-agent/src/tasks/merge/generic.rs b/src/agent/onefuzz-agent/src/tasks/merge/generic.rs index afaa0df433c..cbf4da48e03 100644 --- a/src/agent/onefuzz-agent/src/tasks/merge/generic.rs +++ b/src/agent/onefuzz-agent/src/tasks/merge/generic.rs @@ -19,13 +19,6 @@ use std::{ use storage_queue::{QueueClient, EMPTY_QUEUE_DELAY}; use tokio::process::Command; -#[derive(Debug, Deserialize)] -struct QueueMessage { - content_length: u32, - - url: Url, -} - #[derive(Debug, Deserialize)] pub struct Config { pub supervisor_exe: String, diff --git a/src/agent/onefuzz-agent/src/tasks/merge/libfuzzer_merge.rs b/src/agent/onefuzz-agent/src/tasks/merge/libfuzzer_merge.rs index 3616f0d86ac..b5972dc3c97 100644 --- a/src/agent/onefuzz-agent/src/tasks/merge/libfuzzer_merge.rs +++ b/src/agent/onefuzz-agent/src/tasks/merge/libfuzzer_merge.rs @@ -23,12 +23,6 @@ use std::{ }; use storage_queue::{QueueClient, EMPTY_QUEUE_DELAY}; -#[derive(Debug, Deserialize)] -struct QueueMessage { - content_length: u32, - url: Url, -} - #[derive(Debug, Deserialize)] pub struct Config { pub target_exe: PathBuf, diff --git a/src/agent/onefuzz-agent/src/tasks/report/crash_report.rs b/src/agent/onefuzz-agent/src/tasks/report/crash_report.rs index ed07e81e708..39fa418d0c0 100644 --- a/src/agent/onefuzz-agent/src/tasks/report/crash_report.rs +++ b/src/agent/onefuzz-agent/src/tasks/report/crash_report.rs @@ -75,8 +75,8 @@ pub struct NoCrash { #[derive(Debug, Deserialize, Serialize)] #[serde(rename_all = "snake_case")] pub enum CrashTestResult { - CrashReport(CrashReport), - NoRepro(NoCrash), + CrashReport(Box), + NoRepro(Box), } #[derive(Debug, Deserialize, Serialize)] @@ -268,13 +268,13 @@ pub async fn parse_report_file(path: PathBuf) -> Result { let report: Result = serde_json::from_value(json.clone()); let report_err = match report { - Ok(report) => return Ok(CrashTestResult::CrashReport(report)), + Ok(report) => return Ok(CrashTestResult::CrashReport(Box::new(report))), Err(err) => err, }; let no_repro: Result = serde_json::from_value(json); let no_repro_err = match no_repro { - Ok(no_repro) => return Ok(CrashTestResult::NoRepro(no_repro)), + Ok(no_repro) => return Ok(CrashTestResult::NoRepro(Box::new(no_repro))), Err(err) => err, }; diff --git a/src/agent/onefuzz-agent/src/tasks/report/generic.rs b/src/agent/onefuzz-agent/src/tasks/report/generic.rs index 237d888777a..61e41e63d29 100644 --- a/src/agent/onefuzz-agent/src/tasks/report/generic.rs +++ b/src/agent/onefuzz-agent/src/tasks/report/generic.rs @@ -152,7 +152,7 @@ pub async fn test_input(args: TestInputArgs<'_>) -> Result { input_sha256, args.minimized_stack_depth, ); - Ok(CrashTestResult::CrashReport(crash_report)) + Ok(CrashTestResult::CrashReport(Box::new(crash_report))) } else { let no_repro = NoCrash { input_blob, @@ -164,7 +164,7 @@ pub async fn test_input(args: TestInputArgs<'_>) -> Result { error: test_report.error.map(|e| format!("{}", e)), }; - Ok(CrashTestResult::NoRepro(no_repro)) + Ok(CrashTestResult::NoRepro(Box::new(no_repro))) } } diff --git a/src/agent/onefuzz-agent/src/tasks/report/libfuzzer_report.rs b/src/agent/onefuzz-agent/src/tasks/report/libfuzzer_report.rs index 42f6784db11..1e1e779eb8f 100644 --- a/src/agent/onefuzz-agent/src/tasks/report/libfuzzer_report.rs +++ b/src/agent/onefuzz-agent/src/tasks/report/libfuzzer_report.rs @@ -150,7 +150,7 @@ pub async fn test_input(args: TestInputArgs<'_>) -> Result { input_sha256, args.minimized_stack_depth, ); - Ok(CrashTestResult::CrashReport(crash_report)) + Ok(CrashTestResult::CrashReport(Box::new(crash_report))) } None => { let no_repro = NoCrash { @@ -163,7 +163,7 @@ pub async fn test_input(args: TestInputArgs<'_>) -> Result { error: test_report.error.map(|e| format!("{}", e)), }; - Ok(CrashTestResult::NoRepro(no_repro)) + Ok(CrashTestResult::NoRepro(Box::new(no_repro))) } } }