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

drop duplicated, later on unsolicited blocks

Browse Source
This commit is contained in:
orignal
2026-08-13 17:49:17 -04:00
parent 5352ac46bc
commit 8b9bc39b4d
1 changed files with 8 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files
libi2pd_client/Torrents.cpp
+8 -7
View File
@@ -186,14 +186,13 @@ namespace torrents
void Piece::BlockReceived (const uint8_t * block, size_t len, size_t offset)
{
if (offset + len > m_Size || !m_Blocks) return;
if (!m_Data) m_Data = new uint8_t[m_Size];
memcpy (m_Data + offset, block, len);
size_t startBlock = offset/REQUEST_BLOCK_SIZE;
auto numBlocks = GetNumBlocks (len);
if (numBlocks > 0)
if (!len || offset + len > m_Size || !m_Blocks) return;
size_t blockIndex = offset/REQUEST_BLOCK_SIZE;
if ((*m_Blocks)[blockIndex] == BlockStatus::Requested)
{
std::fill_n (m_Blocks->begin () + startBlock, numBlocks, BlockStatus::Available);
if (!m_Data) m_Data = new uint8_t[m_Size];
memcpy (m_Data + offset, block, len);
(*m_Blocks)[blockIndex] = BlockStatus::Available;
if (std::find_if (m_Blocks->begin (), m_Blocks->end (),
[](BlockStatus status) { return status != BlockStatus::Available; }) == m_Blocks->end ())
{
@@ -202,6 +201,8 @@ namespace torrents
Complete ();
}
}
else
LogPrint (eLogWarning, "Torrents: Duplicated, late or unsolicited piece block ", blockIndex);
}
void Piece::Dump (PieceFileFragment&& fragment)