projects
/
dcpomatic.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Try to move J2K bandwidth and colour LUT to be per-film (#23).
[dcpomatic.git]
/
src
/
lib
/
job.h
diff --git
a/src/lib/job.h
b/src/lib/job.h
index 95599bdbb65bf1dd1ca8bae44b4347ac5bb1015d..f32cfa811ad58c19d10c320bcb323120099354ba 100644
(file)
--- a/
src/lib/job.h
+++ b/
src/lib/job.h
@@
-26,19
+26,19
@@
#include <string>
#include <boost/thread/mutex.hpp>
#include <string>
#include <boost/thread/mutex.hpp>
-#include <sigc++/sigc++.h>
+#include <boost/enable_shared_from_this.hpp>
+#include <boost/signals2.hpp>
-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
* @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<Job>
{
public:
{
public:
- Job (boost::shared_ptr<const FilmState> s, boost::shared_ptr<const Options> o, Log* l);
+ Job (boost::shared_ptr<Film> s, boost::shared_ptr<Job> req);
+ virtual ~Job() {}
/** @return user-readable name of this job */
virtual std::string name () const = 0;
/** @return user-readable name of this job */
virtual std::string name () const = 0;
@@
-47,6
+47,7
@@
public:
void start ();
void start ();
+ bool is_new () const;
bool running () const;
bool finished () const;
bool finished_ok () const;
bool running () const;
bool finished () const;
bool finished_ok () const;
@@
-63,15
+64,17
@@
public:
void descend (float);
float overall_progress () const;
void descend (float);
float overall_progress () const;
- void emit_finished ();
+ boost::shared_ptr<Job> required () const {
+ return _required;
+ }
- /** Emitted from the GUI thread */
- sigc::signal0<void> Finished;
+ boost::signals2::signal<void()> Finished;
protected:
virtual int remaining_time () const;
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
enum State {
NEW, ///< the job hasn't been started yet
RUNNING, ///< the job is running
@@
-82,23
+85,26
@@
protected:
void set_state (State);
void set_error (std::string e);
void set_state (State);
void set_error (std::string e);
- boost::shared_ptr<const FilmState> _fs;
- boost::shared_ptr<const Options> _opt;
-
- /** A log that this job can write to */
- Log* _log;
+ /** Film for this job */
+ boost::shared_ptr<Film> _film;
private:
void run_wrapper ();
private:
void run_wrapper ();
+ boost::shared_ptr<Job> _required;
+
/** mutex for _state and _error */
mutable boost::mutex _state_mutex;
/** mutex for _state and _error */
mutable boost::mutex _state_mutex;
+ /** current state of the job */
State _state;
State _state;
+ /** message for an error that has occurred (when state == FINISHED_ERROR) */
std::string _error;
std::string _error;
+ /** time that this job was started */
time_t _start_time;
time_t _start_time;
-
+
+ /** mutex for _stack and _progress_unknown */
mutable boost::mutex _progress_mutex;
struct Level {
mutable boost::mutex _progress_mutex;
struct Level {
@@
-112,6
+118,8
@@
private:
/** true if this job's progress will always be unknown */
bool _progress_unknown;
/** true if this job's progress will always be unknown */
bool _progress_unknown;
+
+ int _ran_for;
};
#endif
};
#endif