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

#include <ifmap_xmpp.h>

Collaboration diagram for IFMapChannelManager:
Collaboration graph
[legend]

Classes

struct  ConfigTaskQueueEntry
 

Public Member Functions

 IFMapChannelManager (XmppServer *, IFMapServer *)
 
virtual ~IFMapChannelManager ()
 
IFMapXmppChannel * FindChannel (XmppChannel *)
 
IFMapXmppChannel * FindChannel (std::string)
 
void IFMapXmppChannelEventCb (XmppChannel *, xmps::PeerState)
 
virtual IFMapXmppChannel * CreateIFMapXmppChannel (XmppChannel *)
 
void EnqueueChannelUnregister (XmppChannel *channel)
 
void ProcessChannelReady (XmppChannel *channel)
 
void ProcessChannelNotReady (XmppChannel *channel)
 
void incr_unknown_subscribe_messages ()
 
void incr_unknown_unsubscribe_messages ()
 
void incr_duplicate_channel_ready_messages ()
 
void incr_invalid_channel_not_ready_messages ()
 
void incr_invalid_channel_state_messages ()
 
void incr_invalid_vm_subscribe_messages ()
 
void incr_vmsub_novrsub_messages ()
 
void incr_vmunsub_novrsub_messages ()
 
void incr_vmunsub_novmsub_messages ()
 
void incr_duplicate_vrsub_messages ()
 
void incr_duplicate_vmsub_messages ()
 
uint64_t get_unknown_subscribe_messages ()
 
uint64_t get_unknown_unsubscribe_messages ()
 
uint64_t get_duplicate_channel_ready_messages ()
 
uint64_t get_invalid_channel_not_ready_messages ()
 
uint64_t get_invalid_channel_state_messages ()
 
uint64_t get_invalid_vm_subscribe_messages ()
 
uint64_t get_vmsub_novrsub_messages ()
 
uint64_t get_vmunsub_novrsub_messages ()
 
uint64_t get_vmunsub_novmsub_messages ()
 
uint64_t get_duplicate_vrsub_messages ()
 
uint64_t get_duplicate_vmsub_messages ()
 
void FillChannelMap (std::vector< IFMapXmppChannelMapEntry > *out_map)
 

Private Types

typedef std::map< XmppChannel *, IFMapXmppChannel * > ChannelMap
 

Private Member Functions

bool ProcessChannelUnregister (ConfigTaskQueueEntry entry)
 
void DeleteIFMapXmppChannel (IFMapXmppChannel *ifmap_chnl)
 
void EnqueueChannelEvent (XCEvent event, XmppChannel *channel)
 

Private Attributes

XmppServer * xmpp_server_
 
IFMapServer * ifmap_server_
 
ChannelMap channel_map_
 
tbb::mutex channel_map_mutex_
 
WorkQueue< ConfigTaskQueueEntry > config_task_work_queue_
 
tbb::atomic< uint64_t > unknown_subscribe_messages
 
tbb::atomic< uint64_t > unknown_unsubscribe_messages
 
tbb::atomic< uint64_t > duplicate_channel_ready_messages
 
tbb::atomic< uint64_t > invalid_channel_not_ready_messages
 
tbb::atomic< uint64_t > invalid_channel_state_messages
 
tbb::atomic< uint64_t > invalid_vm_subscribe_messages
 
tbb::atomic< uint64_t > vmsub_novrsub_messages
 
tbb::atomic< uint64_t > vmunsub_novrsub_messages
 
tbb::atomic< uint64_t > vmunsub_novmsub_messages
 
tbb::atomic< uint64_t > duplicate_vrsub_messages
 
tbb::atomic< uint64_t > duplicate_vmsub_messages
 

Friends

class IFMapChannelManagerTest
 
class XmppIfmapTest
 

Detailed Description

Definition at line 83 of file ifmap_xmpp.h.

Member Typedef Documentation

◆ ChannelMap

typedef std::map<XmppChannel *, IFMapXmppChannel *> IFMapChannelManager::ChannelMap
private

Definition at line 164 of file ifmap_xmpp.h.

Constructor & Destructor Documentation

◆ IFMapChannelManager()

IFMapChannelManager::IFMapChannelManager ( XmppServer *  xmpp_server,
IFMapServer *  ifmap_server 
)

Definition at line 336 of file ifmap_xmpp.cc.

Here is the call graph for this function:

◆ ~IFMapChannelManager()

IFMapChannelManager::~IFMapChannelManager ( )
virtual

Definition at line 359 of file ifmap_xmpp.cc.

Here is the call graph for this function:

Member Function Documentation

◆ CreateIFMapXmppChannel()

IFMapXmppChannel * IFMapChannelManager::CreateIFMapXmppChannel ( XmppChannel *  channel)
virtual

Definition at line 383 of file ifmap_xmpp.cc.

◆ DeleteIFMapXmppChannel()

