PRIVATE_GIT="881c48805e352dfe150993814757ca974282be18"
- if [ "$1" == "--check" ]; then
- shift 1
- check=1
- else
- check=0
- fi
+DIR="$( cd "$( dirname "${BASH_SOURCE[0]}" )" >/dev/null 2>&1 && pwd )"
+source $DIR/environment
+
+ type=""
+ check=0
+ while [[ $# -gt 0 ]]; do
+ case $1 in
+ -e)
+ environment=$2
+ shift
+ shift
+ ;;
+ --debug)
+ type="debug"
+ shift
+ ;;
+ --backtrace)
+ type="backtrace"
+ shift
+ ;;
+ --valgrind)
+ type="valgrind"
+ shift
+ ;;
+ --callgrind)
+ type="callgrind"
+ shift
+ ;;
+ --quiet)
+ type="quiet"
+ shift
+ ;;
+ --drd)
+ type="drd"
+ shift
+ ;;
+ --helgrind)
+ type="helgrind"
+ shift
+ ;;
+ --check)
+ check=1
+ shift
+ ;;
+ *)
+ break
+ ;;
+ esac
+ done
if [ "$(uname)" == "Linux" ]; then
- export LD_LIBRARY_PATH=build/src/lib:/usr/local/lib:/usr/local/lib64:$LD_LIBRARY_PATH
- rm -f build/test/dcpomatic2_openssl
- # This must be our patched openssl or tests will fail
- if [ ! -f build/test/dcpomatic2_openssl ]; then
- ln -s ../../../openssl/apps/openssl build/test/dcpomatic2_openssl
- fi
- export DCPOMATIC_TEST_TOOLS_PATH=/opt/asdcplib/bin
- if [ -f /src/backports/dcp_inspect ]; then
- export DCPOMATIC_DCP_INSPECT=/src/backports/dcp_inspect
- fi
- set +e
- python3 -m clairmeta.cli --help > /dev/null 2>&1
- if [ "$?" == "0" ]; then
- export DCPOMATIC_CLAIRMETA=1
- fi
- set -e
+ rm -f build/test/dcpomatic2_openssl
+ mkdir -p build/test
+ # This must be our patched openssl or tests will fail
+ if [ ! -f build/test/dcpomatic2_openssl ]; then
+ ln -s ../../../openssl/apps/openssl build/test/dcpomatic2_openssl
+ fi
+ export DCPOMATIC_TEST_TOOLS_PATH=/opt/asdcplib/bin
+ if [ -f /src/backports/dcp_inspect ]; then
+ export DCPOMATIC_DCP_INSPECT=/src/backports/dcp_inspect
+ fi
+ set +e
+ python3 -m clairmeta.cli --help > /dev/null 2>&1
+ if [ "$?" == "0" ]; then
+ export DCPOMATIC_CLAIRMETA=1
+ fi
+ set -e
fi
if [ "$(uname)" == "Darwin" ]; then
fi
if [ "$check" == "1" ]; then
- if [ "$DCPOMATIC_TEST_PRIVATE" == "" ]; then
- pushd ../dcpomatic-test-private
- else
- pushd $DCPOMATIC_TEST_PRIVATE
- fi
- current=$(git rev-parse HEAD)
- if [ "$current" != "$PRIVATE_GIT" ]; then
- echo "Unexpected dcpomatic-test-private version"
- exit 1
- fi
- popd
+ if [ "$DCPOMATIC_TEST_PRIVATE" == "" ]; then
+ pushd ../dcpomatic-test-private
+ else
+ pushd $DCPOMATIC_TEST_PRIVATE
+ fi
+ current=$(git rev-parse HEAD)
+ if [ "$current" != "$PRIVATE_GIT" ]; then
+ echo "Unexpected dcpomatic-test-private version"
+ exit 1
+ fi
+ popd
fi
- if [ "$1" == "--debug" ]; then
- shift;
+ if [ "$type" == "debug" ]; then
gdb --args build/test/unit-tests --catch_system_errors=no --log_level=test_suite $*
- elif [ "$1" == "--backtrace" ]; then
- shift;
+ elif [ "$type" == "backtrace" ]; then
gdb -batch -ex "run" -ex "thread apply all bt" -return-child-result --args build/test/unit-tests --catch_system_errors=yes $*
- elif [ "$1" == "--valgrind" ]; then
- shift;
+ elif [ "$type" == "valgrind" ]; then
# valgrind --tool="memcheck" --vgdb=yes --vgdb-error=0 build/test/unit-tests $*
valgrind --tool="memcheck" --suppressions=suppressions build/test/unit-tests $*
- elif [ "$1" == "--callgrind" ]; then
- shift;
+ elif [ "$type" == "callgrind" ]; then
valgrind --tool="callgrind" build/test/unit-tests $*
- elif [ "$1" == "--quiet" ]; then
- shift;
+ elif [ "$type" == "quiet" ]; then
build/test/unit-tests --catch_system_errors=no $*
- elif [ "$1" == "--drd" ]; then
- shift;
+ elif [ "$type" == "drd" ]; then
valgrind --tool="drd" build/test/unit-tests $*
- elif [ "$1" == "--helgrind" ]; then
- shift;
+ elif [ "$type" == "helgrind" ]; then
valgrind --tool="helgrind" build/test/unit-tests $*
else
ulimit -c unlimited
--- /dev/null
- while (!_player.pass()) {}
+/*
+ Copyright (C) 2012-2020 Carl Hetherington <cth@carlh.net>
+
+ 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.
+
+ 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 DCP-o-matic. If not, see <http://www.gnu.org/licenses/>.
+
+*/
+
+
+/** @file src/dcp_film_encoder.cc
+ * @brief A class which takes a Film and some Options, then uses those to encode the film into a DCP.
+ *
+ * A decoder is selected according to the content type, and the encoder can be specified
+ * as a parameter to the constructor.
+ */
+
+
+#include "audio_decoder.h"
+#include "compose.hpp"
+#include "dcp_film_encoder.h"
+#include "film.h"
+#include "j2k_encoder.h"
+#include "job.h"
+#include "mpeg2_encoder.h"
+#include "player.h"
+#include "player_video.h"
+#include "referenced_reel_asset.h"
+#include "text_content.h"
+#include "video_decoder.h"
+#include "writer.h"
+#include <boost/signals2.hpp>
+#include <iostream>
+
+#include "i18n.h"
+
+
+using std::cout;
+using std::dynamic_pointer_cast;
+using std::list;
+using std::make_shared;
+using std::shared_ptr;
+using std::string;
+using std::vector;
+using std::weak_ptr;
+using boost::optional;
+#if BOOST_VERSION >= 106100
+using namespace boost::placeholders;
+#endif
+using namespace dcpomatic;
+
+
+/** Construct a DCP encoder.
+ * @param film Film that we are encoding.
+ * @param job Job that this encoder is being used in.
+ */
+DCPFilmEncoder::DCPFilmEncoder(shared_ptr<const Film> film, weak_ptr<Job> job)
+ : FilmEncoder(film, job)
+ , _writer(film, job, film->dir(film->dcp_name()))
+ , _finishing (false)
+ , _non_burnt_subtitles (false)
+{
+ switch (_film->video_encoding()) {
+ case VideoEncoding::JPEG2000:
+ _encoder.reset(new J2KEncoder(film, _writer));
+ break;
+ case VideoEncoding::MPEG2:
+ _encoder.reset(new MPEG2Encoder(film, _writer));
+ break;
+ case VideoEncoding::COUNT:
+ DCPOMATIC_ASSERT(false);
+ }
+
+ /* Now that we have a Writer we can clear out the assets directory */
+ clean_up_asset_directory(film->assets_path());
+
+ _player_video_connection = _player.Video.connect(bind(&DCPFilmEncoder::video, this, _1, _2));
+ _player_audio_connection = _player.Audio.connect(bind(&DCPFilmEncoder::audio, this, _1, _2));
+ _player_text_connection = _player.Text.connect(bind(&DCPFilmEncoder::text, this, _1, _2, _3, _4));
+ _player_atmos_connection = _player.Atmos.connect(bind(&DCPFilmEncoder::atmos, this, _1, _2, _3));
+
+ for (auto c: film->content ()) {
+ for (auto i: c->text) {
+ if (i->use() && !i->burn()) {
+ _non_burnt_subtitles = true;
+ }
+ }
+ }
+}
+
+DCPFilmEncoder::~DCPFilmEncoder()
+{
+ /* We must stop receiving more video data before we die */
+ _player_video_connection.release ();
+ _player_audio_connection.release ();
+ _player_text_connection.release ();
+ _player_atmos_connection.release ();
+}
+
+void
+DCPFilmEncoder::go()
+{
+ _writer.start();
+ _encoder->begin();
+
+ {
+ auto job = _job.lock ();
+ DCPOMATIC_ASSERT (job);
+ job->sub (_("Encoding"));
+ }
+
+ if (_non_burnt_subtitles) {
+ _writer.write(_player.get_subtitle_fonts());
+ }
+
-
- auto job = _job.lock ();
- DCPOMATIC_ASSERT (job);
- job->set_progress (float(time.get()) / _film->length().get());
++ int passes = 0;
++ while (!_player.pass()) {
++ if ((++passes % 8) == 0) {
++ auto job = _job.lock();
++ DCPOMATIC_ASSERT(job);
++ job->set_progress(_player.progress());
++ }
++ }
+
+ for (auto i: get_referenced_reel_assets(_film, _film->playlist())) {
+ _writer.write(i);
+ }
+
+ _finishing = true;
+ _encoder->end();
+ _writer.finish();
+}
+
+
+void
+DCPFilmEncoder::pause()
+{
+ _encoder->pause();
+}
+
+
+void
+DCPFilmEncoder::resume()
+{
+ _encoder->resume();
+}
+
+void
+DCPFilmEncoder::video(shared_ptr<PlayerVideo> data, DCPTime time)
+{
+ _encoder->encode(data, time);
+}
+
+void
+DCPFilmEncoder::audio(shared_ptr<AudioBuffers> data, DCPTime time)
+{
+ _writer.write(data, time);
- return _encoder->video_frames_enqueued();
+}
+
+void
+DCPFilmEncoder::text(PlayerText data, TextType type, optional<DCPTextTrack> track, DCPTimePeriod period)
+{
+ if (type == TextType::CLOSED_CAPTION || _non_burnt_subtitles) {
+ _writer.write(data, type, track, period);
+ }
+}
+
+
+void
+DCPFilmEncoder::atmos(shared_ptr<const dcp::AtmosFrame> data, DCPTime time, AtmosMetadata metadata)
+{
+ _writer.write(data, time, metadata);
+}
+
+
+optional<float>
+DCPFilmEncoder::current_rate() const
+{
+ return _encoder->current_encoding_rate();
+}
+
+Frame
+DCPFilmEncoder::frames_done() const
+{
++ return _player.frames_done();
+}
projects / dcpomatic.git / commitdiff