dandri/i2pd
1
0
Fork 0
mirror of https://github.com/PurpleI2P/i2pd.git synced 2026-07-18 22:36:57 +00:00
Code Issues Packages Projects Releases Wiki Activity

std::list for NACKed packets

Browse Source
This commit is contained in:
orignal
2026-06-29 17:09:15 -04:00
parent 6a523096da
commit 8ace25aa01
2 changed files with 5 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
libi2pd/Streaming.cpp
+4 -2
View File
@@ -696,7 +696,6 @@ namespace stream
bool acknowledged = false;
auto ts = i2p::util::GetMillisecondsSinceEpoch ();
uint32_t ackThrough = packet->GetAckThrough ();
m_NACKedPackets.clear ();
if (ackThrough > m_SequenceNumber)
{
LogPrint (eLogError, "Streaming: Unexpected ackThrough=", ackThrough, " > seqn=", m_SequenceNumber);
@@ -708,6 +707,7 @@ namespace stream
m_IsNAcked = false;
m_IsResendNeeded = false;
int nackCount = packet->GetNACKCount ();
std::list<Packet *> newNACKedPackets;
for (auto it = m_SentPackets.begin (); it != m_SentPackets.end ();)
{
auto seqn = (*it)->GetSeqn ();
@@ -719,7 +719,7 @@ namespace stream
for (int i = 0; i < nackCount; i++)
if (seqn == packet->GetNACK (i))
{
m_NACKedPackets.insert (*it);
newNACKedPackets.push_back (*it);
m_IsNAcked = true;
nacked = true;
break;
@@ -753,6 +753,8 @@ namespace stream
else
break;
}
m_NACKedPackets.swap (newNACKedPackets);
if (m_LastACKRecieveTime)
{
uint64_t interval = ts - m_LastACKRecieveTime;