X-Git-Url: https://main.carlh.net/gitweb/?p=dcpomatic.git;a=blobdiff_plain;f=src%2Flib%2Fjob.h;h=a0e988fc8ccd11df26983127e347691da43cd2f2;hp=7bc051142c5507802d022c479c03befadd22b911;hb=f515b8daea9d28200be803bb64ff17e9f30343c4;hpb=f80d8d37323394113d6491e1cae271e32b2de5b4 diff --git a/src/lib/job.h b/src/lib/job.h index 7bc051142..a0e988fc8 100644 --- a/src/lib/job.h +++ b/src/lib/job.h @@ -40,7 +40,7 @@ class Film; class Job : public boost::enable_shared_from_this, public Signaller, public boost::noncopyable { public: - Job (boost::shared_ptr); + explicit Job (boost::shared_ptr film); virtual ~Job (); /** @return user-readable name of this job */ @@ -50,7 +50,8 @@ public: virtual void run () = 0; void start (); - void pause (); + bool pause_by_user (); + void pause_by_priority (); void resume (); void cancel (); @@ -60,12 +61,14 @@ public: bool finished_ok () const; bool finished_in_error () const; bool finished_cancelled () const; - bool paused () const; + bool paused_by_user () const; + bool paused_by_priority () const; std::string error_summary () const; std::string error_details () const; - int elapsed_time () const; + boost::optional message () const; + virtual std::string status () const; std::string json_status () const; std::string sub_name () const { @@ -86,6 +89,8 @@ public: 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: @@ -95,7 +100,8 @@ protected: enum State { NEW, ///< the job hasn't been started yet RUNNING, ///< the job is running - PAUSED, ///< the job has been paused + PAUSED_BY_USER, ///< the job has been paused + PAUSED_BY_PRIORITY, ///< the job has been paused FINISHED_OK, ///< the job has finished successfully FINISHED_ERROR, ///< the job has finished in error FINISHED_CANCELLED ///< the job was cancelled @@ -103,6 +109,10 @@ 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; @@ -111,18 +121,22 @@ 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 sub-job was started */ + /** time that this job was started */ time_t _start_time; + /** time that this sub-job was started */ + time_t _sub_start_time; std::string _sub_name; /** mutex for _progress and _last_progress_update */