#include <session_stats_collector.h>

Inheritance diagram for SessionStatsCollector:

Collaboration diagram for SessionStatsCollector:

[legend]

Classes
class	SessionTask

Public Types
typedef std::map< const SessionEndpointKey, SessionEndpointInfo, SessionEndpointKeyCmp >	SessionEndpointMap

typedef WorkQueue< boost::shared_ptr< SessionStatsReq > >	Queue

typedef std::map< FlowEntryPtr, FlowToSessionMap >	FlowSessionMap

typedef std::map< std::string, SessionSloRuleEntry >	SessionSloRuleMap

Public Types inherited from StatsCollector
enum	StatsInstance { FlowStatsCollector , AgentStatsCollector }

Public Member Functions
uint32_t	RunSessionEndpointStats (uint32_t max_count)

	SessionStatsCollector (boost::asio::io_context &io, AgentUveBase uve, uint32_t instance_id, FlowStatsManager fsm, SessionStatsCollectorObject *obj)

virtual	~SessionStatsCollector ()

bool	Run ()

int	task_id () const

uint32_t	instance_id () const

const Queue *	queue () const

size_t	Size () const

Public Member Functions inherited from StatsCollector
	StatsCollector (int task_id, int32_t instance, boost::asio::io_service &io, int exp, std::string timer_name)

virtual	~StatsCollector ()

void	InitDone ()

void	Shutdown ()

void	TestStartStopTimer (bool stop)

int	expiry_time () const

void	set_expiry_time (int time)

void	RescheduleTimer (int time)

Static Public Attributes
static const uint32_t	kSessionStatsTimerInterval = 1000

static const uint32_t	kSessionsPerTask = 256

Protected Member Functions
virtual void	DispatchSessionMsg (const std::vector< SessionEndpoint > &lst)

Private Member Functions
int	ComputeSloRate (int rate, SecurityLoggingObject *slo) const

bool	FetchFlowStats (SessionFlowStatsInfo info, SessionFlowStatsParams params) const

uint64_t	threshold () const

bool	IsSamplingEnabled () const

bool	SampleSession (SessionPreAggInfo::SessionMap::iterator session_map_iter, SessionStatsParams *params) const

bool	SessionStatsChangedLocked (SessionPreAggInfo::SessionMap::iterator session_map_iter, SessionStatsParams *params) const

bool	SessionStatsChangedUnlocked (SessionPreAggInfo::SessionMap::iterator session_map_iter, SessionStatsParams *params) const

bool	ProcessSessionEndpoint (const SessionEndpointMap::iterator &it)

uint64_t	GetUpdatedSessionFlowBytes (uint64_t info_bytes, uint64_t k_flow_bytes) const

uint64_t	GetUpdatedSessionFlowPackets (uint64_t info_packets, uint64_t k_flow_pkts) const

void	FillSessionEvictStats (SessionPreAggInfo::SessionMap::iterator session_map_iter, SessionInfo *session_info, bool is_sampling, bool is_logging) const

void	FillSessionFlowStats (const SessionFlowStatsParams &stats, SessionFlowInfo *flow_info, bool is_sampling, bool is_logging) const

void	FillSessionFlowInfo (const SessionFlowStatsInfo &session_flow, const SessionStatsInfo &sinfo, const SessionFlowExportInfo &einfo, SessionFlowInfo *flow_info) const

void	CopyFlowInfoInternal (SessionFlowExportInfo info, const boost::uuids::uuid &u, FlowEntry fe) const

void	CopyFlowInfo (SessionStatsInfo &session, const RevFlowDepParams *params)

void	UpdateAggregateStats (const SessionInfo &sinfo, SessionAggInfo *agg_info, bool is_sampling, bool is_logging) const

void	FillSessionInfoLocked (SessionPreAggInfo::SessionMap::iterator session_map_iter, const SessionStatsParams &stats, SessionInfo session_info, SessionIpPort session_key, bool is_sampling, bool is_logging) const

void	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) const

void	FillSessionAggInfo (SessionEndpointInfo::SessionAggMap::iterator it, SessionIpPortProtocol *session_agg_key) const

void	FillSessionEndpoint (SessionEndpointMap::iterator it, SessionEndpoint *session_ep) const

void	FillSessionTags (const TagList &list, SessionEndpoint *ep) const

void	FillSessionRemoteTags (const TagList &list, SessionEndpoint *ep) const

void	UpdateSessionFlowStatsInfo (FlowEntry fe, SessionFlowStatsInfo session_flow) const

void	UpdateSessionStatsInfo (FlowEntry fe, uint64_t setup_time, SessionStatsInfo session) const

