From 27b982ceafba8aa16397552619d907d02c5ae5d7 Mon Sep 17 00:00:00 2001 From: Kevin Ottens Date: Wed, 1 Jul 2020 13:20:56 +0200 Subject: [PATCH] Override parallelism() for uploads This way we'll be able to control parallelism for upload jobs. Signed-off-by: Kevin Ottens --- src/libsync/propagateupload.cpp | 6 ++++++ src/libsync/propagateupload.h | 3 +++ 2 files changed, 9 insertions(+) diff --git a/src/libsync/propagateupload.cpp b/src/libsync/propagateupload.cpp index 44c4dd24c..24b555242 100644 --- a/src/libsync/propagateupload.cpp +++ b/src/libsync/propagateupload.cpp @@ -168,11 +168,17 @@ PropagateUploadFileCommon::PropagateUploadFileCommon(OwncloudPropagator *propaga : PropagateItemJob(propagator, item) , _finished(false) , _deleteExisting(false) + , _parallelism(FullParallelism) , _uploadEncryptedHelper(nullptr) , _uploadingEncrypted(false) { } +PropagatorJob::JobParallelism PropagateUploadFileCommon::parallelism() +{ + return _parallelism; +} + void PropagateUploadFileCommon::setDeleteExisting(bool enabled) { _deleteExisting = enabled; diff --git a/src/libsync/propagateupload.h b/src/libsync/propagateupload.h index ba82fe53c..87291e185 100644 --- a/src/libsync/propagateupload.h +++ b/src/libsync/propagateupload.h @@ -226,10 +226,13 @@ protected: }; UploadFileInfo _fileToUpload; QByteArray _transmissionChecksumHeader; + JobParallelism _parallelism; public: PropagateUploadFileCommon(OwncloudPropagator *propagator, const SyncFileItemPtr &item); + JobParallelism parallelism() override; + /** * Whether an existing entity with the same name may be deleted before * the upload. -- 2.30.2