fixed corrupted NTCP messages

NTCPSession.cpp

@@ -21,7 +21,7 @@ namespace transport
 	NTCPSession::NTCPSession (NTCPServer& server, std::shared_ptr<const i2p::data::RouterInfo> in_RemoteRouter): 
 		TransportSession (in_RemoteRouter),	m_Server (server), m_Socket (m_Server.GetService ()), 
 		m_TerminationTimer (m_Server.GetService ()), m_IsEstablished (false), m_ReceiveBufferOffset (0), 
-		m_NextMessage (nullptr), m_NumSentBytes (0), m_NumReceivedBytes (0)
+		m_NextMessage (nullptr), m_IsSending (false), m_NumSentBytes (0), m_NumReceivedBytes (0)
 	{		
 		m_DHKeysPair = transports.GetNextDHKeysPair ();
 		m_Establisher = new Establisher;
@@ -32,6 +32,8 @@ namespace transport
 		delete m_Establisher;
 		if (m_NextMessage)	
 			i2p::DeleteI2NPMessage (m_NextMessage);
+		for (auto it: m_SendQueue)
+			DeleteI2NPMessage (it);
 	}
 
 	void NTCPSession::CreateAESKey (uint8_t * pubKey, i2p::crypto::AESKey& key)
@@ -538,6 +540,7 @@ namespace transport
 
 	void NTCPSession::Send (i2p::I2NPMessage * msg)
 	{
+		m_IsSending = true;
 		boost::asio::async_write (m_Socket, CreateMsgBuffer (msg), boost::asio::transfer_all (),                      
         	std::bind(&NTCPSession::HandleSent, shared_from_this (), std::placeholders::_1, std::placeholders::_2, std::vector<I2NPMessage *>{ msg }));	
 	}
@@ -581,6 +584,7 @@ namespace transport
 
 	void NTCPSession::Send (const std::vector<I2NPMessage *>& msgs)
 	{
+		m_IsSending = true;
 		std::vector<boost::asio::const_buffer> bufs;
 		for (auto it: msgs)
 			bufs.push_back (CreateMsgBuffer (it));
@@ -590,6 +594,7 @@ namespace transport
 		
 	void NTCPSession::HandleSent (const boost::system::error_code& ecode, std::size_t bytes_transferred, std::vector<I2NPMessage *> msgs)
 	{
+		m_IsSending = false;
 		for (auto it: msgs)
 			if (it) i2p::DeleteI2NPMessage (it);
 		if (ecode)
@@ -602,6 +607,12 @@ namespace transport
 		else
 		{	
 			m_NumSentBytes += bytes_transferred;
+			if (!m_SendQueue.empty())
+			{
+				Send (m_SendQueue);
+				m_SendQueue.clear ();
+			}	
+			else
 				ScheduleTermination (); // reset termination timer
 		}	
 	}	
@@ -620,8 +631,13 @@ namespace transport
 	void NTCPSession::PostI2NPMessage (I2NPMessage * msg)
 	{
 		if (msg)
+		{
+			if (m_IsSending)
+				m_SendQueue.push_back (msg);
+			else	
 				Send (msg);
 		}	
+	}	
 
 	void NTCPSession::SendI2NPMessages (const std::vector<I2NPMessage *>& msgs)
 	{
@@ -630,6 +646,12 @@ namespace transport
 
 	void NTCPSession::PostI2NPMessages (std::vector<I2NPMessage *> msgs)
 	{
+		if (m_IsSending)
+		{
+			for (auto it: msgs)
+				m_SendQueue.push_back (it);
+		}	
+		else	
 			Send (msgs);
 	}	
 		

NTCPSession.h

@@ -133,6 +133,9 @@ namespace transport
 			size_t m_NextMessageOffset;
 			i2p::I2NPMessagesHandler m_Handler;
 
+			bool m_IsSending;
+			std::vector<I2NPMessage *> m_SendQueue;
+			
 			size_t m_NumSentBytes, m_NumReceivedBytes;
 	};