OpenSDN source code
•All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Pages
Classes | Public Types | Public Member Functions | Static Public Attributes | Private Types | Private Member Functions | Private Attributes | Friends | List of all members
IFMapServer Class Reference

#include <ifmap_server.h>

Collaboration diagram for IFMapServer:
Collaboration graph
[legend]

Classes

struct  ClientHistoryInfo
 
class  IFMapStaleEntriesCleaner
 
class  IFMapVmSubscribe
 
struct  QueueEntry
 

Public Types

typedef std::map< std::string,
IFMapClient * > 		ClientMap
 
typedef std::map< int,
IFMapClient * > 		IndexMap
 
typedef std::deque
< ClientHistoryInfo > 		ClientHistory
 
typedef ClientMap::size_type CmSz_t
 
typedef IndexMap::size_type ImSz_t
 

Public Member Functions

 IFMapServer (DB *db, DBGraph *graph, boost::asio::io_context *io_service)
 
virtual ~IFMapServer ()
 
void Initialize ()
 
void Shutdown ()
 
void ClientRegister (IFMapClient *client)
 
void ClientUnregister (IFMapClient *client)
 
bool ProcessClientWork (bool add, IFMapClient *client)
 
IFMapClient * FindClient (const std::string &id)
 
IFMapClient * GetClient (int index)
 
void AddClient (IFMapClient *client)
 
void DeleteClient (IFMapClient *client)
 
void ClientExporterSetup (IFMapClient *client)
 
DB * database ()
 
DBGraph * graph ()
 
IFMapUpdateQueue * queue ()
 
IFMapUpdateSender * sender ()
 
IFMapExporter * exporter ()
 
IFMapVmUuidMapper * vm_uuid_mapper ()
 
boost::asio::io_context * io_service ()
 
void set_config_manager (ConfigClientManager *manager)
 
ConfigClientManager * get_config_manager ()
 
ConfigClientManager * get_config_manager () const
 
void set_ifmap_channel_manager (IFMapChannelManager *manager)
 
IFMapChannelManager * get_ifmap_channel_manager ()
 
uint64_t get_config_generation_number ()
 
void ProcessVmSubscribe (std::string vr_name, std::string vm_uuid, bool subscribe, bool has_vms)
 
void ProcessVmSubscribe (std::string vr_name, std::string vm_uuid, bool subscribe)
 
void ProcessVmRegAsPending (std::string vm_uuid, std::string vr_name, bool subscribe)
 
IFMapNode * GetVmNodeByUuid (const std::string &vm_uuid)
 
void FillClientMap (IFMapServerShowClientMap *out_map, const std::string &search_string)
 
void FillIndexMap (IFMapServerShowIndexMap *out_map, const std::string &search_string)
 
void FillClientHistory (IFMapServerClientHistoryList *out_list, const std::string &search_string)
 
const CmSz_t GetClientMapSize () const
 
const CmSz_t GetIndexMapSize () const
 
void GetUIInfo (IFMapServerInfoUI *server_info) const
 
bool ClientNameToIndex (const std::string &id, int *index)
 
void CleanupStaleEntries ()
 
bool CollectStats (BgpRouterState *state, bool first) const
 

Static Public Attributes

static const int kClientHistorySize = 5000
 

Private Types

enum  QueueOp { ADD = 1, DEL = 2 }
 

Private Member Functions

bool ClientWorker (QueueEntry work_entry)
 
void ClientGraphDownload (IFMapClient *client)
 
void RemoveSelfAddedLinksAndObjects (IFMapClient *client)
 
void CleanupUuidMapper (IFMapClient *client)
 
void ClientExporterCleanup (int index)
 
const ClientMap & GetClientMap () const
 
void SimulateDeleteClient (IFMapClient *client)
 
void SaveClientHistory (IFMapClient *client)
 

Private Attributes

DB * db_
 
DBGraph * graph_
 
boost::scoped_ptr
< IFMapUpdateQueue > 		queue_
 
boost::scoped_ptr< IFMapExporter > exporter_
 
boost::scoped_ptr
< IFMapUpdateSender > 		sender_
 
boost::scoped_ptr
< IFMapVmUuidMapper > 		vm_uuid_mapper_
 
BitSet client_indexes_
 
ClientMap client_map_
 
IndexMap index_map_
 
WorkQueue< QueueEntry > work_queue_
 
boost::asio::io_context * io_service_
 
ConfigClientManager * config_manager_
 
IFMapChannelManager * ifmap_channel_manager_
 
ClientHistory client_history_
 

Friends

class IFMapServerTest
 
class IFMapRestartTest
 
class ShowIFMapXmppClientInfo
 
class XmppIfmapTest
 
class IFMapExporterTest
 
class IFMapVmUuidMapperTest
 

Detailed Description

Definition at line 40 of file ifmap_server.h.

Member Typedef Documentation

typedef std::deque<ClientHistoryInfo> IFMapServer::ClientHistory

Definition at line 60 of file ifmap_server.h.

