#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

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

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

Public Member Functions

Static Public Attributes

Static Protected Member Functions

Friends

Additional Inherited Members