summaryrefslogtreecommitdiff
path: root/src/mongo/db/catalog_raii.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/db/catalog_raii.cpp')
-rw-r--r--src/mongo/db/catalog_raii.cpp6
1 files changed, 4 insertions, 2 deletions
diff --git a/src/mongo/db/catalog_raii.cpp b/src/mongo/db/catalog_raii.cpp
index efd30fb762d..ea15f87137d 100644
--- a/src/mongo/db/catalog_raii.cpp
+++ b/src/mongo/db/catalog_raii.cpp
@@ -198,7 +198,9 @@ ConcealCollectionCatalogChangesBlock::~ConcealCollectionCatalogChangesBlock() {
CollectionCatalog::get(_opCtx).onOpenCatalog(_opCtx);
}
-ReadSourceScope::ReadSourceScope(OperationContext* opCtx)
+ReadSourceScope::ReadSourceScope(OperationContext* opCtx,
+ RecoveryUnit::ReadSource readSource,
+ boost::optional<Timestamp> provided)
: _opCtx(opCtx), _originalReadSource(opCtx->recoveryUnit()->getTimestampReadSource()) {
if (_originalReadSource == RecoveryUnit::ReadSource::kProvided) {
@@ -206,7 +208,7 @@ ReadSourceScope::ReadSourceScope(OperationContext* opCtx)
}
_opCtx->recoveryUnit()->abandonSnapshot();
- _opCtx->recoveryUnit()->setTimestampReadSource(RecoveryUnit::ReadSource::kUnset);
+ _opCtx->recoveryUnit()->setTimestampReadSource(readSource, provided);
}
ReadSourceScope::~ReadSourceScope() {