X-Git-Url: https://main.carlh.net/gitweb/?a=blobdiff_plain;f=src%2Flib%2Fbutler.h;h=c7e71658da25889107d033147e62b16897f92f4d;hb=e1cbceca253ebf16f49e5bc78e3f1d0157c37bee;hp=6263d61431d6e9fff81d7886d5e134d3a1a00c18;hpb=cfa822570e6f2d2d09fe1c36a81b224ded07c6b6;p=dcpomatic.git diff --git a/src/lib/butler.h b/src/lib/butler.h index 6263d6143..c7e71658d 100644 --- a/src/lib/butler.h +++ b/src/lib/butler.h @@ -1,5 +1,5 @@ /* - Copyright (C) 2016-2017 Carl Hetherington + Copyright (C) 2016-2021 Carl Hetherington This file is part of DCP-o-matic. @@ -18,46 +18,67 @@ */ -#include "video_ring_buffers.h" -#include "audio_ring_buffers.h" -#include "text_ring_buffers.h" + #include "audio_mapping.h" +#include "audio_ring_buffers.h" +#include "change_signaller.h" #include "exception_store.h" -#include -#include +#include "text_ring_buffers.h" +#include "video_ring_buffers.h" +#include +#include #include #include -#include -#include + class Player; class PlayerVideo; -class Butler : public ExceptionStore, public boost::noncopyable + +class Butler : public ExceptionStore { public: Butler ( - boost::shared_ptr player, + std::weak_ptr film, + std::shared_ptr player, AudioMapping map, int audio_channels, - boost::function pixel_format, - bool aligned, - bool fast + std::function pixel_format, + VideoRange video_range, + Image::Alignment alignment, + bool fast, + bool prepare_only_proxy ); ~Butler (); + Butler (Butler const&) = delete; + Butler& operator= (Butler const&) = delete; + void seek (dcpomatic::DCPTime position, bool accurate); - enum Error { - NONE, - AGAIN, - DIED, - FINISHED + class Error { + public: + enum class Code { + NONE, + AGAIN, + DIED, + FINISHED + }; + + Code code = Code::NONE; + std::string message; + + std::string summary () const; + }; + + enum class Behaviour { + BLOCKING, + NON_BLOCKING }; - std::pair, dcpomatic::DCPTime> get_video (bool blocking, Error* e = 0); - boost::optional get_audio (float* out, Frame frames); + std::pair, dcpomatic::DCPTime> get_video (Behaviour behaviour, Error* e = nullptr); + boost::optional get_audio (Behaviour behaviour, float* out, Frame frames); boost::optional get_closed_caption (); void disable_audio (); @@ -66,15 +87,16 @@ public: private: void thread (); - void video (boost::shared_ptr video, dcpomatic::DCPTime time); - void audio (boost::shared_ptr audio, dcpomatic::DCPTime time, int frame_rate); + void video (std::shared_ptr video, dcpomatic::DCPTime time); + void audio (std::shared_ptr audio, dcpomatic::DCPTime time, int frame_rate); void text (PlayerText pt, TextType type, boost::optional track, dcpomatic::DCPTimePeriod period); bool should_run () const; - void prepare (boost::weak_ptr video); - void player_change (ChangeType type); + void prepare (std::weak_ptr video); + void player_change (ChangeType type, int property); void seek_unlocked (dcpomatic::DCPTime position, bool accurate); - boost::shared_ptr _player; + std::weak_ptr _film; + std::shared_ptr _player; boost::thread _thread; VideoRingBuffers _video; @@ -83,7 +105,7 @@ private: boost::thread_group _prepare_pool; boost::asio::io_service _prepare_service; - boost::shared_ptr _prepare_work; + std::shared_ptr _prepare_work; /** mutex to protect _pending_seek_position, _pending_seek_accurate, _finished, _died, _stop_thread */ boost::mutex _mutex; @@ -94,6 +116,7 @@ private: int _suspended; bool _finished; bool _died; + std::string _died_message; bool _stop_thread; AudioMapping _audio_mapping; @@ -101,10 +124,19 @@ private: bool _disable_audio; - boost::function _pixel_format; - bool _aligned; + std::function _pixel_format; + VideoRange _video_range; + Image::Alignment _alignment; bool _fast; + /** true to ask PlayerVideo::prepare to only prepare the ImageProxy and not also + * the final image. We want to do this when the viewer is intending to call + * PlayerVideo::raw_image() and do the things in PlayerVideo::make_imgae() itself: + * this is the case for the GLVideoView which can do scale, pixfmt conversion etc. + * in the shader. + */ + bool _prepare_only_proxy = false; + /** If we are waiting to be refilled following a seek, this is the time we were seeking to. */