marcoallegretti/karapace
1
0
Fork 0
mirror of https://github.com/marcoallegretti/karapace.git synced 2026-03-26 21:43:09 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

fix(runtime): handle corrupt running markers

Browse source
This commit is contained in:
Marco Allegretti 2026-02-25 13:30:28 +01:00
parent cad64482c0
commit e77bc35b2a
1 changed files with 15 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

16
crates/karapace-runtime/src/namespace.rs
View file

@ -328,7 +328,20 @@ impl RuntimeBackend for NamespaceBackend {
let running_file = env_dir.join(".running"); let running_file = env_dir.join(".running");
if running_file.exists() { if running_file.exists() {
let pid_str = std::fs::read_to_string(&running_file).unwrap_or_default(); let pid_str = match std::fs::read_to_string(&running_file) {
Ok(s) => s,
Err(e) => {
tracing::warn!(
"failed to read .running file for {}: {e}",
&env_id[..12.min(env_id.len())]
);
return Ok(RuntimeStatus {
env_id: env_id.to_owned(),
running: false,
pid: None,
});
}
};
let pid = pid_str.trim().parse::<u32>().ok(); let pid = pid_str.trim().parse::<u32>().ok();
if pid.is_none() && !pid_str.trim().is_empty() { if pid.is_none() && !pid_str.trim().is_empty() {
tracing::warn!( tracing::warn!(
@ -336,6 +349,7 @@ impl RuntimeBackend for NamespaceBackend {
&env_id[..12.min(env_id.len())], &env_id[..12.min(env_id.len())],
pid_str.trim() pid_str.trim()
); );
let _ = std::fs::remove_file(&running_file);
} }
// Check if process is actually alive // Check if process is actually alive
if let Some(p) = pid { if let Some(p) = pid {