diff options
| author | Benety Goh <benety@mongodb.com> | 2018-03-22 14:33:08 -0400 |
|---|---|---|
| committer | Benety Goh <benety@mongodb.com> | 2018-03-22 14:41:51 -0400 |
| commit | 8c99a68fa8bd95048e5c635539a0cacd565ce419 (patch) | |
| tree | db987317234d7722d9cc99de88f1c9ec3bae6139 /src/mongo/db/repl/data_replicator_external_state_impl.h | |
| parent | 03e42e323bf21e8722c38543fa4ad5e6e9008188 (diff) | |
| download | mongo-8c99a68fa8bd95048e5c635539a0cacd565ce419.tar.gz | |
SERVER-32335 extend InitialSyncer external state function multiApply function to accept ThreadPool, sync source and OplogApplier::Observer
This commit has no functional changes.
Diffstat (limited to 'src/mongo/db/repl/data_replicator_external_state_impl.h')
| -rw-r--r-- | src/mongo/db/repl/data_replicator_external_state_impl.h | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/src/mongo/db/repl/data_replicator_external_state_impl.h b/src/mongo/db/repl/data_replicator_external_state_impl.h index 5ebc16f7064..10398a0b02a 100644 --- a/src/mongo/db/repl/data_replicator_external_state_impl.h +++ b/src/mongo/db/repl/data_replicator_external_state_impl.h @@ -48,8 +48,6 @@ public: executor::TaskExecutor* getTaskExecutor() const override; - ThreadPool* getDbWorkThreadPool() const override; - OpTimeWithTerm getCurrentTermAndLastCommittedOpTime() override; void processMetadata(const rpc::ReplSetMetadata& replMetadata, @@ -66,7 +64,10 @@ public: private: StatusWith<OpTime> _multiApply(OperationContext* opCtx, MultiApplier::Operations ops, - MultiApplier::ApplyOperationFn applyOperation) override; + OplogApplier::Observer* observer, + const HostAndPort& source, + MultiApplier::ApplyOperationFn applyOperation, + ThreadPool* writerPool) override; Status _multiInitialSyncApply(OperationContext* opCtx, MultiApplier::OperationPtrs* ops, |