OpenSDN source code
|
#include <pkt_sandesh_flow.h>
Public Member Functions | |
PktSandeshFlow (Agent *agent, FlowRecordsResp *obj, std::string resp_ctx, std::string key) | |
virtual | ~PktSandeshFlow () |
void | SendResponse (SandeshResponse *resp) |
bool | SetFlowKey (std::string key) |
virtual bool | Run () |
Code to execute. Returns true if task is completed. Return false to reschedule the task. More... | |
std::string | Description () const |
void | SetSandeshFlowData (std::vector< SandeshFlowData > &list, FlowEntry *fe, const FlowExportInfo *info) |
void | set_delete_op (bool delete_op) |
![]() | |
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 |
Static Public Member Functions | |
static std::string | GetFlowKey (const FlowKey &key, uint16_t partition_id) |
![]() | |
static Task * | Running () |
Returns a pointer to the current task the code is executing under. More... | |
Static Public Attributes | |
static const int | kMaxFlowResponse = 100 |
static const char | kDelimiter = '-' |
static const std::string | start_key = "0-0-0-0-0-0.0.0.0-0.0.0.0" |
![]() | |
static const int | kTaskInstanceAny = -1 |
Protected Attributes | |
FlowRecordsResp * | resp_obj_ |
std::string | resp_data_ |
FlowKey | flow_iteration_key_ |
bool | key_valid_ |
bool | delete_op_ |
Agent * | agent_ |
uint16_t | partition_id_ |
Private Member Functions | |
DISALLOW_COPY_AND_ASSIGN (PktSandeshFlow) | |
Additional Inherited Members | |
![]() | |
enum | State { INIT, WAIT, RUN } |
Task states. More... | |
enum | TbbState { TBB_INIT, TBB_ENQUEUED, TBB_EXEC, TBB_DONE } |
Definition at line 13 of file pkt_sandesh_flow.h.
PktSandeshFlow::PktSandeshFlow | ( | Agent * | agent, |
FlowRecordsResp * | obj, | ||
std::string | resp_ctx, | ||
std::string | key | ||
) |
|
virtual |
Definition at line 295 of file pkt_sandesh_flow.cc.
|
inlinevirtual |
Implements Task.
Definition at line 27 of file pkt_sandesh_flow.h.
|
private |
|
static |
Definition at line 311 of file pkt_sandesh_flow.cc.
|
virtual |
Code to execute. Returns true if task is completed. Return false to reschedule the task.
Implements Task.
Reimplemented in PktSandeshFlowStats.
Definition at line 368 of file pkt_sandesh_flow.cc.
void PktSandeshFlow::SendResponse | ( | SandeshResponse * | resp | ) |
|
inline |
Definition at line 30 of file pkt_sandesh_flow.h.
bool PktSandeshFlow::SetFlowKey | ( | std::string | key | ) |
Definition at line 323 of file pkt_sandesh_flow.cc.
void PktSandeshFlow::SetSandeshFlowData | ( | std::vector< SandeshFlowData > & | list, |
FlowEntry * | fe, | ||
const FlowExportInfo * | info | ||
) |
Definition at line 298 of file pkt_sandesh_flow.cc.
|
protected |
Definition at line 38 of file pkt_sandesh_flow.h.
|
protected |
Definition at line 37 of file pkt_sandesh_flow.h.
|
protected |
Definition at line 35 of file pkt_sandesh_flow.h.
|
static |
Definition at line 16 of file pkt_sandesh_flow.h.
|
protected |
Definition at line 36 of file pkt_sandesh_flow.h.
|
static |
Definition at line 15 of file pkt_sandesh_flow.h.
|
protected |
Definition at line 39 of file pkt_sandesh_flow.h.
|
protected |
Definition at line 34 of file pkt_sandesh_flow.h.
|
protected |
Definition at line 33 of file pkt_sandesh_flow.h.
|
static |
Definition at line 17 of file pkt_sandesh_flow.h.