Method OnPacketReceived

src/ServerUDPSocket.cpp:63–103

void CServerUDPSocket::OnPacketReceived(uint32 serverip, uint16 serverport, uint8_t* buffer, size_t length)
{
	wxCHECK_RET(length >= 2, "Invalid packet.");

	size_t nPayLoadLen = length;
	uint8_t* pBuffer = buffer;
	CServer* pServer = theApp->serverlist->GetServerByIPUDP(serverip, serverport, true);
	if (pServer && thePrefs::IsServerCryptLayerUDPEnabled() &&
		((pServer->GetServerKeyUDP() != 0 && pServer->SupportsObfuscationUDP()) || (pServer->GetCryptPingReplyPending() && pServer->GetChallenge() != 0)))
	{
		// eMule TODO
		uint32 dwKey = 0;
		if (pServer->GetCryptPingReplyPending() && pServer->GetChallenge() != 0 /* && pServer->GetPort() == ntohs(sockAddr.sin_port) - 12 */) {
			dwKey = pServer->GetChallenge();
		} else {
			dwKey = pServer->GetServerKeyUDP();
		}

		wxASSERT( dwKey != 0 );
		nPayLoadLen = CEncryptedDatagramSocket::DecryptReceivedServer(buffer, length, &pBuffer, dwKey, serverip);
#ifdef __DEBUG__
		if (nPayLoadLen == length) {
			AddDebugLogLineN(logServerUDP, CFormat("Expected encrypted packet, but received unencrytped from server %s, UDPKey %u, Challenge: %u") % pServer->GetListName() % pServer->GetServerKeyUDP() % pServer->GetChallenge());
		} else {
			AddDebugLogLineN(logServerUDP, CFormat("Received encrypted packet from server %s, UDPKey %u, Challenge: %u") % pServer->GetListName() % pServer->GetServerKeyUDP() % pServer->GetChallenge());
		}
#endif
	}

	uint8 protocol = pBuffer[0];
	uint8 opcode  = pBuffer[1];

	if (protocol == OP_EDONKEYPROT) {
		CMemFile data(pBuffer + 2, nPayLoadLen - 2);
		ProcessPacket(data, opcode, serverip, serverport);
	} else {
		AddDebugLogLineN(logServerUDP, CFormat("Received invalid packet, protocol (0x%x) and opcode (0x%x)") % protocol % opcode);

		theStats::AddDownOverheadOther(length);
	}
}


void CServerUDPSocket::ProcessPacket(CMemFile& packet, uint8 opcode, uint32 ip, uint16 port)