#include <bgp_xmpp_channel.h>

Collaboration diagram for BgpXmppChannel:

[legend]

Classes
struct	ChannelStats

struct	ErrorStats

struct	InstanceMembershipRequestState

class	PeerStats

struct	Stats

struct	SubscriptionState

struct	TableMembershipRequestState

class	XmppPeer

Public Types
enum	StatsIndex { RX , TX }

Public Member Functions
	BgpXmppChannel (XmppChannel channel, BgpServer bgp_server=NULL, BgpXmppChannelManager *manager=NULL)

virtual	~BgpXmppChannel ()

void	Close ()

IPeer *	Peer ()

const IPeer *	Peer () const

virtual TcpSession::Endpoint	endpoint () const

const std::string &	ToString () const

const std::string &	ToUVEKey () const

std::string	StateName () const

TcpSession::Endpoint	remote_endpoint () const

TcpSession::Endpoint	local_endpoint () const

std::string	transport_address_string () const

void	set_peer_closed (bool flag)

bool	peer_deleted () const

uint64_t	peer_closed_at () const

bool	table_membership_request_map_empty () const

size_t	GetMembershipRequestQueueSize () const

const XmppSession *	GetSession () const

const Stats &	rx_stats () const

const Stats &	tx_stats () const

ErrorStats &	error_stats ()

const ErrorStats &	error_stats () const

void	set_deleted (bool deleted)

bool	deleted ()

void	RoutingInstanceCallback (std::string vrf_name, int op)

void	ASNUpdateCallback (as_t old_asn, as_t old_local_asn)

void	FillInstanceMembershipInfo (BgpNeighborResp *resp) const

void	FillTableMembershipInfo (BgpNeighborResp *resp) const

void	FillCloseInfo (BgpNeighborResp *resp) const

void	StaleCurrentSubscriptions ()

void	LlgrStaleCurrentSubscriptions ()

void	SweepCurrentSubscriptions ()

void	XMPPPeerInfoSend (const XmppPeerInfoData &peer_info) const

const XmppChannel *	channel () const

XmppChannel *	channel ()

void	StartEndOfRibReceiveTimer ()

void	ResetEndOfRibSendState ()

bool	EndOfRibSendTimerExpired ()

bool	MembershipResponseHandler (std::string table_name)

Timer *	eor_send_timer () const

bool	eor_sent () const

size_t	table_membership_requests () const

void	ClearEndOfRibState ()

PeerCloseManager *	close_manager ()

uint64_t	get_rx_route_reach () const

uint64_t	get_rx_route_unreach () const

uint64_t	get_rx_update () const

uint64_t	get_tx_route_reach () const

uint64_t	get_tx_route_unreach () const

uint64_t	get_tx_update () const

bool	SkipUpdateSend ()

bool	delete_in_progress () const

void	set_delete_in_progress (bool flag)

BgpXmppRTargetManager *	rtarget_manager ()

bool	IsSubscriptionGrStale (RoutingInstance *instance) const

bool	IsSubscriptionLlgrStale (RoutingInstance *instance) const

bool	IsSubscriptionEmpty () const

const RoutingInstance::RouteTargetList &	GetSubscribedRTargets (RoutingInstance *instance) const

void	ClearSubscriptions ()

BgpServer *	bgp_server ()

const BgpXmppChannelManager *	manager () const

BgpXmppChannelManager *	manager ()

XmppChannel *	xmpp_channel () const

void	ReceiveEndOfRIB (Address::Family family)

void	ProcessPendingSubscriptions ()

int	GetPrimaryInstanceID (const std::string &s, bool expect_prefix_len) const

Static Public Attributes
static const int	kEndOfRibSendRetryTime = 1

Protected Attributes
XmppChannel *	channel_

Private Types
enum	RequestType { NONE , SUBSCRIBE , UNSUBSCRIBE }

typedef std::map< RoutingInstance *, SubscriptionState >	SubscribedRoutingInstanceList

typedef std::map< std::string, TableMembershipRequestState >	TableMembershipRequestMap

typedef std::map< std::string, InstanceMembershipRequestState >	InstanceMembershipRequestMap

typedef std::pair< const std::string, const std::string >	VrfTableName

typedef std::multimap< VrfTableName, DBRequest * >	DeferQ

Private Member Functions
virtual void	ReceiveUpdate (const XmppStanza::XmppMessage *msg)

virtual bool	GetMembershipInfo (BgpTable table, int instance_id, uint64_t subscribed_at, RequestType req_type)

bool	VerifyMembership (const std::string &vrf_name, Address::Family family, BgpTable *table, int instance_id, uint64_t subscribed_at, bool subscribe_pending, bool add_change)

void	AddTableMembershipState (const std::string &table_name, TableMembershipRequestState tmr_state)

bool	DeleteTableMembershipState (const std::string &table_name)

TableMembershipRequestState *	GetTableMembershipState (const std::string &table_name)

const TableMembershipRequestState *	GetTableMembershipState (const std::string &table_name) const

void	AddInstanceMembershipState (const std::string &instance, InstanceMembershipRequestState imr_state)

bool	DeleteInstanceMembershipState (const std::string &instance)

