summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorBenety Goh <benety@mongodb.com>2019-07-11 05:37:42 -0400
committerBenety Goh <benety@mongodb.com>2019-07-11 05:38:32 -0400
commit659c4946cb7e2f18937cbe085b03ec247dd52635 (patch)
tree10541bdd27e645822d850c257c313eddc2ef499c
parent7f89b539052ba710714c2cd09fd7276a293dd6cc (diff)
downloadmongo-659c4946cb7e2f18937cbe085b03ec247dd52635.tar.gz
SERVER-41870 implement IndexBuildsCoordinator::abortIndexBuildByBuildUUID()
-rw-r--r--src/mongo/db/index_builds_coordinator.cpp3
-rw-r--r--src/mongo/db/index_builds_coordinator.h2
2 files changed, 2 insertions, 3 deletions
diff --git a/src/mongo/db/index_builds_coordinator.cpp b/src/mongo/db/index_builds_coordinator.cpp
index 326824752d2..1ec6de7ede8 100644
--- a/src/mongo/db/index_builds_coordinator.cpp
+++ b/src/mongo/db/index_builds_coordinator.cpp
@@ -317,9 +317,10 @@ void IndexBuildsCoordinator::abortDatabaseIndexBuilds(StringData db, const std::
Future<void> IndexBuildsCoordinator::abortIndexBuildByBuildUUID(const UUID& buildUUID,
const std::string& reason) {
- // TODO: not yet implemented. Some code to make it compile.
+ _indexBuildsManager.abortIndexBuild(buildUUID, reason);
auto pf = makePromiseFuture<void>();
auto promise = std::move(pf.promise);
+ promise.setWith([] {});
return std::move(pf.future);
}
diff --git a/src/mongo/db/index_builds_coordinator.h b/src/mongo/db/index_builds_coordinator.h
index 31e56b70749..defcbd5310a 100644
--- a/src/mongo/db/index_builds_coordinator.h
+++ b/src/mongo/db/index_builds_coordinator.h
@@ -200,8 +200,6 @@ public:
/**
* Aborts a given index build by index build UUID.
- *
- * TODO: This is not yet implemented.
*/
Future<void> abortIndexBuildByBuildUUID(const UUID& buildUUID, const std::string& reason);