SERVER-48417 Reconstruct in-memory state when resuming index build

1 files changed, 11 insertions, 0 deletions

diff --git a/src/mongo/db/storage/storage_engine_impl.cpp b/src/mongo/db/storage/storage_engine_impl.cpp
index a4590dd850f..93742937d27 100644
--- a/src/mongo/db/storage/storage_engine_impl.cpp
+++ b/src/mongo/db/storage/storage_engine_impl.cpp
@@ -368,6 +368,11 @@ bool StorageEngineImpl::_handleInternalIdents(
 
             reconcileResult->indexBuildsToResume.push_back(resumeInfo);
 
+            // Once we have parsed the resume info, we can safely drop the internal ident.
+            // TODO SERVER-49846: revisit this logic since this could cause the side tables
+            // associated with the index build to be orphaned if resuming fails.
+            internalIdentsToDrop->insert(ident);
+
             LOGV2(4916301,
                   "Found unfinished index build to resume",
                   "buildUUID"_attr = resumeInfo.getBuildUUID(),
@@ -842,6 +847,12 @@ std::unique_ptr<TemporaryRecordStore> StorageEngineImpl::makeTemporaryRecordStor
     return std::make_unique<TemporaryKVRecordStore>(getEngine(), std::move(rs));
 }
 
+std::unique_ptr<TemporaryRecordStore> StorageEngineImpl::makeTemporaryRecordStoreFromExistingIdent(
+    OperationContext* opCtx, StringData ident) {
+    auto rs = _engine->getRecordStore(opCtx, "", ident, CollectionOptions());
+    return std::make_unique<TemporaryKVRecordStore>(getEngine(), std::move(rs));
+}
+
 void StorageEngineImpl::setJournalListener(JournalListener* jl) {
     _engine->setJournalListener(jl);
 }