From cfd37718188a3d7bbafc8d9728dee83ccb4af828 Mon Sep 17 00:00:00 2001 From: Kevin Ottens Date: Wed, 15 Jul 2020 13:05:11 +0200 Subject: [PATCH] Allow to override the parallelism Signed-off-by: Kevin Ottens --- src/libsync/propagateremotemkdir.cpp | 6 ++++++ src/libsync/propagateremotemkdir.h | 4 ++++ 2 files changed, 10 insertions(+) diff --git a/src/libsync/propagateremotemkdir.cpp b/src/libsync/propagateremotemkdir.cpp index a8e1b68f1..a44e8e93e 100644 --- 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 7a0d8b6ca..43de418ee 100644 --- a/src/libsync/propagateremotemkdir.h +++ b/src/libsync/propagateremotemkdir.h @@ -30,9 +30,13 @@ class PropagateRemoteMkdir : public PropagateItemJob QPointer _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; -- 2.30.2