AddEvent(const FlowEntryPtr &flow) | FlowStatsCollector | |
AddFlow(FlowExportInfo info) | FlowStatsCollector | private |
AgeFlow(KSyncFlowMemory *ksync_obj, const vr_flow_entry *k_flow, const vr_flow_stats &k_stats, const KFlowData &kinfo, FlowExportInfo *info, uint64_t curr_time) | FlowStatsCollector | |
ageing_task_ | FlowStatsCollector | private |
ageing_task_starts_ | FlowStatsCollector | private |
agent_uve_ | FlowStatsCollector | private |
AgentStatsCollector enum value | StatsCollector | |
AgentUtXmlFlowThreshold class | FlowStatsCollector | friend |
AgentUtXmlFlowThresholdValidate class | FlowStatsCollector | friend |
AgeTreeSize() const | FlowStatsCollector | inline |
current_time_ | FlowStatsCollector | private |
deleted() const | FlowStatsCollector | inline |
deleted_ | FlowStatsCollector | private |
DeleteEvent(const FlowEntryPtr &flow, const RevFlowDepParams ¶ms) | FlowStatsCollector | |
DeleteFlow(FlowEntryTree::iterator &it) | FlowStatsCollector | private |
DISALLOW_COPY_AND_ASSIGN(FlowStatsCollector) | FlowStatsCollector | private |
entries_to_visit_ | FlowStatsCollector | private |
EvictedFlowStatsUpdate(const FlowEntryPtr &flow, uint32_t bytes, uint32_t packets, uint32_t oflow_bytes, const boost::uuids::uuid &u) | FlowStatsCollector | private |
EvictFlow(KSyncFlowMemory *ksync_obj, const vr_flow_entry *k_flow, uint16_t k_flow_flags, uint32_t flow_handle, uint16_t gen_id, FlowExportInfo *info, uint64_t curr_time) | FlowStatsCollector | |
expiry_time() const | StatsCollector | inline |
FetchFlowStatsRecord class | FlowStatsCollector | friend |
FindFlowExportInfo(const FlowEntry *fe, FlowEntryTree::iterator &it) | FlowStatsCollector | |
FindFlowExportInfo(const FlowEntry *fe) | FlowStatsCollector | |
FindFlowExportInfo(const FlowEntry *fe) const | FlowStatsCollector | |
flow_age_time_intvl() | FlowStatsCollector | inline |
flow_age_time_intvl_ | FlowStatsCollector | private |
flow_age_time_intvl_in_secs() const | FlowStatsCollector | inline |
flow_aging_key() const | FlowStatsCollector | inline |
flow_aging_key_ | FlowStatsCollector | private |
flow_export_info_list_ | FlowStatsCollector | private |
flow_iteration_key_ | FlowStatsCollector | private |
flow_stats_manager_ | FlowStatsCollector | private |
flow_tcp_syn_age_time() const | FlowStatsCollector | inline |
flow_tcp_syn_age_time_ | FlowStatsCollector | private |
flow_tree_ | FlowStatsCollector | private |
FlowAgeTime | FlowStatsCollector | static |
FlowDeleteEnqueue(FlowExportInfo *info, uint64_t t) | FlowStatsCollector | private |
FlowEntryTree typedef | FlowStatsCollector | |
FlowEvictEnqueue(FlowExportInfo *info, uint64_t t, uint32_t flow_handle, uint16_t gen_id) | FlowStatsCollector | private |
flows_aged_ | FlowStatsCollector | private |
flows_evicted_ | FlowStatsCollector | private |
flows_visited_ | FlowStatsCollector | private |
FlowStatsCollector(boost::asio::io_context &io, int intvl, uint32_t flow_cache_timeout, AgentUveBase *uve, uint32_t instance_id, FlowAgingTableKey *key, FlowStatsManager *aging_module, FlowStatsCollectorObject *obj) | FlowStatsCollector | |
StatsCollector::FlowStatsCollector enum value | StatsCollector | |
FlowStatsCollectorObject class | FlowStatsCollector | friend |
FlowStatsManager class | FlowStatsCollector | friend |
FlowStatsRecordsReq class | FlowStatsCollector | friend |
FlowTcpSynAgeTime | FlowStatsCollector | static |
GetCurrentTime() | FlowStatsCollector | privatestatic |
GetFlowStats(const uint16_t &oflow_data, const uint32_t &data) | FlowStatsCollector | static |
GetUpdatedFlowBytes(const FlowExportInfo *stats, uint64_t k_flow_bytes) | FlowStatsCollector | private |
GetUpdatedFlowPackets(const FlowExportInfo *stats, uint64_t k_flow_pkts) | FlowStatsCollector | private |
HandleFlowStatsUpdate(const FlowKey &key, uint32_t bytes, uint32_t packets, uint32_t oflow_bytes) | FlowStatsCollector | private |
InitDone() | StatsCollector | inline |
instance_id() const | FlowStatsCollector | inline |
instance_id_ | FlowStatsCollector | private |
kDefaultFlowSamplingThreshold | FlowStatsCollector | static |
kFlowDeleteRetryTime | FlowStatsCollector | static |
kFlowScanTime | FlowStatsCollector | static |
kFlowsPerTask | FlowStatsCollector | static |
kFlowStatsTimerInterval | FlowStatsCollector | static |
kMaxFlowMsgsPerSend | FlowStatsCollector | static |
kMinFlowsPerTimer | FlowStatsCollector | static |
NewFlow(FlowEntry *flow) | FlowStatsCollector | |
parent_ | FlowStatsCollector | private |
ProcessFlow(FlowExportInfoList::iterator &it, KSyncFlowMemory *ksync_obj, FlowExportInfo *info, uint64_t curr_time) | FlowStatsCollector | |
Queue typedef | FlowStatsCollector | |
queue() const | FlowStatsCollector | inline |
rand_gen() | FlowStatsCollector | |
rand_gen_ | FlowStatsCollector | private |
request_queue_ | FlowStatsCollector | private |
RequestHandler(boost::shared_ptr< FlowExportReq > req) | FlowStatsCollector | private |
RequestHandlerEntry() | FlowStatsCollector | private |
RequestHandlerExit(bool done) | FlowStatsCollector | private |
RescheduleTimer(int time) | StatsCollector | inline |
retry_delete_ | FlowStatsCollector | private |
ReverseFlowFip(const FlowExportInfo *info) | FlowStatsCollector | private |
ReverseFlowFipEntry(const FlowExportInfo *flow) | FlowStatsCollector | private |
ReverseFlowFipVmi(const FlowExportInfo *info) | FlowStatsCollector | private |
Run() | FlowStatsCollector | virtual |
run_counter_ | StatsCollector | |
RunAgeing(uint32_t max_count) | FlowStatsCollector | |
RunAgeingTask() | FlowStatsCollector | |
set_deleted(bool val) | FlowStatsCollector | inline |
set_expiry_time(int time) | StatsCollector | inline |
set_flow_age_time_intvl(uint64_t interval) | FlowStatsCollector | inline |
set_flow_tcp_syn_age_time(uint64_t interval) | FlowStatsCollector | inline |
ShouldBeAged(FlowExportInfo *info, const vr_flow_entry *k_flow, const vr_flow_stats &k_stats, uint64_t curr_time) | FlowStatsCollector | private |
Shutdown() | FlowStatsCollector | |
Size() const | FlowStatsCollector | inline |
StatsCollector(int task_id, int32_t instance, boost::asio::io_service &io, int exp, std::string timer_name) | StatsCollector | inline |
StatsInstance enum name | StatsCollector | |
task_id() const | FlowStatsCollector | inline |
task_id_ | FlowStatsCollector | private |
TestStartStopTimer(bool stop) | StatsCollector | inline |
timers_per_scan_ | FlowStatsCollector | private |
TimersPerScan() | FlowStatsCollector | private |
UpdateEntriesToVisit() | FlowStatsCollector | private |
UpdateFloatingIpStats(const FlowExportInfo *flow, uint64_t bytes, uint64_t pkts) | FlowStatsCollector | |
UpdateFlowAgeTime(uint64_t usecs) | FlowStatsCollector | inline |
UpdateFlowAgeTimeInSecs(uint32_t secs) | FlowStatsCollector | inline |
UpdateFlowIterationKey(const FlowEntry *del_flow, FlowEntryTree::iterator &tree_it) | FlowStatsCollector | private |
UpdateFlowStats(FlowExportInfo *info, uint64_t teardown_time) | FlowStatsCollector | private |
UpdateFlowStatsInternal(FlowExportInfo *info, uint32_t bytes, uint16_t oflow_bytes, uint32_t pkts, uint16_t oflow_pkts, uint64_t time, bool teardown_time) | FlowStatsCollector | private |
UpdateFlowStatsInternalLocked(FlowExportInfo *info, uint32_t bytes, uint16_t oflow_bytes, uint32_t pkts, uint16_t oflow_pkts, uint64_t time, bool teardown_time) | FlowStatsCollector | private |
UpdateInterVnStats(FlowExportInfo *info, uint64_t bytes, uint64_t pkts) | FlowStatsCollector | private |
UpdateStatsEvent(const FlowEntryPtr &flow, uint32_t bytes, uint32_t packets, uint32_t oflow_bytes, const boost::uuids::uuid &u) | FlowStatsCollector | |
UpdateThreshold(uint32_t new_value) | FlowStatsCollector | private |
UpdateVmiTagBasedStats(FlowExportInfo *info, uint64_t bytes, uint64_t pkts) | FlowStatsCollector | private |
~FlowStatsCollector() | FlowStatsCollector | virtual |
~StatsCollector() | StatsCollector | inlinevirtual |