Drop expired tunnel messages. Don't overwrite tunnel message timestamp

libi2pd/TransitTunnel.cpp

@@ -68,7 +68,9 @@ namespace tunnel
 
 		m_NumTransmittedBytes += tunnelMsg->GetLength ();
 		htobe32buf (tunnelMsg->GetPayload (), GetNextTunnelID ());
-		tunnelMsg->FillI2NPMessageHeader (eI2NPTunnelData);
+		// update header, expiration and size remain the same
+		tunnelMsg->SetMsgID (i2p::tunnel::tunnels.GetRng ()()); // assign new msgID
+		tunnelMsg->UpdateChks (); // new checksum TODO: remove later
 		m_TunnelDataMsgs.push_back (tunnelMsg);
 	}
 

libi2pd/Tunnel.cpp

@@ -561,13 +561,14 @@ namespace tunnel
 				if (m_Queue.Wait (1,0)) // 1 sec
 				{
 					m_Queue.GetWholeQueue (msgs);
+					auto mts = i2p::util::GetMillisecondsSinceEpoch ();
 					int numMsgs = 0;
 					uint32_t prevTunnelID = 0, tunnelID = 0;
 					std::shared_ptr<TunnelBase> prevTunnel;
 					while (!msgs.empty ())
 					{
 						auto msg = msgs.front (); msgs.pop_front ();
-						if (!msg) continue;
+						if (!msg || msg->IsExpired (mts)) continue;
 						std::shared_ptr<TunnelBase> tunnel;
 						uint8_t typeID = msg->GetTypeID ();
 						switch (typeID)

libi2pd/Tunnel.h

@@ -248,6 +248,7 @@ namespace tunnel
 			void SetMaxNumTransitTunnels (uint32_t maxNumTransitTunnels);
 			uint32_t GetMaxNumTransitTunnels () const { return m_MaxNumTransitTunnels; };
 			int GetCongestionLevel() const { return m_MaxNumTransitTunnels ? CONGESTION_LEVEL_FULL * m_TransitTunnels.GetNumTransitTunnels () / m_MaxNumTransitTunnels : CONGESTION_LEVEL_FULL; }
+			std::mt19937& GetRng () { return m_Rng; }
 			
 		private: