summaryrefslogtreecommitdiff
path: root/src/mongo/db/s/session_catalog_migration_destination_test.cpp
diff options
context:
space:
mode:
authorRandolph Tan <randolph@10gen.com>2018-06-29 10:19:48 -0400
committerRandolph Tan <randolph@10gen.com>2018-08-08 16:00:20 -0400
commit52b2cc0886cdb992e2491067bdc029301d5bb6af (patch)
treec414da256a84890af3fb084ab699b572b49dab4f /src/mongo/db/s/session_catalog_migration_destination_test.cpp
parent210bb5d91cb3c77bb3ed169114f8b85cd1062fb3 (diff)
downloadmongo-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.cpp7
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);