diff options
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.cpp | 11 |
1 files changed, 7 insertions, 4 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 64492dc63dd..49ea11001b1 100644 --- a/src/mongo/db/repl/data_replicator_external_state_impl.cpp +++ b/src/mongo/db/repl/data_replicator_external_state_impl.cpp @@ -126,10 +126,13 @@ StatusWith<OpTime> DataReplicatorExternalStateImpl::_multiApply( return _replicationCoordinatorExternalState->multiApply(opCtx, std::move(ops), applyOperation); } -Status DataReplicatorExternalStateImpl::_multiInitialSyncApply(MultiApplier::OperationPtrs* ops, - const HostAndPort& source, - AtomicUInt32* fetchCount) { - return _replicationCoordinatorExternalState->multiInitialSyncApply(ops, source, fetchCount); +Status DataReplicatorExternalStateImpl::_multiInitialSyncApply( + MultiApplier::OperationPtrs* ops, + const HostAndPort& source, + AtomicUInt32* fetchCount, + WorkerMultikeyPathInfo* workerMultikeyPathInfo) { + return _replicationCoordinatorExternalState->multiInitialSyncApply( + ops, source, fetchCount, workerMultikeyPathInfo); } ReplicationCoordinator* DataReplicatorExternalStateImpl::getReplicationCoordinator() const { |