mirror of
https://github.com/QuasarApp/Heart.git
synced 2025-05-13 01:49:41 +00:00
parent
6e0f603e90
commit
470a2424a7
@ -95,6 +95,8 @@ bool BigDataParser::newPackage(const QSharedPointer<PKG::BigDataHeader> &header,
|
||||
request.setCurrentPart(0);
|
||||
request.setPackageId(header->packageId());
|
||||
|
||||
QuasarAppUtils::Params::log("Receive BigData Header:" + header->toString());
|
||||
|
||||
return node()->sendData(&request, sender, &hdr);
|
||||
}
|
||||
|
||||
@ -110,6 +112,11 @@ bool BigDataParser::processPart(const QSharedPointer<PKG::BigDataPart> &part,
|
||||
|
||||
auto& localPool = _pool[part->packageId()];
|
||||
|
||||
QuasarAppUtils::Params::log(QString("Process Part of %0: part %1/%2").
|
||||
arg(part->packageId()).
|
||||
arg(part->getPakckageNumber()).
|
||||
arg(localPool.chaindata.size() - 1));
|
||||
|
||||
localPool.chaindata[part->getPakckageNumber()] = part;
|
||||
|
||||
auto sendRequest = [sender, &hdr, this](int part, unsigned int id){
|
||||
|
Loading…
x
Reference in New Issue
Block a user