/*
* This file is part of the TrinityCore Project. See AUTHORS file for Copyright information
*
* This program is free software; you can redistribute it and/or modify it
* under the terms of the GNU General Public License as published by the
* Free Software Foundation; either version 2 of the License, or (at your
* option) any later version.
*
* This program is distributed in the hope that it will be useful, but WITHOUT
* ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
* FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for
* more details.
*
* You should have received a copy of the GNU General Public License along
* with this program. If not, see .
*/
#ifndef TRINITYCORE_NETWORK_THREAD_H
#define TRINITYCORE_NETWORK_THREAD_H
#include "Containers.h"
#include "DeadlineTimer.h"
#include "Define.h"
#include "Errors.h"
#include "IoContext.h"
#include "Log.h"
#include "Socket.h"
#include
#include
#include
#include
#include
namespace Trinity::Net
{
template
class NetworkThread
{
public:
NetworkThread() : _connections(0), _stopped(false), _thread(nullptr), _ioContext(1),
_acceptSocket(_ioContext), _updateTimer(_ioContext)
{
}
NetworkThread(NetworkThread const&) = delete;
NetworkThread(NetworkThread&&) = delete;
NetworkThread& operator=(NetworkThread const&) = delete;
NetworkThread& operator=(NetworkThread&&) = delete;
virtual ~NetworkThread()
{
Stop();
if (_thread)
Wait();
}
void Stop()
{
_stopped = true;
_ioContext.stop();
}
bool Start()
{
if (_thread)
return false;
_thread = std::make_unique(&NetworkThread::Run, this);
return true;
}
void Wait()
{
ASSERT(_thread);
_thread->join();
_thread = nullptr;
}
int32 GetConnectionCount() const
{
return _connections;
}
void AddSocket(std::shared_ptr sock)
{
std::lock_guard lock(_newSocketsLock);
++_connections;
SocketAdded(_newSockets.emplace_back(std::move(sock)));
}
Trinity::Net::IoContextTcpSocket* GetSocketForAccept() { return &_acceptSocket; }
protected:
virtual void SocketAdded(std::shared_ptr const& /*sock*/) { }
virtual void SocketRemoved(std::shared_ptr const& /*sock*/) { }
void AddNewSockets()
{
std::lock_guard lock(_newSocketsLock);
if (_newSockets.empty())
return;
for (std::shared_ptr& sock : _newSockets)
{
if (!sock->IsOpen())
{
SocketRemoved(sock);
--_connections;
}
else
_sockets.emplace_back(std::move(sock));
}
_newSockets.clear();
}
void Run()
{
TC_LOG_DEBUG("misc", "Network Thread Starting");
_updateTimer.expires_after(1ms);
_updateTimer.async_wait([this](boost::system::error_code const&) { Update(); });
_ioContext.run();
TC_LOG_DEBUG("misc", "Network Thread exits");
_newSockets.clear();
_sockets.clear();
}
void Update()
{
if (_stopped)
return;
_updateTimer.expires_after(1ms);
_updateTimer.async_wait([this](boost::system::error_code const&) { Update(); });
AddNewSockets();
Trinity::Containers::EraseIf(_sockets, [this](std::shared_ptr const& sock)
{
if (!sock->Update())
{
if (sock->IsOpen())
sock->CloseSocket();
this->SocketRemoved(sock);
--this->_connections;
return true;
}
return false;
});
}
private:
typedef std::vector> SocketContainer;
std::atomic _connections;
std::atomic _stopped;
std::unique_ptr _thread;
SocketContainer _sockets;
std::mutex _newSocketsLock;
SocketContainer _newSockets;
Trinity::Asio::IoContext _ioContext;
Trinity::Net::IoContextTcpSocket _acceptSocket;
Trinity::Asio::DeadlineTimer _updateTimer;
};
}
#endif // TRINITYCORE_NETWORK_THREAD_H