summaryrefslogtreecommitdiff
path: root/src/mongo/db/repl/storage_interface_impl.h
diff options
context:
space:
mode:
authorBenety Goh <benety@mongodb.com>2016-07-29 19:44:34 -0400
committerBenety Goh <benety@mongodb.com>2016-07-29 19:47:04 -0400
commite0bb47c1fc8e465687dccba684e6c705867a56f3 (patch)
tree230b02eb75e6a45fa50a027a4b45a83a66b24437 /src/mongo/db/repl/storage_interface_impl.h
parente0b51290e9046a26790c8ad2cc52118eb654a27f (diff)
downloadmongo-e0bb47c1fc8e465687dccba684e6c705867a56f3.tar.gz
Revert "SERVER-25084 removed unused StorageInterfaceImpl::_bulkLoaderThreads"
This reverts commit d305e618162d37ccc16cf574fcc0388a1160af93.
Diffstat (limited to 'src/mongo/db/repl/storage_interface_impl.h')
-rw-r--r--src/mongo/db/repl/storage_interface_impl.h5
1 files changed, 5 insertions, 0 deletions
diff --git a/src/mongo/db/repl/storage_interface_impl.h b/src/mongo/db/repl/storage_interface_impl.h
index 0226c4705aa..7e45c77fae2 100644
--- a/src/mongo/db/repl/storage_interface_impl.h
+++ b/src/mongo/db/repl/storage_interface_impl.h
@@ -35,8 +35,11 @@
#include "mongo/base/string_data.h"
#include "mongo/bson/bsonobj.h"
#include "mongo/db/catalog/index_create.h"
+#include "mongo/db/db_raii.h"
#include "mongo/db/namespace_string.h"
#include "mongo/db/repl/storage_interface.h"
+#include "mongo/db/repl/task_runner.h"
+#include "mongo/util/concurrency/old_thread_pool.h"
namespace mongo {
namespace repl {
@@ -115,6 +118,8 @@ public:
Status isAdminDbValid(OperationContext* txn) override;
private:
+ // One thread per collection/TaskRunner
+ std::unique_ptr<OldThreadPool> _bulkLoaderThreads;
const NamespaceString _minValidNss;
};