summaryrefslogtreecommitdiff
path: root/src/mongo/db/s/set_allow_migrations_coordinator.h
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/db/s/set_allow_migrations_coordinator.h')
-rw-r--r--src/mongo/db/s/set_allow_migrations_coordinator.h16
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