virtual const InstanceMembershipRequestState *	GetInstanceMembershipState (const std::string &instance) const

bool	ProcessItem (std::string vrf_name, const pugi::xml_node &node, bool add_change, int primary_instance_id=0)

bool	ProcessInet6Item (std::string vrf_name, const pugi::xml_node &node, bool add_change)

bool	ProcessMcastItem (std::string vrf_name, const pugi::xml_node &item, bool add_change)

bool	ProcessMvpnItem (std::string vrf_name, const pugi::xml_node &item, bool add_change)

void	CreateType7MvpnRouteRequest (IpAddress grp_address, IpAddress src_address, bool add_change, uint64_t subscription_gen_id, DBRequest &req)

void	CreateType5MvpnRouteRequest (IpAddress grp_address, IpAddress src_address, bool add_change, uint64_t subscription_gen_id, int instance_id, DBRequest &req, const autogen::MvpnNextHopType &nh)

bool	ProcessEnetItem (std::string vrf_name, const pugi::xml_node &item, bool add_change)

void	ProcessSubscriptionRequest (std::string rt_instance, const XmppStanza::XmppMessageIq *iq, bool add_change)

void	AddSubscriptionState (RoutingInstance *rt_instance, int index)

void	DeleteSubscriptionState (RoutingInstance *rt_instance)

SubscriptionState *	GetSubscriptionState (RoutingInstance *rt_instance)

const SubscriptionState *	GetSubscriptionState (RoutingInstance *rt_instance) const

void	RegisterTable (int line, BgpTable table, const TableMembershipRequestState tmr_state)

void	UnregisterTable (int line, BgpTable *table)

void	MembershipRequestCallback (BgpTable *table)

void	DequeueRequest (const std::string &table_name, DBRequest *request)

bool	XmppDecodeAddress (int af, const std::string &address, IpAddress *addrp, bool zero_ok=false)

bool	ResumeClose ()

void	FlushDeferQ (std::string vrf_name)

void	FlushDeferQ (std::string vrf_name, std::string table_name)

void	ProcessDeferredSubscribeRequest (RoutingInstance *rt_instance, const InstanceMembershipRequestState &imr_state)

void	ClearStaledSubscription (RoutingInstance rt_instance, SubscriptionState sub_state)

bool	ProcessMembershipResponse (std::string table_name, TableMembershipRequestState *tmr_state)

bool	EndOfRibReceiveTimerExpired ()

void	EndOfRibTimerErrorHandler (std::string error_name, std::string error_message)

void	SendEndOfRIB ()

virtual time_t	GetEndOfRibSendTime () const

	DISALLOW_COPY_AND_ASSIGN (BgpXmppChannel)

Private Attributes
xmps::PeerId	peer_id_

boost::scoped_ptr< BgpXmppRTargetManager >	rtarget_manager_

BgpServer *	bgp_server_

boost::scoped_ptr< XmppPeer >	peer_

boost::scoped_ptr< BgpXmppPeerClose >	peer_close_

boost::scoped_ptr< PeerCloseManager >	close_manager_

boost::scoped_ptr< PeerStats >	peer_stats_

RibExportPolicy	bgp_policy_

DeferQ	defer_q_

TableMembershipRequestMap	table_membership_request_map_

InstanceMembershipRequestMap	instance_membership_request_map_

BgpXmppChannelManager *	manager_

bool	delete_in_progress_

bool	deleted_

bool	defer_peer_close_

bool	skip_update_send_

bool	skip_update_send_cached_

bool	eor_sent_

Timer *	eor_receive_timer_

Timer *	eor_send_timer_

time_t	eor_receive_timer_start_time_

time_t	eor_send_timer_start_time_

WorkQueue< std::string >	membership_response_worker_

SubscribedRoutingInstanceList	routing_instances_

Stats	stats_ [2]

ChannelStats	channel_stats_

ErrorStats	error_stats_

LabelBlockManagerPtr	lb_mgr_

Friends
class	BgpXmppChannelMock

class	BgpXmppChannelManager

class	BgpXmppParseTest

class	BgpXmppUnitTest

Detailed Description

Definition at line 48 of file bgp_xmpp_channel.h.

Member Typedef Documentation

◆ DeferQ

typedef std::multimap<VrfTableName, DBRequest *> BgpXmppChannel::DeferQ

private

Definition at line 274 of file bgp_xmpp_channel.h.

◆ InstanceMembershipRequestMap

typedef std::map<std::string, InstanceMembershipRequestState> BgpXmppChannel::InstanceMembershipRequestMap

private

Definition at line 269 of file bgp_xmpp_channel.h.

◆ SubscribedRoutingInstanceList

typedef std::map<RoutingInstance *, SubscriptionState> BgpXmppChannel::SubscribedRoutingInstanceList

private

Definition at line 258 of file bgp_xmpp_channel.h.

◆ TableMembershipRequestMap

typedef std::map<std::string, TableMembershipRequestState> BgpXmppChannel::TableMembershipRequestMap

private

Definition at line 262 of file bgp_xmpp_channel.h.

◆ VrfTableName

typedef std::pair<const std::string, const std::string> BgpXmppChannel::VrfTableName

private

