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

Request ack more often

Browse Source
This commit is contained in:
orignal
2025-12-03 15:07:30 -05:00
parent a95b1ce061
commit 99ed95c7eb
1 changed files with 17 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
libi2pd/Streaming.cpp
+17 -3
View File
@@ -622,8 +622,22 @@ namespace stream
LogPrint (eLogError, "Streaming: Missing signature, sSID=", m_SendStreamID, ", rSID=", m_RecvStreamID);
return false;
}
if (immediateAckRequested)
SendQuickAck ();
if (immediateAckRequested)
{
auto ts = i2p::util::GetMillisecondsSinceEpoch ();
if (m_LastACKSendTime != ts) // preventing multiple acks when reading m_SavedPackets
{
if (m_IsAckSendScheduled)
{
SendQuickAck ();
auto ackTimeout = m_RTT/10;
if (ackTimeout > m_AckDelay) ackTimeout = m_AckDelay;
ScheduleAck (ackTimeout);
}
else
SendQuickAck ();
}
}
return true;
}
@@ -1039,7 +1053,7 @@ namespace stream
else
{
// follow on packet
if (m_IsJavaClient && (!m_LastACKRequestTime || ts - m_LastACKRequestTime > m_MinRTT / 10))
if (!m_LastACKRequestTime || ts - m_LastACKRequestTime > m_MinRTT / 10)
{
m_LastACKRequestTime = ts;
htobe16buf (packet + size, PACKET_FLAG_DELAY_REQUESTED);