summaryrefslogtreecommitdiff
path: root/src/third_party/wiredtiger/test
diff options
context:
space:
mode:
authorChenhao Qu <chenhao.qu@mongodb.com>2022-11-02 11:54:33 +1100
committerEvergreen Agent <no-reply@evergreen.mongodb.com>2022-11-02 02:00:19 +0000
commit2ce063ee585aef729f67b61671b4d0469939664c (patch)
tree710b40bcd32d37d240f4a6fc88c35472d8d56447 /src/third_party/wiredtiger/test
parent627a375f5d31ff7af5bd9e854fc9a3186872c219 (diff)
downloadmongo-2ce063ee585aef729f67b61671b4d0469939664c.tar.gz
Import wiredtiger: f78c826b67e6f4ea78a4c90aaff4c799979ce29f from branch mongodb-master
ref: 6215c6d628..f78c826b67 for: 6.2.0-rc0 Revert "WT-9871 schema_abort : Move tiered storage functionality to test_util
Diffstat (limited to 'src/third_party/wiredtiger/test')
-rw-r--r--src/third_party/wiredtiger/test/csuite/random_abort/main.c6
-rw-r--r--src/third_party/wiredtiger/test/csuite/random_directio/main.c3
-rw-r--r--src/third_party/wiredtiger/test/csuite/schema_abort/main.c97
-rw-r--r--src/third_party/wiredtiger/test/csuite/tiered_abort/main.c4
-rw-r--r--src/third_party/wiredtiger/test/csuite/timestamp_abort/main.c4
-rw-r--r--src/third_party/wiredtiger/test/csuite/truncated_log/main.c4
-rw-r--r--src/third_party/wiredtiger/test/csuite/wt6616_checkpoint_oldest_ts/main.c5
-rw-r--r--src/third_party/wiredtiger/test/csuite/wt8246_compact_rts_data_correctness/main.c4
-rw-r--r--src/third_party/wiredtiger/test/utility/misc.c23
-rw-r--r--src/third_party/wiredtiger/test/utility/parse_opts.c22
-rw-r--r--src/third_party/wiredtiger/test/utility/test_util.h14
11 files changed, 85 insertions, 101 deletions
diff --git a/src/third_party/wiredtiger/test/csuite/random_abort/main.c b/src/third_party/wiredtiger/test/csuite/random_abort/main.c
index ff06a4bb6bc..a3a4e35f997 100644
--- a/src/third_party/wiredtiger/test/csuite/random_abort/main.c
+++ b/src/third_party/wiredtiger/test/csuite/random_abort/main.c
@@ -61,12 +61,14 @@ static bool inmem;
#define MODIFY_RECORD_FILE_ID 2
#define MAX_RECORD_FILES 3
+#define ENV_CONFIG_COMPAT ",compatibility=(release=\"2.9\")"
#define ENV_CONFIG_DEF \
"create,log=(file_max=10M,enabled),statistics=(all),statistics_log=(json,on_close,wait=1)"
#define ENV_CONFIG_TXNSYNC \
"create,log=(file_max=10M,enabled)," \
"transaction_sync=(enabled,method=none),statistics=(all),statistics_log=(json,on_close,wait=" \
"1)"
+#define ENV_CONFIG_REC "log=(recover=on),statistics=(all),statistics_log=(json,on_close,wait=1)"
/*
* A minimum width of 10, along with zero filling, means that all the keys sort according to their
@@ -324,7 +326,7 @@ fill_db(uint32_t nth)
else
strcpy(envconf, ENV_CONFIG_TXNSYNC);
if (compat)
- strcat(envconf, TESTUTIL_ENV_CONFIG_COMPAT);
+ strcat(envconf, ENV_CONFIG_COMPAT);
testutil_check(wiredtiger_open(NULL, NULL, envconf, &conn));
testutil_check(conn->open_session(conn, NULL, NULL, &session));
@@ -394,7 +396,7 @@ recover_and_verify(uint32_t nthreads)
bool columnar_table, fatal;
printf("Open database, run recovery and verify content\n");
- testutil_check(wiredtiger_open(NULL, NULL, TESTUTIL_ENV_CONFIG_REC, &conn));
+ testutil_check(wiredtiger_open(NULL, NULL, ENV_CONFIG_REC, &conn));
testutil_check(conn->open_session(conn, NULL, NULL, &session));
testutil_check(session->open_cursor(session, col_uri, NULL, NULL, &col_cursor));
testutil_check(session->open_cursor(session, uri, NULL, NULL, &row_cursor));
diff --git a/src/third_party/wiredtiger/test/csuite/random_directio/main.c b/src/third_party/wiredtiger/test/csuite/random_directio/main.c
index 7e39b504967..25b968d35fe 100644
--- a/src/third_party/wiredtiger/test/csuite/random_directio/main.c
+++ b/src/third_party/wiredtiger/test/csuite/random_directio/main.c
@@ -107,6 +107,7 @@ static const char *const uri_rev = "table:rev";
#define ENV_CONFIG_TIER_EXT \
",extensions=(%s../../../ext/storage_sources/dir_store/" \
"libwiredtiger_dir_store.so=(early_load=true))"
+#define ENV_CONFIG_REC "log=(recover=on),statistics=(all),statistics_log=(json,on_close,wait=1)"
/* 64 spaces */
#define SPACES " "
@@ -933,7 +934,7 @@ check_db(uint32_t nth, uint32_t datasize, pid_t pid, bool directio, uint32_t fla
copy_directory(checkdir, savedir, false);
printf("Open database, run recovery and verify content\n");
- testutil_check(__wt_snprintf(envconf, sizeof(envconf), TESTUTIL_ENV_CONFIG_REC));
+ testutil_check(__wt_snprintf(envconf, sizeof(envconf), ENV_CONFIG_REC));
if (LF_ISSET(TEST_TIERED)) {
testutil_check(__wt_snprintf(tierconf, sizeof(tierconf), ENV_CONFIG_TIER_EXT, ""));
strcat(envconf, tierconf);
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 090a3190bcb..90aab3a072c 100644
--- a/src/third_party/wiredtiger/test/csuite/schema_abort/main.c
+++ b/src/third_party/wiredtiger/test/csuite/schema_abort/main.c
@@ -76,7 +76,7 @@ static const char *const uri_collection = "table:collection";
static const char *const ckpt_file = "checkpoint_done";
-static bool tiered, use_columns, use_ts, use_txn;
+static bool compat, inmem, tiered, use_columns, use_ts, use_txn;
static volatile bool stable_set;
static volatile uint64_t global_ts = 1;
static volatile uint64_t uid = 1;
@@ -86,17 +86,23 @@ typedef struct {
} THREAD_TS;
static volatile THREAD_TS th_ts[MAX_TH];
-static TEST_OPTS *opts, _opts;
-
+#define ENV_CONFIG_COMPAT ",compatibility=(release=\"2.9\")"
#define ENV_CONFIG_DEF \
"create," \
"eviction_updates_trigger=95,eviction_updates_target=80," \
"log=(enabled,file_max=10M,remove=false),statistics=(all),statistics_log=(json,on_close,wait=" \
"1)"
-
+#define ENV_CONFIG_TIER \
+ ",tiered_storage=(bucket=./" \
+ "bucket,bucket_prefix=pfx-,local_retention=2,name=dir_store)"
+#define ENV_CONFIG_TIER_EXT \
+ ",extensions=(../../../../ext/storage_sources/dir_store/" \
+ "libwiredtiger_dir_store.so=(early_load=true))"
#define ENV_CONFIG_TXNSYNC \
ENV_CONFIG_DEF \
",transaction_sync=(enabled,method=none)"
+#define ENV_CONFIG_REC \
+ "log=(recover=on,remove=false),statistics=(all),statistics_log=(json,on_close,wait=1)"
/*
* A minimum width of 10, along with zero filling, means that all the keys sort according to their
@@ -824,14 +830,18 @@ run_workload(uint32_t nth)
stable_set = false;
if (chdir(home) != 0)
testutil_die(errno, "Child chdir: %s", home);
- if (opts->inmem)
+ if (inmem)
strcpy(envconf, ENV_CONFIG_DEF);
else
strcpy(envconf, ENV_CONFIG_TXNSYNC);
+ if (compat)
+ strcat(envconf, ENV_CONFIG_COMPAT);
+ if (tiered) {
+ strcat(envconf, ENV_CONFIG_TIER_EXT);
+ strcat(envconf, ENV_CONFIG_TIER);
+ }
- /* Open WiredTiger without recovery. */
- testutil_wiredtiger_open(opts, envconf, &event_handler, &conn, false);
-
+ testutil_check(wiredtiger_open(NULL, &event_handler, envconf, &conn));
testutil_check(conn->open_session(conn, NULL, NULL, &session));
/*
* Create all the tables.
@@ -954,14 +964,12 @@ main(int argc, char *argv[])
int ch, status;
char buf[1024], statname[1024];
char fname[64], kname[64];
- bool fatal, rand_th, rand_time, verify_only;
+ const char *working_dir;
+ bool fatal, preserve, rand_th, rand_time, verify_only;
(void)testutil_set_progname(argv);
- buf[0] = '\0';
- opts = &_opts;
- memset(opts, 0, sizeof(*opts));
- tiered = false;
+ compat = inmem = tiered = false;
use_ts = true;
/*
* Setting this to false forces us to use internal library code. Allow an override but default
@@ -969,21 +977,33 @@ main(int argc, char *argv[])
*/
use_txn = false;
nth = MIN_TH;
+ preserve = false;
rand_th = rand_time = true;
timeout = MIN_TIME;
verify_only = false;
+ working_dir = "WT_TEST.schema-abort";
- testutil_parse_begin_opt(argc, argv, "b:CmPTh:pv", opts);
-
- while ((ch = __wt_getopt(progname, argc, argv, "BCch:mpP:T:t:vxz")) != EOF)
+ while ((ch = __wt_getopt(progname, argc, argv, "BCch:mpT:t:vxz")) != EOF)
switch (ch) {
case 'B':
tiered = true;
break;
+ case 'C':
+ compat = true;
+ break;
case 'c':
/* Variable-length columns only; fixed would require considerable changes */
use_columns = true;
break;
+ case 'h':
+ working_dir = __wt_optarg;
+ break;
+ case 'm':
+ inmem = true;
+ break;
+ case 'p':
+ preserve = true;
+ break;
case 'T':
rand_th = false;
nth = (uint32_t)atoi(__wt_optarg);
@@ -1002,19 +1022,13 @@ main(int argc, char *argv[])
use_ts = false;
break;
default:
- /* The option is either one that we're asking testutil to support, or illegal. */
- if (testutil_parse_single_opt(opts, ch) != 0) {
- usage();
- }
+ usage();
}
argc -= __wt_optind;
if (argc != 0)
usage();
- testutil_parse_end_opt(opts);
-
- testutil_work_dir_from_path(home, sizeof(home), opts->home);
-
+ testutil_work_dir_from_path(home, sizeof(home), working_dir);
/*
* If the user wants to verify they need to tell us how many threads there were so we can find
* the old record files.
@@ -1025,7 +1039,7 @@ main(int argc, char *argv[])
}
if (!verify_only) {
testutil_make_work_dir(home);
- if (opts->tiered_storage) {
+ if (tiered) {
testutil_check(__wt_snprintf(buf, sizeof(buf), "%s/bucket", home));
testutil_make_work_dir(buf);
}
@@ -1045,12 +1059,12 @@ main(int argc, char *argv[])
printf(
"Parent: compatibility: %s, in-mem log sync: %s, timestamp in use: %s, tiered in use: "
"%s\n",
- opts->compat ? "true" : "false", opts->inmem ? "true" : "false",
- use_ts ? "true" : "false", opts->tiered_storage ? "true" : "false");
+ compat ? "true" : "false", inmem ? "true" : "false", use_ts ? "true" : "false",
+ tiered ? "true" : "false");
printf("Parent: Create %" PRIu32 " threads; sleep %" PRIu32 " seconds\n", nth, timeout);
printf("CONFIG: %s%s%s%s%s -h %s -T %" PRIu32 " -t %" PRIu32 "\n", progname,
- opts->compat ? " -C" : "", opts->inmem ? " -m" : "", opts->tiered_storage ? " -B" : "",
- !use_ts ? " -z" : "", opts->home, nth, timeout);
+ compat ? " -C" : "", inmem ? " -m" : "", tiered ? " -B" : "", !use_ts ? " -z" : "",
+ working_dir, nth, timeout);
/*
* Fork a child to insert as many items. We will then randomly kill the child, run recovery
* and make sure all items we wrote exist after recovery runs.
@@ -1100,11 +1114,15 @@ main(int argc, char *argv[])
testutil_copy_data(home);
printf("Open database, run recovery and verify content\n");
+ strcpy(buf, ENV_CONFIG_REC);
+ if (tiered) {
+ strcat(buf, ENV_CONFIG_TIER_EXT);
+ strcat(buf, ENV_CONFIG_TIER);
+ }
/*
* Open the connection which forces recovery to be run.
*/
- testutil_wiredtiger_open(opts, buf, &event_handler, &conn, true);
-
+ testutil_check(wiredtiger_open(NULL, &event_handler, buf, &conn));
testutil_check(conn->open_session(conn, NULL, NULL, &session));
/*
* Open a cursor on all the tables.
@@ -1186,7 +1204,7 @@ main(int argc, char *argv[])
* If we don't find a record, the stable timestamp written to our file better be
* larger than the saved one.
*/
- if (!opts->inmem && stable_fp != 0 && stable_fp <= stable_val) {
+ if (!inmem && stable_fp != 0 && stable_fp <= stable_val) {
printf("%s: COLLECTION no record with key %" PRIu64 " record ts %" PRIu64
" <= stable ts %" PRIu64 "\n",
fname, key, stable_fp, stable_val);
@@ -1202,7 +1220,7 @@ main(int argc, char *argv[])
*/
c_rep[i].exist_key = key;
fatal = true;
- } else if (!opts->inmem && stable_fp != 0 && stable_fp > stable_val) {
+ } else if (!inmem && stable_fp != 0 && stable_fp > stable_val) {
/*
* If we found a record, the stable timestamp written to our file better be no
* larger than the checkpoint one.
@@ -1218,7 +1236,7 @@ main(int argc, char *argv[])
if ((ret = cur_local->search(cur_local)) != 0) {
if (ret != WT_NOTFOUND)
testutil_die(ret, "search");
- if (!opts->inmem)
+ if (!inmem)
printf("%s: LOCAL no record with key %" PRIu64 "\n", fname, key);
absent_local++;
if (l_rep[i].first_miss == INVALID_KEY)
@@ -1237,7 +1255,7 @@ main(int argc, char *argv[])
if ((ret = cur_oplog->search(cur_oplog)) != 0) {
if (ret != WT_NOTFOUND)
testutil_die(ret, "search");
- if (!opts->inmem)
+ if (!inmem)
printf("%s: OPLOG no record with key %" PRIu64 "\n", fname, key);
absent_oplog++;
if (o_rep[i].first_miss == INVALID_KEY)
@@ -1260,28 +1278,27 @@ main(int argc, char *argv[])
print_missing(&o_rep[i], fname, "OPLOG");
}
testutil_check(conn->close(conn, NULL));
- if (!opts->inmem && absent_coll) {
+ if (!inmem && absent_coll) {
printf("COLLECTION: %" PRIu64 " record(s) absent from %" PRIu64 "\n", absent_coll, count);
fatal = true;
}
- if (!opts->inmem && absent_local) {
+ if (!inmem && absent_local) {
printf("LOCAL: %" PRIu64 " record(s) absent from %" PRIu64 "\n", absent_local, count);
fatal = true;
}
- if (!opts->inmem && absent_oplog) {
+ if (!inmem && absent_oplog) {
printf("OPLOG: %" PRIu64 " record(s) absent from %" PRIu64 "\n", absent_oplog, count);
fatal = true;
}
if (fatal)
return (EXIT_FAILURE);
printf("%" PRIu64 " records verified\n", count);
- if (!opts->preserve) {
+ if (!preserve) {
testutil_clean_test_artifacts(home);
/* At this point $PATH is inside `home`, which we intend to delete. cd to the parent dir. */
if (chdir("../") != 0)
testutil_die(errno, "root chdir: %s", home);
testutil_clean_work_dir(home);
}
- testutil_cleanup(opts);
return (EXIT_SUCCESS);
}
diff --git a/src/third_party/wiredtiger/test/csuite/tiered_abort/main.c b/src/third_party/wiredtiger/test/csuite/tiered_abort/main.c
index dae2aeb9799..c188603f513 100644
--- a/src/third_party/wiredtiger/test/csuite/tiered_abort/main.c
+++ b/src/third_party/wiredtiger/test/csuite/tiered_abort/main.c
@@ -109,7 +109,7 @@ static uint32_t flush_calls = 1;
",eviction_dirty_target=20,eviction_dirty_trigger=90" \
",transaction_sync=(enabled,method=none)"
/* Set the flush_checkpoint debug mode so that the parent can call flush_tier alone. */
-#define ENV_CONFIG_ADD_REC \
+#define ENV_CONFIG_REC \
"log=(recover=on,remove=false),debug_mode=(flush_checkpoint),statistics=(all),statistics_log=" \
"(json,on_close,wait=1)"
@@ -802,7 +802,7 @@ main(int argc, char *argv[])
printf("Open database, run recovery and verify content\n");
/* Open the connection which forces recovery to be run. */
- testutil_check(__wt_snprintf(envconf, sizeof(envconf), ENV_CONFIG_ADD_REC));
+ testutil_check(__wt_snprintf(envconf, sizeof(envconf), ENV_CONFIG_REC));
testutil_check(__wt_snprintf(extconf, sizeof(extconf), ",extensions=(%s/%s=(early_load=true))",
build_dir, WT_STORAGE_LIB));
diff --git a/src/third_party/wiredtiger/test/csuite/timestamp_abort/main.c b/src/third_party/wiredtiger/test/csuite/timestamp_abort/main.c
index d91be97c5a2..4c68871b04c 100644
--- a/src/third_party/wiredtiger/test/csuite/timestamp_abort/main.c
+++ b/src/third_party/wiredtiger/test/csuite/timestamp_abort/main.c
@@ -105,6 +105,8 @@ static uint64_t global_ts = 1;
#define ENV_CONFIG_TXNSYNC \
ENV_CONFIG_DEF \
",transaction_sync=(enabled,method=none)"
+#define ENV_CONFIG_REC \
+ "log=(recover=on,remove=false),statistics=(all),statistics_log=(json,on_close,wait=1)"
/*
* A minimum width of 10, along with zero filling, means that all the keys sort according to their
@@ -903,7 +905,7 @@ main(int argc, char *argv[])
/*
* Open the connection which forces recovery to be run.
*/
- testutil_check(wiredtiger_open(NULL, &my_event, TESTUTIL_ENV_CONFIG_REC, &conn));
+ testutil_check(wiredtiger_open(NULL, &my_event, ENV_CONFIG_REC, &conn));
printf("Connection open and recovery complete. Verify content\n");
/* Sleep to guarantee the statistics thread has enough time to run. */
usleep(USEC_STAT + 10);
diff --git a/src/third_party/wiredtiger/test/csuite/truncated_log/main.c b/src/third_party/wiredtiger/test/csuite/truncated_log/main.c
index 5774ff17d23..568c7ba0f0a 100644
--- a/src/third_party/wiredtiger/test/csuite/truncated_log/main.c
+++ b/src/third_party/wiredtiger/test/csuite/truncated_log/main.c
@@ -40,7 +40,7 @@ static bool use_columns = false;
"create,log=(enabled,file_max=100K,remove=false)," \
"transaction_sync=(enabled,method=none),statistics=(all),statistics_log=(json,on_close,wait=" \
"1)"
-#define ENV_CONFIG_ADD_REC "log=(recover=on),statistics=(all),statistics_log=(json,on_close,wait=1)"
+#define ENV_CONFIG_REC "log=(recover=on),statistics=(all),statistics_log=(json,on_close,wait=1)"
#define LOG_FILE_1 "WiredTigerLog.0000000001"
@@ -319,7 +319,7 @@ main(int argc, char *argv[])
if (truncate(LOG_FILE_1, (wt_off_t)new_offset) != 0)
testutil_die(errno, "truncate");
- testutil_check(wiredtiger_open(NULL, NULL, ENV_CONFIG_ADD_REC, &conn));
+ testutil_check(wiredtiger_open(NULL, NULL, ENV_CONFIG_REC, &conn));
testutil_check(conn->open_session(conn, NULL, NULL, &session));
testutil_check(session->open_cursor(session, uri, NULL, NULL, &cursor));
diff --git a/src/third_party/wiredtiger/test/csuite/wt6616_checkpoint_oldest_ts/main.c b/src/third_party/wiredtiger/test/csuite/wt6616_checkpoint_oldest_ts/main.c
index cc240fe1453..129ccd3f022 100644
--- a/src/third_party/wiredtiger/test/csuite/wt6616_checkpoint_oldest_ts/main.c
+++ b/src/third_party/wiredtiger/test/csuite/wt6616_checkpoint_oldest_ts/main.c
@@ -68,6 +68,9 @@ static const char *const ckpt_file = "checkpoint_done";
"statistics=(all),statistics_log=(json,on_close,wait=1)," \
"timing_stress_for_test=[checkpoint_slow]"
+#define ENV_CONFIG_REC \
+ "log=(recover=on,remove=false),statistics=(all),statistics_log=(json,on_close,wait=1)"
+
static void handler(int) WT_GCC_FUNC_DECL_ATTRIBUTE((noreturn));
static void usage(void) WT_GCC_FUNC_DECL_ATTRIBUTE((noreturn));
@@ -365,7 +368,7 @@ main(int argc, char *argv[])
printf("Open database and run recovery\n");
/* Open the connection which forces recovery to be run. */
- testutil_check(wiredtiger_open(NULL, NULL, TESTUTIL_ENV_CONFIG_REC, &conn));
+ testutil_check(wiredtiger_open(NULL, NULL, ENV_CONFIG_REC, &conn));
testutil_check(conn->open_session(conn, NULL, NULL, &session));
/* Get the stable timestamp from the stable timestamp of the last successful checkpoint. */
diff --git a/src/third_party/wiredtiger/test/csuite/wt8246_compact_rts_data_correctness/main.c b/src/third_party/wiredtiger/test/csuite/wt8246_compact_rts_data_correctness/main.c
index ab43a5415ba..64f9270b370 100644
--- a/src/third_party/wiredtiger/test/csuite/wt8246_compact_rts_data_correctness/main.c
+++ b/src/third_party/wiredtiger/test/csuite/wt8246_compact_rts_data_correctness/main.c
@@ -33,6 +33,8 @@
#define NUM_RECORDS 800000
+#define ENV_CONFIG_REC \
+ "log=(recover=on,remove=false),statistics=(all),statistics_log=(json,on_close,wait=1)"
/* Constants and variables declaration. */
/*
* You may want to add "verbose=[compact,compact_progress]" to the connection config string to get
@@ -180,7 +182,7 @@ run_test(bool column_store, const char *uri, bool preserve)
printf("Open database and run recovery\n");
/* Open the connection which forces recovery to be run. */
- testutil_check(wiredtiger_open(home, NULL, TESTUTIL_ENV_CONFIG_REC, &conn));
+ testutil_check(wiredtiger_open(home, NULL, ENV_CONFIG_REC, &conn));
testutil_check(conn->open_session(conn, NULL, NULL, &session));
/*
diff --git a/src/third_party/wiredtiger/test/utility/misc.c b/src/third_party/wiredtiger/test/utility/misc.c
index cad5c951a28..896efe68aff 100644
--- a/src/third_party/wiredtiger/test/utility/misc.c
+++ b/src/third_party/wiredtiger/test/utility/misc.c
@@ -358,29 +358,6 @@ testutil_print_command_line(int argc, char *const *argv)
printf("\n");
}
-/*
- * testutil_wiredtiger_open --
- * Call wiredtiger_open with the tiered storage configuration if enabled.
- */
-void
-testutil_wiredtiger_open(TEST_OPTS *opts, const char *config, WT_EVENT_HANDLER *event_handler,
- WT_CONNECTION **connectionp, bool rerun)
-{
- char buf[1024];
-
- strncpy(buf, config, sizeof(buf));
- if (rerun)
- strncat(buf, TESTUTIL_ENV_CONFIG_REC, sizeof(buf) - 1);
- else if (opts->compat)
- strncat(buf, TESTUTIL_ENV_CONFIG_COMPAT, sizeof(buf) - 1);
-
- if (opts->tiered_storage) {
- strncat(buf, TESTUTIL_ENV_CONFIG_TIERED_EXT, sizeof(buf) - 1);
- strncat(buf, TESTUTIL_ENV_CONFIG_TIERED, sizeof(buf) - 1);
- }
- testutil_check(wiredtiger_open(NULL, event_handler, buf, connectionp));
-}
-
#ifndef _WIN32
/*
* testutil_sleep_wait --
diff --git a/src/third_party/wiredtiger/test/utility/parse_opts.c b/src/third_party/wiredtiger/test/utility/parse_opts.c
index faee1f15de3..e8d5b9a18c7 100644
--- a/src/third_party/wiredtiger/test/utility/parse_opts.c
+++ b/src/third_party/wiredtiger/test/utility/parse_opts.c
@@ -50,7 +50,7 @@ extern int __wt_optreset;
* parse_tiered_opt --
* Parse a command line option for the tiered storage configurations.
*/
-static void
+static inline void
parse_tiered_opt(TEST_OPTS *opts)
{
switch (*__wt_optarg++) {
@@ -91,14 +91,14 @@ testutil_parse_begin_opt(int argc, char *const *argv, const char *getopts_string
#define USAGE_STR(ch, usage) ((strchr(getopts_string, (ch)) == NULL) ? "" : (usage))
- testutil_check(__wt_snprintf(opts->usage, sizeof(opts->usage), "%s%s%s%s%s%s%s%s%s%s%s%s%s%s%s",
+ testutil_check(__wt_snprintf(opts->usage, sizeof(opts->usage), "%s%s%s%s%s%s%s%s%s%s%s%s%s",
USAGE_STR('A', " [-A append thread count]"), USAGE_STR('b', " [-b build directory]"),
- USAGE_STR('C', " [-C]"), USAGE_STR('d', " [-d add data]"), USAGE_STR('h', " [-h home]"),
- USAGE_STR('m', " [-m]"), USAGE_STR('n', " [-n record count]"),
- USAGE_STR('o', " [-o op count]"), USAGE_STR('P', " [-PT] [-Po storage source]"),
- USAGE_STR('p', " [-p]"), USAGE_STR('R', " [-R read thread count]"),
- USAGE_STR('T', " [-T thread count]"), USAGE_STR('t', " [-t c|f|r table type]"),
- USAGE_STR('v', " [-v]"), USAGE_STR('W', " [-W write thread count]")));
+ USAGE_STR('d', " [-d add data]"), USAGE_STR('h', " [-h home]"),
+ USAGE_STR('n', " [-n record count]"), USAGE_STR('o', " [-o op count]"),
+ USAGE_STR('P', " [-PT] [-Po storage source]"), USAGE_STR('p', " [-p]"),
+ USAGE_STR('R', " [-R read thread count]"), USAGE_STR('T', " [-T thread count]"),
+ USAGE_STR('t', " [-t c|f|r table type]"), USAGE_STR('v', " [-v]"),
+ USAGE_STR('W', " [-W write thread count]")));
}
/*
@@ -153,18 +153,12 @@ testutil_parse_single_opt(TEST_OPTS *opts, int ch)
case 'b': /* Build directory */
opts->build_dir = dstrdup(__wt_optarg);
break;
- case 'C': /* Compatibility */
- opts->compat = true;
- break;
case 'd': /* Use data in multi-threaded test programs */
opts->do_data_ops = true;
break;
case 'h': /* Home directory */
opts->home = dstrdup(__wt_optarg);
break;
- case 'm': /* In-memory */
- opts->inmem = true;
- break;
case 'n': /* Number of records */
opts->nrecords = (uint64_t)atoll(__wt_optarg);
break;
diff --git a/src/third_party/wiredtiger/test/utility/test_util.h b/src/third_party/wiredtiger/test/utility/test_util.h
index d8f31a28382..a0a9cae3efa 100644
--- a/src/third_party/wiredtiger/test/utility/test_util.h
+++ b/src/third_party/wiredtiger/test/utility/test_util.h
@@ -49,16 +49,6 @@
#include "windows_shim.h"
#endif
-#define TESTUTIL_ENV_CONFIG_TIERED \
- ",tiered_storage=(bucket=./" \
- "bucket,bucket_prefix=pfx-,local_retention=2,name=dir_store)"
-#define TESTUTIL_ENV_CONFIG_TIERED_EXT \
- ",extensions=(../../../../ext/storage_sources/dir_store/" \
- "libwiredtiger_dir_store.so=(early_load=true))"
-#define TESTUTIL_ENV_CONFIG_REC \
- "log=(recover=on,remove=false),statistics=(all),statistics_log=(json,on_close,wait=1)"
-#define TESTUTIL_ENV_CONFIG_COMPAT ",compatibility=(release=\"2.9\")"
-
/* Generic option parsing structure shared by all test cases. */
typedef struct {
char *home;
@@ -79,9 +69,7 @@ typedef struct {
FILE *progress_fp; /* Progress tracking file */
char *progress_file_name;
- bool compat; /* Compatibility */
bool do_data_ops; /* Have schema ops use data */
- bool inmem; /* In-memory */
bool preserve; /* Don't remove files on exit */
bool tiered_storage; /* Configure tiered storage */
bool verbose; /* Run in verbose mode */
@@ -407,8 +395,6 @@ void testutil_tiered_begin(TEST_OPTS *);
void testutil_tiered_flush_complete(TEST_OPTS *, WT_SESSION *, void *);
void testutil_tiered_sleep(TEST_OPTS *, WT_SESSION *, uint32_t, bool *);
uint64_t testutil_time_us(WT_SESSION *);
-void testutil_wiredtiger_open(
- TEST_OPTS *, const char *, WT_EVENT_HANDLER *, WT_CONNECTION **, bool);
void testutil_work_dir_from_path(char *, size_t, const char *);
WT_THREAD_RET thread_append(void *);