From a5ad49451e80cae7ec7f5d2a216084aa30e2e704 Mon Sep 17 00:00:00 2001 From: metamuffin Date: Fri, 5 Jan 2024 02:38:34 +0100 Subject: atomic cache insertion --- import/src/lib.rs | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) (limited to 'import/src') diff --git a/import/src/lib.rs b/import/src/lib.rs index 2dbf994..6a725c8 100644 --- a/import/src/lib.rs +++ b/import/src/lib.rs @@ -285,9 +285,9 @@ async fn process_source( } insert_node(&id, node)?; } else if media_path.is_file() { + let _permit = SEM_IMPORT.acquire().await.unwrap(); let location_path = location.path(); let metadata = { - let _permit = SEM_IMPORT.acquire().await.unwrap(); spawn_blocking(move || { cache_memory( &["mkv-probe", location.path().to_str().unwrap()], @@ -365,7 +365,7 @@ async fn process_source( ); } } - + drop(_permit); insert_node(&id, node)?; } else { warn!("non file/dir import ignored: {media_path:?}") -- cgit v1.2.3-70-g09d2