diff options
author | ADAM David Alan Martin <adam.martin@10gen.com> | 2017-05-03 13:14:53 -0400 |
---|---|---|
committer | ADAM David Alan Martin <adam.martin@10gen.com> | 2017-05-03 13:14:53 -0400 |
commit | b7c013aa097b2d999ad3f942cdfce130558ef40f (patch) | |
tree | 04e39ddadd003bff628faeea9b7bf0fb812465e9 /src/mongo/db/logical_clock_test_fixture.cpp | |
parent | 606b3930d1ca73f0184f4b29bb52917cc15e94cf (diff) | |
download | mongo-b7c013aa097b2d999ad3f942cdfce130558ef40f.tar.gz |
Revert "SERVER-28562 Move LogicalTime HMAC computation outside collection lock"
This reverts commit 1a6c4ecddfa4bb7a7275dc4b1bf5b79222aa4b72.
Diffstat (limited to 'src/mongo/db/logical_clock_test_fixture.cpp')
-rw-r--r-- | src/mongo/db/logical_clock_test_fixture.cpp | 19 |
1 files changed, 19 insertions, 0 deletions
diff --git a/src/mongo/db/logical_clock_test_fixture.cpp b/src/mongo/db/logical_clock_test_fixture.cpp index 588ff7dd766..d7f6e8036b6 100644 --- a/src/mongo/db/logical_clock_test_fixture.cpp +++ b/src/mongo/db/logical_clock_test_fixture.cpp @@ -56,6 +56,10 @@ void LogicalClockTestFixture::setUp() { LogicalClock::set(service, std::move(logicalClock)); _clock = LogicalClock::get(service); + auto pTps = stdx::make_unique<TimeProofService>(); + _timeProofService = pTps.get(); + _clock->setTimeProofService(std::move(pTps)); + service->setFastClockSource(stdx::make_unique<SharedClockSourceAdapter>(_mockClockSource)); service->setPreciseClockSource(stdx::make_unique<SharedClockSourceAdapter>(_mockClockSource)); @@ -88,6 +92,21 @@ Date_t LogicalClockTestFixture::getMockClockSourceTime() const { return _mockClockSource->now(); } +SignedLogicalTime LogicalClockTestFixture::makeSignedLogicalTime(LogicalTime logicalTime) const { + TimeProofService::Key key = {}; + return SignedLogicalTime(logicalTime, _timeProofService->getProof(logicalTime, key), 0); +} + +void LogicalClockTestFixture::resetTimeProofService() { + auto pTps = stdx::make_unique<TimeProofService>(); + _timeProofService = pTps.get(); + _clock->setTimeProofService(std::move(pTps)); +} + +void LogicalClockTestFixture::unsetTimeProofService() const { + _clock->setTimeProofService(std::unique_ptr<TimeProofService>()); +} + DBDirectClient* LogicalClockTestFixture::getDBClient() const { return _dbDirectClient.get(); } |