void IFMapChannelManager::DeleteIFMapXmppChannel ( IFMapXmppChannel *  ifmap_chnl)
private

Definition at line 394 of file ifmap_xmpp.cc.

Here is the call graph for this function:

◆ EnqueueChannelEvent()

void IFMapChannelManager::EnqueueChannelEvent ( XCEvent  event,
XmppChannel *  channel 
)
private

Definition at line 436 of file ifmap_xmpp.cc.

Here is the call graph for this function:

◆ EnqueueChannelUnregister()

void IFMapChannelManager::EnqueueChannelUnregister ( XmppChannel *  channel)

Definition at line 470 of file ifmap_xmpp.cc.

◆ FillChannelMap()

void IFMapChannelManager::FillChannelMap ( std::vector< IFMapXmppChannelMapEntry > *  out_map)

Definition at line 477 of file ifmap_xmpp.cc.

Here is the call graph for this function:

◆ FindChannel() [1/2]

IFMapXmppChannel * IFMapChannelManager::FindChannel ( std::string  tostring)

Definition at line 374 of file ifmap_xmpp.cc.

◆ FindChannel() [2/2]

IFMapXmppChannel * IFMapChannelManager::FindChannel ( XmppChannel *  channel)

Definition at line 364 of file ifmap_xmpp.cc.

◆ get_duplicate_channel_ready_messages()

uint64_t IFMapChannelManager::get_duplicate_channel_ready_messages ( )
inline

Definition at line 132 of file ifmap_xmpp.h.

◆ get_duplicate_vmsub_messages()

uint64_t IFMapChannelManager::get_duplicate_vmsub_messages ( )
inline

Definition at line 156 of file ifmap_xmpp.h.

◆ get_duplicate_vrsub_messages()

uint64_t IFMapChannelManager::get_duplicate_vrsub_messages ( )
inline

Definition at line 153 of file ifmap_xmpp.h.

◆ get_invalid_channel_not_ready_messages()

uint64_t IFMapChannelManager::get_invalid_channel_not_ready_messages ( )
inline

Definition at line 135 of file ifmap_xmpp.h.

◆ get_invalid_channel_state_messages()

uint64_t IFMapChannelManager::get_invalid_channel_state_messages ( )
inline

Definition at line 138 of file ifmap_xmpp.h.

◆ get_invalid_vm_subscribe_messages()

uint64_t IFMapChannelManager::get_invalid_vm_subscribe_messages ( )
inline

Definition at line 141 of file ifmap_xmpp.h.

◆ get_unknown_subscribe_messages()

uint64_t IFMapChannelManager::get_unknown_subscribe_messages ( )
inline

Definition at line 126 of file ifmap_xmpp.h.

◆ get_unknown_unsubscribe_messages()

uint64_t IFMapChannelManager::get_unknown_unsubscribe_messages ( )
inline

Definition at line 129 of file ifmap_xmpp.h.

◆ get_vmsub_novrsub_messages()

uint64_t IFMapChannelManager::get_vmsub_novrsub_messages ( )
inline

Definition at line 144 of file ifmap_xmpp.h.

◆ get_vmunsub_novmsub_messages()

uint64_t IFMapChannelManager::get_vmunsub_novmsub_messages ( )
inline

Definition at line 150 of file ifmap_xmpp.h.

◆ get_vmunsub_novrsub_messages()

uint64_t IFMapChannelManager::get_vmunsub_novrsub_messages ( )
inline

Definition at line 147 of file ifmap_xmpp.h.

◆ IFMapXmppChannelEventCb()

void IFMapChannelManager::IFMapXmppChannelEventCb ( XmppChannel *  channel,
xmps::PeerState  state 
)

Definition at line 448 of file ifmap_xmpp.cc.

Here is the call graph for this function:

◆ incr_duplicate_channel_ready_messages()

void IFMapChannelManager::incr_duplicate_channel_ready_messages ( )
inline

Definition at line 98 of file ifmap_xmpp.h.

◆ incr_duplicate_vmsub_messages()

void IFMapChannelManager::incr_duplicate_vmsub_messages ( )
inline

Definition at line 122 of file ifmap_xmpp.h.

◆ incr_duplicate_vrsub_messages()

void IFMapChannelManager::incr_duplicate_vrsub_messages ( )
inline

Definition at line 119 of file ifmap_xmpp.h.

◆ incr_invalid_channel_not_ready_messages()

void IFMapChannelManager::incr_invalid_channel_not_ready_messages ( )
inline

Definition at line 101 of file ifmap_xmpp.h.

◆ incr_invalid_channel_state_messages()

void IFMapChannelManager::incr_invalid_channel_state_messages ( )
inline

Definition at line 104 of file ifmap_xmpp.h.

◆ incr_invalid_vm_subscribe_messages()

void IFMapChannelManager::incr_invalid_vm_subscribe_messages ( )
inline

Definition at line 107 of file ifmap_xmpp.h.

◆ incr_unknown_subscribe_messages()

