OpenSDN source code
|
#include <flow_event.h>
Public Member Functions | |
UpdateFlowEventQueue (Agent *agent, FlowProto *proto, FlowTokenPool *pool, uint16_t latency_limit, uint32_t max_iterations) | |
virtual | ~UpdateFlowEventQueue () |
bool | HandleEvent (FlowEvent *event) |
![]() | |
FlowEventQueueBase (FlowProto *proto, const std::string &name, uint32_t task_id, int task_instance, FlowTokenPool *pool, uint16_t latency_limit, uint32_t max_iterations) | |
virtual | ~FlowEventQueueBase () |
virtual bool | Handler (FlowEvent *event) |
void | Shutdown () |
void | Enqueue (FlowEvent *event) |
bool | TokenCheck () |
bool | TaskEntry () |
void | TaskExit (bool done) |
void | set_disable (bool val) |
uint32_t | Length () |
void | MayBeStartRunner () |
Queue * | queue () const |
uint64_t | events_processed () const |
uint64_t | events_enqueued () const |
Additional Inherited Members | |
![]() | |
typedef WorkQueue< FlowEvent * > | Queue |
![]() | |
bool | CanEnqueue (FlowEvent *event) |
bool | CanProcess (FlowEvent *event) |
void | ProcessDone (FlowEvent *event, bool update_rev_flow) |
![]() | |
Queue * | queue_ |
FlowProto * | flow_proto_ |
FlowTokenPool * | token_pool_ |
uint64_t | task_start_ |
uint32_t | count_ |
uint64_t | events_processed_ |
uint16_t | latency_limit_ |
struct rusage | rusage_ |
Definition at line 345 of file flow_event.h.
UpdateFlowEventQueue::UpdateFlowEventQueue | ( | Agent * | agent, |
FlowProto * | proto, | ||
FlowTokenPool * | pool, | ||
uint16_t | latency_limit, | ||
uint32_t | max_iterations | ||
) |
Definition at line 290 of file flow_event.cc.
|
virtual |
Definition at line 299 of file flow_event.cc.
|
virtual |
Implements FlowEventQueueBase.
Definition at line 302 of file flow_event.cc.