#include <bgp_xmpp_channel.h>

Collaboration diagram for BgpXmppChannel:

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

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

private

Definition at line 274 of file bgp_xmpp_channel.h.

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

private

Definition at line 269 of file bgp_xmpp_channel.h.

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

private

Definition at line 258 of file bgp_xmpp_channel.h.

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

private

Definition at line 262 of file bgp_xmpp_channel.h.

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

enum BgpXmppChannel::RequestType

private

Enumerator
NONE
SUBSCRIBE
UNSUBSCRIBE

Definition at line 212 of file bgp_xmpp_channel.h.

enum BgpXmppChannel::StatsIndex

Enumerator
RX
TX

Definition at line 51 of file bgp_xmpp_channel.h.

Constructor & Destructor Documentation

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

explicit

Definition at line 485 of file bgp_xmpp_channel.cc.

Here is the call graph for this function:

BgpXmppChannel::~BgpXmppChannel ( )

virtual

Definition at line 533 of file bgp_xmpp_channel.cc.

Here is the call graph for this function:

Member Function Documentation

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

private

Definition at line 706 of file bgp_xmpp_channel.cc.

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

private

Definition at line 2521 of file bgp_xmpp_channel.cc.

Here is the call graph for this function:

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

private

Definition at line 667 of file bgp_xmpp_channel.cc.

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

BgpServer* BgpXmppChannel::bgp_server ( )

inline

Definition at line 176 of file bgp_xmpp_channel.h.

const XmppChannel* BgpXmppChannel::channel ( ) const

inline

Definition at line 144 of file bgp_xmpp_channel.h.

XmppChannel* BgpXmppChannel::channel ( )

inline

Definition at line 145 of file bgp_xmpp_channel.h.

void BgpXmppChannel::ClearEndOfRibState ( )

Definition at line 2762 of file bgp_xmpp_channel.cc.

Here is the call graph for this function:

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

private

Definition at line 2508 of file bgp_xmpp_channel.cc.

Here is the call graph for this function:

void BgpXmppChannel::ClearSubscriptions ( )

inline

Definition at line 175 of file bgp_xmpp_channel.h.

void BgpXmppChannel::Close ( )

Definition at line 3283 of file bgp_xmpp_channel.cc.

Here is the call graph for this function:

PeerCloseManager* BgpXmppChannel::close_manager ( )

inline

Definition at line 154 of file bgp_xmpp_channel.h.

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 977 of file bgp_xmpp_channel.cc.

Here is the call graph for this function:

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

private

Definition at line 1011 of file bgp_xmpp_channel.cc.

Here is the call graph for this function:

bool BgpXmppChannel::delete_in_progress ( ) const

inline

Definition at line 164 of file bgp_xmpp_channel.h.

bool BgpXmppChannel::deleted ( )

inline

Definition at line 134 of file bgp_xmpp_channel.h.

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

private

Definition at line 715 of file bgp_xmpp_channel.cc.

void BgpXmppChannel::DeleteSubscriptionState ( RoutingInstance * rt_instance )

private

Definition at line 2537 of file bgp_xmpp_channel.cc.

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

private

Definition at line 676 of file bgp_xmpp_channel.cc.

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

private

Definition at line 2141 of file bgp_xmpp_channel.cc.

Here is the call graph for this function:

BgpXmppChannel::DISALLOW_COPY_AND_ASSIGN ( BgpXmppChannel )

private

bool BgpXmppChannel::EndOfRibReceiveTimerExpired ( )

private

Definition at line 2779 of file bgp_xmpp_channel.cc.

Here is the call graph for this function:

bool BgpXmppChannel::EndOfRibSendTimerExpired ( )

Definition at line 2816 of file bgp_xmpp_channel.cc.

Here is the call graph for this function:

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

private

Definition at line 2773 of file bgp_xmpp_channel.cc.

Here is the call graph for this function:

TcpSession::Endpoint BgpXmppChannel::endpoint ( ) const

virtual

Definition at line 625 of file bgp_xmpp_channel.cc.

Here is the call graph for this function:

Timer* BgpXmppChannel::eor_send_timer ( ) const

inline

Definition at line 150 of file bgp_xmpp_channel.h.

bool BgpXmppChannel::eor_sent ( ) const

inline

Definition at line 151 of file bgp_xmpp_channel.h.

ErrorStats& BgpXmppChannel::error_stats ( )

inline

Definition at line 131 of file bgp_xmpp_channel.h.

const ErrorStats& BgpXmppChannel::error_stats ( ) const

inline

Definition at line 132 of file bgp_xmpp_channel.h.

