EAthena::Network Class Reference

#include <network.h>

Inheritance diagram for EAthena::Network:

Public Member Functions
	Network ()
	~Network ()
void	clearHandlers ()
bool	messageReady ()
void	dispatchMessages ()
void	registerHandlers ()
void	registerFakeHandlers ()
Public Member Functions inherited from Ea::Network
	Network ()
bool	connect (const ServerInfo &server)
void	disconnect ()
ServerInfo	getServer () const
int	getState () const
const std::string &	getError () const
bool	isConnected () const
int	getInSize () const
void	skip (const int len)
void	flush ()
void	fixSendBuffer ()
void	pauseDispatch ()

Static Public Attributes
static Network *	mInstance = 0

Static Protected Member Functions
static Network *	instance ()

Friends
class	MessageOut

Additional Inherited Members
Public Types inherited from Ea::Network
enum	{   IDLE = 0 , CONNECTED , CONNECTING , DATA ,   NET_ERROR }
Protected Member Functions inherited from Ea::Network
void	setError (const std::string &error)
uint16_t	readWord (const int pos) const
bool	realConnect ()
void	receive ()
Protected Attributes inherited from Ea::Network
TcpNet::Socket	mSocket
ServerInfo	mServer
PacketInfo *	mPackets
char *	mInBuffer
char *	mOutBuffer
unsigned int	mInSize
unsigned int	mOutSize
unsigned int	mToSkip
int	mState
std::string	mError
SDL_Thread *	mWorkerThread
SDL_mutex *	mMutexIn
SDL_mutex *	mMutexOut
int	mSleep
bool	mPauseDispatch

Detailed Description

Definition at line 38 of file network.h.

Constructor & Destructor Documentation

Network()

EAthena::Network::Network

(

)

Definition at line 112 of file network.cpp.

 :
 Ea::Network()
{
 mInstance = this;
 mPackets = new PacketInfo[messagesSize];
}

References EAthena::messagesSize, mInstance, and Ea::Network::mPackets.

~Network()

EAthena::Network::~Network ( )

virtual

Reimplemented from Ea::Network.

Definition at line 119 of file network.cpp.

{
 clearHandlers();
 mInstance = nullptr;
}

References clearHandlers(), and mInstance.

Member Function Documentation

clearHandlers()

void EAthena::Network::clearHandlers

(

)

Definition at line 183 of file network.cpp.

{
 for (size_t f = 0; f < packet_lengths_size; f ++)
 {
 mPackets[f].name = "";
 mPackets[f].len = 0;
 mPackets[f].func = nullptr;
 mPackets[f].version = 0;
 }
}

References PacketInfo::func, PacketInfo::len, Ea::Network::mPackets, PacketInfo::name, EAthena::packet_lengths_size, and PacketInfo::version.

Referenced by EAthena::GeneralHandler::clearHandlers(), EAthena::updateProtocol(), and ~Network().

dispatchMessages()

void EAthena::Network::dispatchMessages

(

)

Definition at line 194 of file network.cpp.

{
 mPauseDispatch = false;
 while (messageReady())
 {
 SDL_mutexP(mMutexIn);
 const unsigned int msgId = readWord(0);
 int len = -1;
 if (msgId < packet_lengths_size)
 len = mPackets[msgId].len;
 if (len == -1)
 len = readWord(2);
 
 MessageIn msg(mInBuffer, len);
 unsigned int ver = mPackets[msgId].version;
 if (ver == 0)
 ver = packetVersion;
 msg.postInit(mPackets[msgId].name, ver);
 SDL_mutexV(mMutexIn);
 
 if (len == 0)
 {
 // need copy data for safty
 std::string str = strprintf(
 "Wrong packet %u 0x%x received. Exiting.",
 msgId, msgId);
 logger->safeError(str);
 }
 
 if (msgId < messagesSize)
 {
 const PacketFuncPtr func = mPackets[msgId].func;
 if (func != nullptr)
 func(msg);
 else
 logger->log("Unhandled packet: %u 0x%x", msgId, msgId);
 }
 
 skip(len);
 if (mPauseDispatch)
 break;
 }
}

References PacketInfo::func, PacketInfo::len, Logger::log(), logger, messageReady(), EAthena::messagesSize, Ea::Network::mInBuffer, Ea::Network::mMutexIn, Ea::Network::mPackets, Ea::Network::mPauseDispatch, Actions::msg(), EAthena::packet_lengths_size, packetVersion, Ea::Network::readWord(), Logger::safeError(), Ea::Network::skip(), strprintf(), and PacketInfo::version.

