From: Carl Hetherington Date: Tue, 27 Nov 2018 23:08:41 +0000 (+0000) Subject: Fix active job signalling. X-Git-Tag: v2.13.77~4 X-Git-Url: https://git.carlh.net/gitweb/?p=dcpomatic.git;a=commitdiff_plain;h=b8f0865d6a5d182dc4c718b9320c82091864e55b Fix active job signalling. --- diff --git a/src/lib/job_manager.cc b/src/lib/job_manager.cc index 44c81e725..e2302a215 100644 --- a/src/lib/job_manager.cc +++ b/src/lib/job_manager.cc @@ -153,15 +153,12 @@ JobManager::scheduler () boost::mutex::scoped_lock lm (_mutex); - optional active_job; - while (true) { bool have_new = false; bool have_running = false; BOOST_FOREACH (shared_ptr i, _jobs) { if (i->running()) { have_running = true; - active_job = i->json_name(); } if (i->is_new()) { have_new = true; @@ -183,23 +180,24 @@ JobManager::scheduler () if (i->is_new()) { _connections.push_back (i->FinishedImmediate.connect(bind(&JobManager::job_finished, this))); i->start (); + emit (boost::bind (boost::ref (ActiveJobsChanged), _last_active_job, i->json_name())); + _last_active_job = i->json_name (); /* Only start one job at once */ break; } } - - lm.unlock (); - - if (active_job != _last_active_job) { - emit (boost::bind (boost::ref (ActiveJobsChanged), _last_active_job, active_job)); - _last_active_job = active_job; - } } } void JobManager::job_finished () { + { + boost::mutex::scoped_lock lm (_mutex); + emit (boost::bind (boost::ref (ActiveJobsChanged), _last_active_job, optional())); + _last_active_job = optional(); + } + _empty_condition.notify_all (); }