nevrax.org : docs

00001 
+00007 /* Copyright, 2001 Nevrax Ltd.
+00008  *
+00009  * This file is part of NEVRAX NEL.
+00010  * NEVRAX NEL is free software; you can redistribute it and/or modify
+00011  * it under the terms of the GNU General Public License as published by
+00012  * the Free Software Foundation; either version 2, or (at your option)
+00013  * any later version.
+00014 
+00015  * NEVRAX NEL is distributed in the hope that it will be useful, but
+00016  * WITHOUT ANY WARRANTY; without even the implied warranty of
+00017  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+00018  * General Public License for more details.
+00019 
+00020  * You should have received a copy of the GNU General Public License
+00021  * along with NEVRAX NEL; see the file COPYING. If not, write to the
+00022  * Free Software Foundation, Inc., 59 Temple Place - Suite 330, Boston,
+00023  * MA 02111-1307, USA.
+00024  */
+00025 
+00026 #ifndef NL_NET_MANAGER_H
+00027 #define NL_NET_MANAGER_H
+00028 
+00029 #include "nel/misc/types_nl.h"
+00030 
+00031 #include <string>
+00032 #include <map>
+00033 #include <vector>
+00034 
+00035 #include "nel/misc/time_nl.h"
+00036 #include "nel/net/callback_net_base.h"
+00037 #include "nel/net/naming_client.h"
+00038 
+00039 namespace NLNET {
+00040 
+00042 typedef void (*TNetManagerCallback) (const std::string &serviceName, TSockId from, void *arg);
+00043 
+00050 struct CBaseStruct
+00051 {
+00052         CBaseStruct (const std::string &sn) :
+00053                 Name(sn), ConnectionCallback(NULL), ConnectionCbArg(NULL),
+00054                 DisconnectionCallback(NULL), DisconnectionCbArg(NULL), Type(Unknown)
+00055         { }
+00056 
+00059         std::string     Name;
+00060 
+00061         enum TBaseStructType { Unknown, Client, ClientWithAddr, Group, Server };
+00062 
+00063         std::vector<std::string>                ServiceNames;
+00064 
+00066         std::vector<CCallbackNetBase*>   NetBase;
+00067 
+00068         TNetManagerCallback                              ConnectionCallback;
+00069         void                                                    *ConnectionCbArg;
+00070 
+00071         TNetManagerCallback                              DisconnectionCallback;
+00072         void                                                    *DisconnectionCbArg;
+00073 
+00074         // autoretry is used only when Type is ClientWithAddr. If true, the CNetManager will retry to reconnect if it lost the connection
+00075         bool                                                     AutoRetry;
+00076 
+00077         TBaseStructType                                  Type;
+00078 };
+00079 
+00089 class CNetManager
+00090 {
+00091 public:
+00092 
+00096         static void     init (const CInetAddress *addr, CCallbackNetBase::TRecordingState rec );
+00097 
+00098         static void release ();
+00099 
+00104         static void     addServer (const std::string &serviceName, uint16 servicePort = 0, bool external = false);
+00105 
+00106         static void     addServer (const std::string &serviceName, uint16 servicePort, NLNET::TServiceId &sid, bool external = false);
+00107 
+00109         static void     addClient (const std::string &serviceName, const std::string &addr, bool autoRetry = true);
+00110 
+00112         static void     addClient (const std::string &serviceName);
+00113 
+00115         static void     addGroup (const std::string &groupName, const std::string &serviceName);
+00116 
+00118         static void     addCallbackArray (const std::string &serviceName, const TCallbackItem *callbackarray, NLMISC::CStringIdArray::TStringId arraysize);
+00119 
+00125         static void     update (NLMISC::TTime timeout = 0);
+00126 
+00128         static void     send (const std::string &serviceName, const CMessage &buffer, TSockId hostid = InvalidSockId);
+00129 
+00134         static void     setConnectionCallback (const std::string &serviceName, TNetManagerCallback cb, void *arg);
+00135 
+00140         static void     setDisconnectionCallback (const std::string &serviceName, TNetManagerCallback cb, void *arg);
+00141 
+00143         static NLMISC::CStringIdArray   &getSIDA (const std::string &serviceName);
+00144 
+00146         static CCallbackNetBase *getNetBase (const std::string &serviceName);
+00147 
+00148         static void setUpdateTimeout (uint32 timeout);
+00149 
+00150         static void createConnection(CBaseStruct &Base, const CInetAddress &Addr, const std::string& name);
+00151 
+00152         static uint64 getBytesSent ();
+00153         static uint64 getBytesReceived ();
+00154 
+00155         static uint64 getReceiveQueueSize ();
+00156         static uint64 getSendQueueSize ();
+00157 
+00158 private:
+00159 
+00160         typedef std::map<std::string, CBaseStruct>      TBaseMap;
+00161         typedef TBaseMap::iterator                                      ItBaseMap;
+00162 
+00163         // Contains all the connections (client and server)
+00164         static  TBaseMap        _BaseMap;
+00165 
+00166         static  CCallbackNetBase::TRecordingState _RecordingState;
+00167 
+00168         // used to synchonize the timeout in the update function
+00169         static  NLMISC::TTime _NextUpdateTime;
+00170 
+00171         // Finds the service or add it if not found
+00172         static  ItBaseMap find (const std::string &serviceName);
+00173 
+00174         friend  void RegistrationBroadcast (const std::string &name, TServiceId sid, const std::vector<CInetAddress> &addr);
+00175 
+00176 
+00177         // It's a static class, you can't instanciate it
+00178         CNetManager() { }
+00179 };
+00180 
+00181 
+00182 } // NLNET
+00183 
+00184 
+00185 #endif // NL_NET_MANAGER_H
+00186 
+00187 /* End of net_manager.h */
+