dandri/i2pd
1
0
Fork 0
mirror of https://github.com/PurpleI2P/i2pd.git synced 2026-08-28 07:24:19 +00:00
Code Issues Packages Projects Releases Wiki Activity

don't fragment I2NP if too short

Browse Source
This commit is contained in:
orignal
2026-07-26 20:33:18 -04:00
parent d73407ad85
commit 15fb818993
1 changed files with 11 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
libi2pd/SSU2Session.cpp
+11 -1
View File
@@ -550,12 +550,22 @@ namespace transport
bool SSU2Session::SendFragmentedMessage (std::shared_ptr<I2NPMessage> msg)
{
if (!msg) return false;
auto ts = i2p::util::GetMillisecondsSinceEpoch ();
if (msg->GetNTCP2Length () + 3 <= m_MaxPayloadSize)
{
// non fragmented, send regular I2NP block
auto packet = m_Server.GetSentPacketsPool ().AcquireShared ();
packet->payloadSize = CreateI2NPBlock (packet->payload, m_MaxPayloadSize, std::move (msg));
uint32_t packetNum = SendData (packet->payload, packet->payloadSize);
packet->sendTime = ts;
m_SentPackets.emplace (packetNum, packet);
return true;
}
size_t lastFragmentSize = (msg->GetNTCP2Length () + 3 - m_MaxPayloadSize) % (m_MaxPayloadSize - 8);
size_t extraSize = m_MaxPayloadSize - lastFragmentSize;
bool ackBlockSent = false;
uint32_t msgID;
memcpy (&msgID, msg->GetHeader () + I2NP_HEADER_MSGID_OFFSET, 4);
auto ts = i2p::util::GetMillisecondsSinceEpoch ();
auto packet = m_Server.GetSentPacketsPool ().AcquireShared ();
if (extraSize >= 8)
{