diff options
Diffstat (limited to 'src/mongo/embedded/index_builds_coordinator_embedded.cpp')
-rw-r--r-- | src/mongo/embedded/index_builds_coordinator_embedded.cpp | 34 |
1 files changed, 0 insertions, 34 deletions
diff --git a/src/mongo/embedded/index_builds_coordinator_embedded.cpp b/src/mongo/embedded/index_builds_coordinator_embedded.cpp index e27fe71c201..08d6ffd311a 100644 --- a/src/mongo/embedded/index_builds_coordinator_embedded.cpp +++ b/src/mongo/embedded/index_builds_coordinator_embedded.cpp @@ -34,7 +34,6 @@ #include "mongo/embedded/index_builds_coordinator_embedded.h" #include "mongo/db/catalog/uuid_catalog.h" -#include "mongo/db/catalog_raii.h" #include "mongo/db/operation_context.h" #include "mongo/db/service_context.h" #include "mongo/util/log.h" @@ -105,37 +104,4 @@ Status IndexBuildsCoordinatorEmbedded::setCommitQuorum(const NamespaceString& ns MONGO_UNREACHABLE; } -void IndexBuildsCoordinatorEmbedded::_runIndexBuild(OperationContext* opCtx, - const UUID& buildUUID) noexcept { - auto replState = [&] { - stdx::unique_lock<stdx::mutex> lk(_mutex); - auto it = _allIndexBuilds.find(buildUUID); - invariant(it != _allIndexBuilds.end()); - return it->second; - }(); - - { - stdx::unique_lock<stdx::mutex> lk(_mutex); - while (_sleepForTest) { - lk.unlock(); - sleepmillis(100); - lk.lock(); - } - } - - // TODO: create scoped object to create the index builder, then destroy the builder, set the - // promises and unregister the build. - - // TODO: implement. - - stdx::unique_lock<stdx::mutex> lk(_mutex); - - _unregisterIndexBuild(lk, opCtx, replState); - - ReplIndexBuildState::IndexCatalogStats indexCatalogStats; - replState->sharedPromise.emplaceValue(indexCatalogStats); - - return; -} - } // namespace mongo |