Function cdb2_close

cdb2api/cdb2api.c:3584–3690

}

int cdb2_close(cdb2_hndl_tp *hndl)
{
    cdb2_event *curre;
    void *callbackrc;
    int rc = 0;

    if (log_calls)
        fprintf(stderr, "%p> cdb2_close(%p)\n", (void *)pthread_self(), hndl);

    if (!hndl)
        return 0;

    if (hndl->fdb_hndl) {
        cdb2_close(hndl->fdb_hndl);
        hndl->fdb_hndl = NULL;
    }

    if (hndl->ack)
        ack(hndl);

    if (hndl->auto_consume_timeout_ms > 0 && hndl->sb && !hndl->in_trans && hndl->firstresponse &&
        (!hndl->lastresponse || (hndl->lastresponse->response_type != RESPONSE_TYPE__LAST_ROW))) {
        int nrec = 0;
        sbuf2settimeout(hndl->sb, hndl->auto_consume_timeout_ms, hndl->auto_consume_timeout_ms);
        struct timeval tv;
        gettimeofday(&tv, NULL);
        uint64_t starttimems = ((uint64_t)tv.tv_sec) * 1000 + tv.tv_usec / 1000;
        while (cdb2_next_record_int(hndl, 0) == CDB2_OK) {
            nrec++;
            gettimeofday(&tv, NULL);
            uint64_t curr = ((uint64_t)tv.tv_sec) * 1000 + tv.tv_usec / 1000;
            /* auto consume for up to CDB2_AUTO_CONSUME_TIMEOUT_MS */
            if (curr - starttimems >= hndl->auto_consume_timeout_ms)
                break;
        }
        if (hndl->debug_trace) {
            gettimeofday(&tv, NULL);
            uint64_t curr = ((uint64_t)tv.tv_sec) * 1000 + tv.tv_usec / 1000;
            fprintf(stderr, "%s: auto consume %d records took %" PRIu64 " ms\n",
                    __func__, nrec, curr - starttimems);
        }
    }

    if (hndl->sb)
        newsql_disconnect(hndl, hndl->sb, __LINE__);

    if (hndl->firstresponse) {
        cdb2__sqlresponse__free_unpacked(hndl->firstresponse, NULL);
        free((void *)hndl->first_buf);
        hndl->first_buf = NULL;
    }

    if (hndl->lastresponse) {
        if (hndl->protobuf_used_sysmalloc)
            cdb2__sqlresponse__free_unpacked(hndl->lastresponse,
                                             &hndl->allocator);
        hndl->protobuf_offset = 0;
        free((void *)hndl->last_buf);