diff options
author | Andy Schwerin <Andy Schwerin schwerin@mongodb.com> | 2017-05-18 16:41:38 -0500 |
---|---|---|
committer | Andy Schwerin <Andy Schwerin schwerin@mongodb.com> | 2017-05-18 16:41:38 -0500 |
commit | 9ff6b2d78cee808d633dee952d31e4d4f1fe0dd0 (patch) | |
tree | 00ef5cf14e062f063e19aa34b81b74b823cad462 /src/mongo/db/repl/replication_coordinator_test_fixture.h | |
parent | f5ae1e058b9cef56fdbe08775d48278c79144051 (diff) | |
download | mongo-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.h | 9 |
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"); |