aboutsummaryrefslogtreecommitdiff
path: root/src/game/WorldSocketMgr.h
diff options
context:
space:
mode:
Diffstat (limited to 'src/game/WorldSocketMgr.h')
-rw-r--r--src/game/WorldSocketMgr.h17
1 files changed, 0 insertions, 17 deletions
diff --git a/src/game/WorldSocketMgr.h b/src/game/WorldSocketMgr.h
index 94cfa78324c..0ad8574a2fb 100644
--- a/src/game/WorldSocketMgr.h
+++ b/src/game/WorldSocketMgr.h
@@ -17,64 +17,47 @@
* along with this program; if not, write to the Free Software
* Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
*/
-
/** \addtogroup u2w User to World Communication
* @{
* \file WorldSocketMgr.h
* \author Derex <derex101@gmail.com>
*/
-
#ifndef __WORLDSOCKETMGR_H
#define __WORLDSOCKETMGR_H
-
#include <ace/Basic_Types.h>
#include <ace/Singleton.h>
#include <ace/Thread_Mutex.h>
-
class WorldSocket;
class ReactorRunnable;
class ACE_Event_Handler;
-
/// Manages all sockets connected to peers and network threads
class WorldSocketMgr
{
public:
friend class WorldSocket;
friend class ACE_Singleton<WorldSocketMgr,ACE_Thread_Mutex>;
-
/// Start network, listen at address:port .
int StartNetwork (ACE_UINT16 port, const char* address);
-
/// Stops all network threads, It will wait for all running threads .
void StopNetwork ();
-
/// Wait untill all network threads have "joined" .
void Wait ();
-
/// Make this class singleton .
static WorldSocketMgr* Instance ();
-
private:
int OnSocketOpen(WorldSocket* sock);
-
int StartReactiveIO(ACE_UINT16 port, const char* address);
-
private:
WorldSocketMgr ();
virtual ~WorldSocketMgr ();
-
ReactorRunnable* m_NetThreads;
size_t m_NetThreadsCount;
-
int m_SockOutKBuff;
int m_SockOutUBuff;
bool m_UseNoDelay;
-
ACE_Event_Handler* m_Acceptor;
};
-
#define sWorldSocketMgr WorldSocketMgr::Instance ()
-
#endif
/// @}