SocketMgr< SocketType > Class Template Reference

#include <SocketMgr.h>

Public Member Functions
virtual	~SocketMgr ()
virtual bool	StartNetwork (boost::asio::io_service &service, std::string const &bindIp, uint16 port, int threadCount)
virtual void	StopNetwork ()
void	Wait ()
virtual void	OnSocketOpen (tcp::socket &&sock, uint32 threadIndex)
int32	GetNetworkThreadCount () const
uint32	SelectThreadWithMinConnections () const
std::pair< tcp::socket *, uint32 >	GetSocketForAccept ()

Protected Member Functions
	SocketMgr ()
virtual NetworkThread < SocketType > *	CreateThreads () const =0

Protected Attributes
AsyncAcceptor *	_acceptor
NetworkThread< SocketType > *	_threads
int32	_threadCount

Constructor & Destructor Documentation

template<class SocketType>

virtual SocketMgr< SocketType >::~SocketMgr ( )

inlinevirtual

 {
 ASSERT(!_threads && !_acceptor && !_threadCount, "StopNetwork must be called prior to SocketMgr destruction");
 }

template<class SocketType>

SocketMgr< SocketType >::SocketMgr ( )

inlineprotected

 : _acceptor(nullptr), _threads(nullptr), _threadCount(1)
 {
 }

Member Function Documentation

template<class SocketType>

virtual NetworkThread<SocketType>* SocketMgr< SocketType >::CreateThreads ( ) const

protectedpure virtual

Implemented in WorldSocketMgr, and Battlenet::SessionManager.

Here is the caller graph for this function:

template<class SocketType>

int32 SocketMgr< SocketType >::GetNetworkThreadCount ( ) const

inline

{ return _threadCount; }

template<class SocketType>

std::pair<tcp::socket*, uint32> SocketMgr< SocketType >::GetSocketForAccept ( )

inline

 {
 uint32 threadIndex = SelectThreadWithMinConnections();
 return std::make_pair(_threads[threadIndex].GetSocketForAccept(), threadIndex);
 }

Here is the caller graph for this function:

template<class SocketType>

virtual void SocketMgr< SocketType >::OnSocketOpen ( tcp::socket &&  sock, uint32  threadIndex  )

inlinevirtual

Reimplemented in WorldSocketMgr.

 {
 try
 {
 std::shared_ptr<SocketType> newSocket = std::make_shared<SocketType>(std::move(sock));
 newSocket->Start();

 _threads[threadIndex].AddSocket(newSocket);
 }
 catch (boost::system::system_error const& err)
 {
 TC_LOG_WARN("network", "Failed to retrieve client's remote address %s", err.what());
 }
 }

template<class SocketType>

uint32 SocketMgr< SocketType >::SelectThreadWithMinConnections ( ) const

inline

 {
 uint32 min = 0;

 for (int32 i = 1; i < _threadCount; ++i)
 if (_threads[i].GetConnectionCount() < _threads[min].GetConnectionCount())
 min = i;

 return min;
 }

Here is the caller graph for this function:

template<class SocketType>

virtual bool SocketMgr< SocketType >::StartNetwork ( boost::asio::io_service &  service, std::string const &  bindIp, uint16  port, int  threadCount  )

inlinevirtual

Reimplemented in WorldSocketMgr, and Battlenet::SessionManager.

 {
 ASSERT(threadCount > 0);

 try
 {
 _acceptor = new AsyncAcceptor(service, bindIp, port);
 }
 catch (boost::system::system_error const& err)
 {
 TC_LOG_ERROR("network", "Exception caught in SocketMgr.StartNetwork (%s:%u): %s", bindIp.c_str(), port, err.what());
 return false;
 }

 _threadCount = threadCount;
 _threads = CreateThreads();

 ASSERT(_threads);

 for (int32 i = 0; i < _threadCount; ++i)
 _threads[i].Start();

 return true;
 }

template<class SocketType>

virtual void SocketMgr< SocketType >::StopNetwork ( )

inlinevirtual

Reimplemented in WorldSocketMgr.

 {
 _acceptor->Close();

 if (_threadCount != 0)
 for (int32 i = 0; i < _threadCount; ++i)
 _threads[i].Stop();

 Wait();

 delete _acceptor;
 _acceptor = nullptr;
 delete[] _threads;
 _threads = nullptr;
 _threadCount = 0;
 }

template<class SocketType>

void SocketMgr< SocketType >::Wait ( )

inline

 {
 if (_threadCount != 0)
 for (int32 i = 0; i < _threadCount; ++i)
 _threads[i].Wait();
 }

Here is the caller graph for this function:

Member Data Documentation

template<class SocketType>

AsyncAcceptor* SocketMgr< SocketType >::_acceptor

protected

template<class SocketType>

int32 SocketMgr< SocketType >::_threadCount

protected

template<class SocketType>

NetworkThread<SocketType>* SocketMgr< SocketType >::_threads

protected

---

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

• src/server/shared/Networking/SocketMgr.h