X-Git-Url: https://main.carlh.net/gitweb/?a=blobdiff_plain;f=src%2Flib%2Fvideo_mxf_decoder.cc;h=92cab0259dd8a1697826f2ad5213b221cba7e6e3;hb=76d9b784295f16a9d53d910fac18761e3e633c22;hp=95dd668ee4246709ed72c08479613cd02536b9d2;hpb=de2af791bdfdcd653752cba970e59efc7bf810c7;p=dcpomatic.git diff --git a/src/lib/video_mxf_decoder.cc b/src/lib/video_mxf_decoder.cc index 95dd668ee..92cab0259 100644 --- a/src/lib/video_mxf_decoder.cc +++ b/src/lib/video_mxf_decoder.cc @@ -1,5 +1,5 @@ /* - Copyright (C) 2016 Carl Hetherington + Copyright (C) 2016-2021 Carl Hetherington This file is part of DCP-o-matic. @@ -18,40 +18,48 @@ */ + #include "video_mxf_decoder.h" #include "video_decoder.h" #include "video_mxf_content.h" #include "j2k_image_proxy.h" +#include "frame_interval_checker.h" #include #include #include #include #include -using boost::shared_ptr; -VideoMXFDecoder::VideoMXFDecoder (shared_ptr content, shared_ptr log) - : _content (content) +using std::make_shared; +using std::shared_ptr; +using boost::optional; +using namespace dcpomatic; + + +VideoMXFDecoder::VideoMXFDecoder (shared_ptr film, shared_ptr content) + : Decoder (film) + , _content (content) { - video.reset (new VideoDecoder (this, content, log)); + video = make_shared(this, content); shared_ptr mono; try { - mono.reset (new dcp::MonoPictureAsset (_content->path(0))); + mono = make_shared(_content->path(0)); } catch (dcp::MXFFileError& e) { /* maybe it's stereo */ - } catch (dcp::DCPReadError& e) { + } catch (dcp::ReadError& e) { /* maybe it's stereo */ } shared_ptr stereo; try { - stereo.reset (new dcp::StereoPictureAsset (_content->path(0))); + stereo = make_shared(_content->path(0)); } catch (dcp::MXFFileError& e) { if (!mono) { throw; } - } catch (dcp::DCPReadError& e) { + } catch (dcp::ReadError& e) { if (!mono) { throw; } @@ -59,41 +67,53 @@ VideoMXFDecoder::VideoMXFDecoder (shared_ptr content, sha if (mono) { _mono_reader = mono->start_read (); + _mono_reader->set_check_hmac (false); _size = mono->size (); } else { _stereo_reader = stereo->start_read (); + _stereo_reader->set_check_hmac (false); _size = stereo->size (); } } -void + +bool VideoMXFDecoder::pass () { - double const vfr = _content->active_video_frame_rate (); - int64_t const frame = _next.frames_round (vfr); + auto const vfr = _content->active_video_frame_rate (film()); + auto const frame = _next.frames_round (vfr); if (frame >= _content->video->length()) { - return; + return true; } if (_mono_reader) { video->emit ( - shared_ptr (new J2KImageProxy (_mono_reader->get_frame(frame), _size, AV_PIX_FMT_XYZ12LE)), frame + film(), + std::make_shared(_mono_reader->get_frame(frame), _size, AV_PIX_FMT_XYZ12LE, optional()), + frame ); } else { video->emit ( - shared_ptr (new J2KImageProxy (_stereo_reader->get_frame(frame), _size, dcp::EYE_LEFT, AV_PIX_FMT_XYZ12LE)), frame + film(), + std::make_shared(_stereo_reader->get_frame(frame), _size, dcp::Eye::LEFT, AV_PIX_FMT_XYZ12LE, optional()), + frame ); video->emit ( - shared_ptr (new J2KImageProxy (_stereo_reader->get_frame(frame), _size, dcp::EYE_RIGHT, AV_PIX_FMT_XYZ12LE)), frame + film(), + std::make_shared(_stereo_reader->get_frame(frame), _size, dcp::Eye::RIGHT, AV_PIX_FMT_XYZ12LE, optional()), + frame ); } _next += ContentTime::from_frames (1, vfr); + return false; } + void -VideoMXFDecoder::seek (ContentTime t, bool) +VideoMXFDecoder::seek (ContentTime t, bool accurate) { + Decoder::seek (t, accurate); _next = t; }