diff --git a/src/libsync/propagateremotemkdir.cpp b/src/libsync/propagateremotemkdir.cpp index a8e1b68f18..a44e8e93e3 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 7a0d8b6caf..43de418ee3 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;