Better logging of failure in the task_logger

src/agent/onefuzz-agent/src/validations.rs

@@ -64,10 +64,11 @@ async fn validate_libfuzzer(config: ValidationConfig) -> Result<()> {
     let libfuzzer = LibFuzzer::new(
         &config.target_exe,
         config.target_options.clone(),
-        config.target_env.into_iter().collect(),
+        config.target_env.iter().cloned().collect(),
         config
             .setup_folder
-            .unwrap_or(config.target_exe.parent().unwrap().to_path_buf()),
+            .clone()
+            .unwrap_or_else(|| config.target_exe.parent().unwrap().to_path_buf()),
         None::<&PathBuf>,
         MachineIdentity {
             machine_id: Uuid::nil(),
@@ -103,10 +104,11 @@ async fn get_logs(config: ValidationConfig) -> Result<()> {
     let libfuzzer = LibFuzzer::new(
         &config.target_exe,
         config.target_options.clone(),
-        config.target_env.into_iter().collect(),
+        config.target_env.iter().cloned().collect(),
         config
             .setup_folder
-            .unwrap_or(config.target_exe.parent().unwrap().to_path_buf()),
+            .clone()
+            .unwrap_or_else(|| config.target_exe.parent().unwrap().to_path_buf()),
         None::<&PathBuf>,
         MachineIdentity {
             machine_id: Uuid::nil(),

src/agent/onefuzz-task/src/tasks/task_logger.rs

@@ -422,8 +422,8 @@ impl TaskLogger {
                     }) => break,
                     Ok(c) => c,
                     Err(e) => {
-                        error!("{}", e);
-                        break;
+                        error!("task logger failure {}", e);
+                        return Err(e);
                     }
                 };
             }
@@ -440,7 +440,10 @@ pub struct SpawnedLogger {
 
 impl SpawnedLogger {
     pub async fn flush_and_stop(self, timeout: Duration) -> Result<()> {
-        let _ = tokio::time::timeout(timeout, self.logger_handle).await;
+        if let Ok(Err(e)) = tokio::time::timeout(timeout, self.logger_handle).await {
+            error!("task logger failure {}", e);
+            return Err(e.into());
+        }
         Ok(())
     }
 }