diff --git a/core-dump-agent/src/main.rs b/core-dump-agent/src/main.rs index 8394edb..3bea535 100644 --- a/core-dump-agent/src/main.rs +++ b/core-dump-agent/src/main.rs @@ -292,7 +292,7 @@ async fn process_file(zip_path: &Path, bucket: &Bucket) { let f = File::open(zip_path).expect("no file found"); - match f.try_lock(FileLockMode::Shared) { + match AdvisoryFileLock::try_lock(&f, FileLockMode::Shared) { Ok(_) => { /* If we can lock then we are ok */ } Err(e) => { let l_inotify = env::var("USE_INOTIFY") diff --git a/core-dump-composer/src/events.rs b/core-dump-composer/src/events.rs index 82bae9c..6d1a501 100644 --- a/core-dump-composer/src/events.rs +++ b/core-dump-composer/src/events.rs @@ -87,7 +87,7 @@ impl CoreEvent { pub fn write_event(&self, eventlocation: &str) -> Result<(), anyhow::Error> { let full_path = format!("{}/{}-event.json", eventlocation, self.uuid); let file = File::create(full_path)?; - file.lock(FileLockMode::Exclusive)?; + AdvisoryFileLock::lock(&file, FileLockMode::Exclusive)?; serde_json::to_writer(&file, &self)?; file.unlock()?; Ok(()) diff --git a/core-dump-composer/src/main.rs b/core-dump-composer/src/main.rs index d1bfb2d..8ea2fc6 100644 --- a/core-dump-composer/src/main.rs +++ b/core-dump-composer/src/main.rs @@ -131,7 +131,7 @@ fn handle(mut cc: config::CoreConfig) -> Result<(), anyhow::Error> { process::exit(1); } }; - file.lock(FileLockMode::Exclusive)?; + AdvisoryFileLock::lock(&file, FileLockMode::Exclusive)?; let mut zip = ZipWriter::new(&file); debug!(