diff options
| author | Ben Caimano <ben.caimano@mongodb.com> | 2019-09-09 18:45:01 +0000 |
|---|---|---|
| committer | evergreen <evergreen@mongodb.com> | 2019-09-09 18:45:01 +0000 |
| commit | 0f16c5fc452d16c5a92e43e9fdd96f3822f05271 (patch) | |
| tree | 890ff8a80ae78d7831452aedb30feb9e76be1567 /src/mongo/db/repl/collection_cloner.cpp | |
| parent | f4e387fa1b7e369ce067650bdda9c8676683b929 (diff) | |
| download | mongo-0f16c5fc452d16c5a92e43e9fdd96f3822f05271.tar.gz | |
SERVER-42908 Add ErrorCodes to retryable errors to match drivers
Diffstat (limited to 'src/mongo/db/repl/collection_cloner.cpp')
| -rw-r--r-- | src/mongo/db/repl/collection_cloner.cpp | 10 |
1 files changed, 4 insertions, 6 deletions
diff --git a/src/mongo/db/repl/collection_cloner.cpp b/src/mongo/db/repl/collection_cloner.cpp index d6c17b38cfd..b081be1fce0 100644 --- a/src/mongo/db/repl/collection_cloner.cpp +++ b/src/mongo/db/repl/collection_cloner.cpp @@ -122,10 +122,9 @@ CollectionCloner::CollectionCloner(executor::TaskExecutor* executor, [this](const executor::TaskExecutor::RemoteCommandCallbackArgs& args) { return _countCallback(args); }, - RemoteCommandRetryScheduler::makeRetryPolicy( + RemoteCommandRetryScheduler::makeRetryPolicy<ErrorCategory::RetriableError>( numInitialSyncCollectionCountAttempts.load(), - executor::RemoteCommandRequest::kNoTimeout, - RemoteCommandRetryScheduler::kAllRetriableErrors)), + executor::RemoteCommandRequest::kNoTimeout)), _listIndexesFetcher( _executor, _source, @@ -139,10 +138,9 @@ CollectionCloner::CollectionCloner(executor::TaskExecutor* executor, ReadPreferenceSetting::secondaryPreferredMetadata(), RemoteCommandRequest::kNoTimeout /* find network timeout */, RemoteCommandRequest::kNoTimeout /* getMore network timeout */, - RemoteCommandRetryScheduler::makeRetryPolicy( + RemoteCommandRetryScheduler::makeRetryPolicy<ErrorCategory::RetriableError>( numInitialSyncListIndexesAttempts.load(), - executor::RemoteCommandRequest::kNoTimeout, - RemoteCommandRetryScheduler::kAllRetriableErrors)), + executor::RemoteCommandRequest::kNoTimeout)), _indexSpecs(), _documentsToInsert(), _dbWorkTaskRunner(_dbWorkThreadPool), |