Method OnPacketReceived

src/Nazara/Network/RUdpConnection.cpp:438–572

	*/

	void RUdpConnection::OnPacketReceived(const IpAddress& peerIp, NetPacket&& packet)
	{
		UInt16 protocolBegin;
		UInt16 protocolEnd;
		SequenceIndex sequenceId;
		SequenceIndex lastAck;
		UInt32 ackBits;

		packet.GetStream()->SetCursorPos(packet.GetSize() - MessageFooter);
		packet >> protocolEnd;

		packet.GetStream()->SetCursorPos(NetPacket::HeaderSize);
		packet >> protocolBegin;

		UInt32 protocolId = static_cast<UInt32>(protocolEnd) << 16 | protocolBegin;
		if (protocolId != m_protocol)
			return; ///< Ignore

		packet >> sequenceId >> lastAck >> ackBits;

		auto it = m_peerByIP.find(peerIp);
		if (it == m_peerByIP.end())
		{
			switch (packet.GetNetCode())
			{
				case NetCode_RequestConnection:
				{
					UInt64 token;
					packet >> token;

					NazaraNotice(m_socket.GetBoundAddress().ToString() + ": Received NetCode_RequestConnection from " + peerIp.ToString() + ": " + String::Number(token));
					if (!m_shouldAcceptConnections)
						return; //< Ignore

					OnClientRequestingConnection(peerIp, sequenceId, token);
					break;
				}

				default:
					return; //< Ignore
			}
		}
		else
		{
			PeerData& peer = m_peers[it->second];
			peer.lastPacketTime = m_currentTime;

			if (peer.receivedQueue.find(sequenceId) != peer.receivedQueue.end())
				return; //< Ignore

			if (m_isSimulationEnabled && m_packetLossProbability(s_randomGenerator))
			{
				NazaraNotice(m_socket.GetBoundAddress().ToString() + ": Lost packet " + String::Number(sequenceId) + " from " + peerIp.ToString() + " for simulation purpose");
				return;
			}

			///< Receiving a packet from an acknowledged client means the connection works in both ways
			if (peer.state == PeerState_Aknowledged && packet.GetNetCode() != NetCode_RequestConnection)