summaryrefslogtreecommitdiff
path: root/src/third_party/wiredtiger/test/csuite/schema_abort/main.c
diff options
context:
space:
mode:
authorLuke Chen <luke.chen@mongodb.com>2018-11-02 16:36:36 +1100
committerLuke Chen <luke.chen@mongodb.com>2018-11-02 16:36:36 +1100
commita19da30a1bf7462c9a8a0533c43f98bd13fbb190 (patch)
tree090e8225ea84e4971a077dd26dadf3c61068bf33 /src/third_party/wiredtiger/test/csuite/schema_abort/main.c
parent1559bd33d108e58ffdc0df5fa2af4cc163ae9721 (diff)
downloadmongo-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.c40
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())