diff options
author | James Wahlin <james.wahlin@10gen.com> | 2016-08-08 12:27:35 -0400 |
---|---|---|
committer | James Wahlin <james.wahlin@10gen.com> | 2016-08-09 19:42:33 -0400 |
commit | 875bf157f0d16b10896528026f0e2be93c466f90 (patch) | |
tree | a35097d30807bddd98e4b8c0b68894088bb42d41 /src/mongo/db/repl/database_cloner.cpp | |
parent | d930f4832631eca7092ada4328d780f2b8d19d31 (diff) | |
download | mongo-875bf157f0d16b10896528026f0e2be93c466f90.tar.gz |
SERVER-24506 Cloner support for views
Diffstat (limited to 'src/mongo/db/repl/database_cloner.cpp')
-rw-r--r-- | src/mongo/db/repl/database_cloner.cpp | 8 |
1 files changed, 6 insertions, 2 deletions
diff --git a/src/mongo/db/repl/database_cloner.cpp b/src/mongo/db/repl/database_cloner.cpp index 35ba3254681..8888b958fba 100644 --- a/src/mongo/db/repl/database_cloner.cpp +++ b/src/mongo/db/repl/database_cloner.cpp @@ -38,6 +38,7 @@ #include "mongo/client/remote_command_retry_scheduler.h" #include "mongo/db/catalog/collection_options.h" +#include "mongo/db/commands/list_collections_filter.h" #include "mongo/db/repl/storage_interface.h" #include "mongo/rpc/metadata/server_selection_metadata.h" #include "mongo/stdx/functional.h" @@ -94,7 +95,10 @@ DatabaseCloner::DatabaseCloner(executor::TaskExecutor* executor, _dbWorkThreadPool(dbWorkThreadPool), _source(source), _dbname(dbname), - _listCollectionsFilter(listCollectionsFilter), + _listCollectionsFilter( + listCollectionsFilter.isEmpty() + ? ListCollectionsFilter::makeTypeCollectionFilter() + : ListCollectionsFilter::addTypeCollectionFilter(listCollectionsFilter)), _listCollectionsPredicate(listCollectionsPred ? listCollectionsPred : acceptAllPred), _storageInterface(si), _collectionWork(collWork), @@ -128,7 +132,7 @@ DatabaseCloner::~DatabaseCloner() { DESTRUCTOR_GUARD(shutdown(); join();); } -const std::vector<BSONObj>& DatabaseCloner::getCollectionInfos() const { +const std::vector<BSONObj>& DatabaseCloner::getCollectionInfos_forTest() const { LockGuard lk(_mutex); return _collectionInfos; } |