summaryrefslogtreecommitdiff
path: root/src/mongo/db/repl/freshness_checker.cpp
diff options
context:
space:
mode:
authorAndy Schwerin <Andy Schwerin schwerin@mongodb.com>2017-03-24 17:59:14 -0400
committerAndy Schwerin <Andy Schwerin schwerin@mongodb.com>2017-03-27 13:22:25 -0400
commitf4cce647d9bdd3e988a5d514ec64cd4deb9f7a26 (patch)
tree65b178c2d48751d4bb259e2472ec888b4315bd96 /src/mongo/db/repl/freshness_checker.cpp
parent5e47fab7c971014ae7ce401e94d35dc761fea8c2 (diff)
downloadmongo-f4cce647d9bdd3e988a5d514ec64cd4deb9f7a26.tar.gz
SERVER-28491 Re-host unit tests that used ReplicationExecutorTest onto ThreadPoolExecutorTest.
Diffstat (limited to 'src/mongo/db/repl/freshness_checker.cpp')
-rw-r--r--src/mongo/db/repl/freshness_checker.cpp7
1 files changed, 4 insertions, 3 deletions
diff --git a/src/mongo/db/repl/freshness_checker.cpp b/src/mongo/db/repl/freshness_checker.cpp
index 8ab9cb1cd7c..b6db822eb67 100644
--- a/src/mongo/db/repl/freshness_checker.cpp
+++ b/src/mongo/db/repl/freshness_checker.cpp
@@ -47,6 +47,7 @@ namespace mongo {
namespace repl {
using executor::RemoteCommandRequest;
+using executor::RemoteCommandResponse;
FreshnessChecker::Algorithm::Algorithm(Timestamp lastOpTimeApplied,
const ReplSetConfig& rsConfig,
@@ -122,7 +123,7 @@ bool FreshnessChecker::Algorithm::_isVotingMember(const HostAndPort hap) const {
}
void FreshnessChecker::Algorithm::processResponse(const RemoteCommandRequest& request,
- const ResponseStatus& response) {
+ const RemoteCommandResponse& response) {
++_responsesProcessed;
bool votingMember = _isVotingMember(request.target);
@@ -209,8 +210,8 @@ long long FreshnessChecker::getOriginalConfigVersion() const {
FreshnessChecker::FreshnessChecker() : _isCanceled(false) {}
FreshnessChecker::~FreshnessChecker() {}
-StatusWith<ReplicationExecutor::EventHandle> FreshnessChecker::start(
- ReplicationExecutor* executor,
+StatusWith<executor::TaskExecutor::EventHandle> FreshnessChecker::start(
+ executor::TaskExecutor* executor,
const Timestamp& lastOpTimeApplied,
const ReplSetConfig& currentConfig,
int selfIndex,