summaryrefslogtreecommitdiff
path: root/src/mongo/db/s/sharding_ddl_coordinator_service.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/db/s/sharding_ddl_coordinator_service.cpp')
-rw-r--r--src/mongo/db/s/sharding_ddl_coordinator_service.cpp3
1 files changed, 2 insertions, 1 deletions
diff --git a/src/mongo/db/s/sharding_ddl_coordinator_service.cpp b/src/mongo/db/s/sharding_ddl_coordinator_service.cpp
index 42bf4aced00..101846166a0 100644
--- a/src/mongo/db/s/sharding_ddl_coordinator_service.cpp
+++ b/src/mongo/db/s/sharding_ddl_coordinator_service.cpp
@@ -33,6 +33,7 @@
#include "mongo/db/s/sharding_ddl_coordinator_service.h"
#include "mongo/base/checked_cast.h"
+#include "mongo/db/catalog/catalog_helper.h"
#include "mongo/db/dbdirectclient.h"
#include "mongo/db/pipeline/aggregate_command_gen.h"
#include "mongo/db/pipeline/document_source_count.h"
@@ -264,7 +265,7 @@ ShardingDDLCoordinatorService::getOrCreateInstance(OperationContext* opCtx, BSON
uassert(ErrorCodes::IllegalOperation,
"Request sent without attaching database version",
clientDbVersion);
- DatabaseShardingState::checkIsPrimaryShardForDb(opCtx, nss.db());
+ catalog_helper::assertIsPrimaryShardForDb(opCtx, nss.db());
coorMetadata.setDatabaseVersion(clientDbVersion);
}