X-Git-Url: https://main.carlh.net/gitweb/?p=dcpomatic.git;a=blobdiff_plain;f=src%2Flib%2Fjob_manager.h;h=ff5800aa84a6d2da70eed283eead48c9de6e2609;hp=d4287f8746d667fd999d1d27450cdd9ef03150ae;hb=8963f0007af1a312017b9627c18b82ec2a577591;hpb=ea6b2dae46caa1da829fbf499e83cd6ae3b3773a diff --git a/src/lib/job_manager.h b/src/lib/job_manager.h index d4287f874..ff5800aa8 100644 --- a/src/lib/job_manager.h +++ b/src/lib/job_manager.h @@ -1,5 +1,5 @@ /* - Copyright (C) 2012-2018 Carl Hetherington + Copyright (C) 2012-2021 Carl Hetherington This file is part of DCP-o-matic. @@ -18,10 +18,12 @@ */ + /** @file src/job_manager.h * @brief A simple scheduler for jobs. */ + #include "signaller.h" #include #include @@ -29,26 +31,33 @@ #include #include + class Job; class Film; class Playlist; +class Content; struct threed_test7; + extern bool wait_for_jobs (); + /** @class JobManager * @brief A simple scheduler for jobs. */ -class JobManager : public Signaller, public boost::noncopyable +class JobManager : public Signaller { public: - boost::shared_ptr add (boost::shared_ptr); - boost::shared_ptr add_after (boost::shared_ptr after, boost::shared_ptr j); - std::list > get () const; + JobManager (JobManager const&) = delete; + JobManager& operator= (JobManager const&) = delete; + + std::shared_ptr add (std::shared_ptr); + std::shared_ptr add_after (std::shared_ptr after, std::shared_ptr j); + std::list> get () const; bool work_to_do () const; bool errors () const; - void increase_priority (boost::shared_ptr); - void decrease_priority (boost::shared_ptr); + void increase_priority (std::shared_ptr); + void decrease_priority (std::shared_ptr); void pause (); void resume (); bool paused () const { @@ -57,14 +66,21 @@ public: } void analyse_audio ( - boost::shared_ptr film, - boost::shared_ptr playlist, + std::shared_ptr film, + std::shared_ptr playlist, bool from_zero, boost::signals2::connection& connection, - boost::function ready + std::function ready + ); + + void analyse_subtitles ( + std::shared_ptr film, + std::shared_ptr content, + boost::signals2::connection& connection, + std::function ready ); - boost::signals2::signal)> JobAdded; + boost::signals2::signal)> JobAdded; boost::signals2::signal JobsReordered; boost::signals2::signal, boost::optional)> ActiveJobsChanged; @@ -86,11 +102,11 @@ private: mutable boost::mutex _mutex; boost::condition _empty_condition; /** List of jobs in the order that they will be executed */ - std::list > _jobs; + std::list> _jobs; std::list _connections; - bool _terminate; - bool _paused; - boost::shared_ptr _paused_job; + bool _terminate = false; + bool _paused = false; + std::shared_ptr _paused_job; boost::optional _last_active_job; boost::thread _scheduler;