Method ProcessRequestPartsPacket

src/UploadClient.cpp:691–739

}

void CUpDownClient::ProcessRequestPartsPacket(const uint8_t* pachPacket, uint32 nSize, bool largeblocks) {

	CMemFile data(pachPacket, nSize);

	CMD4Hash reqfilehash = data.ReadHash();

	uint64 auStartOffsets[3];
	uint64 auEndOffsets[3];

	if (largeblocks) {
		auStartOffsets[0] = data.ReadUInt64();
		auStartOffsets[1] = data.ReadUInt64();
		auStartOffsets[2] = data.ReadUInt64();

		auEndOffsets[0] = data.ReadUInt64();
		auEndOffsets[1] = data.ReadUInt64();
		auEndOffsets[2] = data.ReadUInt64();
	} else {
		auStartOffsets[0] = data.ReadUInt32();
		auStartOffsets[1] = data.ReadUInt32();
		auStartOffsets[2] = data.ReadUInt32();

		auEndOffsets[0] = data.ReadUInt32();
		auEndOffsets[1] = data.ReadUInt32();
		auEndOffsets[2] = data.ReadUInt32();
	}

	for (unsigned int i = 0; i < itemsof(auStartOffsets); i++) {
		AddDebugLogLineN(logClient,
			CFormat("Client %s requests %d File block %d-%d (%d bytes):")
				% GetFullIP() % i % auStartOffsets[i] % auEndOffsets[i]
				% (auEndOffsets[i] - auStartOffsets[i]));
		if (auEndOffsets[i] > auStartOffsets[i]) {
			Requested_Block_Struct* reqblock = new Requested_Block_Struct;
			reqblock->StartOffset = auStartOffsets[i];
			reqblock->EndOffset = auEndOffsets[i];
			md4cpy(reqblock->FileID, reqfilehash.GetHash());
			reqblock->transferred = 0;
			AddReqBlock(reqblock, false);
		} else {
			if (auEndOffsets[i] != 0 || auStartOffsets[i] != 0) {
				AddDebugLogLineN(logClient, "Client request is invalid!");
			}
		}
	}
	if (theApp->uploadDiskIOThread) {
		theApp->uploadDiskIOThread->NewBlockRequestsAvailable();
	}
}

void CUpDownClient::ProcessRequestPartsPacketv2(const CMemFile& data) {