void	AddSession (FlowEntry *fe, uint64_t setup_time)

void	DeleteSession (FlowEntry fe, const boost::uuids::uuid &del_uuid, uint64_t teardown_time, const RevFlowDepParams params)

void	EvictedSessionStatsUpdate (const FlowEntryPtr &flow, uint32_t bytes, uint32_t packets, uint32_t oflow_bytes, const boost::uuids::uuid &u)

bool	GetSessionKey (FlowEntry *fe, SessionAggKey &session_agg_key, SessionKey &session_key, SessionEndpointKey &session_endpoint_key)

void	AddFlowToSessionMap (FlowEntry *fe, SessionKey session_key, SessionAggKey session_agg_key, SessionEndpointKey session_endpoint_key)

void	DeleteFlowToSessionMap (FlowEntry *fe)

void	Shutdown ()

void	RegisterDBClients ()

void	AddEvent (const FlowEntryPtr &flow)

void	DeleteEvent (const FlowEntryPtr &flow, const RevFlowDepParams &params)

void	UpdateSessionStatsEvent (const FlowEntryPtr &flow, uint32_t bytes, uint32_t packets, uint32_t oflow_bytes, const boost::uuids::uuid &u)

bool	RequestHandlerEntry ()

void	RequestHandlerExit (bool done)

bool	RequestHandler (boost::shared_ptr< SessionStatsReq > req)

void	EnqueueSessionMsg ()

void	DispatchPendingSessionMsg ()

uint8_t	GetSessionMsgIdx ()

bool	UpdateSloMatchRuleEntry (const boost::uuids::uuid &slo_uuid, const std::string &match_uuid, bool *match)

bool	CheckPolicyMatch (const SessionSloRuleMap &map, const std::string &policy_uuid, const bool &deleted_flag, bool *match, const bool &exported_once)

bool	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)

void	GetPolicyIdFromFlow (const FlowEntry *fe, std::string &fw_policy_uuid, std::string &nw_policy_uuid, std::string &sg_policy_uuid)

void	GetPolicyIdFromDeletedFlow (const SessionFlowExportInfo &flow_info, std::string &fw_policy_uuid, std::string &nw_policy_uuid, std::string &sg_policy_uuid)

bool	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)

void	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)

void	MakeSloList (const FlowEntry fe, SessionSloRuleMap vmi_session_slo_rule_map, SessionSloRuleMap *vn_session_slo_rule_map)

bool	FlowLogging (const SessionStatsInfo &stats_info, const FlowEntry fe, bool logged, const bool &exported_once)

bool	DeletedFlowLogging (const SessionStatsInfo &stats_info, const SessionFlowExportInfo &flow_info, bool *logged, const bool &exported_once)

bool	HandleDeletedFlowLogging (const SessionStatsInfo &stats_info)

bool	HandleFlowLogging (const SessionStatsInfo &stats_info)

bool	CheckSessionLogging (const SessionStatsInfo &stats_info)

void	AddSloList (const UuidList &slo_list, SessionSloRuleMap *slo_rule_map)

void	AddSloEntry (const boost::uuids::uuid &uuid, SessionSloRuleMap *slo_rule_map)

void	AddSloEntryRules (SecurityLoggingObject slo, SessionSloRuleMap slo_rule_map)

void	AddSloFirewallPolicies (SecurityLoggingObject slo, SessionSloRuleMap r_map)

void	AddSloFirewallRules (SecurityLoggingObject slo, SessionSloRuleMap rule_map)

void	AddSloRules (const std::vector< autogen::SecurityLoggingObjectRuleEntryType > &list, SecurityLoggingObject slo, SessionSloRuleMap slo_rule_map)

void	AddSessionSloRuleEntry (const std::string &uuid, int rate, SecurityLoggingObject slo, SessionSloRuleMap slo_rule_map)

void	SloNotify (DBTablePartBase partition, DBEntryBase e)

void	UpdateSloStateRules (SecurityLoggingObject slo, SessionSloState state)

bool	CheckAndDeleteSessionStatsFlow (SessionPreAggInfo::SessionMap::iterator session_map_iter)

	DISALLOW_COPY_AND_ASSIGN (SessionStatsCollector)

Static Private Member Functions
static uint64_t	GetCurrentTime ()

Private Attributes
AgentUveBase *	agent_uve_

int	task_id_

SessionEndpointKey	session_ep_iteration_key_

SessionAggKey	session_agg_iteration_key_

SessionKey	session_iteration_key_

SessionEndpointMap	session_endpoint_map_

FlowSessionMap	flow_session_map_

