X-Git-Url: https://main.carlh.net/gitweb/?a=blobdiff_plain;f=src%2Flib%2Ftranscoder.cc;h=c667a1486e61ee4fd8e70337ce416ffa422c67f9;hb=58b5c57c9a4767c786a1428f243c60ff52c82c26;hp=93963761e2c3d8a7fdd74bfa4c83119b50102367;hpb=32fc1ddb0ee004d18c36155ddcf4d9b3998a7061;p=dcpomatic.git diff --git a/src/lib/transcoder.cc b/src/lib/transcoder.cc index 93963761e..c667a1486 100644 --- a/src/lib/transcoder.cc +++ b/src/lib/transcoder.cc @@ -1,19 +1,20 @@ /* - Copyright (C) 2012 Carl Hetherington + Copyright (C) 2012-2016 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 . */ @@ -24,105 +25,124 @@ * as a parameter to the constructor. */ -#include -#include #include "transcoder.h" #include "encoder.h" -#include "decoder_factory.h" #include "film.h" -#include "matcher.h" -#include "delay_line.h" -#include "options.h" -#include "gain.h" #include "video_decoder.h" #include "audio_decoder.h" +#include "player.h" +#include "job.h" +#include "writer.h" +#include "compose.hpp" +#include "referenced_reel_asset.h" +#include "subtitle_content.h" +#include "player_video.h" +#include +#include +#include + +#include "i18n.h" using std::string; using std::cout; +using std::list; using boost::shared_ptr; +using boost::weak_ptr; using boost::dynamic_pointer_cast; -/** Construct a transcoder using a Decoder that we create and a supplied Encoder. +/** Construct a transcoder. * @param f Film that we are transcoding. - * @param o Decode options. - * @param j Job that we are running under, or 0. - * @param e Encoder to use. + * @param j Job that this transcoder is being used in. */ -Transcoder::Transcoder (shared_ptr f, DecodeOptions o, Job* j, shared_ptr e) - : _job (j) - , _encoder (e) - , _decoders (decoder_factory (f, o, j)) +Transcoder::Transcoder (shared_ptr film, weak_ptr j) + : _film (film) + , _job (j) + , _player (new Player (film, film->playlist ())) + , _writer (new Writer (film, j)) + , _encoder (new Encoder (film, _writer)) + , _finishing (false) { - assert (_encoder); - - if (f->audio_stream()) { - shared_ptr st = f->audio_stream(); - _matcher.reset (new Matcher (f->log(), st->sample_rate(), f->frames_per_second())); - _delay_line.reset (new DelayLine (f->log(), st->channels(), f->audio_delay() * st->sample_rate() / 1000)); - _gain.reset (new Gain (f->log(), f->audio_gain())); - } - - /* Set up the decoder to use the film's set streams */ - _decoders.video->set_subtitle_stream (f->subtitle_stream ()); - if (_decoders.audio) { - _decoders.audio->set_audio_stream (f->audio_stream ()); - } - if (_matcher) { - _decoders.video->connect_video (_matcher); - _matcher->connect_video (_encoder); - } else { - _decoders.video->connect_video (_encoder); - } - - if (_matcher && _delay_line && _decoders.audio) { - _decoders.audio->connect_audio (_delay_line); - _delay_line->connect_audio (_matcher); - _matcher->connect_audio (_gain); - _gain->connect_audio (_encoder); - } } -/** Run the decoder, passing its output to the encoder, until the decoder - * has no more data to present. - */ void Transcoder::go () { - _encoder->process_begin (); - try { - bool done[2] = { false, false }; - - while (1) { - if (!done[0]) { - done[0] = _decoders.video->pass (); - _decoders.video->set_progress (); - } + _writer->start (); + _encoder->begin (); - if (!done[1] && _decoders.audio && dynamic_pointer_cast (_decoders.audio) != dynamic_pointer_cast (_decoders.video)) { - done[1] = _decoders.audio->pass (); - } else { - done[1] = true; - } + { + shared_ptr job = _job.lock (); + DCPOMATIC_ASSERT (job); + job->sub (_("Encoding picture and sound")); + } - if (done[0] && done[1]) { - break; + DCPTime const frame = DCPTime::from_frames (1, _film->video_frame_rate ()); + DCPTime const length = _film->length (); + + int burnt_subtitles = 0; + int non_burnt_subtitles = 0; + BOOST_FOREACH (shared_ptr c, _film->content ()) { + if (c->subtitle && c->subtitle->use()) { + if (c->subtitle->burn()) { + ++burnt_subtitles; + } else { + ++non_burnt_subtitles; } } - - } catch (...) { - _encoder->process_end (); - throw; } - - if (_delay_line) { - _delay_line->process_end (); + + if (non_burnt_subtitles) { + _writer->write (_player->get_subtitle_fonts ()); } - if (_matcher) { - _matcher->process_end (); + + for (DCPTime t; t < length; t += frame) { + + BOOST_FOREACH (shared_ptr i, _player->get_video (t, true)) { + if (!_film->three_d()) { + /* 2D DCP */ + if (i->eyes() == EYES_RIGHT) { + /* Discard right-eye images */ + continue; + } else if (i->eyes() == EYES_LEFT) { + /* Use left-eye images for both eyes */ + i->set_eyes (EYES_BOTH); + } + } + + _encoder->encode (i); + } + + _writer->write (_player->get_audio (t, frame, true)); + + if (non_burnt_subtitles) { + _writer->write (_player->get_subtitles (t, frame, true, false, true)); + } + + { + shared_ptr job = _job.lock (); + DCPOMATIC_ASSERT (job); + job->set_progress (float(t.get()) / length.get()); + } } - if (_gain) { - _gain->process_end (); + + BOOST_FOREACH (ReferencedReelAsset i, _player->get_reel_assets ()) { + _writer->write (i); } - _encoder->process_end (); + + _finishing = true; + _encoder->end (); + _writer->finish (); +} + +float +Transcoder::current_encoding_rate () const +{ + return _encoder->current_encoding_rate (); +} + +int +Transcoder::video_frames_enqueued () const +{ + return _encoder->video_frames_enqueued (); }