limit max number of resends

Streaming.cpp

@@ -176,6 +176,7 @@ namespace stream
 			SendQuickAck (); // send ack for close explicitly?
 			m_IsOpen = false;
 			m_ReceiveTimer.cancel ();
+			m_ResendTimer.cancel ();
 		}
 	}	
 
@@ -427,7 +428,16 @@ namespace stream
 		if (ecode != boost::asio::error::operation_aborted)
 		{	
 			for (auto it : m_SentPackets)
-				SendPacket (it->GetBuffer (), it->GetLength ());
+			{
+				it->numResendAttempts++;
+				if (it->numResendAttempts <= MAX_NUM_RESEND_ATTEMPTS)
+					SendPacket (it->GetBuffer (), it->GetLength ());
+				else
+				{
+					Close ();
+					return;
+				}	
+			}	
 			ScheduleResend ();
 		}	
 	}	

Streaming.h

@@ -37,13 +37,15 @@ namespace stream
 	const size_t MAX_PACKET_SIZE = 4096;
 	const size_t COMPRESSION_THRESHOLD_SIZE = 66;	
 	const int RESEND_TIMEOUT = 10; // in seconds
+	const int MAX_NUM_RESEND_ATTEMPTS = 5;	
 	
 	struct Packet
 	{
 		uint8_t buf[MAX_PACKET_SIZE];	
 		size_t len, offset;
-
+		int numResendAttempts;
-		Packet (): len (0), offset (0) {};
+		
+		Packet (): len (0), offset (0), numResendAttempts (0) {};
 		uint8_t * GetBuffer () { return buf + offset; };
 		size_t GetLength () const { return len - offset; };