Method DataReceived

src/RCONServer.cpp:172–209

void cRCONServer::cConnection::DataReceived(const char * a_Data, size_t a_Size)
{
	// Append data to the buffer:
	m_Buffer.append(a_Data, a_Size);
	
	// Process the packets in the buffer:
	while (m_Buffer.size() >= 14)
	{
		int Length = IntFromBuffer(m_Buffer.data());
		if (Length > 1500)
		{
			// Too long, drop the connection
			LOGWARNING("Received an invalid RCON packet length (%d), dropping RCON connection to %s.",
				Length, m_IPAddress.c_str()
			);
			m_RCONServer.m_SocketThreads.RemoveClient(this);
			m_Socket.CloseSocket();
			delete this;
			return;
		}
		if (Length > (int)(m_Buffer.size() + 4))
		{
			// Incomplete packet yet, wait for more data to come
			return;
		}
		
		int RequestID  = IntFromBuffer(m_Buffer.data() + 4);
		int PacketType = IntFromBuffer(m_Buffer.data() + 8);
		if (!ProcessPacket(RequestID, PacketType, Length - 10, m_Buffer.data() + 12))
		{
			m_RCONServer.m_SocketThreads.RemoveClient(this);
			m_Socket.CloseSocket();
			delete this;
			return;
		}
		m_Buffer.erase(0, Length + 4);
	}  // while (m_Buffer.size() >= 14)
}