Commit d70af213 authored by John Esmet's avatar John Esmet Committed by Yoni Fogel

fixes #5164 small changes to perf insert multiple, which is now complete. it...

fixes #5164 small changes to perf insert multiple, which is now complete. it measures multithreaded put_multiple performance, which is analogous to multiple writers on a single table with many indexes in mysql


git-svn-id: file:///svn/toku/tokudb@45265 c7de825b-a66e-492c-adef-691d508d4ae1
parent dc2b0d2d
...@@ -24,17 +24,17 @@ stress_table(DB_ENV* env, DB** dbp, struct cli_args *cli_args) { ...@@ -24,17 +24,17 @@ stress_table(DB_ENV* env, DB** dbp, struct cli_args *cli_args) {
if (verbose) printf("starting creation of pthreads\n"); if (verbose) printf("starting creation of pthreads\n");
const int num_threads = cli_args->num_put_threads; const int num_threads = cli_args->num_put_threads;
struct arg myargs[num_threads]; struct arg myargs[num_threads];
operation_t put_op = random_put_multiple_op;
struct serial_put_extra spe[num_threads]; struct serial_put_extra spe[num_threads];
ZERO_ARRAY(spe); ZERO_ARRAY(spe);
for (int i = 0; i < num_threads; i++) { for (int i = 0; i < num_threads; i++) {
arg_init(&myargs[i], dbp, env, cli_args); arg_init(&myargs[i], dbp, env, cli_args);
myargs[i].operation = put_op; myargs[i].operation = random_put_multiple_op;
if (cli_args->serial_insert) { if (cli_args->serial_insert) {
myargs[i].operation_extra = &spe[i]; myargs[i].operation_extra = &spe[i];
} }
} }
run_workers(myargs, num_threads, cli_args->time_of_test, false, cli_args); const bool crash_at_end = false;
run_workers(myargs, num_threads, cli_args->time_of_test, crash_at_end, cli_args);
} }
int int
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment