TmwAthena::Network Class Reference

#include <network.h>

Inheritance diagram for TmwAthena::Network:

Public Member Functions
	Network ()
	~Network ()
void	clearHandlers ()
bool	messageReady ()
void	dispatchMessages ()
void	registerHandlers ()
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 37 of file network.h.

Constructor & Destructor Documentation

Network()

TmwAthena::Network::Network

(

)

Definition at line 74 of file network.cpp.

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

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

~Network()

TmwAthena::Network::~Network ( )

virtual

Reimplemented from Ea::Network.

Definition at line 81 of file network.cpp.

{
    clearHandlers();
    mInstance = nullptr;
}

References clearHandlers(), and mInstance.

Member Function Documentation

clearHandlers()

void TmwAthena::Network::clearHandlers

(

)

Definition at line 93 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, TmwAthena::packet_lengths_size, and PacketInfo::version.

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

dispatchMessages()

void TmwAthena::Network::dispatchMessages

(

)

Definition at line 104 of file network.cpp.

{
    BLOCK_START("Network::dispatchMessages 1")
    mPauseDispatch = false;
    while (messageReady())
    {
        SDL_mutexP(mMutexIn);
        BLOCK_START("Network::dispatchMessages 2")
        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);
        msg.postInit(mPackets[msgId].name);
        SDL_mutexV(mMutexIn);
        BLOCK_END("Network::dispatchMessages 2")
        BLOCK_START("Network::dispatchMessages 3")
 
        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)
        {
            BLOCK_END("Network::dispatchMessages 3")
            break;
        }
        BLOCK_END("Network::dispatchMessages 3")
    }
    BLOCK_END("Network::dispatchMessages 1")
}

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

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

instance()

Network * TmwAthena::Network::instance ( )

staticprotected

Definition at line 179 of file network.cpp.

{
    return mInstance;
}

References mInstance.

messageReady()

bool TmwAthena::Network::messageReady

(

)

Definition at line 155 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, TmwAthena::packet_lengths_size, and Ea::Network::readWord().

Referenced by dispatchMessages().

registerHandlers()

void TmwAthena::Network::registerHandlers

(

)

Definition at line 87 of file network.cpp.

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

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

Friends And Related Function Documentation

MessageOut

friend class MessageOut

friend

Definition at line 57 of file network.h.

Field Documentation

mInstance

Network * TmwAthena::Network::mInstance = 0

static

Definition at line 54 of file network.h.

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

---

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

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