[t:4065], add split/merge test

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

src/tests/test_stress_with_verify.c

+/* -*- mode: C; c-basic-offset: 4 -*- */
+#ident "Copyright (c) 2007 Tokutek Inc.  All rights reserved."
+#ident "$Id: test_stress1.c 35109 2011-09-27 18:41:25Z leifwalsh $"
+#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"
+
+
+//
+// purpose of this stress test is to do a bunch of splitting and merging
+// and run db->verify periodically to make sure the db is in a 
+// a good state
+//
+
+static void
+stress_table(DB_ENV *env, DB **dbp, struct cli_args *cli_args) {
+    int n = cli_args->num_elements;
+
+    //
+    // do insertions and queries with a loader lying around doing stuff
+    //
+
+    if (verbose) printf("starting creation of pthreads\n");
+    const int num_threads = 4 + cli_args->num_update_threads + cli_args->num_ptquery_threads;
+    struct arg myargs[num_threads];
+    for (int i = 0; i < num_threads; i++) {
+        arg_init(&myargs[i], n, dbp, env, cli_args);
+    }
+    // make the forward fast scanner
+    myargs[0].fast = TRUE;
+    myargs[0].fwd = TRUE;
+    myargs[0].lock_type = STRESS_LOCK_SHARED;
+    myargs[0].operation = scan_op;
+
+    // make the backward slow scanner
+    myargs[1].lock_type = STRESS_LOCK_EXCL;
+    myargs[1].sleep_ms = 3000; // maybe make this a runtime param at some point
+    myargs[1].operation = verify_op;
+
+    for (int i = 2; i < 2 + cli_args->num_update_threads; ++i) {
+        myargs[i].lock_type = STRESS_LOCK_SHARED;
+        myargs[i].operation = update_op;
+    }
+
+    // make the guy that does point queries
+    for (int i = 2 + cli_args->num_update_threads; i < num_threads; i++) {
+        myargs[i].lock_type = STRESS_LOCK_SHARED;
+        myargs[i].operation = ptquery_op;
+    }
+    run_workers(myargs, num_threads, cli_args->time_of_test, false);
+}
+
+int
+test_main(int argc, char *const argv[]) {
+    struct cli_args args = DEFAULT_ARGS;
+    // let's make default checkpointing period really slow
+    args.checkpointing_period = 1;
+    args.num_elements= 2000; // make default of small num elements to 
+    args.num_ptquery_threads = 0;
+    parse_stress_test_args(argc, argv, &args);
+    stress_test_main(&args);
+    return 0;
+}

src/tests/threaded_stress_test_helpers.h

@@ -264,6 +264,14 @@ static int UU() keyrange_op(DB_ENV *UU(env), DB **dbp, DB_TXN *txn, ARG arg) {
     return r;
 }
 
+static int UU() verify_op(DB_ENV *UU(env), DB **dbp, DB_TXN* UU(txn), ARG UU(arg)) {
+    int r;
+    DB* db = *dbp;
+    r = db->verify_with_progress(db, NULL, NULL, 0, 0);
+    CKERR(r);
+    return r;
+}
+
 static int UU() scan_op(DB_ENV *env, DB **dbp, DB_TXN *txn, ARG arg) {
     return scan_op_and_maybe_check_sum(env, dbp, txn, arg, true);
 }