summaryrefslogtreecommitdiff
path: root/src/mongo/db/operation_context.cpp
diff options
context:
space:
mode:
authorCheahuychou Mao <mao.cheahuychou@gmail.com>2021-08-19 05:37:25 +0000
committerEvergreen Agent <no-reply@evergreen.mongodb.com>2021-09-01 22:02:16 +0000
commit22beeff23a26e44127a15587e8bfd84f1d1e916c (patch)
treebc88a80b18693021bdb60db0399d9ec20630e97c /src/mongo/db/operation_context.cpp
parent9486a2779da1e8821b4b6d90ef3327a649c10b62 (diff)
downloadmongo-22beeff23a26e44127a15587e8bfd84f1d1e916c.tar.gz
SERVER-58752 Support retrying internal transactions on transient transaction errors
Diffstat (limited to 'src/mongo/db/operation_context.cpp')
-rw-r--r--src/mongo/db/operation_context.cpp7
1 files changed, 7 insertions, 0 deletions
diff --git a/src/mongo/db/operation_context.cpp b/src/mongo/db/operation_context.cpp
index cb97d6a197a..0b10331e968 100644
--- a/src/mongo/db/operation_context.cpp
+++ b/src/mongo/db/operation_context.cpp
@@ -406,6 +406,13 @@ void OperationContext::setTxnNumber(TxnNumber txnNumber) {
_txnNumber = txnNumber;
}
+void OperationContext::setTxnRetryCounter(TxnRetryCounter txnRetryCounter) {
+ invariant(_lsid);
+ invariant(_txnNumber);
+ invariant(!_txnRetryCounter.has_value());
+ _txnRetryCounter = txnRetryCounter;
+}
+
std::unique_ptr<RecoveryUnit> OperationContext::releaseRecoveryUnit() {
return std::move(_recoveryUnit);
}