summaryrefslogtreecommitdiff
path: root/src/mongo/db/repl/oplog.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/db/repl/oplog.cpp')
-rw-r--r--src/mongo/db/repl/oplog.cpp6
1 files changed, 2 insertions, 4 deletions
diff --git a/src/mongo/db/repl/oplog.cpp b/src/mongo/db/repl/oplog.cpp
index 3b83398df30..8f345e4e023 100644
--- a/src/mongo/db/repl/oplog.cpp
+++ b/src/mongo/db/repl/oplog.cpp
@@ -213,8 +213,7 @@ Status commitIndexBuild(OperationContext* opCtx,
return statusWithIndexes.getStatus();
}
auto indexBuildsCoord = IndexBuildsCoordinator::get(opCtx);
- indexBuildsCoord->commitIndexBuild(opCtx, statusWithIndexes.getValue(), indexBuildUUID);
- indexBuildsCoord->joinIndexBuild(opCtx, indexBuildUUID);
+ indexBuildsCoord->signalCommitAndWait(opCtx, indexBuildUUID);
return Status::OK();
}
@@ -223,11 +222,10 @@ Status abortIndexBuild(OperationContext* opCtx,
const Status& cause,
OplogApplication::Mode mode) {
// Wait until the index build finishes aborting.
- IndexBuildsCoordinator::get(opCtx)->abortIndexBuildByBuildUUID(
+ IndexBuildsCoordinator::get(opCtx)->signalAbortAndWait(
opCtx,
indexBuildUUID,
str::stream() << "abortIndexBuild oplog entry encountered: " << cause);
- IndexBuildsCoordinator::get(opCtx)->joinIndexBuild(opCtx, indexBuildUUID);
return Status::OK();
}