Queue	request_queue_

std::vector< SessionEndpoint >	session_msg_list_

uint8_t	session_msg_index_

uint32_t	instance_id_

FlowStatsManager *	flow_stats_manager_

SessionStatsCollectorObject *	parent_

SessionTask *	session_task_

uint64_t	current_time_

uint64_t	session_task_starts_

uint32_t	session_ep_visited_

DBTable::ListenerId	slo_listener_id_

Friends
class	FlowStatsManager

class	SessionStatsCollectorObject

Additional Inherited Members
Public Attributes inherited from StatsCollector
int	run_counter_

Detailed Description

Definition at line 166 of file session_stats_collector.h.

Member Typedef Documentation

◆ FlowSessionMap

typedef std::map<FlowEntryPtr, FlowToSessionMap> SessionStatsCollector::FlowSessionMap

Definition at line 171 of file session_stats_collector.h.

◆ Queue

typedef WorkQueue<boost::shared_ptr<SessionStatsReq> > SessionStatsCollector::Queue

Definition at line 170 of file session_stats_collector.h.

◆ SessionEndpointMap

typedef std::map<const SessionEndpointKey, SessionEndpointInfo, SessionEndpointKeyCmp> SessionStatsCollector::SessionEndpointMap

Definition at line 169 of file session_stats_collector.h.

◆ SessionSloRuleMap

typedef std::map<std::string, SessionSloRuleEntry> SessionStatsCollector::SessionSloRuleMap

Definition at line 172 of file session_stats_collector.h.

Constructor & Destructor Documentation

◆ SessionStatsCollector()

SessionStatsCollector::SessionStatsCollector	(	boost::asio::io_context &	io,
		AgentUveBase *	uve,
		uint32_t	instance_id,
		FlowStatsManager *	fsm,
		SessionStatsCollectorObject *	obj
	)

Definition at line 29 of file session_stats_collector.cc.

Here is the call graph for this function:

◆ ~SessionStatsCollector()

SessionStatsCollector::~SessionStatsCollector ( )

virtual

Definition at line 65 of file session_stats_collector.cc.

Here is the call graph for this function:

Member Function Documentation

◆ AddEvent()

void SessionStatsCollector::AddEvent ( const FlowEntryPtr & flow )

private

Definition at line 186 of file session_stats_collector.cc.

Here is the call graph for this function:

◆ AddFlowToSessionMap()

void SessionStatsCollector::AddFlowToSessionMap	(	FlowEntry *	fe,
		SessionKey	session_key,
		SessionAggKey	session_agg_key,
		SessionEndpointKey	session_endpoint_key
	)

private

Definition at line 813 of file session_stats_collector.cc.

Here is the call graph for this function:

◆ AddSession()

void SessionStatsCollector::AddSession	(	FlowEntry *	fe,
		uint64_t	setup_time
	)

private

Definition at line 558 of file session_stats_collector.cc.

Here is the call graph for this function:

◆ AddSessionSloRuleEntry()

void SessionStatsCollector::AddSessionSloRuleEntry	(	const std::string &	uuid,
		int	rate,
		SecurityLoggingObject *	slo,
		SessionSloRuleMap *	slo_rule_map
	)

private

Definition at line 904 of file session_stats_collector.cc.

Here is the call graph for this function:

◆ AddSloEntry()

void SessionStatsCollector::AddSloEntry	(	const boost::uuids::uuid &	uuid,
		SessionSloRuleMap *	slo_rule_map
	)

private

Definition at line 966 of file session_stats_collector.cc.

Here is the call graph for this function:

◆ AddSloEntryRules()

void SessionStatsCollector::AddSloEntryRules	(	SecurityLoggingObject *	slo,
		SessionSloRuleMap *	slo_rule_map
	)

private

Definition at line 959 of file session_stats_collector.cc.

Here is the call graph for this function:

◆ AddSloFirewallPolicies()

void SessionStatsCollector::AddSloFirewallPolicies	(	SecurityLoggingObject *	slo,
		SessionSloRuleMap *	r_map
	)

private

Definition at line 926 of file session_stats_collector.cc.

Here is the call graph for this function:

◆ AddSloFirewallRules()

void SessionStatsCollector::AddSloFirewallRules	(	SecurityLoggingObject *	slo,
		SessionSloRuleMap *	rule_map
	)

private

Definition at line 948 of file session_stats_collector.cc.

Here is the call graph for this function:

◆ AddSloList()

void SessionStatsCollector::AddSloList	(	const UuidList &	slo_list,
		SessionSloRuleMap *	slo_rule_map
	)

private

