Allow to override the parallelism

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

diff --git a/src/libsync/propagateremotemkdir.cpp b/src/libsync/propagateremotemkdir.cpp
index a8e1b68f1807cb3f5951353b800f55b255df200e..a44e8e93e3e35ac0e69ce197de7056ff6bccf858 100644 (file)
--- a/src/libsync/propagateremotemkdir.cpp
+++ b/src/libsync/propagateremotemkdir.cpp
@@ -32,9 +32,15 @@ PropagateRemoteMkdir::PropagateRemoteMkdir(OwncloudPropagator *propagator, const
     : PropagateItemJob(propagator, item)
     , _deleteExisting(false)
     , _uploadEncryptedHelper(nullptr)
+    , _parallelism(FullParallelism)
 {
 }
 
+PropagatorJob::JobParallelism PropagateRemoteMkdir::parallelism()
+{
+    return _parallelism;
+}
+
 void PropagateRemoteMkdir::start()
 {
     if (propagator()->_abortRequested.fetchAndAddRelaxed(0))

diff --git a/src/libsync/propagateremotemkdir.h b/src/libsync/propagateremotemkdir.h
index 7a0d8b6cafcf4f18e14d9f055f2ffa2b16effd38..43de418ee3981a524b5216a948a67aec67071619 100644 (file)
--- a/src/libsync/propagateremotemkdir.h
+++ b/src/libsync/propagateremotemkdir.h
@@ -30,9 +30,13 @@ class PropagateRemoteMkdir : public PropagateItemJob
     QPointer<AbstractNetworkJob> _job;
     bool _deleteExisting;
     PropagateUploadEncrypted *_uploadEncryptedHelper;
+    JobParallelism _parallelism;
     friend class PropagateDirectory; // So it can access the _item;
 public:
     PropagateRemoteMkdir(OwncloudPropagator *propagator, const SyncFileItemPtr &item);
+
+    JobParallelism parallelism() override;
+
     void start() override;
     void abort(PropagatorJob::AbortType abortType) override;