diff options
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.cpp | 55 |
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 |