NLNET::CUnifiedNetwork Class Reference

#include <unified_network.h>

---

Detailed Description

Layer 5

Author:

Vianney Lecroart, Benjamin Legros

Nevrax France

Date:

2002

Definition at line 71 of file unified_network.h.

Public Member Functions
void	addCallbackArray (const TUnifiedCallbackItem *callbackarray, NLMISC::CStringIdArray::TStringId arraysize)
void	addDefaultNetwork (const std::string &defnet)
void	addNetworkAssociation (const std::string &networkName, uint8 nid)
void	addService (const std::string &name, const std::vector< CInetAddress > &addr, bool sendId=true, bool external=true, uint16 sid=0, bool autoRetry=true, bool shouldBeAlreayInserted=false)
void	addService (const std::string &name, const CInetAddress &addr, bool sendId=true, bool external=true, uint16 sid=0, bool autoRetry=true, bool shouldBeAlreayInserted=false)
void	clearDefaultNetwork ()
	Clear all default network.
void	clearNetworkAssociation ()
void	connect ()
void	displayInternalTables (NLMISC::CLog *log=NLMISC::InfoLog)
void	displayUnifiedConnection (uint16 sid, NLMISC::CLog *log=NLMISC::InfoLog)
TUnifiedMsgCallback	findCallback (const std::string &callbackName)
	Find a callback in the array.
uint64	getBytesReceived ()
	Gets the total number of bytes received.
uint64	getBytesSent ()
	Gets the total number of bytes sent.
const std::vector< uint16 > &	getConnectionList () const
	Return the service ids of the active connections.
CCallbackNetBase *	getNetBase (uint16 sid, TSockId &host, uint8 nid=0xFF)
	Gets the CCallbackNetBase of the service.
CCallbackNetBase *	getNetBase (const std::string &name, TSockId &host, uint8 nid=0xFF)
	Gets the CCallbackNetBase of the service.
uint64	getReceiveQueueSize ()
	Gets the total number of bytes queued after receiving.
uint64	getSendQueueSize ()
	Gets the total number of bytes queued for sending.
std::string	getServiceName (uint16 sid)
	Return the name of the specified service, or "" if not found.
std::string	getServiceUnifiedName (uint16 sid)
	Return a string identifying the service, using the format "NAME-sid" (or "sid" only if not found).
bool	init (const CInetAddress *addr, CCallbackNetBase::TRecordingState rec, const std::string &shortName, uint16 port, TServiceId &sid)
bool	isServiceLocal (const std::string &serviceName)
	Returns true if the serviceName service is on the same computer than this service.
bool	isServiceLocal (uint16 sid)
	Returns true if the sid service is on the same computer than this service.
void	release ()
bool	send (uint16 serviceId, const CMessage &msg, uint8 nid=0xFF)
bool	send (const std::string &serviceName, const CMessage &msg, uint8 nid=0xFF)
void	sendAll (const CMessage &msg, uint8 nid=0xFF)
void	setServiceDownCallback (const std::string &serviceName, TUnifiedNetCallback cb, void *arg=0, bool back=true)
void	setServiceUpCallback (const std::string &serviceName, TUnifiedNetCallback cb, void *arg=0, bool back=true)
void	update (NLMISC::TTime timeout=0)
Static Public Member Functions
CUnifiedNetwork *	getInstance ()
bool	isUsed ()
Private Types
typedef std::pair< TUnifiedNetCallback, void * >	TCallbackArgItem
	A callback and its user data.
typedef std::map< std::string, TUnifiedMsgCallback >	TMsgMappedCallback
	A map of callbacks, refered by message name.
typedef std::hash_map< std::string, std::list< TCallbackArgItem > >	TNameMappedCallback
	A map of service up/down callbacks with their user data.
Private Member Functions
void	addNamedCnx (const std::string &name, uint16 sid)
void	autoCheck ()
void	callServiceDownCallback (const std::string &serviceName, uint16 sid, bool callGlobalCallback=true)
void	callServiceUpCallback (const std::string &serviceName, uint16 sid, bool callGlobalCallback=true)
	CUnifiedNetwork ()
uint8	findConnectionId (uint16 sid, uint8 nid)
CUnifiedConnection *	getUnifiedConnection (uint16 sid, bool warn=true)
bool	haveNamedCnx (const std::string &name, uint16 sid)
void	removeNamedCnx (const std::string &name, uint16 sid)
	~CUnifiedNetwork ()
Private Attributes
TMsgMappedCallback	_Callbacks
	Map of callbacks.
CCallbackServer *	_CbServer
	The callback server.
std::vector< std::string >	_DefaultNetwork
	for each services, which network to take
TNameMappedCallback	_DownCallbacks
std::vector< TCallbackArgItem >	_DownUniCallback
uint16	_ExtSId
	Used for external service.
std::vector< CUnifiedConnection >	_IdCnx
	Vector of connections by service id (sid is the entry in this array, it means that there s some hole).
bool	_Initialised
	true if initialisation function called
NLMISC::TTime	_LastRetry
	Last time of retry.
std::string	_Name
	Service name.
TNameMappedConnection	_NamedCnx
	Map of connections by service name.
NLNET::CInetAddress	_NamingServiceAddr
	Naming service.
std::vector< uint32 >	_NetworkAssociations
	for each nid, which network address
NLMISC::TTime	_NextUpdateTime
	Time of the theorical next update.
CCallbackNetBase::TRecordingState	_RecordingState
	Recording state.
uint16	_ServerPort
	The server port.
TServiceId	_SId
	Service id of the running service.
TNameMappedCallback	_UpCallbacks
	Map of the up/down service callbacks.
std::vector< TCallbackArgItem >	_UpUniCallback
std::vector< uint16 >	_UsedConnection
	This vector contains only an index to the unified connection. It is used to have quick access on the available connections.
Static Private Attributes
CUnifiedNetwork *	_Instance = NULL
	The main instance.
Friends
struct	isServiceLocalClass
struct	l5CallbackClass
struct	l5QueuesStatsClass
void	uncbConnection (TSockId from, void *arg)
void	uncbDisconnection (TSockId from, void *arg)
void	uncbMsgProcessing (CMessage &msgin, TSockId from, CCallbackNetBase &netbase)
void	uncbServiceIdentification (CMessage &msgin, TSockId from, CCallbackNetBase &netbase)
void	uNetRegistrationBroadcast (const std::string &name, TServiceId sid, const std::vector< CInetAddress > &addr)
void	uNetUnregistrationBroadcast (const std::string &name, TServiceId sid, const std::vector< CInetAddress > &addr)

---

Member Typedef Documentation

typedef std::pair<TUnifiedNetCallback, void *> NLNET::CUnifiedNetwork::TCallbackArgItem [private]

A callback and its user data. Definition at line 245 of file unified_network.h.

typedef std::map<std::string, TUnifiedMsgCallback> NLNET::CUnifiedNetwork::TMsgMappedCallback [private]

A map of callbacks, refered by message name. Definition at line 242 of file unified_network.h.

typedef std::hash_map<std::string, std::list<TCallbackArgItem> > NLNET::CUnifiedNetwork::TNameMappedCallback [private]

A map of service up/down callbacks with their user data. Definition at line 248 of file unified_network.h.

---

Constructor & Destructor Documentation

NLNET::CUnifiedNetwork::CUnifiedNetwork (   )  [inline, private]

Definition at line 481 of file unified_network.h. References _CbServer, _ExtSId, and _LastRetry. Referenced by getInstance(). : _CbServer(0), _ExtSId(256), _LastRetry(0), _NextUpdateTime(0), _Initialised(false) { }

NLNET::CUnifiedNetwork::~CUnifiedNetwork (   )  [inline, private]

Definition at line 485 of file unified_network.h. { }

---

Member Function Documentation

void NLNET::CUnifiedNetwork::addCallbackArray (  const TUnifiedCallbackItem *  callbackarray, NLMISC::CStringIdArray::TStringId  arraysize )

Adds a callback array in the system. You can add callback only *after* adding the server, the client or the group. Definition at line 1188 of file unified_network.cpp. References _Callbacks, NLMISC::CStringIdArray::TStringId, and uint. Referenced by NLNET::IService::main(). { uint i; for (i=0; i<(uint)arraysize; ++i) _Callbacks.insert(make_pair(string(callbackarray[i].Key),callbackarray[i].Callback)); }

void NLNET::CUnifiedNetwork::addDefaultNetwork (  const std::string &  defnet  )  [inline]

This array says to wich network we need to send the message for the default nid. For example you can says that message for AES will use the network 0 and message for LS will use the network 1. To do that, just call the function with string "AES0" and "LS1" the number is the nid (look at addNetworkAssociation()) addNetworkAssociation("192.168.0.0", 0); addNetworkAssociation("192.168.1.0", 1); In this case if you send a message to AES with default nid, it'll be send to 192.168.0.x In this case if you send a message to LS with default nid, it'll be send to 192.168.1.y Definition at line 184 of file unified_network.h. References _DefaultNetwork, and nlinfo. { nlinfo ("HNETL5: Add default network '%s'", defnet.c_str()); _DefaultNetwork.push_back (defnet); }

void NLNET::CUnifiedNetwork::addNamedCnx (  const std::string &  name, uint16  sid )  [private]

