summaryrefslogtreecommitdiff
path: root/src/mongo/db/repl/repl_set_declare_election_winner.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/db/repl/repl_set_declare_election_winner.cpp')
-rw-r--r--src/mongo/db/repl/repl_set_declare_election_winner.cpp55
1 files changed, 27 insertions, 28 deletions
diff --git a/src/mongo/db/repl/repl_set_declare_election_winner.cpp b/src/mongo/db/repl/repl_set_declare_election_winner.cpp
index 688428ca221..776d20a7a18 100644
--- a/src/mongo/db/repl/repl_set_declare_election_winner.cpp
+++ b/src/mongo/db/repl/repl_set_declare_election_winner.cpp
@@ -36,36 +36,35 @@
namespace mongo {
namespace repl {
- class CmdReplSetDeclareElectionWinner : public ReplSetCommand {
- public:
- CmdReplSetDeclareElectionWinner() : ReplSetCommand("replSetDeclareElectionWinner") { }
- private:
- bool run(OperationContext* txn,
- const std::string&,
- BSONObj& cmdObj,
- int,
- std::string& errmsg,
- BSONObjBuilder& result) final {
+class CmdReplSetDeclareElectionWinner : public ReplSetCommand {
+public:
+ CmdReplSetDeclareElectionWinner() : ReplSetCommand("replSetDeclareElectionWinner") {}
- Status status = getGlobalReplicationCoordinator()->checkReplEnabledForCommand(&result);
- if (!status.isOK()) {
- return appendCommandStatus(result, status);
- }
-
- ReplSetDeclareElectionWinnerArgs parsedArgs;
- status = parsedArgs.initialize(cmdObj);
- if (!status.isOK()) {
- return appendCommandStatus(result, status);
- }
+private:
+ bool run(OperationContext* txn,
+ const std::string&,
+ BSONObj& cmdObj,
+ int,
+ std::string& errmsg,
+ BSONObjBuilder& result) final {
+ Status status = getGlobalReplicationCoordinator()->checkReplEnabledForCommand(&result);
+ if (!status.isOK()) {
+ return appendCommandStatus(result, status);
+ }
- long long responseTerm = -1;
- status = getGlobalReplicationCoordinator()->processReplSetDeclareElectionWinner(
- parsedArgs,
- &responseTerm);
- result.append("term", responseTerm);
+ ReplSetDeclareElectionWinnerArgs parsedArgs;
+ status = parsedArgs.initialize(cmdObj);
+ if (!status.isOK()) {
return appendCommandStatus(result, status);
}
- } cmdReplSetDeclareElectionWinner;
-} // namespace repl
-} // namespace mongo
+ long long responseTerm = -1;
+ status = getGlobalReplicationCoordinator()->processReplSetDeclareElectionWinner(
+ parsedArgs, &responseTerm);
+ result.append("term", responseTerm);
+ return appendCommandStatus(result, status);
+ }
+} cmdReplSetDeclareElectionWinner;
+
+} // namespace repl
+} // namespace mongo