diff options
Diffstat (limited to 'src/mongo/db/op_observer_impl.cpp')
-rw-r--r-- | src/mongo/db/op_observer_impl.cpp | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/src/mongo/db/op_observer_impl.cpp b/src/mongo/db/op_observer_impl.cpp index 524157fafa1..c67b51c8717 100644 --- a/src/mongo/db/op_observer_impl.cpp +++ b/src/mongo/db/op_observer_impl.cpp @@ -190,7 +190,7 @@ OpTimeBundle replLogUpdate(OperationContext* opCtx, const OplogUpdateEntryArgs& if (txnParticipant) { sessionInfo.setSessionId(*opCtx->getLogicalSessionId()); sessionInfo.setTxnNumber(*opCtx->getTxnNumber()); - oplogLink.prevOpTime = txnParticipant->getLastWriteOpTime(*opCtx->getTxnNumber()); + oplogLink.prevOpTime = txnParticipant->getLastWriteOpTime(); } OpTimeBundle opTimes; @@ -254,7 +254,7 @@ OpTimeBundle replLogDelete(OperationContext* opCtx, if (txnParticipant) { sessionInfo.setSessionId(*opCtx->getLogicalSessionId()); sessionInfo.setTxnNumber(*opCtx->getTxnNumber()); - oplogLink.prevOpTime = txnParticipant->getLastWriteOpTime(*opCtx->getTxnNumber()); + oplogLink.prevOpTime = txnParticipant->getLastWriteOpTime(); } OpTimeBundle opTimes; @@ -940,7 +940,7 @@ OpTimeBundle logApplyOpsForTransaction(OperationContext* opCtx, sessionInfo.setTxnNumber(*opCtx->getTxnNumber()); const auto txnParticipant = TransactionParticipant::get(opCtx); - oplogLink.prevOpTime = txnParticipant->getLastWriteOpTime(*opCtx->getTxnNumber()); + oplogLink.prevOpTime = txnParticipant->getLastWriteOpTime(); // Until we support multiple oplog entries per transaction, prevOpTime should always be null. invariant(oplogLink.prevOpTime.isNull()); @@ -983,7 +983,7 @@ void logCommitOrAbortForPreparedTransaction(OperationContext* opCtx, sessionInfo.setTxnNumber(*opCtx->getTxnNumber()); const auto txnParticipant = TransactionParticipant::get(opCtx); - oplogLink.prevOpTime = txnParticipant->getLastWriteOpTime(*opCtx->getTxnNumber()); + oplogLink.prevOpTime = txnParticipant->getLastWriteOpTime(); const StmtId stmtId(1); const auto wallClockTime = getWallClockTimeForOpLog(opCtx); |