diff options
Diffstat (limited to 'src/mongo/db/repl/repl_set_request_votes.cpp')
-rw-r--r-- | src/mongo/db/repl/repl_set_request_votes.cpp | 55 |
1 files changed, 27 insertions, 28 deletions
diff --git a/src/mongo/db/repl/repl_set_request_votes.cpp b/src/mongo/db/repl/repl_set_request_votes.cpp index 3d823de4930..92a72a1a6c4 100644 --- a/src/mongo/db/repl/repl_set_request_votes.cpp +++ b/src/mongo/db/repl/repl_set_request_votes.cpp @@ -36,36 +36,35 @@ namespace mongo { namespace repl { - class CmdReplSetRequestVotes : public ReplSetCommand { - public: - CmdReplSetRequestVotes() : ReplSetCommand("replSetRequestVotes") { } - private: - bool run(OperationContext* txn, - const std::string&, - BSONObj& cmdObj, - int, - std::string& errmsg, - BSONObjBuilder& result) final { +class CmdReplSetRequestVotes : public ReplSetCommand { +public: + CmdReplSetRequestVotes() : ReplSetCommand("replSetRequestVotes") {} - Status status = getGlobalReplicationCoordinator()->checkReplEnabledForCommand(&result); - if (!status.isOK()) { - return appendCommandStatus(result, status); - } - - ReplSetRequestVotesArgs 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); + } - ReplSetRequestVotesResponse response; - status = getGlobalReplicationCoordinator()->processReplSetRequestVotes(txn, - parsedArgs, - &response); - response.addToBSON(&result); + ReplSetRequestVotesArgs parsedArgs; + status = parsedArgs.initialize(cmdObj); + if (!status.isOK()) { return appendCommandStatus(result, status); } - } cmdReplSetRequestVotes; -} // namespace repl -} // namespace mongo + ReplSetRequestVotesResponse response; + status = getGlobalReplicationCoordinator()->processReplSetRequestVotes( + txn, parsedArgs, &response); + response.addToBSON(&result); + return appendCommandStatus(result, status); + } +} cmdReplSetRequestVotes; + +} // namespace repl +} // namespace mongo |