Definition at line 273 of file bgp_xmpp_channel.h.

Member Enumeration Documentation

◆ RequestType

enum BgpXmppChannel::RequestType

private

Enumerator
NONE
SUBSCRIBE
UNSUBSCRIBE

Definition at line 212 of file bgp_xmpp_channel.h.

◆ StatsIndex

enum BgpXmppChannel::StatsIndex

Enumerator
RX
TX

Definition at line 51 of file bgp_xmpp_channel.h.

Constructor & Destructor Documentation

◆ BgpXmppChannel()

BgpXmppChannel::BgpXmppChannel	(	XmppChannel *	channel,
		BgpServer *	bgp_server = `NULL`,
		BgpXmppChannelManager *	manager = `NULL`
	)

explicit

Definition at line 486 of file bgp_xmpp_channel.cc.

Here is the call graph for this function:

◆ ~BgpXmppChannel()

BgpXmppChannel::~BgpXmppChannel ( )

virtual

Definition at line 534 of file bgp_xmpp_channel.cc.

Here is the call graph for this function:

Member Function Documentation

◆ AddInstanceMembershipState()

void BgpXmppChannel::AddInstanceMembershipState	(	const std::string &	instance,
		InstanceMembershipRequestState	imr_state
	)

private

Definition at line 707 of file bgp_xmpp_channel.cc.

◆ AddSubscriptionState()

void BgpXmppChannel::AddSubscriptionState	(	RoutingInstance *	rt_instance,
		int	index
	)

private

Definition at line 2555 of file bgp_xmpp_channel.cc.

Here is the call graph for this function:

◆ AddTableMembershipState()

void BgpXmppChannel::AddTableMembershipState	(	const std::string &	table_name,
		TableMembershipRequestState	tmr_state
	)

private

Definition at line 668 of file bgp_xmpp_channel.cc.

◆ ASNUpdateCallback()

void BgpXmppChannel::ASNUpdateCallback	(	as_t	old_asn,
		as_t	old_local_asn
	)

◆ bgp_server()

BgpServer* BgpXmppChannel::bgp_server ( )

inline

Definition at line 176 of file bgp_xmpp_channel.h.

◆ channel() [1/2]

XmppChannel* BgpXmppChannel::channel ( )

inline

Definition at line 145 of file bgp_xmpp_channel.h.

◆ channel() [2/2]

const XmppChannel* BgpXmppChannel::channel ( ) const

inline

Definition at line 144 of file bgp_xmpp_channel.h.

◆ ClearEndOfRibState()

void BgpXmppChannel::ClearEndOfRibState ( )

Definition at line 2796 of file bgp_xmpp_channel.cc.

Here is the call graph for this function:

◆ ClearStaledSubscription()

void BgpXmppChannel::ClearStaledSubscription	(	RoutingInstance *	rt_instance,
		SubscriptionState *	sub_state
	)

private

Definition at line 2542 of file bgp_xmpp_channel.cc.

Here is the call graph for this function:

◆ ClearSubscriptions()

void BgpXmppChannel::ClearSubscriptions ( )

inline

Definition at line 175 of file bgp_xmpp_channel.h.

◆ Close()

void BgpXmppChannel::Close ( )

Definition at line 3317 of file bgp_xmpp_channel.cc.

Here is the call graph for this function:

◆ close_manager()

PeerCloseManager* BgpXmppChannel::close_manager ( )

inline

Definition at line 154 of file bgp_xmpp_channel.h.

◆ CreateType5MvpnRouteRequest()

void BgpXmppChannel::CreateType5MvpnRouteRequest	(	IpAddress	grp_address,
		IpAddress	src_address,
		bool	add_change,
		uint64_t	subscription_gen_id,
		int	instance_id,
		DBRequest &	req,
		const autogen::MvpnNextHopType &	nh
	)

private

Definition at line 978 of file bgp_xmpp_channel.cc.

Here is the call graph for this function:

◆ CreateType7MvpnRouteRequest()

void BgpXmppChannel::CreateType7MvpnRouteRequest	(	IpAddress	grp_address,
		IpAddress	src_address,
		bool	add_change,
		uint64_t	subscription_gen_id,
		DBRequest &	req
	)

private

Definition at line 1012 of file bgp_xmpp_channel.cc.

Here is the call graph for this function:

◆ delete_in_progress()

bool BgpXmppChannel::delete_in_progress ( ) const

inline

Definition at line 164 of file bgp_xmpp_channel.h.

◆ deleted()

bool BgpXmppChannel::deleted ( )

inline

Definition at line 134 of file bgp_xmpp_channel.h.

◆ DeleteInstanceMembershipState()

bool BgpXmppChannel::DeleteInstanceMembershipState ( const std::string & instance )

private

Definition at line 716 of file bgp_xmpp_channel.cc.

◆ DeleteSubscriptionState()

void BgpXmppChannel::DeleteSubscriptionState ( RoutingInstance * rt_instance )

private

Definition at line 2571 of file bgp_xmpp_channel.cc.

◆ DeleteTableMembershipState()

bool BgpXmppChannel::DeleteTableMembershipState ( const std::string & table_name )

private

Definition at line 677 of file bgp_xmpp_channel.cc.

