X-Git-Url: https://git.carlh.net/gitweb/?a=blobdiff_plain;f=src%2Flib%2Fencoder.h;h=5816fe12f64c88c69d0c19ef47ece2b2744fe8e5;hb=2ac383717e05089fd6ba6e3a6e5affe78594e239;hp=20ec8fb162b04f04e0a0ef2496134bc7d9377520;hpb=315472b02ae6825328fa9877cc6075644fefba01;p=dcpomatic.git diff --git a/src/lib/encoder.h b/src/lib/encoder.h index 20ec8fb16..5816fe12f 100644 --- a/src/lib/encoder.h +++ b/src/lib/encoder.h @@ -1,112 +1,114 @@ /* - Copyright (C) 2012 Carl Hetherington + Copyright (C) 2012-2016 Carl Hetherington - This program is free software; you can redistribute it and/or modify + 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. - This program is distributed in the hope that it will be useful, + 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 this program; if not, write to the Free Software - Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA. + along with DCP-o-matic. If not, see . */ -#ifndef DVDOMATIC_ENCODER_H -#define DVDOMATIC_ENCODER_H +#ifndef DCPOMATIC_ENCODER_H +#define DCPOMATIC_ENCODER_H -/** @file src/encoder.h - * @brief Parent class for classes which can encode video and audio frames. +/** @file src/encoder.h + * @brief Encoder class. */ +#include "util.h" +#include "cross.h" +#include "exception_store.h" #include #include +#include +#include +#include +#include +#include #include #include -extern "C" { -#include -} -#include "util.h" -class Options; -class Image; -class Subtitle; -class AudioBuffers; class Film; +class EncodeServerDescription; +class DCPVideo; +class Writer; +class Job; +class PlayerVideo; /** @class Encoder - * @brief Parent class for classes which can encode video and audio frames. - * - * Video is supplied to process_video as YUV frames, and audio - * is supplied as uncompressed PCM in blocks of various sizes. + * @brief Class to manage encoding to JPEG2000. * - * The subclass is expected to encode the video and/or audio in - * some way and write it to disk. + * This class keeps a queue of frames to be encoded and distributes + * the work around threads and encoding servers. */ -class Encoder +class Encoder : public boost::noncopyable, public ExceptionStore, public boost::enable_shared_from_this { public: - Encoder (boost::shared_ptr f, boost::shared_ptr o); - virtual ~Encoder () {} + Encoder (boost::shared_ptr, boost::shared_ptr); + ~Encoder (); /** Called to indicate that a processing run is about to begin */ - virtual void process_begin (int64_t audio_channel_layout) = 0; + void begin (); - /** Call with a frame of video. - * @param i Video frame image. - * @param f Frame number within the film's source. - * @param s A subtitle that should be on this frame, or 0. - */ - void process_video (boost::shared_ptr i, SourceFrame f, boost::shared_ptr s); - - /** Call with some audio data */ - void process_audio (boost::shared_ptr, int64_t); + /** Called to pass a bit of video to be encoded as the next DCP frame */ + void encode (boost::shared_ptr f); /** Called when a processing run has finished */ - virtual void process_end () = 0; - - float current_frames_per_second () const; - bool skipping () const; - SourceFrame last_frame () const; - -protected: - - /** Called with a frame of video. - * @param i Video frame image. - * @param f Frame number within the film's source. - * @param s A subtitle that should be on this frame, or 0. - */ - virtual void do_process_video (boost::shared_ptr i, SourceFrame f, boost::shared_ptr s) = 0; - - /** Called with some audio data */ - virtual void do_process_audio (boost::shared_ptr) = 0; - - void frame_done (SourceFrame n); - void frame_skipped (); - + void end (); + + float current_encoding_rate () const; + int video_frames_enqueued () const; + + void servers_list_changed (); + +private: + + static void call_servers_list_changed (boost::weak_ptr encoder); + + void frame_done (); + + void encoder_thread (boost::optional); + void terminate_threads (); + /** Film that we are encoding */ boost::shared_ptr _film; - /** Options */ - boost::shared_ptr _opt; - /** Mutex for _time_history, _just_skipped and _last_frame */ - mutable boost::mutex _history_mutex; + /** Mutex for _time_history */ + mutable boost::mutex _state_mutex; /** List of the times of completion of the last _history_size frames; first is the most recently completed. */ std::list _time_history; /** Number of frames that we should keep history for */ static int const _history_size; - /** true if the last frame we processed was skipped (because it was already done) */ - bool _just_skipped; - /** Source index of the last frame to be processed */ - SourceFrame _last_frame; + + /** Mutex for _threads */ + mutable boost::mutex _threads_mutex; + std::list _threads; + mutable boost::mutex _queue_mutex; + 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; + Waker _waker; + + boost::shared_ptr _last_player_video; + + boost::signals2::scoped_connection _server_found_connection; }; #endif