summaryrefslogtreecommitdiff
path: root/src/mongo/db/logical_clock_test_fixture.cpp
diff options
context:
space:
mode:
authorADAM David Alan Martin <adam.martin@10gen.com>2017-05-03 13:14:53 -0400
committerADAM David Alan Martin <adam.martin@10gen.com>2017-05-03 13:14:53 -0400
commitb7c013aa097b2d999ad3f942cdfce130558ef40f (patch)
tree04e39ddadd003bff628faeea9b7bf0fb812465e9 /src/mongo/db/logical_clock_test_fixture.cpp
parent606b3930d1ca73f0184f4b29bb52917cc15e94cf (diff)
downloadmongo-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.cpp19
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();
}