Function check

tests/tools/insert.c:364–443

}

void check(void)
{
    cdb2_hndl_tp *db;
    int rc, reopen_count = 0;

reopen:
    rc = cdb2_open(&db, dbname, cltype, 0);
    if (rc) {
        tdprintf(stderr, db, __func__, __LINE__, "check: open rc %d %s\n", rc,
                 cdb2_errstr(db));
        cdb2_close(db);
        myexit(__func__, __LINE__, 1);
    }
    cdb2_hndl_set_max_retries(db, max_retries);
    if (debug_trace) {
        cdb2_set_debug_trace(db);
    }

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

    rc = cdb2_run_statement(db, "set transaction serializable");
    if (rc) {
        tdprintf(stderr, db, __func__, __LINE__,
                 "set serializable: run rc %d %s\n", rc, cdb2_errstr(db));
        cdb2_close(db);
        myexit(__func__, __LINE__, 1);
    }

    char *host = read_node(db);
    ;
    tdprintf(stderr, db, __func__, __LINE__, "check results run on %s\n", host);

    rc = cdb2_run_statement(db, "select value from jepsen order by value");
    if (rc) {
        tdprintf(stderr, db, __func__, __LINE__, "check: run rc %d %s\n", rc,
                 cdb2_errstr(db));
        cdb2_close(db);
        if (rc == 402) {
            sleep(1);
            reopen_count++;
            tdprintf(stderr, db, __func__, __LINE__, "%s reopen count is %d\n",
                     __func__, reopen_count);
            goto reopen;
        }
        myexit(__func__, __LINE__, 1);
    }
    rc = cdb2_next_record(db);
    while (rc == CDB2_OK) {
        int v = (int)*(long long *)cdb2_column_value(db, 0);
        if (v < 0 || v > largest) {
            fprintf(stderr, "unexpected value %d\n", v);
            goto next;