diff options
author | Siddhartha Mahajan <siddhartha.mahajan8899@mongodb.com> | 2022-11-04 00:16:10 +0000 |
---|---|---|
committer | Evergreen Agent <no-reply@evergreen.mongodb.com> | 2022-11-04 00:45:59 +0000 |
commit | ca7e8d9c7e2089ca347ce51c7906d11e55fc8d70 (patch) | |
tree | 3ebe114119ddd255792cbe152afae8c443f63264 | |
parent | 546e9db9f7a6d9bfce68261be7e9580a83c575aa (diff) | |
download | mongo-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.data | 2 | ||||
-rw-r--r-- | src/third_party/wiredtiger/src/txn/txn.c | 8 | ||||
-rw-r--r-- | src/third_party/wiredtiger/src/txn/txn_ckpt.c | 2 | ||||
-rw-r--r-- | src/third_party/wiredtiger/src/txn/txn_recover.c | 2 | ||||
-rw-r--r-- | src/third_party/wiredtiger/src/txn/txn_rollback_to_stable.c | 20 |
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: |