Function cbm_daemon_expire_leases

src/daemon/daemon.c:467–493

}

size_t cbm_daemon_expire_leases(cbm_daemon_coordinator_t *coordinator, uint64_t now_ms) {
    if (!coordinator) {
        return 0;
    }

    size_t expired_count = 0;
    cbm_daemon_callback_batch_t batch;
    cbm_mutex_lock(&coordinator->mutex);
    callback_batch_init_locked(coordinator, &batch);
    cbm_daemon_client_t **cursor = &coordinator->clients;
    while (*cursor) {
        cbm_daemon_client_t *client = *cursor;
        bool expired = now_ms >= client->last_heartbeat_ms &&
                       now_ms - client->last_heartbeat_ms >= coordinator->lease_timeout_ms;
        if (!expired) {
            cursor = &client->next;
            continue;
        }
        *cursor = client->next;
        release_client_locked(coordinator, client, &batch);
        expired_count++;
    }
    cbm_mutex_unlock(&coordinator->mutex);

    callback_batch_run(coordinator, &batch);
    return expired_count;
}

size_t cbm_daemon_active_clients(cbm_daemon_coordinator_t *coordinator) {
    if (!coordinator) {