summaryrefslogtreecommitdiff
path: root/src/mongo/db/repl/data_replicator_external_state_impl.cpp
diff options
context:
space:
mode:
authorBenety Goh <benety@mongodb.com>2018-03-22 18:21:45 -0400
committerBenety Goh <benety@mongodb.com>2018-03-22 18:21:45 -0400
commitac11c78003b63696ac949995827ed099c8be654d (patch)
tree6c19127c1f6a0de34726f10ed08e74f8a5e9c43b /src/mongo/db/repl/data_replicator_external_state_impl.cpp
parentd6470f917762315ab93b2f7719da78cafdb8d8bf (diff)
downloadmongo-ac11c78003b63696ac949995827ed099c8be654d.tar.gz
SERVER-32335 DataReplicatorExternalStateImpl::_multiApply calls SyncTail directly
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.cpp6
1 files changed, 4 insertions, 2 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 480280bf181..f577d4ecf2f 100644
--- a/src/mongo/db/repl/data_replicator_external_state_impl.cpp
+++ b/src/mongo/db/repl/data_replicator_external_state_impl.cpp
@@ -34,6 +34,7 @@
#include "mongo/db/repl/replication_coordinator.h"
#include "mongo/db/repl/replication_coordinator_external_state.h"
+#include "mongo/db/repl/sync_tail.h"
#include "mongo/util/log.h"
namespace mongo {
@@ -115,8 +116,9 @@ StatusWith<OpTime> DataReplicatorExternalStateImpl::_multiApply(OperationContext
OplogApplier::Observer* observer,
const HostAndPort& source,
ThreadPool* writerPool) {
- return _replicationCoordinatorExternalState->multiApply(
- opCtx, std::move(ops), observer, source, writerPool);
+ SyncTail syncTail(observer, repl::multiInitialSyncApply, writerPool);
+ syncTail.setHostname(source.toString());
+ return syncTail.multiApply(opCtx, std::move(ops));
}
ReplicationCoordinator* DataReplicatorExternalStateImpl::getReplicationCoordinator() const {