diff options
author | Benety Goh <benety@mongodb.com> | 2016-04-15 11:45:36 -0400 |
---|---|---|
committer | Benety Goh <benety@mongodb.com> | 2016-04-18 15:46:12 -0400 |
commit | 2780aef9a4f76ab54f00bb7000e4ecc0219143ec (patch) | |
tree | 4653546be915f6a05f45fd5264e0513420a3db95 /src/mongo/db/repl/check_quorum_for_config_change_test.cpp | |
parent | 6811d7c70d13559c3162e8f4333c3c061e5a5220 (diff) | |
download | mongo-2780aef9a4f76ab54f00bb7000e4ecc0219143ec.tar.gz |
SERVER-18038 ReplicationExecutor no longer requires StorageInterface to create operation context.
Diffstat (limited to 'src/mongo/db/repl/check_quorum_for_config_change_test.cpp')
-rw-r--r-- | src/mongo/db/repl/check_quorum_for_config_change_test.cpp | 6 |
1 files changed, 2 insertions, 4 deletions
diff --git a/src/mongo/db/repl/check_quorum_for_config_change_test.cpp b/src/mongo/db/repl/check_quorum_for_config_change_test.cpp index 493cbbe2380..b8da58e4372 100644 --- a/src/mongo/db/repl/check_quorum_for_config_change_test.cpp +++ b/src/mongo/db/repl/check_quorum_for_config_change_test.cpp @@ -37,11 +37,11 @@ #include "mongo/db/repl/repl_set_heartbeat_response.h" #include "mongo/db/repl/replica_set_config.h" #include "mongo/db/repl/replication_executor.h" -#include "mongo/db/repl/storage_interface_mock.h" #include "mongo/executor/network_interface_mock.h" #include "mongo/platform/unordered_set.h" #include "mongo/rpc/metadata/repl_set_metadata.h" #include "mongo/stdx/functional.h" +#include "mongo/stdx/memory.h" #include "mongo/stdx/thread.h" #include "mongo/unittest/unittest.h" #include "mongo/util/net/hostandport.h" @@ -77,7 +77,6 @@ protected: bool isQuorumCheckDone(); NetworkInterfaceMock* _net; - StorageInterfaceMock* _storage; std::unique_ptr<ReplicationExecutor> _executor; private: @@ -99,8 +98,7 @@ CheckQuorumTest::CheckQuorumTest() void CheckQuorumTest::setUp() { _net = new NetworkInterfaceMock; - _storage = new StorageInterfaceMock; - _executor.reset(new ReplicationExecutor(_net, _storage, 1 /* prng */)); + _executor = stdx::make_unique<ReplicationExecutor>(_net, 1 /* prng seed */); _executorThread.reset(new stdx::thread(stdx::bind(&ReplicationExecutor::run, _executor.get()))); } |