diff options
| author | Baitinq <[email protected]> | 2024-06-11 23:39:55 +0200 |
|---|---|---|
| committer | Baitinq <[email protected]> | 2024-06-11 23:40:12 +0200 |
| commit | d7b44a1623768675dcbc828ca9169483f392966e (patch) | |
| tree | f0d5d89e23bec7bb334a0e1fffd178bdd7d98728 | |
| parent | fs-tracer: handle sending unbatched requests when exiting (diff) | |
| download | fs-tracer-d7b44a1623768675dcbc828ca9169483f392966e.tar.gz fs-tracer-d7b44a1623768675dcbc828ca9169483f392966e.tar.bz2 fs-tracer-d7b44a1623768675dcbc828ca9169483f392966e.zip | |
fs-tracer: remove unneeded comment
| -rw-r--r-- | fs-tracer/src/main.rs | 5 |
1 files changed, 1 insertions, 4 deletions
diff --git a/fs-tracer/src/main.rs b/fs-tracer/src/main.rs index 2a79db1..6fed8e5 100644 --- a/fs-tracer/src/main.rs +++ b/fs-tracer/src/main.rs @@ -75,8 +75,6 @@ async fn main() -> Result<(), anyhow::Error> { let (resolved_files_send, resolved_files_recv) = crossbeam_channel::unbounded(); - // Create arcmutex for the syscall handler in order to use it in threads - let mut handles = vec![]; let mut perf_array = AsyncPerfEventArray::try_from(bpf.take_map("EVENTS").unwrap())?; for cpu_id in online_cpus()? { @@ -112,8 +110,7 @@ async fn main() -> Result<(), anyhow::Error> { batched_req.push(elt); // Batching. TODO: we can probably increase this value but we need to increase max message // in kafka or compress or smth. We should probably batch taking into account the message - // size and also sent messages from multiple threads somehow. - // We might just need websockets + // size. if batched_req.len() < 4000 { continue; } |