Function application_job_wait_for_mutations

src/daemon/application.c:1030–1045

}

static bool application_job_wait_for_mutations(cbm_daemon_application_job_t *job) {
    cbm_daemon_application_t *application = job->application;
    for (;;) {
        cbm_mutex_lock(&application->mutex);
        bool cancelled = job->cancel_requested || application->stopping;
        bool busy = application_mutation_conflicts_locked(application, job->project_key);
        cbm_mutex_unlock(&application->mutex);
        if (cancelled) {
            return false;
        }
        if (!busy) {
            return true;
        }
        cbm_usleep(APPLICATION_JOB_POLL_US);
    }
}

static void application_cancelled_result(cbm_index_worker_result_t *result) {
    memset(result, 0, sizeof(*result));