con::ConnectionReceiveThread Class Reference

#include <connectionthreads.h>

Inheritance diagram for con::ConnectionReceiveThread:

Collaboration diagram for con::ConnectionReceiveThread:

Classes
struct	PacketTypeHandler

Public Member Functions
	ConnectionReceiveThread (unsigned int max_packet_size)
void *	run ()
void	setParent (Connection *parent)
Public Member Functions inherited from Thread
	Thread (const std::string &name="")
virtual	~Thread ()
bool	start ()
bool	stop ()
bool	wait ()
bool	isCurrentThread ()
bool	isRunning ()
bool	stopRequested ()
std::thread::id	getThreadId ()
bool	getReturnValue (void **ret)
bool	bindToProcessor (unsigned int proc_number)
bool	setPriority (int prio)

Private Member Functions
void	receive (SharedBuffer< u8 > &packetdata, bool &packet_queued)
bool	getFromBuffers (session_t &peer_id, SharedBuffer< u8 > &dst)
bool	checkIncomingBuffers (Channel *channel, session_t &peer_id, SharedBuffer< u8 > &dst)
SharedBuffer< u8 >	processPacket (Channel *channel, const SharedBuffer< u8 > &packetdata, session_t peer_id, u8 channelnum, bool reliable)
SharedBuffer< u8 >	handlePacketType_Control (Channel *channel, const SharedBuffer< u8 > &packetdata, Peer *peer, u8 channelnum, bool reliable)
SharedBuffer< u8 >	handlePacketType_Original (Channel *channel, const SharedBuffer< u8 > &packetdata, Peer *peer, u8 channelnum, bool reliable)
SharedBuffer< u8 >	handlePacketType_Split (Channel *channel, const SharedBuffer< u8 > &packetdata, Peer *peer, u8 channelnum, bool reliable)
SharedBuffer< u8 >	handlePacketType_Reliable (Channel *channel, const SharedBuffer< u8 > &packetdata, Peer *peer, u8 channelnum, bool reliable)

Private Attributes
Connection *	m_connection = nullptr

Static Private Attributes
static const PacketTypeHandler	packetTypeRouter [PACKET_TYPE_MAX]

Additional Inherited Members
Static Public Member Functions inherited from Thread
static void	setName (const std::string &name)
static unsigned int	getNumberOfProcessors ()
Protected Attributes inherited from Thread
std::string	m_name

Constructor & Destructor Documentation

ConnectionReceiveThread()

con::ConnectionReceiveThread::ConnectionReceiveThread

(

unsigned int

max_packet_size

)

Member Function Documentation

checkIncomingBuffers()

bool con::ConnectionReceiveThread::checkIncomingBuffers ( Channel *  channel, session_t &  peer_id, SharedBuffer< u8 > &  dst  )

private

References BASE_HEADER_SIZE, dout_con, con::Connection::getDesc(), con::ReliablePacketBuffer::getFirstSeqnum(), SharedBuffer< T >::getSize(), con::Channel::incNextIncomingSeqNum(), con::Channel::incoming_reliables, LOG, m_connection, p(), con::ReliablePacketBuffer::popFirst(), processPacket(), con::readChannel(), con::Channel::readNextIncomingSeqNum(), con::readPeerId(), readU16(), and RELIABLE_HEADER_SIZE.

Referenced by getFromBuffers().

Here is the call graph for this function:

Here is the caller graph for this function:

getFromBuffers()

bool con::ConnectionReceiveThread::getFromBuffers ( session_t &  peer_id, SharedBuffer< u8 > &  dst  )

private

References checkIncomingBuffers(), con::Connection::getPeerIDs(), con::Connection::getPeerNoEx(), and m_connection.

Referenced by receive().

Here is the call graph for this function:

Here is the caller graph for this function:

handlePacketType_Control()

SharedBuffer< u8 > con::ConnectionReceiveThread::handlePacketType_Control ( Channel *  channel, const SharedBuffer< u8 > &  packetdata, Peer *  peer, u8  channelnum, bool  reliable  )

private

References CONTROLTYPE_ACK, CONTROLTYPE_DISCO, CONTROLTYPE_PING, CONTROLTYPE_SET_PEER_ID, con::Connection::deletePeer(), derr_con, dout_con, con::Connection::getDesc(), con::Connection::GetPeerID(), SharedBuffer< T >::getSize(), porting::getTimeMs(), con::Peer::id, LOG, m_connection, con::Channel::outgoing_reliables_sent, p(), PEER_ID_INEXISTENT, con::ReliablePacketBuffer::popSeqnum(), readU16(), readU8(), con::Connection::SetPeerID(), con::ReliablePacketBuffer::size(), con::Connection::TriggerSend(), con::Channel::UpdateBytesSent(), and con::Channel::UpdatePacketTooLateCounter().

Here is the call graph for this function:

handlePacketType_Original()

SharedBuffer< u8 > con::ConnectionReceiveThread::handlePacketType_Original ( Channel *  channel, const SharedBuffer< u8 > &  packetdata, Peer *  peer, u8  channelnum, bool  reliable  )

private

References dout_con, con::Connection::getDesc(), SharedBuffer< T >::getSize(), LOG, m_connection, and ORIGINAL_HEADER_SIZE.

