summaryrefslogtreecommitdiff
path: root/src/mongo/db/repl/replication_coordinator_test_fixture.h
diff options
context:
space:
mode:
authorAndy Schwerin <Andy Schwerin schwerin@mongodb.com>2017-05-18 16:41:38 -0500
committerAndy Schwerin <Andy Schwerin schwerin@mongodb.com>2017-05-18 16:41:38 -0500
commit9ff6b2d78cee808d633dee952d31e4d4f1fe0dd0 (patch)
tree00ef5cf14e062f063e19aa34b81b74b823cad462 /src/mongo/db/repl/replication_coordinator_test_fixture.h
parentf5ae1e058b9cef56fdbe08775d48278c79144051 (diff)
downloadmongo-9ff6b2d78cee808d633dee952d31e4d4f1fe0dd0.tar.gz
SERVER-28865 Replace ReplicationExecutor with ThreadPoolTaskExecutor in ReplicationCoordinatorImpl.
Diffstat (limited to 'src/mongo/db/repl/replication_coordinator_test_fixture.h')
-rw-r--r--src/mongo/db/repl/replication_coordinator_test_fixture.h9
1 files changed, 6 insertions, 3 deletions
diff --git a/src/mongo/db/repl/replication_coordinator_test_fixture.h b/src/mongo/db/repl/replication_coordinator_test_fixture.h
index ab2653be11d..9f1b27aabea 100644
--- a/src/mongo/db/repl/replication_coordinator_test_fixture.h
+++ b/src/mongo/db/repl/replication_coordinator_test_fixture.h
@@ -33,7 +33,7 @@
#include "mongo/db/client.h"
#include "mongo/db/repl/repl_settings.h"
#include "mongo/db/repl/replication_coordinator.h"
-#include "mongo/db/repl/replication_executor.h"
+#include "mongo/executor/task_executor.h"
#include "mongo/unittest/unittest.h"
namespace mongo {
@@ -102,7 +102,7 @@ protected:
/**
* Gets the replication executor under test.
*/
- ReplicationExecutor* getReplExec();
+ executor::TaskExecutor* getReplExec();
/**
* Gets the replication coordinator under test.
@@ -261,10 +261,13 @@ private:
std::unique_ptr<ReplicationCoordinatorImpl> _repl;
// Owned by ReplicationCoordinatorImpl
TopologyCoordinatorImpl* _topo = nullptr;
- // Owned by ReplicationExecutor
+ // Owned by executor
executor::NetworkInterfaceMock* _net = nullptr;
// Owned by ReplicationCoordinatorImpl
ReplicationCoordinatorExternalStateMock* _externalState = nullptr;
+ // Owned by ReplicationCoordinatorImpl
+ executor::TaskExecutor* _replExec = nullptr;
+
ReplSettings _settings;
bool _callShutdown = false;
ServiceContext::UniqueClient _client = getGlobalServiceContext()->makeClient("testClient");