summaryrefslogtreecommitdiff
path: root/src/mongo/db/s/session_catalog_migration_source_test.cpp
diff options
context:
space:
mode:
authorBenety Goh <benety@mongodb.com>2019-04-05 17:33:12 -0400
committerBenety Goh <benety@mongodb.com>2019-04-05 17:33:31 -0400
commitf8a74023fa0034ee96668348904f6f1493c6fef0 (patch)
tree1cc760a4247f486669976bee897d2288f9c14f5e /src/mongo/db/s/session_catalog_migration_source_test.cpp
parent20c33aa11ae2925d66b2df81e2ddb6813d81400a (diff)
downloadmongo-f8a74023fa0034ee96668348904f6f1493c6fef0.tar.gz
SERVER-40169 OplogEntry constructor accepts prepare argument
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.cpp15
1 files changed, 10 insertions, 5 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 f46461761af..352877a8edf 100644
--- a/src/mongo/db/s/session_catalog_migration_source_test.cpp
+++ b/src/mongo/db/s/session_catalog_migration_source_test.cpp
@@ -61,7 +61,8 @@ repl::OplogEntry makeOplogEntry(repl::OpTime opTime,
StmtId stmtId,
repl::OpTime prevWriteOpTimeInTransaction,
boost::optional<repl::OpTime> preImageOpTime,
- boost::optional<repl::OpTime> postImageOpTime) {
+ boost::optional<repl::OpTime> postImageOpTime,
+ boost::optional<bool> prepare) {
return repl::OplogEntry(
opTime, // optime
0, // hash
@@ -78,7 +79,8 @@ repl::OplogEntry makeOplogEntry(repl::OpTime opTime,
stmtId, // statement id
prevWriteOpTimeInTransaction, // optime of previous write within same transaction
preImageOpTime, // pre-image optime
- postImageOpTime); // post-image optime
+ postImageOpTime, // post-image optime
+ prepare); // prepare
}
repl::OplogEntry makeOplogEntry(repl::OpTime opTime,
@@ -89,7 +91,8 @@ repl::OplogEntry makeOplogEntry(repl::OpTime opTime,
StmtId stmtId,
repl::OpTime prevWriteOpTimeInTransaction,
boost::optional<repl::OpTime> preImageOpTime = boost::none,
- boost::optional<repl::OpTime> postImageOpTime = boost::none) {
+ boost::optional<repl::OpTime> postImageOpTime = boost::none,
+ boost::optional<bool> prepare = boost::none) {
return makeOplogEntry(opTime,
opType,
kNs,
@@ -99,7 +102,8 @@ repl::OplogEntry makeOplogEntry(repl::OpTime opTime,
stmtId,
prevWriteOpTimeInTransaction,
preImageOpTime,
- postImageOpTime);
+ postImageOpTime,
+ prepare);
}
TEST_F(SessionCatalogMigrationSourceTest, NoSessionsToTransferShouldNotHaveOplog) {
@@ -368,7 +372,8 @@ TEST_F(SessionCatalogMigrationSourceTest, OplogWithOtherNsShouldBeIgnored) {
1, // statement id
repl::OpTime(Timestamp(0, 0), 0), // optime of previous write within same transaction
boost::none, // pre-image optime
- boost::none); // post-image optime
+ boost::none, // pre-image optime
+ boost::none); // prepare
insertOplogEntry(entry2);
SessionTxnRecord sessionRecord2;