X-Git-Url: https://git.carlh.net/gitweb/?a=blobdiff_plain;f=src%2Flib%2Fjob.h;h=791a9101b24bed0ca792049cf5bd24123b4c89a8;hb=5f1046a2164fff00a6fc74aecf4cacbca531d415;hp=c98dbaea15dfb13133611f61727439d332158470;hpb=8bfb6ae0780b0bf3318c345df78518ad3fabc9fc;p=dcpomatic.git diff --git a/src/lib/job.h b/src/lib/job.h index c98dbaea1..791a9101b 100644 --- a/src/lib/job.h +++ b/src/lib/job.h @@ -21,13 +21,14 @@ * @brief A parent class to represent long-running tasks which are run in their own thread. */ -#ifndef DVDOMATIC_JOB_H -#define DVDOMATIC_JOB_H +#ifndef DCPOMATIC_JOB_H +#define DCPOMATIC_JOB_H #include #include #include #include +#include class Film; @@ -37,7 +38,7 @@ class Film; class Job : public boost::enable_shared_from_this { public: - Job (boost::shared_ptr s); + Job (boost::shared_ptr); virtual ~Job() {} /** @return user-readable name of this job */ @@ -46,12 +47,17 @@ public: virtual void run () = 0; void start (); + void pause (); + void resume (); + 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; + bool paused () const; std::string error_summary () const; std::string error_details () const; @@ -65,7 +71,7 @@ public: void descend (float); float overall_progress () const; - /** Emitted by the JobManagerView from the UI thread */ + /** Emitted from the UI thread when the job is finished */ boost::signals2::signal Finished; protected: @@ -74,22 +80,25 @@ 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 + PAUSED, ///< 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 }; void set_state (State); void set_error (std::string s, std::string d); - /** Film for this job */ - boost::shared_ptr _film; + boost::shared_ptr _film; private: void run_wrapper (); + boost::thread* _thread; + /** mutex for _state and _error */ mutable boost::mutex _state_mutex; /** current state of the job */