diff options
Diffstat (limited to 'src/mongo/db/s/migration_destination_manager.h')
-rw-r--r-- | src/mongo/db/s/migration_destination_manager.h | 24 |
1 files changed, 2 insertions, 22 deletions
diff --git a/src/mongo/db/s/migration_destination_manager.h b/src/mongo/db/s/migration_destination_manager.h index 74d737f8302..925296091cb 100644 --- a/src/mongo/db/s/migration_destination_manager.h +++ b/src/mongo/db/s/migration_destination_manager.h @@ -29,7 +29,6 @@ #pragma once -#include <memory> #include <string> #include "mongo/base/string_data.h" @@ -40,8 +39,6 @@ #include "mongo/db/namespace_string.h" #include "mongo/db/repl/replica_set_aware_service.h" #include "mongo/db/s/active_migrations_registry.h" -#include "mongo/db/s/collection_sharding_runtime.h" -#include "mongo/db/s/migration_batch_fetcher.h" #include "mongo/db/s/migration_recipient_recovery_document_gen.h" #include "mongo/db/s/migration_session_id.h" #include "mongo/db/s/session_catalog_migration_destination.h" @@ -181,11 +178,6 @@ public: const boost::optional<ChunkManager>& cm, boost::optional<Timestamp> afterClusterTime); - - bool isParallelFetchingSupported() { - return _parallelFetchersSupported; - } - /** * Gets the collection uuid and options from fromShardId. If given a chunk manager, will fetch * the collection options using the database version protocol. @@ -291,22 +283,8 @@ private: stdx::thread _migrateThreadHandle; - long long _getNumCloned() { - return _migrationCloningProgress->getNumCloned(); - } - - long long _getNumBytesCloned() { - return _migrationCloningProgress->getNumBytes(); - } - boost::optional<UUID> _migrationId; boost::optional<UUID> _collectionUuid; - - // State that is shared among all inserter threads. - std::shared_ptr<MigrationCloningProgressSharedState> _migrationCloningProgress; - - bool _parallelFetchersSupported; - LogicalSessionId _lsid; TxnNumber _txnNumber{kUninitializedTxnNumber}; NamespaceString _nss; @@ -326,6 +304,8 @@ private: // failure we can perform the appropriate cleanup. bool _chunkMarkedPending{false}; + long long _numCloned{0}; + long long _clonedBytes{0}; long long _numCatchup{0}; long long _numSteady{0}; |