#include <bfd_proto.h>

Inheritance diagram for BfdProto:

Collaboration diagram for BfdProto:

[legend]

Classes
class	BfdCommunicator

struct	BfdStats

Public Member Functions
	BfdProto (Agent *agent, boost::asio::io_context &io)

virtual	~BfdProto ()

ProtoHandler *	AllocProtoHandler (boost::shared_ptr< PktInfo > info, boost::asio::io_context &io)

void	Shutdown ()

bool	Enqueue (boost::shared_ptr< PktInfo > msg)

void	ProcessStats (PktStatsType::Type type)

bool	ProcessBfdKeepAlive (boost::shared_ptr< PktInfo > msg)

void	HandleReceiveSafe (boost::asio::const_buffer pkt, const boost::asio::ip::udp::endpoint &local_endpoint, const boost::asio::ip::udp::endpoint &remote_endpoint, const BFD::SessionIndex &session_index, uint8_t pkt_len, boost::system::error_code ec)

bool	BfdHealthCheckSessionControl (HealthCheckTable::HealthCheckServiceAction action, HealthCheckInstanceService *service)

void	NotifyHealthCheckInstanceService (uint32_t interface, IpAddress address, std::string &data)

BfdCommunicator &	bfd_communicator ()

void	IncrementSent ()

void	IncrementReceived ()

void	IncrementReceiveDropCount ()

void	IncrementKaEnqueueCount ()

const BfdStats &	GetStats () const

uint32_t	ActiveSessions () const

Public Member Functions inherited from Proto
	Proto (Agent agent, const char task_name, PktHandler::PktModuleName mod, boost::asio::io_context &io)

virtual	~Proto ()

virtual bool	Validate (PktInfo *msg)

void	FreeBuffer (PktInfo *msg)

bool	ProcessProto (boost::shared_ptr< PktInfo > msg_info)

bool	RunProtoHandler (ProtoHandler *handler)

void	set_trace (bool val)

void	set_free_buffer (bool val)

boost::asio::io_context &	get_io_service () const

Agent *	agent () const

const ProtoWorkQueue *	work_queue () const

virtual void	TokenAvailable (TokenPool *pool)

Static Public Attributes
static const uint32_t	kMultiplier = 2

static const uint32_t	kMinRxInterval = 500000

static const uint32_t	kMinTxInterval = 500000

Private Types
typedef std::map< BfdSessionsKey, HealthCheckInstanceService *, BfdSessionsKeyCmp >	Sessions

typedef std::pair< BfdSessionsKey, HealthCheckInstanceService * >	SessionsPair

Private Member Functions
	DISALLOW_COPY_AND_ASSIGN (BfdProto)

Private Attributes
friend	BfdCommunicator

tbb::mutex	mutex_

tbb::mutex	rx_mutex_

boost::shared_ptr< PktInfo >	msg_

BfdCommunicator	communicator_

BFD::Server *	server_

BFD::Client *	client_

BfdHandler	handler_

Sessions	sessions_

BfdStats	stats_

Additional Inherited Members
Public Types inherited from Proto
typedef WorkQueue< boost::shared_ptr< PktInfo > >	ProtoWorkQueue

Protected Attributes inherited from Proto
Agent *	agent_

PktHandler::PktModuleName	module_

bool	trace_

bool	free_buffer_

boost::asio::io_context &	io_

ProtoWorkQueue	work_queue_

Detailed Description

Definition at line 56 of file bfd_proto.h.

Member Typedef Documentation

◆ Sessions

typedef std::map<BfdSessionsKey, HealthCheckInstanceService *, BfdSessionsKeyCmp> BfdProto::Sessions

private

Definition at line 136 of file bfd_proto.h.

◆ SessionsPair

typedef std::pair<BfdSessionsKey, HealthCheckInstanceService *> BfdProto::SessionsPair

private

Definition at line 137 of file bfd_proto.h.

Constructor & Destructor Documentation

◆ BfdProto()

BfdProto::BfdProto	(	Agent *	agent,
		boost::asio::io_context &	io
	)

Definition at line 20 of file bfd_proto.cc.

Here is the call graph for this function:

◆ ~BfdProto()

BfdProto::~BfdProto ( )

virtual

Definition at line 36 of file bfd_proto.cc.

Member Function Documentation

◆ ActiveSessions()

uint32_t BfdProto::ActiveSessions ( ) const

inline

Definition at line 131 of file bfd_proto.h.

◆ AllocProtoHandler()

ProtoHandler * BfdProto::AllocProtoHandler	(	boost::shared_ptr< PktInfo >	info,
		boost::asio::io_context &	io
	)

virtual

Implements Proto.

Definition at line 39 of file bfd_proto.cc.

Here is the call graph for this function:

◆ bfd_communicator()

BfdCommunicator& BfdProto::bfd_communicator ( )

inline

Definition at line 124 of file bfd_proto.h.

◆ BfdHealthCheckSessionControl()

bool BfdProto::BfdHealthCheckSessionControl	(	HealthCheckTable::HealthCheckServiceAction	action,
		HealthCheckInstanceService *	service
	)

Definition at line 61 of file bfd_proto.cc.

Here is the call graph for this function:

◆ DISALLOW_COPY_AND_ASSIGN()

