Method with_lock

src/docker/proxy_manager.rs:56–77

Execute an operation while holding both in-process and cross-process locks for the given proxy fingerprint.

(&self, fingerprint: &str, operation: F)

    /// Execute an operation while holding both in-process and cross-process locks
    /// for the given proxy fingerprint.
    async fn with_lock<F, Fut, T>(&self, fingerprint: &str, operation: F) -> T
    where
        F: FnOnce() -> Fut,
        Fut: std::future::Future<Output = T>,
    {
        let lock = self.get_or_create_lock(fingerprint).await;
        let _guard = lock.lock().await;

        let lock_path = self.lock_path(fingerprint);
        if let Some(parent) = lock_path.parent() {
            let _ = std::fs::create_dir_all(parent);
        }
        let _flock_file = acquire_flock(lock_path.clone()).await.unwrap_or_else(|e| {
            panic!(
                "Failed to acquire proxy file lock at {}: {}",
                lock_path.display(),
                e
            )
        });

        operation().await
    }

    /// Get or create an in-process lock for a proxy fingerprint.
    async fn get_or_create_lock(&self, fingerprint: &str) -> Arc<Mutex<()>> {