X-Git-Url: https://main.carlh.net/gitweb/?a=blobdiff_plain;f=src%2Flib%2Fbutler.cc;h=5a8e646aa4635556fca90f8791f23e46b6468a9e;hb=c269ebfdae53a2f5c5e9acc6f6588ebb47eeac9d;hp=270abd2d6348dc32f6d7009cfde5683c3f4b8c91;hpb=be2e6e017d853069f02a83f5fe67423235c3096c;p=dcpomatic.git diff --git a/src/lib/butler.cc b/src/lib/butler.cc index 270abd2d6..5a8e646aa 100644 --- a/src/lib/butler.cc +++ b/src/lib/butler.cc @@ -1,5 +1,5 @@ /* - Copyright (C) 2016-2020 Carl Hetherington + Copyright (C) 2016-2021 Carl Hetherington This file is part of DCP-o-matic. @@ -18,6 +18,7 @@ */ + #include "butler.h" #include "player.h" #include "util.h" @@ -27,23 +28,23 @@ #include "compose.hpp" #include "exceptions.h" #include "video_content.h" -#include -#include + using std::cout; using std::pair; using std::make_pair; using std::string; -using boost::weak_ptr; -using boost::shared_ptr; +using std::weak_ptr; +using std::shared_ptr; using boost::bind; using boost::optional; -using boost::function; +using std::function; using namespace dcpomatic; #if BOOST_VERSION >= 106100 using namespace boost::placeholders; #endif + /** Minimum video readahead in frames */ #define MINIMUM_VIDEO_READAHEAD 10 /** Maximum video readahead in frames; should never be exceeded (by much) unless there are bugs in Player */ @@ -53,6 +54,7 @@ using namespace boost::placeholders; /** Maximum audio readahead in frames; should never be exceeded (by much) unless there are bugs in Player */ #define MAXIMUM_AUDIO_READAHEAD (48000 * MAXIMUM_VIDEO_READAHEAD / 24) + /** @param pixel_format Pixel format functor that will be used when calling ::image on PlayerVideos coming out of this * butler. This will be used (where possible) to prepare the PlayerVideos so that calling image() on them is quick. * @param aligned Same as above for the `aligned' flag. @@ -70,7 +72,7 @@ Butler::Butler ( ) : _film (film) , _player (player) - , _prepare_work (new boost::asio::io_service::work (_prepare_service)) + , _prepare_work (new boost::asio::io_service::work(_prepare_service)) , _pending_seek_accurate (false) , _suspended (0) , _finished (false) @@ -107,6 +109,7 @@ Butler::Butler ( } } + Butler::~Butler () { boost::this_thread::disable_interruption dis; @@ -176,10 +179,13 @@ Butler::should_run () const return (_video.size() < MAXIMUM_VIDEO_READAHEAD) && (_audio.size() < MAXIMUM_AUDIO_READAHEAD); } + void Butler::thread () try { + start_of_thread ("Butler"); + while (true) { boost::mutex::scoped_lock lm (_mutex); @@ -229,6 +235,7 @@ try _arrived.notify_all (); } + /** @param blocking true if we should block until video is available. If blocking is false * and no video is immediately available the method will return a 0 PlayerVideo and the error AGAIN. * @param e if non-0 this is filled with an error code (if an error occurs) or is untouched if no error occurs. @@ -238,10 +245,21 @@ Butler::get_video (bool blocking, Error* e) { boost::mutex::scoped_lock lm (_mutex); - if (_suspended || (_video.empty() && !blocking)) { + auto setup_error = [this](Error* e, Error::Code fallback) { if (e) { - e->code = Error::AGAIN; + if (_died) { + e->code = Error::DIED; + e->message = _died_message; + } else if (_finished) { + e->code = Error::FINISHED; + } else { + e->code = fallback; + } } + }; + + if (_video.empty() && (_finished || _died || (_suspended && !blocking))) { + setup_error (e, Error::AGAIN); return make_pair(shared_ptr(), DCPTime()); } @@ -251,24 +269,16 @@ Butler::get_video (bool blocking, Error* e) } if (_video.empty()) { - if (e) { - if (_died) { - e->code = Error::DIED; - e->message = _died_message; - } else if (_finished) { - e->code = Error::FINISHED; - } else { - e->code = Error::NONE; - } - } + setup_error (e, Error::NONE); return make_pair(shared_ptr(), DCPTime()); } - pair, DCPTime> const r = _video.get (); + auto const r = _video.get (); _summon.notify_all (); return r; } + optional Butler::get_closed_caption () { @@ -276,6 +286,7 @@ Butler::get_closed_caption () return _closed_caption.get (); } + void Butler::seek (DCPTime position, bool accurate) { @@ -284,6 +295,7 @@ Butler::seek (DCPTime position, bool accurate) seek_unlocked (position, accurate); } + void Butler::seek_unlocked (DCPTime position, bool accurate) { @@ -302,11 +314,12 @@ Butler::seek_unlocked (DCPTime position, bool accurate) _summon.notify_all (); } + void Butler::prepare (weak_ptr weak_video) try { - shared_ptr video = weak_video.lock (); + auto video = weak_video.lock (); /* If the weak_ptr cannot be locked the video obviously no longer requires any work */ if (video) { LOG_TIMING("start-prepare in %1", thread_id()); @@ -328,6 +341,7 @@ catch (...) _died = true; } + void Butler::video (shared_ptr video, DCPTime time) { @@ -338,11 +352,12 @@ Butler::video (shared_ptr video, DCPTime time) return; } - _prepare_service.post (bind (&Butler::prepare, this, weak_ptr(video))); + _prepare_service.post (bind(&Butler::prepare, this, weak_ptr(video))); _video.put (video, time); } + void Butler::audio (shared_ptr audio, DCPTime time, int frame_rate) { @@ -352,9 +367,10 @@ Butler::audio (shared_ptr audio, DCPTime time, int frame_rate) return; } - _audio.put (remap (audio, _audio_channels, _audio_mapping), time, frame_rate); + _audio.put (remap(audio, _audio_channels, _audio_mapping), time, frame_rate); } + /** Try to get `frames' frames of audio and copy it into `out'. Silence * will be filled if no audio is available. * @return time of this audio, or unset if there was a buffer underrun. @@ -362,11 +378,12 @@ Butler::audio (shared_ptr audio, DCPTime time, int frame_rate) optional Butler::get_audio (float* out, Frame frames) { - optional t = _audio.get (out, _audio_channels, frames); + auto t = _audio.get (out, _audio_channels, frames); _summon.notify_all (); return t; } + void Butler::disable_audio () { @@ -374,6 +391,7 @@ Butler::disable_audio () _disable_audio = true; } + pair Butler::memory_used () const { @@ -381,12 +399,13 @@ Butler::memory_used () const return _video.memory_used(); } + void Butler::player_change (ChangeType type, int property) { if (property == VideoContentProperty::CROP) { - if (type == CHANGE_TYPE_DONE) { - shared_ptr film = _film.lock(); + if (type == ChangeType::DONE) { + auto film = _film.lock(); if (film) { _video.reset_metadata (film, _player->video_container_size()); } @@ -396,9 +415,9 @@ Butler::player_change (ChangeType type, int property) boost::mutex::scoped_lock lm (_mutex); - if (type == CHANGE_TYPE_PENDING) { + if (type == ChangeType::PENDING) { ++_suspended; - } else if (type == CHANGE_TYPE_DONE) { + } else if (type == ChangeType::DONE) { --_suspended; if (_died || _pending_seek_position) { lm.unlock (); @@ -407,7 +426,7 @@ Butler::player_change (ChangeType type, int property) } DCPTime seek_to; - DCPTime next = _video.get().second; + auto next = _video.get().second; if (_awaiting && _awaiting > next) { /* We have recently done a player_changed seek and our buffers haven't been refilled yet, so assume that we're seeking to the same place as last time. @@ -419,7 +438,7 @@ Butler::player_change (ChangeType type, int property) seek_unlocked (seek_to, true); _awaiting = seek_to; - } else if (type == CHANGE_TYPE_CANCELLED) { + } else if (type == ChangeType::CANCELLED) { --_suspended; } @@ -427,10 +446,11 @@ Butler::player_change (ChangeType type, int property) _summon.notify_all (); } + void Butler::text (PlayerText pt, TextType type, optional track, DCPTimePeriod period) { - if (type != TEXT_CLOSED_CAPTION) { + if (type != TextType::CLOSED_CAPTION) { return; } @@ -439,6 +459,7 @@ Butler::text (PlayerText pt, TextType type, optional track, DCPTim _closed_caption.put (pt, *track, period); } + string Butler::Error::summary () const {