Definition at line 1700 of file unified_network.cpp. References _NamedCnx, NLNET::allstuffs, AUTOCHECK_DISPLAY, range, NLMISC::toString(), and uint16. Referenced by addService(), NLNET::uncbServiceIdentification(), and update(). { // check if not already inserted CUnifiedNetwork::TNameMappedConnection::iterator it; pair<CUnifiedNetwork::TNameMappedConnection::iterator,CUnifiedNetwork::TNameMappedConnection::iterator> range; range = _NamedCnx.equal_range(name); if (range.first != range.second) { for (it=range.first; it!=range.second && (*it).second!=sid; ++it) ; if (it != range.second) { AUTOCHECK_DISPLAY ("HNETL5: Try to add 2 times the same connection %s-%hu", name.c_str(), sid); return; } } // insert the name in the map to be able to send message with the name _NamedCnx.insert(make_pair(name, sid)); allstuffs += "+name "+name+"-"+toString(sid)+"\n"; test.displayNL ("+name %s-%hu", name.c_str (), sid); }

void NLNET::CUnifiedNetwork::addNetworkAssociation (  const std::string &  networkName, uint8  nid )

Associate a string with a network id If the send don't set a specific nid, it ll use the 0, so be sure that the nid 0 is set to a network. You must call this function before the connect() function. Parameters: networkName  must be in a xxx.xxx.xxx.xxx format. The low value will be ignore depending of the network class. nid  a number (used as an index in a vector for constant access so numbers should be contiguous) that will be use to send to this network. Definition at line 1759 of file unified_network.cpp. References _NetworkAssociations, NLNET::internalIPAddressToString(), nlinfo, NLNET::stringToInternalIPAddress(), uint16, and uint8. { if (nid >= _NetworkAssociations.size ()) _NetworkAssociations.resize (nid+1, 0xFF); _NetworkAssociations[nid] = stringToInternalIPAddress (networkName); nlinfo ("HNETL5: Associate network '%s' 0x%08x '%s' to nid %hu", networkName.c_str(), _NetworkAssociations[nid], internalIPAddressToString (_NetworkAssociations[nid]).c_str(), (uint16)nid); }

void NLNET::CUnifiedNetwork::addService (  const std::string &  name, const std::vector< CInetAddress > &  addr, bool  sendId = true, bool  external = true, uint16  sid = 0, bool  autoRetry = true, bool  shouldBeAlreayInserted = false )

Definition at line 653 of file unified_network.cpp. References _DefaultNetwork, _ExtSId, _IdCnx, _NetworkAssociations, _UsedConnection, addNamedCnx(), addr, NLNET::allstuffs, AUTOCHECK_DISPLAY, NLNET::CUnifiedNetwork::CUnifiedConnection::AutoRetry, callServiceUpCallback(), NLNET::CCallbackClient::connect(), NLNET::CUnifiedNetwork::CUnifiedConnection::Connection, NLNET::CUnifiedNetwork::CUnifiedConnection::ExtAddress, NLNET::CCallbackClient::getSockId(), NLMISC::getThreadId(), NLNET::CUnifiedNetwork::CUnifiedConnection::IsExternal, nlassert, nlassertex, nldebug, nlinfo, nlwarning, NLNET::CCallbackClient::send(), NLNET::CUnifiedNetwork::CUnifiedConnection::SendId, NLMISC::CMemStream::serial(), NLNET::CUnifiedNetwork::CUnifiedConnection::ServiceId, NLNET::CUnifiedNetwork::CUnifiedConnection::ServiceName, NLNET::CBufSock::setAppId(), NLNET::CCallbackNetBase::setDefaultCallback(), NLNET::CCallbackClient::setDisconnectionCallback(), NLNET::CUnifiedNetwork::CUnifiedConnection::setupNetworkAssociation(), NLNET::CUnifiedNetwork::CUnifiedConnection::State, NLNET::ThreadCreator, NLMISC::toString(), uint, uint16, uint8, NLNET::uncbDisconnection(), NLNET::uncbMsgProcessing(), and NLNET::vectorCInetAddressToString(). { nlassertex(_Initialised == true, ("Try to CUnifiedNetwork::addService() whereas it is not initialised yet")); if (ThreadCreator != NLMISC::getThreadId()) nlwarning ("HNETL5: Multithread access but this class is not thread safe thread creator = %u thread used = %u", ThreadCreator, NLMISC::getThreadId()); if (external) sid = _ExtSId++; nlinfo("HNETL5: addService %s-%hu '%s'", name.c_str(), sid, vectorCInetAddressToString(addr).c_str()); allstuffs += "addService "+name+"-"+toString(sid)+"\n"; test.displayNL ("+service %s-%hu", name.c_str (), (uint16)sid); if (external && addr.size () != 1) { AUTOCHECK_DISPLAY ("HNETL5: Can't add external service with more than one connection"); } // add the entry in the unified connection table if (sid >= _IdCnx.size()) _IdCnx.resize(sid+1); CUnifiedConnection *uc = &_IdCnx[sid]; // at this point it s possible that the service already added in the _IdCnx by the uNetRegistrationBroadcast() if (shouldBeAlreayInserted && _IdCnx[sid].State == CUnifiedNetwork::CUnifiedConnection::NotUsed) AUTOCHECK_DISPLAY ("HNETL5: the unified connection should already set by the naming reg broadcast and is not (%hu)", sid); if (!shouldBeAlreayInserted && _IdCnx[sid].State == CUnifiedNetwork::CUnifiedConnection::Ready) AUTOCHECK_DISPLAY ("HNETL5: the unified connection should not already set but is (%hu)", sid); if (_IdCnx[sid].State == CUnifiedNetwork::CUnifiedConnection::NotUsed) { *uc = CUnifiedConnection(name, sid, external); _UsedConnection.push_back (sid); } else { // If the entry already set, check that all is correct if (name != uc->ServiceName) AUTOCHECK_DISPLAY ("HNETL5: name are different in addService %s %s", name.c_str (), uc->ServiceName.c_str ()); if (sid != uc->ServiceId) AUTOCHECK_DISPLAY ("HNETL5: sid are different in addService %hu %hu", sid, uc->ServiceId); if (addr != uc->ExtAddress) AUTOCHECK_DISPLAY ("HNETL5: external addr are different in addService '%s' '%s'", vectorCInetAddressToString(addr).c_str(), vectorCInetAddressToString(uc->ExtAddress).c_str ()); } uc->AutoRetry = autoRetry; uc->SendId = sendId; uc->ExtAddress = addr; nlassert (!addr.empty()); // associate nid with ext address uc->setupNetworkAssociation (_NetworkAssociations, _DefaultNetwork); // connect to all connection bool connectSuccess; if (uc->Connection.size () < addr.size ()) { uc->Connection.resize (addr.size ()); } vector<CInetAddress> laddr = CInetAddress::localAddresses(); for (uint i = 0; i < addr.size(); i++) { // first we have to look if we have a network that can established the connection uint j = 0; // it s 127.0.0.1, it s ok if (!addr[i].is127001 ()) { for (j = 0; j < laddr.size (); j++) { if (laddr[j].internalNetAddress () == addr[i].internalNetAddress ()) { // it's ok, we can try break; } } // If we don't found a valid network, we'll try with the first one. // It's happen, for example, when you try to connect to a service that is not in the network but use IP translation if (j == laddr.size ()) { nlwarning ("HNETL5: I can't access '%s' because I haven't a net card on this network, we'll use the first network", addr[i].asString ().c_str ()); j = 0; } } // create a new connection with the service, setup callback and connect CCallbackClient *cbc = new CCallbackClient(); cbc->setDisconnectionCallback(uncbDisconnection, NULL); cbc->setDefaultCallback(uncbMsgProcessing); cbc->getSockId()->setAppId(sid); try { cbc->connect(addr[i]); connectSuccess = true; allstuffs += "+lconnect "+name+"-"+toString(sid)+"\n"; test.displayNL ("+lconnect %s-%hu", name.c_str (), (uint16)sid); } catch (ESocketConnectionFailed &e) { nlwarning ("HNETL5: can't connect to %s (sid %u) now (%s) '%s'", name.c_str(), sid, e.what (), addr[i].asString ().c_str()); connectSuccess = false; allstuffs += "+lconnect failed "+name+"-"+toString((uint16)sid)+"\n"; test.displayNL ("+lconnect failed %s-%hu", name.c_str (), (uint16)sid); } if (!connectSuccess && !autoRetry) { nlwarning ("HNETL5: Can't add service because no retry and can't connect"); delete cbc; } else { uc->Connection[i] = CUnifiedNetwork::CUnifiedConnection::TConnection(cbc); // nlinfo ("HNETL5: %s", allstuffs.c_str ()); } if (connectSuccess && sendId) { // send identification to the service CMessage msg("UN_SIDENT"); msg.serial(_Name); uint16 ssid = _SId; if (uc->IsExternal) { // in the case that the service is external, we can't send our sid because the external service can // have other connectin with the same sid (for example, LS can have 2 WS with same sid => sid = 0 and leave // the other side to find a good number ssid = 0; } msg.serial(ssid); // serializes a 16 bits service id uint8 pos = j; msg.serial(pos); // send the position in the connection table msg.serial (uc->IsExternal); cbc->send (msg); } } if (addr.size () != uc->Connection.size()) { nlwarning ("HNETL5: Can't connect to all connections to the service %d/%d", addr.size (), uc->Connection.size()); } bool cntok = false; for (uint j = 0; j < uc->Connection.size(); j++) { if (uc->Connection[j].CbNetBase != NULL) { if (uc->Connection[j].CbNetBase->connected ()) { cntok = true; break; } } } if (cntok) { // add the name only if at least one connection is ok addNamedCnx (name, sid); callServiceUpCallback (name, sid, !external); /* // call the connection callback associated to this service TNameMappedCallback::iterator itcb = _UpCallbacks.find(name); if (itcb != _UpCallbacks.end()) { for (list<TCallbackArgItem> it2 = (*itcb).second.begin(); it2 != (*itcb).second.end(); it2++) { TUnifiedNetCallback cb = (*it2).first; if (cb) cb(name, sid, (*it2).second); } } if (!external) { for (uint i = 0; i < _UpUniCallback.size (); i++) { if (_UpUniCallback[i].first != NULL) _UpUniCallback[i].first (name, sid, _UpUniCallback[i].second); } } */ } nldebug ("HNETL5: addService was successful"); }

void NLNET::CUnifiedNetwork::addService (  const std::string &  name, const CInetAddress &  addr, bool  sendId = true, bool  external = true, uint16  sid = 0, bool  autoRetry = true, bool  shouldBeAlreayInserted = false )

Adds a specific service to the list of connected services. Definition at line 646 of file unified_network.cpp. References addr, and uint16. Referenced by connect(). { vector <CInetAddress> addrs; addrs.push_back (addr); addService (name, addrs, sendId, external, sid, autoRetry, shouldBeAlreayInserted); }

void NLNET::CUnifiedNetwork::autoCheck (   )  [private]

Definition at line 1517 of file unified_network.cpp. References _IdCnx, _NamedCnx, _NetworkAssociations, _UsedConnection, AUTOCHECK_DISPLAY, H_AUTO, NL_I64, and uint. Referenced by update(). { H_AUTO(L5UpdateAutoCheck); uint i, j; for (i = 0; i < _IdCnx.size (); i++) { if (_IdCnx[i].State == CUnifiedNetwork::CUnifiedConnection::Ready) { _IdCnx[i].AutoCheck = 1; } else { _IdCnx[i].AutoCheck = 0; } } TNameMappedConnection::iterator itn; for (itn = _NamedCnx.begin(); itn != _NamedCnx.end(); ++itn) { if ((*itn).first != _IdCnx[(*itn).second].ServiceName) AUTOCHECK_DISPLAY ("HLNET5: problem with name syncro between _NameCnx and _IdCnx '%s' '%s' '%d'", (*itn).first.c_str(), _IdCnx[(*itn).second].ServiceName.c_str (), (*itn).second); if (_IdCnx[(*itn).second].AutoCheck == 0) AUTOCHECK_DISPLAY ("HLNET5: problem with name syncro between _NameCnx '%s' and _IdCnx '%s' '%d'", (*itn).first.c_str(), _IdCnx[(*itn).second].ServiceName.c_str (), (*itn).second); if (_IdCnx[(*itn).second].AutoCheck > 1) AUTOCHECK_DISPLAY ("HLNET5: problem with name syncro between _NameCnx and _IdCnx '%s' '%d' more than one entry in named with the same name", (*itn).first.c_str(), _IdCnx[(*itn).second].ServiceName.c_str (),(*itn).second); _IdCnx[(*itn).second].AutoCheck++; } for (i = 0; i < _UsedConnection.size (); i++) { if (_IdCnx[_UsedConnection[i]].State != CUnifiedNetwork::CUnifiedConnection::Ready) AUTOCHECK_DISPLAY ("HLNET5: problem with the _UsedConnection syncro sid %d is not used in _IdCnx", _UsedConnection[i]); } for (i = 0; i < _IdCnx.size (); i++) { if (_IdCnx[i].State == CUnifiedNetwork::CUnifiedConnection::Ready) { for (j = 0; j < _UsedConnection.size (); j++) { if (_UsedConnection[j] == i) break; } if (j == _UsedConnection.size ()) AUTOCHECK_DISPLAY ("HLNET5: problem with the _UsedConnection syncro sid %d is not in _UsedConnection", i); } } for (i = 0; i < _IdCnx.size (); i++) { if (_IdCnx[i].State == CUnifiedNetwork::CUnifiedConnection::NotUsed) { if (_IdCnx[i].ServiceName != "DEAD") AUTOCHECK_DISPLAY ("HLNET5: sid %d name should be DEAD and is '%s'", i, _IdCnx[i].ServiceName.c_str ()); if (_IdCnx[i].ServiceId != 0xDEAD) AUTOCHECK_DISPLAY ("HLNET5: sid %d sid should be 0xDEAD and is 0x%X", i, _IdCnx[i].ServiceId); if (!_IdCnx[i].Connection.empty ()) AUTOCHECK_DISPLAY ("HLNET5: sid %d connection size should be 0 and is %d", i, _IdCnx[i].Connection.size ()); if (!_IdCnx[i].ExtAddress.empty ()) AUTOCHECK_DISPLAY ("HLNET5: sid %d ext addr size should be 0 and is %d", i, _IdCnx[i].ExtAddress.size ()); if (_IdCnx[i].AutoCheck != 0) AUTOCHECK_DISPLAY ("HLNET5: sid %d prob with syncro with _NamedCnx", i); } else if (_IdCnx[i].State == CUnifiedNetwork::CUnifiedConnection::Ready) { if (_IdCnx[i].ServiceId != i) AUTOCHECK_DISPLAY ("HNETL5: Bad syncro sid index sid entry for %d %d", i, _IdCnx[i].ServiceId); if (_IdCnx[i].ServiceName == "DEAD") AUTOCHECK_DISPLAY ("HLNET5: sid %d name should not be DEAD and is '%s'", i, _IdCnx[i].ServiceName.c_str ()); if (_IdCnx[i].ServiceId == 0xDEAD) AUTOCHECK_DISPLAY ("HLNET5: sid %d sid should not be 0xDEAD and is 0x%X", i, _IdCnx[i].ServiceId); if (!_IdCnx[i].ExtAddress.empty () && _IdCnx[i].Connection.size () > _IdCnx[i].ExtAddress.size()) AUTOCHECK_DISPLAY ("HLNET5: sid %d ext addr size should not be 0 and is %d", i, _IdCnx[i].ExtAddress.size ()); if (_IdCnx[i].AutoRetry == true && _IdCnx[i].Connection.size () > 1) AUTOCHECK_DISPLAY ("HLNET5: sid %d auto retry with more than one connection %d", i, _IdCnx[i].Connection.size ()); if (_IdCnx[i].AutoRetry == true && _IdCnx[i].IsExternal == false) AUTOCHECK_DISPLAY ("HLNET5: sid %d auto retry with internal connection", i); if (_IdCnx[i].AutoRetry == true && _IdCnx[i].Connection[0].valid() == false) AUTOCHECK_DISPLAY ("HLNET5: sid %d auto retry with invalid connection", i); for (j = 0; j < _IdCnx[i].Connection.size (); j++) { if (_IdCnx[i].Connection[j].valid() && !_IdCnx[i].Connection[j].IsServerConnection && _IdCnx[i].Connection[j].CbNetBase->connected () && _IdCnx[i].Connection[j].getAppId() != i) AUTOCHECK_DISPLAY ("HLNET5: sid %d bad appid %"NL_I64"X", i, _IdCnx[i].Connection[j].getAppId()); } for (j = 0; j < _IdCnx[i].NetworkConnectionAssociations.size (); j++) { if (_IdCnx[i].NetworkConnectionAssociations[j] != 0) { if (_NetworkAssociations[j] != _IdCnx[i].ExtAddress[_IdCnx[i].NetworkConnectionAssociations[j]].internalNetAddress ()) AUTOCHECK_DISPLAY ("HLNET5: sid %d nid %d have address 0x%08x and is not the good connection net 0x%08x", i, j, _NetworkAssociations[j], _IdCnx[i].ExtAddress[_IdCnx[i].NetworkConnectionAssociations[j]].internalNetAddress ()); } } } } }

void NLNET::CUnifiedNetwork::callServiceDownCallback (  const std::string &  serviceName, uint16  sid, bool  callGlobalCallback = true )  [private]

Definition at line 1797 of file unified_network.cpp. References _DownCallbacks, _DownUniCallback, nlwarning, NLNET::TUnifiedNetCallback, uint, and uint16. Referenced by NLNET::uncbDisconnection(), and NLNET::uNetUnregistrationBroadcast(). { // now we warn the user CUnifiedNetwork::TNameMappedCallback::iterator it = _DownCallbacks.find(serviceName); if (it != _DownCallbacks.end()) { // call it for (list<TCallbackArgItem>::iterator it2 = (*it).second.begin(); it2 != (*it).second.end(); it2++) { TUnifiedNetCallback cb = (*it2).first; if (cb) cb(serviceName, sid, (*it2).second); else nlwarning ("HNETL5: User set an empty callback for '%s' service down", serviceName.c_str()); } } if(callGlobalCallback) { for (uint c = 0; c < _DownUniCallback.size (); c++) { if (_DownUniCallback[c].first != NULL) _DownUniCallback[c].first (serviceName, sid, _DownUniCallback[c].second); else nlwarning ("HNETL5: User set an empty callback for '*' service down"); } } }

void NLNET::CUnifiedNetwork::callServiceUpCallback (  const std::string &  serviceName, uint16  sid, bool  callGlobalCallback = true )  [private]

Definition at line 1768 of file unified_network.cpp. References _UpCallbacks, _UpUniCallback, nlwarning, NLNET::TUnifiedNetCallback, uint, and uint16. Referenced by addService(), NLNET::uncbServiceIdentification(), and update(). { // now we warn the user CUnifiedNetwork::TNameMappedCallback::iterator it = _UpCallbacks.find(serviceName); if (it != _UpCallbacks.end()) { // call it for (list<TCallbackArgItem>::iterator it2 = (*it).second.begin(); it2 != (*it).second.end(); it2++) { TUnifiedNetCallback cb = (*it2).first; if (cb) cb(serviceName, sid, (*it2).second); else nlwarning ("HNETL5: User set an empty callback for '%s' service up", serviceName.c_str()); } } if(callGlobalCallback) { for (uint c = 0; c < _UpUniCallback.size (); c++) { if (_UpUniCallback[c].first != NULL) _UpUniCallback[c].first (serviceName, sid, _UpUniCallback[c].second); else nlwarning ("HNETL5: User set an empty callback for '*' service up"); } } }

void NLNET::CUnifiedNetwork::clearDefaultNetwork (   )  [inline]

Clear all default network. Definition at line 187 of file unified_network.h. References _DefaultNetwork. { _DefaultNetwork.clear (); }

void NLNET::CUnifiedNetwork::clearNetworkAssociation (   )  [inline]

Clear all network association Definition at line 175 of file unified_network.h. References _NetworkAssociations. { _NetworkAssociations.clear (); }

void NLNET::CUnifiedNetwork::connect (   )

Registers to the Naming Service, and connects to the present services Definition at line 566 of file unified_network.cpp. References addService(), NLMISC::getThreadId(), nlassertex, nlwarning, and NLNET::ThreadCreator. { nlassertex(_Initialised == true, ("Try to CUnifiedNetwork::connect() whereas it is not initialised yet")); if (ThreadCreator != NLMISC::getThreadId()) nlwarning ("HNETL5: Multithread access but this class is not thread safe thread creator = %u thread used = %u", ThreadCreator, NLMISC::getThreadId()); if (CNamingClient::connected()) { // get the services list const list<CNamingClient::CServiceEntry> &services = CNamingClient::getRegisteredServices(); // connects to the registered services list<CNamingClient::CServiceEntry>::const_iterator its; // don't connect to itself for (its = services.begin(); its != services.end(); ++its) { if (_SId != (*its).SId) { // add service with name, address, ident, not external, service id, and not autoretry (obsolete) // we put the last true because the name callback should already inserted it by uNetRegistrationBroadcast() addService((*its).Name, (*its).Addr, true, false, (*its).SId, false, true); } else { // don't process services received after mine because they'll connect to me break; } } } }

void NLNET::CUnifiedNetwork::displayInternalTables (  NLMISC::CLog *  log = NLMISC::InfoLog  )

Definition at line 1599 of file unified_network.cpp. References _IdCnx, _NamedCnx, _NetworkAssociations, _UsedConnection, NLMISC::CLog::displayNL(), NLNET::internalIPAddressToString(), uint, and uint16. Referenced by NLNET::NLMISC_COMMAND(). { uint i, j; log->displayNL ("%d Named Connections:", _NamedCnx.size ()); for (TNameMappedConnection::iterator it = _NamedCnx.begin(); it != _NamedCnx.end (); it++) { log->displayNL ("> '%s' -> %hu", (*it).first.c_str(), (*it).second); } uint nbused = 0; for (i = 0; i < _IdCnx.size (); i++) { if(_IdCnx[i].State != CUnifiedNetwork::CUnifiedConnection::NotUsed) nbused++; } log->displayNL ("%u/%u Unified Connections:", nbused, _IdCnx.size ()); for (i = 0; i < _IdCnx.size (); i++) { if(_IdCnx[i].State != CUnifiedNetwork::CUnifiedConnection::NotUsed) { /* log->displayNL ("> %s-%hu %s %s %s (%d extaddr %d cnx) tcbc %d", _IdCnx[i].ServiceName.c_str (), _IdCnx[i].ServiceId, _IdCnx[i].IsExternal?"ext":"int", _IdCnx[i].AutoRetry?"autoretry":"noautoretry", _IdCnx[i].SendId?"sendid":"nosendid", _IdCnx[i].ExtAddress.size (), _IdCnx[i].Connection.size (), _IdCnx[i].TotalCallbackCalled); uint maxc = _IdCnx[i].Connection.size (); if(_IdCnx[i].Connection.size () <= _IdCnx[i].ExtAddress.size ()) maxc = _IdCnx[i].ExtAddress.size (); for (j = 0; j < maxc; j++) { string base; if(j < _IdCnx[i].ExtAddress.size ()) { base += _IdCnx[i].ExtAddress[j].asString (); } else { base += "notvalid"; } string ext; if(j < _IdCnx[i].Connection.size () && _IdCnx[i].Connection[j].valid()) { if(_IdCnx[i].Connection[j].IsServerConnection) { ext += "server "; } else { ext += "client "; } ext += _IdCnx[i].Connection[j].CbNetBase->getSockId (_IdCnx[i].Connection[j].HostId)->asString (); ext += " appid:" + toString(_IdCnx[i].Connection[j].getAppId()); if (_IdCnx[i].Connection[j].CbNetBase->connected ()) ext += " connected"; else ext += " notconnected"; } else { ext += "notvalid"; } log->displayNL (" - %s %s", base.c_str (), ext.c_str ()); }*/ _IdCnx[i].display (false, log); for (j = 0; j < _IdCnx[i].NetworkConnectionAssociations.size (); j++) { log->displayNL (" * nid %d -> cnxn %hu", j, (uint16)_IdCnx[i].NetworkConnectionAssociations[j]); } } } log->displayNL ("%u Used Unified Connections:", _UsedConnection.size()); for (i = 0; i < _UsedConnection.size (); i++) { log->displayNL ("> %hu", _UsedConnection[i]); } log->displayNL ("%u Network Associations:", _NetworkAssociations.size()); for (i = 0; i < _NetworkAssociations.size (); i++) { log->displayNL ("> 0x%08x -> '%s'", _NetworkAssociations[i], internalIPAddressToString (_NetworkAssociations[i]).c_str ()); } }

void NLNET::CUnifiedNetwork::displayUnifiedConnection (  uint16  sid, NLMISC::CLog *  log = NLMISC::InfoLog )  [inline]

Definition at line 231 of file unified_network.h. References NLNET::CUnifiedNetwork::CUnifiedConnection::display(), getUnifiedConnection(), and uint16. { getUnifiedConnection(sid)->display(false, log); }

TUnifiedMsgCallback NLNET::CUnifiedNetwork::findCallback (  const std::string &  callbackName  )

Find a callback in the array. Definition at line 1393 of file unified_network.cpp. References _Callbacks, and NLNET::TUnifiedMsgCallback. Referenced by NLNET::NLMISC_COMMAND(). { TMsgMappedCallback::iterator itcb = _Callbacks.find(callbackName); if (itcb == _Callbacks.end()) return NULL; else return (*itcb).second; }

uint8 NLNET::CUnifiedNetwork::findConnectionId (  uint16  sid, uint8  nid )  [private]

Definition at line 1030 of file unified_network.cpp. References _IdCnx, nlwarning, uint16, and uint8. Referenced by getNetBase(), send(), and sendAll(). { if (_IdCnx[sid].Connection.size () == 0) { nlwarning ("HNETL5: Can't send message to %s because no connection are available", _IdCnx[sid].ServiceName.c_str ()); return 0xFF; } // by default, connection id will be the default one uint8 connectionId = _IdCnx[sid].DefaultNetwork; if (nid == 0xFF) { // it s often appen because they didn't set a good network configuration, so it s in debug to disable it easily //nldebug ("HNETL5: nid %hu, will use the default connection %hu", (uint16)nid, (uint16)connectionId); } else if (nid >= _IdCnx[sid].NetworkConnectionAssociations.size()) { nlwarning ("HNETL5: No net association for nid %hu, use the default connection %hu", (uint16)nid, (uint16)connectionId); } else { if (_IdCnx[sid].NetworkConnectionAssociations[nid] >= _IdCnx[sid].Connection.size ()) { nlwarning ("HNETL5: Can't send message to %s because nid %d point on a bad connection (%d and only have %d cnx), use default connection", _IdCnx[sid].ServiceName.c_str (), nid, connectionId, _IdCnx[sid].Connection.size ()); } else { connectionId = _IdCnx[sid].NetworkConnectionAssociations[nid]; } } if (connectionId >= _IdCnx[sid].Connection.size() || !_IdCnx[sid].Connection[connectionId].valid() || !_IdCnx[sid].Connection[connectionId].CbNetBase->connected()) { // there's a problem with the selected connectionID, so try to find a valid one nlwarning ("HNETL5: Can't find selected connection id %hu to send message to %s because connection is not valid or connected, find a valid connection id", (uint16)connectionId, _IdCnx[sid].ServiceName.c_str ()); for (connectionId = 0; connectionId < _IdCnx[sid].Connection.size(); connectionId++) { if (_IdCnx[sid].Connection[connectionId].valid() && _IdCnx[sid].Connection[connectionId].CbNetBase->connected()) { // we found one at last, use this one //nldebug ("HNETL5: Ok, we found a valid connectionid, use %hu", (uint16)connectionId); break; } } if (connectionId == _IdCnx[sid].Connection.size()) { nlwarning ("HNETL5: Can't send message to %s because default connection is not exist, valid or connected", _IdCnx[sid].ServiceName.c_str ()); return 0xFF; } } return connectionId; }

uint64 NLNET::CUnifiedNetwork::getBytesReceived (   )

Gets the total number of bytes received. Definition at line 1263 of file unified_network.cpp. References _CbServer, _IdCnx, _UsedConnection, NLNET::CCallbackNetBase::getBytesReceived(), uint, and uint64. Referenced by NLNET::NLMISC_DYNVARIABLE(). { uint64 received = 0; uint j; for (vector<uint16>::iterator it = _UsedConnection.begin (); it != _UsedConnection.end(); it++) { if (_IdCnx[(*it)].State == CUnifiedNetwork::CUnifiedConnection::Ready) for (j=0; j<_IdCnx[(*it)].Connection.size (); ++j) if(_IdCnx[(*it)].Connection[j].valid () && !_IdCnx[(*it)].Connection[j].IsServerConnection) received += _IdCnx[(*it)].Connection[j].CbNetBase->getBytesReceived(); } /* for (i=0; i<_IdCnx.size(); ++i) if (_IdCnx[i].State == CUnifiedNetwork::CUnifiedConnection::Ready) for (j=0; j<_IdCnx[i].Connection.size (); ++j) if(_IdCnx[i].Connection[j].valid () && !_IdCnx[i].Connection[j].IsServerConnection) received += _IdCnx[i].Connection[j].CbNetBase->getBytesReceived(); */ if (_CbServer) received += _CbServer->getBytesReceived(); return received; }

uint64 NLNET::CUnifiedNetwork::getBytesSent (   )

Gets the total number of bytes sent. Definition at line 1239 of file unified_network.cpp. References _CbServer, _IdCnx, _UsedConnection, NLNET::CCallbackNetBase::getBytesSent(), uint, and uint64. Referenced by NLNET::NLMISC_DYNVARIABLE(). { uint64 sent = 0; uint j; for (vector<uint16>::iterator it = _UsedConnection.begin (); it != _UsedConnection.end(); it++) { if (_IdCnx[(*it)].State == CUnifiedNetwork::CUnifiedConnection::Ready) for (j=0; j<_IdCnx[(*it)].Connection.size (); ++j) if(_IdCnx[(*it)].Connection[j].valid () && !_IdCnx[(*it)].Connection[j].IsServerConnection) sent += _IdCnx[(*it)].Connection[j].CbNetBase->getBytesSent(); } /* for (i=0; i<_IdCnx.size(); ++i) if (_IdCnx[i].State == CUnifiedNetwork::CUnifiedConnection::Ready) for (j=0; j<_IdCnx[i].Connection.size (); ++j) if(_IdCnx[i].Connection[j].valid () && !_IdCnx[i].Connection[j].IsServerConnection) sent += _IdCnx[i].Connection[j].CbNetBase->getBytesSent(); */ if(_CbServer) sent += _CbServer->getBytesSent(); return sent; }

const std::vector<uint16>& NLNET::CUnifiedNetwork::getConnectionList (   )  const [inline]

Return the service ids of the active connections. Definition at line 227 of file unified_network.h. References _UsedConnection. { return _UsedConnection; }

CUnifiedNetwork * NLNET::CUnifiedNetwork::getInstance (   )  [static]

Returns the singleton instance of the CUnifiedNetwork class. Definition at line 1481 of file unified_network.cpp. References CUnifiedNetwork(). Referenced by NLNET::IService::main(). { if (_Instance == NULL) _Instance = new CUnifiedNetwork(); return _Instance; }

CCallbackNetBase * NLNET::CUnifiedNetwork::getNetBase (  uint16  sid, TSockId &  host, uint8  nid = 0xFF )

Gets the CCallbackNetBase of the service. Definition at line 1368 of file unified_network.cpp. References _IdCnx, findConnectionId(), NLMISC::getThreadId(), nlassertex, nlwarning, NLNET::ThreadCreator, NLNET::TSockId, uint16, and uint8. { nlassertex(_Initialised == true, ("Try to CUnifiedNetwork::getNetBase() whereas it is not initialised yet")); if (ThreadCreator != NLMISC::getThreadId()) nlwarning ("HNETL5: Multithread access but this class is not thread safe thread creator = %u thread used = %u", ThreadCreator, NLMISC::getThreadId()); if (sid >= _IdCnx.size () || _IdCnx[sid].State != CUnifiedNetwork::CUnifiedConnection::Ready) { nlwarning ("HNETL5: Can't get net base to the service '%hu' because not in _IdCnx", sid); host = InvalidSockId; return NULL; } uint8 connectionId = findConnectionId (sid, nid); if (connectionId == 0xff) // failed { nlwarning ("HNETL5: Can't getNetBase %hu because no connection available", sid); host = InvalidSockId; return NULL; } host = _IdCnx[sid].Connection[connectionId].HostId; return _IdCnx[sid].Connection[connectionId].CbNetBase; }

CCallbackNetBase * NLNET::CUnifiedNetwork::getNetBase (  const std::string &  name, TSockId &  host, uint8  nid = 0xFF )

Gets the CCallbackNetBase of the service. Warning: You should not use getNetBase functions because it could have more than one connection to a service and in this case it ll return the first connection Definition at line 1335 of file unified_network.cpp. References _IdCnx, _NamedCnx, count, findConnectionId(), NLMISC::getThreadId(), nlassertex, nlwarning, sint, NLNET::ThreadCreator, NLNET::TSockId, and uint8. Referenced by NLNET::NLMISC_COMMAND(). { nlassertex(_Initialised == true, ("Try to CUnifiedNetwork::getNetBase() whereas it is not initialised yet")); if (ThreadCreator != NLMISC::getThreadId()) nlwarning ("HNETL5: Multithread access but this class is not thread safe thread creator = %u thread used = %u", ThreadCreator, NLMISC::getThreadId()); sint count = _NamedCnx.count(name); if (count <= 0) { nlwarning ("HNETL5: couldn't access the service %s", name.c_str()); host = InvalidSockId; return NULL; } else if (count > 1) { nlwarning ("HNETL5: %d services %s to getNetBase, returns the first valid", count, name.c_str()); } TNameMappedConnection::const_iterator itnmc = _NamedCnx.find(name); uint8 connectionId = findConnectionId ((*itnmc).second, nid); if (connectionId == 0xff) // failed { nlwarning ("HNETL5: Can't getNetBase %s because no connection available", name.c_str()); host = InvalidSockId; return NULL; } host = _IdCnx[(*itnmc).second].Connection[connectionId].HostId; return _IdCnx[(*itnmc).second].Connection[connectionId].CbNetBase; }

uint64 NLNET::CUnifiedNetwork::getReceiveQueueSize (   )

Gets the total number of bytes queued after receiving. Definition at line 1311 of file unified_network.cpp. References _CbServer, _IdCnx, _UsedConnection, NLNET::CCallbackServer::getReceiveQueueSize(), uint, and uint64. Referenced by NLNET::NLMISC_DYNVARIABLE(). { uint64 received = 0; uint j; for (vector<uint16>::iterator it = _UsedConnection.begin (); it != _UsedConnection.end(); it++) { if (_IdCnx[(*it)].State == CUnifiedNetwork::CUnifiedConnection::Ready) for (j=0; j<_IdCnx[(*it)].Connection.size (); ++j) if(_IdCnx[(*it)].Connection[j].valid () && !_IdCnx[(*it)].Connection[j].IsServerConnection) received += _IdCnx[(*it)].Connection[j].CbNetBase->getReceiveQueueSize(); } /* for (i=0; i<_IdCnx.size(); ++i) if (_IdCnx[i].State == CUnifiedNetwork::CUnifiedConnection::Ready) for (j=0; j<_IdCnx[i].Connection.size (); ++j) if(_IdCnx[i].Connection[j].valid () && !_IdCnx[i].Connection[j].IsServerConnection) received += _IdCnx[i].Connection[j].CbNetBase->getReceiveQueueSize(); */ if (_CbServer) received += _CbServer->getReceiveQueueSize(); return received; }

uint64 NLNET::CUnifiedNetwork::getSendQueueSize (   )

Gets the total number of bytes queued for sending. Definition at line 1287 of file unified_network.cpp. References _CbServer, _IdCnx, _UsedConnection, NLNET::CCallbackServer::getSendQueueSize(), uint, and uint64. Referenced by NLNET::NLMISC_DYNVARIABLE(). { uint64 sent = 0; uint j; for (vector<uint16>::iterator it = _UsedConnection.begin (); it != _UsedConnection.end(); it++) { if (_IdCnx[(*it)].State == CUnifiedNetwork::CUnifiedConnection::Ready) for (j=0; j<_IdCnx[(*it)].Connection.size (); ++j) if(_IdCnx[(*it)].Connection[j].valid () && !_IdCnx[(*it)].Connection[j].IsServerConnection) sent += _IdCnx[(*it)].Connection[j].CbNetBase->getSendQueueSize(); } /* for (i=0; i<_IdCnx.size(); ++i) if (_IdCnx[i].State == CUnifiedNetwork::CUnifiedConnection::Ready) for (j=0; j<_IdCnx[i].Connection.size (); ++j) if(_IdCnx[i].Connection[j].valid () && !_IdCnx[i].Connection[j].IsServerConnection) sent += _IdCnx[i].Connection[j].CbNetBase->getSendQueueSize(); */ if (_CbServer) sent += _CbServer->getSendQueueSize(); return sent; }

std::string NLNET::CUnifiedNetwork::getServiceName (  uint16  sid  )

Return the name of the specified service, or "" if not found. Definition at line 1451 of file unified_network.cpp. References getUnifiedConnection(), s, NLNET::CUnifiedNetwork::CUnifiedConnection::ServiceName, and uint16. { string s; CUnifiedConnection *c = getUnifiedConnection(sid, false); if (c) s = c->ServiceName; return s; }

std::string NLNET::CUnifiedNetwork::getServiceUnifiedName (  uint16  sid  )

Return a string identifying the service, using the format "NAME-sid" (or "sid" only if not found). Definition at line 1464 of file unified_network.cpp. References getUnifiedConnection(), s, NLNET::CUnifiedNetwork::CUnifiedConnection::ServiceName, NLMISC::toString(), and uint16. { string s; CUnifiedConnection *c = getUnifiedConnection(sid, false); if (c) s = c->ServiceName + "-"; s += toString(sid); return s; }

CUnifiedNetwork::CUnifiedConnection * NLNET::CUnifiedNetwork::getUnifiedConnection (  uint16  sid, bool  warn = true )  [private]

Definition at line 1498 of file unified_network.cpp. References _IdCnx, AUTOCHECK_DISPLAY, nlwarning, and uint16. Referenced by displayUnifiedConnection(), getServiceName(), getServiceUnifiedName(), NLNET::uncbDisconnection(), NLNET::uncbMsgProcessing(), and NLNET::uNetUnregistrationBroadcast(). { if (sid < _IdCnx.size () && _IdCnx[sid].State == CUnifiedConnection::Ready) { if (sid != _IdCnx[sid].ServiceId) { AUTOCHECK_DISPLAY ("HNETL5: Sid index %hu is not the same that in the entry %hu", sid, _IdCnx[sid].ServiceId); return NULL; } return &_IdCnx[sid]; } else { if ( warn ) nlwarning ("HNETL5: Try to get a bad unified connection (sid %hu is not in the table)", sid); return NULL; } }

bool NLNET::CUnifiedNetwork::haveNamedCnx (  const std::string &  name, uint16  sid )  [private]

Definition at line 1684 of file unified_network.cpp. References _NamedCnx, range, and uint16. Referenced by update(). { CUnifiedNetwork::TNameMappedConnection::iterator it; pair<CUnifiedNetwork::TNameMappedConnection::iterator,CUnifiedNetwork::TNameMappedConnection::iterator> range; range = _NamedCnx.equal_range(name); if (range.first != range.second) { for (it=range.first; it!=range.second && (*it).second!=sid; ++it) ; return (it != range.second); } return false; }

bool NLNET::CUnifiedNetwork::init (  const CInetAddress *  addr, CCallbackNetBase::TRecordingState  rec, const std::string &  shortName, uint16  port, TServiceId &  sid )

Creates the connection to the Naming Service. If the connection failed, ESocketConnectionFailed exception is generated. This function is called automatically called by the service class at the beginning. Parameters: addr  address of the naming service (0 is you don't want to use the naming service) rec  recording state to know if we have to record or replay messages Returns: false if the instance startup was denied by the naming service Definition at line 479 of file unified_network.cpp. References _CbServer, _NamingServiceAddr, _ServerPort, NLNET::CCallbackNetBase::addCallbackArray(), addr, AUTOCHECK_DISPLAY, NLNET::fd, NLMISC::getThreadId(), NLNET::CBufServer::init(), NLNET::CInetAddress::isValid(), nlassert, nlinfo, NLNET::CCallbackServer::setConnectionCallback(), NLNET::CCallbackNetBase::setDefaultCallback(), NLNET::CCallbackServer::setDisconnectionCallback(), NLMISC::CFileDisplayer::setParam(), NLNET::ThreadCreator, NLMISC::toString(), NLNET::TServiceId, uint, uint16, NLNET::uncbConnection(), NLNET::uncbDisconnection(), NLNET::uncbMsgProcessing(), NLNET::uNetRegistrationBroadcast(), NLNET::uNetUnregistrationBroadcast(), and NLNET::unServerCbArray. { //DebugLog->addNegativeFilter ("HNETL5"); if (_Initialised) { AUTOCHECK_DISPLAY ("HNETL5: Unified network layer already initialized"); return true; } ThreadCreator = NLMISC::getThreadId(); vector<CInetAddress> laddr = CInetAddress::localAddresses(); _RecordingState = rec; _Name = shortName; _SId = sid; if (addr != 0) _NamingServiceAddr = *addr; // if the address isn't 0, uses the naming service if (_NamingServiceAddr.isValid ()) { // connect the callback to know when a new service comes in or goes down CNamingClient::setRegistrationBroadcastCallback(uNetRegistrationBroadcast); CNamingClient::setUnregistrationBroadcastCallback(uNetUnregistrationBroadcast); // connect to the naming service (may generate a ESocketConnectionFailed exception) CNamingClient::connect(_NamingServiceAddr, _RecordingState, laddr); if (port == 0) port = CNamingClient::queryServicePort (); } // setup the server callback only if server port != 0, otherwise there's no server callback _ServerPort = port; if(_ServerPort != 0) { nlassert (_CbServer == 0); _CbServer = new CCallbackServer; _CbServer->init(port); _CbServer->addCallbackArray(unServerCbArray, 1); // the service ident callback _CbServer->setDefaultCallback(uncbMsgProcessing); // the default callback wrapper _CbServer->setConnectionCallback(uncbConnection, NULL); _CbServer->setDisconnectionCallback(uncbDisconnection, NULL); } else { nlinfo ("HNETL5: ServerPort is 0 so I don't create a CCallbackServer"); } if (CNamingClient::connected()) { // register the service for (uint i = 0; i < laddr.size(); i++) laddr[i].setPort(_ServerPort); if (_SId == 0) { if ( ! CNamingClient::registerService(_Name, laddr, _SId) ) { nlinfo ("HNETL5: Registration denied"); return false; } } else { CNamingClient::registerServiceWithSId(_Name, laddr, _SId); } sid = _SId; nlinfo ("HNETL5: Server '%s' added, registered and listen to port %hu", _Name.c_str (), _ServerPort); } string fn = _Name+"_"+toString(_SId)+".log"; fd.setParam (fn); test.addDisplayer (&fd); test.displayNL ("**************INIT***************"); _Initialised = true; return true; }

bool NLNET::CUnifiedNetwork::isServiceLocal (  const std::string &  serviceName  )

Returns true if the serviceName service is on the same computer than this service. Definition at line 1402 of file unified_network.cpp. References _NamedCnx, isServiceLocal(), range, and uint16. { // it s me, of course we are local if (serviceName == _Name) return true; pair<TNameMappedConnection::const_iterator,TNameMappedConnection::const_iterator> range; range = _NamedCnx.equal_range(serviceName); if (range.first != _NamedCnx.end()) { uint16 sid = (*(range.first)).second; return isServiceLocal (sid); } return false; }

bool NLNET::CUnifiedNetwork::isServiceLocal (  uint16  sid  )

Returns true if the sid service is on the same computer than this service. Definition at line 1420 of file unified_network.cpp. References _IdCnx, uint, and uint16. Referenced by isServiceLocal(), and NLNET::NLMISC_COMMAND(). { // it s me, of course we are local if (sid == _SId) return true; if (sid >= _IdCnx.size () || _IdCnx[sid].State != CUnifiedNetwork::CUnifiedConnection::Ready) { return false; } vector<CInetAddress> laddr = CInetAddress::localAddresses(); for (uint i = 0; i < laddr.size(); i++) { for (uint j = 0; j < _IdCnx[sid].ExtAddress.size(); j++) { if (_IdCnx[sid].ExtAddress[j].is127001 ()) return true; if (_IdCnx[sid].ExtAddress[j].internalIPAddress () == laddr[i].internalIPAddress ()) return true; } } return false; }

bool NLNET::CUnifiedNetwork::isUsed (   )  [static]

Returns true if the application called getInstance(). This function is used to know if the user is using layer 4 or layer 5 Definition at line 1489 of file unified_network.cpp. { return (_Instance != NULL); }

void NLNET::CUnifiedNetwork::release (   )

Closes the connection to the naming service, every other connection and free. Definition at line 599 of file unified_network.cpp. References _Callbacks, _CbServer, _DownCallbacks, _IdCnx, _NamedCnx, _UpCallbacks, _UsedConnection, NLNET::CCallbackServer::disconnect(), NLMISC::getThreadId(), nlwarning, NLNET::ThreadCreator, and uint. { if (!_Initialised) return; if (ThreadCreator != NLMISC::getThreadId()) nlwarning ("HNETL5: Multithread access but this class is not thread safe thread creator = %u thread used = %u", ThreadCreator, NLMISC::getThreadId()); // disconnect all clients if(_CbServer) { _CbServer->disconnect(InvalidSockId); delete _CbServer; _CbServer = 0; } // disconnect all connections to servers for (uint i = 0; i<_IdCnx.size(); ++i) { if (_IdCnx[i].State != CUnifiedNetwork::CUnifiedConnection::NotUsed) { for(uint j = 0 ; j < _IdCnx[i].Connection.size (); j++) { if (_IdCnx[i].Connection[j].valid() && !_IdCnx[i].Connection[j].IsServerConnection) { if (_IdCnx[i].Connection[j].CbNetBase->connected ()) _IdCnx[i].Connection[j].CbNetBase->disconnect(); delete _IdCnx[i].Connection[j].CbNetBase; } } _IdCnx[i].Connection.clear (); } } // clear all other data _IdCnx.clear(); _UsedConnection.clear (); _NamedCnx.clear(); _UpCallbacks.clear(); _DownCallbacks.clear(); _Callbacks.clear(); // disconnect the connection with the naming service if (CNamingClient::connected ()) CNamingClient::disconnect (); }

void NLNET::CUnifiedNetwork::removeNamedCnx (  const std::string &  name, uint16  sid )  [private]

Definition at line 1727 of file unified_network.cpp. References _NamedCnx, NLNET::allstuffs, AUTOCHECK_DISPLAY, range, NLMISC::toString(), and uint16. Referenced by NLNET::uncbDisconnection(), and NLNET::uNetUnregistrationBroadcast(). { // get all map nodes of that service name CUnifiedNetwork::TNameMappedConnection::iterator it; pair<CUnifiedNetwork::TNameMappedConnection::iterator,CUnifiedNetwork::TNameMappedConnection::iterator> range; range = _NamedCnx.equal_range(name); // assume not empty if (range.first == range.second) { AUTOCHECK_DISPLAY ("HNETL5: The unified connection %s-%hu wasn't on the _NamedCnx", name.c_str(), sid); return; } // select good service id for (it=range.first; it!=range.second && (*it).second!=sid; ++it) ; // assume id exists if (it == range.second) { AUTOCHECK_DISPLAY ("HNETL5: The unified connection %s-%hu wasn't on the _NamedCnx", name.c_str(), sid); return; } // remove service for map _NamedCnx.erase(it); allstuffs += "-name "+name+"-"+toString(sid)+"\n"; test.displayNL ("-name %s-%hu", name.c_str (), sid); }

bool NLNET::CUnifiedNetwork::send (  uint16  serviceId, const CMessage &  msg, uint8  nid = 0xFF )

Sends a message to a specific serviceId. Parameters: serviceId  Id of the service you want to send the message. msg  the message you want to send. nid  Network Id specify to which network the message must pass throw (0xFF mean the default network) Returns: true if the service was found (may return true even if the sending failed) Definition at line 1136 of file unified_network.cpp. References _IdCnx, findConnectionId(), NLMISC::getThreadId(), nlassertex, nlwarning, NLNET::ThreadCreator, uint16, and uint8. { nlassertex(_Initialised == true, ("Try to CUnifiedNetwork::send(uint16, const CMessage&) whereas it is not initialised yet")); if (ThreadCreator != NLMISC::getThreadId()) nlwarning ("HNETL5: Multithread access but this class is not thread safe thread creator = %u thread used = %u", ThreadCreator, NLMISC::getThreadId()); if (sid >= _IdCnx.size () || _IdCnx[sid].State != CUnifiedNetwork::CUnifiedConnection::Ready) { // happen when trying to send a message to an unknown service id nlwarning ("HNETL5: Can't send to the service '%hu' because not in _IdCnx", sid); return false; } uint8 connectionId = findConnectionId (sid, nid); if (connectionId == 0xff) // failed { nlwarning ("HNETL5: Can't send to the service '%hu' because no connection available", sid); return false; } _IdCnx[sid].Connection[connectionId].CbNetBase->send (msgout, _IdCnx[sid].Connection[connectionId].HostId); return true; }

bool NLNET::CUnifiedNetwork::send (  const std::string &  serviceName, const CMessage &  msg, uint8  nid = 0xFF )

Sends a message to a specific serviceName. If there's more than one service with this name, all services of this name will receive the message. Parameters: serviceName  name of the service you want to send the message (may not be unique.) msg  the message you want to send. nid  Network Id specify to which network the message must pass throw (0xFF mean the default network) Returns: true if the service was found (one or more instances) (may return true even if the sending failed) Definition at line 1091 of file unified_network.cpp. References _IdCnx, _NamedCnx, findConnectionId(), NLNET::CMessage::getName(), NLMISC::getThreadId(), nlassertex, nlwarning, range, NLNET::ThreadCreator, uint16, and uint8. { nlassertex(_Initialised == true, ("Try to CUnifiedNetwork::send(const string&, const CMessage&) whereas it is not initialised yet")); if (ThreadCreator != NLMISC::getThreadId()) nlwarning ("HNETL5: Multithread access but this class is not thread safe thread creator = %u thread used = %u", ThreadCreator, NLMISC::getThreadId()); TNameMappedConnection::const_iterator it; pair<TNameMappedConnection::const_iterator,TNameMappedConnection::const_iterator> range; range = _NamedCnx.equal_range(serviceName); bool found = false; if (range.first != _NamedCnx.end()) { for (it=range.first; it!=range.second; ++it) { uint16 sid = (*it).second; if (sid >= _IdCnx.size () || _IdCnx[sid].State != CUnifiedNetwork::CUnifiedConnection::Ready) { // It often happen when the service is down (connection broke and the naming not already say that it s down) // In this case, just warn nlwarning ("HNETL5: Can't send to the service '%s' because it was in the _NamedCnx but not in _IdCnx (means that the service is down)", serviceName.c_str ()); return false; } found = true; uint8 connectionId = findConnectionId (sid, nid); if (connectionId == 0xff) // failed { nlwarning ("HNETL5: Can't send message to %hu because no connection available", sid); found = false; continue; } //nldebug ("HNETL5: send message to %s using nid %d cnx %d / %s", serviceName.c_str (), nid, connectionId, connectionId<_IdCnx[sid].ExtAddress.size ()?_IdCnx[sid].ExtAddress[connectionId].asString().c_str():"???"); _IdCnx[sid].Connection[connectionId].CbNetBase->send (msgout, _IdCnx[sid].Connection[connectionId].HostId); } } if (!found) nlwarning ("HNETL5: can't find service %s to send message %s", serviceName.c_str(), msgout.getName().c_str()); return found; }

void NLNET::CUnifiedNetwork::sendAll (  const CMessage &  msg, uint8  nid = 0xFF )

Broadcasts a message to all connected services. Parameters: msg  the message you want to send. nid  Network Id specify to which network the message must pass throw (0xFF mean the default network) Definition at line 1160 of file unified_network.cpp. References _IdCnx, findConnectionId(), NLMISC::getThreadId(), nlassertex, nlwarning, NLNET::ThreadCreator, uint, and uint8. { nlassertex(_Initialised == true, ("Try to CUnifiedNetwork::send(const CMessage&) whereas it is not initialised yet")); if (ThreadCreator != NLMISC::getThreadId()) nlwarning ("HNETL5: Multithread access but this class is not thread safe thread creator = %u thread used = %u", ThreadCreator, NLMISC::getThreadId()); uint i; for (i=0; i<_IdCnx.size(); ++i) { if (_IdCnx[i].State == CUnifiedNetwork::CUnifiedConnection::Ready) { uint8 connectionId = findConnectionId (i, nid); if (connectionId == 0xff) // failed { nlwarning ("HNETL5: Can't send message to %u because no connection available", i); continue; } _IdCnx[i].Connection[connectionId].CbNetBase->send (msgout, _IdCnx[i].Connection[connectionId].HostId); } } }

void NLNET::CUnifiedNetwork::setServiceDownCallback (  const std::string &  serviceName, TUnifiedNetCallback  cb, void *  arg = 0, bool  back = true )

Sets callback for disconnections. On a client, the callback will be call each time the connection to the server is lost. On a server, the callback is called each time a client is disconnected. You can set more than one callback, each one will be called one after one. If the serviceName is "*", the callback will be call for any services If you set the same callback for a specific service S and for "*", the callback might be call twice (in case the service S is down) Parameters: back  if true, put the callback at the end of the callback array, otherwise but on the beginning. You should always use true Definition at line 1216 of file unified_network.cpp. References _DownCallbacks, _DownUniCallback, nlassert, and NLNET::TUnifiedNetCallback. { nlassert (cb != NULL); if (serviceName == "*") { if (back) _DownUniCallback.push_back (make_pair(cb, arg)); else _DownUniCallback.insert (_DownUniCallback.begin(), make_pair(cb, arg)); } else { if (back) _DownCallbacks[serviceName].push_back (make_pair(cb, arg)); else _DownCallbacks[serviceName].insert (_DownCallbacks[serviceName].begin(), make_pair(cb, arg)); } }

void NLNET::CUnifiedNetwork::setServiceUpCallback (  const std::string &  serviceName, TUnifiedNetCallback  cb, void *  arg = 0, bool  back = true )

Sets callback for incoming connections. On a client, the callback will be call when the connection to the server is established (the first connection or after the server shutdown and started) On a server, the callback is called each time a new client is connected to him You can set more than one callback, each one will be called one after one. If the serviceName is "*", the callback will be call for any services If you set the same callback for a specific service S and for "*", the callback might be call twice (in case the service S is up) Parameters: back  if true, put the callback at the end of the callback array, otherwise but on the beginning. You should always use true Definition at line 1197 of file unified_network.cpp. References _UpCallbacks, _UpUniCallback, nlassert, and NLNET::TUnifiedNetCallback. { nlassert (cb != NULL); if (serviceName == "*") { if (back) _UpUniCallback.push_back (make_pair(cb, arg)); else _UpUniCallback.insert (_UpUniCallback.begin(), make_pair(cb, arg)); } else { if (back) _UpCallbacks[serviceName].push_back (make_pair(cb, arg)); else _UpCallbacks[serviceName].insert (_UpCallbacks[serviceName].begin(), make_pair(cb, arg)); } }

void NLNET::CUnifiedNetwork::update (  NLMISC::TTime  timeout = 0  )

Call it evenly. the parameter select the timeout value in seconds for each update. You are absolutely certain that this function will not be returns before this amount of time you set. If you set the update timeout value higher than 0, all messages in queues will be process until the time is greater than the timeout user update(). If you set the update timeout value to 0, all messages in queues will be process one time before calling the user update(). In this case, we don't nlSleep(1). Definition at line 857 of file unified_network.cpp. References _CbServer, _IdCnx, _LastRetry, _NamingServiceAddr, _ServerPort, _UsedConnection, addNamedCnx(), NLNET::CInetAddress::asString(), autoCheck(), NLNET::CUnifiedNetwork::CUnifiedConnection::AutoRetry, callServiceUpCallback(), NLNET::CCallbackClient::connect(), NLNET::CUnifiedNetwork::CUnifiedConnection::Connection, NLNET::CUnifiedNetwork::CUnifiedConnection::ExtAddress, NLMISC::getThreadId(), H_AUTO, H_TIME, haveNamedCnx(), NLNET::CUnifiedNetwork::CUnifiedConnection::IsExternal, NLNET::CInetAddress::isValid(), nlassert, nlassertex, nlinfo, NLMISC::nlSleep(), nlwarning, NLNET::CUnifiedNetwork::CUnifiedConnection::SendId, NLMISC::CMemStream::serial(), NLNET::CUnifiedNetwork::CUnifiedConnection::ServiceId, NLNET::CUnifiedNetwork::CUnifiedConnection::ServiceName, NLNET::CUnifiedNetwork::CUnifiedConnection::State, NLNET::ThreadCreator, NLMISC::TTime, uint, uint16, uint8, and NLNET::CCallbackServer::update(). { H_AUTO(CUnifiedNetworkUpdate); nlassertex(_Initialised == true, ("Try to CUnifiedNetwork::update() whereas it is not initialised yet")); if (ThreadCreator != NLMISC::getThreadId()) nlwarning ("HNETL5: Multithread access but this class is not thread safe thread creator = %u thread used = %u", ThreadCreator, NLMISC::getThreadId()); bool enableRetry; // true every 5 seconds to reconnect if necessary // Compute the real timeout based on the next update timeout TTime t0 = CTime::getLocalTime (); if (timeout > 0) { if (_NextUpdateTime == 0) { _NextUpdateTime = t0 + timeout; } else { TTime err = t0 - _NextUpdateTime; _NextUpdateTime += timeout; // if we are too late, resync to the next value while (err > timeout) { err -= timeout; _NextUpdateTime += timeout; } timeout -= err; if (timeout < 0) timeout = 0; } } // check if we need to retry to connect to the client if ((enableRetry = (t0-_LastRetry > 5000))) _LastRetry = t0; // Try to reconnect to the naming service if connection lost if (_NamingServiceAddr.isValid ()) { if (CNamingClient::connected ()) { CNamingClient::update (); } else if (enableRetry) { H_AUTO(L5NSReconnect); try { vector<CInetAddress> laddr = CInetAddress::localAddresses(); CNamingClient::connect (_NamingServiceAddr, _RecordingState, laddr); // re-register the service for (uint i = 0; i < laddr.size(); i++) laddr[i].setPort(_ServerPort); CNamingClient::resendRegisteration (_Name, laddr, _SId); } catch (ESocketConnectionFailed &) { nlwarning ("HNETL5: Could not connect to the Naming Service (%s). Retrying in a few seconds...", _NamingServiceAddr.asString().c_str()); } } } while (true) { // update all server connections if (_CbServer) { _CbServer->update(0); } // update all client connections for (uint k = 0; k<_UsedConnection.size(); ++k) { CUnifiedConnection &uc = _IdCnx[_UsedConnection[k]]; nlassert (uc.State == CUnifiedNetwork::CUnifiedConnection::Ready); for (uint j = 0; j < uc.Connection.size (); j++) { if (!uc.Connection[j].valid()) continue; if (uc.Connection[j].IsServerConnection) continue; if (uc.Connection[j].CbNetBase->connected ()) { uc.Connection[j].CbNetBase->update(0); } else if (enableRetry && uc.AutoRetry) { H_AUTO(L5AutoReconnect); try { CCallbackClient *cbc = (CCallbackClient *)uc.Connection[j].CbNetBase; cbc->connect(uc.ExtAddress[j]); uc.Connection[j].CbNetBase->getSockId()->setAppId(uc.ServiceId); nlinfo ("HNETL5: reconnection to %s-%hu success", uc.ServiceName.c_str(), uc.ServiceId); // add the name only if at least one connection is ok if (!haveNamedCnx (uc.ServiceName, uc.ServiceId)) addNamedCnx (uc.ServiceName, uc.ServiceId); // resend the identification is necessary if (uc.SendId) { // send identification to the service CMessage msg("UN_SIDENT"); msg.serial(_Name); uint16 ssid = _SId; if (uc.IsExternal) { // in the case that the service is external, we can't send our sid because the external service can // have other connection with the same sid (for example, LS can have 2 WS with same sid => sid = 0 and leave // the other side to find a good number ssid = 0; } msg.serial(ssid); // serializes a 16 bits service id uint8 pos = j; msg.serial(pos); // send the position in the connection table msg.serial (uc.IsExternal); uc.Connection[j].CbNetBase->send (msg, uc.Connection[j].HostId); } // call the user callback callServiceUpCallback (uc.ServiceName, uc.ServiceId); /* CUnifiedNetwork::TNameMappedCallback::iterator it = _UpCallbacks.find(uc.ServiceName); if (it != _UpCallbacks.end()) { // call it for (list<TCallbackArgItem> it2 = (*it).second.begin(); it2 != (*it).second.end(); it2++) { TUnifiedNetCallback cb = (*it2).first; if (cb) cb(uc.ServiceName, uc.ServiceId, (*it2).second); } } for (uint c = 0; c < _UpUniCallback.size (); c++) { if (_UpUniCallback[c].first != NULL) _UpUniCallback[c].first (uc.ServiceName, uc.ServiceId, _UpUniCallback[c].second); } */ } catch (ESocketConnectionFailed &e) { nlinfo ("HNETL5: can't connect to %s-%hu now (%s)", uc.ServiceName.c_str(), uc.ServiceId, e.what ()); } } } } enableRetry = false; // If it's the end, don't nlSleep() if (CTime::getLocalTime() - t0 > timeout) break; // Enable windows multithreading before rescanning all connections H_TIME(L5UpdateSleep, nlSleep(1);); } autoCheck(); }

---

Friends And Related Function Documentation

friend struct isServiceLocalClass [friend]

Definition at line 510 of file unified_network.h.

friend struct l5CallbackClass [friend]

Definition at line 511 of file unified_network.h.

friend struct l5QueuesStatsClass [friend]

Definition at line 512 of file unified_network.h.

void uncbConnection (  TSockId  from, void *  arg )  [friend]

Definition at line 172 of file unified_network.cpp. { nlinfo ("HNETL5: + connec '%s'", from->asString().c_str()); from->setAppId (AppIdDeadConnection); }

void uncbDisconnection (  TSockId  from, void *  arg )  [friend]

Definition at line 179 of file unified_network.cpp. { if(from->appId () == AppIdDeadConnection) { nlinfo ("HNETL5: - connec '%s'", from->asString().c_str()); test.displayNL ("-connect dead conenction"); } else { CUnifiedNetwork *uni = CUnifiedNetwork::getInstance(); uint16 sid = (uint16)from->appId(); CUnifiedNetwork::CUnifiedConnection *uc = uni->getUnifiedConnection (sid); if (uc == 0) { nlinfo ("HNETL5: - connec '%s' sid %hu", from->asString().c_str(), sid); test.displayNL ("-connect '%s' %hu", from->asString ().c_str (), sid); } else { nlinfo ("HNETL5: - connec '%s' %s-%hu", from->asString().c_str(), uc->ServiceName.c_str (), sid); allstuffs += "-connect "+uc->ServiceName+"-"+toString(sid)+"\n"; test.displayNL ("-connect %s-%hu", uc->ServiceName.c_str (), (uint16)(uc->ServiceId)); if (uc->IsExternal) { if (!uc->AutoRetry) { // If it s a external service with no auto retry, remove the connection // call the user callback uni->callServiceDownCallback(uc->ServiceName, uc->ServiceId); /*CUnifiedNetwork::TNameMappedCallback::iterator it2 = uni->_DownCallbacks.find(uc->ServiceName); if (it2 != uni->_DownCallbacks.end()) { // call it TUnifiedNetCallback cb = (*it2).second.first; cb(uc->ServiceName, uc->ServiceId, (*it2).second.second); } for (uint c = 0; c < uni->_DownUniCallback.size (); c++) { if (uni->_DownUniCallback[c].first != NULL) uni->_DownUniCallback[c].first(uc->ServiceName, uc->ServiceId, uni->_DownUniCallback[c].second); }*/ uni->removeNamedCnx (uc->ServiceName, uc->ServiceId); // remove the _UsedConnection bool found = false; for (vector<uint16>::iterator it = uni->_UsedConnection.begin (); it != uni->_UsedConnection.end(); it++) { if (*it == uc->ServiceId) { found = true; uni->_UsedConnection.erase (it); break; } } if (!found) AUTOCHECK_DISPLAY ("HNETL5: can't find the sid %hu in the _UsedConnection", uc->ServiceId); uc->reset (); } } else { // reset the connection uint i; for (i = 0; i < uc->Connection.size (); i++) { if (uc->Connection[i].valid() && uc->Connection[i].CbNetBase->getSockId(uc->Connection[i].HostId) == from) { if (uc->Connection[i].IsServerConnection) { // we have to remove the stuffs now because HostId will not be accessible later uc->Connection[i].reset(); } else { // if it s a client, we can't delete now because the callback client is currently in use // only disconnect if(uc->Connection[i].CbNetBase->connected ()) { uc->Connection[i].CbNetBase->disconnect (uc->Connection[i].HostId); } } break; } } if (i == uc->Connection.size ()) { AUTOCHECK_DISPLAY ("HNETL5: received a disconnection from a service but the connection is not in my list!"); } } } from->setAppId (AppIdDeadConnection); } }

void uncbMsgProcessing (  CMessage &  msgin, TSockId  from, CCallbackNetBase &  netbase )  [friend]

Definition at line 406 of file unified_network.cpp. { if (from->appId() == AppIdDeadConnection) { AUTOCHECK_DISPLAY ("HNETL5: Receive a message from a dead connection"); return; } CUnifiedNetwork *uni = CUnifiedNetwork::getInstance(); uint16 sid = (uint16)from->appId(); CUnifiedNetwork::TMsgMappedCallback::iterator itcb; itcb = uni->_Callbacks.find(msgin.getName()); if (itcb == uni->_Callbacks.end()) { // the callback doesn't exist nlwarning ("HNETL5: Can't find callback '%s' called by service %hu", msgin.getName().c_str(), sid); } else { CUnifiedNetwork::CUnifiedConnection *uc = uni->getUnifiedConnection (sid); if (uc == 0) { nlwarning ("HNETL5: Received a message from a service %hu that is not ready (bad appid? 0x%"NL_I64"X)", sid, from->appId ()); return; } if((*itcb).second == 0) { nlwarning ("HNETL5: Received message %s from a service %hu but the associated callback is NULL", msgin.getName ().c_str(), sid); return; } { static map<string, CHTimer> timers; map<string, CHTimer>::iterator it; { H_AUTO(L5UCHTimerOverhead); string callbackName = "USRCB_" + msgin.getName(); it = timers.find(callbackName); if(it == timers.end()) { it = timers.insert(make_pair(callbackName, CHTimer(NULL))).first; (*it).second.setName((*it).first.c_str()); } } { H_AUTO(L5UserCallback); (*it).second.before(); (*itcb).second (msgin, uc->ServiceName, sid); (*it).second.after(); } } uc->TotalCallbackCalled++; TotalCallbackCalled++; } }

void uncbServiceIdentification (  CMessage &  msgin, TSockId  from, CCallbackNetBase &  netbase )  [friend]

Definition at line 284 of file unified_network.cpp. { string inSName; uint16 inSid; if (from->appId () != AppIdDeadConnection) AUTOCHECK_DISPLAY ("HNETL5: received a connec ident from an unknown connection 0x%"NL_I64"X", from->appId ()); // recover the service name and id msgin.serial(inSName); msgin.serial(inSid); uint8 pos; msgin.serial (pos); bool isExternal; msgin.serial (isExternal); nlinfo ("HNETL5: + connec ident '%s' %s-%hu pos %hu ext %d", from->asString().c_str(), inSName.c_str(), inSid, (uint16)pos, (uint8)isExternal); allstuffs += "+rconnect "+inSName+"-"+toString(inSid)+" pos "+toString((uint16)pos)+"\n"; test.displayNL ("+rconnect %s-%hu pos %hu", inSName.c_str (), (uint16)inSid, (uint16)pos); if(isExternal) { nlassert (pos == 0); } if (inSid == 0) { if (isExternal) { inSid = CUnifiedNetwork::getInstance ()->_ExtSId++; nlwarning ("HNETL5: Received a connection from a service with a SId 0, we give him the SId %d", inSid); } else { nlwarning ("HNETL5: Received a connection from a service with a SId 0 and wasn't external, disconnecting it"); netbase.disconnect(); return; } } from->setAppId(inSid); // add a new connection to the list CUnifiedNetwork *uni= CUnifiedNetwork::getInstance(); if(inSid >= uni->_IdCnx.size ()) { uni->_IdCnx.resize (inSid+1); } switch(uni->_IdCnx[inSid].State) { case CUnifiedNetwork::CUnifiedConnection::NotUsed: // add the new unified connection uni->_IdCnx[inSid] = CUnifiedNetwork::CUnifiedConnection(inSName, inSid, isExternal); uni->_UsedConnection.push_back (inSid); break; default: break; } if (uni->_IdCnx[inSid].IsExternal != isExternal) { AUTOCHECK_DISPLAY ("HNETL5: Receive a connection that is not totally external %d %d", uni->_IdCnx[inSid].IsExternal, isExternal); return; } bool FirstConnection = (uni->_IdCnx[inSid].Connection.size () == 0); // add the connection to the already inserted unified connection if (pos >= uni->_IdCnx[inSid].Connection.size ()) uni->_IdCnx[inSid].Connection.resize(pos+1); uni->_IdCnx[inSid].Connection[pos] = CUnifiedNetwork::CUnifiedConnection::TConnection(&netbase, from); // If the connection is external, we'll never receive the ExtAddress by the naming service, so add it manually if (isExternal) { uni->_IdCnx[inSid].ExtAddress.push_back (netbase.hostAddress (from)); uni->_IdCnx[inSid].setupNetworkAssociation (uni->_NetworkAssociations, uni->_DefaultNetwork); } // todo ace temp to savoir comment c est possible ce cas la if (uni->_IdCnx[inSid].Connection.size() == 3) { CUnifiedNetwork::CUnifiedConnection *uc = &uni->_IdCnx[inSid]; nlstop; nlinfo ("HNETL5: ext addr %s", vectorCInetAddressToString (uc->ExtAddress).c_str ()); for(uint i = 0; i < uc->Connection.size(); i++) nlinfo ("HNETL5: cnx %s", uc->Connection[i].HostId->asString ().c_str ()); nlinfo ("HNETL5: %s", allstuffs.c_str ()); } // send the callback to the user with the first connection if (FirstConnection) { // insert the name in the map to be able to send message with the name uni->addNamedCnx (inSName, inSid); uni->callServiceUpCallback (inSName, inSid); /* // now we warn the user CUnifiedNetwork::TNameMappedCallback::iterator it = uni->_UpCallbacks.find(inSName); if (it != uni->_UpCallbacks.end()) { // call it for (list<TCallbackArgItem> it2 = (*it).second.begin(); it2 != (*it).second.end(); it2++) { TUnifiedNetCallback cb = (*it2).first; if (cb) cb(inSName, inSid, (*it2).second); } } for (uint c = 0; c < uni->_UpUniCallback.size (); c++) { if (uni->_UpUniCallback[c].first != NULL) uni->_UpUniCallback[c].first (inSName, inSid, uni->_UpUniCallback[c].second); }*/ } }

void uNetRegistrationBroadcast (  const std::string &  name, TServiceId  sid, const std::vector< CInetAddress > &  addr )  [friend]

void uNetUnregistrationBroadcast (  const std::string &  name, TServiceId  sid, const std::vector< CInetAddress > &  addr )  [friend]

---

Field Documentation

TMsgMappedCallback NLNET::CUnifiedNetwork::_Callbacks [private]

Map of callbacks. Definition at line 454 of file unified_network.h. Referenced by addCallbackArray(), findCallback(), NLNET::NLMISC_COMMAND(), release(), and NLNET::uncbMsgProcessing().

CCallbackServer* NLNET::CUnifiedNetwork::_CbServer [private]

The callback server. Definition at line 433 of file unified_network.h. Referenced by CUnifiedNetwork(), getBytesReceived(), getBytesSent(), getReceiveQueueSize(), getSendQueueSize(), init(), release(), and update().

std::vector<std::string> NLNET::CUnifiedNetwork::_DefaultNetwork [private]

for each services, which network to take Definition at line 478 of file unified_network.h. Referenced by addDefaultNetwork(), addService(), clearDefaultNetwork(), NLNET::uncbServiceIdentification(), and NLNET::uNetRegistrationBroadcast().

TNameMappedCallback NLNET::CUnifiedNetwork::_DownCallbacks [private]

Definition at line 441 of file unified_network.h. Referenced by callServiceDownCallback(), release(), and setServiceDownCallback().

std::vector<TCallbackArgItem> NLNET::CUnifiedNetwork::_DownUniCallback [private]

Definition at line 442 of file unified_network.h. Referenced by callServiceDownCallback(), and setServiceDownCallback().

uint16 NLNET::CUnifiedNetwork::_ExtSId [private]

Used for external service. Definition at line 457 of file unified_network.h. Referenced by addService(), and CUnifiedNetwork().

std::vector<CUnifiedConnection> NLNET::CUnifiedNetwork::_IdCnx [private]

Vector of connections by service id (sid is the entry in this array, it means that there s some hole). Definition at line 424 of file unified_network.h. Referenced by addService(), autoCheck(), displayInternalTables(), findConnectionId(), getBytesReceived(), getBytesSent(), getNetBase(), getReceiveQueueSize(), getSendQueueSize(), getUnifiedConnection(), isServiceLocal(), NLNET::NLMISC_COMMAND(), release(), send(), sendAll(), NLNET::uncbServiceIdentification(), NLNET::uNetRegistrationBroadcast(), and update().

bool NLNET::CUnifiedNetwork::_Initialised [private]

true if initialisation function called Definition at line 472 of file unified_network.h.

CUnifiedNetwork * NLNET::CUnifiedNetwork::_Instance = NULL [static, private]

The main instance. Definition at line 1479 of file unified_network.cpp.

NLMISC::TTime NLNET::CUnifiedNetwork::_LastRetry [private]

Last time of retry. Definition at line 460 of file unified_network.h. Referenced by CUnifiedNetwork(), and update().

std::string NLNET::CUnifiedNetwork::_Name [private]

Service name. Definition at line 451 of file unified_network.h.

TNameMappedConnection NLNET::CUnifiedNetwork::_NamedCnx [private]

Map of connections by service name. Definition at line 430 of file unified_network.h. Referenced by addNamedCnx(), autoCheck(), displayInternalTables(), getNetBase(), haveNamedCnx(), isServiceLocal(), release(), removeNamedCnx(), and send().

NLNET::CInetAddress NLNET::CUnifiedNetwork::_NamingServiceAddr [private]

Naming service. Definition at line 469 of file unified_network.h. Referenced by init(), and update().

std::vector<uint32> NLNET::CUnifiedNetwork::_NetworkAssociations [private]

for each nid, which network address Definition at line 475 of file unified_network.h. Referenced by addNetworkAssociation(), addService(), autoCheck(), clearNetworkAssociation(), displayInternalTables(), NLNET::uncbServiceIdentification(), and NLNET::uNetRegistrationBroadcast().

NLMISC::TTime NLNET::CUnifiedNetwork::_NextUpdateTime [private]

Time of the theorical next update. Definition at line 463 of file unified_network.h.

CCallbackNetBase::TRecordingState NLNET::CUnifiedNetwork::_RecordingState [private]

Recording state. Definition at line 445 of file unified_network.h.

uint16 NLNET::CUnifiedNetwork::_ServerPort [private]

The server port. Definition at line 436 of file unified_network.h. Referenced by init(), and update().

TServiceId NLNET::CUnifiedNetwork::_SId [private]

Service id of the running service. Definition at line 448 of file unified_network.h. Referenced by NLNET::NLMISC_COMMAND(), and NLNET::uNetRegistrationBroadcast().

TNameMappedCallback NLNET::CUnifiedNetwork::_UpCallbacks [private]

Map of the up/down service callbacks. Definition at line 439 of file unified_network.h. Referenced by callServiceUpCallback(), release(), and setServiceUpCallback().

std::vector<TCallbackArgItem> NLNET::CUnifiedNetwork::_UpUniCallback [private]

Definition at line 440 of file unified_network.h. Referenced by callServiceUpCallback(), and setServiceUpCallback().

std::vector<uint16> NLNET::CUnifiedNetwork::_UsedConnection [private]

This vector contains only an index to the unified connection. It is used to have quick access on the available connections. Definition at line 427 of file unified_network.h. Referenced by addService(), autoCheck(), displayInternalTables(), getBytesReceived(), getBytesSent(), getConnectionList(), getReceiveQueueSize(), getSendQueueSize(), release(), NLNET::uncbDisconnection(), NLNET::uncbServiceIdentification(), NLNET::uNetRegistrationBroadcast(), NLNET::uNetUnregistrationBroadcast(), and update().

---

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

• unified_network.h
• unified_network.cpp

---