X-Git-Url: https://git.carlh.net/gitweb/?a=blobdiff_plain;f=src%2Flib%2Fjob_manager.cc;h=f31a00a18b33f0bce674f0406b06197f8fbea691;hb=e60bb3e51bd1508b149e6b8f6608f09b5196ae26;hp=b5b64a77eccc9d9f000d8512ee3a2101142a059b;hpb=04bd447fd8960625bda5081cbac235b848d7631f;p=dcpomatic.git diff --git a/src/lib/job_manager.cc b/src/lib/job_manager.cc index b5b64a77e..f31a00a18 100644 --- a/src/lib/job_manager.cc +++ b/src/lib/job_manager.cc @@ -40,7 +40,7 @@ JobManager::JobManager () , _last_active_jobs (false) , _scheduler (new boost::thread (boost::bind (&JobManager::scheduler, this))) { - + } JobManager::~JobManager () @@ -64,7 +64,7 @@ JobManager::add (shared_ptr j) } emit (boost::bind (boost::ref (JobAdded), weak_ptr (j))); - + return j; } @@ -98,7 +98,7 @@ JobManager::errors () const } return false; -} +} void JobManager::scheduler () @@ -112,21 +112,21 @@ JobManager::scheduler () if (_terminate) { return; } - + for (list >::iterator i = _jobs.begin(); i != _jobs.end(); ++i) { if (!(*i)->finished ()) { active_jobs = true; } - + if ((*i)->running ()) { /* Something is already happening */ break; } - + if ((*i)->is_new()) { (*i)->start (); - + /* Only start one job at once */ break; }