X-Git-Url: https://main.carlh.net/gitweb/?a=blobdiff_plain;f=src%2Flib%2Ftranscode_job.cc;h=fd4dfcef6dfc10c89b699777514377b1b47820b2;hb=2e504b33eb9f38cac629ad31b7c107fb0cf5efda;hp=e9a59c743ad3fc81e12abceb3c320f11a4db485d;hpb=0b760c0526b0b9d13def519ab8afba1e511d8111;p=dcpomatic.git diff --git a/src/lib/transcode_job.cc b/src/lib/transcode_job.cc index e9a59c743..fd4dfcef6 100644 --- a/src/lib/transcode_job.cc +++ b/src/lib/transcode_job.cc @@ -25,10 +25,10 @@ #include #include "transcode_job.h" #include "film.h" -#include "format.h" #include "transcoder.h" #include "log.h" -#include "encoder.h" + +#include "i18n.h" using std::string; using std::stringstream; @@ -37,12 +37,9 @@ using std::setprecision; using boost::shared_ptr; /** @param s Film to use. - * @param o Decode options. - * @param req Job that must be completed before this job is run. */ -TranscodeJob::TranscodeJob (shared_ptr f, DecodeOptions o, shared_ptr req) - : Job (f, req) - , _decode_opt (o) +TranscodeJob::TranscodeJob (shared_ptr f) + : Job (f) { } @@ -50,7 +47,13 @@ TranscodeJob::TranscodeJob (shared_ptr f, DecodeOptions o, shared_ptr string TranscodeJob::name () const { - return String::compose ("Transcode %1", _film->name()); + return String::compose (_("Transcode %1"), _film->name()); +} + +string +TranscodeJob::json_name () const +{ + return N_("transcode"); } void @@ -58,26 +61,21 @@ TranscodeJob::run () { try { - _film->log()->log ("Transcode job starting"); - _film->log()->log (String::compose ("Audio delay is %1ms", _film->audio_delay())); + _film->log()->log (N_("Transcode job starting")); - _encoder.reset (new Encoder (_film)); - Transcoder w (_film, _decode_opt, this, _encoder); - w.go (); + _transcoder.reset (new Transcoder (_film, shared_from_this ())); + _transcoder->go (); set_progress (1); set_state (FINISHED_OK); - _film->set_dcp_intrinsic_duration (_encoder->video_frames_out ()); - - _film->log()->log ("Transcode job completed successfully"); - _film->log()->log (String::compose ("DCP intrinsic duration is %1", _encoder->video_frames_out())); - - } catch (std::exception& e) { + _film->log()->log (N_("Transcode job completed successfully")); + _transcoder.reset (); + } catch (...) { set_progress (1); set_state (FINISHED_ERROR); - _film->log()->log (String::compose ("Transcode job failed (%1)", e.what())); - + _film->log()->log (N_("Transcode job failed or cancelled")); + _transcoder.reset (); throw; } } @@ -85,11 +83,11 @@ TranscodeJob::run () string TranscodeJob::status () const { - if (!_encoder) { - return "0%"; + if (!_transcoder) { + return Job::status (); } - float const fps = _encoder->current_frames_per_second (); + float const fps = _transcoder->current_encoding_rate (); if (fps == 0) { return Job::status (); } @@ -98,34 +96,30 @@ TranscodeJob::status () const s << Job::status (); - if (!finished ()) { - s << "; " << fixed << setprecision (1) << fps << " frames per second"; + if (!finished () && !_transcoder->finishing ()) { + s << "; " << fixed << setprecision (1) << fps << " " << _("frames per second"); } return s.str (); } +/** @return Approximate remaining time in seconds */ int TranscodeJob::remaining_time () const { - float fps = _encoder->current_frames_per_second (); - if (fps == 0) { + /* _transcoder might be destroyed by the job-runner thread */ + shared_ptr t = _transcoder; + + if (!t) { return 0; } + + float fps = t->current_encoding_rate (); - if (!_film->length()) { + if (fps == 0) { return 0; } /* Compute approximate proposed length here, as it's only here that we need it */ - int length = _film->length().get(); - DCPFrameRate const dfr (_film->frames_per_second ()); - if (dfr.skip) { - length /= 2; - } - /* If we are repeating it shouldn't affect transcode time, so don't take it into account */ - - /* We assume that dcp_length() is valid, if it is set */ - int const left = length - _encoder->video_frames_out(); - return left / fps; + return (_film->length().frames (_film->video_frame_rate ()) - t->video_frames_out()) / fps; }