Don't seek a piece if the seek is outside its boundary.
[dcpomatic.git] / src / lib / player.cc
index 2a5452e1e300a6503d35b622c1844d463e4abd5d..3de26ec90fcae36e18f5c07cd62622d525aacaed 100644 (file)
@@ -143,8 +143,9 @@ Player::setup_pieces ()
                }
 
                if (decoder->subtitle) {
-                       decoder->subtitle->ImageData.connect (bind (&Player::image_subtitle, this, weak_ptr<Piece> (piece), _1));
-                       decoder->subtitle->TextData.connect (bind (&Player::text_subtitle, this, weak_ptr<Piece> (piece), _1));
+                       decoder->subtitle->ImageStart.connect (bind (&Player::image_subtitle_start, this, weak_ptr<Piece> (piece), _1));
+                       decoder->subtitle->TextStart.connect (bind (&Player::text_subtitle_start, this, weak_ptr<Piece> (piece), _1));
+                       decoder->subtitle->Stop.connect (bind (&Player::subtitle_stop, this, weak_ptr<Piece> (piece), _1));
                }
        }
 
@@ -416,13 +417,6 @@ Player::set_ignore_video ()
        _ignore_video = true;
 }
 
-/** Set this player never to produce any audio data */
-void
-Player::set_ignore_audio ()
-{
-       _ignore_audio = true;
-}
-
 /** Set whether or not this player should always burn text subtitles into the image,
  *  regardless of the content settings.
  *  @param burn true to always burn subtitles, false to obey content settings.
@@ -554,7 +548,7 @@ Player::pass ()
                /* No more content; fill up with silent black */
                DCPTimePeriod remaining_video (DCPTime(), _playlist->length());
                if (_last_video_time) {
-                       remaining_video.from = _last_video_time.get() + one_video_frame();
+                       remaining_video.from = _last_video_time.get();
                }
                fill_video (remaining_video);
                DCPTimePeriod remaining_audio (DCPTime(), _playlist->length());
@@ -584,10 +578,21 @@ Player::pass ()
 
        list<pair<shared_ptr<AudioBuffers>, DCPTime> > audio = _audio_merger.pull (pull_from);
        for (list<pair<shared_ptr<AudioBuffers>, DCPTime> >::iterator i = audio.begin(); i != audio.end(); ++i) {
-               DCPOMATIC_ASSERT (!_last_audio_time || i->second >= _last_audio_time.get());
+               if (_last_audio_time && i->second < _last_audio_time.get()) {
+                       /* There has been an accurate seek and we have received some audio before the seek time;
+                          discard it.
+                       */
+                       pair<shared_ptr<AudioBuffers>, DCPTime> cut = discard_audio (i->first, i->second, *_last_audio_time);
+                       if (!cut.first) {
+                               continue;
+                       }
+                       *i = cut;
+               }
+
                if (_last_audio_time) {
                        fill_audio (DCPTimePeriod (_last_audio_time.get(), i->second));
                }
+
                Audio (i->first, i->second);
                _last_audio_time = i->second + DCPTime::from_frames(i->first->frames(), _film->audio_frame_rate());
        }
@@ -612,8 +617,8 @@ Player::video (weak_ptr<Piece> wp, ContentVideo video)
        DCPTime const time = content_video_to_dcp (piece, video.frame);
        DCPTimePeriod const period (time, time + one_video_frame());
 
