summaryrefslogtreecommitdiff
path: root/src/mongo/db/repl/database_cloner.h
diff options
context:
space:
mode:
authorBenety Goh <benety@mongodb.com>2016-07-14 16:18:11 -0400
committerBenety Goh <benety@mongodb.com>2016-07-16 07:52:31 -0400
commit098d5a1198b178744f831552e52797494f8431b1 (patch)
treeac1908a50c996e415d25c9b7600248e26109b595 /src/mongo/db/repl/database_cloner.h
parentdcb0d3fe6429db310307122e640196d7bd88b5eb (diff)
downloadmongo-098d5a1198b178744f831552e52797494f8431b1.tar.gz
SERVER-25069 DatabaseCloner accepts db worker thread pool at construction
Diffstat (limited to 'src/mongo/db/repl/database_cloner.h')
-rw-r--r--src/mongo/db/repl/database_cloner.h5
1 files changed, 5 insertions, 0 deletions
diff --git a/src/mongo/db/repl/database_cloner.h b/src/mongo/db/repl/database_cloner.h
index 0d8235408c9..a5460d15fbf 100644
--- a/src/mongo/db/repl/database_cloner.h
+++ b/src/mongo/db/repl/database_cloner.h
@@ -45,6 +45,9 @@
#include "mongo/util/net/hostandport.h"
namespace mongo {
+
+class OldThreadPool;
+
namespace repl {
namespace {
@@ -105,6 +108,7 @@ public:
* Takes ownership of the passed StorageInterface object.
*/
DatabaseCloner(executor::TaskExecutor* executor,
+ OldThreadPool* dbWorkThreadPool,
const HostAndPort& source,
const std::string& dbname,
const BSONObj& listCollectionsFilter,
@@ -191,6 +195,7 @@ private:
mutable stdx::mutex _mutex;
mutable stdx::condition_variable _condition; // (M)
executor::TaskExecutor* _executor; // (R)
+ OldThreadPool* _dbWorkThreadPool; // (R)
const HostAndPort _source; // (R)
const std::string _dbname; // (R)
const BSONObj _listCollectionsFilter; // (R)