typedef std::map<std::string, IFMapClient *> IFMapServer::ClientMap

Definition at line 58 of file ifmap_server.h.

typedef ClientMap::size_type IFMapServer::CmSz_t

Definition at line 61 of file ifmap_server.h.

typedef IndexMap::size_type IFMapServer::ImSz_t

Definition at line 62 of file ifmap_server.h.

typedef std::map<int, IFMapClient *> IFMapServer::IndexMap

Definition at line 59 of file ifmap_server.h.

Member Enumeration Documentation

enum IFMapServer::QueueOp
private
Enumerator
ADD 
DEL 

Definition at line 137 of file ifmap_server.h.

Constructor & Destructor Documentation

IFMapServer::IFMapServer ( DB *  db,
DBGraph *  graph,
boost::asio::io_context *  io_service 
)

Definition at line 193 of file ifmap_server.cc.

IFMapServer::~IFMapServer ( )
virtual

Definition at line 206 of file ifmap_server.cc.

Member Function Documentation

void IFMapServer::AddClient ( IFMapClient *  client)

Definition at line 282 of file ifmap_server.cc.

void IFMapServer::CleanupStaleEntries ( )

Definition at line 536 of file ifmap_server.cc.

Here is the call graph for this function:

void IFMapServer::CleanupUuidMapper ( IFMapClient *  client)
private

Definition at line 318 of file ifmap_server.cc.

Here is the call graph for this function:

void IFMapServer::ClientExporterCleanup ( int  index)
private

Definition at line 369 of file ifmap_server.cc.

Here is the call graph for this function:

void IFMapServer::ClientExporterSetup ( IFMapClient *  client)

Definition at line 365 of file ifmap_server.cc.

Here is the call graph for this function:

void IFMapServer::ClientGraphDownload ( IFMapClient *  client)
private

Definition at line 346 of file ifmap_server.cc.

Here is the call graph for this function:

bool IFMapServer::ClientNameToIndex ( const std::string &  id,
int *  index 
)

Definition at line 394 of file ifmap_server.cc.

Here is the call graph for this function:

void IFMapServer::ClientRegister ( IFMapClient *  client)

Definition at line 219 of file ifmap_server.cc.

Here is the call graph for this function:

void IFMapServer::ClientUnregister ( IFMapClient *  client)

Definition at line 250 of file ifmap_server.cc.

Here is the call graph for this function:

bool IFMapServer::ClientWorker ( QueueEntry  work_entry)
private

Definition at line 307 of file ifmap_server.cc.

Here is the call graph for this function:

bool IFMapServer::CollectStats ( BgpRouterState *  state,
bool  first 
) const

Definition at line 504 of file ifmap_server.cc.

Here is the call graph for this function:

DB* IFMapServer::database ( )
inline

Definition at line 82 of file ifmap_server.h.

void IFMapServer::DeleteClient ( IFMapClient *  client)

Definition at line 291 of file ifmap_server.cc.

IFMapExporter* IFMapServer::exporter ( )
inline

Definition at line 86 of file ifmap_server.h.

void IFMapServer::FillClientHistory ( IFMapServerClientHistoryList *  out_list,
const std::string &  search_string 
)

Definition at line 480 of file ifmap_server.cc.

Here is the call graph for this function:

void IFMapServer::FillClientMap ( IFMapServerShowClientMap *  out_map,
const std::string &  search_string 
)

Definition at line 433 of file ifmap_server.cc.

Here is the call graph for this function:

void IFMapServer::FillIndexMap ( IFMapServerShowIndexMap *  out_map,
const std::string &  search_string 
)

Definition at line 454 of file ifmap_server.cc.

Here is the call graph for this function:

IFMapClient * IFMapServer::FindClient ( const std::string &  id)

Definition at line 378 of file ifmap_server.cc.

uint64_t IFMapServer::get_config_generation_number ( )
inline

Definition at line 101 of file ifmap_server.h.

Here is the call graph for this function:

ConfigClientManager* IFMapServer::get_config_manager ( )
inline

Definition at line 92 of file ifmap_server.h.

ConfigClientManager* IFMapServer::get_config_manager ( ) const
inline

Definition at line 93 of file ifmap_server.h.

IFMapChannelManager* IFMapServer::get_ifmap_channel_manager ( )
inline

Definition at line 97 of file ifmap_server.h.

IFMapClient * IFMapServer::GetClient ( int  index)

Definition at line 386 of file ifmap_server.cc.

Here is the call graph for this function:

const ClientMap& IFMapServer::GetClientMap ( ) const
inlineprivate

Definition at line 150 of file ifmap_server.h.

const CmSz_t IFMapServer::GetClientMapSize ( ) const
inline

Definition at line 122 of file ifmap_server.h.

const CmSz_t IFMapServer::GetIndexMapSize ( ) const
inline

Definition at line 123 of file ifmap_server.h.

Here is the call graph for this function:

void IFMapServer::GetUIInfo ( IFMapServerInfoUI *  server_info) const

Definition at line 500 of file ifmap_server.cc.

