SERVER-33732 extend SyncTail::MultiSyncApplyFunc to accept an OperationContext

1 files changed, 9 insertions, 4 deletions

diff --git a/src/mongo/db/repl/data_replicator_external_state_mock.h b/src/mongo/db/repl/data_replicator_external_state_mock.h
index 1b93307f2fa..7d5f058627b 100644
--- a/src/mongo/db/repl/data_replicator_external_state_mock.h
+++ b/src/mongo/db/repl/data_replicator_external_state_mock.h
@@ -90,12 +90,16 @@ public:
 
     // Override to change _multiInitialSyncApply behavior.
     using MultiInitialSyncApplyFn =
-        stdx::function<Status(MultiApplier::OperationPtrs* ops,
+        stdx::function<Status(OperationContext* opCtx,
+                              MultiApplier::OperationPtrs* ops,
                               const HostAndPort& source,
                               AtomicUInt32* fetchCount,
                               WorkerMultikeyPathInfo* workerMultikeyPathInfo)>;
-    MultiInitialSyncApplyFn multiInitialSyncApplyFn = [](
-        MultiApplier::OperationPtrs*, const HostAndPort&, AtomicUInt32*, WorkerMultikeyPathInfo*) {
+    MultiInitialSyncApplyFn multiInitialSyncApplyFn = [](OperationContext*,
+                                                         MultiApplier::OperationPtrs*,
+                                                         const HostAndPort&,
+                                                         AtomicUInt32*,
+                                                         WorkerMultikeyPathInfo*) {
         return Status::OK();
     };
 
@@ -106,7 +110,8 @@ private:
                                    MultiApplier::Operations ops,
                                    MultiApplier::ApplyOperationFn applyOperation) override;
 
-    Status _multiInitialSyncApply(MultiApplier::OperationPtrs* ops,
+    Status _multiInitialSyncApply(OperationContext* opCtx,
+                                  MultiApplier::OperationPtrs* ops,
                                   const HostAndPort& source,
                                   AtomicUInt32* fetchCount,
                                   WorkerMultikeyPathInfo* workerMultikeyPathInfo) override;