Function application_update_thread

src/daemon/application.c:1777–1826

}

static void *application_update_thread(void *opaque) {
    cbm_daemon_application_t *application = opaque;
    cbm_daemon_application_update_worker_t worker = NULL;
    if (application->update_ops.start(application->update_ops.context, &worker) != 0 || !worker) {
        cbm_mutex_lock(&application->mutex);
        application_update_publish_terminal_locked(application, NULL, false);
        cbm_mutex_unlock(&application->mutex);
        return NULL;
    }

    cbm_mutex_lock(&application->mutex);
    application->update_worker = worker;
    if (application->update_cancel_requested || application->stopping ||
        application->update_owners == 0) {
        application_update_cancel_locked(application);
    }
    cbm_mutex_unlock(&application->mutex);

    const char *latest_version = NULL;
    for (;;) {
        cbm_daemon_application_update_poll_t status =
            application->update_ops.poll(application->update_ops.context, worker, &latest_version);
        if (status != CBM_DAEMON_APPLICATION_UPDATE_POLL_RUNNING) {
            if (status == CBM_DAEMON_APPLICATION_UPDATE_POLL_ERROR) {
                latest_version = NULL;
            }
            break;
        }
        cbm_mutex_lock(&application->mutex);
        if (application->update_cancel_requested || application->stopping ||
            application->update_owners == 0) {
            application_update_cancel_locked(application);
        }
        cbm_mutex_unlock(&application->mutex);
        cbm_usleep(APPLICATION_UPDATE_POLL_US);
    }

    char version[APPLICATION_UPDATE_VERSION_CAP] = {0};
    if (latest_version && strlen(latest_version) < sizeof(version)) {
        (void)snprintf(version, sizeof(version), "%s", latest_version);
    }
    cbm_mutex_lock(&application->mutex);
    bool completed_generation = !application->update_cancel_requested && !application->stopping &&
                                application->update_owners > 0;
    application_update_publish_terminal_locked(application, version[0] ? version : NULL,
                                               completed_generation);
    cbm_mutex_unlock(&application->mutex);
    application->update_ops.destroy(application->update_ops.context, worker);
    return NULL;
}

static void application_update_subscribe_locked(cbm_daemon_application_session_t *session) {
    cbm_daemon_application_t *application = session->application;