summaryrefslogtreecommitdiff
path: root/src/mongo/db/s/session_catalog_migration_source_test.cpp
diff options
context:
space:
mode:
authorKaloian Manassiev <kaloian.manassiev@mongodb.com>2018-09-27 06:05:54 -0400
committerKaloian Manassiev <kaloian.manassiev@mongodb.com>2018-10-08 02:38:48 -0400
commitb272bf351c39677d1e87d5c7fcd8b15b61465012 (patch)
tree9a92c09de2c9eb4244ca4b97d320f9d1e70637af /src/mongo/db/s/session_catalog_migration_source_test.cpp
parent07066a49b935a538ed54716fdd9a98d40c31fba4 (diff)
downloadmongo-b272bf351c39677d1e87d5c7fcd8b15b61465012.tar.gz
SERVER-36799 Move all transactions and retryable writes functionality from Session into TransactionParticipant
This change leaves the Session class to be a plain decorable structure only used for serialization of operations on the same logical session.
Diffstat (limited to 'src/mongo/db/s/session_catalog_migration_source_test.cpp')
-rw-r--r--src/mongo/db/s/session_catalog_migration_source_test.cpp3
1 files changed, 2 insertions, 1 deletions
diff --git a/src/mongo/db/s/session_catalog_migration_source_test.cpp b/src/mongo/db/s/session_catalog_migration_source_test.cpp
index dc2ae5677de..b8a99afb851 100644
--- a/src/mongo/db/s/session_catalog_migration_source_test.cpp
+++ b/src/mongo/db/s/session_catalog_migration_source_test.cpp
@@ -35,6 +35,7 @@
#include "mongo/db/s/session_catalog_migration_source.h"
#include "mongo/db/session.h"
#include "mongo/db/session_txn_record_gen.h"
+#include "mongo/db/transaction_participant.h"
#include "mongo/executor/remote_command_request.h"
#include "mongo/unittest/unittest.h"
@@ -593,7 +594,7 @@ TEST_F(SessionCatalogMigrationSourceTest, ReturnsDeadEndSentinelForIncompleteHis
auto oplog = *nextOplogResult.oplog;
ASSERT_TRUE(oplog.getObject2());
- ASSERT_BSONOBJ_EQ(Session::kDeadEndSentinel, *oplog.getObject2());
+ ASSERT_BSONOBJ_EQ(TransactionParticipant::kDeadEndSentinel, *oplog.getObject2());
ASSERT_TRUE(oplog.getStatementId());
ASSERT_EQ(kIncompleteHistoryStmtId, *oplog.getStatementId());
ASSERT_TRUE(oplog.getWallClockTime());