◆ DequeueRequest()

void BgpXmppChannel::DequeueRequest	(	const std::string &	table_name,
		DBRequest *	request
	)

private

Definition at line 2175 of file bgp_xmpp_channel.cc.

Here is the call graph for this function:

◆ DISALLOW_COPY_AND_ASSIGN()

BgpXmppChannel::DISALLOW_COPY_AND_ASSIGN ( BgpXmppChannel )

private

◆ EndOfRibReceiveTimerExpired()

bool BgpXmppChannel::EndOfRibReceiveTimerExpired ( )

private

Definition at line 2813 of file bgp_xmpp_channel.cc.

Here is the call graph for this function:

◆ EndOfRibSendTimerExpired()

bool BgpXmppChannel::EndOfRibSendTimerExpired ( )

Definition at line 2850 of file bgp_xmpp_channel.cc.

Here is the call graph for this function:

◆ EndOfRibTimerErrorHandler()

void BgpXmppChannel::EndOfRibTimerErrorHandler	(	std::string	error_name,
		std::string	error_message
	)

private

Definition at line 2807 of file bgp_xmpp_channel.cc.

Here is the call graph for this function:

◆ endpoint()

TcpSession::Endpoint BgpXmppChannel::endpoint ( ) const

virtual

Definition at line 626 of file bgp_xmpp_channel.cc.

Here is the call graph for this function:

◆ eor_send_timer()

Timer* BgpXmppChannel::eor_send_timer ( ) const

inline

Definition at line 150 of file bgp_xmpp_channel.h.

◆ eor_sent()

bool BgpXmppChannel::eor_sent ( ) const

inline

Definition at line 151 of file bgp_xmpp_channel.h.

◆ error_stats() [1/2]

ErrorStats& BgpXmppChannel::error_stats ( )

inline

Definition at line 131 of file bgp_xmpp_channel.h.

◆ error_stats() [2/2]

const ErrorStats& BgpXmppChannel::error_stats ( ) const

inline

Definition at line 132 of file bgp_xmpp_channel.h.

◆ FillCloseInfo()

void BgpXmppChannel::FillCloseInfo ( BgpNeighborResp * resp ) const

Definition at line 2399 of file bgp_xmpp_channel.cc.

◆ FillInstanceMembershipInfo()

void BgpXmppChannel::FillInstanceMembershipInfo ( BgpNeighborResp * resp ) const

Definition at line 2403 of file bgp_xmpp_channel.cc.

◆ FillTableMembershipInfo()

void BgpXmppChannel::FillTableMembershipInfo ( BgpNeighborResp * resp ) const

Definition at line 2432 of file bgp_xmpp_channel.cc.

Here is the call graph for this function:

◆ FlushDeferQ() [1/2]

void BgpXmppChannel::FlushDeferQ ( std::string vrf_name )

private

◆ FlushDeferQ() [2/2]

void BgpXmppChannel::FlushDeferQ	(	std::string	vrf_name,
		std::string	table_name
	)

private

◆ get_rx_route_reach()

uint64_t BgpXmppChannel::get_rx_route_reach ( ) const

inline

Definition at line 156 of file bgp_xmpp_channel.h.

◆ get_rx_route_unreach()

uint64_t BgpXmppChannel::get_rx_route_unreach ( ) const

inline

Definition at line 157 of file bgp_xmpp_channel.h.

◆ get_rx_update()

uint64_t BgpXmppChannel::get_rx_update ( ) const

inline

Definition at line 158 of file bgp_xmpp_channel.h.

◆ get_tx_route_reach()

uint64_t BgpXmppChannel::get_tx_route_reach ( ) const

inline

Definition at line 160 of file bgp_xmpp_channel.h.

◆ get_tx_route_unreach()

uint64_t BgpXmppChannel::get_tx_route_unreach ( ) const

inline

Definition at line 161 of file bgp_xmpp_channel.h.

◆ get_tx_update()

uint64_t BgpXmppChannel::get_tx_update ( ) const

inline

Definition at line 162 of file bgp_xmpp_channel.h.

◆ GetEndOfRibSendTime()

time_t BgpXmppChannel::GetEndOfRibSendTime ( ) const

privatevirtual

Definition at line 2844 of file bgp_xmpp_channel.cc.

Here is the call graph for this function:

◆ GetInstanceMembershipState()

const BgpXmppChannel::InstanceMembershipRequestState * BgpXmppChannel::GetInstanceMembershipState ( const std::string & instance ) const

privatevirtual

Definition at line 724 of file bgp_xmpp_channel.cc.

◆ GetMembershipInfo()

bool BgpXmppChannel::GetMembershipInfo	(	BgpTable *	table,
		int *	instance_id,
		uint64_t *	subscribed_at,
		RequestType *	req_type
	)

privatevirtual

Definition at line 646 of file bgp_xmpp_channel.cc.

Here is the call graph for this function:

◆ GetMembershipRequestQueueSize()

size_t BgpXmppChannel::GetMembershipRequestQueueSize ( ) const

Definition at line 585 of file bgp_xmpp_channel.cc.

◆ GetPrimaryInstanceID()

