Override parallelism() for uploads

This way we'll be able to control parallelism for upload jobs.

Signed-off-by: Kevin Ottens <kevin.ottens@nextcloud.com>

diff --git a/src/libsync/propagateupload.cpp b/src/libsync/propagateupload.cpp
index 44c4dd24ceb31536074bbd5310c93bf34ca3c57d..24b55524264c1ff00f1679ae163b26d07362956a 100644 (file)
--- 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 ba82fe53cad1b2d2ca62d81319d8a8d2346693cd..87291e1854cc6a3d93069100ae0887aa2430bff2 100644 (file)
--- 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.