#4434 must use DB_THREAD in multi-thread BDB apps refs[t:4434]

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

src/tests/blocking-c-del-deadlock.c

@@ -197,13 +197,10 @@ int test_main(int argc, char * const argv[]) {
     // create the db
     DB *db = NULL;
     r = db_create(&db, db_env, 0); assert(r == 0);
-    DB_TXN *create_txn = NULL;
-    r = db_env->txn_begin(db_env, NULL, &create_txn, 0); assert(r == 0);
     if (pagesize) {
         r = db->set_pagesize(db, pagesize); assert(r == 0);
     }
-    r = db->open(db, create_txn, db_filename, NULL, DB_BTREE, DB_CREATE, S_IRUSR | S_IWUSR | S_IRGRP | S_IROTH); assert(r == 0);
-    r = create_txn->commit(create_txn, 0); assert(r == 0);
+    r = db->open(db, NULL, db_filename, NULL, DB_BTREE, DB_CREATE|DB_AUTO_COMMIT|DB_THREAD, S_IRUSR | S_IWUSR | S_IRGRP | S_IROTH); assert(r == 0);
 
     // populate the db
     populate(db_env, db, nrows);

src/tests/blocking-c-del.c

@@ -195,13 +195,10 @@ int test_main(int argc, char * const argv[]) {
     // create the db
     DB *db = NULL;
     r = db_create(&db, db_env, 0); assert(r == 0);
-    DB_TXN *create_txn = NULL;
-    r = db_env->txn_begin(db_env, NULL, &create_txn, 0); assert(r == 0);
     if (pagesize) {
         r = db->set_pagesize(db, pagesize); assert(r == 0);
     }
-    r = db->open(db, create_txn, db_filename, NULL, DB_BTREE, DB_CREATE, S_IRUSR | S_IWUSR | S_IRGRP | S_IROTH); assert(r == 0);
-    r = create_txn->commit(create_txn, 0); assert(r == 0);
+    r = db->open(db, NULL, db_filename, NULL, DB_BTREE, DB_CREATE|DB_AUTO_COMMIT|DB_THREAD, S_IRUSR | S_IWUSR | S_IRGRP | S_IROTH); assert(r == 0);
 
     // populate the db
     populate(db_env, db, nrows);

src/tests/blocking-first-empty.c

@@ -149,13 +149,10 @@ int test_main(int argc, char * const argv[]) {
     // create the db
     DB *db = NULL;
     r = db_create(&db, db_env, 0); assert(r == 0);
-    DB_TXN *create_txn = NULL;
-    r = db_env->txn_begin(db_env, NULL, &create_txn, 0); assert(r == 0);
     if (pagesize) {
         r = db->set_pagesize(db, pagesize); assert(r == 0);
     }
-    r = db->open(db, create_txn, db_filename, NULL, DB_BTREE, DB_CREATE, S_IRUSR | S_IWUSR | S_IRGRP | S_IROTH); assert(r == 0);
-    r = create_txn->commit(create_txn, 0); assert(r == 0);
+    r = db->open(db, NULL, db_filename, NULL, DB_BTREE, DB_CREATE|DB_AUTO_COMMIT|DB_THREAD, S_IRUSR | S_IWUSR | S_IRGRP | S_IROTH); assert(r == 0);
 
     run_test(db_env, db, nthreads, nrows, sleeptime);
 

src/tests/blocking-first.c

@@ -166,13 +166,10 @@ int test_main(int argc, char * const argv[]) {
     // create the db
     DB *db = NULL;
     r = db_create(&db, db_env, 0); assert(r == 0);
-    DB_TXN *create_txn = NULL;
-    r = db_env->txn_begin(db_env, NULL, &create_txn, 0); assert(r == 0);
     if (pagesize) {
         r = db->set_pagesize(db, pagesize); assert(r == 0);
     }
-    r = db->open(db, create_txn, db_filename, NULL, DB_BTREE, DB_CREATE, S_IRUSR | S_IWUSR | S_IRGRP | S_IROTH); assert(r == 0);
-    r = create_txn->commit(create_txn, 0); assert(r == 0);
+    r = db->open(db, NULL, db_filename, NULL, DB_BTREE, DB_CREATE|DB_AUTO_COMMIT|DB_THREAD, S_IRUSR | S_IWUSR | S_IRGRP | S_IROTH); assert(r == 0);
 
     // populate the db
     populate(db_env, db, nrows);

src/tests/blocking-last.c

@@ -166,13 +166,10 @@ int test_main(int argc, char * const argv[]) {
     // create the db
     DB *db = NULL;
     r = db_create(&db, db_env, 0); assert(r == 0);
-    DB_TXN *create_txn = NULL;
-    r = db_env->txn_begin(db_env, NULL, &create_txn, 0); assert(r == 0);
     if (pagesize) {
         r = db->set_pagesize(db, pagesize); assert(r == 0);
     }
-    r = db->open(db, create_txn, db_filename, NULL, DB_BTREE, DB_CREATE, S_IRUSR | S_IWUSR | S_IRGRP | S_IROTH); assert(r == 0);
-    r = create_txn->commit(create_txn, 0); assert(r == 0);
+    r = db->open(db, NULL, db_filename, NULL, DB_BTREE, DB_CREATE|DB_AUTO_COMMIT|DB_THREAD, S_IRUSR | S_IWUSR | S_IRGRP | S_IROTH); assert(r == 0);
 
     // populate the db
     populate(db_env, db, nrows);

src/tests/blocking-next-prev-deadlock.c

@@ -237,13 +237,10 @@ int test_main(int argc, char * const argv[]) {
     // create the db
     DB *db = NULL;
     r = db_create(&db, db_env, 0); assert(r == 0);
-    DB_TXN *create_txn = NULL;
-    r = db_env->txn_begin(db_env, NULL, &create_txn, 0); assert(r == 0);
     if (pagesize) {
         r = db->set_pagesize(db, pagesize); assert(r == 0);
     }
-    r = db->open(db, create_txn, db_filename, NULL, DB_BTREE, DB_CREATE, S_IRUSR | S_IWUSR | S_IRGRP | S_IROTH); assert(r == 0);
-    r = create_txn->commit(create_txn, 0); assert(r == 0);
+    r = db->open(db, NULL, db_filename, NULL, DB_BTREE, DB_CREATE|DB_AUTO_COMMIT|DB_THREAD, S_IRUSR | S_IWUSR | S_IRGRP | S_IROTH); assert(r == 0);
 
     // populate the db
     populate(db_env, db, nrows);

src/tests/blocking-next-prev.c

@@ -231,13 +231,10 @@ int test_main(int argc, char * const argv[]) {
     // create the db
     DB *db = NULL;
     r = db_create(&db, db_env, 0); assert(r == 0);
-    DB_TXN *create_txn = NULL;
-    r = db_env->txn_begin(db_env, NULL, &create_txn, 0); assert(r == 0);
     if (pagesize) {
         r = db->set_pagesize(db, pagesize); assert(r == 0);
     }
-    r = db->open(db, create_txn, db_filename, NULL, DB_BTREE, DB_CREATE, S_IRUSR | S_IWUSR | S_IRGRP | S_IROTH); assert(r == 0);
-    r = create_txn->commit(create_txn, 0); assert(r == 0);
+    r = db->open(db, NULL, db_filename, NULL, DB_BTREE, DB_CREATE|DB_AUTO_COMMIT|DB_THREAD, S_IRUSR | S_IWUSR | S_IRGRP | S_IROTH); assert(r == 0);
 
     // populate the db
     populate(db_env, db, nrows);

src/tests/blocking-prelock-range.c

@@ -104,13 +104,10 @@ int test_main(int argc, char * const argv[]) {
     // create the db
     DB *db = NULL;
     r = db_create(&db, db_env, 0); assert(r == 0);
-    DB_TXN *create_txn = NULL;
-    r = db_env->txn_begin(db_env, NULL, &create_txn, 0); assert(r == 0);
     if (pagesize) {
         r = db->set_pagesize(db, pagesize); assert(r == 0);
     }
-    r = db->open(db, create_txn, db_filename, NULL, DB_BTREE, DB_CREATE, S_IRUSR | S_IWUSR | S_IRGRP | S_IROTH); assert(r == 0);
-    r = create_txn->commit(create_txn, 0); assert(r == 0);
+    r = db->open(db, NULL, db_filename, NULL, DB_BTREE, DB_CREATE|DB_AUTO_COMMIT|DB_THREAD, S_IRUSR | S_IWUSR | S_IRGRP | S_IROTH); assert(r == 0);
 
     toku_pthread_t tids[nthreads];
     for (int i = 0; i < nthreads-1; i++) {

src/tests/blocking-put-timeout.c

@@ -159,13 +159,10 @@ int test_main(int argc, char * const argv[]) {
     // create the db
     DB *db = NULL;
     r = db_create(&db, db_env, 0); assert(r == 0);
-    DB_TXN *create_txn = NULL;
-    r = db_env->txn_begin(db_env, NULL, &create_txn, 0); assert(r == 0);
     if (pagesize) {
         r = db->set_pagesize(db, pagesize); assert(r == 0);
     }
-    r = db->open(db, create_txn, db_filename, NULL, DB_BTREE, DB_CREATE, S_IRUSR | S_IWUSR | S_IRGRP | S_IROTH); assert(r == 0);
-    r = create_txn->commit(create_txn, 0); assert(r == 0);
+    r = db->open(db, NULL, db_filename, NULL, DB_BTREE, DB_CREATE|DB_AUTO_COMMIT|DB_THREAD, S_IRUSR | S_IWUSR | S_IRGRP | S_IROTH); assert(r == 0);
 
     // run test
     struct test_seq seq; test_seq_init(&seq);

src/tests/blocking-put-wakeup.c

@@ -135,13 +135,10 @@ int test_main(int argc, char * const argv[]) {
     // create the db
     DB *db = NULL;
     r = db_create(&db, db_env, 0); assert(r == 0);
-    DB_TXN *create_txn = NULL;
-    r = db_env->txn_begin(db_env, NULL, &create_txn, 0); assert(r == 0);
     if (pagesize) {
         r = db->set_pagesize(db, pagesize); assert(r == 0);
     }
-    r = db->open(db, create_txn, db_filename, NULL, DB_BTREE, DB_CREATE, S_IRUSR | S_IWUSR | S_IRGRP | S_IROTH); assert(r == 0);
-    r = create_txn->commit(create_txn, 0); assert(r == 0);
+    r = db->open(db, NULL, db_filename, NULL, DB_BTREE, DB_CREATE|DB_AUTO_COMMIT|DB_THREAD, S_IRUSR | S_IWUSR | S_IRGRP | S_IROTH); assert(r == 0);
 
     // run test
     struct test_seq seq; test_seq_init(&seq);

src/tests/blocking-put.c

@@ -103,13 +103,10 @@ int test_main(int argc, char * const argv[]) {
     // create the db
     DB *db = NULL;
     r = db_create(&db, db_env, 0); assert(r == 0);
-    DB_TXN *create_txn = NULL;
-    r = db_env->txn_begin(db_env, NULL, &create_txn, 0); assert(r == 0);
     if (pagesize) {
         r = db->set_pagesize(db, pagesize); assert(r == 0);
     }
-    r = db->open(db, create_txn, db_filename, NULL, DB_BTREE, DB_CREATE, S_IRUSR | S_IWUSR | S_IRGRP | S_IROTH); assert(r == 0);
-    r = create_txn->commit(create_txn, 0); assert(r == 0);
+    r = db->open(db, NULL, db_filename, NULL, DB_BTREE, DB_CREATE|DB_AUTO_COMMIT|DB_THREAD, S_IRUSR | S_IWUSR | S_IRGRP | S_IROTH); assert(r == 0);
 
     toku_pthread_t tids[nthreads];
     for (int i = 0; i < nthreads-1; i++) {

src/tests/blocking-set-range-0.c

@@ -176,13 +176,10 @@ int test_main(int argc, char * const argv[]) {
     // create the db
     DB *db = NULL;
     r = db_create(&db, db_env, 0); assert(r == 0);
-    DB_TXN *create_txn = NULL;
-    r = db_env->txn_begin(db_env, NULL, &create_txn, 0); assert(r == 0);
     if (pagesize) {
         r = db->set_pagesize(db, pagesize); assert(r == 0);
     }
-    r = db->open(db, create_txn, db_filename, NULL, DB_BTREE, DB_CREATE, S_IRUSR | S_IWUSR | S_IRGRP | S_IROTH); assert(r == 0);
-    r = create_txn->commit(create_txn, 0); assert(r == 0);
+    r = db->open(db, NULL, db_filename, NULL, DB_BTREE, DB_CREATE|DB_AUTO_COMMIT|DB_THREAD, S_IRUSR | S_IWUSR | S_IRGRP | S_IROTH); assert(r == 0);
 
     // populate the db
     populate(db_env, db, nrows);

src/tests/blocking-set-range-n.c

@@ -171,13 +171,10 @@ int test_main(int argc, char * const argv[]) {
     // create the db
     DB *db = NULL;
     r = db_create(&db, db_env, 0); assert(r == 0);
-    DB_TXN *create_txn = NULL;
-    r = db_env->txn_begin(db_env, NULL, &create_txn, 0); assert(r == 0);
     if (pagesize) {
         r = db->set_pagesize(db, pagesize); assert(r == 0);
     }
-    r = db->open(db, create_txn, db_filename, NULL, DB_BTREE, DB_CREATE, S_IRUSR | S_IWUSR | S_IRGRP | S_IROTH); assert(r == 0);
-    r = create_txn->commit(create_txn, 0); assert(r == 0);
+    r = db->open(db, NULL, db_filename, NULL, DB_BTREE, DB_CREATE|DB_AUTO_COMMIT|DB_THREAD, S_IRUSR | S_IWUSR | S_IRGRP | S_IROTH); assert(r == 0);
 
     // populate the db
     populate(db_env, db, nrows);

src/tests/blocking-set-range-reverse-0.c

@@ -174,13 +174,10 @@ int test_main(int argc, char * const argv[]) {
     // create the db
     DB *db = NULL;
     r = db_create(&db, db_env, 0); assert(r == 0);
-    DB_TXN *create_txn = NULL;
-    r = db_env->txn_begin(db_env, NULL, &create_txn, 0); assert(r == 0);
     if (pagesize) {
         r = db->set_pagesize(db, pagesize); assert(r == 0);
     }
-    r = db->open(db, create_txn, db_filename, NULL, DB_BTREE, DB_CREATE, S_IRUSR | S_IWUSR | S_IRGRP | S_IROTH); assert(r == 0);
-    r = create_txn->commit(create_txn, 0); assert(r == 0);
+    r = db->open(db, NULL, db_filename, NULL, DB_BTREE, DB_CREATE|DB_AUTO_COMMIT|DB_THREAD, S_IRUSR | S_IWUSR | S_IRGRP | S_IROTH); assert(r == 0);
 
     // populate the db
     populate(db_env, db, nrows);

src/tests/blocking-set.c

@@ -148,13 +148,10 @@ int test_main(int argc, char * const argv[]) {
     // create the db
     DB *db = NULL;
     r = db_create(&db, db_env, 0); assert(r == 0);
-    DB_TXN *create_txn = NULL;
-    r = db_env->txn_begin(db_env, NULL, &create_txn, 0); assert(r == 0);
     if (pagesize) {
         r = db->set_pagesize(db, pagesize); assert(r == 0);
     }
-    r = db->open(db, create_txn, db_filename, NULL, DB_BTREE, DB_CREATE, S_IRUSR | S_IWUSR | S_IRGRP | S_IROTH); assert(r == 0);
-    r = create_txn->commit(create_txn, 0); assert(r == 0);
+    r = db->open(db, NULL, db_filename, NULL, DB_BTREE, DB_CREATE|DB_AUTO_COMMIT|DB_THREAD, S_IRUSR | S_IWUSR | S_IRGRP | S_IROTH); assert(r == 0);
 
     // populate the db
     populate(db_env, db, nrows);

src/tests/blocking-table-lock.c

@@ -97,13 +97,10 @@ int test_main(int argc, char * const argv[]) {
     // create the db
     DB *db = NULL;
     r = db_create(&db, db_env, 0); assert(r == 0);
-    DB_TXN *create_txn = NULL;
-    r = db_env->txn_begin(db_env, NULL, &create_txn, 0); assert(r == 0);
     if (pagesize) {
         r = db->set_pagesize(db, pagesize); assert(r == 0);
     }
-    r = db->open(db, create_txn, db_filename, NULL, DB_BTREE, DB_CREATE, S_IRUSR | S_IWUSR | S_IRGRP | S_IROTH); assert(r == 0);
-    r = create_txn->commit(create_txn, 0); assert(r == 0);
+    r = db->open(db, NULL, db_filename, NULL, DB_BTREE, DB_CREATE|DB_AUTO_COMMIT|DB_THREAD, S_IRUSR | S_IWUSR | S_IRGRP | S_IROTH); assert(r == 0);
 
     toku_pthread_t tids[nthreads];
     for (int i = 0; i < nthreads-1; i++) {