diff options
Diffstat (limited to 'src/mongo/db/s/txn_two_phase_commit_cmds.cpp')
| -rw-r--r-- | src/mongo/db/s/txn_two_phase_commit_cmds.cpp | 10 |
1 files changed, 4 insertions, 6 deletions
diff --git a/src/mongo/db/s/txn_two_phase_commit_cmds.cpp b/src/mongo/db/s/txn_two_phase_commit_cmds.cpp index 18596e672a9..147878c02d6 100644 --- a/src/mongo/db/s/txn_two_phase_commit_cmds.cpp +++ b/src/mongo/db/s/txn_two_phase_commit_cmds.cpp @@ -321,10 +321,9 @@ public: MongoDOperationContextSession sessionTxnState(opCtx); auto txnParticipant = TransactionParticipant::get(opCtx); txnParticipant.beginOrContinue(opCtx, - *opCtx->getTxnNumber(), + txnNumberAndRetryCounter, false /* autocommit */, - boost::none /* startTransaction */, - *opCtx->getTxnRetryCounter()); + boost::none /* startTransaction */); if (txnParticipant.transactionIsCommitted()) return; @@ -344,10 +343,9 @@ public: // Call beginOrContinue again in case the transaction number has changed. txnParticipant.beginOrContinue(opCtx, - *opCtx->getTxnNumber(), + txnNumberAndRetryCounter, false /* autocommit */, - boost::none /* startTransaction */, - *opCtx->getTxnRetryCounter()); + boost::none /* startTransaction */); invariant(!txnParticipant.transactionIsOpen(), "The participant should not be in progress after we waited for the " |