Method ProcessBlockPacket

src/DownloadClient.cpp:853–1067

*/

void CUpDownClient::ProcessBlockPacket(const uint8_t* packet, uint32 size, bool packed, bool largeblocks)
{
	// Ignore if no data required
	if (!(GetDownloadState() == DS_DOWNLOADING || GetDownloadState() == DS_NONEEDEDPARTS)) {
		return;
	}

	// This vars are defined here to be able to use them on the catch
	int header_size = 16;
	uint64 nStartPos = 0;
	uint64 nEndPos = 0;
	uint32 nBlockSize = 0;
	uint32 lenUnzipped = 0;

	// Update stats
	m_dwLastBlockReceived = ::GetTickCount64();

	try {

		// Read data from packet
		const CMemFile data(packet, size);

		// Check that this data is for the correct file
		if ((!m_reqfile) || data.ReadHash() != m_reqfile->GetFileHash()) {
			throw wxString("Wrong fileid sent (ProcessBlockPacket)");
		}

		// Find the start & end positions, and size of this chunk of data

		if (largeblocks) {
			nStartPos = data.ReadUInt64();
			header_size += 8;
		} else {
			nStartPos = data.ReadUInt32();
			header_size += 4;
		}

		if (packed) {
			nBlockSize = data.ReadUInt32();
			header_size += 4;
			nEndPos = nStartPos + (size - header_size);
		} else {
			if (largeblocks) {
				nEndPos = data.ReadUInt64();
				header_size += 8;
			} else {
				nEndPos = data.ReadUInt32();
				header_size += 4;
			}
		}

		// Check that packet size matches the declared data size + header size
		if ( nEndPos == nStartPos || size != ((nEndPos - nStartPos) + header_size)) {
			throw wxString("Corrupted or invalid DataBlock received (ProcessBlockPacket)");
		}
		theStats::AddDownloadFromSoft(GetClientSoft(),size - header_size);
		bytesReceivedCycle += size - header_size;