#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

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

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

Public Member Functions

Static Public Attributes

Static Protected Member Functions

Friends

Additional Inherited Members