summaryrefslogtreecommitdiff
path: root/src/mongo/db/repl/database_cloner.h
diff options
context:
space:
mode:
authorMathias Stearn <mathias@10gen.com>2018-10-31 15:42:17 -0400
committerMathias Stearn <mathias@10gen.com>2018-11-15 17:25:11 -0500
commit3d7ed4fdd5e4840e9599a74ec92e16bc619bebf0 (patch)
tree2bd06655367af012e17bf80947cdb792fa1b9b44 /src/mongo/db/repl/database_cloner.h
parent1ded7067e2d1a6161b15e5a462f8cba2d755c9a6 (diff)
downloadmongo-3d7ed4fdd5e4840e9599a74ec92e16bc619bebf0.tar.gz
SERVER-35682 kill existing SharedPromise type
This required plumbing unique_function into many more places.
Diffstat (limited to 'src/mongo/db/repl/database_cloner.h')
-rw-r--r--src/mongo/db/repl/database_cloner.h9
1 files changed, 6 insertions, 3 deletions
diff --git a/src/mongo/db/repl/database_cloner.h b/src/mongo/db/repl/database_cloner.h
index 0a5b893b294..7b2cd152592 100644
--- a/src/mongo/db/repl/database_cloner.h
+++ b/src/mongo/db/repl/database_cloner.h
@@ -97,6 +97,9 @@ public:
*/
using StartCollectionClonerFn = stdx::function<Status(CollectionCloner&)>;
+ using ScheduleDbWorkFn = stdx::function<StatusWith<executor::TaskExecutor::CallbackHandle>(
+ executor::TaskExecutor::CallbackFn)>;
+
/**
* Creates DatabaseCloner task in inactive state. Use start() to activate cloner.
*
@@ -116,7 +119,7 @@ public:
const ListCollectionsPredicateFn& listCollectionsPredicate,
StorageInterface* storageInterface,
const CollectionCallbackFn& collectionWork,
- const CallbackFn& onCompletion);
+ CallbackFn onCompletion);
virtual ~DatabaseCloner();
@@ -146,7 +149,7 @@ public:
*
* For testing only.
*/
- void setScheduleDbWorkFn_forTest(const CollectionCloner::ScheduleDbWorkFn& scheduleDbWorkFn);
+ void setScheduleDbWorkFn_forTest(const ScheduleDbWorkFn& scheduleDbWorkFn);
/**
* Overrides how executor starts a collection cloner.
@@ -234,7 +237,7 @@ private:
std::vector<NamespaceString> _collectionNamespaces; // (M)
std::list<CollectionCloner> _collectionCloners; // (M)
std::list<CollectionCloner>::iterator _currentCollectionClonerIter; // (M)
- CollectionCloner::ScheduleDbWorkFn
+ ScheduleDbWorkFn
_scheduleDbWorkFn; // (RT) Function for scheduling database work using the executor.
StartCollectionClonerFn _startCollectionCloner; // (RT)
Stats _stats; // (M) Stats about what this instance did.