File indexing completed on 2024-04-14 03:48:52

 // SPDX-License-Identifier: LGPL-2.1-or-later
 //
 // SPDX-FileCopyrightText: 2011 Dennis Nienhüser <nienhueser@kde.org>
 //
 
 #include "jobqueue.h"
 #include "logger.h"
 
 #include <QDebug>
 #include <QThreadPool>
 
 JobQueue::JobQueue(QObject *parent) :
     QObject(parent), m_maxConcurrentJobs(1)
 {
     // nothing to do
 }
 
 void JobQueue::addJob(Job *newJob)
 {
     QList<Job*> const allJobs = m_jobs + m_runningJobs;
     for(Job* job: allJobs) {
         if (*job == *newJob) {
             qDebug() << "Ignoring job, still running";
             return;
         }
     }
 
     connect(newJob, SIGNAL(finished(Job*)), this, SLOT(removeJob(Job*)));
 
     if (m_runningJobs.size()<m_maxConcurrentJobs) {
         startJob(newJob);
     } else {
         Logger::instance().setStatus(newJob->region().id() + QLatin1Char('_') + newJob->transport(), newJob->region().name() + QLatin1String(" (") + newJob->transport() + QLatin1Char(')'), "waiting", "Queued.");
         m_jobs << newJob;
     }
 }
 
 void JobQueue::setMaxConcurrentJobs(int size)
 {
     m_maxConcurrentJobs = size;
 }
 
 void JobQueue::removeJob(Job *job)
 {
     m_runningJobs.removeAll(job);
 
     while (m_runningJobs.size()<m_maxConcurrentJobs && !m_jobs.isEmpty()) {
         Job* newJob = m_jobs.first();
         m_jobs.removeFirst();
         startJob(newJob);
     }
 }
 
 void JobQueue::startJob(Job *job)
 {
     m_runningJobs << job;
     QThreadPool::globalInstance()->start(job);
 }
 
 #include "moc_jobqueue.cpp"