summaryrefslogtreecommitdiff
path: root/src/mongo/db/repl/data_replicator.cpp
diff options
context:
space:
mode:
authorBenety Goh <benety@mongodb.com>2016-07-07 20:07:23 -0400
committerBenety Goh <benety@mongodb.com>2016-07-12 11:14:22 -0400
commitd54798452c0dd008b624a620d55dd866b9daa0fc (patch)
treebc1ae8cc0c74706866ce6c2ca25107252405f12b /src/mongo/db/repl/data_replicator.cpp
parentdd0165b595c8470d7252218a490c2deb9ad2e387 (diff)
downloadmongo-d54798452c0dd008b624a620d55dd866b9daa0fc.tar.gz
SERVER-24945 DataReplicator no longer shares task executor with ReplicationCoordinatorImpl
Diffstat (limited to 'src/mongo/db/repl/data_replicator.cpp')
-rw-r--r--src/mongo/db/repl/data_replicator.cpp3
1 files changed, 1 insertions, 2 deletions
diff --git a/src/mongo/db/repl/data_replicator.cpp b/src/mongo/db/repl/data_replicator.cpp
index e47d2325b90..facd568d26a 100644
--- a/src/mongo/db/repl/data_replicator.cpp
+++ b/src/mongo/db/repl/data_replicator.cpp
@@ -220,11 +220,10 @@ std::string toString(DataReplicatorState s) {
DataReplicator::DataReplicator(
DataReplicatorOptions opts,
std::unique_ptr<DataReplicatorExternalState> dataReplicatorExternalState,
- executor::TaskExecutor* exec,
StorageInterface* storage)
: _opts(opts),
_dataReplicatorExternalState(std::move(dataReplicatorExternalState)),
- _exec(exec),
+ _exec(_dataReplicatorExternalState->getTaskExecutor()),
_state(DataReplicatorState::Uninitialized),
_storage(storage) {
uassert(ErrorCodes::BadValue, "invalid storage interface", _storage);