summaryrefslogtreecommitdiff
path: root/src/mongo/db/op_observer_impl_test.cpp
diff options
context:
space:
mode:
authorCheahuychou Mao <mao.cheahuychou@gmail.com>2022-01-14 19:38:07 +0000
committerEvergreen Agent <no-reply@evergreen.mongodb.com>2022-01-14 21:42:58 +0000
commit29ef581da2924a81963c563c0f96edd5e56ca9c7 (patch)
treee25723f3eff63fa8b8b6b170ea34e9a810ae10d8 /src/mongo/db/op_observer_impl_test.cpp
parentda1a24bd16ce627122def05de91856ea8686b64a (diff)
downloadmongo-29ef581da2924a81963c563c0f96edd5e56ca9c7.tar.gz
SERVER-62020 Make retryable write statements executed with or without internal transactions retryable whether or not internal transactions are involved on retries
Diffstat (limited to 'src/mongo/db/op_observer_impl_test.cpp')
-rw-r--r--src/mongo/db/op_observer_impl_test.cpp4
1 files changed, 2 insertions, 2 deletions
diff --git a/src/mongo/db/op_observer_impl_test.cpp b/src/mongo/db/op_observer_impl_test.cpp
index d0273e162ea..0f8b635acd3 100644
--- a/src/mongo/db/op_observer_impl_test.cpp
+++ b/src/mongo/db/op_observer_impl_test.cpp
@@ -746,7 +746,7 @@ TEST_F(OpObserverSessionCatalogRollbackTest,
simulateSessionWrite(opCtx.get(), txnParticipant, nss, txnNum, stmtId);
// Check that the statement executed
- ASSERT(txnParticipant.checkStatementExecutedNoOplogEntryFetch(stmtId));
+ ASSERT(txnParticipant.checkStatementExecutedNoOplogEntryFetch(opCtx.get(), stmtId));
}
// Because there are no sessions to rollback, the OpObserver should not invalidate the in-memory
@@ -764,7 +764,7 @@ TEST_F(OpObserverSessionCatalogRollbackTest,
opCtx->setLogicalSessionId(sessionId);
MongoDOperationContextSession ocs(opCtx.get());
auto txnParticipant = TransactionParticipant::get(opCtx.get());
- ASSERT(txnParticipant.checkStatementExecutedNoOplogEntryFetch(stmtId));
+ ASSERT(txnParticipant.checkStatementExecutedNoOplogEntryFetch(opCtx.get(), stmtId));
}
}