From ecd60d317a1df1fa3920063d110d7f7aeb4b34da Mon Sep 17 00:00:00 2001 From: Tunglies <77394545+Tunglies@users.noreply.github.com> Date: Wed, 30 Sep 2026 22:12:10 +0800 Subject: [PATCH] refactor(service): drop redundant provider sync serial lock --- src-tauri/src/core/service.rs | 12 ++++-------- 1 file changed, 4 insertions(+), 8 deletions(-) diff --git a/src-tauri/src/core/service.rs b/src-tauri/src/core/service.rs index 498d087eb..fa1bc012b 100644 --- a/src-tauri/src/core/service.rs +++ b/src-tauri/src/core/service.rs @@ -1008,7 +1008,6 @@ fn decode_hex(encoded: &str) -> Result> { } static PROVIDER_SYNC_QUEUED: AtomicBool = AtomicBool::new(false); -static PROVIDER_SYNC_SERIAL: Lazy> = Lazy::new(|| tokio::sync::Mutex::new(())); static SYNC_TEMP_SEQUENCE: AtomicU64 = AtomicU64::new(0); const RUNTIME_PROVIDER_SYNC_ATTEMPTS: u32 = 4; const CONTENT_COMPARE_CHUNK: usize = 64 * 1024; @@ -1027,13 +1026,10 @@ pub(crate) fn request_runtime_provider_sync(delay: Duration) { ), |index| async move { let attempt = index as u32 + 1; - let outcome = { - let _serial = PROVIDER_SYNC_SERIAL.lock().await; - if attempt == 1 { - PROVIDER_SYNC_QUEUED.store(false, Ordering::Release); - } - sync_runtime_providers_by_service().await - }; + if attempt == 1 { + PROVIDER_SYNC_QUEUED.store(false, Ordering::Release); + } + let outcome = sync_runtime_providers_by_service().await; match outcome { Ok(ProviderSync { pending: 0, .. }) => Ok(()), Ok(ProviderSync { pending, .. }) if attempt < RUNTIME_PROVIDER_SYNC_ATTEMPTS => {