diff --git a/pokerth_lib.pro b/pokerth_lib.pro index 85bbad4b..782a830f 100644 --- a/pokerth_lib.pro +++ b/pokerth_lib.pro @@ -73,8 +73,8 @@ HEADERS += \ src/net/netpacket.h \ src/net/resolverthread.h \ src/net/senderinterface.h \ - src/net/senderthread.h \ - src/net/serveracceptmanager.h \ + src/net/senderhelper.h \ + src/net/serveraccepthelper.h \ src/net/servergamethread.h \ src/net/servergamestate.h \ src/net/serverlobbythread.h \ @@ -168,11 +168,11 @@ SOURCES += \ src/net/common/netpacket.cpp \ src/net/common/resolverthread.cpp \ src/net/common/senderinterface.cpp \ - src/net/common/senderthread.cpp \ + src/net/common/senderhelper.cpp \ src/net/common/sendercallback.cpp \ src/net/common/servercontext.cpp \ src/net/common/serverexception.cpp \ - src/net/common/serveracceptmanager.cpp \ + src/net/common/serveraccepthelper.cpp \ src/net/common/servergamethread.cpp \ src/net/common/servergamestate.cpp \ src/net/common/serverlobbythread.cpp \ diff --git a/src/net/clientthread.h b/src/net/clientthread.h index af48ea9e..1faee779 100644 --- a/src/net/clientthread.h +++ b/src/net/clientthread.h @@ -233,7 +233,7 @@ private: mutable boost::mutex m_curStatsMutex; ServerStats m_curStats; - boost::shared_ptr m_senderThread; + boost::shared_ptr m_senderHelper; friend class AbstractClientStateReceiving; friend class ClientStateInit; diff --git a/src/net/common/clientstate.cpp b/src/net/common/clientstate.cpp index 505b3e4e..4e150ee8 100644 --- a/src/net/common/clientstate.cpp +++ b/src/net/common/clientstate.cpp @@ -20,7 +20,7 @@ #include #include #include -#include +#include #include #include #include diff --git a/src/net/common/clientthread.cpp b/src/net/common/clientthread.cpp index 9b9d5f48..90b95770 100644 --- a/src/net/common/clientthread.cpp +++ b/src/net/common/clientthread.cpp @@ -22,7 +22,7 @@ #include #include #include -#include +#include #include #include #include @@ -70,7 +70,7 @@ ClientThread::ClientThread(GuiInterface &gui, AvatarManager &avatarManager) m_receiver.reset(new ReceiverHelper); myQtToolsInterface.reset(CreateQtToolsWrapper()); m_senderCallback.reset(new ClientSenderCallback()); - m_senderThread.reset(new SenderThread(*m_senderCallback, m_ioService)); + m_senderHelper.reset(new SenderHelper(*m_senderCallback, m_ioService)); } ClientThread::~ClientThread() @@ -737,7 +737,7 @@ ClientThread::CreateContextSession() GetContext().SetSessionData(boost::shared_ptr(new SessionData( newSock, SESSION_ID_GENERIC, - m_senderThread, + m_senderHelper, *m_senderCallback))); validSocket = true; } catch (...) diff --git a/src/net/common/senderthread.cpp b/src/net/common/senderhelper.cpp similarity index 95% rename from src/net/common/senderthread.cpp rename to src/net/common/senderhelper.cpp index 05cd941e..58fd1fde 100644 --- a/src/net/common/senderthread.cpp +++ b/src/net/common/senderhelper.cpp @@ -18,7 +18,7 @@ ***************************************************************************/ #include -#include +#include #include #include #include @@ -91,17 +91,17 @@ SendDataManager::AsyncSendNextPacket(bool handlerMode) } } -SenderThread::SenderThread(SenderCallback &cb, boost::shared_ptr ioService) +SenderHelper::SenderHelper(SenderCallback &cb, boost::shared_ptr ioService) : m_callback(cb), m_ioService(ioService) { } -SenderThread::~SenderThread() +SenderHelper::~SenderHelper() { } void -SenderThread::Send(boost::shared_ptr session, boost::shared_ptr packet) +SenderHelper::Send(boost::shared_ptr session, boost::shared_ptr packet) { if (packet.get() && session.get()) { @@ -129,7 +129,7 @@ SenderThread::Send(boost::shared_ptr session, boost::shared_ptr session, const NetPacketList &packetList) +SenderHelper::Send(boost::shared_ptr session, const NetPacketList &packetList) { if (!packetList.empty() && session.get()) { @@ -165,14 +165,14 @@ SenderThread::Send(boost::shared_ptr session, const NetPacketList & } void -SenderThread::SignalSessionTerminated(unsigned sessionId) +SenderHelper::SignalSessionTerminated(unsigned sessionId) { boost::mutex::scoped_lock lock(m_removedSessionsMutex); m_removedSessions.push_back(sessionId); } void -SenderThread::Process() +SenderHelper::Process() { // Close sessions if they were destructed. { diff --git a/src/net/common/serveracceptmanager.cpp b/src/net/common/serveraccepthelper.cpp similarity index 83% rename from src/net/common/serveracceptmanager.cpp rename to src/net/common/serveraccepthelper.cpp index 05de2574..009cc6e9 100644 --- a/src/net/common/serveracceptmanager.cpp +++ b/src/net/common/serveraccepthelper.cpp @@ -17,7 +17,7 @@ * 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA. * ***************************************************************************/ -#include +#include #include #include #include @@ -29,18 +29,18 @@ using namespace std; using boost::asio::ip::tcp; -ServerAcceptManager::ServerAcceptManager(ServerCallback &serverCallback, boost::shared_ptr ioService) +ServerAcceptHelper::ServerAcceptHelper(ServerCallback &serverCallback, boost::shared_ptr ioService) : m_ioService(ioService), m_serverCallback(serverCallback) { m_acceptor.reset(new tcp::acceptor(*m_ioService)); } -ServerAcceptManager::~ServerAcceptManager() +ServerAcceptHelper::~ServerAcceptHelper() { } void -ServerAcceptManager::Listen(unsigned serverPort, bool ipv6, bool sctp, const string &pwd, const string &logDir, boost::shared_ptr lobbyThread) +ServerAcceptHelper::Listen(unsigned serverPort, bool ipv6, bool sctp, const string &pwd, const string &logDir, boost::shared_ptr lobbyThread) { m_lobbyThread = lobbyThread; @@ -63,7 +63,7 @@ ServerAcceptManager::Listen(unsigned serverPort, bool ipv6, bool sctp, const str } void -ServerAcceptManager::InternalListen(unsigned serverPort, bool ipv6, bool sctp) +ServerAcceptHelper::InternalListen(unsigned serverPort, bool ipv6, bool sctp) { if (serverPort < 1024) throw ServerException(__FILE__, __LINE__, ERR_SOCK_INVALID_PORT, 0); @@ -89,13 +89,13 @@ ServerAcceptManager::InternalListen(unsigned serverPort, bool ipv6, bool sctp) boost::shared_ptr newSocket(new tcp::socket(*m_ioService)); m_acceptor->async_accept( *newSocket, - boost::bind(&ServerAcceptManager::HandleAccept, this, newSocket, + boost::bind(&ServerAcceptHelper::HandleAccept, this, newSocket, boost::asio::placeholders::error) ); } void -ServerAcceptManager::HandleAccept(boost::shared_ptr acceptedSocket, +ServerAcceptHelper::HandleAccept(boost::shared_ptr acceptedSocket, const boost::system::error_code& error) { if (!error) @@ -109,7 +109,7 @@ ServerAcceptManager::HandleAccept(boost::shared_ptr newSocket(new tcp::socket(*m_ioService)); m_acceptor->async_accept( *newSocket, - boost::bind(&ServerAcceptManager::HandleAccept, this, newSocket, + boost::bind(&ServerAcceptHelper::HandleAccept, this, newSocket, boost::asio::placeholders::error) ); } @@ -122,13 +122,13 @@ ServerAcceptManager::HandleAccept(boost::shared_ptr #include #include -#include +#include #include #include #include diff --git a/src/net/common/servergamethread.cpp b/src/net/common/servergamethread.cpp index fe08ebef..e2acf518 100644 --- a/src/net/common/servergamethread.cpp +++ b/src/net/common/servergamethread.cpp @@ -21,7 +21,7 @@ #include #include #include -#include +#include #include #include #include diff --git a/src/net/common/serverlobbythread.cpp b/src/net/common/serverlobbythread.cpp index 36c02db8..6a512623 100644 --- a/src/net/common/serverlobbythread.cpp +++ b/src/net/common/serverlobbythread.cpp @@ -20,7 +20,7 @@ #include #include #include -#include +#include #include #include #include @@ -93,7 +93,7 @@ ServerLobbyThread::ServerLobbyThread(GuiInterface &gui, ConfigFile *playerConfig m_statDataChanged(false), m_startTime(boost::posix_time::second_clock::local_time()) { m_senderCallback.reset(new ServerSenderCallback(*this)); - m_sender.reset(new SenderThread(*m_senderCallback, m_ioService)); + m_sender.reset(new SenderHelper(*m_senderCallback, m_ioService)); m_receiver.reset(new ReceiverHelper); } diff --git a/src/net/common/servermanager.cpp b/src/net/common/servermanager.cpp index 82f70795..4fba7fbe 100644 --- a/src/net/common/servermanager.cpp +++ b/src/net/common/servermanager.cpp @@ -23,7 +23,7 @@ #include #include #include -#include +#include #include #include #include @@ -54,15 +54,15 @@ ServerManager::Init(unsigned serverPort, bool ipv6, ServerNetworkMode mode, cons if (mode & NETWORK_MODE_TCP) { - boost::shared_ptr tcpAcceptThread(new ServerAcceptManager(GetGui(), m_ioService)); - tcpAcceptThread->Listen(serverPort, ipv6, false, pwd, logDir, m_lobbyThread); - m_acceptManagerPool.push_back(tcpAcceptThread); + boost::shared_ptr tcpAcceptHelper(new ServerAcceptHelper(GetGui(), m_ioService)); + tcpAcceptHelper->Listen(serverPort, ipv6, false, pwd, logDir, m_lobbyThread); + m_acceptHelperPool.push_back(tcpAcceptHelper); } if (mode & NETWORK_MODE_SCTP) { - boost::shared_ptr sctpAcceptThread(new ServerAcceptManager(GetGui(), m_ioService)); - sctpAcceptThread->Listen(serverPort, ipv6, true, pwd, logDir, m_lobbyThread); - m_acceptManagerPool.push_back(sctpAcceptThread); + boost::shared_ptr sctpAcceptHelper(new ServerAcceptHelper(GetGui(), m_ioService)); + sctpAcceptHelper->Listen(serverPort, ipv6, true, pwd, logDir, m_lobbyThread); + m_acceptHelperPool.push_back(sctpAcceptHelper); } m_ircThread = ircThread; } diff --git a/src/net/senderthread.h b/src/net/senderhelper.h similarity index 92% rename from src/net/senderthread.h rename to src/net/senderhelper.h index cd43eb84..7b7c54c7 100644 --- a/src/net/senderthread.h +++ b/src/net/senderhelper.h @@ -18,8 +18,8 @@ ***************************************************************************/ /* Network sender thread. */ -#ifndef _SENDERTHREAD_H_ -#define _SENDERTHREAD_H_ +#ifndef _SENDERHELPER_H_ +#define _SENDERHELPER_H_ #include #include @@ -28,11 +28,11 @@ class SessionData; class SendDataManager; -class SenderThread : public SenderInterface +class SenderHelper : public SenderInterface { public: - SenderThread(SenderCallback &cb, boost::shared_ptr ioService); - virtual ~SenderThread(); + SenderHelper(SenderCallback &cb, boost::shared_ptr ioService); + virtual ~SenderHelper(); virtual void Send(boost::shared_ptr session, boost::shared_ptr packet); virtual void Send(boost::shared_ptr session, const NetPacketList &packetList); diff --git a/src/net/serveracceptmanager.h b/src/net/serveraccepthelper.h similarity index 88% rename from src/net/serveracceptmanager.h rename to src/net/serveraccepthelper.h index 20274402..aa52dc9c 100644 --- a/src/net/serveracceptmanager.h +++ b/src/net/serveraccepthelper.h @@ -16,10 +16,10 @@ * Free Software Foundation, Inc., * * 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA. * ***************************************************************************/ -/* Network server manager to accept connections. */ +/* Network server helper to accept connections. */ -#ifndef _SERVERACCEPTMANAGER_H_ -#define _SERVERACCEPTMANAGER_H_ +#ifndef _SERVERACCEPTHELPER_H_ +#define _SERVERACCEPTHELPER_H_ #include #include @@ -29,11 +29,11 @@ class ServerLobbyThread; -class ServerAcceptManager +class ServerAcceptHelper { public: - ServerAcceptManager(ServerCallback &serverCallback, boost::shared_ptr ioService); - virtual ~ServerAcceptManager(); + ServerAcceptHelper(ServerCallback &serverCallback, boost::shared_ptr ioService); + virtual ~ServerAcceptHelper(); // Set the parameters. void Listen(unsigned serverPort, bool ipv6, bool sctp, const std::string &pwd, const std::string &logDir, diff --git a/src/net/servermanager.h b/src/net/servermanager.h index 9262578d..906d496f 100644 --- a/src/net/servermanager.h +++ b/src/net/servermanager.h @@ -30,7 +30,7 @@ #include class ServerLobbyThread; -class ServerAcceptManager; +class ServerAcceptHelper; class SenderThread; class ConfigFile; class AvatarManager; @@ -67,7 +67,7 @@ public: virtual void SignalIrcServerError(int errorCode); protected: - typedef std::list > AcceptManagerList; + typedef std::list > AcceptHelperList; ServerLobbyThread &GetLobbyThread(); @@ -82,7 +82,7 @@ private: boost::shared_ptr m_lobbyThread; boost::shared_ptr m_ircThread; boost::timers::portable::microsec_timer m_ircRestartTimer; - AcceptManagerList m_acceptManagerPool; + AcceptHelperList m_acceptHelperPool; }; #endif