OpenSDN source code
Classes | Public Types | Public Member Functions | Static Public Member Functions | Static Public Attributes | Private Member Functions | Private Attributes | Static Private Attributes | Friends | List of all members
RibOutUpdates Class Reference

#include <bgp_ribout_updates.h>

Collaboration diagram for RibOutUpdates:
Collaboration graph
[legend]

Classes

struct  Stats
 

Public Types

enum  QueueId { QFIRST = 0 , QBULK = 0 , QUPDATE , QCOUNT }
 
typedef std::vector< UpdateQueue * > QueueVec
 

Public Member Functions

 RibOutUpdates (RibOut *ribout, int index)
 
virtual ~RibOutUpdates ()
 
void Enqueue (DBEntryBase *db_entry, RouteUpdate *rt_update)
 
virtual bool TailDequeue (int queue_id, const RibPeerSet &msync, RibPeerSet *blocked, RibPeerSet *unsync)
 
virtual bool PeerDequeue (int queue_id, IPeerUpdate *peer, RibPeerSet *blocked)
 
bool QueueJoin (int queue_id, int bit)
 
void QueueLeave (int queue_id, int bit)
 
bool Empty () const
 
size_t queue_size (int queue_id) const
 
size_t queue_marker_count (int queue_id) const
 
RibUpdateMonitor * monitor ()
 
UpdateQueue * queue (int queue_id)
 
QueueVec & queue_vec ()
 
const QueueVec & queue_vec () const
 
void AddStatisticsInfo (int queue_id, Stats *stats) const
 

Static Public Member Functions

static void Initialize ()
 
static void Terminate ()
 

Static Public Attributes

static const int kQueueIdInvalid = -1
 

Private Member Functions

Message * GetMessage () const
 
bool DequeueCommon (UpdateQueue *queue, UpdateMarker *marker, RouteUpdate *rt_update, RibPeerSet *blocked)
 
void UpdatePack (int queue_id, Message *message, UpdateInfo *start_uinfo, const RibPeerSet &isect)
 
void UpdateSend (int queue_id, Message *message, const RibPeerSet &dst, RibPeerSet *blocked)
 
void UpdateFlush (const RibPeerSet &dst, RibPeerSet *blocked)
 
bool ClearAdvertisedBits (RouteUpdate *rt_update, UpdateInfo *uinfo, const RibPeerSet &bits, bool update_history)
 
void StoreHistory (RouteUpdate *rt_update)
 
void ClearState (RouteUpdate *rt_update)
 
void ClearUpdate (RouteUpdatePtr *update)
 
bool UpdateMarkersOnBlocked (UpdateMarker *marker, RouteUpdate *rt_update, const RibPeerSet *blocked)
 
 DISALLOW_COPY_AND_ASSIGN (RibOutUpdates)
 

Private Attributes

RibOut * ribout_
 
int index_
 
QueueVec queue_vec_
 
Stats stats_ [QCOUNT]
 
boost::scoped_ptr< RibUpdateMonitor > monitor_
 

Static Private Attributes

static std::vector< Message * > bgp_messages_
 
static std::vector< Message * > xmpp_messages_
 

Friends

class RibOutUpdatesTest
 
class XmppMessageBuilderTest
 
class XmppMvpnMessageBuilderTest
 

Detailed Description

Definition at line 41 of file bgp_ribout_updates.h.

Member Typedef Documentation

◆ QueueVec

typedef std::vector<UpdateQueue *> RibOutUpdates::QueueVec

Definition at line 43 of file bgp_ribout_updates.h.

Member Enumeration Documentation

◆ QueueId

enum RibOutUpdates::QueueId
Enumerator
QFIRST 
QBULK 
QUPDATE 
QCOUNT 

Definition at line 45 of file bgp_ribout_updates.h.

Constructor & Destructor Documentation

◆ RibOutUpdates()

RibOutUpdates::RibOutUpdates ( RibOut *  ribout,
int  index 
)

