summaryrefslogtreecommitdiff
path: root/src/mongo/db/s/sharding_ddl_coordinator_service.cpp
diff options
context:
space:
mode:
authorAllison Easton <allison.easton@mongodb.com>2021-07-29 12:55:51 +0000
committerEvergreen Agent <no-reply@evergreen.mongodb.com>2021-08-03 08:34:20 +0000
commit64a119b69ce7ae34ec7eac15e52ad1a08beb5b08 (patch)
tree25a7024099282a290c9229efc59f4b508de685b2 /src/mongo/db/s/sharding_ddl_coordinator_service.cpp
parent29e7de221b3e32c4a85dbff86e922553a5852ae8 (diff)
downloadmongo-64a119b69ce7ae34ec7eac15e52ad1a08beb5b08.tar.gz
SERVER-53283 Remove code that patches up sharding metadata on FCV upgrade/downgrade to/from 4.9
Diffstat (limited to 'src/mongo/db/s/sharding_ddl_coordinator_service.cpp')
-rw-r--r--src/mongo/db/s/sharding_ddl_coordinator_service.cpp24
1 files changed, 0 insertions, 24 deletions
diff --git a/src/mongo/db/s/sharding_ddl_coordinator_service.cpp b/src/mongo/db/s/sharding_ddl_coordinator_service.cpp
index bf21a715361..7e239e6d2a9 100644
--- a/src/mongo/db/s/sharding_ddl_coordinator_service.cpp
+++ b/src/mongo/db/s/sharding_ddl_coordinator_service.cpp
@@ -96,12 +96,6 @@ ShardingDDLCoordinatorService* ShardingDDLCoordinatorService::getService(Operati
std::shared_ptr<ShardingDDLCoordinatorService::Instance>
ShardingDDLCoordinatorService::constructInstance(BSONObj initialState) {
auto coord = constructShardingDDLCoordinatorInstance(this, std::move(initialState));
-
- {
- stdx::lock_guard lg(_completionMutex);
- ++_numActiveCoordinators;
- }
-
coord->getConstructionCompletionFuture()
.thenRunOn(getInstanceCleanupExecutor())
.getAsync([this](auto status) {
@@ -115,27 +109,9 @@ ShardingDDLCoordinatorService::constructInstance(BSONObj initialState) {
_recoveredCV.notify_all();
}
});
-
- coord->getCompletionFuture()
- .thenRunOn(getInstanceCleanupExecutor())
- .getAsync([this](auto status) {
- stdx::lock_guard lg(_completionMutex);
- if (--_numActiveCoordinators == 0) {
- _completedCV.notify_all();
- }
- });
-
return coord;
}
-void ShardingDDLCoordinatorService::waitForAllCoordinatorsToComplete(
- OperationContext* opCtx) const {
- _waitForRecoveryCompletion(opCtx);
- stdx::unique_lock lk(_completionMutex);
- opCtx->waitForConditionOrInterrupt(
- _completedCV, lk, [this]() { return _numActiveCoordinators == 0; });
-}
-
void ShardingDDLCoordinatorService::_afterStepDown() {
stdx::lock_guard lg(_mutex);