Definition at line 978 of file session_stats_collector.cc.

Here is the call graph for this function:

◆ AddSloRules()

void SessionStatsCollector::AddSloRules	(	const std::vector< autogen::SecurityLoggingObjectRuleEntryType > &	list,
		SecurityLoggingObject *	slo,
		SessionSloRuleMap *	slo_rule_map
	)

private

Definition at line 914 of file session_stats_collector.cc.

Here is the call graph for this function:

◆ BuildSloList()

void SessionStatsCollector::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
	)

private

Definition at line 1008 of file session_stats_collector.cc.

Here is the call graph for this function:

◆ CheckAndDeleteSessionStatsFlow()

bool SessionStatsCollector::CheckAndDeleteSessionStatsFlow ( SessionPreAggInfo::SessionMap::iterator session_map_iter )

private

Definition at line 1467 of file session_stats_collector.cc.

Here is the call graph for this function:

◆ CheckPolicyMatch()

bool SessionStatsCollector::CheckPolicyMatch	(	const SessionSloRuleMap &	map,
		const std::string &	policy_uuid,
		const bool &	deleted_flag,
		bool *	match,
		const bool &	exported_once
	)

private

Definition at line 1053 of file session_stats_collector.cc.

Here is the call graph for this function:

◆ CheckSessionLogging()

bool SessionStatsCollector::CheckSessionLogging ( const SessionStatsInfo & stats_info )

private

Definition at line 1293 of file session_stats_collector.cc.

Here is the call graph for this function:

◆ ComputeSloRate()

int SessionStatsCollector::ComputeSloRate	(	int	rate,
		SecurityLoggingObject *	slo
	)		const

private

Definition at line 835 of file session_stats_collector.cc.

Here is the call graph for this function:

◆ CopyFlowInfo()

void SessionStatsCollector::CopyFlowInfo	(	SessionStatsInfo &	session,
		const RevFlowDepParams *	params
	)

private

Definition at line 1360 of file session_stats_collector.cc.

Here is the call graph for this function:

◆ CopyFlowInfoInternal()

void SessionStatsCollector::CopyFlowInfoInternal	(	SessionFlowExportInfo *	info,
		const boost::uuids::uuid &	u,
		FlowEntry *	fe
	)		const

private

Definition at line 1344 of file session_stats_collector.cc.

Here is the call graph for this function:

◆ DeletedFlowLogging()

bool SessionStatsCollector::DeletedFlowLogging	(	const SessionStatsInfo &	stats_info,
		const SessionFlowExportInfo &	flow_info,
		bool *	logged,
		const bool &	exported_once
	)

private

Definition at line 1217 of file session_stats_collector.cc.

Here is the call graph for this function:

◆ DeleteEvent()

void SessionStatsCollector::DeleteEvent	(	const FlowEntryPtr &	flow,
		const RevFlowDepParams &	params
	)

private

Definition at line 193 of file session_stats_collector.cc.

Here is the call graph for this function:

◆ DeleteFlowToSessionMap()

void SessionStatsCollector::DeleteFlowToSessionMap ( FlowEntry * fe )

private

Definition at line 827 of file session_stats_collector.cc.

◆ DeleteSession()

void SessionStatsCollector::DeleteSession	(	FlowEntry *	fe,
		const boost::uuids::uuid &	del_uuid,
		uint64_t	teardown_time,
		const RevFlowDepParams *	params
	)

private

Definition at line 652 of file session_stats_collector.cc.

Here is the call graph for this function:

◆ DISALLOW_COPY_AND_ASSIGN()

SessionStatsCollector::DISALLOW_COPY_AND_ASSIGN ( SessionStatsCollector )

private

◆ DispatchPendingSessionMsg()

void SessionStatsCollector::DispatchPendingSessionMsg ( )

private

Definition at line 227 of file session_stats_collector.cc.

Here is the call graph for this function:

◆ DispatchSessionMsg()

void SessionStatsCollector::DispatchSessionMsg ( const std::vector< SessionEndpoint > & lst )

protectedvirtual

Definition at line 212 of file session_stats_collector.cc.

Here is the call graph for this function:

◆ EnqueueSessionMsg()

void SessionStatsCollector::EnqueueSessionMsg ( )

private

Definition at line 218 of file session_stats_collector.cc.

Here is the call graph for this function:

◆ EvictedSessionStatsUpdate()

void SessionStatsCollector::EvictedSessionStatsUpdate	(	const FlowEntryPtr &	flow,
		uint32_t	bytes,
		uint32_t	packets,
		uint32_t	oflow_bytes,
		const boost::uuids::uuid &	u
	)

