diff options
author | Jack Mulrow <jack.mulrow@mongodb.com> | 2019-01-03 12:21:49 -0500 |
---|---|---|
committer | Jack Mulrow <jack.mulrow@mongodb.com> | 2019-01-09 14:16:00 -0500 |
commit | 0c8e948f50cec99860e4ac0d15ba76f33512c9d2 (patch) | |
tree | f9f1ebe145f9723d3a5ebecc698e74a6bbd7a9ea /src/mongo/db/op_observer_impl_test.cpp | |
parent | 627853bdc19ed147fe5c14e9e458035598c062ea (diff) | |
download | mongo-0c8e948f50cec99860e4ac0d15ba76f33512c9d2.tar.gz |
SERVER-36639 Disallow restarting txn at active txn number if shard has aborted after being prepared
Diffstat (limited to 'src/mongo/db/op_observer_impl_test.cpp')
-rw-r--r-- | src/mongo/db/op_observer_impl_test.cpp | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/src/mongo/db/op_observer_impl_test.cpp b/src/mongo/db/op_observer_impl_test.cpp index 991b452a1bc..ea3b80b605e 100644 --- a/src/mongo/db/op_observer_impl_test.cpp +++ b/src/mongo/db/op_observer_impl_test.cpp @@ -755,7 +755,7 @@ TEST_F(OpObserverTransactionTest, TransactionalPreparedAbortTest) { opCtx()->setWriteUnitOfWork(nullptr); opCtx()->lockState()->unsetMaxLockTimeout(); opObserver().onTransactionAbort(opCtx(), abortSlot); - txnParticipant->transitionToAbortedforTest(); + txnParticipant->transitionToAbortedWithPrepareforTest(); repl::OplogInterfaceLocal oplogInterface(opCtx(), NamespaceString::kRsOplogNamespace.ns()); auto oplogIter = oplogInterface.makeIterator(); @@ -807,7 +807,7 @@ TEST_F(OpObserverTransactionTest, TransactionalUnpreparedAbortTest) { AutoGetCollection autoColl(opCtx(), nss, MODE_IX); opObserver().onInserts(opCtx(), nss, uuid, insert.begin(), insert.end(), false); - txnParticipant->transitionToAbortedforTest(); + txnParticipant->transitionToAbortedWithoutPrepareforTest(); opObserver().onTransactionAbort(opCtx(), boost::none); } @@ -891,7 +891,7 @@ TEST_F(OpObserverTransactionTest, AbortingPreparedTransactionWritesToTransaction opCtx()->setWriteUnitOfWork(nullptr); opCtx()->lockState()->unsetMaxLockTimeout(); opObserver().onTransactionAbort(opCtx(), abortSlot); - txnParticipant->transitionToAbortedforTest(); + txnParticipant->transitionToAbortedWithPrepareforTest(); txnParticipant->stashTransactionResources(opCtx()); |