Here is the call graph for this function:

IFMapNode * IFMapServer::GetVmNodeByUuid ( const std::string &  vm_uuid)

Definition at line 429 of file ifmap_server.cc.

DBGraph* IFMapServer::graph ( )
inline

Definition at line 83 of file ifmap_server.h.

void IFMapServer::Initialize ( )

Definition at line 209 of file ifmap_server.cc.

boost::asio::io_context* IFMapServer::io_service ( )
inline

Definition at line 88 of file ifmap_server.h.

bool IFMapServer::ProcessClientWork ( bool  add,
IFMapClient *  client 
)

Definition at line 263 of file ifmap_server.cc.

Here is the call graph for this function:

void IFMapServer::ProcessVmRegAsPending ( std::string  vm_uuid,
std::string  vr_name,
bool  subscribe 
)

Definition at line 423 of file ifmap_server.cc.

void IFMapServer::ProcessVmSubscribe ( std::string  vr_name,
std::string  vm_uuid,
bool  subscribe,
bool  has_vms 
)

Definition at line 403 of file ifmap_server.cc.

Here is the call graph for this function:

void IFMapServer::ProcessVmSubscribe ( std::string  vr_name,
std::string  vm_uuid,
bool  subscribe 
)

Definition at line 412 of file ifmap_server.cc.

Here is the call graph for this function:

IFMapUpdateQueue* IFMapServer::queue ( )
inline

Definition at line 84 of file ifmap_server.h.

void IFMapServer::RemoveSelfAddedLinksAndObjects ( IFMapClient *  client)
private

Definition at line 325 of file ifmap_server.cc.

Here is the call graph for this function:

void IFMapServer::SaveClientHistory ( IFMapClient *  client)
private

Definition at line 240 of file ifmap_server.cc.

Here is the call graph for this function:

IFMapUpdateSender* IFMapServer::sender ( )
inline

Definition at line 85 of file ifmap_server.h.

void IFMapServer::set_config_manager ( ConfigClientManager *  manager)
inline

Definition at line 89 of file ifmap_server.h.

void IFMapServer::set_ifmap_channel_manager ( IFMapChannelManager *  manager)
inline

Definition at line 94 of file ifmap_server.h.

void IFMapServer::Shutdown ( )

Definition at line 214 of file ifmap_server.cc.

void IFMapServer::SimulateDeleteClient ( IFMapClient *  client)
private

Definition at line 300 of file ifmap_server.cc.

Here is the call graph for this function:

IFMapVmUuidMapper* IFMapServer::vm_uuid_mapper ( )
inline

Definition at line 87 of file ifmap_server.h.

Friends And Related Function Documentation

friend class IFMapExporterTest
friend

Definition at line 134 of file ifmap_server.h.

friend class IFMapRestartTest
friend

Definition at line 131 of file ifmap_server.h.

friend class IFMapServerTest
friend

Definition at line 130 of file ifmap_server.h.

friend class IFMapVmUuidMapperTest
friend

Definition at line 135 of file ifmap_server.h.

friend class ShowIFMapXmppClientInfo
friend

Definition at line 132 of file ifmap_server.h.

friend class XmppIfmapTest
friend

Definition at line 133 of file ifmap_server.h.

Member Data Documentation

ClientHistory IFMapServer::client_history_
private

Definition at line 167 of file ifmap_server.h.

BitSet IFMapServer::client_indexes_
private

Definition at line 160 of file ifmap_server.h.

ClientMap IFMapServer::client_map_
private

Definition at line 161 of file ifmap_server.h.

ConfigClientManager* IFMapServer::config_manager_
private

Definition at line 165 of file ifmap_server.h.

DB* IFMapServer::db_
private

Definition at line 154 of file ifmap_server.h.

boost::scoped_ptr<IFMapExporter> IFMapServer::exporter_
private

Definition at line 157 of file ifmap_server.h.

DBGraph* IFMapServer::graph_
private

Definition at line 155 of file ifmap_server.h.

IFMapChannelManager* IFMapServer::ifmap_channel_manager_
private

Definition at line 166 of file ifmap_server.h.

IndexMap IFMapServer::index_map_
private

Definition at line 162 of file ifmap_server.h.

boost::asio::io_context* IFMapServer::io_service_
private

Definition at line 164 of file ifmap_server.h.

const int IFMapServer::kClientHistorySize = 5000
static

Definition at line 57 of file ifmap_server.h.

boost::scoped_ptr<IFMapUpdateQueue> IFMapServer::queue_
private

Definition at line 156 of file ifmap_server.h.

boost::scoped_ptr<IFMapUpdateSender> IFMapServer::sender_
private

Definition at line 158 of file ifmap_server.h.

boost::scoped_ptr<IFMapVmUuidMapper> IFMapServer::vm_uuid_mapper_
private

Definition at line 159 of file ifmap_server.h.

WorkQueue<QueueEntry> IFMapServer::work_queue_
private

Definition at line 163 of file ifmap_server.h.

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