Method HandleNextPacket

libi2pd/Streaming.cpp:200–378

	}

	void Stream::HandleNextPacket (Packet * packet)
	{
		if (m_Status == eStreamStatusTerminated)
		{
			m_LocalDestination.DeletePacket (packet);
			return;
		}
		m_NumReceivedBytes += packet->GetLength ();
		if (!m_SendStreamID)
		{
			m_SendStreamID = packet->GetReceiveStreamID ();
			if (!m_RemoteIdentity && !packet->from && packet->GetNACKCount () == 8 && // first incoming packet
			    memcmp (packet->GetNACKs (), m_LocalDestination.GetOwner ()->GetIdentHash (), 32))
			{
				LogPrint (eLogWarning, "Streaming: Destination mismatch for ", m_LocalDestination.GetOwner ()->GetIdentHash ().ToBase32 ());
				m_LocalDestination.DeletePacket (packet);
				return;
			}
		}

		if (!packet->IsNoAck ()) // ack received
			ProcessAck (packet);

		int32_t receivedSeqn = packet->GetSeqn ();
		if (!receivedSeqn && m_LastReceivedSequenceNumber >= 0)
		{
			uint16_t flags = packet->GetFlags ();
			if (flags)
				// plain ack with options
				ProcessOptions (flags, packet);
			else
				// plain ack
				{
					LogPrint (eLogDebug, "Streaming: Plain ACK received");
					if (m_IsImmediateAckRequested)
					{
						auto ts = i2p::util::GetMillisecondsSinceEpoch ();
						if (m_IsFirstRttSample)
						{
							m_RTT = ts - m_LastSendTime;
							m_IsFirstRttSample = false;
						}
						else
							m_RTT = (m_RTT + (ts - m_LastSendTime)) / 2;
						m_IsImmediateAckRequested = false;
					}
				}
			m_LocalDestination.DeletePacket (packet);
			return;
		}

		LogPrint (eLogDebug, "Streaming: Received seqn=", receivedSeqn, " on sSID=", m_SendStreamID);
		if (m_ReceiveQueue.size () > m_MaxWindowSize*3)
		{
			LogPrint (eLogDebug, "Streaming: ReceiveQueue is full, delete packet");
			m_LocalDestination.DeletePacket (packet);
			m_IsChoking3 = true;
			if (!m_IsAckSendScheduled)