summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorSiddhartha Mahajan <siddhartha.mahajan8899@mongodb.com>2022-11-04 00:16:10 +0000
committerEvergreen Agent <no-reply@evergreen.mongodb.com>2022-11-04 00:45:59 +0000
commitca7e8d9c7e2089ca347ce51c7906d11e55fc8d70 (patch)
tree3ebe114119ddd255792cbe152afae8c443f63264
parent546e9db9f7a6d9bfce68261be7e9580a83c575aa (diff)
downloadmongo-ca7e8d9c7e2089ca347ce51c7906d11e55fc8d70.tar.gz
Import wiredtiger: 61d013e0ea816d72592686ea05674b9f41ffadfa from branch mongodb-master
ref: 0ac71ba2af..61d013e0ea for: 6.2.0-rc0 WT-10059 Check RTS and txn verbosity
-rw-r--r--src/third_party/wiredtiger/import.data2
-rw-r--r--src/third_party/wiredtiger/src/txn/txn.c8
-rw-r--r--src/third_party/wiredtiger/src/txn/txn_ckpt.c2
-rw-r--r--src/third_party/wiredtiger/src/txn/txn_recover.c2
-rw-r--r--src/third_party/wiredtiger/src/txn/txn_rollback_to_stable.c20
5 files changed, 18 insertions, 16 deletions
diff --git a/src/third_party/wiredtiger/import.data b/src/third_party/wiredtiger/import.data
index c6771f50429..01742f10018 100644
--- a/src/third_party/wiredtiger/import.data
+++ b/src/third_party/wiredtiger/import.data
@@ -2,5 +2,5 @@
"vendor": "wiredtiger",
"github": "wiredtiger/wiredtiger.git",
"branch": "mongodb-master",
- "commit": "0ac71ba2af5d2b3abceeccce1bf924b3c560d26e"
+ "commit": "61d013e0ea816d72592686ea05674b9f41ffadfa"
}
diff --git a/src/third_party/wiredtiger/src/txn/txn.c b/src/third_party/wiredtiger/src/txn/txn.c
index 04c693297a6..0aca6b79756 100644
--- a/src/third_party/wiredtiger/src/txn/txn.c
+++ b/src/third_party/wiredtiger/src/txn/txn.c
@@ -762,7 +762,7 @@ __txn_prepare_rollback_restore_hs_update(
F_SET(upd, WT_UPDATE_RESTORED_FROM_HS | WT_UPDATE_TO_DELETE_FROM_HS);
total_size += size;
- __wt_verbose(session, WT_VERB_TRANSACTION,
+ __wt_verbose_debug2(session, WT_VERB_TRANSACTION,
"update restored from history store (txnid: %" PRIu64 ", start_ts: %s, durable_ts: %s",
upd->txnid, __wt_timestamp_to_string(upd->start_ts, ts_string[0]),
__wt_timestamp_to_string(upd->durable_ts, ts_string[1]));
@@ -782,7 +782,7 @@ __txn_prepare_rollback_restore_hs_update(
F_SET(tombstone, WT_UPDATE_RESTORED_FROM_HS | WT_UPDATE_TO_DELETE_FROM_HS);
total_size += size;
- __wt_verbose(session, WT_VERB_TRANSACTION,
+ __wt_verbose_debug2(session, WT_VERB_TRANSACTION,
"tombstone restored from history store (txnid: %" PRIu64 ", start_ts: %s, durable_ts: %s",
tombstone->txnid, __wt_timestamp_to_string(tombstone->start_ts, ts_string[0]),
__wt_timestamp_to_string(tombstone->durable_ts, ts_string[1]));
@@ -1178,14 +1178,14 @@ __txn_resolve_prepared_op(WT_SESSION_IMPL *session, WT_TXN_OP *op, bool commit,
WT_RET(__txn_search_prepared_op(session, op, cursorp, &upd));
if (commit)
- __wt_verbose(session, WT_VERB_TRANSACTION,
+ __wt_verbose_debug2(session, WT_VERB_TRANSACTION,
"commit resolving prepared transaction with txnid: %" PRIu64
"and timestamp: %s to commit and durable timestamps: %s,%s",
txn->id, __wt_timestamp_to_string(txn->prepare_timestamp, ts_string[0]),
__wt_timestamp_to_string(txn->commit_timestamp, ts_string[1]),
__wt_timestamp_to_string(txn->durable_timestamp, ts_string[2]));
else
- __wt_verbose(session, WT_VERB_TRANSACTION,
+ __wt_verbose_debug2(session, WT_VERB_TRANSACTION,
"rollback resolving prepared transaction with txnid: %" PRIu64 "and timestamp:%s",
txn->id, __wt_timestamp_to_string(txn->prepare_timestamp, ts_string[0]));
diff --git a/src/third_party/wiredtiger/src/txn/txn_ckpt.c b/src/third_party/wiredtiger/src/txn/txn_ckpt.c
index fff1c86403a..352334d234c 100644
--- a/src/third_party/wiredtiger/src/txn/txn_ckpt.c
+++ b/src/third_party/wiredtiger/src/txn/txn_ckpt.c
@@ -106,7 +106,7 @@ __checkpoint_flush_tier(WT_SESSION_IMPL *session, bool force)
cursor->get_value(cursor, &value);
/* For now just switch tiers which just does metadata manipulation. */
if (WT_PREFIX_MATCH(key, "tiered:")) {
- __wt_verbose(
+ __wt_verbose_debug2(
session, WT_VERB_TIERED, "CKPT_FLUSH_TIER: %s %s force %d", key, value, force);
if (!force) {
/*
diff --git a/src/third_party/wiredtiger/src/txn/txn_recover.c b/src/third_party/wiredtiger/src/txn/txn_recover.c
index 4638f906089..c2c2e5b74b0 100644
--- a/src/third_party/wiredtiger/src/txn/txn_recover.c
+++ b/src/third_party/wiredtiger/src/txn/txn_recover.c
@@ -106,7 +106,7 @@ __recovery_cursor(
*/
#define GET_RECOVERY_CURSOR(session, r, lsnp, fileid, cp) \
ret = __recovery_cursor(session, r, lsnp, fileid, false, cp); \
- __wt_verbose(session, WT_VERB_RECOVERY, \
+ __wt_verbose_debug2(session, WT_VERB_RECOVERY, \
"%s op %" PRIu32 " to file %" PRIu32 " at LSN %" PRIu32 "/%" PRIu32, \
ret != 0 ? "Error" : cursor == NULL ? "Skipping" : "Applying", optype, fileid, \
(lsnp)->l.file, (lsnp)->l.offset); \
diff --git a/src/third_party/wiredtiger/src/txn/txn_rollback_to_stable.c b/src/third_party/wiredtiger/src/txn/txn_rollback_to_stable.c
index 329d8a9eac2..2f4411e4a4d 100644
--- a/src/third_party/wiredtiger/src/txn/txn_rollback_to_stable.c
+++ b/src/third_party/wiredtiger/src/txn/txn_rollback_to_stable.c
@@ -404,7 +404,8 @@ __rollback_ondisk_fixup_key(WT_SESSION_IMPL *session, WT_REF *ref, WT_ROW *rip,
}
WT_ERR(__wt_scr_alloc(session, 0, &key_string));
- __wt_verbose_multi(session, WT_VERB_RECOVERY_RTS(session), "rolling back the on-disk key: %s",
+ __wt_verbose_level_multi(session, WT_VERB_RECOVERY_RTS(session), WT_VERBOSE_DEBUG_2,
+ "rolling back the on-disk key: %s",
__wt_key_string(session, key->data, key->size, S2BT(session)->key_format, key_string));
WT_ERR(__wt_scr_alloc(session, 0, &full_value));
@@ -492,7 +493,7 @@ __rollback_ondisk_fixup_key(WT_SESSION_IMPL *session, WT_REF *ref, WT_ROW *rip,
WT_ERR(__wt_buf_set(session, full_value, hs_value->data, hs_value->size));
}
} else
- __wt_verbose_multi(session, WT_VERB_RECOVERY_RTS(session),
+ __wt_verbose_level_multi(session, WT_VERB_RECOVERY_RTS(session), WT_VERBOSE_DEBUG_2,
"history store update more recent than on-disk update with time window: %s and type: "
"%" PRIu8,
__wt_time_window_to_string(hs_tw, tw_string), type);
@@ -544,7 +545,7 @@ __rollback_ondisk_fixup_key(WT_SESSION_IMPL *session, WT_REF *ref, WT_ROW *rip,
*/
if (__rollback_txn_visible_id(session, hs_tw->start_txn) &&
hs_tw->durable_start_ts <= rollback_timestamp) {
- __wt_verbose_multi(session, WT_VERB_RECOVERY_RTS(session),
+ __wt_verbose_level_multi(session, WT_VERB_RECOVERY_RTS(session), WT_VERBOSE_DEBUG_2,
"history store update valid with time window: %s, type: %" PRIu8
" and stable timestamp: %s",
__wt_time_window_to_string(hs_tw, tw_string), type,
@@ -656,7 +657,8 @@ __rollback_ondisk_fixup_key(WT_SESSION_IMPL *session, WT_REF *ref, WT_ROW *rip,
} else {
WT_ERR(__wt_upd_alloc_tombstone(session, &upd, NULL));
WT_STAT_CONN_DATA_INCR(session, txn_rts_keys_removed);
- __wt_verbose_multi(session, WT_VERB_RECOVERY_RTS(session), "%s", "key removed");
+ __wt_verbose_level_multi(
+ session, WT_VERB_RECOVERY_RTS(session), WT_VERBOSE_DEBUG_3, "%s", "key removed");
}
if (rip != NULL)
@@ -846,8 +848,8 @@ __rollback_abort_ondisk_kv(WT_SESSION_IMPL *session, WT_REF *ref, WT_ROW *rip, u
}
WT_ERR(__wt_scr_alloc(session, 0, &key_string));
- __wt_verbose_multi(session, WT_VERB_RECOVERY_RTS(session), "removing the key%s: %s",
- upd->type == WT_UPDATE_TOMBSTONE ? "" : " tombstone",
+ __wt_verbose_level_multi(session, WT_VERB_RECOVERY_RTS(session), WT_VERBOSE_DEBUG_2,
+ "removing the key%s: %s", upd->type == WT_UPDATE_TOMBSTONE ? "" : " tombstone",
__wt_key_string(session, key->data, key->size, S2BT(session)->key_format, key_string));
if (rip != NULL)
@@ -1266,14 +1268,14 @@ __rollback_abort_updates(WT_SESSION_IMPL *session, WT_REF *ref, wt_timestamp_t r
page = ref->page;
modified = __wt_page_is_modified(page);
if (!modified && !__rollback_page_needs_abort(session, ref, rollback_timestamp)) {
- __wt_verbose_multi(session, WT_VERB_RECOVERY_RTS(session),
+ __wt_verbose_level_multi(session, WT_VERB_RECOVERY_RTS(session), WT_VERBOSE_DEBUG_3,
"%p: unmodified stable page skipped", (void *)ref);
return (0);
}
WT_STAT_CONN_INCR(session, txn_rts_pages_visited);
- __wt_verbose_multi(session, WT_VERB_RECOVERY_RTS(session), "%p: roll back %s page", (void *)ref,
- modified ? "modified" : "clean");
+ __wt_verbose_level_multi(session, WT_VERB_RECOVERY_RTS(session), WT_VERBOSE_DEBUG_2,
+ "%p: roll back %s page", (void *)ref, modified ? "modified" : "clean");
switch (page->type) {
case WT_PAGE_COL_FIX: