diff options
Diffstat (limited to 'src/mongo/db/repl/check_quorum_for_config_change.cpp')
-rw-r--r-- | src/mongo/db/repl/check_quorum_for_config_change.cpp | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/src/mongo/db/repl/check_quorum_for_config_change.cpp b/src/mongo/db/repl/check_quorum_for_config_change.cpp index 1dd1fe3ebbb..a1be65dbaf3 100644 --- a/src/mongo/db/repl/check_quorum_for_config_change.cpp +++ b/src/mongo/db/repl/check_quorum_for_config_change.cpp @@ -111,7 +111,7 @@ std::vector<RemoteCommandRequest> QuorumChecker::getRequests() const { } void QuorumChecker::processResponse(const RemoteCommandRequest& request, - const ResponseStatus& response) { + const executor::RemoteCommandResponse& response) { _tabulateHeartbeatResponse(request, response); if (hasReceivedSufficientResponses()) { _onQuorumCheckComplete(); @@ -177,7 +177,7 @@ void QuorumChecker::_onQuorumCheckComplete() { } void QuorumChecker::_tabulateHeartbeatResponse(const RemoteCommandRequest& request, - const ResponseStatus& response) { + const executor::RemoteCommandResponse& response) { ++_numResponses; if (!response.isOK()) { warning() << "Failed to complete heartbeat request to " << request.target << "; " @@ -279,7 +279,7 @@ bool QuorumChecker::hasReceivedSufficientResponses() const { return true; } -Status checkQuorumGeneral(ReplicationExecutor* executor, +Status checkQuorumGeneral(executor::TaskExecutor* executor, const ReplSetConfig& rsConfig, const int myIndex) { QuorumChecker checker(&rsConfig, myIndex); @@ -292,14 +292,14 @@ Status checkQuorumGeneral(ReplicationExecutor* executor, return checker.getFinalStatus(); } -Status checkQuorumForInitiate(ReplicationExecutor* executor, +Status checkQuorumForInitiate(executor::TaskExecutor* executor, const ReplSetConfig& rsConfig, const int myIndex) { invariant(rsConfig.getConfigVersion() == 1); return checkQuorumGeneral(executor, rsConfig, myIndex); } -Status checkQuorumForReconfig(ReplicationExecutor* executor, +Status checkQuorumForReconfig(executor::TaskExecutor* executor, const ReplSetConfig& rsConfig, const int myIndex) { invariant(rsConfig.getConfigVersion() > 1); |