diff options
| author | Blake Oler <blake.oler@mongodb.com> | 2018-03-08 17:44:24 -0500 |
|---|---|---|
| committer | Blake Oler <blake.oler@mongodb.com> | 2018-03-16 11:06:11 -0400 |
| commit | 1848f026aa094d6d143dc3b664a272fbd64155e5 (patch) | |
| tree | b8703fd6ac0f348b3f679d382c813f771ac7c642 /src/mongo/db/s/migration_destination_manager.h | |
| parent | 1823b6ddf986e1dd7f1a4761acc330d8bca1ad2b (diff) | |
| download | mongo-1848f026aa094d6d143dc3b664a272fbd64155e5.tar.gz | |
SERVER-32885 Overlap chunk clone application on the donor with fetching documents from the recipient
Diffstat (limited to 'src/mongo/db/s/migration_destination_manager.h')
| -rw-r--r-- | src/mongo/db/s/migration_destination_manager.h | 8 |
1 files changed, 8 insertions, 0 deletions
diff --git a/src/mongo/db/s/migration_destination_manager.h b/src/mongo/db/s/migration_destination_manager.h index 290c7f2218c..79d8eaacd86 100644 --- a/src/mongo/db/s/migration_destination_manager.h +++ b/src/mongo/db/s/migration_destination_manager.h @@ -118,6 +118,14 @@ public: const WriteConcernOptions& writeConcern); /** + * Clones documents from a donor shard. + */ + static void cloneDocumentsFromDonor( + OperationContext* opCtx, + stdx::function<void(OperationContext*, BSONObjIterator)> insertBatchFn, + stdx::function<BSONObj(OperationContext*)> fetchBatchFn); + + /** * Idempotent method, which causes the current ongoing migration to abort only if it has the * specified session id. If the migration is already aborted, does nothing. */ |