/*- * Copyright (c) 2014-present MongoDB, Inc. * Copyright (c) 2008-2014 WiredTiger, Inc. * All rights reserved. * * See the file LICENSE for redistribution information. */ #include "util.h" /* * usage -- * Display a usage message for the verify command. */ static int usage(void) { static const char *options[] = {"-a", "abort on error during verification of all tables", "-c", "continue to the next page after encountering error during verification", "-d config", "display underlying information during verification", "-s", "verify against the specified timestamp", "-t", "do not clear txn ids during verification", "-k", "display only the keys in the application data with configuration dump_blocks or dump_pages", "-u", "display all the application data when dumping with configuration dump_blocks or dump_pages", "-?", "show this message", NULL, NULL}; util_usage( "verify [-ackSstu] [-d dump_address | dump_blocks | dump_layout | dump_tree_shape | " "dump_offsets=#,# " "| dump_pages] [uri]", "options:", options); return (1); } /* * verify_one -- * Verify the file specified by the URI. */ static int verify_one(WT_SESSION *session, char *config, char *uri) { WT_DECL_RET; if ((ret = session->verify(session, uri, config)) != 0) ret = util_err(session, ret, "session.verify: %s", uri); else if (verbose) { /* Verbose configures a progress counter, move to the next line. */ printf("\n"); } return (ret); } /* * util_verify -- * The verify command. */ int util_verify(WT_SESSION *session, int argc, char *argv[]) { WT_CURSOR *cursor; WT_DECL_RET; size_t size; int ch; char *config, *dump_offsets, *key, *uri; bool abort_on_error, do_not_clear_txn_id, dump_address, dump_all_data, dump_key_data, dump_blocks, dump_layout, dump_tree_shape, dump_pages, read_corrupt, stable_timestamp, strict; abort_on_error = do_not_clear_txn_id = dump_address = dump_all_data = dump_key_data = dump_blocks = dump_layout = dump_tree_shape = dump_pages = read_corrupt = stable_timestamp = strict = false; config = dump_offsets = uri = NULL; while ((ch = __wt_getopt(progname, argc, argv, "acd:kSstu?")) != EOF) switch (ch) { case 'a': abort_on_error = true; break; case 'c': read_corrupt = true; break; case 'd': if (strcmp(__wt_optarg, "dump_address") == 0) dump_address = true; else if (strcmp(__wt_optarg, "dump_blocks") == 0) dump_blocks = true; else if (strcmp(__wt_optarg, "dump_layout") == 0) dump_layout = true; else if (strcmp(__wt_optarg, "dump_tree_shape") == 0) dump_tree_shape = true; else if (WT_PREFIX_MATCH(__wt_optarg, "dump_offsets=")) { if (dump_offsets != NULL) { fprintf( stderr, "%s: only a single 'dump_offsets' argument supported\n", progname); return (usage()); } dump_offsets = __wt_optarg + strlen("dump_offsets="); } else if (strcmp(__wt_optarg, "dump_pages") == 0) dump_pages = true; else return (usage()); break; case 'k': dump_key_data = true; break; case 'S': strict = true; break; case 's': stable_timestamp = true; break; case 't': do_not_clear_txn_id = true; break; case 'u': dump_all_data = true; break; case '?': usage(); return (0); default: return (usage()); } if (dump_all_data && dump_key_data) WT_RET_MSG((WT_SESSION_IMPL *)session, ENOTSUP, "%s", "-u (unredact all data), should not be set to true simultaneously with -k (unredact only " "keys)"); argc -= __wt_optind; argv += __wt_optind; if (do_not_clear_txn_id || dump_address || dump_all_data || dump_blocks || dump_key_data || dump_layout || dump_tree_shape || dump_offsets != NULL || dump_pages || read_corrupt || stable_timestamp || strict) { size = strlen("do_not_clear_txn_id,") + strlen("dump_address,") + strlen("dump_all_data,") + strlen("dump_blocks,") + strlen("dump_key_data,") + strlen("dump_layout,") + strlen("dump_tree_shape,") + strlen("dump_pages,") + strlen("dump_offsets[],") + (dump_offsets == NULL ? 0 : strlen(dump_offsets)) + strlen("history_store") + strlen("read_corrupt,") + strlen("stable_timestamp,") + strlen("strict") + 20; if ((config = util_malloc(size)) == NULL) { ret = util_err(session, errno, NULL); goto err; } if ((ret = __wt_snprintf(config, size, "%s%s%s%s%s%s%s%s%s%s%s%s%s%s", do_not_clear_txn_id ? "do_not_clear_txn_id," : "", dump_address ? "dump_address," : "", dump_all_data ? "dump_all_data," : "", dump_blocks ? "dump_blocks," : "", dump_key_data ? "dump_key_data," : "", dump_layout ? "dump_layout," : "", dump_tree_shape ? "dump_tree_shape," : "", dump_offsets != NULL ? "dump_offsets=[" : "", dump_offsets != NULL ? dump_offsets : "", dump_offsets != NULL ? "]," : "", dump_pages ? "dump_pages," : "", read_corrupt ? "read_corrupt," : "", stable_timestamp ? "stable_timestamp," : "", strict ? "strict," : "")) != 0) { (void)util_err(session, ret, NULL); goto err; } } /* Verify all the tables if no particular URI is specified. */ if (argc < 1) { /* Open the metadata file and iterate through its entries, verifying each one. */ if ((ret = session->open_cursor(session, WT_METADATA_URI, NULL, NULL, &cursor)) != 0) { /* * If there is no metadata (yet), this will return ENOENT. Treat that the same as an * empty metadata. */ if (ret == ENOENT) ret = 0; WT_ERR(util_err(session, ret, "%s: WT_SESSION.open_cursor", WT_METADATA_URI)); } while ((ret = cursor->next(cursor)) == 0) { if ((ret = cursor->get_key(cursor, &key)) != 0) WT_ERR(util_cerr(cursor, "get_key", ret)); /* * Typically each WT file will have multiple entries, and so only run verify on table * and lsm entries to prevent unnecessary work. Skip over the double up entries and also * any entries that are not supported with verify. */ if ((WT_PREFIX_MATCH(key, "table:") || WT_PREFIX_MATCH(key, "lsm:")) && !WT_PREFIX_MATCH(key, WT_SYSTEM_PREFIX)) { if (abort_on_error) WT_ERR_ERROR_OK(verify_one(session, config, key), ENOTSUP, false); else WT_TRET(verify_one(session, config, key)); } } if (ret == WT_NOTFOUND) ret = 0; } else { if ((uri = util_uri(session, *argv, "table")) == NULL) goto err; ret = verify_one(session, config, uri); } err: util_free(config); util_free(uri); return (ret); }