summaryrefslogtreecommitdiff
path: root/src/mongo/db/repl/data_replicator_external_state_impl.cpp
diff options
context:
space:
mode:
authorBenety Goh <benety@mongodb.com>2018-05-15 16:17:25 -0400
committerBenety Goh <benety@mongodb.com>2018-05-15 16:17:25 -0400
commit43d15d7bf913939321905ae0439fa8741a1deb9f (patch)
tree28ee4aaa7297e2941242e4289185777fa6ebbdc0 /src/mongo/db/repl/data_replicator_external_state_impl.cpp
parentbae37257c81b34327db93208d31d4963ff6a8cc6 (diff)
downloadmongo-43d15d7bf913939321905ae0439fa8741a1deb9f.tar.gz
SERVER-32335 make initial sync batch limits internal to getNextApplierBatch()
Stop using batch limits provided by the caller.
Diffstat (limited to 'src/mongo/db/repl/data_replicator_external_state_impl.cpp')
-rw-r--r--src/mongo/db/repl/data_replicator_external_state_impl.cpp7
1 files changed, 4 insertions, 3 deletions
diff --git a/src/mongo/db/repl/data_replicator_external_state_impl.cpp b/src/mongo/db/repl/data_replicator_external_state_impl.cpp
index 89d7836d820..98eb0c55c74 100644
--- a/src/mongo/db/repl/data_replicator_external_state_impl.cpp
+++ b/src/mongo/db/repl/data_replicator_external_state_impl.cpp
@@ -148,11 +148,12 @@ std::unique_ptr<OplogBuffer> DataReplicatorExternalStateImpl::makeInitialSyncOpl
}
StatusWith<OplogApplier::Operations> DataReplicatorExternalStateImpl::getNextApplierBatch(
- OperationContext* opCtx,
- OplogBuffer* oplogBuffer,
- const OplogApplier::BatchLimits& batchLimits) {
+ OperationContext* opCtx, OplogBuffer* oplogBuffer, const OplogApplier::BatchLimits&) {
OplogApplier oplogApplier(
nullptr, oplogBuffer, nullptr, nullptr, nullptr, nullptr, {}, nullptr);
+ OplogApplier::BatchLimits batchLimits;
+ batchLimits.bytes = SyncTail::replBatchLimitBytes;
+ batchLimits.ops = std::size_t(SyncTail::replBatchLimitOperations.load());
return oplogApplier.getNextApplierBatch(opCtx, batchLimits);
}