Emit the state of the job with the Finished signals.

[dcpomatic.git] / src / lib / job_manager.cc

diff --git a/src/lib/job_manager.cc b/src/lib/job_manager.cc
index 7a6bda8405b32240ae18bd9211e65abfe228a060..9fcd86f2d38b7c034a332740a74457f672bd1b9b 100644 (file)
--- a/src/lib/job_manager.cc
+++ b/src/lib/job_manager.cc
@@ -75,7 +75,7 @@ JobManager::~JobManager ()
        {
                boost::mutex::scoped_lock lm (_mutex);
                _terminate = true;
-               _empty_condition.notify_all ();
+               _schedule_condition.notify_all();
        }
 
        try {
@@ -90,7 +90,7 @@ JobManager::add (shared_ptr<Job> j)
        {
                boost::mutex::scoped_lock lm (_mutex);
                _jobs.push_back (j);
-               _empty_condition.notify_all ();
+               _schedule_condition.notify_all();
        }
 
        emit (boost::bind(boost::ref(JobAdded), weak_ptr<Job>(j)));
@@ -107,7 +107,7 @@ JobManager::add_after (shared_ptr<Job> after, shared_ptr<Job> j)
                auto i = find (_jobs.begin(), _jobs.end(), after);
                DCPOMATIC_ASSERT (i != _jobs.end());
                _jobs.insert (i, j);
-               _empty_condition.notify_all ();
+               _schedule_condition.notify_all();
        }
 
        emit (boost::bind(boost::ref(JobAdded), weak_ptr<Job>(j)));
@@ -166,9 +166,11 @@ JobManager::scheduler ()
 
                bool have_running = false;
                for (auto i: _jobs) {
-                       if (have_running && i->running()) {
+                       if ((have_running || _paused) && i->running()) {
+                               /* We already have a running job, or are totally paused, so this job should not be running */
                                i->pause_by_priority();
-                       } else if (!have_running && (i->is_new() || i->paused_by_priority())) {
+                       } else if (!have_running && !_paused && (i->is_new() || i->paused_by_priority())) {
+                               /* We don't have a running job, and we should have one, so start/resume this */
                                if (i->is_new()) {
                                        _connections.push_back (i->FinishedImmediate.connect(bind(&JobManager::job_finished, this)));
                                        i->start ();
@@ -183,7 +185,7 @@ JobManager::scheduler ()
                        }
                }
 
-               _empty_condition.wait (lm);
+               _schedule_condition.wait(lm);
        }
 }
 
@@ -197,7 +199,7 @@ JobManager::job_finished ()
                _last_active_job = optional<string>();
        }
 
-       _empty_condition.notify_all ();
+       _schedule_condition.notify_all();
 }
 
 
@@ -227,7 +229,7 @@ JobManager::analyse_audio (
        shared_ptr<const Playlist> playlist,
        bool from_zero,
        boost::signals2::connection& connection,
-       function<void()> ready
+       function<void (Job::Result)> ready
        )
 {
        {
@@ -250,7 +252,7 @@ JobManager::analyse_audio (
                job = make_shared<AnalyseAudioJob> (film, playlist, from_zero);
                connection = job->Finished.connect (ready);
                _jobs.push_back (job);
-               _empty_condition.notify_all ();
+               _schedule_condition.notify_all ();
        }
 
        emit (boost::bind (boost::ref (JobAdded), weak_ptr<Job> (job)));
@@ -262,7 +264,7 @@ JobManager::analyse_subtitles (
        shared_ptr<const Film> film,
        shared_ptr<Content> content,
        boost::signals2::connection& connection,
-       function<void()> ready
+       function<void (Job::Result)> ready
        )
 {
        {
@@ -285,7 +287,7 @@ JobManager::analyse_subtitles (
                job = make_shared<AnalyseSubtitlesJob>(film, content);
                connection = job->Finished.connect (ready);
                _jobs.push_back (job);
-               _empty_condition.notify_all ();
+               _schedule_condition.notify_all ();
        }
 
        emit (boost::bind(boost::ref(JobAdded), weak_ptr<Job>(job)));
@@ -304,7 +306,7 @@ JobManager::increase_priority (shared_ptr<Job> job)
                swap(*iter, *std::prev(iter));
        }
 
-       _empty_condition.notify_all();
+       _schedule_condition.notify_all();
        emit(boost::bind(boost::ref(JobsReordered)));
 }
 
@@ -321,42 +323,26 @@ JobManager::decrease_priority (shared_ptr<Job> job)
                swap(*iter, *std::next(iter));
        }
 
-       _empty_condition.notify_all();
+       _schedule_condition.notify_all();
        emit(boost::bind(boost::ref(JobsReordered)));
 }
 
 
+/** Pause all job processing */
 void
 JobManager::pause ()
 {
        boost::mutex::scoped_lock lm (_mutex);
-
-       if (_paused) {
-               return;
-       }
-
-       for (auto i: _jobs) {
-               if (i->pause_by_user()) {
-                       _paused_job = i;
-               }
-       }
-
        _paused = true;
+       _schedule_condition.notify_all();
 }
 
 
+/** Resume processing jobs after a previous pause() */
 void
 JobManager::resume ()
 {
        boost::mutex::scoped_lock lm (_mutex);
-       if (!_paused) {
-               return;
-       }
-
-       if (_paused_job) {
-               _paused_job->resume ();
-       }
-
-       _paused_job.reset ();
        _paused = false;
+       _schedule_condition.notify_all();
 }