Definition at line 30 of file bgp_ribout_updates.cc.

Here is the call graph for this function:

◆ ~RibOutUpdates()

RibOutUpdates::~RibOutUpdates ( )
virtual

Definition at line 44 of file bgp_ribout_updates.cc.

Here is the call graph for this function:

Member Function Documentation

◆ AddStatisticsInfo()

void RibOutUpdates::AddStatisticsInfo ( int  queue_id,
Stats *  stats 
) const

Definition at line 687 of file bgp_ribout_updates.cc.

◆ ClearAdvertisedBits()

bool RibOutUpdates::ClearAdvertisedBits ( RouteUpdate *  rt_update,
UpdateInfo *  uinfo,
const RibPeerSet &  bits,
bool  update_history 
)
private

Definition at line 599 of file bgp_ribout_updates.cc.

Here is the call graph for this function:

◆ ClearState()

void RibOutUpdates::ClearState ( RouteUpdate *  rt_update)
private

Definition at line 539 of file bgp_ribout_updates.cc.

Here is the call graph for this function:

◆ ClearUpdate()

void RibOutUpdates::ClearUpdate ( RouteUpdatePtr *  update)
private

Definition at line 551 of file bgp_ribout_updates.cc.

Here is the call graph for this function:

◆ DequeueCommon()

bool RibOutUpdates::DequeueCommon ( UpdateQueue *  queue,
UpdateMarker *  marker,
RouteUpdate *  rt_update,
RibPeerSet *  blocked 
)
private

Definition at line 130 of file bgp_ribout_updates.cc.

Here is the call graph for this function:

◆ DISALLOW_COPY_AND_ASSIGN()

RibOutUpdates::DISALLOW_COPY_AND_ASSIGN ( RibOutUpdates  )
private

◆ Empty()

bool RibOutUpdates::Empty ( ) const

Definition at line 654 of file bgp_ribout_updates.cc.

Here is the call graph for this function:

◆ Enqueue()

void RibOutUpdates::Enqueue ( DBEntryBase *  db_entry,
RouteUpdate *  rt_update 
)

Definition at line 102 of file bgp_ribout_updates.cc.

Here is the call graph for this function:

◆ GetMessage()

Message * RibOutUpdates::GetMessage ( ) const
private

Definition at line 69 of file bgp_ribout_updates.cc.

Here is the call graph for this function:

◆ Initialize()

void RibOutUpdates::Initialize ( )
static

Definition at line 51 of file bgp_ribout_updates.cc.

Here is the call graph for this function:

◆ monitor()

RibUpdateMonitor* RibOutUpdates::monitor ( )
inline

Definition at line 85 of file bgp_ribout_updates.h.

◆ PeerDequeue()

bool RibOutUpdates::PeerDequeue ( int  queue_id,
IPeerUpdate *  peer,
RibPeerSet *  blocked 
)
virtual

Definition at line 296 of file bgp_ribout_updates.cc.

Here is the call graph for this function:

◆ queue()

UpdateQueue* RibOutUpdates::queue ( int  queue_id)
inline

Definition at line 87 of file bgp_ribout_updates.h.

◆ queue_marker_count()

size_t RibOutUpdates::queue_marker_count ( int  queue_id) const

Definition at line 669 of file bgp_ribout_updates.cc.

Here is the call graph for this function:

◆ queue_size()

size_t RibOutUpdates::queue_size ( int  queue_id) const

Definition at line 664 of file bgp_ribout_updates.cc.

Here is the call graph for this function:

◆ queue_vec() [1/2]

QueueVec& RibOutUpdates::queue_vec ( )
inline

Definition at line 91 of file bgp_ribout_updates.h.

◆ queue_vec() [2/2]

const QueueVec& RibOutUpdates::queue_vec ( ) const
inline

Definition at line 92 of file bgp_ribout_updates.h.

◆ QueueJoin()

