From 218c0e5cda9413c24b3a5d701b59088f5b147669 Mon Sep 17 00:00:00 2001 From: Johann Wagner Date: Wed, 22 Nov 2023 14:44:21 +0100 Subject: [PATCH] Increasing log sizes --- vicky/src/lib/logs/mod.rs | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/vicky/src/lib/logs/mod.rs b/vicky/src/lib/logs/mod.rs index 1ff18c3..c1692e6 100644 --- a/vicky/src/lib/logs/mod.rs +++ b/vicky/src/lib/logs/mod.rs @@ -20,7 +20,7 @@ pub struct LogDrain { impl LogDrain { pub fn new(s3_client: S3Client) -> &'static LogDrain { - let (tx, rx1) = broadcast::channel(100); + let (tx, rx1) = broadcast::channel(1000); let s3_client_m = Box::leak(Box::new(s3_client.clone())); @@ -88,7 +88,7 @@ impl LogDrain { // Immediate Retry, doing our best efford ehre. }, Err(TryRecvError::Empty) => { - tokio::time::sleep(time::Duration::from_millis(100)).await; + tokio::time::sleep(time::Duration::from_millis(10)).await; }, } }