Function cdb2_read_record

cdb2api/cdb2api.c:2766–2908

}

static int cdb2_read_record(cdb2_hndl_tp *hndl, uint8_t **buf, int *len, int *type)
{
    /* Got response */
    SBUF2 *sb = hndl->sb;
    struct newsqlheader hdr = {0};
    int b_read;
    int rc = 0; /* Make compilers happy. */

    void *callbackrc;
    int overwrite_rc = 0;
    cdb2_event *e = NULL;

    while ((e = cdb2_next_callback(hndl, CDB2_BEFORE_READ_RECORD, e)) != NULL) {
        callbackrc = cdb2_invoke_callback(hndl, e, 0);
        PROCESS_EVENT_CTRL_BEFORE(hndl, e, rc, callbackrc, overwrite_rc);
    }

    if (overwrite_rc)
        goto after_callback;

retry:
    b_read = sbuf2fread((char *)&hdr, 1, sizeof(hdr), sb);
    debugprint("READ HDR b_read=%d, sizeof(hdr)=(%zu):\n", b_read, sizeof(hdr));

    if (b_read != sizeof(hdr)) {
        debugprint("bad read or numbytes, b_read=%d, sizeof(hdr)=(%zu):\n",
                   b_read, sizeof(hdr));
        rc = -1;
        /* In TLS 1.3, client authentication happens after handshake (RFC 8446).
           An invalid client (e.g., a revoked cert) may see a successful
           handshake but encounter an error when reading data from the server.
           Catch the error here. */
        if ((hndl->sslerr = sbuf2lasterror(sb, NULL, 0)))
            sbuf2lasterror(sb, hndl->errstr, sizeof(hndl->errstr));
        goto after_callback;
    }

    hdr.type = ntohl(hdr.type);
    hdr.compression = ntohl(hdr.compression);
    hdr.state = ntohl(hdr.state);
    hdr.length = ntohl(hdr.length);
    hndl->ack = (hdr.type == RESPONSE_HEADER__SQL_RESPONSE_PING);

    /* Server requires SSL. Return the header type in `type'.
       We may reach here under DIRECT_CPU mode where we skip DBINFO lookup. */
    if (hdr.type == RESPONSE_HEADER__SQL_RESPONSE_SSL) {
        if (type == NULL) {
            rc = -1;
            goto after_callback;
        }
        *type = hdr.type;
        rc = 0;
        goto after_callback;
    }

    if (hdr.length == 0) {
        debugprint("hdr length (0) from mach %s - going to retry\n",
                   hndl->hosts[hndl->connected_host]);