BfdProto::DISALLOW_COPY_AND_ASSIGN ( BfdProto )

private

◆ Enqueue()

bool BfdProto::Enqueue ( boost::shared_ptr< PktInfo > msg )

virtual

Reimplemented from Proto.

Definition at line 238 of file bfd_proto.cc.

Here is the call graph for this function:

◆ GetStats()

const BfdStats& BfdProto::GetStats ( ) const

inline

Definition at line 130 of file bfd_proto.h.

◆ HandleReceiveSafe()

void BfdProto::HandleReceiveSafe	(	boost::asio::const_buffer	pkt,
		const boost::asio::ip::udp::endpoint &	local_endpoint,
		const boost::asio::ip::udp::endpoint &	remote_endpoint,
		const BFD::SessionIndex &	session_index,
		uint8_t	pkt_len,
		boost::system::error_code	ec
	)

Definition at line 204 of file bfd_proto.cc.

Here is the call graph for this function:

◆ IncrementKaEnqueueCount()

void BfdProto::IncrementKaEnqueueCount ( )

inline

Definition at line 129 of file bfd_proto.h.

◆ IncrementReceived()

void BfdProto::IncrementReceived ( )

inline

Definition at line 127 of file bfd_proto.h.

◆ IncrementReceiveDropCount()

void BfdProto::IncrementReceiveDropCount ( )

inline

Definition at line 128 of file bfd_proto.h.

◆ IncrementSent()

void BfdProto::IncrementSent ( )

inline

Definition at line 126 of file bfd_proto.h.

◆ NotifyHealthCheckInstanceService()

void BfdProto::NotifyHealthCheckInstanceService	(	uint32_t	interface,
		IpAddress	address,
		std::string &	data
	)

Definition at line 161 of file bfd_proto.cc.

◆ ProcessBfdKeepAlive()

bool BfdProto::ProcessBfdKeepAlive ( boost::shared_ptr< PktInfo > msg )

Definition at line 262 of file bfd_proto.cc.

Here is the call graph for this function:

◆ ProcessStats()

void BfdProto::ProcessStats ( PktStatsType::Type type )

virtual

Reimplemented from Proto.

Definition at line 249 of file bfd_proto.cc.

Here is the call graph for this function:

◆ Shutdown()

void BfdProto::Shutdown ( )

inline

Definition at line 96 of file bfd_proto.h.

Here is the call graph for this function:

Member Data Documentation

◆ BfdCommunicator

friend BfdProto::BfdCommunicator

private

Definition at line 134 of file bfd_proto.h.

◆ client_

BFD::Client* BfdProto::client_

private

Definition at line 144 of file bfd_proto.h.

◆ communicator_

BfdCommunicator BfdProto::communicator_

private

Definition at line 142 of file bfd_proto.h.

◆ handler_

BfdHandler BfdProto::handler_

private

Definition at line 145 of file bfd_proto.h.

◆ kMinRxInterval

const uint32_t BfdProto::kMinRxInterval = 500000

static

Definition at line 59 of file bfd_proto.h.

◆ kMinTxInterval

const uint32_t BfdProto::kMinTxInterval = 500000

static

Definition at line 60 of file bfd_proto.h.

◆ kMultiplier

const uint32_t BfdProto::kMultiplier = 2

static

Definition at line 58 of file bfd_proto.h.

◆ msg_

boost::shared_ptr<PktInfo> BfdProto::msg_

private

Definition at line 141 of file bfd_proto.h.

◆ mutex_

tbb::mutex BfdProto::mutex_

private

Definition at line 139 of file bfd_proto.h.

◆ rx_mutex_

tbb::mutex BfdProto::rx_mutex_

private

Definition at line 140 of file bfd_proto.h.

◆ server_

BFD::Server* BfdProto::server_

private

Definition at line 143 of file bfd_proto.h.

◆ sessions_

Sessions BfdProto::sessions_

private

Definition at line 146 of file bfd_proto.h.

◆ stats_

BfdStats BfdProto::stats_

private

Definition at line 147 of file bfd_proto.h.

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

Classes

Public Member Functions

Static Public Attributes

Private Types

Private Member Functions

Private Attributes

Additional Inherited Members

Detailed Description

Member Typedef Documentation

◆ Sessions

◆ SessionsPair

Constructor & Destructor Documentation

◆ BfdProto()

◆ ~BfdProto()

Member Function Documentation

◆ ActiveSessions()

◆ AllocProtoHandler()

◆ bfd_communicator()

◆ BfdHealthCheckSessionControl()

◆ DISALLOW_COPY_AND_ASSIGN()

◆ Enqueue()

◆ GetStats()

◆ HandleReceiveSafe()

◆ IncrementKaEnqueueCount()

◆ IncrementReceived()

◆ IncrementReceiveDropCount()

◆ IncrementSent()

◆ NotifyHealthCheckInstanceService()

◆ ProcessBfdKeepAlive()

◆ ProcessStats()

◆ Shutdown()

Member Data Documentation

◆ BfdCommunicator

◆ client_

◆ communicator_

◆ handler_

◆ kMinRxInterval

◆ kMinTxInterval

◆ kMultiplier

◆ msg_

◆ mutex_

◆ rx_mutex_

◆ server_

◆ sessions_

◆ stats_