Function runtime_worker_handle_status

src/daemon/runtime.c:1509–1555

}

static void runtime_worker_handle_status(cbm_daemon_runtime_worker_t *worker,
                                         const uint8_t *payload, uint32_t length) {
    cbm_daemon_runtime_service_t *service = worker->service;
    char requested_build[CBM_DAEMON_BUILD_FINGERPRINT_SIZE] = {0};
    bool peer_verified =
        runtime_control_request_decode(payload, length, requested_build) &&
        runtime_activation_peer_matches_claim(service, worker->peer_process_id, requested_build);
    uint8_t response[CBM_DAEMON_STATUS_RESPONSE_SIZE];
    memset(response, 0, sizeof(response));
    if (peer_verified) {
        uint8_t count = 0U;
        uint32_t pids[CBM_DAEMON_CONTROL_CLIENT_CAP] = {0};
        cbm_mutex_lock(&service->mutex);
        response[0] = 1U;
        response[1] =
            (uint8_t)((service->permanent ? 0x01U : 0U) |
                      (service->state != CBM_DAEMON_RUNTIME_SERVICE_RUNNING ? 0x02U : 0U));
        uint16_t committed = service->committed_clients > UINT16_MAX
                                 ? UINT16_MAX
                                 : (uint16_t)service->committed_clients;
        response[2] = (uint8_t)(committed >> 8);
        response[3] = (uint8_t)(committed & 0xFFU);
        uint32_t daemon_pid = (uint32_t)runtime_current_process_id();
        response[4] = (uint8_t)(daemon_pid >> 24);
        response[5] = (uint8_t)(daemon_pid >> 16);
        response[6] = (uint8_t)(daemon_pid >> 8);
        response[7] = (uint8_t)(daemon_pid & 0xFFU);
        runtime_control_collect_clients_locked(service, worker, &count, pids);
        response[8] = count;
        for (size_t index = 0; index < CBM_DAEMON_CONTROL_CLIENT_CAP; index++) {
            size_t offset = 12U + index * 4U;
            response[offset] = (uint8_t)(pids[index] >> 24);
            response[offset + 1U] = (uint8_t)(pids[index] >> 16);
            response[offset + 2U] = (uint8_t)(pids[index] >> 8);
            response[offset + 3U] = (uint8_t)(pids[index] & 0xFFU);
        }
        (void)snprintf((char *)response + 44U, CBM_DAEMON_BUILD_FINGERPRINT_SIZE, "%s",
                       service->identity.build_fingerprint);
        (void)snprintf((char *)response + 109U, 12U, "%s",
                       service->identity.semantic_version ? service->identity.semantic_version
                                                          : "");
        cbm_mutex_unlock(&service->mutex);
    }
    (void)runtime_worker_send_frame(worker, CBM_DAEMON_FRAME_RESPONSE, CBM_DAEMON_RUNTIME_OP_STATUS,
                                    response, (uint32_t)sizeof(response));
    runtime_worker_finish(worker);
}

static void runtime_worker_handle_stop(cbm_daemon_runtime_worker_t *worker, const uint8_t *payload,
                                       uint32_t length) {