X-Git-Url: https://git.carlh.net/gitweb/?a=blobdiff_plain;f=src%2Flib%2Fjob_manager.h;h=c623b6ef98d7f7fd5831b9644281a10946b58084;hb=1460bda6f80b6529e31a1a63029dc0ec5f7d0ae8;hp=7de7862a18bd2ff7bfc929462d184279d8c8bfb3;hpb=d2bd0c628fd0616fe3b7dd02bd955b2c07ab48d5;p=dcpomatic.git diff --git a/src/lib/job_manager.h b/src/lib/job_manager.h index 7de7862a1..c623b6ef9 100644 --- a/src/lib/job_manager.h +++ b/src/lib/job_manager.h @@ -1,19 +1,20 @@ /* Copyright (C) 2012-2015 Carl Hetherington - This program is free software; you can redistribute it and/or modify + This file is part of DCP-o-matic. + + DCP-o-matic is free software; you can redistribute it and/or modify it under the terms of the GNU General Public License as published by the Free Software Foundation; either version 2 of the License, or (at your option) any later version. - This program is distributed in the hope that it will be useful, + DCP-o-matic is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for more details. You should have received a copy of the GNU General Public License - along with this program; if not, write to the Free Software - Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA. + along with DCP-o-matic. If not, see . */ @@ -31,7 +32,7 @@ class Job; class Film; class Playlist; -extern void wait_for_jobs (); +extern bool wait_for_jobs (); /** @class JobManager * @brief A simple scheduler for jobs. @@ -39,11 +40,12 @@ extern void wait_for_jobs (); class JobManager : public Signaller, public boost::noncopyable { public: - boost::shared_ptr add (boost::shared_ptr); std::list > get () const; bool work_to_do () const; bool errors () const; + void increase_priority (boost::shared_ptr); + void decrease_priority (boost::shared_ptr); void analyse_audio ( boost::shared_ptr film, @@ -53,21 +55,24 @@ public: ); boost::signals2::signal)> JobAdded; - boost::signals2::signal)> ActiveJobsChanged; + boost::signals2::signal JobsReordered; + boost::signals2::signal, boost::optional)> ActiveJobsChanged; static JobManager* instance (); static void drop (); private: /* This function is part of the test suite */ - friend void ::wait_for_jobs (); + friend bool ::wait_for_jobs (); JobManager (); ~JobManager (); void scheduler (); void start (); + void priority_changed (); mutable boost::mutex _mutex; + /** List of jobs in the order that they will be executed */ std::list > _jobs; bool _terminate;