diff options
| author | metamuffin <metamuffin@disroot.org> | 2024-01-05 02:38:34 +0100 |
|---|---|---|
| committer | metamuffin <metamuffin@disroot.org> | 2024-01-05 02:38:34 +0100 |
| commit | a5ad49451e80cae7ec7f5d2a216084aa30e2e704 (patch) | |
| tree | 9fafbfed0c539045dcabb2fcf56539e8c35535af /import/src | |
| parent | 7608522c8fdf46b93877da3fee4f21df3496beec (diff) | |
| download | jellything-a5ad49451e80cae7ec7f5d2a216084aa30e2e704.tar jellything-a5ad49451e80cae7ec7f5d2a216084aa30e2e704.tar.bz2 jellything-a5ad49451e80cae7ec7f5d2a216084aa30e2e704.tar.zst | |
atomic cache insertion
Diffstat (limited to 'import/src')
| -rw-r--r-- | import/src/lib.rs | 4 |
1 files changed, 2 insertions, 2 deletions
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:?}") |