X-Git-Url: https://git.carlh.net/gitweb/?a=blobdiff_plain;f=src%2Flib%2Ffilter_graph.cc;h=d2427c31faf35957b251320d1d091fce2e54b161;hb=8c7a308c03e4b4196b4e2379a26d432b100ae2b1;hp=48d94e17570c2c6306ba975574c42a1e66f64e7f;hpb=c28b3d6f168607aca9995282b96647eb64a26dc9;p=dcpomatic.git diff --git a/src/lib/filter_graph.cc b/src/lib/filter_graph.cc index 48d94e175..d2427c31f 100644 --- a/src/lib/filter_graph.cc +++ b/src/lib/filter_graph.cc @@ -34,10 +34,10 @@ extern "C" { #include "exceptions.h" #include "image.h" #include "ffmpeg_content.h" +#include "safe_stringstream.h" #include "i18n.h" -using std::stringstream; using std::string; using std::list; using std::pair; @@ -53,18 +53,21 @@ using dcp::Size; * @param p Pixel format of the images to process. */ FilterGraph::FilterGraph (shared_ptr content, dcp::Size s, AVPixelFormat p) - : _buffer_src_context (0) + : _copy (false) + , _buffer_src_context (0) , _buffer_sink_context (0) , _size (s) , _pixel_format (p) + , _frame (0) { - _frame = av_frame_alloc (); - - string filters = Filter::ffmpeg_strings (content->filters()).first; + string const filters = Filter::ffmpeg_string (content->filters()); if (filters.empty ()) { - filters = "copy"; + _copy = true; + return; } + _frame = av_frame_alloc (); + AVFilterGraph* graph = avfilter_graph_alloc(); if (graph == 0) { throw DecodeError (N_("could not create filter graph.")); @@ -80,7 +83,7 @@ FilterGraph::FilterGraph (shared_ptr content, dcp::Size s, throw DecodeError (N_("Could not create buffer sink filter")); } - stringstream a; + SafeStringStream a; a << "video_size=" << _size.width << "x" << _size.height << ":" << "pix_fmt=" << _pixel_format << ":" << "time_base=1/1:" @@ -128,7 +131,9 @@ FilterGraph::FilterGraph (shared_ptr content, dcp::Size s, FilterGraph::~FilterGraph () { - av_frame_free (&_frame); + if (_frame) { + av_frame_free (&_frame); + } } /** Take an AVFrame and process it using our configured filters, returning a @@ -139,19 +144,23 @@ FilterGraph::process (AVFrame* frame) { list, int64_t> > images; - if (av_buffersrc_write_frame (_buffer_src_context, frame) < 0) { - throw DecodeError (N_("could not push buffer into filter chain.")); - } - - while (1) { - if (av_buffersink_get_frame (_buffer_sink_context, _frame) < 0) { - break; + if (_copy) { + images.push_back (make_pair (shared_ptr (new Image (frame)), av_frame_get_best_effort_timestamp (frame))); + } else { + if (av_buffersrc_write_frame (_buffer_src_context, frame) < 0) { + throw DecodeError (N_("could not push buffer into filter chain.")); + } + + while (true) { + if (av_buffersink_get_frame (_buffer_sink_context, _frame) < 0) { + break; + } + + images.push_back (make_pair (shared_ptr (new Image (_frame)), av_frame_get_best_effort_timestamp (_frame))); + av_frame_unref (_frame); } - - images.push_back (make_pair (shared_ptr (new Image (_frame)), av_frame_get_best_effort_timestamp (_frame))); - av_frame_unref (_frame); } - + return images; }