int BgpXmppChannel::GetPrimaryInstanceID	(	const std::string &	s,
		bool	expect_prefix_len
	)		const

Definition at line 2944 of file bgp_xmpp_channel.cc.

◆ GetSession()

const XmppSession * BgpXmppChannel::GetSession ( ) const

Definition at line 561 of file bgp_xmpp_channel.cc.

Here is the call graph for this function:

◆ GetSubscribedRTargets()

const RoutingInstance::RouteTargetList & BgpXmppChannel::GetSubscribedRTargets ( RoutingInstance * instance ) const

Definition at line 3401 of file bgp_xmpp_channel.cc.

◆ GetSubscriptionState() [1/2]

BgpXmppChannel::SubscriptionState * BgpXmppChannel::GetSubscriptionState ( RoutingInstance * rt_instance )

private

Definition at line 2575 of file bgp_xmpp_channel.cc.

◆ GetSubscriptionState() [2/2]

const BgpXmppChannel::SubscriptionState * BgpXmppChannel::GetSubscriptionState ( RoutingInstance * rt_instance ) const

private

Definition at line 2582 of file bgp_xmpp_channel.cc.

◆ GetTableMembershipState() [1/2]

TableMembershipRequestState* BgpXmppChannel::GetTableMembershipState ( const std::string & table_name )

private

◆ GetTableMembershipState() [2/2]

const TableMembershipRequestState* BgpXmppChannel::GetTableMembershipState ( const std::string & table_name ) const

private

◆ IsSubscriptionEmpty()

bool BgpXmppChannel::IsSubscriptionEmpty ( ) const

Definition at line 3397 of file bgp_xmpp_channel.cc.

◆ IsSubscriptionGrStale()

bool BgpXmppChannel::IsSubscriptionGrStale ( RoutingInstance * instance ) const

Definition at line 3383 of file bgp_xmpp_channel.cc.

◆ IsSubscriptionLlgrStale()

bool BgpXmppChannel::IsSubscriptionLlgrStale ( RoutingInstance * instance ) const

Definition at line 3390 of file bgp_xmpp_channel.cc.

◆ LlgrStaleCurrentSubscriptions()

void BgpXmppChannel::LlgrStaleCurrentSubscriptions ( )

Definition at line 2508 of file bgp_xmpp_channel.cc.

◆ local_endpoint()

TcpSession::Endpoint BgpXmppChannel::local_endpoint ( ) const

Definition at line 3344 of file bgp_xmpp_channel.cc.

Here is the call graph for this function:

◆ manager() [1/2]

BgpXmppChannelManager* BgpXmppChannel::manager ( )

inline

Definition at line 178 of file bgp_xmpp_channel.h.

◆ manager() [2/2]

const BgpXmppChannelManager* BgpXmppChannel::manager ( ) const

inline

Definition at line 177 of file bgp_xmpp_channel.h.

◆ MembershipRequestCallback()

void BgpXmppChannel::MembershipRequestCallback ( BgpTable * table )

private

Definition at line 2395 of file bgp_xmpp_channel.cc.

Here is the call graph for this function:

◆ MembershipResponseHandler()

bool BgpXmppChannel::MembershipResponseHandler ( std::string table_name )

Definition at line 2286 of file bgp_xmpp_channel.cc.

Here is the call graph for this function:

◆ Peer() [1/2]

IPeer * BgpXmppChannel::Peer ( )

Definition at line 618 of file bgp_xmpp_channel.cc.

◆ Peer() [2/2]

const IPeer * BgpXmppChannel::Peer ( ) const

Definition at line 622 of file bgp_xmpp_channel.cc.

◆ peer_closed_at()

uint64_t BgpXmppChannel::peer_closed_at ( ) const

Definition at line 3379 of file bgp_xmpp_channel.cc.

◆ peer_deleted()

bool BgpXmppChannel::peer_deleted ( ) const

Definition at line 3372 of file bgp_xmpp_channel.cc.

◆ ProcessDeferredSubscribeRequest()

void BgpXmppChannel::ProcessDeferredSubscribeRequest	(	RoutingInstance *	rt_instance,
		const InstanceMembershipRequestState &	imr_state
	)

private

Definition at line 2589 of file bgp_xmpp_channel.cc.

Here is the call graph for this function:

◆ ProcessEnetItem()

bool BgpXmppChannel::ProcessEnetItem	(	std::string	vrf_name,
		const pugi::xml_node &	item,
		bool	add_change
	)

private

Definition at line 1785 of file bgp_xmpp_channel.cc.

Here is the call graph for this function:

◆ ProcessInet6Item()

bool BgpXmppChannel::ProcessInet6Item	(	std::string	vrf_name,
		const pugi::xml_node &	node,
		bool	add_change
	)

private

Definition at line 1447 of file bgp_xmpp_channel.cc.

Here is the call graph for this function:

◆ ProcessItem()

bool BgpXmppChannel::ProcessItem	(	std::string	vrf_name,
		const pugi::xml_node &	node,
		bool	add_change,
		int	primary_instance_id = `0`
	)

private

Definition at line 1145 of file bgp_xmpp_channel.cc.

Here is the call graph for this function:

◆ ProcessMcastItem()

