OpenSDN source code
|
Public Member Functions | |
Worker (Walker *walker, int db_partition_id, const DBRequestKey *key) | |
virtual bool | Run () |
Code to execute. Returns true if task is completed. Return false to reschedule the task. More... | |
std::string | Description () const |
![]() | |
Task (int task_id, int task_instance) | |
Task (int task_id) | |
virtual | ~Task () |
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 | GetState () const |
int | GetTaskId () const |
int | GetTaskInstance () const |
uint64_t | GetSeqno () const |
bool | task_cancelled () const |
uint64_t | enqueue_time () const |
uint64_t | schedule_time () const |
uint32_t | execute_delay () const |
uint32_t | schedule_delay () const |
Private Attributes | |
DBTableWalker::Walker * | walker_ |
std::unique_ptr< DBRequestKey > | walk_ctx_ |
const DBRequestKey * | key_start_ |
DBTablePartition * | tbl_partition_ |
Additional Inherited Members | |
![]() | |
enum | State { INIT, WAIT, RUN } |
Task states. More... | |
enum | TbbState { TBB_INIT, TBB_ENQUEUED, TBB_EXEC, TBB_DONE } |
![]() | |
static Task * | Running () |
Returns a pointer to the current task the code is executing under. More... | |
![]() | |
static const int | kTaskInstanceAny = -1 |
Definition at line 64 of file db_table_walker.cc.
|
inline |
|
inlinevirtual |
Implements Task.
Definition at line 74 of file db_table_walker.cc.
|
virtual |
Code to execute. Returns true if task is completed. Return false to reschedule the task.
Implements Task.
Definition at line 109 of file db_table_walker.cc.
|
private |
Definition at line 83 of file db_table_walker.cc.
|
private |
Definition at line 86 of file db_table_walker.cc.
|
private |
Definition at line 80 of file db_table_walker.cc.
|
private |
Definition at line 77 of file db_table_walker.cc.