X-Git-Url: https://main.carlh.net/gitweb/?p=dcpomatic.git;a=blobdiff_plain;f=src%2Flib%2Fj2k_encoder.h;h=ea0a2bef89bfbe873a83cbad11be48a1a0788985;hp=a52cf0d1fc44f264bc614b33877d32a1d79b981a;hb=HEAD;hpb=592fa9ba3913a37676260bd581398a6b49496677 diff --git a/src/lib/j2k_encoder.h b/src/lib/j2k_encoder.h index a52cf0d1f..63228a6b8 100644 --- a/src/lib/j2k_encoder.h +++ b/src/lib/j2k_encoder.h @@ -29,9 +29,10 @@ #include "cross.h" +#include "enum_indexed_vector.h" #include "event_history.h" #include "exception_store.h" -#include "util.h" +#include "writer.h" #include #include #include @@ -46,7 +47,6 @@ class EncodeServerDescription; class Film; class Job; class PlayerVideo; -class Writer; /** @class J2KEncoder @@ -55,10 +55,10 @@ class Writer; * This class keeps a queue of frames to be encoded and distributes * the work around threads and encoding servers. */ -class J2KEncoder : public ExceptionStore, public std::enable_shared_from_this +class J2KEncoder : public ExceptionStore { public: - J2KEncoder (std::shared_ptr film, std::shared_ptr writer); + J2KEncoder(std::shared_ptr film, Writer& writer); ~J2KEncoder (); J2KEncoder (J2KEncoder const&) = delete; @@ -80,8 +80,6 @@ public: private: - static void call_servers_list_changed (std::weak_ptr encoder); - void frame_done (); void encoder_thread (boost::optional); @@ -102,10 +100,10 @@ private: /** condition to manage thread wakeups when we have too much to do */ boost::condition _full_condition; - std::shared_ptr _writer; + Writer& _writer; Waker _waker; - std::shared_ptr _last_player_video[static_cast(Eyes::COUNT)]; + EnumIndexedVector, Eyes> _last_player_video; boost::optional _last_player_video_time; boost::signals2::scoped_connection _server_found_connection;