|
|
@ -853,6 +853,8 @@ namespace stream |
|
|
|
if (packet->IsSYN () && !packet->GetSeqn ()) // new incoming stream
|
|
|
|
if (packet->IsSYN () && !packet->GetSeqn ()) // new incoming stream
|
|
|
|
{ |
|
|
|
{ |
|
|
|
auto incomingStream = CreateNewIncomingStream (); |
|
|
|
auto incomingStream = CreateNewIncomingStream (); |
|
|
|
|
|
|
|
uint32_t receiveStreamID = packet->GetReceiveStreamID (); |
|
|
|
|
|
|
|
incomingStream->HandleNextPacket (packet); // SYN
|
|
|
|
auto ident = incomingStream->GetRemoteIdentity(); |
|
|
|
auto ident = incomingStream->GetRemoteIdentity(); |
|
|
|
if(ident) |
|
|
|
if(ident) |
|
|
|
{ |
|
|
|
{ |
|
|
@ -864,14 +866,14 @@ namespace stream |
|
|
|
incomingStream->Close(); |
|
|
|
incomingStream->Close(); |
|
|
|
DeleteStream(incomingStream); |
|
|
|
DeleteStream(incomingStream); |
|
|
|
incomingStream = nullptr; |
|
|
|
incomingStream = nullptr; |
|
|
|
|
|
|
|
if(m_SavedPackets.find(receiveStreamID) != m_SavedPackets.end()) |
|
|
|
|
|
|
|
m_SavedPackets.erase(receiveStreamID); |
|
|
|
delete packet; |
|
|
|
delete packet; |
|
|
|
return; |
|
|
|
return; |
|
|
|
} |
|
|
|
} |
|
|
|
} else |
|
|
|
} else |
|
|
|
LogPrint(eLogWarning, "Streaming: Inbound stream has no identity"); |
|
|
|
LogPrint(eLogWarning, "Streaming: Inbound stream has no identity"); |
|
|
|
|
|
|
|
|
|
|
|
uint32_t receiveStreamID = packet->GetReceiveStreamID (); |
|
|
|
|
|
|
|
incomingStream->HandleNextPacket (packet); // SYN
|
|
|
|
|
|
|
|
// handle saved packets if any
|
|
|
|
// handle saved packets if any
|
|
|
|
{ |
|
|
|
{ |
|
|
|
auto it = m_SavedPackets.find (receiveStreamID); |
|
|
|
auto it = m_SavedPackets.find (receiveStreamID); |
|
|
|