diff options
author | Kaloian Manassiev <kaloian.manassiev@mongodb.com> | 2018-03-09 15:45:08 -0500 |
---|---|---|
committer | Kaloian Manassiev <kaloian.manassiev@mongodb.com> | 2018-03-13 18:54:52 -0400 |
commit | a1b194059660d78afba0d8750231f48e4f77f2a6 (patch) | |
tree | cd8d34fa5475ed56250294a20d08861e2f12c496 /src/mongo/db/s/active_migrations_registry.cpp | |
parent | bed7bb44a9cd84da56631b3a83437fc18ed46e3d (diff) | |
download | mongo-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.cpp | 16 |
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); |