summaryrefslogtreecommitdiff
path: root/src/mongo/db/service_context_d_test_fixture.cpp
diff options
context:
space:
mode:
authorDianna Hohensee <dianna.hohensee@10gen.com>2018-11-30 16:58:50 -0500
committerDianna Hohensee <dianna.hohensee@10gen.com>2018-12-05 21:53:20 -0500
commite9030987ff429ea3d80f30bf7e857caef86bc2ae (patch)
treecbd9651312fb084e0072cc6a70047a84bee44e6c /src/mongo/db/service_context_d_test_fixture.cpp
parent00b8071cfaccf4c1ff380207240064444021c070 (diff)
downloadmongo-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.cpp5
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);