private

Definition at line 743 of file session_stats_collector.cc.

Here is the call graph for this function:

◆ FetchFlowStats()

bool SessionStatsCollector::FetchFlowStats	(	SessionFlowStatsInfo *	info,
		SessionFlowStatsParams *	params
	)		const

private

Definition at line 1500 of file session_stats_collector.cc.

Here is the call graph for this function:

◆ FillSessionAggInfo()

void SessionStatsCollector::FillSessionAggInfo	(	SessionEndpointInfo::SessionAggMap::iterator	it,
		SessionIpPortProtocol *	session_agg_key
	)		const

private

Definition at line 1700 of file session_stats_collector.cc.

◆ FillSessionEndpoint()

void SessionStatsCollector::FillSessionEndpoint	(	SessionEndpointMap::iterator	it,
		SessionEndpoint *	session_ep
	)		const

private

Definition at line 1759 of file session_stats_collector.cc.

Here is the call graph for this function:

◆ FillSessionEvictStats()

void SessionStatsCollector::FillSessionEvictStats	(	SessionPreAggInfo::SessionMap::iterator	session_map_iter,
		SessionInfo *	session_info,
		bool	is_sampling,
		bool	is_logging
	)		const

private

Definition at line 1568 of file session_stats_collector.cc.

◆ FillSessionFlowInfo()

void SessionStatsCollector::FillSessionFlowInfo	(	const SessionFlowStatsInfo &	session_flow,
		const SessionStatsInfo &	sinfo,
		const SessionFlowExportInfo &	einfo,
		SessionFlowInfo *	flow_info
	)		const

private

Definition at line 1425 of file session_stats_collector.cc.

Here is the call graph for this function:

◆ FillSessionFlowStats()

void SessionStatsCollector::FillSessionFlowStats	(	const SessionFlowStatsParams &	stats,
		SessionFlowInfo *	flow_info,
		bool	is_sampling,
		bool	is_logging
	)		const

private

Definition at line 1407 of file session_stats_collector.cc.

◆ FillSessionInfoLocked()

void SessionStatsCollector::FillSessionInfoLocked	(	SessionPreAggInfo::SessionMap::iterator	session_map_iter,
		const SessionStatsParams &	stats,
		SessionInfo *	session_info,
		SessionIpPort *	session_key,
		bool	is_sampling,
		bool	is_logging
	)		const

private

Definition at line 1557 of file session_stats_collector.cc.

Here is the call graph for this function:

◆ FillSessionInfoUnlocked()

void SessionStatsCollector::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
	)		const

private

Definition at line 1595 of file session_stats_collector.cc.

Here is the call graph for this function:

◆ FillSessionRemoteTags()

void SessionStatsCollector::FillSessionRemoteTags	(	const TagList &	list,
		SessionEndpoint *	ep
	)		const

private

Definition at line 1735 of file session_stats_collector.cc.

Here is the call graph for this function:

◆ FillSessionTags()

void SessionStatsCollector::FillSessionTags	(	const TagList &	list,
		SessionEndpoint *	ep
	)		const

private

Definition at line 1711 of file session_stats_collector.cc.

Here is the call graph for this function:

◆ FindSloMatchRule()

bool SessionStatsCollector::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
	)

private

Definition at line 1077 of file session_stats_collector.cc.

Here is the call graph for this function:

◆ FlowLogging()

bool SessionStatsCollector::FlowLogging	(	const SessionStatsInfo &	stats_info,
		const FlowEntry *	fe,
		bool *	logged,
		const bool &	exported_once
	)

private

Definition at line 1191 of file session_stats_collector.cc.

Here is the call graph for this function:

◆ GetCurrentTime()

uint64_t SessionStatsCollector::GetCurrentTime ( )

staticprivate

Definition at line 69 of file session_stats_collector.cc.

Here is the call graph for this function:

◆ GetPolicyIdFromDeletedFlow()

void SessionStatsCollector::GetPolicyIdFromDeletedFlow	(	const SessionFlowExportInfo &	flow_info,
		std::string &	fw_policy_uuid,
		std::string &	nw_policy_uuid,
		std::string &	sg_policy_uuid
	)

private

Definition at line 1169 of file session_stats_collector.cc.

◆ GetPolicyIdFromFlow()

void SessionStatsCollector::GetPolicyIdFromFlow	(	const FlowEntry *	fe,
		std::string &	fw_policy_uuid,
		std::string &	nw_policy_uuid,
		std::string &	sg_policy_uuid
	)

private

Definition at line 1180 of file session_stats_collector.cc.

