X-Git-Url: https://main.carlh.net/gitweb/?a=blobdiff_plain;f=src%2Flib%2Fjob.h;h=791a9101b24bed0ca792049cf5bd24123b4c89a8;hb=c1bae7f0dac684147e00f5f51dcd5544ba13ee53;hp=2a77f78f7775e43009e5642fddb5710fcaf1c934;hpb=bb767c7e338414beee132af3e96829c1448e214b;p=dcpomatic.git diff --git a/src/lib/job.h b/src/lib/job.h index 2a77f78f7..791a9101b 100644 --- a/src/lib/job.h +++ b/src/lib/job.h @@ -21,24 +21,25 @@ * @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 +#include -class Log; -class FilmState; -class Options; +class Film; /** @class Job * @brief A parent class to represent long-running tasks which are run in their own thread. */ -class Job +class Job : public boost::enable_shared_from_this { public: - Job (boost::shared_ptr s, boost::shared_ptr o, Log* l); + Job (boost::shared_ptr); + virtual ~Job() {} /** @return user-readable name of this job */ virtual std::string name () const = 0; @@ -46,13 +47,20 @@ 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 () const; + std::string error_summary () const; + std::string error_details () const; int elapsed_time () const; virtual std::string status () const; @@ -63,40 +71,46 @@ public: void descend (float); float overall_progress () const; - void emit_finished (); - - /** Emitted from the GUI thread */ - sigc::signal0 Finished; + /** Emitted from the UI thread when the job is finished */ + boost::signals2::signal Finished; protected: + virtual int remaining_time () const; + + /** 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 e); + void set_error (std::string s, std::string d); - boost::shared_ptr _fs; - boost::shared_ptr _opt; - - /** A log that this job can write to */ - Log* _log; + 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 */ State _state; - 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; - + + /** mutex for _stack and _progress_unknown */ mutable boost::mutex _progress_mutex; struct Level { @@ -110,6 +124,8 @@ private: /** true if this job's progress will always be unknown */ bool _progress_unknown; + + int _ran_for; }; #endif