X-Git-Url: https://git.carlh.net/gitweb/?a=blobdiff_plain;ds=sidebyside;f=src%2Flib%2Fjob.cc;h=3309fe16c64393b6a961841677512f8db02254f6;hb=febb57f618c0f932fca1f9f6400145b5ce1785d1;hp=39ce4173a78a8af19621e5f4f31f95a946ea170c;hpb=5d48e36440d6b4ebf4c04a413bd340b214ba8c42;p=dcpomatic.git

diff --git a/src/lib/job.cc b/src/lib/job.cc
index 39ce4173a..3309fe16c 100644
--- a/src/lib/job.cc
+++ b/src/lib/job.cc
@@ -27,24 +27,21 @@
 #include "job.h"
 #include "util.h"
 
-using namespace std;
-using namespace boost;
+using std::string;
+using std::list;
+using std::stringstream;
+using boost::shared_ptr;
 
-/** @param s FilmState for the film that we are operating on.
- *  @param o Options.
- *  @param l A log that we can write to.
+/** @param s Film that we are operating on.
  */
-Job::Job (shared_ptr<const FilmState> s, shared_ptr<const Options> o, Log* l)
-	: _fs (s)
-	, _opt (o)
-	, _log (l)
+Job::Job (shared_ptr<Film> f, shared_ptr<Job> req)
+	: _film (f)
+	, _required (req)
 	, _state (NEW)
 	, _start_time (0)
 	, _progress_unknown (false)
 	, _ran_for (0)
 {
-	assert (_log);
-	
 	descend (1);
 }
 
@@ -69,7 +66,7 @@ Job::run_wrapper ()
 		
 		set_progress (1);
 		set_state (FINISHED_ERROR);
-		set_error (String::compose ("%1 (%2)", e.what(), filesystem::path (e.filename()).leaf()));
+		set_error (String::compose ("%1 (%2)", e.what(), boost::filesystem::path (e.filename()).leaf()));
 		
 	} catch (std::exception& e) {
 
@@ -80,6 +77,13 @@ Job::run_wrapper ()
 	}
 }
 
+bool
+Job::is_new () const
+{
+	boost::mutex::scoped_lock lm (_state_mutex);
+	return _state == NEW;
+}
+
 /** @return true if the job is running */
 bool
 Job::running () const
@@ -123,20 +127,10 @@ Job::set_state (State s)
 
 	if (_state == FINISHED_OK || _state == FINISHED_ERROR) {
 		_ran_for = elapsed_time ();
+		Finished ();
 	}
 }
 
-/** A hack to work around our lack of cross-thread
- *  signalling; this emits Finished, and listeners
- *  assume that it will be emitted in the GUI thread,
- *  so this method must be called from the GUI thread.
- */
-void
-Job::emit_finished ()
-{
-	Finished ();
-}
-
 /** @return Time (in seconds) that this job has been running */
 int
 Job::elapsed_time () const
@@ -155,6 +149,7 @@ void
 Job::set_progress (float p)
 {
 	boost::mutex::scoped_lock lm (_progress_mutex);
+	_progress_unknown = false;
 	_stack.back().normalised = p;
 }
 
@@ -226,7 +221,7 @@ Job::set_error (string e)
 	_error = e;
 }
 
-/** Say that this job's progress will always be unknown */
+/** Say that this job's progress will be unknown until further notice */
 void
 Job::set_progress_unknown ()
 {
@@ -241,7 +236,7 @@ Job::status () const
 	float const p = overall_progress ();
 	int const t = elapsed_time ();
 	int const r = remaining_time ();
-	
+
 	stringstream s;
 	if (!finished () && p >= 0 && t > 10 && r > 0) {
 		s << rint (p * 100) << "%; " << seconds_to_approximate_hms (r) << " remaining";