diff options
author | Daniel Gottlieb <daniel.gottlieb@mongodb.com> | 2017-11-21 12:25:54 -0500 |
---|---|---|
committer | Daniel Gottlieb <daniel.gottlieb@mongodb.com> | 2017-11-21 12:25:54 -0500 |
commit | 470c30273c479c5ab139de0d38e016f95c589c49 (patch) | |
tree | 1b8fa734567a6976c4980bb6ca4885b13af6ed8a /src/mongo/db/repl/initial_syncer_test.cpp | |
parent | a094c5b4b4783895d5fe168541bd97103a0d05f5 (diff) | |
download | mongo-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.cpp | 11 |
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, |