Merge pull request #309 from microsoft/main

Fork Sync: Update from parent repository

Author: AdamL-Microsoft

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

@@ -16,10 +16,10 @@ use uuid::Uuid;
 
 use tokio::sync::broadcast::{error::TryRecvError, Receiver};
 
-const LOGS_BUFFER_SIZE: usize = 100;
+const LOGS_BUFFER_SIZE: usize = 1000;
 const MAX_LOG_SIZE: u64 = 100000000; // 100 MB
-const DEFAULT_LOGGING_INTERVAL: Duration = Duration::from_secs(60);
-const DEFAULT_POLLING_INTERVAL: Duration = Duration::from_secs(5);
+const DEFAULT_LOGGING_INTERVAL: Duration = Duration::from_secs(20);
+const DEFAULT_POLLING_INTERVAL: Duration = Duration::from_secs(3);
 
 #[derive(Debug, Deserialize)]
 #[serde(rename_all = "PascalCase")]

src/agent/onefuzz-telemetry/src/lib.rs

@@ -254,7 +254,7 @@ mod global {
 
     lazy_static! {
         pub static ref EVENT_SOURCE: RwLock<Option<Sender<LoggingEvent>>> = {
-            let (telemetry_event_source, _) = broadcast::channel::<_>(100);
+            let (telemetry_event_source, _) = broadcast::channel::<_>(5000);
             RwLock::new(Some(telemetry_event_source))
         };
     }