|
|
@ -129,6 +129,11 @@ namespace stream |
|
|
|
|
|
|
|
|
|
|
|
void Stream::HandleNextPacket (Packet * packet) |
|
|
|
void Stream::HandleNextPacket (Packet * packet) |
|
|
|
{ |
|
|
|
{ |
|
|
|
|
|
|
|
if (m_Status == eStreamStatusTerminated) |
|
|
|
|
|
|
|
{ |
|
|
|
|
|
|
|
m_LocalDestination.DeletePacket (packet); |
|
|
|
|
|
|
|
return; |
|
|
|
|
|
|
|
} |
|
|
|
m_NumReceivedBytes += packet->GetLength (); |
|
|
|
m_NumReceivedBytes += packet->GetLength (); |
|
|
|
if (!m_SendStreamID) |
|
|
|
if (!m_SendStreamID) |
|
|
|
{ |
|
|
|
{ |
|
|
@ -159,6 +164,7 @@ namespace stream |
|
|
|
{ |
|
|
|
{ |
|
|
|
// we have received next in sequence message
|
|
|
|
// we have received next in sequence message
|
|
|
|
ProcessPacket (packet); |
|
|
|
ProcessPacket (packet); |
|
|
|
|
|
|
|
if (m_Status == eStreamStatusTerminated) return; |
|
|
|
|
|
|
|
|
|
|
|
// we should also try stored messages if any
|
|
|
|
// we should also try stored messages if any
|
|
|
|
for (auto it = m_SavedPackets.begin (); it != m_SavedPackets.end ();) |
|
|
|
for (auto it = m_SavedPackets.begin (); it != m_SavedPackets.end ();) |
|
|
@ -169,6 +175,7 @@ namespace stream |
|
|
|
m_SavedPackets.erase (it++); |
|
|
|
m_SavedPackets.erase (it++); |
|
|
|
|
|
|
|
|
|
|
|
ProcessPacket (savedPacket); |
|
|
|
ProcessPacket (savedPacket); |
|
|
|
|
|
|
|
if (m_Status == eStreamStatusTerminated) return; |
|
|
|
} |
|
|
|
} |
|
|
|
else |
|
|
|
else |
|
|
|
break; |
|
|
|
break; |
|
|
|