2 Copyright (C) 2012-2020 Carl Hetherington <cth@carlh.net>
4 This file is part of DCP-o-matic.
6 DCP-o-matic is free software; you can redistribute it and/or modify
7 it under the terms of the GNU General Public License as published by
8 the Free Software Foundation; either version 2 of the License, or
9 (at your option) any later version.
11 DCP-o-matic is distributed in the hope that it will be useful,
12 but WITHOUT ANY WARRANTY; without even the implied warranty of
13 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
14 GNU General Public License for more details.
16 You should have received a copy of the GNU General Public License
17 along with DCP-o-matic. If not, see <http://www.gnu.org/licenses/>.
22 /** @file src/dcp_film_encoder.cc
23 * @brief A class which takes a Film and some Options, then uses those to encode the film into a DCP.
25 * A decoder is selected according to the content type, and the encoder can be specified
26 * as a parameter to the constructor.
30 #include "audio_decoder.h"
31 #include "compose.hpp"
32 #include "dcp_film_encoder.h"
34 #include "j2k_encoder.h"
37 #include "player_video.h"
38 #include "referenced_reel_asset.h"
39 #include "text_content.h"
40 #include "video_decoder.h"
42 #include <boost/signals2.hpp>
49 using std::dynamic_pointer_cast;
51 using std::make_shared;
52 using std::shared_ptr;
56 using boost::optional;
57 #if BOOST_VERSION >= 106100
58 using namespace boost::placeholders;
60 using namespace dcpomatic;
63 /** Construct a DCP encoder.
64 * @param film Film that we are encoding.
65 * @param job Job that this encoder is being used in.
67 DCPFilmEncoder::DCPFilmEncoder(shared_ptr<const Film> film, weak_ptr<Job> job)
68 : FilmEncoder(film, job)
70 , _encoder(new J2KEncoder(film, _writer))
72 , _non_burnt_subtitles (false)
74 _player_video_connection = _player.Video.connect(bind(&DCPFilmEncoder::video, this, _1, _2));
75 _player_audio_connection = _player.Audio.connect(bind(&DCPFilmEncoder::audio, this, _1, _2));
76 _player_text_connection = _player.Text.connect(bind(&DCPFilmEncoder::text, this, _1, _2, _3, _4));
77 _player_atmos_connection = _player.Atmos.connect(bind(&DCPFilmEncoder::atmos, this, _1, _2, _3));
79 for (auto c: film->content ()) {
80 for (auto i: c->text) {
81 if (i->use() && !i->burn()) {
82 _non_burnt_subtitles = true;
88 DCPFilmEncoder::~DCPFilmEncoder()
90 /* We must stop receiving more video data before we die */
91 _player_video_connection.release ();
92 _player_audio_connection.release ();
93 _player_text_connection.release ();
94 _player_atmos_connection.release ();
104 auto job = _job.lock ();
105 DCPOMATIC_ASSERT (job);
106 job->sub (_("Encoding"));
109 if (_non_burnt_subtitles) {
110 _writer.write(_player.get_subtitle_fonts());
113 while (!_player.pass()) {}
115 for (auto i: get_referenced_reel_assets(_film, _film->playlist())) {
121 _writer.finish(_film->dir(_film->dcp_name()));
126 DCPFilmEncoder::pause()
133 DCPFilmEncoder::resume()
139 DCPFilmEncoder::video(shared_ptr<PlayerVideo> data, DCPTime time)
141 _encoder->encode(data, time);
145 DCPFilmEncoder::audio(shared_ptr<AudioBuffers> data, DCPTime time)
147 _writer.write(data, time);
149 auto job = _job.lock ();
150 DCPOMATIC_ASSERT (job);
151 job->set_progress (float(time.get()) / _film->length().get());
155 DCPFilmEncoder::text(PlayerText data, TextType type, optional<DCPTextTrack> track, DCPTimePeriod period)
157 if (type == TextType::CLOSED_CAPTION || _non_burnt_subtitles) {
158 _writer.write(data, type, track, period);
164 DCPFilmEncoder::atmos(shared_ptr<const dcp::AtmosFrame> data, DCPTime time, AtmosMetadata metadata)
166 _writer.write(data, time, metadata);
171 DCPFilmEncoder::current_rate() const
173 return _encoder->current_encoding_rate();
177 DCPFilmEncoder::frames_done() const
179 return _encoder->video_frames_enqueued();