summaryrefslogtreecommitdiff
path: root/src/mongo/db/repl/initial_syncer_test.cpp
diff options
context:
space:
mode:
authorDaniel Gottlieb <daniel.gottlieb@mongodb.com>2017-11-21 12:25:54 -0500
committerDaniel Gottlieb <daniel.gottlieb@mongodb.com>2017-11-21 12:25:54 -0500
commit470c30273c479c5ab139de0d38e016f95c589c49 (patch)
tree1b8fa734567a6976c4980bb6ca4885b13af6ed8a /src/mongo/db/repl/initial_syncer_test.cpp
parenta094c5b4b4783895d5fe168541bd97103a0d05f5 (diff)
downloadmongo-470c30273c479c5ab139de0d38e016f95c589c49.tar.gz
SERVER-31304: Refactor away SnapshotName.
Diffstat (limited to 'src/mongo/db/repl/initial_syncer_test.cpp')
-rw-r--r--src/mongo/db/repl/initial_syncer_test.cpp11
1 files changed, 5 insertions, 6 deletions
diff --git a/src/mongo/db/repl/initial_syncer_test.cpp b/src/mongo/db/repl/initial_syncer_test.cpp
index 9df6094127b..7cb8d53cbde 100644
--- a/src/mongo/db/repl/initial_syncer_test.cpp
+++ b/src/mongo/db/repl/initial_syncer_test.cpp
@@ -727,15 +727,15 @@ TEST_F(InitialSyncerTest, StartupSetsInitialDataTimestampAndStableTimestampOnSuc
// Set initial data timestamp forward first.
auto serviceCtx = opCtx.get()->getServiceContext();
- _storageInterface->setInitialDataTimestamp(serviceCtx, SnapshotName(Timestamp(5, 5)));
- _storageInterface->setStableTimestamp(serviceCtx, SnapshotName(Timestamp(6, 6)));
+ _storageInterface->setInitialDataTimestamp(serviceCtx, Timestamp(5, 5));
+ _storageInterface->setStableTimestamp(serviceCtx, Timestamp(6, 6));
ASSERT_OK(initialSyncer->startup(opCtx.get(), maxAttempts));
ASSERT_TRUE(initialSyncer->isActive());
- ASSERT_EQUALS(SnapshotName(Timestamp::kAllowUnstableCheckpointsSentinel),
+ ASSERT_EQUALS(Timestamp::kAllowUnstableCheckpointsSentinel,
_storageInterface->getInitialDataTimestamp());
- ASSERT_EQUALS(SnapshotName::min(), _storageInterface->getStableTimestamp());
+ ASSERT_EQUALS(Timestamp::min(), _storageInterface->getStableTimestamp());
}
TEST_F(InitialSyncerTest, InitialSyncerReturnsCallbackCanceledIfShutdownImmediatelyAfterStartup) {
@@ -3480,8 +3480,7 @@ void InitialSyncerTest::doSuccessfulInitialSyncWithOneBatch() {
ASSERT_EQUALS(lastOp.getOpTime(), unittest::assertGet(_lastApplied).opTime);
ASSERT_EQUALS(lastOp.getHash(), unittest::assertGet(_lastApplied).value);
- ASSERT_EQUALS(SnapshotName(lastOp.getOpTime().getTimestamp()),
- _storageInterface->getInitialDataTimestamp());
+ ASSERT_EQUALS(lastOp.getOpTime().getTimestamp(), _storageInterface->getInitialDataTimestamp());
}
TEST_F(InitialSyncerTest,