From 44d8915afea8d36aa89b7fc694369299159f9a96 Mon Sep 17 00:00:00 2001 From: Baitinq Date: Fri, 31 May 2024 00:12:56 +0200 Subject: BATCHING BROKE FS_TRACER EXITING --- fs-tracer/src/main.rs | 19 ++++++++++--------- 1 file changed, 10 insertions(+), 9 deletions(-) diff --git a/fs-tracer/src/main.rs b/fs-tracer/src/main.rs index a6d41b7..4e59469 100644 --- a/fs-tracer/src/main.rs +++ b/fs-tracer/src/main.rs @@ -109,18 +109,19 @@ async fn main() -> Result<(), anyhow::Error> { } info!("Waiting for threads to stop"); + let mut batched_req = vec![]; + let mut i = 0; for elt in resolved_files_recv { - // TODO: Batching. + batched_req.push(elt); + i += 1; + // Batching. + if i % 40 != 0 { + continue; + } + let request_body = format!("[{}]", batched_req.join(",")); let resp = ureq::post(&url) .set("API_KEY", &fs_tracer_api_key) - .send_string(&format!( - r#" - [ - {} - ] - "#, - elt - )) + .send_string(&request_body) .expect("Failed to send request"); if resp.status() != 200 { panic!("Failed to send request: {:?}", resp); -- cgit 1.4.1