diff options
Diffstat (limited to 'src/mongo/db/s/set_allow_migrations_coordinator.h')
-rw-r--r-- | src/mongo/db/s/set_allow_migrations_coordinator.h | 16 |
1 files changed, 6 insertions, 10 deletions
diff --git a/src/mongo/db/s/set_allow_migrations_coordinator.h b/src/mongo/db/s/set_allow_migrations_coordinator.h index cf8e14348d7..78d2e03696a 100644 --- a/src/mongo/db/s/set_allow_migrations_coordinator.h +++ b/src/mongo/db/s/set_allow_migrations_coordinator.h @@ -38,31 +38,27 @@ namespace mongo { -class SetAllowMigrationsCoordinator final : public ShardingDDLCoordinator { +class SetAllowMigrationsCoordinator final + : public ShardingDDLCoordinatorImpl<SetAllowMigrationsCoordinatorDocument> { public: SetAllowMigrationsCoordinator(ShardingDDLCoordinatorService* service, - const BSONObj& initialState); + const BSONObj& initialState) + : ShardingDDLCoordinatorImpl(service, "SetAllowMigrationsCoordinator", initialState), + _allowMigrations(_doc.getAllowMigrations()) {} void checkIfOptionsConflict(const BSONObj& coorDoc) const override; - boost::optional<BSONObj> reportForCurrentOp( - MongoProcessInterface::CurrentOpConnectionsMode connMode, - MongoProcessInterface::CurrentOpSessionsMode sessionMode) noexcept override; + void appendCommandInfo(BSONObjBuilder* cmdInfoBuilder) const override; bool canAlwaysStartWhenUserWritesAreDisabled() const override { return true; } private: - ShardingDDLCoordinatorMetadata const& metadata() const override { - return _doc.getShardingDDLCoordinatorMetadata(); - } - ExecutorFuture<void> _runImpl(std::shared_ptr<executor::ScopedTaskExecutor> executor, const CancellationToken& token) noexcept override; - SetAllowMigrationsCoordinatorDocument _doc; const bool _allowMigrations; }; } // namespace mongo |