summaryrefslogtreecommitdiff
path: root/src/mongo/db/s/migration_destination_manager.h
diff options
context:
space:
mode:
authorBlake Oler <blake.oler@mongodb.com>2018-06-28 15:05:47 -0400
committerBlake Oler <blake.oler@mongodb.com>2018-07-02 11:17:00 -0400
commite117102282d4d8bc0352429cf67b2d01754f4ad1 (patch)
treeeb340ccc51bac2677670dc76e80c7422c1f5b443 /src/mongo/db/s/migration_destination_manager.h
parent2f730baf61adae417517c149271576207ce3a210 (diff)
downloadmongo-e117102282d4d8bc0352429cf67b2d01754f4ad1.tar.gz
SERVER-25333 Clean up argument passing in the MigrationDestinationManager
Diffstat (limited to 'src/mongo/db/s/migration_destination_manager.h')
-rw-r--r--src/mongo/db/s/migration_destination_manager.h45
1 files changed, 13 insertions, 32 deletions
diff --git a/src/mongo/db/s/migration_destination_manager.h b/src/mongo/db/s/migration_destination_manager.h
index 7fa514e107c..eedf65b14fb 100644
--- a/src/mongo/db/s/migration_destination_manager.h
+++ b/src/mongo/db/s/migration_destination_manager.h
@@ -144,33 +144,13 @@ private:
/**
* Thread which drives the migration apply process on the recipient side.
*/
- void _migrateThread(BSONObj min,
- BSONObj max,
- BSONObj shardKeyPattern,
- OID epoch,
- WriteConcernOptions writeConcern);
-
- void _migrateDriver(OperationContext* opCtx,
- const BSONObj& min,
- const BSONObj& max,
- const BSONObj& shardKeyPattern,
- const OID& epoch,
- const WriteConcernOptions& writeConcern);
-
- bool _applyMigrateOp(OperationContext* opCtx,
- const NamespaceString& ns,
- const BSONObj& min,
- const BSONObj& max,
- const BSONObj& shardKeyPattern,
- const BSONObj& xfer,
- repl::OpTime* lastOpApplied);
-
- bool _flushPendingWrites(OperationContext* opCtx,
- const std::string& ns,
- BSONObj min,
- BSONObj max,
- const repl::OpTime& lastOpApplied,
- const WriteConcernOptions& writeConcern);
+ void _migrateThread();
+
+ void _migrateDriver(OperationContext* opCtx);
+
+ bool _applyMigrateOp(OperationContext* opCtx, const BSONObj& xfer, repl::OpTime* lastOpApplied);
+
+ bool _flushPendingWrites(OperationContext* opCtx, const repl::OpTime& lastOpApplied);
/**
* Remembers a chunk range between 'min' and 'max' as a range which will have data migrated
@@ -178,16 +158,13 @@ private:
* it schedules deletion of any documents in the range, so that process must be seen to be
* complete before migrating any new documents in.
*/
- CollectionShardingState::CleanupNotification _notePending(OperationContext*,
- NamespaceString const&,
- OID const&,
- ChunkRange const&);
+ CollectionShardingState::CleanupNotification _notePending(OperationContext*, ChunkRange const&);
/**
* Stops tracking a chunk range between 'min' and 'max' that previously was having data
* migrated into it, and schedules deletion of any such documents already migrated in.
*/
- void _forgetPending(OperationContext*, NamespaceString const&, OID const&, ChunkRange const&);
+ void _forgetPending(OperationContext*, ChunkRange const&);
/**
* Checks whether the MigrationDestinationManager is currently handling a migration by checking
@@ -217,6 +194,10 @@ private:
BSONObj _max;
BSONObj _shardKeyPattern;
+ OID _epoch;
+
+ WriteConcernOptions _writeConcern;
+
// Set to true once we have accepted the chunk as pending into our metadata. Used so that on
// failure we can perform the appropriate cleanup.
bool _chunkMarkedPending{false};