Function reader_thread

tests/bench/fdb_bench.cc:343–387

}

void *reader_thread(void *args){
    TEST_INIT();

    thread_context *ctx= (thread_context*)args;
    fdb_kvs_handle *db = ctx->handle;
    fdb_iterator *iterator;
    fdb_doc *rdoc = NULL;
    ts_nsec latency = 0;
    float a_latency1 = 0.0, a_latency2 = 0.0;
    int samples = 0;

    latency = timed_fdb_iterator_init(db, &iterator);
    ctx->latency1 = latency;

    // repeat until fail
    do {
        // sum time of all gets
        latency = timed_fdb_iterator_get(iterator, &rdoc);
        fdb_doc_free(rdoc);
        rdoc = NULL;
        if(latency == ERR_NS){ break; }
        a_latency1 += latency;

        // sum time of calls to next
        latency = timed_fdb_iterator_next(iterator);
        if(latency == ERR_NS){ break; }
        a_latency2 += latency;

        samples++;

    } while (latency != ERR_NS);

    a_latency1 = a_latency1/samples;
    a_latency2 = a_latency2/samples;

    // get latency
    ctx->avg_latency1 = a_latency1;
    // seek latency
    ctx->avg_latency2 = a_latency2;
    // close latency
    latency = timed_fdb_iterator_close(iterator);
    ctx->latency2 = latency;

    return NULL;
}


void single_file_single_kvs(int n_threads){