diff options
author | Cheahuychou Mao <mao.cheahuychou@gmail.com> | 2022-01-14 19:38:07 +0000 |
---|---|---|
committer | Evergreen Agent <no-reply@evergreen.mongodb.com> | 2022-01-14 21:42:58 +0000 |
commit | 29ef581da2924a81963c563c0f96edd5e56ca9c7 (patch) | |
tree | e25723f3eff63fa8b8b6b170ea34e9a810ae10d8 /src/mongo/db/op_observer_impl_test.cpp | |
parent | da1a24bd16ce627122def05de91856ea8686b64a (diff) | |
download | mongo-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.cpp | 4 |
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)); } } |