diff options
| author | Eric Milkie <milkie@10gen.com> | 2017-09-19 11:27:59 -0400 |
|---|---|---|
| committer | Eric Milkie <milkie@10gen.com> | 2017-09-25 13:17:16 -0400 |
| commit | 8c118d741327e6e3fe29955f7f75f6fe853297e5 (patch) | |
| tree | b215e7de950e487f67fbd8f98fe27437d90a70d3 /src/mongo/db/repl/replication_process_test.cpp | |
| parent | 62fe0f89e9fa15c69f912d31b822b3631f691fe7 (diff) | |
| download | mongo-8c118d741327e6e3fe29955f7f75f6fe853297e5.tar.gz | |
SERVER-31086 adorn secondary inserts and vector inserts with timestamps
Diffstat (limited to 'src/mongo/db/repl/replication_process_test.cpp')
| -rw-r--r-- | src/mongo/db/repl/replication_process_test.cpp | 21 |
1 files changed, 14 insertions, 7 deletions
diff --git a/src/mongo/db/repl/replication_process_test.cpp b/src/mongo/db/repl/replication_process_test.cpp index 3950e27418b..99b3d22e287 100644 --- a/src/mongo/db/repl/replication_process_test.cpp +++ b/src/mongo/db/repl/replication_process_test.cpp @@ -113,7 +113,8 @@ TEST_F(ReplicationProcessTest, ReplicationProcess::kRollbackProgressNamespace, TimestampedBSONObj{BSON("_id" << "not progress"), - SnapshotName(0)})); + SnapshotName()}, + OpTime::kUninitializedTerm)); ASSERT_EQUALS(ErrorCodes::NoSuchKey, replicationProcess.getRollbackProgress(opCtx.get())); } @@ -126,8 +127,10 @@ TEST_F(ReplicationProcessTest, GetRollbackProgressReturnsBadStatusIfApplyUntilFi auto opCtx = makeOpCtx(); ASSERT_OK(_storageInterface->createCollection( opCtx.get(), ReplicationProcess::kRollbackProgressNamespace, {})); - ASSERT_OK(_storageInterface->insertDocument( - opCtx.get(), ReplicationProcess::kRollbackProgressNamespace, doc)); + ASSERT_OK(_storageInterface->insertDocument(opCtx.get(), + ReplicationProcess::kRollbackProgressNamespace, + doc, + OpTime::kUninitializedTerm)); ReplicationProcess replicationProcess( _storageInterface.get(), @@ -149,8 +152,10 @@ TEST_F(ReplicationProcessTest, auto opCtx = makeOpCtx(); ASSERT_OK(_storageInterface->createCollection( opCtx.get(), ReplicationProcess::kRollbackProgressNamespace, {})); - ASSERT_OK(_storageInterface->insertDocument( - opCtx.get(), ReplicationProcess::kRollbackProgressNamespace, doc)); + ASSERT_OK(_storageInterface->insertDocument(opCtx.get(), + ReplicationProcess::kRollbackProgressNamespace, + doc, + OpTime::kUninitializedTerm)); ReplicationProcess replicationProcess( _storageInterface.get(), @@ -170,8 +175,10 @@ TEST_F(ReplicationProcessTest, auto opCtx = makeOpCtx(); ASSERT_OK(_storageInterface->createCollection( opCtx.get(), ReplicationProcess::kRollbackProgressNamespace, {})); - ASSERT_OK(_storageInterface->insertDocument( - opCtx.get(), ReplicationProcess::kRollbackProgressNamespace, doc)); + ASSERT_OK(_storageInterface->insertDocument(opCtx.get(), + ReplicationProcess::kRollbackProgressNamespace, + doc, + OpTime::kUninitializedTerm)); ReplicationProcess replicationProcess( _storageInterface.get(), |