fix: Memory profile not outputing data

deepflowio · Sep 12, 2024 · 1c78046 · 1c78046
1 parent 80bcff4
commit 1c78046
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/agent/src/ebpf_dispatcher/memory_profile.rs b/agent/src/ebpf_dispatcher/memory_profile.rs
@@ -231,6 +231,13 @@ impl MemoryContext {
             }
         }
 
+        if !batch.is_empty() {
+            if let Err(e) = sender.send_all(&mut batch) {
+                warn!("output queue failed to send data: {e}");
+                batch.clear();
+            }
+        }
+
         for pid in dead_pids {
             self.processes.remove(&pid);
         }