diff options
author | Randolph Tan <randolph@10gen.com> | 2018-06-29 10:19:48 -0400 |
---|---|---|
committer | Randolph Tan <randolph@10gen.com> | 2018-08-08 16:00:20 -0400 |
commit | 52b2cc0886cdb992e2491067bdc029301d5bb6af (patch) | |
tree | c414da256a84890af3fb084ab699b572b49dab4f /src/mongo/db/s/session_catalog_migration_destination_test.cpp | |
parent | 210bb5d91cb3c77bb3ed169114f8b85cd1062fb3 (diff) | |
download | mongo-52b2cc0886cdb992e2491067bdc029301d5bb6af.tar.gz |
SERVER-35900 Refactor transaction machinery out from Session class
Diffstat (limited to 'src/mongo/db/s/session_catalog_migration_destination_test.cpp')
-rw-r--r-- | src/mongo/db/s/session_catalog_migration_destination_test.cpp | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/src/mongo/db/s/session_catalog_migration_destination_test.cpp b/src/mongo/db/s/session_catalog_migration_destination_test.cpp index 5d8fa25978d..5299f54142f 100644 --- a/src/mongo/db/s/session_catalog_migration_destination_test.cpp +++ b/src/mongo/db/s/session_catalog_migration_destination_test.cpp @@ -36,6 +36,7 @@ #include "mongo/db/logical_session_cache_noop.h" #include "mongo/db/logical_session_id.h" #include "mongo/db/logical_session_id_gen.h" +#include "mongo/db/operation_context_session_mongod.h" #include "mongo/db/ops/write_ops_exec.h" #include "mongo/db/ops/write_ops_gen.h" #include "mongo/db/repl/oplog_entry.h" @@ -171,7 +172,7 @@ public: const LogicalSessionId& sessionId, const TxnNumber& txnNum) { auto scopedSession = SessionCatalog::get(opCtx)->getOrCreateSession(opCtx, sessionId); - scopedSession->beginOrContinueTxnOnMigration(opCtx, txnNum); + scopedSession->beginOrContinueTxn(opCtx, txnNum); return scopedSession; } @@ -243,8 +244,8 @@ public: // up the session state and perform the insert. initializeOperationSessionInfo( innerOpCtx.get(), insertBuilder.obj(), true, true, true, false); - OperationContextSession sessionTxnState( - innerOpCtx.get(), true, boost::none, boost::none, "testDB", "insert"); + OperationContextSessionMongod sessionTxnState( + innerOpCtx.get(), true, boost::none, boost::none); const auto reply = performInserts(innerOpCtx.get(), insertRequest); ASSERT(reply.results.size() == 1); |