OpenSDN source code
cass::cql::impl::WorkerTask Class Reference
Inheritance diagram for cass::cql::impl::WorkerTask:
Collaboration diagram for cass::cql::impl::WorkerTask:

Public Types

typedef boost::function< void(void)> FunctionPtr
 
- Public Types inherited from Task
enum  State { INIT , WAIT , RUN }
 Task states. More...
 
enum  TbbState { TBB_INIT , TBB_ENQUEUED , TBB_EXEC , TBB_DONE }
 Describes states of a task according to TBB library. More...
 

Public Member Functions

 WorkerTask (FunctionPtr func, int task_id, int task_instance)
 
bool Run ()
 Code to execute in a task. Returns true if task is completed. Return false to reschedule the task. More...
 
std::string Description () const
 Gives a description of the task. More...
 
- Public Member Functions inherited from Task
 Task (int task_id, int task_data_id)
 Creates a new task with the given values of task code ID and task data ID. More...
 
 Task (int task_id)
 Creates a new task with the given value of task code ID and wildcard for task data ID. More...
 
virtual ~Task ()
 Destroys a task. More...
 
virtual void OnTaskCancel ()
 Called on task exit, if it is marked for cancellation. If the user wants to do any cleanup on task cancellation, then he/she can overload this function. More...
 
State state () const
 Returns a state value of a task. More...
 
int task_code_id () const
 Returns the code ID of this task. More...
 
int task_data_id () const
 Returns the data ID of this task. More...
 
uint64_t seqno () const
 Returns the sequence number of this task. More...
 
bool task_cancelled () const
 Returns true if the task has been canceled. More...
 
uint64_t enqueue_time () const
 Returns the time when the task was enqueued for execution. More...
 
uint64_t schedule_time () const
 Returns the time when the task execution was started. More...
 
uint32_t execute_delay () const
 Returns the threshold for the task execution duration. More...
 
uint32_t schedule_delay () const
 Returns the time threshold for time difference between moments when the task was started and when it was enqueue. More...
 

Private Attributes

FunctionPtr func_
 

Additional Inherited Members

- Static Public Member Functions inherited from Task
static TaskRunning ()
 Returns a pointer to the current task the code is executing under. More...
 
- Static Public Attributes inherited from Task
static const int kTaskInstanceAny = -1
 Specifies value for wildcard (any or *) task data ID. More...
 

Detailed Description

Definition at line 1828 of file cql_if.cc.

Member Typedef Documentation

◆ FunctionPtr

typedef boost::function<void(void)> cass::cql::impl::WorkerTask::FunctionPtr

Definition at line 1830 of file cql_if.cc.

Constructor & Destructor Documentation

◆ WorkerTask()

cass::cql::impl::WorkerTask::WorkerTask ( FunctionPtr  func,
int  task_id,
int  task_instance 
)
inline

Definition at line 1831 of file cql_if.cc.

Member Function Documentation

◆ Description()

std::string cass::cql::impl::WorkerTask::Description ( ) const
inlinevirtual

Gives a description of the task.

Implements Task.

Definition at line 1839 of file cql_if.cc.

◆ Run()

bool cass::cql::impl::WorkerTask::Run ( )
inlinevirtual

Code to execute in a task. Returns true if task is completed. Return false to reschedule the task.

Implements Task.

Definition at line 1835 of file cql_if.cc.

Member Data Documentation

◆ func_

FunctionPtr cass::cql::impl::WorkerTask::func_
private

Definition at line 1843 of file cql_if.cc.


The documentation for this class was generated from the following file: