diff options
author | Benety Goh <benety@mongodb.com> | 2018-03-22 18:21:45 -0400 |
---|---|---|
committer | Benety Goh <benety@mongodb.com> | 2018-03-22 18:21:45 -0400 |
commit | ac11c78003b63696ac949995827ed099c8be654d (patch) | |
tree | 6c19127c1f6a0de34726f10ed08e74f8a5e9c43b /src/mongo/db/repl/data_replicator_external_state_impl.cpp | |
parent | d6470f917762315ab93b2f7719da78cafdb8d8bf (diff) | |
download | mongo-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.cpp | 6 |
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 { |