summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorGregory Noma <gregory.noma@gmail.com>2022-03-30 17:40:36 +0000
committerEvergreen Agent <no-reply@evergreen.mongodb.com>2022-05-20 13:23:48 +0000
commitc7793f7d8adcede69939b1c2242598828da2fdc1 (patch)
tree2e78dc0e30e40871731041faa98b61647d0da6be /src
parentaecbb01f4bf1e34f0f299eab5b6ea950dd2a7a73 (diff)
downloadmongo-c7793f7d8adcede69939b1c2242598828da2fdc1.tar.gz
SERVER-64797 Use `WT_SESSION::timestamp_transaction_uint`
(cherry picked from commit f9bbbfb86db15ac7e4111890447dc46caf5fe4b4)
Diffstat (limited to 'src')
-rw-r--r--src/mongo/db/storage/wiredtiger/wiredtiger_begin_transaction_block.cpp5
-rw-r--r--src/mongo/db/storage/wiredtiger/wiredtiger_recovery_unit.cpp4
2 files changed, 4 insertions, 5 deletions
diff --git a/src/mongo/db/storage/wiredtiger/wiredtiger_begin_transaction_block.cpp b/src/mongo/db/storage/wiredtiger/wiredtiger_begin_transaction_block.cpp
index 2307cff038b..45acf82f307 100644
--- a/src/mongo/db/storage/wiredtiger/wiredtiger_begin_transaction_block.cpp
+++ b/src/mongo/db/storage/wiredtiger/wiredtiger_begin_transaction_block.cpp
@@ -91,9 +91,8 @@ WiredTigerBeginTxnBlock::~WiredTigerBeginTxnBlock() {
Status WiredTigerBeginTxnBlock::setReadSnapshot(Timestamp readTimestamp) {
invariant(_rollback);
- std::string readTSConfigString = "read_timestamp={:x}"_format(readTimestamp.asULL());
-
- return wtRCToStatus(_session->timestamp_transaction(_session, readTSConfigString.c_str()));
+ return wtRCToStatus(
+ _session->timestamp_transaction_uint(_session, WT_TS_TXN_TYPE_READ, readTimestamp.asULL()));
}
void WiredTigerBeginTxnBlock::done() {
diff --git a/src/mongo/db/storage/wiredtiger/wiredtiger_recovery_unit.cpp b/src/mongo/db/storage/wiredtiger/wiredtiger_recovery_unit.cpp
index 995f880921b..11fbd699c1c 100644
--- a/src/mongo/db/storage/wiredtiger/wiredtiger_recovery_unit.cpp
+++ b/src/mongo/db/storage/wiredtiger/wiredtiger_recovery_unit.cpp
@@ -797,8 +797,8 @@ Status WiredTigerRecoveryUnit::setTimestamp(Timestamp timestamp) {
return Status::OK();
}
- const std::string conf = "commit_timestamp=" + unsignedHex(timestamp.asULL());
- auto rc = session->timestamp_transaction(session, conf.c_str());
+ auto rc =
+ session->timestamp_transaction_uint(session, WT_TS_TXN_TYPE_COMMIT, timestamp.asULL());
if (rc == 0) {
_isTimestamped = true;
}