summaryrefslogtreecommitdiff
path: root/src/mongo/db/s/active_migrations_registry.cpp
diff options
context:
space:
mode:
authorKaloian Manassiev <kaloian.manassiev@mongodb.com>2018-03-09 15:45:08 -0500
committerKaloian Manassiev <kaloian.manassiev@mongodb.com>2018-03-13 18:54:52 -0400
commita1b194059660d78afba0d8750231f48e4f77f2a6 (patch)
treecd8d34fa5475ed56250294a20d08861e2f12c496 /src/mongo/db/s/active_migrations_registry.cpp
parentbed7bb44a9cd84da56631b3a83437fc18ed46e3d (diff)
downloadmongo-a1b194059660d78afba0d8750231f48e4f77f2a6.tar.gz
SERVER-29908 Move more libraries from sharding into sharding_api_d/sharding_runtime_d
Diffstat (limited to 'src/mongo/db/s/active_migrations_registry.cpp')
-rw-r--r--src/mongo/db/s/active_migrations_registry.cpp16
1 files changed, 14 insertions, 2 deletions
diff --git a/src/mongo/db/s/active_migrations_registry.cpp b/src/mongo/db/s/active_migrations_registry.cpp
index e98497d90f9..6c07939d7d7 100644
--- a/src/mongo/db/s/active_migrations_registry.cpp
+++ b/src/mongo/db/s/active_migrations_registry.cpp
@@ -30,14 +30,18 @@
#include "mongo/db/s/active_migrations_registry.h"
-#include "mongo/base/status_with.h"
#include "mongo/db/catalog_raii.h"
#include "mongo/db/s/collection_sharding_state.h"
#include "mongo/db/s/migration_session_id.h"
#include "mongo/db/s/migration_source_manager.h"
-#include "mongo/util/assert_util.h"
+#include "mongo/db/service_context.h"
namespace mongo {
+namespace {
+
+const auto getRegistry = ServiceContext::declareDecoration<ActiveMigrationsRegistry>();
+
+} // namespace
ActiveMigrationsRegistry::ActiveMigrationsRegistry() = default;
@@ -45,6 +49,14 @@ ActiveMigrationsRegistry::~ActiveMigrationsRegistry() {
invariant(!_activeMoveChunkState);
}
+ActiveMigrationsRegistry& ActiveMigrationsRegistry::get(ServiceContext* service) {
+ return getRegistry(service);
+}
+
+ActiveMigrationsRegistry& ActiveMigrationsRegistry::get(OperationContext* opCtx) {
+ return get(opCtx->getServiceContext());
+}
+
StatusWith<ScopedDonateChunk> ActiveMigrationsRegistry::registerDonateChunk(
const MoveChunkRequest& args) {
stdx::lock_guard<stdx::mutex> lk(_mutex);