ExternalVendorCode/onefuzz
1
0
Fork 0
mirror of https://github.com/microsoft/onefuzz.git synced 2025-06-18 12:48:07 +00:00
Code Issues Packages Projects Releases Wiki Activity

sync new inputs found by supervisor tasks (#484)

Browse Source
This commit is contained in:
bmc-msft
2021-01-28 21:33:30 -05:00
committed by GitHub
parent a46f7b4193
commit bcf42485eb
1 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/agent/onefuzz-agent/src/tasks/fuzz/supervisor.rs
View File

@ -16,7 +16,7 @@ use onefuzz::{
jitter::delay_with_jitter, jitter::delay_with_jitter,
process::monitor_process, process::monitor_process,
syncdir::{SyncOperation::Pull, SyncedDir}, syncdir::{SyncOperation::Pull, SyncedDir},
telemetry::Event::new_result, telemetry::Event::{new_coverage, new_result},
}; };
use serde::Deserialize; use serde::Deserialize;
use std::{ use std::{
@ -95,6 +95,7 @@ pub async fn spawn(config: SupervisorConfig) -> Result<(), Error> {
path: runtime_dir.path().join("inputs"), path: runtime_dir.path().join("inputs"),
url: config.inputs.url.clone(), url: config.inputs.url.clone(),
}; };
inputs.init().await?; inputs.init().await?;
if let Some(context) = &config.wait_for_files { if let Some(context) = &config.wait_for_files {
let dir = match context { let dir = match context {
@ -110,7 +111,7 @@ pub async fn spawn(config: SupervisorConfig) -> Result<(), Error> {
delay_with_jitter(delay).await; delay_with_jitter(delay).await;
} }
} }
let monitor_inputs = inputs.monitor_results(new_coverage);
let continuous_sync_task = inputs.continuous_sync(Pull, config.ensemble_sync_delay); let continuous_sync_task = inputs.continuous_sync(Pull, config.ensemble_sync_delay);
let process = start_supervisor( let process = start_supervisor(
@ -147,6 +148,7 @@ pub async fn spawn(config: SupervisorConfig) -> Result<(), Error> {
monitor_supervisor, monitor_supervisor,
monitor_stats, monitor_stats,
monitor_crashes, monitor_crashes,
monitor_inputs,
continuous_sync_task, continuous_sync_task,
monitor_reports_future, monitor_reports_future,
)?; )?;