diff options
author | Randolph Tan <randolph@10gen.com> | 2017-02-23 14:57:14 -0500 |
---|---|---|
committer | Randolph Tan <randolph@10gen.com> | 2017-03-07 17:12:01 -0500 |
commit | 43be7d92a003f075a5130b2eb38175a062d0729d (patch) | |
tree | bb751ca50470551a85fd2f36b85d21f22d7820e8 /src/mongo/db/logical_clock_test.cpp | |
parent | 07c73edf683342d91ba941dd2733ff9e9e6fa6c0 (diff) | |
download | mongo-43be7d92a003f075a5130b2eb38175a062d0729d.tar.gz |
SERVER-27749 Integrate LogicalTimeMetadata
Attach logical time metadata to all outgoing messages and process incoming logical time metadata in mongod
Diffstat (limited to 'src/mongo/db/logical_clock_test.cpp')
-rw-r--r-- | src/mongo/db/logical_clock_test.cpp | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/src/mongo/db/logical_clock_test.cpp b/src/mongo/db/logical_clock_test.cpp index e3e75acd9dc..bb8bdba9afc 100644 --- a/src/mongo/db/logical_clock_test.cpp +++ b/src/mongo/db/logical_clock_test.cpp @@ -50,7 +50,7 @@ protected: TimeProofService::Key key(std::move(tempKey)); auto pTps = stdx::make_unique<TimeProofService>(std::move(key)); _timeProofService = pTps.get(); - _clock = stdx::make_unique<LogicalClock>(_serviceContext.get(), std::move(pTps), true); + _clock = stdx::make_unique<LogicalClock>(_serviceContext.get(), std::move(pTps)); } void tearDown() { @@ -82,7 +82,7 @@ TEST_F(LogicalClockTestBase, roundtrip) { auto pTps = stdx::make_unique<TimeProofService>(std::move(key)); auto time = LogicalTime(tX); - LogicalClock logicalClock(&serviceContext, std::move(pTps), true); + LogicalClock logicalClock(&serviceContext, std::move(pTps)); logicalClock.initClusterTimeFromTrustedSource(time); auto storedTime(logicalClock.getClusterTime()); @@ -113,7 +113,7 @@ TEST_F(LogicalClockTestBase, advanceClusterTime) { auto t1 = getClock()->reserveTicks(1); t1.addTicks(100); SignedLogicalTime l1 = makeSignedLogicalTime(t1); - ASSERT_OK(getClock()->advanceClusterTime(l1)); + ASSERT_OK(getClock()->advanceClusterTimeFromTrustedSource(l1)); auto l2(getClock()->getClusterTime()); ASSERT_TRUE(l1.getTime() == l2.getTime()); } |