mirrors/nextcloud-desktop
3
0
Fork 0
mirror of https://github.com/nextcloud/desktop.git synced 2025-10-26 11:17:43 +00:00
Code Issues Packages Projects Releases Wiki Activity

use memory to buffer the data of the files sent during bulk upload

Browse Source 
should help make it faster to send all data

Signed-off-by: Matthieu Gallien <matthieu.gallien@nextcloud.com>
This commit is contained in:
Matthieu Gallien 2025-03-19 11:08:09 +01:00
parent f84d41b9bf
commit 2ed48e9c7d
No known key found for this signature in database
GPG Key ID: 7D0F74F05C22F553
1 changed files with 13 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
src/libsync/putmultifilejob.cpp
View File

@ -32,8 +32,6 @@ PutMultiFileJob::PutMultiFileJob(AccountPtr account,
for(const auto &singleDevice : _devices) {
singleDevice._device->setParent(this);
connect(this, &PutMultiFileJob::uploadProgress,
singleDevice._device.get(), &UploadDevice::slotJobUploadProgress);
}
}
@ -56,7 +54,12 @@ void PutMultiFileJob::start()
if (oneDevice._device->size() == 0) {
onePart.setBody({});
} else {
onePart.setBodyDevice(oneDevice._device.get());
const auto allData = oneDevice._device->readAll();
onePart.setBody(allData);
}
if (oneDevice._device->isOpen()) {
oneDevice._device->close();
}
for (auto it = oneDevice._headers.begin(); it != oneDevice._headers.end(); ++it) {
@ -76,6 +79,9 @@ void PutMultiFileJob::start()
}
connect(reply(), &QNetworkReply::uploadProgress, this, &PutMultiFileJob::uploadProgress);
connect(reply(), &QNetworkReply::uploadProgress, this, [] (qint64 bytesSent, qint64 bytesTotal) {
qCInfo(lcPutMultiFileJob()) << "upload progress" << bytesSent << bytesTotal;
});
connect(this, &AbstractNetworkJob::networkActivity, account().data(), &Account::propagatorNetworkActivity);
_requestTimer.start();
AbstractNetworkJob::start();
@ -91,8 +97,10 @@ bool PutMultiFileJob::finished()
for(const auto &oneDevice : _devices) {
Q_ASSERT(oneDevice._device);
if (!oneDevice._device->errorString().isEmpty()) {
qCWarning(lcPutMultiFileJob) << "oneDevice has error:" << oneDevice._device->errorString();
if (oneDevice._device->isOpen()) {
if (!oneDevice._device->errorString().isEmpty()) {
qCWarning(lcPutMultiFileJob) << "oneDevice has error:" << oneDevice._device->errorString();
}
}
if (oneDevice._device->isOpen()) {