refs #5891, make a benchmark test

git-svn-id: file:///svn/toku/tokudb@52046 c7de825b-a66e-492c-adef-691d508d4ae1

src/tests/CMakeLists.txt

@@ -103,6 +103,7 @@ if(BUILD_TESTING OR BUILD_SRC_TESTS)
       perf_ptquery
       perf_ptquery2
       perf_read_txn
+      perf_read_txn_single_thread
       perf_read_write
       perf_txn_single_thread
       perf_xmalloc_free

src/tests/perf_read_txn_single_thread.cc

+/* -*- mode: C++; c-basic-offset: 4; indent-tabs-mode: nil -*- */
+// vim: ft=cpp:expandtab:ts=8:sw=4:softtabstop=4:
+#ident "Copyright (c) 2007 Tokutek Inc.  All rights reserved."
+#ident "$Id: perf_txn_single_thread.cc 51911 2013-01-10 18:21:29Z zardosht $"
+#include "test.h"
+
+#include <stdio.h>
+#include <stdlib.h>
+
+#include <toku_pthread.h>
+#include <unistd.h>
+#include <memory.h>
+#include <sys/stat.h>
+#include <db.h>
+
+#include "threaded_stress_test_helpers.h"
+
+// The intent of this test is to measure how fast a single thread can 
+// commit and create transactions when there exist N transactions.
+
+DB_TXN** txns;
+int num_txns;
+
+static int commit_and_create_txn(
+    DB_TXN* UU(txn), 
+    ARG arg, 
+    void* UU(operation_extra), 
+    void* UU(stats_extra)
+    ) 
+{
+    int rand_txn_id = random() % num_txns;
+    int r = txns[rand_txn_id]->commit(txns[rand_txn_id], 0);
+    CKERR(r);
+    r = arg->env->txn_begin(arg->env, 0, &txns[rand_txn_id], arg->txn_flags | DB_TXN_READ_ONLY); 
+    CKERR(r);
+    return 0;
+}
+
+static void
+stress_table(DB_ENV* env, DB** dbp, struct cli_args *cli_args) {
+    if (verbose) printf("starting running of stress\n");
+
+    num_txns = cli_args->txn_size;
+    XCALLOC_N(num_txns, txns);
+    for (int i = 0; i < num_txns; i++) {
+        int r = env->txn_begin(env, 0, &txns[i], DB_TXN_SNAPSHOT); 
+        CKERR(r);
+    }
+    
+    struct arg myarg;
+    arg_init(&myarg, dbp, env, cli_args);
+    myarg.operation = commit_and_create_txn;
+    
+    run_workers(&myarg, 1, cli_args->num_seconds, false, cli_args);
+
+    for (int i = 0; i < num_txns; i++) {
+        int chk_r = txns[i]->commit(txns[i], 0);
+        CKERR(chk_r);
+    }
+    toku_free(txns);
+    num_txns = 0;
+}
+
+int
+test_main(int argc, char *const argv[]) {
+    num_txns = 0;
+    txns = NULL;
+    struct cli_args args = get_default_args_for_perf();
+    parse_stress_test_args(argc, argv, &args);
+    args.single_txn = true;
+    // this test is all about transactions, make the DB small
+    args.num_elements = 1;
+    args.num_DBs= 1;    
+    perf_test_main(&args);
+    return 0;
+}