diff options
author | Benety Goh <benety@mongodb.com> | 2016-04-15 11:45:36 -0400 |
---|---|---|
committer | Benety Goh <benety@mongodb.com> | 2016-04-18 15:46:12 -0400 |
commit | 2780aef9a4f76ab54f00bb7000e4ecc0219143ec (patch) | |
tree | 4653546be915f6a05f45fd5264e0513420a3db95 /src/mongo/db/repl/task_runner.h | |
parent | 6811d7c70d13559c3162e8f4333c3c061e5a5220 (diff) | |
download | mongo-2780aef9a4f76ab54f00bb7000e4ecc0219143ec.tar.gz |
SERVER-18038 ReplicationExecutor no longer requires StorageInterface to create operation context.
Diffstat (limited to 'src/mongo/db/repl/task_runner.h')
-rw-r--r-- | src/mongo/db/repl/task_runner.h | 8 |
1 files changed, 2 insertions, 6 deletions
diff --git a/src/mongo/db/repl/task_runner.h b/src/mongo/db/repl/task_runner.h index b8bf39ef57b..80fbd12d337 100644 --- a/src/mongo/db/repl/task_runner.h +++ b/src/mongo/db/repl/task_runner.h @@ -38,7 +38,6 @@ namespace mongo { -class Client; class Status; class OldThreadPool; class OperationContext; @@ -59,8 +58,6 @@ public: kCancel = 3, }; - using CreateOperationContextFn = - stdx::function<ServiceContext::UniqueOperationContext(Client*)>; using Task = stdx::function<NextAction(OperationContext*, const Status&)>; /** @@ -72,7 +69,7 @@ public: */ static Task makeCancelTask(); - TaskRunner(OldThreadPool* threadPool, const CreateOperationContextFn& createOperationContext); + explicit TaskRunner(OldThreadPool* threadPool); virtual ~TaskRunner(); @@ -92,7 +89,7 @@ public: * * This transitions the task runner to an active state. * - * The task runner creates an operation context using '_createOperationContext' + * The task runner creates an operation context using the current client * prior to running a scheduled task. Depending on the NextAction returned from the * task, operation contexts may be shared between consecutive tasks invoked by the task * runner. @@ -145,7 +142,6 @@ private: Task _waitForNextTask(); OldThreadPool* _threadPool; - CreateOperationContextFn _createOperationContext; // Protects member data of this TaskRunner. mutable stdx::mutex _mutex; |