|
|
@ -235,7 +235,7 @@ namespace transport |
|
|
|
{ |
|
|
|
{ |
|
|
|
if (m_ReceivedMessages.size () > 100) m_ReceivedMessages.clear (); |
|
|
|
if (m_ReceivedMessages.size () > 100) m_ReceivedMessages.clear (); |
|
|
|
m_ReceivedMessages.insert (msgID); |
|
|
|
m_ReceivedMessages.insert (msgID); |
|
|
|
i2p::HandleI2NPMessage (msg); |
|
|
|
m_Handler.PutNextMessage (msg); |
|
|
|
} |
|
|
|
} |
|
|
|
else |
|
|
|
else |
|
|
|
{ |
|
|
|
{ |
|
|
@ -260,6 +260,8 @@ namespace transport |
|
|
|
SendFragmentAck (msgID, fragmentNum); |
|
|
|
SendFragmentAck (msgID, fragmentNum); |
|
|
|
buf += fragmentSize; |
|
|
|
buf += fragmentSize; |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
if (numFragments > 0) |
|
|
|
|
|
|
|
m_Handler.Flush (); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
void SSUData::ProcessMessage (uint8_t * buf, size_t len) |
|
|
|
void SSUData::ProcessMessage (uint8_t * buf, size_t len) |
|
|
|