con::ConnectionReceiveThread Class Reference

#include <threads.h>

Inheritance diagram for con::ConnectionReceiveThread:

Collaboration diagram for con::ConnectionReceiveThread:

Classes
struct	PacketTypeHandler
struct	RateLimitHelper

Public Member Functions
	ConnectionReceiveThread ()
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 () const
bool	isRunning () const
bool	stopRequested () const
std::thread::id	getThreadId () const
bool	getReturnValue (void **ret) const
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
RateLimitHelper	m_new_peer_ratelimit

Static Private Attributes
static const PacketTypeHandler	packetTypeRouter [PACKET_TYPE_MAX]

Additional Inherited Members
Static Public Member Functions inherited from Thread
static Thread *	getCurrentThread ()
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

(

)

References Thread::Thread().

Here is the call graph for this function:

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::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(), 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(), m_connection, and p().

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 con::CONTROLTYPE_ACK, con::CONTROLTYPE_DISCO, con::CONTROLTYPE_PING, con::CONTROLTYPE_SET_PEER_ID, derr_con, dout_con, SharedBuffer< T >::getSize(), porting::getTimeMs(), con::IPeer::id, LOG, m_connection, con::Channel::outgoing_reliables_sent, p(), PEER_ID_INEXISTENT, con::ReliablePacketBuffer::popSeqnum(), readU16(), readU8(), con::ReliablePacketBuffer::size(), 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, 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::IPeer::getAddress(), con::ReliablePacketBuffer::getFirstSeqnum(), SharedBuffer< T >::getSize(), con::IPeer::id, con::Channel::incNextIncomingSeqNum(), con::Channel::incoming_reliables, con::ReliablePacketBuffer::insert(), LOG, m_connection, con::makePacket(), MAX_RELIABLE_WINDOW_SIZE, con::ReliablePacketBuffer::popFirst(), processPacket(), con::Channel::readNextIncomingSeqNum(), readU16(), RELIABLE_HEADER_SIZE, 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, con::IPeer::getAddress(), SharedBuffer< T >::getSize(), con::IPeer::id, LOG, m_connection, and con::makePacket().

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, 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::ConnectionEvent::dataReceived(), derr_con, dout_con, con::IPeer::getAddress(), getFromBuffers(), SharedBuffer< T >::getSize(), con::Peer::isHalfOpen(), LOG, m_connection, m_new_peer_ratelimit, MAX_NEW_PEERS_PER_SEC, PEER_ID_INEXISTENT, processPacket(), con::readChannel(), con::readPeerId(), readU32(), con::Peer::ResetTimeout(), con::Peer::SetFullyOpen(), con::Channel::UpdateBytesReceived(), and warningstream.

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, porting::getTimeMs(), LOG, m_connection, PROFILE, receive(), 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().

m_new_peer_ratelimit

RateLimitHelper con::ConnectionReceiveThread::m_new_peer_ratelimit

private

Referenced by receive().

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/mtp/threads.h
• network/mtp/threads.cpp