bool BgpXmppChannel::ProcessMcastItem	(	std::string	vrf_name,
		const pugi::xml_node &	item,
		bool	add_change
	)

private

Definition at line 790 of file bgp_xmpp_channel.cc.

Here is the call graph for this function:

◆ ProcessMembershipResponse()

bool BgpXmppChannel::ProcessMembershipResponse	(	std::string	table_name,
		TableMembershipRequestState *	tmr_state
	)

private

Definition at line 2338 of file bgp_xmpp_channel.cc.

Here is the call graph for this function:

◆ ProcessMvpnItem()

bool BgpXmppChannel::ProcessMvpnItem	(	std::string	vrf_name,
		const pugi::xml_node &	item,
		bool	add_change
	)

private

Definition at line 1042 of file bgp_xmpp_channel.cc.

Here is the call graph for this function:

◆ ProcessPendingSubscriptions()

void BgpXmppChannel::ProcessPendingSubscriptions ( )

Definition at line 2266 of file bgp_xmpp_channel.cc.

Here is the call graph for this function:

◆ ProcessSubscriptionRequest()

void BgpXmppChannel::ProcessSubscriptionRequest	(	std::string	rt_instance,
		const XmppStanza::XmppMessageIq *	iq,
		bool	add_change
	)

private

Definition at line 2608 of file bgp_xmpp_channel.cc.

Here is the call graph for this function:

◆ ReceiveEndOfRIB()

void BgpXmppChannel::ReceiveEndOfRIB ( Address::Family family )

Definition at line 2802 of file bgp_xmpp_channel.cc.

Here is the call graph for this function:

◆ ReceiveUpdate()

void BgpXmppChannel::ReceiveUpdate ( const XmppStanza::XmppMessage * msg )

privatevirtual

Definition at line 2973 of file bgp_xmpp_channel.cc.

Here is the call graph for this function:

◆ RegisterTable()

void BgpXmppChannel::RegisterTable	(	int	line,
		BgpTable *	table,
		const TableMembershipRequestState *	tmr_state
	)

private

Definition at line 2211 of file bgp_xmpp_channel.cc.

Here is the call graph for this function:

◆ remote_endpoint()

TcpSession::Endpoint BgpXmppChannel::remote_endpoint ( ) const

Definition at line 3333 of file bgp_xmpp_channel.cc.

Here is the call graph for this function:

◆ ResetEndOfRibSendState()

void BgpXmppChannel::ResetEndOfRibSendState ( )

Definition at line 2891 of file bgp_xmpp_channel.cc.

Here is the call graph for this function:

◆ ResumeClose()

bool BgpXmppChannel::ResumeClose ( )

private

Definition at line 2206 of file bgp_xmpp_channel.cc.

◆ RoutingInstanceCallback()

void BgpXmppChannel::RoutingInstanceCallback	(	std::string	vrf_name,
		int	op
	)

Definition at line 589 of file bgp_xmpp_channel.cc.

Here is the call graph for this function:

◆ rtarget_manager()

BgpXmppRTargetManager* BgpXmppChannel::rtarget_manager ( )

inline

Definition at line 167 of file bgp_xmpp_channel.h.

◆ rx_stats()

const Stats& BgpXmppChannel::rx_stats ( ) const

inline

Definition at line 129 of file bgp_xmpp_channel.h.

◆ SendEndOfRIB()

void BgpXmppChannel::SendEndOfRIB ( )

private

Definition at line 2918 of file bgp_xmpp_channel.cc.

Here is the call graph for this function:

◆ set_delete_in_progress()

void BgpXmppChannel::set_delete_in_progress ( bool flag )

inline

Definition at line 165 of file bgp_xmpp_channel.h.

◆ set_deleted()

void BgpXmppChannel::set_deleted ( bool deleted )

inline

Definition at line 133 of file bgp_xmpp_channel.h.

Here is the call graph for this function:

◆ set_peer_closed()

void BgpXmppChannel::set_peer_closed ( bool flag )

Definition at line 3365 of file bgp_xmpp_channel.cc.

◆ SkipUpdateSend()

bool BgpXmppChannel::SkipUpdateSend ( )

Definition at line 429 of file bgp_xmpp_channel.cc.

Here is the call graph for this function:

◆ StaleCurrentSubscriptions()

void BgpXmppChannel::StaleCurrentSubscriptions ( )

Definition at line 2497 of file bgp_xmpp_channel.cc.

◆ StartEndOfRibReceiveTimer()

void BgpXmppChannel::StartEndOfRibReceiveTimer ( )

Definition at line 2876 of file bgp_xmpp_channel.cc.

Here is the call graph for this function:

◆ StateName()

string BgpXmppChannel::StateName ( ) const

Definition at line 580 of file bgp_xmpp_channel.cc.

Here is the call graph for this function:

◆ SweepCurrentSubscriptions()

void BgpXmppChannel::SweepCurrentSubscriptions ( )

Definition at line 2520 of file bgp_xmpp_channel.cc.

Here is the call graph for this function:

◆ table_membership_request_map_empty()

bool BgpXmppChannel::table_membership_request_map_empty ( ) const

◆ table_membership_requests()

size_t BgpXmppChannel::table_membership_requests ( ) const

