WorldSocketMgr Class Reference

Manages all sockets connected to peers and network threads. More...

#include <WorldSocketMgr.h>

Public Member Functions
	~WorldSocketMgr ()
bool	StartNetwork (boost::asio::io_service &service, std::string const &bindIp, uint16 port, int networkThreads) override
	Start network, listen at address:port . More...
void	StopNetwork () override
	Stops all network threads, It will wait for all running threads . More...
void	OnSocketOpen (tcp::socket &&sock, uint32 threadIndex) override
Public Member Functions inherited from SocketMgr< WorldSocket >
virtual	~SocketMgr ()
void	Wait ()
int32	GetNetworkThreadCount () const
uint32	SelectThreadWithMinConnections () const
std::pair< tcp::socket *, uint32 >	GetSocketForAccept ()

Static Public Member Functions
static WorldSocketMgr &	Instance ()

Protected Member Functions
	WorldSocketMgr ()
NetworkThread< WorldSocket > *	CreateThreads () const override
Protected Member Functions inherited from SocketMgr< WorldSocket >
	SocketMgr ()

Private Types
typedef SocketMgr< WorldSocket >	BaseSocketMgr

Private Attributes
AsyncAcceptor *	_instanceAcceptor
int32	_socketSendBufferSize
int32	m_SockOutUBuff
bool	_tcpNoDelay

Additional Inherited Members
Protected Attributes inherited from SocketMgr< WorldSocket >
AsyncAcceptor *	_acceptor
NetworkThread< WorldSocket > *	_threads
int32	_threadCount

Detailed Description

Manages all sockets connected to peers and network threads.

Member Typedef Documentation

typedef SocketMgr<WorldSocket> WorldSocketMgr::BaseSocketMgr

private

Constructor & Destructor Documentation

WorldSocketMgr::~WorldSocketMgr

(

)

{
 ASSERT(!_instanceAcceptor, "StopNetwork must be called prior to WorldSocketMgr destruction");
}

WorldSocketMgr::WorldSocketMgr ( )

protected

 : BaseSocketMgr(), _instanceAcceptor(nullptr), _socketSendBufferSize(-1), m_SockOutUBuff(65536), _tcpNoDelay(true)
{
}

Member Function Documentation

NetworkThread< WorldSocket > * WorldSocketMgr::CreateThreads ( ) const

overrideprotectedvirtual

Implements SocketMgr< WorldSocket >.

{
 return new WorldSocketThread[GetNetworkThreadCount()];
}

Here is the call graph for this function:

WorldSocketMgr & WorldSocketMgr::Instance ( )

static

{
 static WorldSocketMgr instance;
 return instance;
}

void WorldSocketMgr::OnSocketOpen ( tcp::socket &&  sock, uint32  threadIndex  )

overridevirtual

Reimplemented from SocketMgr< WorldSocket >.

{
 // set some options here
 if (_socketSendBufferSize >= 0)
 {
 boost::system::error_code err;
 sock.set_option(boost::asio::socket_base::send_buffer_size(_socketSendBufferSize), err);
 if (err && err != boost::system::errc::not_supported)
 {
 TC_LOG_ERROR("misc", "WorldSocketMgr::OnSocketOpen sock.set_option(boost::asio::socket_base::send_buffer_size) err = %s", err.message().c_str());
 return;
 }
 }

 // Set TCP_NODELAY.
 if (_tcpNoDelay)
 {
 boost::system::error_code err;
 sock.set_option(boost::asio::ip::tcp::no_delay(true), err);
 if (err)
 {
 TC_LOG_ERROR("misc", "WorldSocketMgr::OnSocketOpen sock.set_option(boost::asio::ip::tcp::no_delay) err = %s", err.message().c_str());
 return;
 }
 }

 //sock->m_OutBufferSize = static_cast<size_t> (m_SockOutUBuff);

 BaseSocketMgr::OnSocketOpen(std::forward<tcp::socket>(sock), threadIndex);
}

Here is the call graph for this function:

bool WorldSocketMgr::StartNetwork ( boost::asio::io_service &  service, std::string const &  bindIp, uint16  port, int  networkThreads  )

overridevirtual

Start network, listen at address:port .

Reimplemented from SocketMgr< WorldSocket >.

{
 _tcpNoDelay = sConfigMgr->GetBoolDefault("Network.TcpNodelay", true);

 int const max_connections = boost::asio::socket_base::max_connections;
 TC_LOG_DEBUG("misc", "Max allowed socket connections %d", max_connections);

 // -1 means use default
 _socketSendBufferSize = sConfigMgr->GetIntDefault("Network.OutKBuff", -1);

 m_SockOutUBuff = sConfigMgr->GetIntDefault("Network.OutUBuff", 65536);

 if (m_SockOutUBuff <= 0)
 {
 TC_LOG_ERROR("misc", "Network.OutUBuff is wrong in your config file");
 return false;
 }

 BaseSocketMgr::StartNetwork(service, bindIp, port, threadCount);
 _instanceAcceptor = new AsyncAcceptor(service, bindIp, uint16(sWorld->getIntConfig(CONFIG_PORT_INSTANCE)));

 _acceptor->SetSocketFactory(std::bind(&BaseSocketMgr::GetSocketForAccept, this));
 _instanceAcceptor->SetSocketFactory(std::bind(&BaseSocketMgr::GetSocketForAccept, this));

 _acceptor->AsyncAcceptWithCallback<&OnSocketAccept>();
 _instanceAcceptor->AsyncAcceptWithCallback<&OnSocketAccept>();

 sScriptMgr->OnNetworkStart();
 return true;
}

Here is the call graph for this function:

void WorldSocketMgr::StopNetwork ( )

overridevirtual

Stops all network threads, It will wait for all running threads .

Reimplemented from SocketMgr< WorldSocket >.

{
 _instanceAcceptor->Close();
 BaseSocketMgr::StopNetwork();

 delete _instanceAcceptor;
 _instanceAcceptor = nullptr;

 sScriptMgr->OnNetworkStop();
}

Here is the call graph for this function:

Member Data Documentation

AsyncAcceptor* WorldSocketMgr::_instanceAcceptor

private

int32 WorldSocketMgr::_socketSendBufferSize

private

bool WorldSocketMgr::_tcpNoDelay

private

int32 WorldSocketMgr::m_SockOutUBuff

private

---

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

• src/server/game/Server/WorldSocketMgr.h
• src/server/game/Server/WorldSocketMgr.cpp