diff options
author | leak <leak@bitmx.net> | 2014-07-07 22:03:41 +0200 |
---|---|---|
committer | leak <leak@bitmx.net> | 2014-07-07 22:03:41 +0200 |
commit | a738cd96dcf506530e79ecb1f53e09fd59511a70 (patch) | |
tree | 4b2ade3d7750ea39bc6aad0f30b306cbfb8efb96 /src | |
parent | c7d5660e992bdec5cdac6a9fab76ecb6447dcb49 (diff) |
Renamed WorldTcpSession back to WorldSocket
Diffstat (limited to 'src')
-rw-r--r-- | src/server/game/Scripting/ScriptMgr.cpp | 10 | ||||
-rw-r--r-- | src/server/game/Scripting/ScriptMgr.h | 22 | ||||
-rw-r--r-- | src/server/game/Server/WorldSession.cpp | 4 | ||||
-rw-r--r-- | src/server/game/Server/WorldSession.h | 6 | ||||
-rw-r--r-- | src/server/game/Server/WorldSocket.cpp (renamed from src/server/game/Server/WorldTcpSession.cpp) | 20 | ||||
-rw-r--r-- | src/server/game/Server/WorldSocket.h (renamed from src/server/game/Server/WorldTcpSession.h) | 8 | ||||
-rw-r--r-- | src/server/worldserver/Main.cpp | 4 |
7 files changed, 37 insertions, 37 deletions
diff --git a/src/server/game/Scripting/ScriptMgr.cpp b/src/server/game/Scripting/ScriptMgr.cpp index b45ed6b640c..1b91ed1690c 100644 --- a/src/server/game/Scripting/ScriptMgr.cpp +++ b/src/server/game/Scripting/ScriptMgr.cpp @@ -400,35 +400,35 @@ void ScriptMgr::OnNetworkStop() FOREACH_SCRIPT(ServerScript)->OnNetworkStop(); } -void ScriptMgr::OnSocketOpen(std::shared_ptr<WorldTcpSession> socket) +void ScriptMgr::OnSocketOpen(std::shared_ptr<WorldSocket> socket) { ASSERT(socket); FOREACH_SCRIPT(ServerScript)->OnSocketOpen(socket); } -void ScriptMgr::OnSocketClose(std::shared_ptr<WorldTcpSession> socket, bool wasNew) +void ScriptMgr::OnSocketClose(std::shared_ptr<WorldSocket> socket, bool wasNew) { ASSERT(socket); FOREACH_SCRIPT(ServerScript)->OnSocketClose(socket, wasNew); } -void ScriptMgr::OnPacketReceive(std::shared_ptr<WorldTcpSession> socket, WorldPacket packet) +void ScriptMgr::OnPacketReceive(std::shared_ptr<WorldSocket> socket, WorldPacket packet) { ASSERT(socket); FOREACH_SCRIPT(ServerScript)->OnPacketReceive(socket, packet); } -void ScriptMgr::OnPacketSend(std::shared_ptr<WorldTcpSession> socket, WorldPacket packet) +void ScriptMgr::OnPacketSend(std::shared_ptr<WorldSocket> socket, WorldPacket packet) { ASSERT(socket); FOREACH_SCRIPT(ServerScript)->OnPacketSend(socket, packet); } -void ScriptMgr::OnUnknownPacketReceive(std::shared_ptr<WorldTcpSession> socket, WorldPacket packet) +void ScriptMgr::OnUnknownPacketReceive(std::shared_ptr<WorldSocket> socket, WorldPacket packet) { ASSERT(socket); diff --git a/src/server/game/Scripting/ScriptMgr.h b/src/server/game/Scripting/ScriptMgr.h index 81c764cb1ca..260c43f9b3b 100644 --- a/src/server/game/Scripting/ScriptMgr.h +++ b/src/server/game/Scripting/ScriptMgr.h @@ -57,7 +57,7 @@ class Transport; class Unit; class Vehicle; class WorldPacket; -class WorldTcpSession; +class WorldSocket; class WorldObject; struct AchievementCriteriaData; @@ -221,23 +221,23 @@ class ServerScript : public ScriptObject virtual void OnNetworkStop() { } // Called when a remote socket establishes a connection to the server. Do not store the socket object. - virtual void OnSocketOpen(std::shared_ptr<WorldTcpSession> /*socket*/) { } + virtual void OnSocketOpen(std::shared_ptr<WorldSocket> /*socket*/) { } // Called when a socket is closed. Do not store the socket object, and do not rely on the connection // being open; it is not. - virtual void OnSocketClose(std::shared_ptr<WorldTcpSession> /*socket*/, bool /*wasNew*/) { } + virtual void OnSocketClose(std::shared_ptr<WorldSocket> /*socket*/, bool /*wasNew*/) { } // Called when a packet is sent to a client. The packet object is a copy of the original packet, so reading // and modifying it is safe. - virtual void OnPacketSend(std::shared_ptr<WorldTcpSession> /*socket*/, WorldPacket& /*packet*/) { } + virtual void OnPacketSend(std::shared_ptr<WorldSocket> /*socket*/, WorldPacket& /*packet*/) { } // Called when a (valid) packet is received by a client. The packet object is a copy of the original packet, so // reading and modifying it is safe. - virtual void OnPacketReceive(std::shared_ptr<WorldTcpSession> /*socket*/, WorldPacket& /*packet*/) { } + virtual void OnPacketReceive(std::shared_ptr<WorldSocket> /*socket*/, WorldPacket& /*packet*/) { } // Called when an invalid (unknown opcode) packet is received by a client. The packet is a reference to the orignal // packet; not a copy. This allows you to actually handle unknown packets (for whatever purpose). - virtual void OnUnknownPacketReceive(std::shared_ptr<WorldTcpSession> /*socket*/, WorldPacket& /*packet*/) { } + virtual void OnUnknownPacketReceive(std::shared_ptr<WorldSocket> /*socket*/, WorldPacket& /*packet*/) { } }; class WorldScript : public ScriptObject @@ -908,11 +908,11 @@ class ScriptMgr void OnNetworkStart(); void OnNetworkStop(); - void OnSocketOpen(std::shared_ptr<WorldTcpSession> socket); - void OnSocketClose(std::shared_ptr<WorldTcpSession> socket, bool wasNew); - void OnPacketReceive(std::shared_ptr<WorldTcpSession> socket, WorldPacket packet); - void OnPacketSend(std::shared_ptr<WorldTcpSession> socket, WorldPacket packet); - void OnUnknownPacketReceive(std::shared_ptr<WorldTcpSession> socket, WorldPacket packet); + void OnSocketOpen(std::shared_ptr<WorldSocket> socket); + void OnSocketClose(std::shared_ptr<WorldSocket> socket, bool wasNew); + void OnPacketReceive(std::shared_ptr<WorldSocket> socket, WorldPacket packet); + void OnPacketSend(std::shared_ptr<WorldSocket> socket, WorldPacket packet); + void OnUnknownPacketReceive(std::shared_ptr<WorldSocket> socket, WorldPacket packet); public: /* WorldScript */ diff --git a/src/server/game/Server/WorldSession.cpp b/src/server/game/Server/WorldSession.cpp index 63bceb53f2c..f30991b385e 100644 --- a/src/server/game/Server/WorldSession.cpp +++ b/src/server/game/Server/WorldSession.cpp @@ -20,7 +20,7 @@ \ingroup u2w */ -#include "WorldTcpSession.h" +#include "WorldSocket.h" #include "Config.h" #include "Common.h" #include "DatabaseEnv.h" @@ -97,7 +97,7 @@ bool WorldSessionFilter::Process(WorldPacket* packet) } /// WorldSession constructor -WorldSession::WorldSession(uint32 id, std::shared_ptr<WorldTcpSession> sock, AccountTypes sec, uint8 expansion, time_t mute_time, LocaleConstant locale, uint32 recruiter, bool isARecruiter): +WorldSession::WorldSession(uint32 id, std::shared_ptr<WorldSocket> sock, AccountTypes sec, uint8 expansion, time_t mute_time, LocaleConstant locale, uint32 recruiter, bool isARecruiter): m_muteTime(mute_time), m_timeOutTime(0), AntiDOS(this), diff --git a/src/server/game/Server/WorldSession.h b/src/server/game/Server/WorldSession.h index d7b2b9ca4d4..06ae5d4f635 100644 --- a/src/server/game/Server/WorldSession.h +++ b/src/server/game/Server/WorldSession.h @@ -46,7 +46,7 @@ class SpellCastTargets; class Unit; class Warden; class WorldPacket; -class WorldTcpSession; +class WorldSocket; struct AreaTableEntry; struct AuctionEntry; struct DeclinedName; @@ -208,7 +208,7 @@ struct PacketCounter class WorldSession { public: - WorldSession(uint32 id, std::shared_ptr<WorldTcpSession> sock, AccountTypes sec, uint8 expansion, time_t mute_time, LocaleConstant locale, uint32 recruiter, bool isARecruiter); + WorldSession(uint32 id, std::shared_ptr<WorldSocket> sock, AccountTypes sec, uint8 expansion, time_t mute_time, LocaleConstant locale, uint32 recruiter, bool isARecruiter); ~WorldSession(); bool PlayerLoading() const { return m_playerLoading; } @@ -981,7 +981,7 @@ class WorldSession uint32 m_GUIDLow; // set logined or recently logout player (while m_playerRecentlyLogout set) Player* _player; - std::shared_ptr<WorldTcpSession> m_Socket; + std::shared_ptr<WorldSocket> m_Socket; std::string m_Address; // Current Remote Address // std::string m_LAddress; // Last Attempted Remote Adress - we can not set attempted ip for a non-existing session! diff --git a/src/server/game/Server/WorldTcpSession.cpp b/src/server/game/Server/WorldSocket.cpp index 89ecb31ae68..f024d3d98ca 100644 --- a/src/server/game/Server/WorldTcpSession.cpp +++ b/src/server/game/Server/WorldSocket.cpp @@ -19,7 +19,7 @@ #include <boost/asio/write.hpp> #include <boost/asio/read_until.hpp> #include <memory> -#include "WorldTcpSession.h" +#include "WorldSocket.h" #include "ServerPktHeader.h" #include "BigNumber.h" #include "Opcodes.h" @@ -29,18 +29,18 @@ using boost::asio::ip::tcp; using boost::asio::streambuf; -WorldTcpSession::WorldTcpSession(tcp::socket socket) +WorldSocket::WorldSocket(tcp::socket socket) : _socket(std::move(socket)), _authSeed(static_cast<uint32>(rand32())), _worldSession(nullptr), _OverSpeedPings(0) { } -void WorldTcpSession::Start() +void WorldSocket::Start() { AsyncReadHeader(); HandleSendAuthSession(); } -void WorldTcpSession::HandleSendAuthSession() +void WorldSocket::HandleSendAuthSession() { WorldPacket packet(SMSG_AUTH_CHALLENGE, 37); packet << uint32(1); // 1...31 @@ -58,7 +58,7 @@ void WorldTcpSession::HandleSendAuthSession() } -void WorldTcpSession::AsyncReadHeader() +void WorldSocket::AsyncReadHeader() { auto self(shared_from_this()); _socket.async_read_some(boost::asio::buffer(_readBuffer, sizeof(ClientPktHeader)), [this, self](boost::system::error_code error, size_t transferedBytes) @@ -82,7 +82,7 @@ void WorldTcpSession::AsyncReadHeader() }); } -void WorldTcpSession::AsyncReadData(size_t dataSize) +void WorldSocket::AsyncReadData(size_t dataSize) { auto self(shared_from_this()); _socket.async_read_some(boost::asio::buffer(&_readBuffer[sizeof(ClientPktHeader)], dataSize), [this, dataSize, self](boost::system::error_code error, size_t transferedBytes) @@ -152,7 +152,7 @@ void WorldTcpSession::AsyncReadData(size_t dataSize) }); } -void WorldTcpSession::AsyncWrite(WorldPacket const& packet) +void WorldSocket::AsyncWrite(WorldPacket const& packet) { ServerPktHeader header(packet.size() + 2, packet.GetOpcode()); _authCrypt.EncryptSend((uint8*)header.header, header.getHeaderLength()); @@ -177,7 +177,7 @@ void WorldTcpSession::AsyncWrite(WorldPacket const& packet) }); } -void WorldTcpSession::HandleAuthSession(WorldPacket& recvPacket) +void WorldSocket::HandleAuthSession(WorldPacket& recvPacket) { uint8 digest[20]; uint32 clientSeed; @@ -404,7 +404,7 @@ void WorldTcpSession::HandleAuthSession(WorldPacket& recvPacket) sWorld->AddSession(_worldSession); } -void WorldTcpSession::SendAuthResponseError(uint8 code) +void WorldSocket::SendAuthResponseError(uint8 code) { WorldPacket packet(SMSG_AUTH_RESPONSE, 1); packet << uint8(code); @@ -412,7 +412,7 @@ void WorldTcpSession::SendAuthResponseError(uint8 code) AsyncWrite(packet); } -void WorldTcpSession::HandlePing(WorldPacket& recvPacket) +void WorldSocket::HandlePing(WorldPacket& recvPacket) { uint32 ping; uint32 latency; diff --git a/src/server/game/Server/WorldTcpSession.h b/src/server/game/Server/WorldSocket.h index 387768bfbef..ddce699f7f1 100644 --- a/src/server/game/Server/WorldTcpSession.h +++ b/src/server/game/Server/WorldSocket.h @@ -41,13 +41,13 @@ struct ClientPktHeader #pragma pack(pop) -class WorldTcpSession : public std::enable_shared_from_this<WorldTcpSession> +class WorldSocket : public std::enable_shared_from_this<WorldSocket> { public: - WorldTcpSession(tcp::socket socket); + WorldSocket(tcp::socket socket); - WorldTcpSession(WorldTcpSession const& right) = delete; - WorldTcpSession& operator=(WorldTcpSession const& right) = delete; + WorldSocket(WorldSocket const& right) = delete; + WorldSocket& operator=(WorldSocket const& right) = delete; void Start(); diff --git a/src/server/worldserver/Main.cpp b/src/server/worldserver/Main.cpp index dae947b7324..15a282b70ea 100644 --- a/src/server/worldserver/Main.cpp +++ b/src/server/worldserver/Main.cpp @@ -43,7 +43,7 @@ #include "TCSoap.h" #include "CliRunnable.h" #include "SystemConfig.h" -#include "WorldTcpSession.h" +#include "WorldSocket.h" #define TRINITY_CORE_CONFIG "worldserver.conf" #define WORLD_SLEEP_CONST 50 @@ -230,7 +230,7 @@ extern int main(int argc, char** argv) std::string worldListener = sConfigMgr->GetStringDefault("BindIP", "0.0.0.0"); bool tcpNoDelay = sConfigMgr->GetBoolDefault("Network.TcpNodelay", true); - AsyncAcceptor<WorldTcpSession> worldAcceptor(_ioService, worldListener, worldPort, tcpNoDelay); + AsyncAcceptor<WorldSocket> worldAcceptor(_ioService, worldListener, worldPort, tcpNoDelay); sScriptMgr->OnStartup(); |