summaryrefslogtreecommitdiff
path: root/src/mongo/db/op_observer_impl_test.cpp
diff options
context:
space:
mode:
authorJack Mulrow <jack.mulrow@mongodb.com>2019-01-03 12:21:49 -0500
committerJack Mulrow <jack.mulrow@mongodb.com>2019-01-09 14:16:00 -0500
commit0c8e948f50cec99860e4ac0d15ba76f33512c9d2 (patch)
treef9f1ebe145f9723d3a5ebecc698e74a6bbd7a9ea /src/mongo/db/op_observer_impl_test.cpp
parent627853bdc19ed147fe5c14e9e458035598c062ea (diff)
downloadmongo-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.cpp6
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());