Here is the call graph for this function:

◆ GetSessionKey()

bool SessionStatsCollector::GetSessionKey	(	FlowEntry *	fe,
		SessionAggKey &	session_agg_key,
		SessionKey &	session_key,
		SessionEndpointKey &	session_endpoint_key
	)

private

Definition at line 412 of file session_stats_collector.cc.

Here is the call graph for this function:

◆ GetSessionMsgIdx()

uint8_t SessionStatsCollector::GetSessionMsgIdx ( )

private

Definition at line 240 of file session_stats_collector.cc.

◆ GetUpdatedSessionFlowBytes()

uint64_t SessionStatsCollector::GetUpdatedSessionFlowBytes	(	uint64_t	info_bytes,
		uint64_t	k_flow_bytes
	)		const

private

Definition at line 1323 of file session_stats_collector.cc.

◆ GetUpdatedSessionFlowPackets()

uint64_t SessionStatsCollector::GetUpdatedSessionFlowPackets	(	uint64_t	info_packets,
		uint64_t	k_flow_pkts
	)		const

private

Definition at line 1333 of file session_stats_collector.cc.

◆ HandleDeletedFlowLogging()

bool SessionStatsCollector::HandleDeletedFlowLogging ( const SessionStatsInfo & stats_info )

private

Definition at line 1243 of file session_stats_collector.cc.

Here is the call graph for this function:

◆ HandleFlowLogging()

bool SessionStatsCollector::HandleFlowLogging ( const SessionStatsInfo & stats_info )

private

Definition at line 1267 of file session_stats_collector.cc.

Here is the call graph for this function:

◆ instance_id()

uint32_t SessionStatsCollector::instance_id ( ) const

inline

Definition at line 197 of file session_stats_collector.h.

◆ IsSamplingEnabled()

bool SessionStatsCollector::IsSamplingEnabled ( ) const

private

Definition at line 1995 of file session_stats_collector.cc.

Here is the call graph for this function:

◆ MakeSloList()

void SessionStatsCollector::MakeSloList	(	const FlowEntry *	fe,
		SessionSloRuleMap *	vmi_session_slo_rule_map,
		SessionSloRuleMap *	vn_session_slo_rule_map
	)

private

Definition at line 987 of file session_stats_collector.cc.

Here is the call graph for this function:

◆ MatchSloForFlow()

bool SessionStatsCollector::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
	)

private

Definition at line 1107 of file session_stats_collector.cc.

Here is the call graph for this function:

◆ ProcessSessionEndpoint()

bool SessionStatsCollector::ProcessSessionEndpoint ( const SessionEndpointMap::iterator & it )

private

Definition at line 1783 of file session_stats_collector.cc.

Here is the call graph for this function:

◆ queue()

const Queue* SessionStatsCollector::queue ( ) const

inline

Definition at line 198 of file session_stats_collector.h.

◆ RegisterDBClients()

void SessionStatsCollector::RegisterDBClients ( )

private

Definition at line 78 of file session_stats_collector.cc.

Here is the call graph for this function:

◆ RequestHandler()

bool SessionStatsCollector::RequestHandler ( boost::shared_ptr< SessionStatsReq > req )

private

Definition at line 254 of file session_stats_collector.cc.

Here is the call graph for this function:

◆ RequestHandlerEntry()

bool SessionStatsCollector::RequestHandlerEntry ( )

private

Definition at line 246 of file session_stats_collector.cc.

Here is the call graph for this function:

◆ RequestHandlerExit()

void SessionStatsCollector::RequestHandlerExit ( bool done )

private

Definition at line 251 of file session_stats_collector.cc.

◆ Run()

bool SessionStatsCollector::Run ( void )

virtual

Implements StatsCollector.

Definition at line 86 of file session_stats_collector.cc.

Here is the call graph for this function:

◆ RunSessionEndpointStats()

uint32_t SessionStatsCollector::RunSessionEndpointStats ( uint32_t max_count )

Definition at line 1924 of file session_stats_collector.cc.

Here is the call graph for this function:

◆ SampleSession()

bool SessionStatsCollector::SampleSession	(	SessionPreAggInfo::SessionMap::iterator	session_map_iter,
		SessionStatsParams *	params
	)		const

private

Definition at line 2004 of file session_stats_collector.cc.

Here is the call graph for this function:

◆ SessionStatsChangedLocked()

bool SessionStatsCollector::SessionStatsChangedLocked	(	SessionPreAggInfo::SessionMap::iterator	session_map_iter,
		SessionStatsParams *	params
	)		const

private

Definition at line 1480 of file session_stats_collector.cc.

