X-Git-Url: https://git.carlh.net/gitweb/?a=blobdiff_plain;f=src%2Flib%2Ftranscode_job.cc;h=6b1563b9b85da2b30a37f4a09e3b2cbd47a255b6;hb=dba7e1137282b52a1bd6ad1d56fe6371a8c97e30;hp=a879e8c77d6331b67e6bcd0285a7bc4de1e4daeb;hpb=7feda7e97b67917d240585a09ed6c50d4605a83d;p=dcpomatic.git diff --git a/src/lib/transcode_job.cc b/src/lib/transcode_job.cc index a879e8c77..6b1563b9b 100644 --- a/src/lib/transcode_job.cc +++ b/src/lib/transcode_job.cc @@ -1,147 +1,204 @@ /* - Copyright (C) 2012-2015 Carl Hetherington + Copyright (C) 2012-2021 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 . */ + /** @file src/transcode_job.cc * @brief A job which transcodes from one format to another. */ -#include "transcode_job.h" -#include "upload_job.h" -#include "job_manager.h" + +#include "analytics.h" +#include "compose.hpp" +#include "content.h" +#include "config.h" +#include "dcp_encoder.h" +#include "dcpomatic_log.h" +#include "encoder.h" +#include "examine_content_job.h" #include "film.h" -#include "transcoder.h" +#include "job_manager.h" #include "log.h" -#include "safe_stringstream.h" -#include "compose.hpp" -#include +#include "transcode_job.h" +#include "upload_job.h" #include +#include #include "i18n.h" -#define LOG_GENERAL(...) _film->log()->log (String::compose (__VA_ARGS__), LogEntry::TYPE_GENERAL); -#define LOG_GENERAL_NC(...) _film->log()->log (__VA_ARGS__, LogEntry::TYPE_GENERAL); -#define LOG_ERROR_NC(...) _film->log()->log (__VA_ARGS__, LogEntry::TYPE_ERROR); -using std::string; +using std::cout; using std::fixed; +using std::make_shared; using std::setprecision; -using std::cout; -using boost::shared_ptr; +using std::shared_ptr; +using std::string; +using boost::optional; +using std::dynamic_pointer_cast; -/** @param s Film to use. - */ -TranscodeJob::TranscodeJob (shared_ptr film) + +/** @param film Film to use */ +TranscodeJob::TranscodeJob (shared_ptr film, ChangedBehaviour changed) : Job (film) + , _changed (changed) { } + +TranscodeJob::~TranscodeJob () +{ + stop_thread (); +} + + string TranscodeJob::name () const { - return String::compose (_("Transcode %1"), _film->name()); + return String::compose (_("Transcoding %1"), _film->name()); } + string TranscodeJob::json_name () const { return N_("transcode"); } + +void +TranscodeJob::set_encoder (shared_ptr e) +{ + _encoder = e; +} + + void TranscodeJob::run () { try { + auto content = _film->content(); + std::vector> changed; + std::copy_if (content.begin(), content.end(), std::back_inserter(changed), [](shared_ptr c) { return c->changed(); }); + + if (!changed.empty()) { + switch (_changed) { + case ChangedBehaviour::EXAMINE_THEN_STOP: + for (auto i: changed) { + JobManager::instance()->add(make_shared(_film, i)); + } + set_progress (1); + set_message (_("Some files have been changed since they were added to the project.\n\nThese files will now be re-examined, so you may need to check their settings before trying again.")); + set_error (_("Files have changed since they were added to the project."), _("Check their new settings, then try again.")); + set_state (FINISHED_ERROR); + return; + case ChangedBehaviour::STOP: + set_progress (1); + set_error (_("Files have changed since they were added to the project."), _("Open the project in DCP-o-matic, check the settings, then save it before trying again.")); + set_state (FINISHED_ERROR); + return; + default: + LOG_GENERAL_NC (_("Some files have been changed since they were added to the project.")); + break; + } + } + struct timeval start; gettimeofday (&start, 0); LOG_GENERAL_NC (N_("Transcode job starting")); - _transcoder.reset (new Transcoder (_film, shared_from_this ())); - _transcoder->go (); - set_progress (1); - set_state (FINISHED_OK); + DCPOMATIC_ASSERT (_encoder); + _encoder->go (); struct timeval finish; gettimeofday (&finish, 0); float fps = 0; if (finish.tv_sec != start.tv_sec) { - fps = _transcoder->video_frames_out() / (finish.tv_sec - start.tv_sec); + fps = _encoder->frames_done() / (finish.tv_sec - start.tv_sec); } - LOG_GENERAL (N_("Transcode job completed successfully: %1 fps"), fps); - _transcoder.reset (); + LOG_GENERAL (N_("Transcode job completed successfully: %1 fps"), dcp::locale_convert(fps, 2, true)); - if (_film->upload_after_make_dcp ()) { - shared_ptr job (new UploadJob (_film)); - JobManager::instance()->add (job); + if (dynamic_pointer_cast(_encoder)) { + try { + Analytics::instance()->successful_dcp_encode(); + } catch (FileError& e) { + LOG_WARNING (N_("Failed to write analytics (%1)"), e.what()); + } } + post_transcode (); + + _encoder.reset (); + + set_progress (1); + set_state (FINISHED_OK); + } catch (...) { - _transcoder.reset (); + _encoder.reset (); throw; } } + string TranscodeJob::status () const { - if (!_transcoder) { + if (!_encoder) { return Job::status (); } - float const fps = _transcoder->current_encoding_rate (); - if (fps == 0) { - return Job::status (); + if (finished() || _encoder->finishing()) { + return Job::status(); } - SafeStringStream s; - - s << Job::status (); - - if (!finished () && !_transcoder->finishing ()) { + auto status = String::compose(_("%1; %2/%3 frames"), Job::status(), _encoder->frames_done(), _film->length().frames_round(_film->video_frame_rate())); + if (auto const fps = _encoder->current_rate()) { /// TRANSLATORS: fps here is an abbreviation for frames per second - s << "; " << _transcoder->video_frames_out() << "/" - << _film->length().frames_round (_film->video_frame_rate ()) << " " << _("frames") << "; " - << fixed << setprecision (1) << fps << " " << _("fps"); + status += String::compose(_("; %1 fps"), dcp::locale_convert(*fps, 1, true)); } - return s.str (); + return status; } + /** @return Approximate remaining time in seconds */ int TranscodeJob::remaining_time () const { - /* _transcoder might be destroyed by the job-runner thread */ - shared_ptr t = _transcoder; + /* _encoder might be destroyed by the job-runner thread */ + auto e = _encoder; - if (!t) { - return 0; + if (!e || e->finishing()) { + /* We aren't doing any actual encoding so just use the job's guess */ + return Job::remaining_time (); } - float fps = t->current_encoding_rate (); + /* We're encoding so guess based on the current encoding rate */ + + auto fps = e->current_rate (); - if (fps == 0) { + if (!fps) { return 0; } /* Compute approximate proposed length here, as it's only here that we need it */ - return (_film->length().frames_round (_film->video_frame_rate ()) - t->video_frames_out()) / fps; + return (_film->length().frames_round(_film->video_frame_rate()) - e->frames_done()) / *fps; }