Definition at line 2282 of file bgp_xmpp_channel.cc.

◆ ToString()

const string & BgpXmppChannel::ToString ( ) const

Definition at line 568 of file bgp_xmpp_channel.cc.

Here is the call graph for this function:

◆ ToUVEKey()

const string & BgpXmppChannel::ToUVEKey ( ) const

Definition at line 572 of file bgp_xmpp_channel.cc.

Here is the call graph for this function:

◆ transport_address_string()

string BgpXmppChannel::transport_address_string ( ) const

Definition at line 3355 of file bgp_xmpp_channel.cc.

Here is the call graph for this function:

◆ tx_stats()

const Stats& BgpXmppChannel::tx_stats ( ) const

inline

Definition at line 130 of file bgp_xmpp_channel.h.

◆ UnregisterTable()

void BgpXmppChannel::UnregisterTable	(	int	line,
		BgpTable *	table
	)

private

Definition at line 2244 of file bgp_xmpp_channel.cc.

Here is the call graph for this function:

◆ VerifyMembership()

bool BgpXmppChannel::VerifyMembership	(	const std::string &	vrf_name,
		Address::Family	family,
		BgpTable **	table,
		int *	instance_id,
		uint64_t *	subscribed_at,
		bool *	subscribe_pending,
		bool	add_change
	)

private

Definition at line 739 of file bgp_xmpp_channel.cc.

Here is the call graph for this function:

◆ xmpp_channel()

XmppChannel* BgpXmppChannel::xmpp_channel ( ) const

inline

Definition at line 179 of file bgp_xmpp_channel.h.

◆ XmppDecodeAddress()

bool BgpXmppChannel::XmppDecodeAddress	(	int	af,
		const std::string &	address,
		IpAddress *	addrp,
		bool	zero_ok = `false`
	)

private

Definition at line 630 of file bgp_xmpp_channel.cc.

◆ XMPPPeerInfoSend()

void BgpXmppChannel::XMPPPeerInfoSend ( const XmppPeerInfoData & peer_info ) const

Definition at line 556 of file bgp_xmpp_channel.cc.

Friends And Related Function Documentation

◆ BgpXmppChannelManager

friend class BgpXmppChannelManager

friend

Definition at line 201 of file bgp_xmpp_channel.h.

◆ BgpXmppChannelMock

friend class BgpXmppChannelMock

friend

Definition at line 200 of file bgp_xmpp_channel.h.

◆ BgpXmppParseTest

friend class BgpXmppParseTest

friend

Definition at line 202 of file bgp_xmpp_channel.h.

◆ BgpXmppUnitTest

friend class BgpXmppUnitTest

friend

Definition at line 203 of file bgp_xmpp_channel.h.

Member Data Documentation

◆ bgp_policy_

RibExportPolicy BgpXmppChannel::bgp_policy_

private

Definition at line 352 of file bgp_xmpp_channel.h.

◆ bgp_server_

BgpServer* BgpXmppChannel::bgp_server_

private

Definition at line 347 of file bgp_xmpp_channel.h.

◆ channel_

XmppChannel* BgpXmppChannel::channel_

protected

Definition at line 197 of file bgp_xmpp_channel.h.

◆ channel_stats_

ChannelStats BgpXmppChannel::channel_stats_

private

Definition at line 375 of file bgp_xmpp_channel.h.

◆ close_manager_

boost::scoped_ptr<PeerCloseManager> BgpXmppChannel::close_manager_

private

Definition at line 350 of file bgp_xmpp_channel.h.

◆ defer_peer_close_

bool BgpXmppChannel::defer_peer_close_

private

Definition at line 362 of file bgp_xmpp_channel.h.

◆ defer_q_

DeferQ BgpXmppChannel::defer_q_

private

Definition at line 355 of file bgp_xmpp_channel.h.

◆ delete_in_progress_

bool BgpXmppChannel::delete_in_progress_

private

Definition at line 360 of file bgp_xmpp_channel.h.

◆ deleted_

bool BgpXmppChannel::deleted_

private

Definition at line 361 of file bgp_xmpp_channel.h.

◆ eor_receive_timer_

Timer* BgpXmppChannel::eor_receive_timer_

private

Definition at line 366 of file bgp_xmpp_channel.h.

◆ eor_receive_timer_start_time_

time_t BgpXmppChannel::eor_receive_timer_start_time_

private

Definition at line 368 of file bgp_xmpp_channel.h.

◆ eor_send_timer_

Timer* BgpXmppChannel::eor_send_timer_

private

Definition at line 367 of file bgp_xmpp_channel.h.

◆ eor_send_timer_start_time_

time_t BgpXmppChannel::eor_send_timer_start_time_

private

Definition at line 369 of file bgp_xmpp_channel.h.

◆ eor_sent_

bool BgpXmppChannel::eor_sent_

private

Definition at line 365 of file bgp_xmpp_channel.h.

◆ error_stats_

ErrorStats BgpXmppChannel::error_stats_

private

Definition at line 376 of file bgp_xmpp_channel.h.

◆ instance_membership_request_map_

InstanceMembershipRequestMap BgpXmppChannel::instance_membership_request_map_

private