void BgpXmppChannel::FillCloseInfo ( BgpNeighborResp * resp ) const

Definition at line 2365 of file bgp_xmpp_channel.cc.

void BgpXmppChannel::FillInstanceMembershipInfo ( BgpNeighborResp * resp ) const

Definition at line 2369 of file bgp_xmpp_channel.cc.

void BgpXmppChannel::FillTableMembershipInfo ( BgpNeighborResp * resp ) const

Definition at line 2398 of file bgp_xmpp_channel.cc.

Here is the call graph for this function:

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

private

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

private

uint64_t BgpXmppChannel::get_rx_route_reach ( ) const

inline

Definition at line 156 of file bgp_xmpp_channel.h.

uint64_t BgpXmppChannel::get_rx_route_unreach ( ) const

inline

Definition at line 157 of file bgp_xmpp_channel.h.

uint64_t BgpXmppChannel::get_rx_update ( ) const

inline

Definition at line 158 of file bgp_xmpp_channel.h.

uint64_t BgpXmppChannel::get_tx_route_reach ( ) const

inline

Definition at line 160 of file bgp_xmpp_channel.h.

uint64_t BgpXmppChannel::get_tx_route_unreach ( ) const

inline

Definition at line 161 of file bgp_xmpp_channel.h.

uint64_t BgpXmppChannel::get_tx_update ( ) const

inline

Definition at line 162 of file bgp_xmpp_channel.h.

time_t BgpXmppChannel::GetEndOfRibSendTime ( ) const

privatevirtual

Definition at line 2810 of file bgp_xmpp_channel.cc.

Here is the call graph for this function:

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

privatevirtual

Definition at line 723 of file bgp_xmpp_channel.cc.

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

privatevirtual

Definition at line 645 of file bgp_xmpp_channel.cc.

Here is the call graph for this function:

size_t BgpXmppChannel::GetMembershipRequestQueueSize ( ) const

Definition at line 584 of file bgp_xmpp_channel.cc.

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

Definition at line 2910 of file bgp_xmpp_channel.cc.

const XmppSession * BgpXmppChannel::GetSession ( ) const

Definition at line 560 of file bgp_xmpp_channel.cc.

Here is the call graph for this function:

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

Definition at line 3367 of file bgp_xmpp_channel.cc.

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

private

Definition at line 2541 of file bgp_xmpp_channel.cc.

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

private

Definition at line 2548 of file bgp_xmpp_channel.cc.

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

private

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

private

bool BgpXmppChannel::IsSubscriptionEmpty ( ) const

Definition at line 3363 of file bgp_xmpp_channel.cc.

bool BgpXmppChannel::IsSubscriptionGrStale ( RoutingInstance * instance ) const

Definition at line 3349 of file bgp_xmpp_channel.cc.

bool BgpXmppChannel::IsSubscriptionLlgrStale ( RoutingInstance * instance ) const

Definition at line 3356 of file bgp_xmpp_channel.cc.

void BgpXmppChannel::LlgrStaleCurrentSubscriptions ( )

Definition at line 2474 of file bgp_xmpp_channel.cc.

TcpSession::Endpoint BgpXmppChannel::local_endpoint ( ) const

Definition at line 3310 of file bgp_xmpp_channel.cc.

Here is the call graph for this function:

const BgpXmppChannelManager* BgpXmppChannel::manager ( ) const

inline

Definition at line 177 of file bgp_xmpp_channel.h.

BgpXmppChannelManager* BgpXmppChannel::manager ( )

inline

Definition at line 178 of file bgp_xmpp_channel.h.

void BgpXmppChannel::MembershipRequestCallback ( BgpTable * table )

private

Definition at line 2361 of file bgp_xmpp_channel.cc.

Here is the call graph for this function:

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

Definition at line 2252 of file bgp_xmpp_channel.cc.

Here is the call graph for this function:

IPeer * BgpXmppChannel::Peer ( )

Definition at line 617 of file bgp_xmpp_channel.cc.

const IPeer * BgpXmppChannel::Peer ( ) const

Definition at line 621 of file bgp_xmpp_channel.cc.

uint64_t BgpXmppChannel::peer_closed_at ( ) const

Definition at line 3345 of file bgp_xmpp_channel.cc.

bool BgpXmppChannel::peer_deleted ( ) const

Definition at line 3338 of file bgp_xmpp_channel.cc.

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

private

Definition at line 2555 of file bgp_xmpp_channel.cc.

Here is the call graph for this function:

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

private

Definition at line 1762 of file bgp_xmpp_channel.cc.

