Function cbm_daemon_job_unsubscribe

src/daemon/daemon.c:629–656

}

bool cbm_daemon_job_unsubscribe(cbm_daemon_coordinator_t *coordinator,
                                cbm_daemon_client_id_t client_id,
                                cbm_daemon_subscription_id_t subscription_id) {
    if (!coordinator || client_id == CBM_DAEMON_CLIENT_ID_INVALID ||
        subscription_id == CBM_DAEMON_SUBSCRIPTION_ID_INVALID) {
        return false;
    }

    cbm_daemon_callback_batch_t batch;
    cbm_mutex_lock(&coordinator->mutex);
    callback_batch_init_locked(coordinator, &batch);
    if (!find_client_locked(coordinator, client_id)) {
        cbm_mutex_unlock(&coordinator->mutex);
        return false;
    }
    bool removed = false;
    for (cbm_daemon_job_t *job = coordinator->jobs; job; job = job->next) {
        removed = remove_subscription_locked(&job->subscriptions, &job->subscription_count,
                                             client_id, subscription_id);
        if (removed) {
            request_job_cancel_locked(coordinator, job, &batch);
            break;
        }
    }
    cbm_mutex_unlock(&coordinator->mutex);
    callback_batch_run(coordinator, &batch);
    return removed;
}

bool cbm_daemon_watch_unsubscribe(cbm_daemon_coordinator_t *coordinator,
                                  cbm_daemon_client_id_t client_id,