diff options
author | Jason Chan <jason.chan@10gen.com> | 2019-03-25 14:04:50 -0400 |
---|---|---|
committer | Jason Chan <jason.chan@10gen.com> | 2019-03-25 14:18:15 -0400 |
commit | f8bf360e86ff96a0636575af7d1cee8ae9f0c3f0 (patch) | |
tree | fca8003369076ab69c7be139e8d726538e78e944 /src/mongo/db/transaction_participant_retryable_writes_test.cpp | |
parent | 35374f25e2bc3fca9b42958ffc98032cf31f53a1 (diff) | |
download | mongo-f8bf360e86ff96a0636575af7d1cee8ae9f0c3f0.tar.gz |
SERVER-39792 Update the txn table only on the first txn operation on primary
Diffstat (limited to 'src/mongo/db/transaction_participant_retryable_writes_test.cpp')
-rw-r--r-- | src/mongo/db/transaction_participant_retryable_writes_test.cpp | 21 |
1 files changed, 13 insertions, 8 deletions
diff --git a/src/mongo/db/transaction_participant_retryable_writes_test.cpp b/src/mongo/db/transaction_participant_retryable_writes_test.cpp index 6f51d4ddf7c..84a9da1c91f 100644 --- a/src/mongo/db/transaction_participant_retryable_writes_test.cpp +++ b/src/mongo/db/transaction_participant_retryable_writes_test.cpp @@ -238,7 +238,7 @@ protected: const auto opTime = logOp(opCtx(), kNss, uuid, session->getSessionId(), txnNum, stmtId, prevOpTime); txnParticipant.onWriteOpCompletedOnPrimary( - opCtx(), txnNum, {stmtId}, opTime, Date_t::now(), txnState); + opCtx(), txnNum, {stmtId}, opTime, Date_t::now(), txnState, boost::none); wuow.commit(); return opTime; @@ -398,7 +398,7 @@ TEST_F(TransactionParticipantRetryableWritesTest, SessionTransactionsCollectionN const auto uuid = UUID::gen(); const auto opTime = logOp(opCtx(), kNss, uuid, sessionId, txnNum, 0); ASSERT_THROWS(txnParticipant.onWriteOpCompletedOnPrimary( - opCtx(), txnNum, {0}, opTime, Date_t::now(), boost::none), + opCtx(), txnNum, {0}, opTime, Date_t::now(), boost::none, boost::none), AssertionException); } @@ -457,7 +457,7 @@ DEATH_TEST_F(TransactionParticipantRetryableWritesTest, WriteUnitOfWork wuow(opCtx()); const auto opTime = logOp(opCtx(), kNss, uuid, sessionId, txnNum, 0); txnParticipant.onWriteOpCompletedOnPrimary( - opCtx(), txnNum, {0}, opTime, Date_t::now(), boost::none); + opCtx(), txnNum, {0}, opTime, Date_t::now(), boost::none, boost::none); wuow.commit(); } @@ -466,7 +466,7 @@ DEATH_TEST_F(TransactionParticipantRetryableWritesTest, WriteUnitOfWork wuow(opCtx()); const auto opTime = logOp(opCtx(), kNss, uuid, sessionId, txnNum - 1, 0); txnParticipant.onWriteOpCompletedOnPrimary( - opCtx(), txnNum - 1, {0}, opTime, Date_t::now(), boost::none); + opCtx(), txnNum - 1, {0}, opTime, Date_t::now(), boost::none, boost::none); } } @@ -486,7 +486,7 @@ DEATH_TEST_F(TransactionParticipantRetryableWritesTest, txnParticipant.invalidate(opCtx()); txnParticipant.onWriteOpCompletedOnPrimary( - opCtx(), txnNum, {0}, opTime, Date_t::now(), boost::none); + opCtx(), txnNum, {0}, opTime, Date_t::now(), boost::none, boost::none); } TEST_F(TransactionParticipantRetryableWritesTest, IncompleteHistoryDueToOpLogTruncation) { @@ -591,7 +591,7 @@ TEST_F(TransactionParticipantRetryableWritesTest, ErrorOnlyWhenStmtIdBeingChecke false /* inTxn */, OplogSlot()); txnParticipant.onWriteOpCompletedOnPrimary( - opCtx(), txnNum, {1}, opTime, wallClockTime, boost::none); + opCtx(), txnNum, {1}, opTime, wallClockTime, boost::none, boost::none); wuow.commit(); return opTime; @@ -621,8 +621,13 @@ TEST_F(TransactionParticipantRetryableWritesTest, ErrorOnlyWhenStmtIdBeingChecke false /* inTxn */, OplogSlot()); - txnParticipant.onWriteOpCompletedOnPrimary( - opCtx(), txnNum, {kIncompleteHistoryStmtId}, opTime, wallClockTime, boost::none); + txnParticipant.onWriteOpCompletedOnPrimary(opCtx(), + txnNum, + {kIncompleteHistoryStmtId}, + opTime, + wallClockTime, + boost::none, + boost::none); wuow.commit(); } |