WorldSocketMgr.h

Go to the documentation of this file.

/*
* This file is part of Project SkyFire https://www.projectskyfire.org.
* See LICENSE.md file for Copyright information
*/

 
#ifndef SF_WORLDSOCKETMGR_H
#define SF_WORLDSOCKETMGR_H
 
#include "Common.h"
#include "Platform/Singleton.h"
#include <boost/asio/io_context.hpp>
 
class WorldSocket;
class ReactorRunnable;

class WorldSocketMgr
{
public:
    friend class WorldSocket;
    friend class WorldSocketAcceptor;
    friend class Skyfire::Singleton<WorldSocketMgr, Skyfire::Mutex>;

    int StartNetwork(uint16 port, const char* address);

    void StopNetwork();

    void Wait();
 
private:
    int OnSocketOpen(WorldSocket* sock, ReactorRunnable* reactor);
 
    int StartReactiveIO(uint16 port, const char* address);
    ReactorRunnable* SelectNetworkThread();
    boost::asio::io_context& GetNetworkIoContext(ReactorRunnable* reactor);
 
private:
    WorldSocketMgr();
    virtual ~WorldSocketMgr();
 
    ReactorRunnable* m_NetThreads;
    size_t m_NetThreadsCount;
 
    int m_SockOutKBuff;
    int m_SockOutUBuff;
    bool m_UseNoDelay;
 
    class WorldSocketAcceptor* m_Acceptor;
};
 
#define sWorldSocketMgr Skyfire::Singleton<WorldSocketMgr, Skyfire::Mutex>::instance()
 
#endif