void IFMapChannelManager::incr_unknown_subscribe_messages ( )
inline

Definition at line 96 of file ifmap_xmpp.h.

◆ incr_unknown_unsubscribe_messages()

void IFMapChannelManager::incr_unknown_unsubscribe_messages ( )
inline

Definition at line 97 of file ifmap_xmpp.h.

◆ incr_vmsub_novrsub_messages()

void IFMapChannelManager::incr_vmsub_novrsub_messages ( )
inline

Definition at line 110 of file ifmap_xmpp.h.

◆ incr_vmunsub_novmsub_messages()

void IFMapChannelManager::incr_vmunsub_novmsub_messages ( )
inline

Definition at line 116 of file ifmap_xmpp.h.

◆ incr_vmunsub_novrsub_messages()

void IFMapChannelManager::incr_vmunsub_novrsub_messages ( )
inline

Definition at line 113 of file ifmap_xmpp.h.

◆ ProcessChannelNotReady()

void IFMapChannelManager::ProcessChannelNotReady ( XmppChannel *  channel)

Definition at line 418 of file ifmap_xmpp.cc.

Here is the call graph for this function:

◆ ProcessChannelReady()

void IFMapChannelManager::ProcessChannelReady ( XmppChannel *  channel)

Definition at line 400 of file ifmap_xmpp.cc.

Here is the call graph for this function:

◆ ProcessChannelUnregister()

bool IFMapChannelManager::ProcessChannelUnregister ( ConfigTaskQueueEntry  entry)
private

Definition at line 462 of file ifmap_xmpp.cc.

Here is the call graph for this function:

Friends And Related Function Documentation

◆ IFMapChannelManagerTest

friend class IFMapChannelManagerTest
friend

Definition at line 162 of file ifmap_xmpp.h.

◆ XmppIfmapTest

friend class XmppIfmapTest
friend

Definition at line 163 of file ifmap_xmpp.h.

Member Data Documentation

◆ channel_map_

ChannelMap IFMapChannelManager::channel_map_
private

Definition at line 171 of file ifmap_xmpp.h.

◆ channel_map_mutex_

tbb::mutex IFMapChannelManager::channel_map_mutex_
private

Definition at line 172 of file ifmap_xmpp.h.

◆ config_task_work_queue_

WorkQueue<ConfigTaskQueueEntry> IFMapChannelManager::config_task_work_queue_
private

Definition at line 173 of file ifmap_xmpp.h.

◆ duplicate_channel_ready_messages

tbb::atomic<uint64_t> IFMapChannelManager::duplicate_channel_ready_messages
private

Definition at line 182 of file ifmap_xmpp.h.

◆ duplicate_vmsub_messages

tbb::atomic<uint64_t> IFMapChannelManager::duplicate_vmsub_messages
private

Definition at line 190 of file ifmap_xmpp.h.

◆ duplicate_vrsub_messages

tbb::atomic<uint64_t> IFMapChannelManager::duplicate_vrsub_messages
private

Definition at line 189 of file ifmap_xmpp.h.

◆ ifmap_server_

IFMapServer* IFMapChannelManager::ifmap_server_
private

Definition at line 170 of file ifmap_xmpp.h.

◆ invalid_channel_not_ready_messages

tbb::atomic<uint64_t> IFMapChannelManager::invalid_channel_not_ready_messages
private

Definition at line 183 of file ifmap_xmpp.h.

◆ invalid_channel_state_messages

tbb::atomic<uint64_t> IFMapChannelManager::invalid_channel_state_messages
private

Definition at line 184 of file ifmap_xmpp.h.

◆ invalid_vm_subscribe_messages

tbb::atomic<uint64_t> IFMapChannelManager::invalid_vm_subscribe_messages
private

Definition at line 185 of file ifmap_xmpp.h.

◆ unknown_subscribe_messages

tbb::atomic<uint64_t> IFMapChannelManager::unknown_subscribe_messages
private

Definition at line 180 of file ifmap_xmpp.h.

◆ unknown_unsubscribe_messages

tbb::atomic<uint64_t> IFMapChannelManager::unknown_unsubscribe_messages
private

Definition at line 181 of file ifmap_xmpp.h.

◆ vmsub_novrsub_messages

tbb::atomic<uint64_t> IFMapChannelManager::vmsub_novrsub_messages
private

Definition at line 186 of file ifmap_xmpp.h.

◆ vmunsub_novmsub_messages

tbb::atomic<uint64_t> IFMapChannelManager::vmunsub_novmsub_messages
private

Definition at line 188 of file ifmap_xmpp.h.

◆ vmunsub_novrsub_messages

tbb::atomic<uint64_t> IFMapChannelManager::vmunsub_novrsub_messages
private

Definition at line 187 of file ifmap_xmpp.h.

◆ xmpp_server_

XmppServer* IFMapChannelManager::xmpp_server_
private

Definition at line 169 of file ifmap_xmpp.h.

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