Merge FilmState / Film.
[dcpomatic.git] / src / lib / ffmpeg_decoder.cc
index ca35c6e81279b7c90f6e029a5c0ae03e9746f1f7..30701797affc9f3f74837378b79735d19b66e08a 100644 (file)
@@ -41,19 +41,19 @@ extern "C" {
 #include "transcoder.h"
 #include "job.h"
 #include "filter.h"
-#include "film_state.h"
 #include "options.h"
 #include "exceptions.h"
 #include "image.h"
 #include "util.h"
 #include "log.h"
 #include "ffmpeg_decoder.h"
+#include "subtitle.h"
 
 using namespace std;
 using namespace boost;
 
-FFmpegDecoder::FFmpegDecoder (boost::shared_ptr<const FilmState> s, boost::shared_ptr<const Options> o, Job* j, Log* l, bool minimal, bool ignore_length)
-       : Decoder (s, o, j, l, minimal, ignore_length)
+FFmpegDecoder::FFmpegDecoder (boost::shared_ptr<Film> f, boost::shared_ptr<const Options> o, Job* j, bool minimal, bool ignore_length)
+       : Decoder (f, o, j, minimal, ignore_length)
        , _format_context (0)
        , _video_stream (-1)
        , _audio_stream (-1)
@@ -65,7 +65,6 @@ FFmpegDecoder::FFmpegDecoder (boost::shared_ptr<const FilmState> s, boost::share
        , _audio_codec (0)
        , _subtitle_codec_context (0)
        , _subtitle_codec (0)
-       , _have_subtitle (false)
 {
        setup_general ();
        setup_video ();
@@ -83,10 +82,6 @@ FFmpegDecoder::~FFmpegDecoder ()
                avcodec_close (_video_codec_context);
        }
 
-       if (_have_subtitle) {
-               avsubtitle_free (&_subtitle);
-       }
-
        if (_subtitle_codec_context) {
                avcodec_close (_subtitle_codec_context);
        }
@@ -102,24 +97,43 @@ FFmpegDecoder::setup_general ()
        
        av_register_all ();
 
-       if ((r = avformat_open_input (&_format_context, _fs->content_path().c_str(), 0, 0)) != 0) {
-               throw OpenFileError (_fs->content_path ());
+       if ((r = avformat_open_input (&_format_context, _film->content_path().c_str(), 0, 0)) != 0) {
+               throw OpenFileError (_film->content_path ());
        }
 
        if (avformat_find_stream_info (_format_context, 0) < 0) {
                throw DecodeError ("could not find stream information");
        }
 
+       /* Find video, audio and subtitle streams and choose the first of each */
+
        for (uint32_t i = 0; i < _format_context->nb_streams; ++i) {
-               if (_format_context->streams[i]->codec->codec_type == AVMEDIA_TYPE_VIDEO) {
+               AVStream* s = _format_context->streams[i];
+               if (s->codec->codec_type == AVMEDIA_TYPE_VIDEO) {
                        _video_stream = i;
-               } else if (_format_context->streams[i]->codec->codec_type == AVMEDIA_TYPE_AUDIO) {
-                       _audio_stream = i;
-               } else if (_format_context->streams[i]->codec->codec_type == AVMEDIA_TYPE_SUBTITLE) {
-                       _subtitle_stream = i;
+               } else if (s->codec->codec_type == AVMEDIA_TYPE_AUDIO) {
+                       if (_audio_stream == -1) {
+                               _audio_stream = i;
+                       }
+                       _audio_streams.push_back (AudioStream (stream_name (s), i, s->codec->channels));
+               } else if (s->codec->codec_type == AVMEDIA_TYPE_SUBTITLE) {
+                       if (_subtitle_stream == -1) {
+                               _subtitle_stream = i;
+                       }
+                       _subtitle_streams.push_back (SubtitleStream (stream_name (s), i));
                }
        }
 
+       /* Now override audio and subtitle streams with those from the Film, if it has any */
+
+       if (_film->audio_stream_index() != -1) {
+               _audio_stream = _film->audio_stream().id();
+       }
+
+       if (_film->subtitle_stream_index() != -1) {
+               _subtitle_stream = _film->subtitle_stream().id ();
+       }
+
        if (_video_stream < 0) {
                throw DecodeError ("could not find video stream");
        }
@@ -196,6 +210,7 @@ bool
 FFmpegDecoder::do_pass ()
 {
        int r = av_read_frame (_format_context, &_packet);
+       
        if (r < 0) {
                if (r != AVERROR_EOF) {
                        throw DecodeError ("error on av_read_frame");
@@ -206,6 +221,8 @@ FFmpegDecoder::do_pass ()
                _packet.data = 0;
                _packet.size = 0;
 
+               /* XXX: should we reset _packet.data and size after each *_decode_* call? */
+
                int frame_finished;
 
                while (avcodec_decode_video2 (_video_codec_context, _frame, &frame_finished, &_packet) >= 0 && frame_finished) {
@@ -217,8 +234,8 @@ FFmpegDecoder::do_pass ()
                                int const data_size = av_samples_get_buffer_size (
                                        0, _audio_codec_context->channels, _frame->nb_samples, audio_sample_format (), 1
                                        );
-                               
-                               assert (_audio_codec_context->channels == _fs->audio_channels);
+
+                               assert (_audio_codec_context->channels == _film->audio_channels());
                                process_audio (_frame->data[0], data_size);
                        }
                }
@@ -226,14 +243,53 @@ FFmpegDecoder::do_pass ()
                return true;
        }
 
+       double const pts_seconds = av_q2d (_format_context->streams[_packet.stream_index]->time_base) * _packet.pts;
+       
        if (_packet.stream_index == _video_stream) {
 
+               if (!_first_video) {
+                       _first_video = pts_seconds;
+               }
+               
                int frame_finished;
                if (avcodec_decode_video2 (_video_codec_context, _frame, &frame_finished, &_packet) >= 0 && frame_finished) {
                        process_video (_frame);
                }
 
-       } else if (_audio_stream >= 0 && _packet.stream_index == _audio_stream && _opt->decode_audio) {
+       } else if (_audio_stream >= 0 && _packet.stream_index == _audio_stream && _opt->decode_audio && _first_video && _first_video.get() <= pts_seconds) {
+
+               /* Note: We only decode audio if we've had our first video packet through, and if it
+                  was before this packet.  Until then audio is thrown away.
+               */
+               
+               if (!_first_audio) {
+                       _first_audio = pts_seconds;
+                       
+                       /* This is our first audio packet, and if we've arrived here we must have had our
+                          first video packet.  Push some silence to make up the gap between our first
+                          video packet and our first audio.
+                       */
+                       
+                       /* frames of silence that we must push */
+                       int const s = rint ((_first_audio.get() - _first_video.get()) * audio_sample_rate ());
+                       
+                       _log->log (
+                               String::compose (
+                                       "First video at %1, first audio at %2, pushing %3 frames of silence for %4 channels (%5 bytes per sample)",
+                                       _first_video.get(), _first_audio.get(), s, audio_channels(), bytes_per_audio_sample()
+                                       )
+                               );
+                       
+                       /* hence bytes */
+                       int const b = s * audio_channels() * bytes_per_audio_sample();
+                       
+                       /* XXX: this assumes that it won't be too much, and there are shaky assumptions
+                          that all sound representations are silent with memset()ed zero data.
+                       */
+                       uint8_t silence[b];
+                       memset (silence, 0, b);
+                       process_audio (silence, b);
+               }
                
                avcodec_get_frame_defaults (_frame);
                
@@ -242,21 +298,25 @@ FFmpegDecoder::do_pass ()
                        int const data_size = av_samples_get_buffer_size (
                                0, _audio_codec_context->channels, _frame->nb_samples, audio_sample_format (), 1
                                );
-
-                       assert (_audio_codec_context->channels == _fs->audio_channels);
+                       
+                       assert (_audio_codec_context->channels == _film->audio_channels());
                        process_audio (_frame->data[0], data_size);
                }
-
-       } else if (_subtitle_stream >= 0 && _packet.stream_index == _subtitle_stream && _fs->with_subtitles) {
-
-               if (_have_subtitle) {
-                       avsubtitle_free (&_subtitle);
-                       _have_subtitle = false;
-               }
+                       
+       } else if (_subtitle_stream >= 0 && _packet.stream_index == _subtitle_stream && _opt->decode_subtitles && _first_video) {
 
                int got_subtitle;
-               if (avcodec_decode_subtitle2 (_subtitle_codec_context, &_subtitle, &got_subtitle, &_packet) && got_subtitle) {
-                       _have_subtitle = true;
+               AVSubtitle sub;
+               if (avcodec_decode_subtitle2 (_subtitle_codec_context, &sub, &got_subtitle, &_packet) && got_subtitle) {
+                       /* Sometimes we get an empty AVSubtitle, which is used by some codecs to
+                          indicate that the previous subtitle should stop.
+                       */
+                       if (sub.num_rects > 0) {
+                               process_subtitle (shared_ptr<TimedSubtitle> (new TimedSubtitle (sub, _first_video.get())));
+                       } else {
+                               process_subtitle (shared_ptr<TimedSubtitle> ());
+                       }
+                       avsubtitle_free (&sub);
                }
        }
        
@@ -264,12 +324,6 @@ FFmpegDecoder::do_pass ()
        return false;
 }
 
-int
-FFmpegDecoder::length_in_frames () const
-{
-       return (_format_context->duration / AV_TIME_BASE) * frames_per_second ();
-}
-
 float
 FFmpegDecoder::frames_per_second () const
 {
@@ -358,107 +412,46 @@ FFmpegDecoder::sample_aspect_ratio_denominator () const
        return _video_codec_context->sample_aspect_ratio.den;
 }
 
-void
-FFmpegDecoder::overlay (shared_ptr<Image> image) const
+bool
+FFmpegDecoder::has_subtitles () const
 {
-       if (!_have_subtitle) {
-               return;
-       }
-       
-       /* subtitle PTS in seconds */
-       float const packet_time = (_subtitle.pts / AV_TIME_BASE) + float (_subtitle.pts % AV_TIME_BASE) / 1e6;
-       /* hence start time for this sub */
-       float const from = packet_time + (float (_subtitle.start_display_time) / 1e3);
-       float const to = packet_time + (float (_subtitle.end_display_time) / 1e3);
-       
-       float const video_frame_time = float (last_video_frame ()) / rint (_fs->frames_per_second);
-
-       if (from > video_frame_time || video_frame_time < to) {
-               return;
-       }
-
-       for (unsigned int i = 0; i < _subtitle.num_rects; ++i) {
-               AVSubtitleRect* rect = _subtitle.rects[i];
-               if (rect->type != SUBTITLE_BITMAP) {
-                       throw DecodeError ("non-bitmap subtitles not yet supported");
-               }
+       return (_subtitle_stream != -1);
+}
 
-               /* XXX: all this assumes YUV420 in image */
-               
-               assert (rect->pict.data[0]);
+vector<AudioStream>
+FFmpegDecoder::audio_streams () const
+{
+       return _audio_streams;
+}
 
-               /* Start of the first line in the target image */
-               uint8_t* frame_y_p = image->data()[0] + rect->y * image->line_size()[0];
-               uint8_t* frame_u_p = image->data()[1] + (rect->y / 2) * image->line_size()[1];
-               uint8_t* frame_v_p = image->data()[2] + (rect->y / 2) * image->line_size()[2];
+vector<SubtitleStream>
+FFmpegDecoder::subtitle_streams () const
+{
+       return _subtitle_streams;
+}
 
-               int const hlim = min (rect->y + rect->h, image->size().height) - rect->y;
-               
-               /* Start of the first line in the subtitle */
-               uint8_t* sub_p = rect->pict.data[0];
-               /* sub_p looks up into a RGB palette which is here */
-               uint32_t const * palette = (uint32_t *) rect->pict.data[1];
-               
-               for (int sub_y = 0; sub_y < hlim; ++sub_y) {
-                       /* Pointers to the start of this line */
-                       uint8_t* sub_line_p = sub_p;
-                       uint8_t* frame_line_y_p = frame_y_p + rect->x;
-                       uint8_t* frame_line_u_p = frame_u_p + (rect->x / 2);
-                       uint8_t* frame_line_v_p = frame_v_p + (rect->x / 2);
-                       
-                       /* U and V are subsampled */
-                       uint8_t next_u = 0;
-                       uint8_t next_v = 0;
-                       int subsample_step = 0;
-                       
-                       for (int sub_x = 0; sub_x < rect->w; ++sub_x) {
-                               
-                               /* RGB value for this subtitle pixel */
-                               uint32_t const val = palette[*sub_line_p++];
-                               
-                               int const     red =  (val &       0xff);
-                               int const   green =  (val &     0xff00) >> 8;
-                               int const    blue =  (val &   0xff0000) >> 16;
-                               float const alpha = ((val & 0xff000000) >> 24) / 255.0;
-                               
-                               /* Alpha-blend Y */
-                               int const cy = *frame_line_y_p;
-                               *frame_line_y_p++ = int (cy * (1 - alpha)) + int (RGB_TO_Y_CCIR (red, green, blue) * alpha);
-                               
-                               /* Store up U and V */
-                               next_u |= ((RGB_TO_U_CCIR (red, green, blue, 0) & 0xf0) >> 4) << (4 * subsample_step);
-                               next_v |= ((RGB_TO_V_CCIR (red, green, blue, 0) & 0xf0) >> 4) << (4 * subsample_step);
-                               
-                               if (subsample_step == 1 && (sub_y % 2) == 0) {
-                                       int const cu = *frame_line_u_p;
-                                       int const cv = *frame_line_v_p;
-
-                                       *frame_line_u_p++ =
-                                               int (((cu & 0x0f) * (1 - alpha) + (next_u & 0x0f) * alpha)) |
-                                               int (((cu & 0xf0) * (1 - alpha) + (next_u & 0xf0) * alpha));
-
-                                       *frame_line_v_p++ = 
-                                               int (((cv & 0x0f) * (1 - alpha) + (next_v & 0x0f) * alpha)) |
-                                               int (((cv & 0xf0) * (1 - alpha) + (next_v & 0xf0) * alpha));
-                                       
-                                       next_u = next_v = 0;
-                               }
-                               
-                               subsample_step = (subsample_step + 1) % 2;
-                       }
-                       
-                       sub_p += rect->pict.linesize[0];
-                       frame_y_p += image->line_size()[0];
-                       if ((sub_y % 2) == 0) {
-                               frame_u_p += image->line_size()[1];
-                               frame_v_p += image->line_size()[2];
-                       }
+string
+FFmpegDecoder::stream_name (AVStream* s) const
+{
+       stringstream n;
+       
+       AVDictionaryEntry const * lang = av_dict_get (s->metadata, "language", 0, 0);
+       if (lang) {
+               n << lang->value;
+       }
+       
+       AVDictionaryEntry const * title = av_dict_get (s->metadata, "title", 0, 0);
+       if (title) {
+               if (!n.str().empty()) {
+                       n << " ";
                }
+               n << title->value;
        }
+
+       if (n.str().empty()) {
+               n << "unknown";
+       }
+
+       return n.str ();
 }
-    
-bool
-FFmpegDecoder::has_subtitles () const
-{
-       return (_subtitle_stream != -1);
-}
+