Function cbm_daemon_client_connected

src/daemon/daemon.c:393–423

}

cbm_daemon_client_id_t cbm_daemon_client_connected(cbm_daemon_coordinator_t *coordinator,
                                                   uint64_t now_ms) {
    if (!coordinator) {
        return CBM_DAEMON_CLIENT_ID_INVALID;
    }

    cbm_daemon_client_t *client = malloc(sizeof(*client));
    if (!client) {
        return CBM_DAEMON_CLIENT_ID_INVALID;
    }

    cbm_mutex_lock(&coordinator->mutex);
    if (coordinator->state != CBM_DAEMON_COORDINATOR_RUNNING) {
        cbm_mutex_unlock(&coordinator->mutex);
        free(client);
        return CBM_DAEMON_CLIENT_ID_INVALID;
    }
    cbm_daemon_client_id_t client_id = issue_client_id_locked(coordinator);
    if (client_id == CBM_DAEMON_CLIENT_ID_INVALID) {
        cbm_mutex_unlock(&coordinator->mutex);
        free(client);
        return CBM_DAEMON_CLIENT_ID_INVALID;
    }
    client->id = client_id;
    client->last_heartbeat_ms = now_ms;
    client->next = coordinator->clients;
    coordinator->clients = client;
    coordinator->client_count++;
    cbm_mutex_unlock(&coordinator->mutex);
    return client_id;
}

bool cbm_daemon_client_disconnected(cbm_daemon_coordinator_t *coordinator,
                                    cbm_daemon_client_id_t client_id, uint64_t now_ms) {