Here is the call graph for this function:

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

private

Definition at line 1435 of file bgp_xmpp_channel.cc.

Here is the call graph for this function:

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

private

Definition at line 1144 of file bgp_xmpp_channel.cc.

Here is the call graph for this function:

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

private

Definition at line 789 of file bgp_xmpp_channel.cc.

Here is the call graph for this function:

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

private

Definition at line 2304 of file bgp_xmpp_channel.cc.

Here is the call graph for this function:

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

private

Definition at line 1041 of file bgp_xmpp_channel.cc.

Here is the call graph for this function:

void BgpXmppChannel::ProcessPendingSubscriptions ( )

Definition at line 2232 of file bgp_xmpp_channel.cc.

Here is the call graph for this function:

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

private

Definition at line 2574 of file bgp_xmpp_channel.cc.

Here is the call graph for this function:

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

Definition at line 2768 of file bgp_xmpp_channel.cc.

Here is the call graph for this function:

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

privatevirtual

Definition at line 2939 of file bgp_xmpp_channel.cc.

Here is the call graph for this function:

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

private

Definition at line 2177 of file bgp_xmpp_channel.cc.

Here is the call graph for this function:

TcpSession::Endpoint BgpXmppChannel::remote_endpoint ( ) const

Definition at line 3299 of file bgp_xmpp_channel.cc.

Here is the call graph for this function:

void BgpXmppChannel::ResetEndOfRibSendState ( )

Definition at line 2857 of file bgp_xmpp_channel.cc.

Here is the call graph for this function:

bool BgpXmppChannel::ResumeClose ( )

private

Definition at line 2172 of file bgp_xmpp_channel.cc.

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

Definition at line 588 of file bgp_xmpp_channel.cc.

Here is the call graph for this function:

BgpXmppRTargetManager* BgpXmppChannel::rtarget_manager ( )

inline

Definition at line 167 of file bgp_xmpp_channel.h.

const Stats& BgpXmppChannel::rx_stats ( ) const

inline

Definition at line 129 of file bgp_xmpp_channel.h.

void BgpXmppChannel::SendEndOfRIB ( )

private

Definition at line 2884 of file bgp_xmpp_channel.cc.

Here is the call graph for this function:

void BgpXmppChannel::set_delete_in_progress ( bool flag )

inline

Definition at line 165 of file bgp_xmpp_channel.h.

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:

void BgpXmppChannel::set_peer_closed ( bool flag )

Definition at line 3331 of file bgp_xmpp_channel.cc.

bool BgpXmppChannel::SkipUpdateSend ( )

Definition at line 428 of file bgp_xmpp_channel.cc.

Here is the call graph for this function:

void BgpXmppChannel::StaleCurrentSubscriptions ( )

Definition at line 2463 of file bgp_xmpp_channel.cc.

void BgpXmppChannel::StartEndOfRibReceiveTimer ( )

Definition at line 2842 of file bgp_xmpp_channel.cc.

Here is the call graph for this function:

string BgpXmppChannel::StateName ( ) const

Definition at line 579 of file bgp_xmpp_channel.cc.

Here is the call graph for this function:

void BgpXmppChannel::SweepCurrentSubscriptions ( )

Definition at line 2486 of file bgp_xmpp_channel.cc.

Here is the call graph for this function:

bool BgpXmppChannel::table_membership_request_map_empty ( ) const

size_t BgpXmppChannel::table_membership_requests ( ) const

Definition at line 2248 of file bgp_xmpp_channel.cc.

const string & BgpXmppChannel::ToString ( ) const

Definition at line 567 of file bgp_xmpp_channel.cc.

Here is the call graph for this function:

const string & BgpXmppChannel::ToUVEKey ( ) const

Definition at line 571 of file bgp_xmpp_channel.cc.

Here is the call graph for this function:

string BgpXmppChannel::transport_address_string ( ) const

Definition at line 3321 of file bgp_xmpp_channel.cc.

Here is the call graph for this function:

const Stats& BgpXmppChannel::tx_stats ( ) const

inline

Definition at line 130 of file bgp_xmpp_channel.h.

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

private

Definition at line 2210 of file bgp_xmpp_channel.cc.

Here is the call graph for this function:

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 738 of file bgp_xmpp_channel.cc.

Here is the call graph for this function:

XmppChannel* BgpXmppChannel::xmpp_channel ( ) const

inline

Definition at line 179 of file bgp_xmpp_channel.h.

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

private

Definition at line 629 of file bgp_xmpp_channel.cc.

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

Definition at line 555 of file bgp_xmpp_channel.cc.

