X-Git-Url: https://main.carlh.net/gitweb/?a=blobdiff_plain;f=src%2Flib%2Fjob_manager.h;h=2788fc657d2a00278e81ac55fb6c785059134dce;hb=4285355ff2bec853924647f0523d121860fe64e3;hp=a382dd7363732cc4ddd20fad782005bd438ea2ff;hpb=ab1c8a67afba072b1c29f0c3c34aa9779643e66a;p=dcpomatic.git diff --git a/src/lib/job_manager.h b/src/lib/job_manager.h index a382dd736..2788fc657 100644 --- a/src/lib/job_manager.h +++ b/src/lib/job_manager.h @@ -26,11 +26,13 @@ #include #include #include +#include #include class Job; class Film; class Playlist; +struct threed_test7; extern bool wait_for_jobs (); @@ -47,6 +49,12 @@ public: bool errors () const; void increase_priority (boost::shared_ptr); void decrease_priority (boost::shared_ptr); + void pause (); + void resume (); + bool paused () const { + boost::mutex::scoped_lock lm (_mutex); + return _paused; + } void analyse_audio ( boost::shared_ptr film, @@ -66,17 +74,23 @@ public: private: /* This function is part of the test suite */ friend bool ::wait_for_jobs (); + friend struct threed_test7; JobManager (); ~JobManager (); void scheduler (); void start (); void priority_changed (); + void job_finished (); mutable boost::mutex _mutex; + boost::condition _empty_condition; /** List of jobs in the order that they will be executed */ std::list > _jobs; + std::list _connections; bool _terminate; + bool _paused; + boost::shared_ptr _paused_job; boost::optional _last_active_job; boost::thread* _scheduler;