Definition at line 358 of file bgp_xmpp_channel.h.

◆ kEndOfRibSendRetryTime

const int BgpXmppChannel::kEndOfRibSendRetryTime = 1

static

Definition at line 50 of file bgp_xmpp_channel.h.

◆ lb_mgr_

LabelBlockManagerPtr BgpXmppChannel::lb_mgr_

private

Definition at line 379 of file bgp_xmpp_channel.h.

◆ manager_

BgpXmppChannelManager* BgpXmppChannel::manager_

private

Definition at line 359 of file bgp_xmpp_channel.h.

◆ membership_response_worker_

WorkQueue<std::string> BgpXmppChannel::membership_response_worker_

private

Definition at line 370 of file bgp_xmpp_channel.h.

◆ peer_

boost::scoped_ptr<XmppPeer> BgpXmppChannel::peer_

private

Definition at line 348 of file bgp_xmpp_channel.h.

◆ peer_close_

boost::scoped_ptr<BgpXmppPeerClose> BgpXmppChannel::peer_close_

private

Definition at line 349 of file bgp_xmpp_channel.h.

◆ peer_id_

xmps::PeerId BgpXmppChannel::peer_id_

private

Definition at line 345 of file bgp_xmpp_channel.h.

◆ peer_stats_

boost::scoped_ptr<PeerStats> BgpXmppChannel::peer_stats_

private

Definition at line 351 of file bgp_xmpp_channel.h.

◆ routing_instances_

SubscribedRoutingInstanceList BgpXmppChannel::routing_instances_

private

Definition at line 371 of file bgp_xmpp_channel.h.

◆ rtarget_manager_

boost::scoped_ptr<BgpXmppRTargetManager> BgpXmppChannel::rtarget_manager_

private

Definition at line 346 of file bgp_xmpp_channel.h.

◆ skip_update_send_

bool BgpXmppChannel::skip_update_send_

private

Definition at line 363 of file bgp_xmpp_channel.h.

◆ skip_update_send_cached_

bool BgpXmppChannel::skip_update_send_cached_

private

Definition at line 364 of file bgp_xmpp_channel.h.

◆ stats_

Stats BgpXmppChannel::stats_[2]

private

Definition at line 374 of file bgp_xmpp_channel.h.

◆ table_membership_request_map_

TableMembershipRequestMap BgpXmppChannel::table_membership_request_map_

private

Definition at line 357 of file bgp_xmpp_channel.h.

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

Classes

Public Types

Public Member Functions

Static Public Attributes

Protected Attributes

Private Types

Private Member Functions

Private Attributes

Friends

Detailed Description

Member Typedef Documentation

◆ DeferQ

◆ InstanceMembershipRequestMap

◆ SubscribedRoutingInstanceList

◆ TableMembershipRequestMap

◆ VrfTableName

Member Enumeration Documentation

◆ RequestType

◆ StatsIndex

Constructor & Destructor Documentation

◆ BgpXmppChannel()

◆ ~BgpXmppChannel()

Member Function Documentation

◆ AddInstanceMembershipState()

◆ AddSubscriptionState()

◆ AddTableMembershipState()

◆ ASNUpdateCallback()

◆ bgp_server()

◆ channel() [1/2]

◆ channel() [2/2]

◆ ClearEndOfRibState()

◆ ClearStaledSubscription()

◆ ClearSubscriptions()

◆ Close()

◆ close_manager()

◆ CreateType5MvpnRouteRequest()

◆ CreateType7MvpnRouteRequest()

◆ delete_in_progress()

◆ deleted()

◆ DeleteInstanceMembershipState()

◆ DeleteSubscriptionState()

◆ DeleteTableMembershipState()

◆ DequeueRequest()

◆ DISALLOW_COPY_AND_ASSIGN()

◆ EndOfRibReceiveTimerExpired()

◆ EndOfRibSendTimerExpired()

◆ EndOfRibTimerErrorHandler()

◆ endpoint()

◆ eor_send_timer()

◆ eor_sent()

◆ error_stats() [1/2]

◆ error_stats() [2/2]

◆ FillCloseInfo()

◆ FillInstanceMembershipInfo()

◆ FillTableMembershipInfo()

◆ FlushDeferQ() [1/2]

◆ FlushDeferQ() [2/2]

◆ get_rx_route_reach()

◆ get_rx_route_unreach()

◆ get_rx_update()

◆ get_tx_route_reach()

◆ get_tx_route_unreach()

◆ get_tx_update()

◆ GetEndOfRibSendTime()

◆ GetInstanceMembershipState()

◆ GetMembershipInfo()

◆ GetMembershipRequestQueueSize()

◆ GetPrimaryInstanceID()

◆ GetSession()

◆ GetSubscribedRTargets()

◆ GetSubscriptionState() [1/2]

◆ GetSubscriptionState() [2/2]

◆ GetTableMembershipState() [1/2]

◆ GetTableMembershipState() [2/2]

◆ IsSubscriptionEmpty()

◆ IsSubscriptionGrStale()

◆ IsSubscriptionLlgrStale()

◆ LlgrStaleCurrentSubscriptions()

◆ local_endpoint()

◆ manager() [1/2]