Function watcher_git_run

src/watcher/watcher.c:323–453

Run one literal argv vector in a contained process tree. active_git is * published under projects_lock before supervision starts, so stop/unwatch can * request cancellation without racing destruction of the handle. */

 * published under projects_lock before supervision starts, so stop/unwatch can
 * request cancellation without racing destruction of the handle. */
static watcher_git_status_t watcher_git_run(cbm_watcher_t *w, project_state_t *state,
                                            const char *const *argv, size_t output_limit,
                                            watcher_git_output_t *output) {
    if (!w || !state || !argv || !argv[0]) {
        return WATCHER_GIT_SUPERVISION_FAILED;
    }
    if (output) {
        memset(output, 0, sizeof(*output));
    }
    if (output_limit > 0 && (!output || !watcher_git_output_create(output))) {
        return WATCHER_GIT_SUPERVISION_FAILED;
    }

#ifdef _WIN32
    char git_executable[CBM_SZ_4K];
    if (!watcher_resolve_git_executable(git_executable)) {
        watcher_git_output_cleanup(output);
        return WATCHER_GIT_SUPERVISION_FAILED;
    }
#endif

    cbm_proc_opts_t options = {
#ifdef _WIN32
        .bin = git_executable,
#else
        .bin = argv[0],
#endif
        .argv = argv,
        .log_file = output_limit > 0 ? output->path : NULL,
        /* A wall deadline below is authoritative. Binary `status -z` output
         * deliberately has no line-based quiet-timeout semantics. */
        .quiet_timeout_ms = 0,
        .cancel_grace_ms = CBM_SUBPROCESS_DEFAULT_CANCEL_GRACE_MS,
        .delete_log_on_exit = false,
    };
    cbm_subprocess_t *process = NULL;
    if (cbm_subprocess_spawn(&options, &process) != 0) {
        watcher_git_output_cleanup(output);
        return WATCHER_GIT_SUPERVISION_FAILED;
    }

    bool cancelled = false;
    bool deadline_expired = false;
    bool output_exceeded = false;
    bool publication_conflict = false;
    cbm_mutex_lock(&w->projects_lock);
    if (state->active_git) {
        publication_conflict = true;
        cancelled = cbm_subprocess_request_cancel(process);
    } else {
        state->active_git = process;
    }
    if (!cancelled && (atomic_load_explicit(&w->stopped, memory_order_acquire) ||
                       !atomic_load_explicit(&state->registered, memory_order_acquire))) {
        cancelled = cbm_subprocess_request_cancel(process);
    }
    cbm_mutex_unlock(&w->projects_lock);