diff options
Diffstat (limited to 'src/mongo/db/s/config/configsvr_reshard_collection_cmd.cpp')
| -rw-r--r-- | src/mongo/db/s/config/configsvr_reshard_collection_cmd.cpp | 12 |
1 files changed, 7 insertions, 5 deletions
diff --git a/src/mongo/db/s/config/configsvr_reshard_collection_cmd.cpp b/src/mongo/db/s/config/configsvr_reshard_collection_cmd.cpp index 7f284e2c642..1a094c7db5f 100644 --- a/src/mongo/db/s/config/configsvr_reshard_collection_cmd.cpp +++ b/src/mongo/db/s/config/configsvr_reshard_collection_cmd.cpp @@ -63,8 +63,9 @@ getExistingInstanceToJoin(OperationContext* opCtx, const NamespaceString& nss, const BSONObj& newShardKey) { auto instances = - getReshardingStateMachines<ReshardingCoordinatorService, - ReshardingCoordinatorService::ReshardingCoordinator>(opCtx, nss); + resharding::getReshardingStateMachines<ReshardingCoordinatorService, + ReshardingCoordinatorService::ReshardingCoordinator>( + opCtx, nss); for (const auto& instance : instances) { if (SimpleBSONObjComparator::kInstance.evaluate( instance->getMetadata().getReshardingKey().toBSON() == newShardKey)) { @@ -139,7 +140,7 @@ public: "Must specify only one of _presetReshardedChunks or numInitialChunks", !(bool(request().getNumInitialChunks()))); - validateReshardedChunks( + resharding::validateReshardedChunks( *presetChunks, opCtx, ShardKeyPattern(request().getKey()).getKeyPattern()); } @@ -183,11 +184,12 @@ public: return boost::none; } - auto tempReshardingNss = constructTemporaryReshardingNss(nss.db(), cm.getUUID()); + auto tempReshardingNss = + resharding::constructTemporaryReshardingNss(nss.db(), cm.getUUID()); if (auto zones = request().getZones()) { - checkForOverlappingZones(*zones); + resharding::checkForOverlappingZones(*zones); } auto coordinatorDoc = |