summaryrefslogtreecommitdiff
path: root/src/mongo/db/repl/task_runner.h
diff options
context:
space:
mode:
authorBenety Goh <benety@mongodb.com>2016-04-15 11:45:36 -0400
committerBenety Goh <benety@mongodb.com>2016-04-18 15:46:12 -0400
commit2780aef9a4f76ab54f00bb7000e4ecc0219143ec (patch)
tree4653546be915f6a05f45fd5264e0513420a3db95 /src/mongo/db/repl/task_runner.h
parent6811d7c70d13559c3162e8f4333c3c061e5a5220 (diff)
downloadmongo-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.h8
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;