LogPrint(eLogDebug,"Streaming: closing stream sSID=",m_SendStreamID,", rSID=",m_RecvStreamID,": reset flag received in packet #",receivedSeqn);
m_Status=eStreamStatusReset;
m_Status=eStreamStatusReset;
Close();
Close();
}
}
@ -495,6 +496,7 @@ namespace stream
voidStream::Close()
voidStream::Close()
{
{
LogPrint(eLogDebug,"Streaming: closing stream with sSID=",m_SendStreamID,", rSID=",m_RecvStreamID,", status=",m_Status);
switch(m_Status)
switch(m_Status)
{
{
caseeStreamStatusOpen:
caseeStreamStatusOpen:
@ -668,7 +670,7 @@ namespace stream
// check for resend attempts
// check for resend attempts
if(m_NumResendAttempts>=MAX_NUM_RESEND_ATTEMPTS)
if(m_NumResendAttempts>=MAX_NUM_RESEND_ATTEMPTS)
{
{
LogPrint(eLogWarning,"Streaming: packet was not ACKed after ",MAX_NUM_RESEND_ATTEMPTS," attempts, terminate, sSID=",m_SendStreamID);
LogPrint(eLogWarning,"Streaming: packet was not ACKed after ",MAX_NUM_RESEND_ATTEMPTS," attempts, terminate, rSID=",m_RecvStreamID,", sSID=",m_SendStreamID);
LogPrint(eLogWarning,"Streaming: Another remote lease has been selected for stream with sSID=",m_SendStreamID);
LogPrint(eLogWarning,"Streaming: Another remote lease has been selected for stream with rSID=",m_RecvStreamID,", sSID=",m_SendStreamID);
break;
break;
case3:
case3:
// pick another outbound tunnel
// pick another outbound tunnel
@ -725,7 +727,7 @@ namespace stream
{
{
if(m_LastReceivedSequenceNumber<0)
if(m_LastReceivedSequenceNumber<0)
{
{
LogPrint(eLogWarning,"Streaming: SYN has not been recived after ",ACK_SEND_TIMEOUT," milliseconds after follow on, terminate sSID=",m_SendStreamID);
LogPrint(eLogWarning,"Streaming: SYN has not been received after ",ACK_SEND_TIMEOUT," milliseconds after follow on, terminate rSID=",m_RecvStreamID,", sSID=",m_SendStreamID);