summaryrefslogtreecommitdiff
path: root/src/mongo/db/repl/reporter.h
diff options
context:
space:
mode:
authorBenety Goh <benety@mongodb.com>2016-02-22 13:12:25 -0500
committerBenety Goh <benety@mongodb.com>2016-02-22 14:10:07 -0500
commit7451ed94d9c296e15041300aa4fec39c7b03bfae (patch)
tree45edb0706dbfd37459a357b328315c432388f525 /src/mongo/db/repl/reporter.h
parentc2bbfb86311d3651b97a2c607d50c5c2965cf1be (diff)
downloadmongo-7451ed94d9c296e15041300aa4fec39c7b03bfae.tar.gz
SERVER-18154 migrated Reporter from repl::ReplicationExecutor to executor::TaskExecutor
Diffstat (limited to 'src/mongo/db/repl/reporter.h')
-rw-r--r--src/mongo/db/repl/reporter.h12
1 files changed, 6 insertions, 6 deletions
diff --git a/src/mongo/db/repl/reporter.h b/src/mongo/db/repl/reporter.h
index 5fba25e5ba0..ad1b3be953f 100644
--- a/src/mongo/db/repl/reporter.h
+++ b/src/mongo/db/repl/reporter.h
@@ -31,7 +31,7 @@
#include "mongo/base/status.h"
#include "mongo/base/status_with.h"
#include "mongo/db/jsobj.h"
-#include "mongo/db/repl/replication_executor.h"
+#include "mongo/executor/task_executor.h"
#include "mongo/stdx/functional.h"
namespace mongo {
@@ -49,7 +49,7 @@ public:
*/
using PrepareReplSetUpdatePositionCommandFn = stdx::function<StatusWith<BSONObj>()>;
- Reporter(ReplicationExecutor* executor,
+ Reporter(executor::TaskExecutor* executor,
PrepareReplSetUpdatePositionCommandFn prepareOldReplSetUpdatePositionCommandFn,
const HostAndPort& target);
virtual ~Reporter();
@@ -99,10 +99,10 @@ private:
/**
* Callback for remote command.
*/
- void _callback(const ReplicationExecutor::RemoteCommandCallbackArgs& rcbd);
+ void _callback(const executor::TaskExecutor::RemoteCommandCallbackArgs& rcbd);
// Not owned by us.
- ReplicationExecutor* _executor;
+ executor::TaskExecutor* _executor;
// Prepares update command object.
PrepareReplSetUpdatePositionCommandFn _prepareOldReplSetUpdatePositionCommandFn;
@@ -113,7 +113,7 @@ private:
// Protects member data of this Reporter.
mutable stdx::mutex _mutex;
- // Stores the most recent Status returned from the ReplicationExecutor.
+ // Stores the most recent Status returned from the executor.
Status _status;
// _willRunAgain is true when Reporter is scheduled to be run by the executor and subsequent
@@ -123,7 +123,7 @@ private:
bool _active;
// Callback handle to the scheduled remote command.
- ReplicationExecutor::CallbackHandle _remoteCommandCallbackHandle;
+ executor::TaskExecutor::CallbackHandle _remoteCommandCallbackHandle;
};
} // namespace repl