18#ifndef NetworkThread_h__
19#define NetworkThread_h__
26#include <boost/asio/ip/tcp.hpp>
32template<
class SocketType>
102 for (std::shared_ptr<SocketType> sock :
_newSockets)
120 _updateTimer.expires_from_now(boost::posix_time::milliseconds(1));
134 _updateTimer.expires_from_now(boost::posix_time::milliseconds(1));
146 this->SocketRemoved(sock);
148 --this->_connections;
#define TC_LOG_DEBUG(filterType__,...)
virtual void SocketRemoved(std::shared_ptr< SocketType >)
int32 GetConnectionCount() const
boost::asio::ip::tcp::socket _acceptSocket
virtual void SocketAdded(std::shared_ptr< SocketType >)
std::mutex _newSocketsLock
boost::asio::ip::tcp::socket * GetSocketForAccept()
Trinity::Asio::DeadlineTimer _updateTimer
Trinity::Asio::IoContext _ioContext
std::vector< std::shared_ptr< SocketType > > SocketContainer
std::atomic< bool > _stopped
SocketContainer _newSockets
void AddSocket(std::shared_ptr< SocketType > sock)
std::atomic< int32 > _connections