X-Git-Url: https://git.carlh.net/gitweb/?a=blobdiff_plain;f=src%2Flib%2Fjob.h;h=96f0acbe5a0c886d54a9b96128eed3c5a11a439d;hb=cfbe9d2f44e380efed7a61b5b5c7a2fec7794915;hp=185273e2d590a1d604ed62632ea39d12ce66c9fe;hpb=67a68bd971ebe1b35daa3f75873b4ccb53c00ba0;p=dcpomatic.git diff --git a/src/lib/job.h b/src/lib/job.h index 185273e2d..96f0acbe5 100644 --- a/src/lib/job.h +++ b/src/lib/job.h @@ -27,7 +27,6 @@ #include "signaller.h" #include -#include #include #include #include @@ -37,12 +36,15 @@ class Film; /** @class Job * @brief A parent class to represent long-running tasks which are run in their own thread. */ -class Job : public boost::enable_shared_from_this, public Signaller, public boost::noncopyable +class Job : public std::enable_shared_from_this, public Signaller { public: - Job (boost::shared_ptr film); + explicit Job (std::shared_ptr film); virtual ~Job (); + Job (Job const&) = delete; + Job& operator= (Job const&) = delete; + /** @return user-readable name of this job */ virtual std::string name () const = 0; virtual std::string json_name () const = 0; @@ -50,7 +52,7 @@ public: virtual void run () = 0; void start (); - void pause_by_user (); + bool pause_by_user (); void pause_by_priority (); void resume (); void cancel (); @@ -67,6 +69,8 @@ public: std::string error_summary () const; std::string error_details () const; + boost::optional message () const; + virtual std::string status () const; std::string json_status () const; std::string sub_name () const { @@ -78,15 +82,17 @@ public: void sub (std::string); boost::optional progress () const; - boost::shared_ptr film () const { + std::shared_ptr film () const { return _film; } - void when_finished (boost::signals2::connection& connection, boost::function finished); + void when_finished (boost::signals2::connection& connection, std::function finished); boost::signals2::signal Progress; /** Emitted from the UI thread when the job is finished */ boost::signals2::signal Finished; + /** Emitted from the job thread when the job is finished */ + boost::signals2::signal FinishedImmediate; protected: @@ -105,25 +111,29 @@ protected: void set_state (State); void set_error (std::string s, std::string d); + void set_message (std::string m); int elapsed_sub_time () const; void check_for_interruption_or_pause (); + void stop_thread (); - boost::shared_ptr _film; + std::shared_ptr _film; private: void run_wrapper (); void set_progress_common (boost::optional p); - boost::thread* _thread; + boost::thread _thread; - /** mutex for _state and _error */ + /** mutex for _state, _error*, _message */ mutable boost::mutex _state_mutex; /** current state of the job */ State _state; /** summary of an error that has occurred (when state == FINISHED_ERROR) */ std::string _error_summary; std::string _error_details; + /** a message that should be given to the user when the job finishes */ + boost::optional _message; /** time that this job was started */ time_t _start_time;