Function thd

tests/tools/insert.c:317–362

}

void *thd(void *arg)
{
    int64_t now = timems(), end = now + runtime * 1000;
    char *readnode;
    cdb2_hndl_tp *db;
    int rc;

    rc = cdb2_open(&db, dbname, cltype, CDB2_RANDOM);
    if (rc) {
        tdprintf(stderr, db, __func__, __LINE__, "thd: open rc %d %s\n", rc,
                 cdb2_errstr(db));
        cdb2_close(db);
        myexit(__func__, __LINE__, 1);
    }

    if (is_hasql) {
        rc = cdb2_run_statement(db, "set hasql on");
        if (rc) {
            tdprintf(stderr, db, __func__, __LINE__,
                     "thd: set hasql on rc %d, %s\n", rc, cdb2_errstr(db));
            cdb2_close(db);
            myexit(__func__, __LINE__, 1);
        }
    }

    if (debug_trace) {
        cdb2_set_debug_trace(db);
    }

    if (!(readnode = read_node(db)))
        tdprintf(stderr, db, __func__, __LINE__,
                 "Couldn't determine read node for thread\n");
    else {
        if (debug_trace)
            tdprintf(stderr, db, __func__, __LINE__, "read node is %s\n",
                     readnode);
    }

    while (now < end) {
        insert(&db, readnode);
        now = timems();
    }
    cdb2_close(db);
    if (readnode) free(readnode);
    return NULL;
}

void check(void)
{