mirrors/i2pd
2
0
Fork 0
mirror of https://github.com/PurpleI2P/i2pd synced 2024-11-10 08:00:38 +03:00
Code Issues Packages Projects Releases Wiki Activity

correct Ack range

Browse Source
This commit is contained in:
orignal 2022-04-23 11:11:49 -04:00
parent 1326597226
commit 45ebfe378b
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
libi2pd/SSU2.cpp
View File

@ -897,7 +897,7 @@ namespace transport
if (*ranges > lastPacketNum) break; if (*ranges > lastPacketNum) break;
lastPacketNum -= *ranges; ranges++; // nacks lastPacketNum -= *ranges; ranges++; // nacks
if (*ranges > lastPacketNum) break; if (*ranges > lastPacketNum) break;
firstPacketNum -= *ranges; ranges++; // acks firstPacketNum = lastPacketNum - *ranges; ranges++; // acks
len -= 2; len -= 2;
HandleAckRange (firstPacketNum, lastPacketNum); HandleAckRange (firstPacketNum, lastPacketNum);
} }
@ -905,6 +905,7 @@ namespace transport
void SSU2Session::HandleAckRange (uint32_t firstPacketNum, uint32_t lastPacketNum) void SSU2Session::HandleAckRange (uint32_t firstPacketNum, uint32_t lastPacketNum)
{ {
if (firstPacketNum > lastPacketNum) return;
auto it = m_SentPackets.begin (); auto it = m_SentPackets.begin ();
while (it != m_SentPackets.end () && it->first < firstPacketNum) it++; // find first acked packet while (it != m_SentPackets.end () && it->first < firstPacketNum) it++; // find first acked packet
if (it == m_SentPackets.end ()) return; // not found if (it == m_SentPackets.end ()) return; // not found