Referenced by EAthena::GeneralHandler::flushNetwork().

instance()

Network * EAthena::Network::instance ( )

staticprotected

Definition at line 262 of file network.cpp.

{
 return mInstance;
}

References mInstance.

messageReady()

bool EAthena::Network::messageReady

(

)

Definition at line 238 of file network.cpp.

{
 int len = -1;
 
 SDL_mutexP(mMutexIn);
 if (mInSize >= 2)
 {
 const int msgId = readWord(0);
 if (msgId >= 0 &&
 CAST_U32(msgId) < packet_lengths_size)
 {
 len = mPackets[msgId].len;
 }
 
 if (len == -1 && mInSize > 4)
 len = readWord(2);
 }
 
 const bool ret = (mInSize >= CAST_U32(len));
 SDL_mutexV(mMutexIn);
 
 return ret;
}

References CAST_U32, PacketInfo::len, Ea::Network::mInSize, Ea::Network::mMutexIn, Ea::Network::mPackets, EAthena::packet_lengths_size, and Ea::Network::readWord().

Referenced by dispatchMessages().

registerFakeHandlers()

void EAthena::Network::registerFakeHandlers

(

)

Definition at line 131 of file network.cpp.

{
 const NetworkInPacketInfos &packets = NetworkDb::getFakePackets();
 FOR_EACH (NetworkInPacketInfosIter, it, packets)
 {
 const size_t id = (*it).first;
 if (id >= packet_lengths_size)
 {
 reportAlways("Wrong fake packet id %d", CAST_S32(id))
 continue;
 }
 if (mPackets[id].len != 0 ||
 mPackets[id].func != nullptr ||
 mPackets[id].version != 0)
 {
 continue;
 }
 const int32_t len = (*it).second;
 logger->log("Add fake packet: %d, %d",
 CAST_S32(id),
 len);
 mPackets[id].name = "fake";
 mPackets[id].len = len;
 mPackets[id].func = nullptr;
 mPackets[id].version = 0;
 }
 
 const NetworkRemovePacketInfos &removePackets =
 NetworkDb::getRemovePackets();
 FOR_EACH (NetworkRemovePacketInfosIter, it, removePackets)
 {
 const size_t id = *it;
 if (id >= packet_lengths_size)
 {
 reportAlways("Wrong remove packet id %d", CAST_S32(id))
 continue;
 }
 if (mPackets[id].len == 0 &&
 mPackets[id].func == nullptr &&
 mPackets[id].version == 0)
 {
 continue;
 }
 logger->log("Remove packet: %d",
 CAST_S32(id));
 mPackets[id].name = "";
 mPackets[id].len = 0;
 mPackets[id].func = nullptr;
 mPackets[id].version = 0;
 }
}

References CAST_S32, FOR_EACH, PacketInfo::func, NetworkDb::getFakePackets(), NetworkDb::getRemovePackets(), PacketInfo::len, Logger::log(), logger, Ea::Network::mPackets, PacketInfo::name, EAthena::packet_lengths_size, reportAlways, and PacketInfo::version.

Referenced by EAthena::updateProtocol().

registerHandlers()

void EAthena::Network::registerHandlers

(

)

Definition at line 125 of file network.cpp.

{
#include "net/eathena/recvpackets.inc"
 RECVPACKETS_VOID
}

Referenced by EAthena::GeneralHandler::load(), and EAthena::updateProtocol().

Friends And Related Function Documentation

MessageOut

friend class MessageOut

friend

Definition at line 60 of file network.h.

Field Documentation

mInstance

Network * EAthena::Network::mInstance = 0

static

Definition at line 57 of file network.h.

Referenced by EAthena::GeneralHandler::clearHandlers(), EAthena::CharServerHandler::connect(), EAthena::GameHandler::connect(), EAthena::LoginHandler::connect(), EAthena::GameHandler::disconnect(), EAthena::LoginHandler::disconnect(), EAthena::GeneralHandler::flushNetwork(), EAthena::GeneralHandler::flushSend(), instance(), EAthena::GameHandler::isConnected(), EAthena::LoginHandler::isConnected(), EAthena::GeneralHandler::load(), Network(), EAthena::CharServerRecv::processChangeMapServer(), EAthena::CharServerRecv::processCharMapInfo(), EAthena::GameRecv::processMapLogin(), EAthena::GeneralHandler::reload(), EAthena::updateProtocol(), EAthena::GeneralHandler::~GeneralHandler(), and ~Network().

---

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

• src/net/eathena/network.h (986a3bf)
• src/net/eathena/network.cpp (986a3bf)