diff options
Diffstat (limited to 'src/mongo/dbtests/storage_timestamp_tests.cpp')
| -rw-r--r-- | src/mongo/dbtests/storage_timestamp_tests.cpp | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/src/mongo/dbtests/storage_timestamp_tests.cpp b/src/mongo/dbtests/storage_timestamp_tests.cpp index 750c8ac447d..d270e0467d7 100644 --- a/src/mongo/dbtests/storage_timestamp_tests.cpp +++ b/src/mongo/dbtests/storage_timestamp_tests.cpp @@ -103,7 +103,7 @@ public: OneOffRead(OperationContext* opCtx, const Timestamp& ts) : _opCtx(opCtx) { _opCtx->recoveryUnit()->abandonSnapshot(); if (ts.isNull()) { - _opCtx->recoveryUnit()->setTimestampReadSource(RecoveryUnit::ReadSource::kUnset); + _opCtx->recoveryUnit()->setTimestampReadSource(RecoveryUnit::ReadSource::kNoTimestamp); } else { _opCtx->recoveryUnit()->setTimestampReadSource(RecoveryUnit::ReadSource::kProvided, ts); } @@ -111,7 +111,7 @@ public: ~OneOffRead() { _opCtx->recoveryUnit()->abandonSnapshot(); - _opCtx->recoveryUnit()->setTimestampReadSource(RecoveryUnit::ReadSource::kUnset); + _opCtx->recoveryUnit()->setTimestampReadSource(RecoveryUnit::ReadSource::kNoTimestamp); } private: @@ -234,7 +234,7 @@ public: */ void reset(NamespaceString nss) const { ::mongo::writeConflictRetry(_opCtx, "deleteAll", nss.ns(), [&] { - _opCtx->recoveryUnit()->setTimestampReadSource(RecoveryUnit::ReadSource::kUnset); + _opCtx->recoveryUnit()->setTimestampReadSource(RecoveryUnit::ReadSource::kNoTimestamp); AutoGetCollection collRaii(_opCtx, nss, LockMode::MODE_X); if (collRaii) { @@ -2057,7 +2057,7 @@ public: firstInsert.asTimestamp()); ASSERT_OK(indexer.drainBackgroundWrites(_opCtx, - RecoveryUnit::ReadSource::kUnset, + RecoveryUnit::ReadSource::kNoTimestamp, IndexBuildInterceptor::DrainYieldPolicy::kNoYield)); auto indexCatalog = autoColl.getCollection()->getIndexCatalog(); @@ -2100,7 +2100,7 @@ public: setReplCoordAppliedOpTime(repl::OpTime(afterSecondInsert.asTimestamp(), presentTerm)); ASSERT_OK(indexer.drainBackgroundWrites(_opCtx, - RecoveryUnit::ReadSource::kUnset, + RecoveryUnit::ReadSource::kNoTimestamp, IndexBuildInterceptor::DrainYieldPolicy::kNoYield)); { @@ -2843,7 +2843,7 @@ public: ASSERT_FALSE(buildingIndex->indexBuildInterceptor()->areAllWritesApplied(_opCtx)); ASSERT_OK(indexer.drainBackgroundWrites(_opCtx, - RecoveryUnit::ReadSource::kUnset, + RecoveryUnit::ReadSource::kNoTimestamp, IndexBuildInterceptor::DrainYieldPolicy::kNoYield)); |