Method PacketReceived

src/ClientTCPSocket.cpp:1914–2005

bool CClientTCPSocket::PacketReceived(CPacket* packet)
{
	// 0.42e
	bool bResult = false;
	uint32 uRawSize = packet->GetPacketSize();

	AddDebugLogLineN( logRemoteClient,
		CFormat("Packet with protocol %x, opcode %x, size %u received from %s")
			% packet->GetProtocol()
			% packet->GetOpCode()
			% packet->GetPacketSize()
			% ( m_client ? m_client->GetFullIP() : "Unknown Client" )
	);

	wxString exception;

	try {
		bool process = true;

		if ((packet->GetProtocol() == OP_PACKEDPROT) ||
			(packet->GetProtocol() == OP_ED2KV2PACKEDPROT)) {

			if (!packet->UnPackPacket()) {
				AddDebugLogLineN(logZLib, "Failed to decompress client TCP packet.");
				bResult = false;
				process = false;
			} else {
				AddDebugLogLineN(logRemoteClient, CFormat("Packet unpacked, new protocol %x, opcode %x, size %u")
					% packet->GetProtocol() % packet->GetOpCode() % packet->GetPacketSize());
			}
		}

		if (process) {
			switch (packet->GetProtocol()) {
				case OP_EDONKEYPROT:
					bResult = ProcessPacket(packet->GetDataBuffer(),uRawSize,packet->GetOpCode());
					break;
				case OP_EMULEPROT:
					bResult = ProcessExtPacket(packet->GetDataBuffer(), packet->GetPacketSize(), packet->GetOpCode());
					break;
				case OP_ED2KV2HEADER:
					bResult = ProcessED2Kv2Packet(packet->GetDataBuffer(), packet->GetPacketSize(), packet->GetOpCode());
					break;
				case OP_ED2KV2PACKEDPROT:
				case OP_PACKEDPROT:
					// Packed inside packed?
					wxFAIL;
					break;
				default: {
					theStats::AddDownOverheadOther(uRawSize);
					if (m_client) {
						m_client->SetDownloadState(DS_ERROR);
					}
					Disconnect("Unknown protocol");
					bResult = false;
				}
			}
		}