X-Git-Url: https://git.carlh.net/gitweb/?a=blobdiff_plain;f=src%2Flib%2Fwriter.h;h=486d7d672aa31357b330259cfa89bffc9fbfff0b;hb=e60bb3e51bd1508b149e6b8f6608f09b5196ae26;hp=fe803d35e5c4d84fea5084ac98696cdecf43199e;hpb=f07623551706b849190c84059bac455088f8eb1e;p=dcpomatic.git diff --git a/src/lib/writer.h b/src/lib/writer.h index fe803d35e..486d7d672 100644 --- a/src/lib/writer.h +++ b/src/lib/writer.h @@ -24,6 +24,8 @@ #include "exceptions.h" #include "types.h" #include "player_subtitles.h" +#include "data.h" +#include #include #include #include @@ -31,7 +33,7 @@ #include class Film; -class EncodedData; +class Data; class AudioBuffers; class Job; class Font; @@ -45,12 +47,16 @@ namespace dcp { class PictureAssetWriter; class SoundAsset; class SoundAssetWriter; - class InteropSubtitleAsset; + class SubtitleAsset; } struct QueueItem { public: + QueueItem () + : size (0) + {} + enum Type { /** a normal frame with some JPEG200 data */ FULL, @@ -59,10 +65,11 @@ public: state but we use the data that is already on disk. */ FAKE, + REPEAT, } type; /** encoded data for FULL */ - boost::shared_ptr encoded; + boost::optional encoded; /** size of data for FAKE */ int size; /** frame index */ @@ -76,11 +83,11 @@ bool operator== (QueueItem const & a, QueueItem const & b); /** @class Writer * @brief Class to manage writing JPEG2000 and audio data to assets on disk. * - * This class creates sound and picture assets, then takes EncodedData + * This class creates sound and picture assets, then takes Data * or AudioBuffers objects (containing image or sound data respectively) * and writes them to the assets. * - * ::write() for EncodedData can be called out of order, and the Writer + * ::write() for Data can be called out of order, and the Writer * will sort it out. write() for AudioBuffers must be called in order. */ @@ -91,13 +98,13 @@ public: ~Writer (); bool can_fake_write (int) const; - - void write (boost::shared_ptr, int, Eyes); + + void write (Data, int, Eyes); void fake_write (int, Eyes); + void repeat (int, Eyes); void write (boost::shared_ptr); void write (PlayerSubtitles subs); void write (std::list > fonts); - void repeat (int f, Eyes); void finish (); void set_encoder_threads (int threads); @@ -109,6 +116,9 @@ private: void check_existing_picture_asset (); bool check_existing_picture_asset_frame (FILE *, int, Eyes); bool have_sequenced_image_at_queue_head (); + void write_frame_info (int frame, Eyes eyes, dcp::FrameInfo info) const; + long frame_info_position (int frame, Eyes eyes) const; + dcp::FrameInfo read_frame_info (FILE* file, int frame, Eyes eyes) const; /** our Film */ boost::shared_ptr _film; @@ -130,8 +140,8 @@ private: boost::condition _empty_condition; /** condition to manage thread wakeups when we have too much to do */ boost::condition _full_condition; - /** the data of the last written frame, or 0 if there isn't one */ - boost::shared_ptr _last_written[EYES_COUNT]; + /** the data of the last written frame, if there is one */ + boost::optional _last_written[EYES_COUNT]; /** the index of the last written frame */ int _last_written_frame; Eyes _last_written_eyes; @@ -139,21 +149,22 @@ private: * ordering */ int _maximum_frames_in_memory; - + /** number of FULL written frames */ int _full_written; /** number of FAKE written frames */ int _fake_written; + int _repeat_written; /** number of frames pushed to disk and then recovered due to the limit of frames to be held in memory. */ int _pushed_to_disk; - + boost::shared_ptr _picture_asset; boost::shared_ptr _picture_asset_writer; boost::shared_ptr _sound_asset; boost::shared_ptr _sound_asset_writer; - boost::shared_ptr _subtitle_asset; + boost::shared_ptr _subtitle_asset; std::list > _fonts; };