Here is the call graph for this function:

◆ SessionStatsChangedUnlocked()

bool SessionStatsCollector::SessionStatsChangedUnlocked	(	SessionPreAggInfo::SessionMap::iterator	session_map_iter,
		SessionStatsParams *	params
	)		const

private

Definition at line 1489 of file session_stats_collector.cc.

Here is the call graph for this function:

◆ Shutdown()

void SessionStatsCollector::Shutdown ( void )

private

Definition at line 73 of file session_stats_collector.cc.

Here is the call graph for this function:

◆ Size()

size_t SessionStatsCollector::Size ( ) const

inline

Definition at line 199 of file session_stats_collector.h.

◆ SloNotify()

void SessionStatsCollector::SloNotify	(	DBTablePartBase *	partition,
		DBEntryBase *	e
	)

private

Definition at line 883 of file session_stats_collector.cc.

Here is the call graph for this function:

◆ task_id()

int SessionStatsCollector::task_id ( ) const

inline

Definition at line 196 of file session_stats_collector.h.

◆ threshold()

uint64_t SessionStatsCollector::threshold ( ) const

private

Definition at line 2087 of file session_stats_collector.cc.

Here is the call graph for this function:

◆ UpdateAggregateStats()

void SessionStatsCollector::UpdateAggregateStats	(	const SessionInfo &	sinfo,
		SessionAggInfo *	agg_info,
		bool	is_sampling,
		bool	is_logging
	)		const

private

Definition at line 1674 of file session_stats_collector.cc.

◆ UpdateSessionFlowStatsInfo()

void SessionStatsCollector::UpdateSessionFlowStatsInfo	(	FlowEntry *	fe,
		SessionFlowStatsInfo *	session_flow
	)		const

private

Definition at line 507 of file session_stats_collector.cc.

Here is the call graph for this function:

◆ UpdateSessionStatsEvent()

void SessionStatsCollector::UpdateSessionStatsEvent	(	const FlowEntryPtr &	flow,
		uint32_t	bytes,
		uint32_t	packets,
		uint32_t	oflow_bytes,
		const boost::uuids::uuid &	u
	)

private

Definition at line 201 of file session_stats_collector.cc.

Here is the call graph for this function:

◆ UpdateSessionStatsInfo()

void SessionStatsCollector::UpdateSessionStatsInfo	(	FlowEntry *	fe,
		uint64_t	setup_time,
		SessionStatsInfo *	session
	)		const

private

Definition at line 517 of file session_stats_collector.cc.

Here is the call graph for this function:

◆ UpdateSloMatchRuleEntry()

bool SessionStatsCollector::UpdateSloMatchRuleEntry	(	const boost::uuids::uuid &	slo_uuid,
		const std::string &	match_uuid,
		bool *	match
	)

private

Definition at line 1034 of file session_stats_collector.cc.

Here is the call graph for this function:

◆ UpdateSloStateRules()

void SessionStatsCollector::UpdateSloStateRules	(	SecurityLoggingObject *	slo,
		SessionSloState *	state
	)

private

Definition at line 845 of file session_stats_collector.cc.

Here is the call graph for this function:

Friends And Related Function Documentation

◆ FlowStatsManager

friend class FlowStatsManager

friend

Definition at line 200 of file session_stats_collector.h.

◆ SessionStatsCollectorObject

friend class SessionStatsCollectorObject

friend

Definition at line 201 of file session_stats_collector.h.

Member Data Documentation

◆ agent_uve_

AgentUveBase* SessionStatsCollector::agent_uve_

private

Definition at line 380 of file session_stats_collector.h.

◆ current_time_

uint64_t SessionStatsCollector::current_time_

private

Definition at line 397 of file session_stats_collector.h.

◆ flow_session_map_

FlowSessionMap SessionStatsCollector::flow_session_map_

private

Definition at line 386 of file session_stats_collector.h.

◆ flow_stats_manager_

FlowStatsManager* SessionStatsCollector::flow_stats_manager_

private

Definition at line 391 of file session_stats_collector.h.

◆ instance_id_

uint32_t SessionStatsCollector::instance_id_

private

Definition at line 390 of file session_stats_collector.h.

◆ kSessionsPerTask

const uint32_t SessionStatsCollector::kSessionsPerTask = 256

static

Definition at line 175 of file session_stats_collector.h.

◆ kSessionStatsTimerInterval

const uint32_t SessionStatsCollector::kSessionStatsTimerInterval = 1000

static

Definition at line 174 of file session_stats_collector.h.

◆ parent_

SessionStatsCollectorObject* SessionStatsCollector::parent_