bool RibOutUpdates::QueueJoin ( int  queue_id,
int  bit 
)

Definition at line 674 of file bgp_ribout_updates.cc.

Here is the call graph for this function:

◆ QueueLeave()

void RibOutUpdates::QueueLeave ( int  queue_id,
int  bit 
)

Definition at line 679 of file bgp_ribout_updates.cc.

Here is the call graph for this function:

◆ StoreHistory()

void RibOutUpdates::StoreHistory ( RouteUpdate *  rt_update)
private

Definition at line 526 of file bgp_ribout_updates.cc.

Here is the call graph for this function:

◆ TailDequeue()

bool RibOutUpdates::TailDequeue ( int  queue_id,
const RibPeerSet &  msync,
RibPeerSet *  blocked,
RibPeerSet *  unsync 
)
virtual

Definition at line 222 of file bgp_ribout_updates.cc.

Here is the call graph for this function:

◆ Terminate()

void RibOutUpdates::Terminate ( )
static

Definition at line 59 of file bgp_ribout_updates.cc.

Here is the call graph for this function:

◆ UpdateFlush()

void RibOutUpdates::UpdateFlush ( const RibPeerSet &  dst,
RibPeerSet *  blocked 
)
private

Definition at line 504 of file bgp_ribout_updates.cc.

Here is the call graph for this function:

◆ UpdateMarkersOnBlocked()

bool RibOutUpdates::UpdateMarkersOnBlocked ( UpdateMarker *  marker,
RouteUpdate *  rt_update,
const RibPeerSet *  blocked 
)
private

Definition at line 625 of file bgp_ribout_updates.cc.

Here is the call graph for this function:

◆ UpdatePack()

void RibOutUpdates::UpdatePack ( int  queue_id,
Message *  message,
UpdateInfo *  start_uinfo,
const RibPeerSet &  isect 
)
private

Definition at line 407 of file bgp_ribout_updates.cc.

Here is the call graph for this function:

◆ UpdateSend()

void RibOutUpdates::UpdateSend ( int  queue_id,
Message *  message,
const RibPeerSet &  dst,
RibPeerSet *  blocked 
)
private

Definition at line 457 of file bgp_ribout_updates.cc.

Here is the call graph for this function:

Friends And Related Function Documentation

◆ RibOutUpdatesTest

friend class RibOutUpdatesTest
friend

Definition at line 97 of file bgp_ribout_updates.h.

◆ XmppMessageBuilderTest

friend class XmppMessageBuilderTest
friend

Definition at line 98 of file bgp_ribout_updates.h.

◆ XmppMvpnMessageBuilderTest

friend class XmppMvpnMessageBuilderTest
friend

Definition at line 99 of file bgp_ribout_updates.h.

Member Data Documentation

◆ bgp_messages_

vector< Message * > RibOutUpdates::bgp_messages_
staticprivate

Definition at line 131 of file bgp_ribout_updates.h.

◆ index_

int RibOutUpdates::index_
private

Definition at line 127 of file bgp_ribout_updates.h.

◆ kQueueIdInvalid

const int RibOutUpdates::kQueueIdInvalid = -1
static

Definition at line 44 of file bgp_ribout_updates.h.

◆ monitor_

boost::scoped_ptr<RibUpdateMonitor> RibOutUpdates::monitor_
private

Definition at line 130 of file bgp_ribout_updates.h.

◆ queue_vec_

QueueVec RibOutUpdates::queue_vec_
private

Definition at line 128 of file bgp_ribout_updates.h.

◆ ribout_

RibOut* RibOutUpdates::ribout_
private

Definition at line 126 of file bgp_ribout_updates.h.

◆ stats_

Stats RibOutUpdates::stats_[QCOUNT]
private

Definition at line 129 of file bgp_ribout_updates.h.

◆ xmpp_messages_

vector< Message * > RibOutUpdates::xmpp_messages_
staticprivate

Definition at line 132 of file bgp_ribout_updates.h.

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