Function cbm_httpd_read_request

src/ui/httpd.c:603–693

/* ── Request reading ──────────────────────────────────────────── */

int cbm_httpd_read_request(cbm_http_conn_t *c, cbm_http_req_t *req) {
    if (!c || !req)
        return -1;

    char *head = malloc(CBM_HTTP_MAX_HEAD);
    if (!head)
        return -1;

    int64_t deadline = now_ms() + c->recv_deadline_ms;
    size_t have = 0;
    size_t body_off = 0, clen = 0;
    int rc = CBM_HTTP_NEED_MORE;

    /* Read until the head parses (or fails to). */
    for (;;) {
        int w = wait_connection_ready(c, false, deadline);
        if (w == 0) {
            free(head);
            return 408;
        }
        if (w < 0) {
            free(head);
            return -1;
        }
#ifdef _WIN32
        int n = recv(c->fd, head + have, (int)(CBM_HTTP_MAX_HEAD - have), 0);
#else
        ssize_t n = recv(c->fd, head + have, CBM_HTTP_MAX_HEAD - have, 0);
#endif
        if (n < 0 && socket_would_block())
            continue;
        if (n <= 0) {
            free(head); /* peer vanished mid-request — nothing to answer */
            return -1;
        }
        have += (size_t)n;

        rc = cbm_http_parse_head(head, have, req, &body_off, &clen);
        if (rc == 0)
            break;
        if (rc != CBM_HTTP_NEED_MORE) {
            free(head);
            return rc;
        }
        if (have >= CBM_HTTP_MAX_HEAD) {
            free(head);
            return 431;
        }
    }

    /* Read the body per Content-Length (already capped by the parser). */
    if (clen > 0) {
        char *body = malloc(clen + 1);
        if (!body) {
            free(head);
            return -1;
        }
        size_t got = have - body_off;