From 7f91c9e63e4325bbc0abc802d761f16b937ac25d Mon Sep 17 00:00:00 2001
From: orignal <i2porignal@yandex.ru>
Date: Mon, 23 Mar 2015 18:07:43 -0400
Subject: [PATCH] close stream is SYN has not been received

---
 Streaming.cpp | 31 +++++++++++++++++++++++++------
 1 file changed, 25 insertions(+), 6 deletions(-)

diff --git a/Streaming.cpp b/Streaming.cpp
index 28ea7557..510d0f14 100644
--- a/Streaming.cpp
+++ b/Streaming.cpp
@@ -21,6 +21,7 @@ namespace stream
 		m_LastWindowSizeIncreaseTime (0), m_NumResendAttempts (0)
 	{
 		m_RecvStreamID = i2p::context.GetRandomNumberGenerator ().GenerateWord32 ();
+		m_RemoteIdentity = remote->GetIdentity ();
 		UpdateCurrentRemoteLease ();
 	}	
 
@@ -130,13 +131,24 @@ namespace stream
 				LogPrint (eLogWarning, "Missing messages from ", m_LastReceivedSequenceNumber + 1, " to ", receivedSeqn - 1);
 				// save message and wait for missing message again
 				SavePacket (packet);
-				// send NACKs for missing messages ASAP
-				if (m_IsAckSendScheduled)
+				if (m_LastReceivedSequenceNumber >= 0)
+				{	
+					// send NACKs for missing messages ASAP
+					if (m_IsAckSendScheduled)
+					{
+						m_IsAckSendScheduled = false;	
+						m_AckSendTimer.cancel ();
+					}
+					SendQuickAck ();
+				}	
+				else
 				{
-					m_IsAckSendScheduled = false;	
-					m_AckSendTimer.cancel ();
-				}
-				SendQuickAck ();
+					// wait for SYN
+					m_IsAckSendScheduled = true;
+					m_AckSendTimer.expires_from_now (boost::posix_time::milliseconds(ACK_SEND_TIMEOUT));
+					m_AckSendTimer.async_wait (std::bind (&Stream::HandleAckSendTimer,
+						shared_from_this (), std::placeholders::_1));
+				}			
 			}	
 		}	
 	}	
@@ -676,6 +688,13 @@ namespace stream
 	{
 		if (m_IsAckSendScheduled)
 		{
+			if (m_LastReceivedSequenceNumber < 0)
+			{
+				LogPrint (eLogWarning, "SYN has not been recived after ", ACK_SEND_TIMEOUT, " milliseconds after follow on. Terminate");
+				m_Status = eStreamStatusReset;
+				Close ();
+				return;
+			}	
 			if (m_Status == eStreamStatusOpen)
 				SendQuickAck ();
 			m_IsAckSendScheduled = false;