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

try to request blocks again for stalled connection

Browse Source
This commit is contained in:
orignal
2026-08-14 09:23:42 -04:00
parent 7dcbeadf8c
commit c3f8c762cc
2 changed files with 23 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files
libi2pd_client/Torrents.cpp
+22 -8
View File
@@ -202,7 +202,12 @@ namespace torrents
}
}
else
LogPrint (eLogWarning, "Torrents: Duplicated, late or unsolicited piece block ", blockIndex);
{
if ((*m_Blocks)[blockIndex] == BlockStatus::Available)
LogPrint (eLogWarning, "Torrents: Duplicated piece block ", blockIndex);
else
LogPrint (eLogWarning, "Torrents: Late or unsolicited piece block ", blockIndex);
}
}
void Piece::Dump (PieceFileFragment&& fragment)
@@ -759,10 +764,14 @@ namespace torrents
}
else if (ts > m_LastSendTime + PEER_KEEP_SEND_INTERVAL)
{
// send keep-alive
uint32_t len = 0;
WriteToStream ((const uint8_t *)&len, 4);
m_LastSendTime = ts;
m_NumRequests = 0; // if we need to send keep-alive, all pending requests are invalid now
if (m_Torrent->IsComplete () || !RequestNextBlocks ()) // try to request if we still have blocks to request
{
// send keep-alive
uint32_t len = 0;
WriteToStream ((const uint8_t *)&len, 4);
m_LastSendTime = ts;
}
}
}
}
@@ -1307,13 +1316,18 @@ namespace torrents
m_NumRequests++;
}
void PeerConnection::RequestNextBlocks ()
bool PeerConnection::RequestNextBlocks ()
{
if (m_IsChoked || !m_Torrent || m_Torrent->IsComplete ()) return;
if (m_IsChoked || !m_Torrent || m_Torrent->IsComplete ()) return false;
bool sent = false;
while (m_NumRequests < MAX_NUM_REQUESTS)
{
if (!RequestNextBlock ()) break;
if (RequestNextBlock ())
sent = true;
else
break;
}
return sent;
}
TorrentsTunnel::TorrentsTunnel (std::string_view name, std::shared_ptr<i2p::client::ClientDestination> localDestination,
libi2pd_client/Torrents.h
+1 -1
View File
@@ -266,7 +266,7 @@ namespace torrents
bool RequestNextBlock ();
void RequestNextBlock (uint32_t index, uint32_t offset, uint32_t len);
void RequestNextBlocks ();
bool RequestNextBlocks ();
bool SendRequestedBlock (const RequestedBlock& requestedBlock);