-       /* Discard if it's outside the content's period */
-       if (time < piece->content->position() || time >= piece->content->end()) {
+       /* Discard if it's outside the content's period or if it's before the last accurate seek */
+       if (time < piece->content->position() || time >= piece->content->end() || (_last_video_time && time < _last_video_time)) {
                return;
        }
 
@@ -621,21 +626,28 @@ Player::video (weak_ptr<Piece> wp, ContentVideo video)
 
        optional<PositionImage> subtitles;
 
-       for (list<pair<PlayerSubtitles, DCPTimePeriod> >::const_iterator i = _subtitles.begin(); i != _subtitles.end(); ++i) {
+       for (ActiveSubtitles::const_iterator i = _active_subtitles.begin(); i != _active_subtitles.end(); ++i) {
 
-               if (!i->second.overlap (period)) {
+               shared_ptr<Piece> sub_piece = i->first.lock ();
+               if (!sub_piece) {
                        continue;
                }
 
+               if (!sub_piece->content->subtitle->use() || (!_always_burn_subtitles && !piece->content->subtitle->burn())) {
+                       continue;
+               }
+
+               pair<PlayerSubtitles, DCPTime> sub = i->second;
+
                list<PositionImage> sub_images;
 
                /* Image subtitles */
-               list<PositionImage> c = transform_image_subtitles (i->first.image);
+               list<PositionImage> c = transform_image_subtitles (sub.first.image);
                copy (c.begin(), c.end(), back_inserter (sub_images));
 
                /* Text subtitles (rendered to an image) */
-               if (!i->first.text.empty ()) {
-                       list<PositionImage> s = render_subtitles (i->first.text, i->first.fonts, _video_container_size, time);
+               if (!sub.first.text.empty ()) {
+                       list<PositionImage> s = render_subtitles (sub.first.text, sub.first.fonts, _video_container_size, time);
                        copy (s.begin (), s.end (), back_inserter (sub_images));
                }
 
@@ -647,7 +659,7 @@ Player::video (weak_ptr<Piece> wp, ContentVideo video)
        /* Fill gaps */
 
        if (_last_video_time) {
-               fill_video (DCPTimePeriod (_last_video_time.get() + one_video_frame(), time));
+               fill_video (DCPTimePeriod (_last_video_time.get(), time));
        }
 
        _last_video.reset (
@@ -669,22 +681,9 @@ Player::video (weak_ptr<Piece> wp, ContentVideo video)
                _last_video->set_subtitle (subtitles.get ());
        }
 
-       _last_video_time = time;
-
-       Video (_last_video, *_last_video_time);
-
-       /* Discard any subtitles we no longer need */
-
-       for (list<pair<PlayerSubtitles, DCPTimePeriod> >::iterator i = _subtitles.begin (); i != _subtitles.end(); ) {
-               list<pair<PlayerSubtitles, DCPTimePeriod> >::iterator tmp = i;
-               ++tmp;
+       Video (_last_video, time);
 
-               if (i->second.to < time) {
-                       _subtitles.erase (i);
-               }
-
-               i = tmp;
-       }
+       _last_video_time = time + one_video_frame ();
 }
 
 void
@@ -792,17 +791,13 @@ Player::audio (weak_ptr<Piece> wp, AudioStreamPtr stream, ContentAudio content_a
 
        /* Remove anything that comes before the start or after the end of the content */
        if (time < piece->content->position()) {
-               DCPTime const discard_time = piece->content->position() - time;
-               Frame discard_frames = discard_time.frames_round(_film->audio_frame_rate());
-               Frame remaining_frames = content_audio.audio->frames() - discard_frames;
-               if (remaining_frames <= 0) {
+               pair<shared_ptr<AudioBuffers>, DCPTime> cut = discard_audio (content_audio.audio, time, piece->content->position());
+               if (!cut.first) {
                        /* This audio is entirely discarded */
                        return;
                }
-               shared_ptr<AudioBuffers> cut (new AudioBuffers (content_audio.audio->channels(), remaining_frames));
-               cut->copy_from (content_audio.audio.get(), remaining_frames, discard_frames, 0);
-               content_audio.audio = cut;
-               time += discard_time;
+               content_audio.audio = cut.first;
+               time = cut.second;
        } else if (time > piece->content->end()) {
                /* Discard it all */
                return;
@@ -818,7 +813,7 @@ Player::audio (weak_ptr<Piece> wp, AudioStreamPtr stream, ContentAudio content_a
 }
 
 void
-Player::image_subtitle (weak_ptr<Piece> wp, ContentImageSubtitle subtitle)
+Player::image_subtitle_start (weak_ptr<Piece> wp, ContentImageSubtitle subtitle)
 {
        shared_ptr<Piece> piece = wp.lock ();
        if (!piece) {
@@ -839,17 +834,13 @@ Player::image_subtitle (weak_ptr<Piece> wp, ContentImageSubtitle subtitle)
 
        PlayerSubtitles ps;
        ps.image.push_back (subtitle.sub);
-       DCPTimePeriod period (content_time_to_dcp (piece, subtitle.period().from), content_time_to_dcp (piece, subtitle.period().to));
+       DCPTime from (content_time_to_dcp (piece, subtitle.from()));
 
-       if (piece->content->subtitle->use() && (piece->content->subtitle->burn() || _always_burn_subtitles)) {
-               _subtitles.push_back (make_pair (ps, period));
-       } else {
-               Subtitle (ps, period);
-       }
+       _active_subtitles[wp] = make_pair (ps, from);
 }
 
 void
-Player::text_subtitle (weak_ptr<Piece> wp, ContentTextSubtitle subtitle)
+Player::text_subtitle_start (weak_ptr<Piece> wp, ContentTextSubtitle subtitle)
 {
        shared_ptr<Piece> piece = wp.lock ();
        if (!piece) {
@@ -857,7 +848,7 @@ Player::text_subtitle (weak_ptr<Piece> wp, ContentTextSubtitle subtitle)
        }
 
        PlayerSubtitles ps;
-       DCPTimePeriod const period (content_time_to_dcp (piece, subtitle.period().from), content_time_to_dcp (piece, subtitle.period().to));
+       DCPTime const from (content_time_to_dcp (piece, subtitle.from()));
 
        BOOST_FOREACH (dcp::SubtitleString s, subtitle.subs) {
                s.set_h_position (s.h_position() + piece->content->subtitle->x_offset ());
@@ -879,17 +870,31 @@ Player::text_subtitle (weak_ptr<Piece> wp, ContentTextSubtitle subtitle)
                        s.set_aspect_adjust (xs / ys);
                }
 
-               s.set_in (dcp::Time(period.from.seconds(), 1000));
-               s.set_out (dcp::Time(period.to.seconds(), 1000));
+               s.set_in (dcp::Time(from.seconds(), 1000));
                ps.text.push_back (SubtitleString (s, piece->content->subtitle->outline_width()));
                ps.add_fonts (piece->content->subtitle->fonts ());
        }
 
-       if (piece->content->subtitle->use() && (piece->content->subtitle->burn() || _always_burn_subtitles)) {
-               _subtitles.push_back (make_pair (ps, period));
-       } else {
-               Subtitle (ps, period);
+       _active_subtitles[wp] = make_pair (ps, from);
+}
+
+void
+Player::subtitle_stop (weak_ptr<Piece> wp, ContentTime to)
+{
+       if (_active_subtitles.find (wp) == _active_subtitles.end ()) {
+               return;
        }
+
+       shared_ptr<Piece> piece = wp.lock ();
+       if (!piece) {
+               return;
+       }
+
+       if (piece->content->subtitle->use() && !_always_burn_subtitles && !piece->content->subtitle->burn()) {
+               Subtitle (_active_subtitles[wp].first, DCPTimePeriod (_active_subtitles[wp].second, content_time_to_dcp (piece, to)));
+       }
+
+       _active_subtitles.erase (wp);
 }
 
 void
@@ -904,15 +909,26 @@ Player::seek (DCPTime time, bool accurate)
                i->second->reset ();
        }
 
+       _audio_merger.clear ();
+       _active_subtitles.clear ();
+
        BOOST_FOREACH (shared_ptr<Piece> i, _pieces) {
-               i->done = false;
-               if (i->content->position() <= time && time < i->content->end()) {
+               if (time < i->content->position()) {
+                       /* Before; seek to 0 */
+                       i->decoder->seek (ContentTime(), accurate);
+                       i->done = false;
+               } else if (i->content->position() <= time && time < i->content->end()) {
+                       /* During; seek to position */
                        i->decoder->seek (dcp_to_content_time (i, time), accurate);
+                       i->done = false;
+               } else {
+                       /* After; this piece is done */
+                       i->done = true;
                }
        }
 
        if (accurate) {
-               _last_video_time = time - one_video_frame ();
+               _last_video_time = time;
                _last_audio_time = time;
        } else {
                _last_video_time = optional<DCPTime> ();
@@ -985,3 +1001,17 @@ Player::one_video_frame () const
 {
        return DCPTime::from_frames (1, _film->video_frame_rate ());
 }
+
+pair<shared_ptr<AudioBuffers>, DCPTime>
+Player::discard_audio (shared_ptr<const AudioBuffers> audio, DCPTime time, DCPTime discard_to) const
+{
+       DCPTime const discard_time = discard_to - time;
+       Frame const discard_frames = discard_time.frames_round(_film->audio_frame_rate());
+       Frame remaining_frames = audio->frames() - discard_frames;
+       if (remaining_frames <= 0) {
+               return make_pair(shared_ptr<AudioBuffers>(), DCPTime());
+       }
+       shared_ptr<AudioBuffers> cut (new AudioBuffers (audio->channels(), remaining_frames));
+       cut->copy_from (audio.get(), remaining_frames, discard_frames, 0);
+       return make_pair(cut, time + discard_time);
+}