private

Definition at line 392 of file session_stats_collector.h.

◆ request_queue_

Queue SessionStatsCollector::request_queue_

private

Definition at line 387 of file session_stats_collector.h.

◆ session_agg_iteration_key_

SessionAggKey SessionStatsCollector::session_agg_iteration_key_

private

Definition at line 383 of file session_stats_collector.h.

◆ session_endpoint_map_

SessionEndpointMap SessionStatsCollector::session_endpoint_map_

private

Definition at line 385 of file session_stats_collector.h.

◆ session_ep_iteration_key_

SessionEndpointKey SessionStatsCollector::session_ep_iteration_key_

private

Definition at line 382 of file session_stats_collector.h.

◆ session_ep_visited_

uint32_t SessionStatsCollector::session_ep_visited_

private

Definition at line 399 of file session_stats_collector.h.

◆ session_iteration_key_

SessionKey SessionStatsCollector::session_iteration_key_

private

Definition at line 384 of file session_stats_collector.h.

◆ session_msg_index_

uint8_t SessionStatsCollector::session_msg_index_

private

Definition at line 389 of file session_stats_collector.h.

◆ session_msg_list_

std::vector<SessionEndpoint> SessionStatsCollector::session_msg_list_

private

Definition at line 388 of file session_stats_collector.h.

◆ session_task_

SessionTask* SessionStatsCollector::session_task_

private

Definition at line 393 of file session_stats_collector.h.

◆ session_task_starts_

uint64_t SessionStatsCollector::session_task_starts_

private

Definition at line 398 of file session_stats_collector.h.

◆ slo_listener_id_

DBTable::ListenerId SessionStatsCollector::slo_listener_id_

private

Definition at line 400 of file session_stats_collector.h.

◆ task_id_

int SessionStatsCollector::task_id_

private

Definition at line 381 of file session_stats_collector.h.

The documentation for this class was generated from the following files:

Classes

Public Types

Public Member Functions

Static Public Attributes

Protected Member Functions

Private Member Functions

Static Private Member Functions

Private Attributes

Friends

Additional Inherited Members

Detailed Description

Member Typedef Documentation

◆ FlowSessionMap

◆ Queue

◆ SessionEndpointMap

◆ SessionSloRuleMap

Constructor & Destructor Documentation

◆ SessionStatsCollector()

◆ ~SessionStatsCollector()

Member Function Documentation

◆ AddEvent()

◆ AddFlowToSessionMap()

◆ AddSession()

◆ AddSessionSloRuleEntry()

◆ AddSloEntry()

◆ AddSloEntryRules()

◆ AddSloFirewallPolicies()

◆ AddSloFirewallRules()

◆ AddSloList()

◆ AddSloRules()

◆ BuildSloList()

◆ CheckAndDeleteSessionStatsFlow()

◆ CheckPolicyMatch()

◆ CheckSessionLogging()

◆ ComputeSloRate()

◆ CopyFlowInfo()

◆ CopyFlowInfoInternal()

◆ DeletedFlowLogging()

◆ DeleteEvent()

◆ DeleteFlowToSessionMap()

◆ DeleteSession()

◆ DISALLOW_COPY_AND_ASSIGN()

◆ DispatchPendingSessionMsg()

◆ DispatchSessionMsg()

◆ EnqueueSessionMsg()

◆ EvictedSessionStatsUpdate()

◆ FetchFlowStats()

◆ FillSessionAggInfo()

◆ FillSessionEndpoint()

◆ FillSessionEvictStats()

◆ FillSessionFlowInfo()

◆ FillSessionFlowStats()

◆ FillSessionInfoLocked()

◆ FillSessionInfoUnlocked()

◆ FillSessionRemoteTags()

◆ FillSessionTags()

◆ FindSloMatchRule()

◆ FlowLogging()

◆ GetCurrentTime()

◆ GetPolicyIdFromDeletedFlow()

◆ GetPolicyIdFromFlow()

◆ GetSessionKey()

◆ GetSessionMsgIdx()

◆ GetUpdatedSessionFlowBytes()

◆ GetUpdatedSessionFlowPackets()

◆ HandleDeletedFlowLogging()

◆ HandleFlowLogging()

◆ instance_id()

◆ IsSamplingEnabled()

◆ MakeSloList()

◆ MatchSloForFlow()

◆ ProcessSessionEndpoint()

◆ queue()

◆ RegisterDBClients()

◆ RequestHandler()

◆ RequestHandlerEntry()

◆ RequestHandlerExit()

◆ Run()

◆ RunSessionEndpointStats()

◆ SampleSession()