adjust MTU for incoming SSU sessions

SSU.cpp

@@ -236,6 +236,7 @@ namespace ssu
 			i2p::data::Identity ident;
 			ident.FromBuffer (payload, identitySize);
 			m_RemoteIdent = ident.Hash ();
+			m_Data.UpdatePacketSize (m_RemoteIdent);
 		}
 		else
 			LogPrint ("SSU unexpected identity size ", identitySize);

SSUData.cpp

@@ -2,6 +2,7 @@
 #include <boost/bind.hpp>
 #include "Log.h"
 #include "Timestamp.h"
+#include "NetDb.h"
 #include "SSU.h"
 #include "SSUData.h"
 
@@ -15,8 +16,24 @@ namespace ssu
 		m_PacketSize = SSU_MAX_PACKET_SIZE;
 		auto remoteRouter = session.GetRemoteRouter ();
 		if (remoteRouter)
+			AdjustPacketSize (*remoteRouter);
+	}
+
+	SSUData::~SSUData ()
+	{
+		for (auto it: m_IncomleteMessages)
+			if (it.second)
+			{
+				DeleteI2NPMessage (it.second->msg);
+				delete it.second;
+			}	
+		for (auto it: m_SentMessages)
+			delete it.second;
+	}
+
+	void SSUData::AdjustPacketSize (const i2p::data::RouterInfo& remoteRouter)
 	{
-			auto ssuAddress = remoteRouter->GetSSUAddress ();
+		auto ssuAddress = remoteRouter.GetSSUAddress ();
 		if (ssuAddress && ssuAddress->mtu)
 		{
 			m_PacketSize = ssuAddress->mtu - IPV4_HEADER_SIZE - UDP_HEADER_SIZE;
@@ -35,18 +52,12 @@ namespace ssu
 			}	
 		}		
 	}
-	}
 
-	SSUData::~SSUData ()
+	void SSUData::UpdatePacketSize (const i2p::data::IdentHash& remoteIdent)
-	{
-		for (auto it: m_IncomleteMessages)
-			if (it.second)
 	{
-				DeleteI2NPMessage (it.second->msg);
+ 		auto routerInfo = i2p::data::netdb.FindRouter (remoteIdent);
-				delete it.second;
+		if (routerInfo)
-			}	
+			AdjustPacketSize (*routerInfo);
-		for (auto it: m_SentMessages)
-			delete it.second;
 	}
 
 	void SSUData::ProcessSentMessageAck (uint32_t msgID)

SSUData.h

@@ -8,6 +8,8 @@
 #include <set>
 #include <boost/asio.hpp>
 #include "I2NPProtocol.h"
+#include "Identity.h"
+#include "RouterInfo.h"
 
 namespace i2p
 {
@@ -78,6 +80,8 @@ namespace ssu
 			void ProcessMessage (uint8_t * buf, size_t len);
 			void Send (i2p::I2NPMessage * msg);
 
+			void UpdatePacketSize (const i2p::data::IdentHash& remoteIdent);
+
 		private:
 
 			void SendMsgAck (uint32_t msgID);
@@ -89,6 +93,8 @@ namespace ssu
 			void ScheduleResend ();
 			void HandleResendTimer (const boost::system::error_code& ecode);	
 			
+			void AdjustPacketSize (const i2p::data::RouterInfo& remoteRouter);	
+			
 		private:	
 
 			SSUSession& m_Session;