summaryrefslogtreecommitdiff
path: root/src/mongo/db/repl/bgsync.cpp
diff options
context:
space:
mode:
authorBenety Goh <benety@mongodb.com>2017-04-25 10:15:22 -0400
committerBenety Goh <benety@mongodb.com>2017-05-04 14:11:21 -0400
commitf1730beea3b55c31e33ece40e8bc1f9b4ed78b9a (patch)
tree1a742e5123c182bc0ad4002bded05c25c496b9ae /src/mongo/db/repl/bgsync.cpp
parentc65825adeeae0ff217f3780afbe9f0a03e7a9f5d (diff)
downloadmongo-f1730beea3b55c31e33ece40e8bc1f9b4ed78b9a.tar.gz
SERVER-28214 add remoteOplogNss and maxFetcherRestarts arguments to RollbackImpl constructor
Diffstat (limited to 'src/mongo/db/repl/bgsync.cpp')
-rw-r--r--src/mongo/db/repl/bgsync.cpp17
1 files changed, 10 insertions, 7 deletions
diff --git a/src/mongo/db/repl/bgsync.cpp b/src/mongo/db/repl/bgsync.cpp
index 387dd04cd40..8bd3c0e8ab0 100644
--- a/src/mongo/db/repl/bgsync.cpp
+++ b/src/mongo/db/repl/bgsync.cpp
@@ -634,13 +634,16 @@ void BackgroundSync::_runRollback(OperationContext* opCtx,
if (_state != ProducerState::Running) {
return;
}
- _rollback = stdx::make_unique<RollbackImpl>(executor,
- &localOplog,
- source,
- requiredRBID,
- _replCoord,
- storageInterface,
- onRollbackShutdownCallbackFn);
+ _rollback = stdx::make_unique<RollbackImpl>(
+ executor,
+ &localOplog,
+ source,
+ NamespaceString(rsOplogName),
+ _replicationCoordinatorExternalState->getOplogFetcherMaxFetcherRestarts(),
+ requiredRBID,
+ _replCoord,
+ storageInterface,
+ onRollbackShutdownCallbackFn);
rollback = _rollback.get();
} catch (...) {
fassertFailedWithStatus(40401, exceptionToStatus());