diff options
Diffstat (limited to 'src/mongo/db/repl/database_cloner.cpp')
-rw-r--r-- | src/mongo/db/repl/database_cloner.cpp | 32 |
1 files changed, 16 insertions, 16 deletions
diff --git a/src/mongo/db/repl/database_cloner.cpp b/src/mongo/db/repl/database_cloner.cpp index 1d1f3dda338..1466b7b2dc3 100644 --- a/src/mongo/db/repl/database_cloner.cpp +++ b/src/mongo/db/repl/database_cloner.cpp @@ -112,22 +112,22 @@ DatabaseCloner::DatabaseCloner(executor::TaskExecutor* executor, _storageInterface(si), _collectionWork(collWork), _onCompletion(std::move(onCompletion)), - _listCollectionsFetcher(_executor, - _source, - _dbname, - createListCollectionsCommandObject(_listCollectionsFilter), - [=](const StatusWith<Fetcher::QueryResponse>& result, - Fetcher::NextAction* nextAction, - BSONObjBuilder* getMoreBob) { - _listCollectionsCallback(result, nextAction, getMoreBob); - }, - ReadPreferenceSetting::secondaryPreferredMetadata(), - RemoteCommandRequest::kNoTimeout /* find network timeout */, - RemoteCommandRequest::kNoTimeout /* getMore network timeout */, - RemoteCommandRetryScheduler::makeRetryPolicy( - numInitialSyncListCollectionsAttempts.load(), - executor::RemoteCommandRequest::kNoTimeout, - RemoteCommandRetryScheduler::kAllRetriableErrors)), + _listCollectionsFetcher( + _executor, + _source, + _dbname, + createListCollectionsCommandObject(_listCollectionsFilter), + [=](const StatusWith<Fetcher::QueryResponse>& result, + Fetcher::NextAction* nextAction, + BSONObjBuilder* getMoreBob) { + _listCollectionsCallback(result, nextAction, getMoreBob); + }, + ReadPreferenceSetting::secondaryPreferredMetadata(), + RemoteCommandRequest::kNoTimeout /* find network timeout */, + RemoteCommandRequest::kNoTimeout /* getMore network timeout */, + RemoteCommandRetryScheduler::makeRetryPolicy<ErrorCategory::RetriableError>( + numInitialSyncListCollectionsAttempts.load(), + executor::RemoteCommandRequest::kNoTimeout)), _startCollectionCloner([](CollectionCloner& cloner) { return cloner.startup(); }) { // Fetcher throws an exception on null executor. invariant(executor); |