Method with_repo_lock

src/git_sync.rs:25–47

Perform a git operation with both in-process and cross-process synchronization.

(&self, repo_path: &Path, operation: F)

    /// Perform a git operation with both in-process and cross-process synchronization.
    pub async fn with_repo_lock<F, Fut, T>(&self, repo_path: &Path, operation: F) -> T
    where
        F: FnOnce() -> Fut,
        Fut: std::future::Future<Output = T>,
    {
        let canonical_path = canonicalize_path(repo_path);

        let lock = self.get_or_create_lock(&canonical_path).await;
        let _guard = lock.lock().await;

        let lock_dir = crate::repo_utils::resolve_git_common_dir(&canonical_path)
            .unwrap_or_else(|_| canonical_path.join(".git"));
        let lock_path = lock_dir.join("tsk.lock");
        let _flock_file = acquire_flock(lock_path.clone()).await.unwrap_or_else(|e| {
            panic!(
                "Failed to acquire repository file lock at {}: {}",
                lock_path.display(),
                e
            )
        });

        operation().await
    }

    /// Get or create an in-process lock for a canonicalized repository path.
    async fn get_or_create_lock(&self, canonical_path: &Path) -> Arc<Mutex<()>> {