X-Git-Url: https://main.carlh.net/gitweb/?a=blobdiff_plain;f=src%2Flib%2Fjob.h;h=fd036bce29c921625bfe71d099214fdd8a508821;hb=ba0a895137b630f5d308b123ef886d68090f855d;hp=41cefb9bee113a2ba322f06845fb4e02cf3daca0;hpb=5e8d74d83b479c3175e837c402d341fb558d3873;p=dcpomatic.git diff --git a/src/lib/job.h b/src/lib/job.h index 41cefb9be..fd036bce2 100644 --- a/src/lib/job.h +++ b/src/lib/job.h @@ -28,9 +28,9 @@ #include #include #include +#include class Film; -class Options; /** @class Job * @brief A parent class to represent long-running tasks which are run in their own thread. @@ -38,7 +38,7 @@ class Options; class Job : public boost::enable_shared_from_this { public: - Job (boost::shared_ptr s, boost::shared_ptr req); + Job (boost::shared_ptr s); virtual ~Job() {} /** @return user-readable name of this job */ @@ -47,14 +47,17 @@ public: virtual void run () = 0; void start (); + void cancel (); bool is_new () const; bool running () const; bool finished () const; bool finished_ok () const; bool finished_in_error () const; + bool finished_cancelled () const; - std::string error () const; + std::string error_summary () const; + std::string error_details () const; int elapsed_time () const; virtual std::string status () const; @@ -65,10 +68,7 @@ public: void descend (float); float overall_progress () const; - boost::shared_ptr required () const { - return _required; - } - + /** Emitted by the JobManagerView from the UI thread */ boost::signals2::signal Finished; protected: @@ -77,14 +77,15 @@ protected: /** Description of a job's state */ enum State { - NEW, ///< the job hasn't been started yet - RUNNING, ///< the job is running - FINISHED_OK, ///< the job has finished successfully - FINISHED_ERROR ///< the job has finished in error + NEW, ///< the job hasn't been started yet + RUNNING, ///< the job is running + FINISHED_OK, ///< the job has finished successfully + FINISHED_ERROR, ///< the job has finished in error + FINISHED_CANCELLED ///< the job was cancelled }; void set_state (State); - void set_error (std::string e); + void set_error (std::string s, std::string d); /** Film for this job */ boost::shared_ptr _film; @@ -93,14 +94,15 @@ private: void run_wrapper (); - boost::shared_ptr _required; + boost::thread* _thread; /** mutex for _state and _error */ mutable boost::mutex _state_mutex; /** current state of the job */ State _state; - /** message for an error that has occurred (when state == FINISHED_ERROR) */ - std::string _error; + /** summary of an error that has occurred (when state == FINISHED_ERROR) */ + std::string _error_summary; + std::string _error_details; /** time that this job was started */ time_t _start_time;