Commit 82a8d332 authored by Leif Walsh's avatar Leif Walsh Committed by Yoni Fogel

refs #5507 zero out more mutexes


git-svn-id: file:///svn/toku/tokudb@48060 c7de825b-a66e-492c-adef-691d508d4ae1
parent 7e477702
...@@ -135,7 +135,7 @@ static void *run_locker_b(void *arg) { ...@@ -135,7 +135,7 @@ static void *run_locker_b(void *arg) {
static void simple_deadlock(DB_ENV *db_env) { static void simple_deadlock(DB_ENV *db_env) {
int r; int r;
struct test_seq test_seq; test_seq_init(&test_seq); struct test_seq test_seq; ZERO_STRUCT(test_seq); test_seq_init(&test_seq);
int deadlock_count = 0 ; int deadlock_count = 0 ;
......
...@@ -162,7 +162,7 @@ int test_main(int argc, char * const argv[]) { ...@@ -162,7 +162,7 @@ int test_main(int argc, char * const argv[]) {
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); 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 // run test
struct test_seq seq; test_seq_init(&seq); struct test_seq seq; ZERO_STRUCT(seq); test_seq_init(&seq);
toku_pthread_t t_a_id; toku_pthread_t t_a_id;
struct t_a_args t_a_args = { db_env, db, &seq }; struct t_a_args t_a_args = { db_env, db, &seq };
r = toku_pthread_create(&t_a_id, NULL, t_a_thread, &t_a_args); assert(r == 0); r = toku_pthread_create(&t_a_id, NULL, t_a_thread, &t_a_args); assert(r == 0);
......
...@@ -136,7 +136,7 @@ int test_main(int argc, char * const argv[]) { ...@@ -136,7 +136,7 @@ int test_main(int argc, char * const argv[]) {
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); 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 // run test
struct test_seq seq; test_seq_init(&seq); struct test_seq seq; ZERO_STRUCT(seq); test_seq_init(&seq);
toku_pthread_t t_a_id; toku_pthread_t t_a_id;
struct t_a_args t_a_args = { db_env, db, &seq }; struct t_a_args t_a_args = { db_env, db, &seq };
r = toku_pthread_create(&t_a_id, NULL, t_a_thread, &t_a_args); assert(r == 0); r = toku_pthread_create(&t_a_id, NULL, t_a_thread, &t_a_args); assert(r == 0);
......
...@@ -113,7 +113,7 @@ static void simple_deadlock(DB_ENV *db_env, DB *db, int do_txn, int n) { ...@@ -113,7 +113,7 @@ static void simple_deadlock(DB_ENV *db_env, DB *db, int do_txn, int n) {
r = db_env->txn_begin(db_env, NULL, &txn_b, txn_flags); assert(r == 0); r = db_env->txn_begin(db_env, NULL, &txn_b, txn_flags); assert(r == 0);
} }
struct test_seq test_seq; test_seq_init(&test_seq); struct test_seq test_seq; ZERO_STRUCT(test_seq); test_seq_init(&test_seq);
toku_pthread_t tid; toku_pthread_t tid;
struct run_txn_b_arg arg = { &test_seq, txn_b, db, n}; struct run_txn_b_arg arg = { &test_seq, txn_b, db, n};
......
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