Friends And Related Function Documentation

friend class BgpXmppChannelManager

friend

Definition at line 201 of file bgp_xmpp_channel.h.

friend class BgpXmppChannelMock

friend

Definition at line 200 of file bgp_xmpp_channel.h.

friend class BgpXmppParseTest

friend

Definition at line 202 of file bgp_xmpp_channel.h.

friend class BgpXmppUnitTest

friend

Definition at line 203 of file bgp_xmpp_channel.h.

Member Data Documentation

RibExportPolicy BgpXmppChannel::bgp_policy_

private

Definition at line 352 of file bgp_xmpp_channel.h.

BgpServer* BgpXmppChannel::bgp_server_

private

Definition at line 347 of file bgp_xmpp_channel.h.

XmppChannel* BgpXmppChannel::channel_

protected

Definition at line 197 of file bgp_xmpp_channel.h.

ChannelStats BgpXmppChannel::channel_stats_

private

Definition at line 375 of file bgp_xmpp_channel.h.

boost::scoped_ptr<PeerCloseManager> BgpXmppChannel::close_manager_

private

Definition at line 350 of file bgp_xmpp_channel.h.

bool BgpXmppChannel::defer_peer_close_

private

Definition at line 362 of file bgp_xmpp_channel.h.

DeferQ BgpXmppChannel::defer_q_

private

Definition at line 355 of file bgp_xmpp_channel.h.

bool BgpXmppChannel::delete_in_progress_

private

Definition at line 360 of file bgp_xmpp_channel.h.

bool BgpXmppChannel::deleted_

private

Definition at line 361 of file bgp_xmpp_channel.h.

Timer* BgpXmppChannel::eor_receive_timer_

private

Definition at line 366 of file bgp_xmpp_channel.h.

time_t BgpXmppChannel::eor_receive_timer_start_time_

private

Definition at line 368 of file bgp_xmpp_channel.h.

Timer* BgpXmppChannel::eor_send_timer_

private

Definition at line 367 of file bgp_xmpp_channel.h.

time_t BgpXmppChannel::eor_send_timer_start_time_

private

Definition at line 369 of file bgp_xmpp_channel.h.

bool BgpXmppChannel::eor_sent_

private

Definition at line 365 of file bgp_xmpp_channel.h.

ErrorStats BgpXmppChannel::error_stats_

private

Definition at line 376 of file bgp_xmpp_channel.h.

InstanceMembershipRequestMap BgpXmppChannel::instance_membership_request_map_

private

Definition at line 358 of file bgp_xmpp_channel.h.

const int BgpXmppChannel::kEndOfRibSendRetryTime = 1

static

Definition at line 50 of file bgp_xmpp_channel.h.

LabelBlockManagerPtr BgpXmppChannel::lb_mgr_

private

Definition at line 379 of file bgp_xmpp_channel.h.

BgpXmppChannelManager* BgpXmppChannel::manager_

private

Definition at line 359 of file bgp_xmpp_channel.h.

WorkQueue<std::string> BgpXmppChannel::membership_response_worker_

private

Definition at line 370 of file bgp_xmpp_channel.h.

boost::scoped_ptr<XmppPeer> BgpXmppChannel::peer_

private

Definition at line 348 of file bgp_xmpp_channel.h.

boost::scoped_ptr<BgpXmppPeerClose> BgpXmppChannel::peer_close_

private

Definition at line 349 of file bgp_xmpp_channel.h.

xmps::PeerId BgpXmppChannel::peer_id_

private

Definition at line 345 of file bgp_xmpp_channel.h.

boost::scoped_ptr<PeerStats> BgpXmppChannel::peer_stats_

private

Definition at line 351 of file bgp_xmpp_channel.h.

SubscribedRoutingInstanceList BgpXmppChannel::routing_instances_

private

Definition at line 371 of file bgp_xmpp_channel.h.

boost::scoped_ptr<BgpXmppRTargetManager> BgpXmppChannel::rtarget_manager_

private

Definition at line 346 of file bgp_xmpp_channel.h.

bool BgpXmppChannel::skip_update_send_

private

Definition at line 363 of file bgp_xmpp_channel.h.

bool BgpXmppChannel::skip_update_send_cached_

private

Definition at line 364 of file bgp_xmpp_channel.h.

Stats BgpXmppChannel::stats_[2]

private

Definition at line 374 of file bgp_xmpp_channel.h.

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

Member Enumeration Documentation

Constructor & Destructor Documentation

Member Function Documentation

Friends And Related Function Documentation

Member Data Documentation