diff options
Diffstat (limited to 'src/third_party/wiredtiger/src/btree/bt_curprev.c')
-rw-r--r-- | src/third_party/wiredtiger/src/btree/bt_curprev.c | 16 |
1 files changed, 8 insertions, 8 deletions
diff --git a/src/third_party/wiredtiger/src/btree/bt_curprev.c b/src/third_party/wiredtiger/src/btree/bt_curprev.c index 3b13e4b7b9c..fa3718a6e87 100644 --- a/src/third_party/wiredtiger/src/btree/bt_curprev.c +++ b/src/third_party/wiredtiger/src/btree/bt_curprev.c @@ -197,7 +197,7 @@ __cursor_fix_append_prev(WT_CURSOR_BTREE *cbt, bool newpage, bool restart) cbt->iface.value.data = &cbt->v; } else { restart_read: - WT_RET(__wt_txn_read_upd_list(session, cbt, cbt->ins->upd)); + WT_RET(__wt_txn_read_upd_list(session, cbt, cbt->ins->upd, NULL)); if (cbt->upd_value->type == WT_UPDATE_INVALID) { cbt->v = 0; cbt->iface.value.data = &cbt->v; @@ -296,11 +296,11 @@ new_page: __cursor_set_recno(cbt, WT_INSERT_RECNO(cbt->ins)); restart_read: - WT_RET(__wt_txn_read_upd_list(session, cbt, cbt->ins->upd)); + WT_RET(__wt_txn_read_upd_list(session, cbt, cbt->ins->upd, NULL)); if (cbt->upd_value->type == WT_UPDATE_INVALID) continue; if (cbt->upd_value->type == WT_UPDATE_TOMBSTONE) { - if (cbt->upd_value->txnid != WT_TXN_NONE && + if (cbt->upd_value->tw.stop_txn != WT_TXN_NONE && __wt_txn_upd_value_visible_all(session, cbt->upd_value)) ++cbt->page_deleted_count; continue; @@ -367,10 +367,10 @@ restart_read: cbt->ins = __col_insert_search_match(cbt->ins_head, cbt->recno); __wt_upd_value_clear(cbt->upd_value); if (cbt->ins != NULL) - WT_RET(__wt_txn_read_upd_list(session, cbt, cbt->ins->upd)); + WT_RET(__wt_txn_read_upd_list(session, cbt, cbt->ins->upd, NULL)); if (cbt->upd_value->type != WT_UPDATE_INVALID) { if (cbt->upd_value->type == WT_UPDATE_TOMBSTONE) { - if (cbt->upd_value->txnid != WT_TXN_NONE && + if (cbt->upd_value->tw.stop_txn != WT_TXN_NONE && __wt_txn_upd_value_visible_all(session, cbt->upd_value)) ++cbt->page_deleted_count; continue; @@ -502,11 +502,11 @@ restart_read_insert: if ((ins = cbt->ins) != NULL) { key->data = WT_INSERT_KEY(ins); key->size = WT_INSERT_KEY_SIZE(ins); - WT_RET(__wt_txn_read_upd_list(session, cbt, ins->upd)); + WT_RET(__wt_txn_read_upd_list(session, cbt, ins->upd, NULL)); if (cbt->upd_value->type == WT_UPDATE_INVALID) continue; if (cbt->upd_value->type == WT_UPDATE_TOMBSTONE) { - if (cbt->upd_value->txnid != WT_TXN_NONE && + if (cbt->upd_value->tw.stop_txn != WT_TXN_NONE && __wt_txn_upd_value_visible_all(session, cbt->upd_value)) ++cbt->page_deleted_count; continue; @@ -543,7 +543,7 @@ restart_read_page: if (cbt->upd_value->type == WT_UPDATE_INVALID) continue; if (cbt->upd_value->type == WT_UPDATE_TOMBSTONE) { - if (cbt->upd_value->txnid != WT_TXN_NONE && + if (cbt->upd_value->tw.stop_txn != WT_TXN_NONE && __wt_txn_upd_value_visible_all(session, cbt->upd_value)) ++cbt->page_deleted_count; continue; |