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/>.
21 /** @file src/dcp_encoder.cc
22 * @brief A class which takes a Film and some Options, then uses those to encode the film into a DCP.
24 * A decoder is selected according to the content type, and the encoder can be specified
25 * as a parameter to the constructor.
28 #include "dcp_encoder.h"
29 #include "j2k_encoder.h"
31 #include "video_decoder.h"
32 #include "audio_decoder.h"
36 #include "compose.hpp"
37 #include "referenced_reel_asset.h"
38 #include "text_content.h"
39 #include "player_video.h"
40 #include <boost/signals2.hpp>
49 using std::shared_ptr;
51 using std::dynamic_pointer_cast;
52 using std::make_shared;
53 using boost::optional;
54 #if BOOST_VERSION >= 106100
55 using namespace boost::placeholders;
57 using namespace dcpomatic;
60 /** Construct a DCP encoder.
61 * @param film Film that we are encoding.
62 * @param job Job that this encoder is being used in.
64 DCPEncoder::DCPEncoder (shared_ptr<const Film> film, weak_ptr<Job> job)
67 , _j2k_encoder(film, _writer)
69 , _non_burnt_subtitles (false)
71 _player_video_connection = _player.Video.connect(bind(&DCPEncoder::video, this, _1, _2));
72 _player_audio_connection = _player.Audio.connect(bind(&DCPEncoder::audio, this, _1, _2));
73 _player_text_connection = _player.Text.connect(bind(&DCPEncoder::text, this, _1, _2, _3, _4));
74 _player_atmos_connection = _player.Atmos.connect(bind(&DCPEncoder::atmos, this, _1, _2, _3));
76 for (auto c: film->content ()) {
77 for (auto i: c->text) {
78 if (i->use() && !i->burn()) {
79 _non_burnt_subtitles = true;
85 DCPEncoder::~DCPEncoder ()
87 /* We must stop receiving more video data before we die */
88 _player_video_connection.release ();
89 _player_audio_connection.release ();
90 _player_text_connection.release ();
91 _player_atmos_connection.release ();
101 auto job = _job.lock ();
102 DCPOMATIC_ASSERT (job);
103 job->sub (_("Encoding"));
106 if (_non_burnt_subtitles) {
107 _writer.write(_player.get_subtitle_fonts());
110 while (!_player.pass()) {}
112 for (auto i: get_referenced_reel_assets(_film, _film->playlist())) {
118 _writer.finish(_film->dir(_film->dcp_name()));
122 DCPEncoder::video (shared_ptr<PlayerVideo> data, DCPTime time)
124 _j2k_encoder.encode(data, time);
128 DCPEncoder::audio (shared_ptr<AudioBuffers> data, DCPTime time)
130 _writer.write(data, time);
132 auto job = _job.lock ();
133 DCPOMATIC_ASSERT (job);
134 job->set_progress (float(time.get()) / _film->length().get());
138 DCPEncoder::text (PlayerText data, TextType type, optional<DCPTextTrack> track, DCPTimePeriod period)
140 if (type == TextType::CLOSED_CAPTION || _non_burnt_subtitles) {
141 _writer.write(data, type, track, period);
147 DCPEncoder::atmos (shared_ptr<const dcp::AtmosFrame> data, DCPTime time, AtmosMetadata metadata)
149 _writer.write(data, time, metadata);
154 DCPEncoder::current_rate () const
156 return _j2k_encoder.current_encoding_rate();
160 DCPEncoder::frames_done () const
162 return _j2k_encoder.video_frames_enqueued();