X-Git-Url: https://git.carlh.net/gitweb/?p=dcpomatic.git;a=blobdiff_plain;f=src%2Flib%2Fj2k_encoder.h;h=ea0a2bef89bfbe873a83cbad11be48a1a0788985;hp=818c75c99209052044f6d2131e680417406555a2;hb=723f062e76370a142144a86df8c75fc2176c744e;hpb=0fc3ee1eac41d391ebb79044b0f46849a90f5138 diff --git a/src/lib/j2k_encoder.h b/src/lib/j2k_encoder.h index 818c75c99..ea0a2bef8 100644 --- a/src/lib/j2k_encoder.h +++ b/src/lib/j2k_encoder.h @@ -1,5 +1,5 @@ /* - Copyright (C) 2012-2016 Carl Hetherington + Copyright (C) 2012-2021 Carl Hetherington This file is part of DCP-o-matic. @@ -18,27 +18,29 @@ */ + #ifndef DCPOMATIC_J2K_ENCODER_H #define DCPOMATIC_J2K_ENCODER_H + /** @file src/j2k_encoder.h * @brief J2KEncoder class. */ + #include "util.h" #include "cross.h" #include "event_history.h" #include "exception_store.h" -#include #include #include #include #include #include -#include #include #include + class Film; class EncodeServerDescription; class DCPVideo; @@ -46,24 +48,27 @@ class Writer; class Job; class PlayerVideo; + /** @class J2KEncoder * @brief Class to manage encoding to J2K. * * This class keeps a queue of frames to be encoded and distributes * the work around threads and encoding servers. */ - -class J2KEncoder : public boost::noncopyable, public ExceptionStore, public boost::enable_shared_from_this +class J2KEncoder : public ExceptionStore, public std::enable_shared_from_this { public: - J2KEncoder (boost::shared_ptr film, boost::shared_ptr writer); + J2KEncoder (std::shared_ptr film, std::shared_ptr writer); ~J2KEncoder (); + J2KEncoder (J2KEncoder const&) = delete; + J2KEncoder& operator= (J2KEncoder const&) = delete; + /** Called to indicate that a processing run is about to begin */ void begin (); /** Called to pass a bit of video to be encoded as the next DCP frame */ - void encode (boost::shared_ptr pv, dcpomatic::DCPTime time); + void encode (std::shared_ptr pv, dcpomatic::DCPTime time); /** Called when a processing run has finished */ void end (); @@ -75,7 +80,7 @@ public: private: - static void call_servers_list_changed (boost::weak_ptr encoder); + static void call_servers_list_changed (std::weak_ptr encoder); void frame_done (); @@ -83,27 +88,28 @@ private: void terminate_threads (); /** Film that we are encoding */ - boost::shared_ptr _film; + std::shared_ptr _film; EventHistory _history; boost::mutex _threads_mutex; - boost::shared_ptr _threads; + std::shared_ptr _threads; mutable boost::mutex _queue_mutex; - std::list > _queue; + std::list _queue; /** condition to manage thread wakeups when we have nothing to do */ boost::condition _empty_condition; /** condition to manage thread wakeups when we have too much to do */ boost::condition _full_condition; - boost::shared_ptr _writer; + std::shared_ptr _writer; Waker _waker; - boost::shared_ptr _last_player_video[EYES_COUNT]; + std::shared_ptr _last_player_video[static_cast(Eyes::COUNT)]; boost::optional _last_player_video_time; boost::signals2::scoped_connection _server_found_connection; }; + #endif