Mirrors/i2pd
2
0
Fork 0
mirror of https://github.com/PurpleI2P/i2pd.git synced 2025-04-24 18:06:35 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions

Merge f6f38de2db into f2893097a7

Browse source
This commit is contained in:
Jeff 2016-08-31 01:26:40 +00:00 • committed by GitHub
commit 02b4554cb0
1 changed files with 5 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
Streaming.cpp
View file

@ -96,7 +96,7 @@ namespace stream
// we should also try stored messages if any // we should also try stored messages if any
for (auto it = m_SavedPackets.begin (); it != m_SavedPackets.end ();) for (auto it = m_SavedPackets.begin (); it != m_SavedPackets.end ();)
{ {
if ((*it)->GetSeqn () == (uint32_t)(m_LastReceivedSequenceNumber + 1)) if ((*it)->GetSeqn () < (uint32_t)(m_LastReceivedSequenceNumber + 1))
{ {
Packet * savedPacket = *it; Packet * savedPacket = *it;
m_SavedPackets.erase (it++); m_SavedPackets.erase (it++);
@ -439,8 +439,8 @@ namespace stream
return; return;
} }
Packet p; Packet * p = new Packet;
uint8_t * packet = p.GetBuffer (); uint8_t * packet = p->GetBuffer ();
size_t size = 0; size_t size = 0;
htobe32buf (packet + size, m_SendStreamID); htobe32buf (packet + size, m_SendStreamID);
size += 4; // sendStreamID size += 4; // sendStreamID
@ -488,9 +488,9 @@ namespace stream
size += 2; // flags size += 2; // flags
htobuf16 (packet + size, 0); // no options htobuf16 (packet + size, 0); // no options
size += 2; // options size size += 2; // options size
p.len = size; p->len = size;
SendPackets (std::vector<Packet *> { &p }); SendPackets (std::vector<Packet *> { p });
LogPrint (eLogDebug, "Streaming: Quick Ack sent. ", (int)numNacks, " NACKs"); LogPrint (eLogDebug, "Streaming: Quick Ack sent. ", (int)numNacks, " NACKs");
} }