From 647175cf12bfb08fea148ae4904e4fdaa250c28e Mon Sep 17 00:00:00 2001
From: orignal <i2porignal@yandex.ru>
Date: Sun, 30 Oct 2016 09:29:43 -0400
Subject: [PATCH] correct RTO reset

---
 Streaming.cpp | 7 +++----
 1 file changed, 3 insertions(+), 4 deletions(-)

diff --git a/Streaming.cpp b/Streaming.cpp
index 852d11a6..97cfad0a 100644
--- a/Streaming.cpp
+++ b/Streaming.cpp
@@ -693,8 +693,7 @@ namespace stream
 	{
 		m_ResendTimer.cancel ();
 		// check for invalid value
-		if (m_RTO <= 0)
-			m_RTO = 1;
+		if (m_RTO <= 0) m_RTO = INITIAL_RTO;
 		m_ResendTimer.expires_from_now (boost::posix_time::milliseconds(m_RTO));
 		m_ResendTimer.async_wait (std::bind (&Stream::HandleResendTimer,
 			shared_from_this (), std::placeholders::_1));
@@ -901,13 +900,13 @@ namespace stream
 			if (packet->IsSYN () && !packet->GetSeqn ()) // new incoming stream
 			{	
 				uint32_t receiveStreamID = packet->GetReceiveStreamID ();
-				if (receiveStreamID == m_LastIncomingReceiveStreamID) 
+		/*		if (receiveStreamID == m_LastIncomingReceiveStreamID) 
 				{
 					// already pending
 					LogPrint(eLogWarning, "Streaming: Incoming streaming with rSID=", receiveStreamID, " already exists");
 					delete packet; // drop it, because previous should be connected
 					return;
-				}	
+				}	*/
 				auto incomingStream = CreateNewIncomingStream ();
 				incomingStream->HandleNextPacket (packet); // SYN
 				auto ident = incomingStream->GetRemoteIdentity();