diff options
author | Benety Goh <benety@mongodb.com> | 2016-02-22 13:12:25 -0500 |
---|---|---|
committer | Benety Goh <benety@mongodb.com> | 2016-02-22 14:10:07 -0500 |
commit | 7451ed94d9c296e15041300aa4fec39c7b03bfae (patch) | |
tree | 45edb0706dbfd37459a357b328315c432388f525 /src/mongo/db/repl/reporter.h | |
parent | c2bbfb86311d3651b97a2c607d50c5c2965cf1be (diff) | |
download | mongo-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.h | 12 |
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 |