summaryrefslogtreecommitdiff
path: root/src/mongo/db/s/config/configsvr_control_balancer_command.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/db/s/config/configsvr_control_balancer_command.cpp')
-rw-r--r--src/mongo/db/s/config/configsvr_control_balancer_command.cpp24
1 files changed, 12 insertions, 12 deletions
diff --git a/src/mongo/db/s/config/configsvr_control_balancer_command.cpp b/src/mongo/db/s/config/configsvr_control_balancer_command.cpp
index 88deff30a9e..f4905406f78 100644
--- a/src/mongo/db/s/config/configsvr_control_balancer_command.cpp
+++ b/src/mongo/db/s/config/configsvr_control_balancer_command.cpp
@@ -72,7 +72,7 @@ public:
return Status::OK();
}
- bool run(OperationContext* txn,
+ bool run(OperationContext* opCtx,
const std::string& unusedDbName,
BSONObj& cmdObj,
int options,
@@ -87,13 +87,13 @@ public:
str::stream() << getName() << " can only be run on config servers",
serverGlobalParams.clusterRole == ClusterRole::ConfigServer);
- _run(txn, &result);
+ _run(opCtx, &result);
return true;
}
private:
- virtual void _run(OperationContext* txn, BSONObjBuilder* result) = 0;
+ virtual void _run(OperationContext* opCtx, BSONObjBuilder* result) = 0;
};
class ConfigSvrBalancerStartCommand : public ConfigSvrBalancerControlCommand {
@@ -101,9 +101,9 @@ public:
ConfigSvrBalancerStartCommand() : ConfigSvrBalancerControlCommand("_configsvrBalancerStart") {}
private:
- void _run(OperationContext* txn, BSONObjBuilder* result) override {
- uassertStatusOK(Grid::get(txn)->getBalancerConfiguration()->setBalancerMode(
- txn, BalancerSettingsType::kFull));
+ void _run(OperationContext* opCtx, BSONObjBuilder* result) override {
+ uassertStatusOK(Grid::get(opCtx)->getBalancerConfiguration()->setBalancerMode(
+ opCtx, BalancerSettingsType::kFull));
}
};
@@ -112,10 +112,10 @@ public:
ConfigSvrBalancerStopCommand() : ConfigSvrBalancerControlCommand("_configsvrBalancerStop") {}
private:
- void _run(OperationContext* txn, BSONObjBuilder* result) override {
- uassertStatusOK(Grid::get(txn)->getBalancerConfiguration()->setBalancerMode(
- txn, BalancerSettingsType::kOff));
- Balancer::get(txn)->joinCurrentRound(txn);
+ void _run(OperationContext* opCtx, BSONObjBuilder* result) override {
+ uassertStatusOK(Grid::get(opCtx)->getBalancerConfiguration()->setBalancerMode(
+ opCtx, BalancerSettingsType::kOff));
+ Balancer::get(opCtx)->joinCurrentRound(opCtx);
}
};
@@ -125,8 +125,8 @@ public:
: ConfigSvrBalancerControlCommand("_configsvrBalancerStatus") {}
private:
- void _run(OperationContext* txn, BSONObjBuilder* result) override {
- Balancer::get(txn)->report(txn, result);
+ void _run(OperationContext* opCtx, BSONObjBuilder* result) override {
+ Balancer::get(opCtx)->report(opCtx, result);
}
};