OpenSDN source code
SessionStatsCollector Member List

This is the complete list of members for SessionStatsCollector, including all inherited members.

AddEvent(const FlowEntryPtr &flow)SessionStatsCollectorprivate
AddFlowToSessionMap(FlowEntry *fe, SessionKey session_key, SessionAggKey session_agg_key, SessionEndpointKey session_endpoint_key)SessionStatsCollectorprivate
AddSession(FlowEntry *fe, uint64_t setup_time)SessionStatsCollectorprivate
AddSessionSloRuleEntry(const std::string &uuid, int rate, SecurityLoggingObject *slo, SessionSloRuleMap *slo_rule_map)SessionStatsCollectorprivate
AddSloEntry(const boost::uuids::uuid &uuid, SessionSloRuleMap *slo_rule_map)SessionStatsCollectorprivate
AddSloEntryRules(SecurityLoggingObject *slo, SessionSloRuleMap *slo_rule_map)SessionStatsCollectorprivate
AddSloFirewallPolicies(SecurityLoggingObject *slo, SessionSloRuleMap *r_map)SessionStatsCollectorprivate
AddSloFirewallRules(SecurityLoggingObject *slo, SessionSloRuleMap *rule_map)SessionStatsCollectorprivate
AddSloList(const UuidList &slo_list, SessionSloRuleMap *slo_rule_map)SessionStatsCollectorprivate
AddSloRules(const std::vector< autogen::SecurityLoggingObjectRuleEntryType > &list, SecurityLoggingObject *slo, SessionSloRuleMap *slo_rule_map)SessionStatsCollectorprivate
agent_uve_SessionStatsCollectorprivate
AgentStatsCollector enum valueStatsCollector
BuildSloList(const SessionStatsInfo &stats_info, const FlowEntry *fe, SessionSloRuleMap *global_session_slo_rule_map, SessionSloRuleMap *vmi_session_slo_rule_map, SessionSloRuleMap *vn_session_slo_rule_map)SessionStatsCollectorprivate
CheckAndDeleteSessionStatsFlow(SessionPreAggInfo::SessionMap::iterator session_map_iter)SessionStatsCollectorprivate
CheckPolicyMatch(const SessionSloRuleMap &map, const std::string &policy_uuid, const bool &deleted_flag, bool *match, const bool &exported_once)SessionStatsCollectorprivate
CheckSessionLogging(const SessionStatsInfo &stats_info)SessionStatsCollectorprivate
ComputeSloRate(int rate, SecurityLoggingObject *slo) constSessionStatsCollectorprivate
CopyFlowInfo(SessionStatsInfo &session, const RevFlowDepParams *params)SessionStatsCollectorprivate
CopyFlowInfoInternal(SessionFlowExportInfo *info, const boost::uuids::uuid &u, FlowEntry *fe) constSessionStatsCollectorprivate
current_time_SessionStatsCollectorprivate
DeletedFlowLogging(const SessionStatsInfo &stats_info, const SessionFlowExportInfo &flow_info, bool *logged, const bool &exported_once)SessionStatsCollectorprivate
DeleteEvent(const FlowEntryPtr &flow, const RevFlowDepParams &params)SessionStatsCollectorprivate
DeleteFlowToSessionMap(FlowEntry *fe)SessionStatsCollectorprivate
DeleteSession(FlowEntry *fe, const boost::uuids::uuid &del_uuid, uint64_t teardown_time, const RevFlowDepParams *params)SessionStatsCollectorprivate
DISALLOW_COPY_AND_ASSIGN(SessionStatsCollector)SessionStatsCollectorprivate
DispatchPendingSessionMsg()SessionStatsCollectorprivate
DispatchSessionMsg(const std::vector< SessionEndpoint > &lst)SessionStatsCollectorprotectedvirtual
EnqueueSessionMsg()SessionStatsCollectorprivate
EvictedSessionStatsUpdate(const FlowEntryPtr &flow, uint32_t bytes, uint32_t packets, uint32_t oflow_bytes, const boost::uuids::uuid &u)SessionStatsCollectorprivate
expiry_time() constStatsCollectorinline
expiry_time_StatsCollectorprivate
FetchFlowStats(SessionFlowStatsInfo *info, SessionFlowStatsParams *params) constSessionStatsCollectorprivate
FillSessionAggInfo(SessionEndpointInfo::SessionAggMap::iterator it, SessionIpPortProtocol *session_agg_key) constSessionStatsCollectorprivate
FillSessionEndpoint(SessionEndpointMap::iterator it, SessionEndpoint *session_ep) constSessionStatsCollectorprivate
FillSessionEvictStats(SessionPreAggInfo::SessionMap::iterator session_map_iter, SessionInfo *session_info, bool is_sampling, bool is_logging) constSessionStatsCollectorprivate
FillSessionFlowInfo(const SessionFlowStatsInfo &session_flow, const SessionStatsInfo &sinfo, const SessionFlowExportInfo &einfo, SessionFlowInfo *flow_info) constSessionStatsCollectorprivate
FillSessionFlowStats(const SessionFlowStatsParams &stats, SessionFlowInfo *flow_info, bool is_sampling, bool is_logging) constSessionStatsCollectorprivate
FillSessionInfoLocked(SessionPreAggInfo::SessionMap::iterator session_map_iter, const SessionStatsParams &stats, SessionInfo *session_info, SessionIpPort *session_key, bool is_sampling, bool is_logging) constSessionStatsCollectorprivate
FillSessionInfoUnlocked(SessionPreAggInfo::SessionMap::iterator session_map_iter, const SessionStatsParams &stats, SessionInfo *session_info, SessionIpPort *session_key, const RevFlowDepParams *params, bool read_flow, bool is_sampling, bool is_logging) constSessionStatsCollectorprivate
FillSessionRemoteTags(const TagList &list, SessionEndpoint *ep) constSessionStatsCollectorprivate
FillSessionTags(const TagList &list, SessionEndpoint *ep) constSessionStatsCollectorprivate
FindSloMatchRule(const SessionSloRuleMap &map, const std::string &fw_policy_uuid, const std::string &nw_policy_uuid, const std::string &sg_policy_uuid, const bool &deleted_flag, bool *match, const bool &exported_once)SessionStatsCollectorprivate
flow_session_map_SessionStatsCollectorprivate
flow_stats_manager_SessionStatsCollectorprivate
FlowLogging(const SessionStatsInfo &stats_info, const FlowEntry *fe, bool *logged, const bool &exported_once)SessionStatsCollectorprivate
FlowSessionMap typedefSessionStatsCollector
FlowStatsCollector enum valueStatsCollector
FlowStatsManager classSessionStatsCollectorfriend
GetCurrentTime()SessionStatsCollectorprivatestatic
GetPolicyIdFromDeletedFlow(const SessionFlowExportInfo &flow_info, std::string &fw_policy_uuid, std::string &nw_policy_uuid, std::string &sg_policy_uuid)SessionStatsCollectorprivate
GetPolicyIdFromFlow(const FlowEntry *fe, std::string &fw_policy_uuid, std::string &nw_policy_uuid, std::string &sg_policy_uuid)SessionStatsCollectorprivate
GetSessionKey(FlowEntry *fe, SessionAggKey &session_agg_key, SessionKey &session_key, SessionEndpointKey &session_endpoint_key)SessionStatsCollectorprivate
GetSessionMsgIdx()SessionStatsCollectorprivate
GetUpdatedSessionFlowBytes(uint64_t info_bytes, uint64_t k_flow_bytes) constSessionStatsCollectorprivate
GetUpdatedSessionFlowPackets(uint64_t info_packets, uint64_t k_flow_pkts) constSessionStatsCollectorprivate
HandleDeletedFlowLogging(const SessionStatsInfo &stats_info)SessionStatsCollectorprivate
HandleFlowLogging(const SessionStatsInfo &stats_info)SessionStatsCollectorprivate
InitDone()StatsCollectorinline
instance_id() constSessionStatsCollectorinline
instance_id_SessionStatsCollectorprivate
IsSamplingEnabled() constSessionStatsCollectorprivate
kSessionsPerTaskSessionStatsCollectorstatic
kSessionStatsTimerIntervalSessionStatsCollectorstatic
MakeSloList(const FlowEntry *fe, SessionSloRuleMap *vmi_session_slo_rule_map, SessionSloRuleMap *vn_session_slo_rule_map)SessionStatsCollectorprivate
MatchSloForFlow(const SessionStatsInfo &stats_info, const FlowEntry *fe, const std::string &fw_policy_uuid, const std::string &nw_policy_uuid, const std::string &sg_policy_uuid, const bool &deleted_flag, bool *logged, const bool &exported_once)SessionStatsCollectorprivate
parent_SessionStatsCollectorprivate
ProcessSessionEndpoint(const SessionEndpointMap::iterator &it)SessionStatsCollectorprivate
Queue typedefSessionStatsCollector
queue() constSessionStatsCollectorinline
RegisterDBClients()SessionStatsCollectorprivate
request_queue_SessionStatsCollectorprivate
RequestHandler(boost::shared_ptr< SessionStatsReq > req)SessionStatsCollectorprivate
RequestHandlerEntry()SessionStatsCollectorprivate
RequestHandlerExit(bool done)SessionStatsCollectorprivate
RescheduleTimer(int time)StatsCollectorinline
RestartTimer()StatsCollectorinlineprivate
Run()SessionStatsCollectorvirtual
run_counter_StatsCollector
RunSessionEndpointStats(uint32_t max_count)SessionStatsCollector
SampleSession(SessionPreAggInfo::SessionMap::iterator session_map_iter, SessionStatsParams *params) constSessionStatsCollectorprivate
session_agg_iteration_key_SessionStatsCollectorprivate
session_endpoint_map_SessionStatsCollectorprivate
session_ep_iteration_key_SessionStatsCollectorprivate
session_ep_visited_SessionStatsCollectorprivate
session_iteration_key_SessionStatsCollectorprivate
session_msg_index_SessionStatsCollectorprivate
session_msg_list_SessionStatsCollectorprivate
session_task_SessionStatsCollectorprivate
session_task_starts_SessionStatsCollectorprivate
SessionEndpointMap typedefSessionStatsCollector
SessionSloRuleMap typedefSessionStatsCollector
SessionStatsChangedLocked(SessionPreAggInfo::SessionMap::iterator session_map_iter, SessionStatsParams *params) constSessionStatsCollectorprivate
SessionStatsChangedUnlocked(SessionPreAggInfo::SessionMap::iterator session_map_iter, SessionStatsParams *params) constSessionStatsCollectorprivate
SessionStatsCollector(boost::asio::io_context &io, AgentUveBase *uve, uint32_t instance_id, FlowStatsManager *fsm, SessionStatsCollectorObject *obj)SessionStatsCollector
SessionStatsCollectorObject classSessionStatsCollectorfriend
set_expiry_time(int time)StatsCollectorinline
Shutdown()SessionStatsCollectorprivate
Size() constSessionStatsCollectorinline
slo_listener_id_SessionStatsCollectorprivate
SloNotify(DBTablePartBase *partition, DBEntryBase *e)SessionStatsCollectorprivate
StatsCollector(int task_id, int32_t instance, boost::asio::io_service &io, int exp, std::string timer_name)StatsCollectorinline
StatsInstance enum nameStatsCollector
task_id() constSessionStatsCollectorinline
task_id_SessionStatsCollectorprivate
TestStartStopTimer(bool stop)StatsCollectorinline
threshold() constSessionStatsCollectorprivate
timer_StatsCollectorprivate
timer_restart_trigger_StatsCollectorprivate
TimerExpiry()StatsCollectorinlineprivate
UpdateAggregateStats(const SessionInfo &sinfo, SessionAggInfo *agg_info, bool is_sampling, bool is_logging) constSessionStatsCollectorprivate
UpdateSessionFlowStatsInfo(FlowEntry *fe, SessionFlowStatsInfo *session_flow) constSessionStatsCollectorprivate
UpdateSessionStatsEvent(const FlowEntryPtr &flow, uint32_t bytes, uint32_t packets, uint32_t oflow_bytes, const boost::uuids::uuid &u)SessionStatsCollectorprivate
UpdateSessionStatsInfo(FlowEntry *fe, uint64_t setup_time, SessionStatsInfo *session) constSessionStatsCollectorprivate
UpdateSloMatchRuleEntry(const boost::uuids::uuid &slo_uuid, const std::string &match_uuid, bool *match)SessionStatsCollectorprivate
UpdateSloStateRules(SecurityLoggingObject *slo, SessionSloState *state)SessionStatsCollectorprivate
~SessionStatsCollector()SessionStatsCollectorvirtual
~StatsCollector()StatsCollectorinlinevirtual