diff options
author | Luke Chen <luke.chen@mongodb.com> | 2018-11-02 16:36:36 +1100 |
---|---|---|
committer | Luke Chen <luke.chen@mongodb.com> | 2018-11-02 16:36:36 +1100 |
commit | a19da30a1bf7462c9a8a0533c43f98bd13fbb190 (patch) | |
tree | 090e8225ea84e4971a077dd26dadf3c61068bf33 /src/third_party/wiredtiger/test/csuite/schema_abort/main.c | |
parent | 1559bd33d108e58ffdc0df5fa2af4cc163ae9721 (diff) | |
download | mongo-a19da30a1bf7462c9a8a0533c43f98bd13fbb190.tar.gz |
Import wiredtiger: e8cf194d813096cc2b30c0dd2d9d9c93ade79756 from branch mongodb-4.2
ref: 22b1224ee0..e8cf194d81
for: 4.1.5
WT-4298 Fix workgen to retry on WT_ROLLBACK and clear ops after warmup
WT-4343 Unlock when sleeping to allow other log threads to make progress
WT-4371 Workgen improvements to create a MongoDB-like workload
WT-4376 Fix a bug where table index open can race
WT-4385 Prepare-conflict during a cursor scan can return the wrong key
WT-4392 A large lint change
WT-4395 Seg fault walking corrupted log with log cursor
WT-4396 When retrying after prepare-conflict, cursor unable to find a valid update
WT-4400 Fix workgen use of PRIxxx macros, needed for old C++ compilers
Diffstat (limited to 'src/third_party/wiredtiger/test/csuite/schema_abort/main.c')
-rw-r--r-- | src/third_party/wiredtiger/test/csuite/schema_abort/main.c | 40 |
1 files changed, 18 insertions, 22 deletions
diff --git a/src/third_party/wiredtiger/test/csuite/schema_abort/main.c b/src/third_party/wiredtiger/test/csuite/schema_abort/main.c index 79832199bf7..14cdf9d9016 100644 --- a/src/third_party/wiredtiger/test/csuite/schema_abort/main.c +++ b/src/third_party/wiredtiger/test/csuite/schema_abort/main.c @@ -185,8 +185,8 @@ static void test_bulk(THREAD_DATA *td) { WT_CURSOR *c; + WT_DECL_RET; WT_SESSION *session; - int ret; bool create; testutil_check(td->conn->open_session(td->conn, NULL, NULL, &session)); @@ -232,9 +232,9 @@ static void test_bulk_unique(THREAD_DATA *td, int force) { WT_CURSOR *c; + WT_DECL_RET; WT_SESSION *session; uint64_t my_uid; - int ret; char new_uri[64]; testutil_check(td->conn->open_session(td->conn, NULL, NULL, &session)); @@ -242,7 +242,7 @@ test_bulk_unique(THREAD_DATA *td, int force) /* Generate a unique object name. */ my_uid = __wt_atomic_addv64(&uid, 1); testutil_check(__wt_snprintf( - new_uri, sizeof(new_uri), "%s.%u", uri, my_uid)); + new_uri, sizeof(new_uri), "%s.%" PRIu64, uri, my_uid)); if (use_txn) testutil_check(session->begin_transaction(session, NULL)); @@ -280,8 +280,8 @@ static void test_cursor(THREAD_DATA *td) { WT_CURSOR *cursor; + WT_DECL_RET; WT_SESSION *session; - int ret; testutil_check(td->conn->open_session(td->conn, NULL, NULL, &session)); @@ -310,8 +310,8 @@ test_cursor(THREAD_DATA *td) static void test_create(THREAD_DATA *td) { + WT_DECL_RET; WT_SESSION *session; - int ret; testutil_check(td->conn->open_session(td->conn, NULL, NULL, &session)); @@ -335,9 +335,9 @@ test_create(THREAD_DATA *td) static void test_create_unique(THREAD_DATA *td, int force) { + WT_DECL_RET; WT_SESSION *session; uint64_t my_uid; - int ret; char new_uri[64]; testutil_check(td->conn->open_session(td->conn, NULL, NULL, &session)); @@ -345,7 +345,7 @@ test_create_unique(THREAD_DATA *td, int force) /* Generate a unique object name. */ my_uid = __wt_atomic_addv64(&uid, 1); testutil_check(__wt_snprintf( - new_uri, sizeof(new_uri), "%s.%u", uri, my_uid)); + new_uri, sizeof(new_uri), "%s.%" PRIu64, uri, my_uid)); if (use_txn) testutil_check(session->begin_transaction(session, NULL)); @@ -377,8 +377,8 @@ test_create_unique(THREAD_DATA *td, int force) static void test_drop(THREAD_DATA *td, int force) { + WT_DECL_RET; WT_SESSION *session; - int ret; testutil_check(td->conn->open_session(td->conn, NULL, NULL, &session)); @@ -412,8 +412,8 @@ test_drop(THREAD_DATA *td, int force) static void test_rebalance(THREAD_DATA *td) { + WT_DECL_RET; WT_SESSION *session; - int ret; testutil_check(td->conn->open_session(td->conn, NULL, NULL, &session)); @@ -431,8 +431,8 @@ test_rebalance(THREAD_DATA *td) static void test_upgrade(THREAD_DATA *td) { + WT_DECL_RET; WT_SESSION *session; - int ret; testutil_check(td->conn->open_session(td->conn, NULL, NULL, &session)); @@ -450,8 +450,8 @@ test_upgrade(THREAD_DATA *td) static void test_verify(THREAD_DATA *td) { + WT_DECL_RET; WT_SESSION *session; - int ret; testutil_check(td->conn->open_session(td->conn, NULL, NULL, &session)); @@ -559,8 +559,7 @@ thread_ckpt_run(void *arg) * Keep writing checkpoints until killed by parent. */ __wt_epoch(NULL, &start); - i = 0; - while (true) { + for (i = 0;;) { sleep_time = __wt_random(&rnd) % MAX_CKPT_INVL; sleep(sleep_time); if (use_ts) { @@ -575,8 +574,7 @@ thread_ckpt_run(void *arg) printf("CKPT: !stable_set time %" PRIu64 "\n", WT_TIMEDIFF_SEC(now, start)); - if (WT_TIMEDIFF_SEC(now, start) > - MAX_STARTUP) { + if (WT_TIMEDIFF_SEC(now, start) > MAX_STARTUP) { fprintf(stderr, "After %d seconds stable still not " "set. Aborting.\n", MAX_STARTUP); @@ -985,20 +983,18 @@ main(int argc, char *argv[]) REPORT c_rep[MAX_TH], l_rep[MAX_TH], o_rep[MAX_TH]; WT_CONNECTION *conn; WT_CURSOR *cur_coll, *cur_local, *cur_oplog; + WT_DECL_RET; WT_RAND_STATE rnd; WT_SESSION *session; pid_t pid; uint64_t absent_coll, absent_local, absent_oplog, count, key, last_key; uint64_t stable_fp, stable_val; - uint32_t i; - int ret; - char fname[64], kname[64]; - bool fatal; - uint32_t nth, timeout; + uint32_t i, nth, timeout; int ch, status; - const char *working_dir; char buf[512], statname[1024]; - bool rand_th, rand_time, verify_only; + char fname[64], kname[64]; + const char *working_dir; + bool fatal, rand_th, rand_time, verify_only; /* We have nothing to do if this is not a timestamp build */ if (!timestamp_build()) |