Here is the call graph for this function:

handlePacketType_Reliable()

SharedBuffer< u8 > con::ConnectionReceiveThread::handlePacketType_Reliable ( Channel *  channel, const SharedBuffer< u8 > &  packetdata, Peer *  peer, u8  channelnum, bool  reliable  )

private

TODO find a way to verify the new against the old packet

References derr_con, con::ConnectionCommand::disconnect_peer(), dout_con, con::Peer::getAddress(), con::Connection::getDesc(), con::ReliablePacketBuffer::getFirstSeqnum(), con::Connection::GetProtocolID(), SharedBuffer< T >::getSize(), con::Peer::id, con::Channel::incNextIncomingSeqNum(), con::Channel::incoming_reliables, con::ReliablePacketBuffer::insert(), LOG, m_connection, con::makePacket(), MAX_RELIABLE_WINDOW_SIZE, con::MTP_MINETEST_RELIABLE_UDP, con::ReliablePacketBuffer::popFirst(), processPacket(), con::Connection::putCommand(), con::Channel::readNextIncomingSeqNum(), readU16(), RELIABLE_HEADER_SIZE, con::Connection::sendAck(), con::seqnum_higher(), and con::seqnum_in_window().

Here is the call graph for this function:

handlePacketType_Split()

SharedBuffer< u8 > con::ConnectionReceiveThread::handlePacketType_Split ( Channel *  channel, const SharedBuffer< u8 > &  packetdata, Peer *  peer, u8  channelnum, bool  reliable  )

private

References con::Peer::addSplitPacket(), dout_con, FATAL_ERROR, con::Peer::getAddress(), con::Connection::getDesc(), con::Connection::GetProtocolID(), SharedBuffer< T >::getSize(), con::Peer::id, LOG, m_connection, con::makePacket(), and con::MTP_UDP.

Here is the call graph for this function:

processPacket()

SharedBuffer< u8 > con::ConnectionReceiveThread::processPacket ( Channel *  channel, const SharedBuffer< u8 > &  packetdata, session_t  peer_id, u8  channelnum, bool  reliable  )

private

References derr_con, errorstream, con::Connection::getDesc(), con::Connection::getPeerNoEx(), SharedBuffer< T >::getSize(), con::ConnectionReceiveThread::PacketTypeHandler::handler, itos(), m_connection, MAX_UDP_PEERS, con::PACKET_TYPE_MAX, packetTypeRouter, and readU8().

Referenced by checkIncomingBuffers(), handlePacketType_Reliable(), and receive().

Here is the call graph for this function:

Here is the caller graph for this function:

receive()

void con::ConnectionReceiveThread::receive ( SharedBuffer< u8 > &  packetdata, bool &  packet_queued  )

private

References BASE_HEADER_SIZE, CHANNEL_COUNT, con::Connection::ConnectedToServer(), con::Connection::createPeer(), con::ConnectionEvent::dataReceived(), derr_con, dout_con, con::Peer::getAddress(), con::Connection::getDesc(), getFromBuffers(), con::Connection::getPeerNoEx(), con::Connection::GetProtocolID(), SharedBuffer< T >::getSize(), LOG, con::Connection::lookupPeer(), m_connection, con::Connection::m_udpSocket, con::MTP_MINETEST_RELIABLE_UDP, con::MTP_UDP, PEER_ID_INEXISTENT, processPacket(), con::Connection::putEvent(), con::readChannel(), con::readPeerId(), readU32(), UDPSocket::Receive(), con::Peer::ResetTimeout(), and con::Channel::UpdateBytesReceived().

Referenced by run().

Here is the call graph for this function:

Here is the caller graph for this function:

run()

void * con::ConnectionReceiveThread::run ( )

virtual

Implements Thread.

References BEGIN_DEBUG_EXCEPTION_HANDLER, con::CALC_DTIME(), CHANNEL_COUNT, dout_con, END_DEBUG_EXCEPTION_HANDLER, g_profiler, con::Connection::getDesc(), con::Connection::getPeerIDs(), con::Connection::getPeerNoEx(), porting::getTimeMs(), LOG, m_connection, PROFILE, receive(), Profiler::remove(), SPT_AVG, and Thread::stopRequested().

Here is the call graph for this function:

setParent()

void con::ConnectionReceiveThread::setParent ( Connection *  parent )

inline

References m_connection.

Member Data Documentation

m_connection

Connection* con::ConnectionReceiveThread::m_connection = nullptr

private

Referenced by checkIncomingBuffers(), getFromBuffers(), handlePacketType_Control(), handlePacketType_Original(), handlePacketType_Reliable(), handlePacketType_Split(), processPacket(), receive(), run(), and setParent().

packetTypeRouter

const ConnectionReceiveThread::PacketTypeHandler con::ConnectionReceiveThread::packetTypeRouter

staticprivate

Initial value:

= {
    {&ConnectionReceiveThread::handlePacketType_Control},
    {&ConnectionReceiveThread::handlePacketType_Original},
    {&ConnectionReceiveThread::handlePacketType_Split},
    {&ConnectionReceiveThread::handlePacketType_Reliable},
}

Referenced by processPacket().

---

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

• network/connectionthreads.h
• network/connectionthreads.cpp