diff options
author | Dianna Hohensee <dianna.hohensee@10gen.com> | 2018-11-30 16:58:50 -0500 |
---|---|---|
committer | Dianna Hohensee <dianna.hohensee@10gen.com> | 2018-12-05 21:53:20 -0500 |
commit | e9030987ff429ea3d80f30bf7e857caef86bc2ae (patch) | |
tree | cbd9651312fb084e0072cc6a70047a84bee44e6c /src/mongo/db/service_context_d_test_fixture.cpp | |
parent | 00b8071cfaccf4c1ff380207240064444021c070 (diff) | |
download | mongo-e9030987ff429ea3d80f30bf7e857caef86bc2ae.tar.gz |
SERVER-38323 turn the IndexBuildsCoordinator into an interface and add an implementation for embedded
Diffstat (limited to 'src/mongo/db/service_context_d_test_fixture.cpp')
-rw-r--r-- | src/mongo/db/service_context_d_test_fixture.cpp | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/src/mongo/db/service_context_d_test_fixture.cpp b/src/mongo/db/service_context_d_test_fixture.cpp index c02348243c3..8cc88261648 100644 --- a/src/mongo/db/service_context_d_test_fixture.cpp +++ b/src/mongo/db/service_context_d_test_fixture.cpp @@ -39,6 +39,7 @@ #include "mongo/db/catalog/database_holder.h" #include "mongo/db/catalog/uuid_catalog.h" #include "mongo/db/concurrency/d_concurrency.h" +#include "mongo/db/index_builds_coordinator_mongod.h" #include "mongo/db/logical_clock.h" #include "mongo/db/op_observer_registry.h" #include "mongo/db/service_entry_point_mongod.h" @@ -78,6 +79,8 @@ ServiceContextMongoDTest::ServiceContextMongoDTest(std::string engine, RepairAct initializeStorageEngine(serviceContext, StorageEngineInitFlags::kNone); + IndexBuildsCoordinator::set(serviceContext, std::make_unique<IndexBuildsCoordinatorMongod>()); + // Set up UUID Catalog observer. This is necessary because the Collection destructor contains an // invariant to ensure the UUID corresponding to that Collection object is no longer associated // with that Collection object in the UUIDCatalog. UUIDs may be registered in the UUIDCatalog @@ -95,6 +98,8 @@ ServiceContextMongoDTest::~ServiceContextMongoDTest() { DatabaseHolder::getDatabaseHolder().closeAll(opCtx.get(), "all databases dropped"); } + IndexBuildsCoordinator::get(getServiceContext())->shutdown(); + shutdownGlobalStorageEngineCleanly(getServiceContext()); std::swap(storageGlobalParams.engine, _stashedStorageParams.engine); |