diff --git a/src/agent/rustjail/src/cgroups/notifier.rs b/src/agent/rustjail/src/cgroups/notifier.rs index c81da53b4a..1b4750a02a 100644 --- a/src/agent/rustjail/src/cgroups/notifier.rs +++ b/src/agent/rustjail/src/cgroups/notifier.rs @@ -191,7 +191,10 @@ async fn register_memory_event( let content = fs::read_to_string(path.clone()); info!( sl!(), - "OOM event for container: {}, content: {:?}", &containere_id, content + "cgroup event for container: {}, path: {:?}, content: {:?}", + &containere_id, + &path, + content ); } } diff --git a/src/agent/src/sandbox.rs b/src/agent/src/sandbox.rs index 946d1f4097..94b65f1d20 100644 --- a/src/agent/src/sandbox.rs +++ b/src/agent/src/sandbox.rs @@ -317,7 +317,13 @@ impl Sandbox { tokio::spawn(async move { loop { let event = rx.recv().await; + // None means the container has exited, + // and sender in OOM notifier is dropped. + if event.is_none() { + return; + } info!(logger, "got an OOM event {:?}", event); + let _ = tx .send(container_id.clone()) .await