X-Git-Url: https://git.carlh.net/gitweb/?a=blobdiff_plain;f=src%2Flib%2Fplaylist.cc;h=de48ff5f5cd0d49bb31a2691a437c4f825eddf38;hb=1ba7bca7f2950faa441ec83920d35b65016f3fa6;hp=717c1daceacbc7c2945c35eedb7c14b06f3cb142;hpb=8f1c131a933e7695684e22eb82abba30fe119915;p=dcpomatic.git diff --git a/src/lib/playlist.cc b/src/lib/playlist.cc index 717c1dace..de48ff5f5 100644 --- a/src/lib/playlist.cc +++ b/src/lib/playlist.cc @@ -17,259 +17,314 @@ */ +#include #include +#include #include "playlist.h" #include "sndfile_content.h" #include "sndfile_decoder.h" #include "video_content.h" #include "ffmpeg_decoder.h" #include "ffmpeg_content.h" -#include "imagemagick_decoder.h" +#include "still_image_decoder.h" +#include "still_image_content.h" +#include "content_factory.h" #include "job.h" +#include "config.h" +#include "util.h" + +#include "i18n.h" using std::list; using std::cout; using std::vector; using std::min; using std::max; +using std::string; +using std::stringstream; +using std::pair; +using boost::optional; using boost::shared_ptr; using boost::weak_ptr; using boost::dynamic_pointer_cast; +using boost::lexical_cast; Playlist::Playlist () - : _audio_from (AUDIO_FFMPEG) + : _sequence_video (true) + , _sequencing_video (false) { } -void -Playlist::setup (ContentList content) +Playlist::~Playlist () { - _audio_from = AUDIO_FFMPEG; - - _video.clear (); - _sndfile.clear (); + _content.clear (); + reconnect (); +} - for (list::iterator i = _content_connections.begin(); i != _content_connections.end(); ++i) { - i->disconnect (); +void +Playlist::content_changed (weak_ptr content, int property, bool frequent) +{ + if (property == ContentProperty::LENGTH) { + maybe_sequence_video (); } - _content_connections.clear (); + ContentChanged (content, property, frequent); +} - for (ContentList::const_iterator i = content.begin(); i != content.end(); ++i) { - shared_ptr vc = dynamic_pointer_cast (*i); - if (vc) { - _video.push_back (vc); +void +Playlist::maybe_sequence_video () +{ + if (!_sequence_video || _sequencing_video) { + return; + } + + _sequencing_video = true; + + ContentList cl = _content; + sort (cl.begin(), cl.end(), ContentSorter ()); + Time last = 0; + for (ContentList::iterator i = cl.begin(); i != cl.end(); ++i) { + if (!dynamic_pointer_cast (*i)) { + continue; } - shared_ptr sc = dynamic_pointer_cast (*i); - if (sc) { - _sndfile.push_back (sc); - _audio_from = AUDIO_SNDFILE; + (*i)->set_position (last); + last = (*i)->end (); + } + + _sequencing_video = false; +} + +string +Playlist::video_identifier () const +{ + string t; + + for (ContentList::const_iterator i = _content.begin(); i != _content.end(); ++i) { + shared_ptr vc = dynamic_pointer_cast (*i); + if (vc) { + t += vc->identifier (); } + } + + return md5_digest (t.c_str(), t.length()); +} - _content_connections.push_back ((*i)->Changed.connect (bind (&Playlist::content_changed, this, _1, _2))); +/** @param node node */ +void +Playlist::set_from_xml (shared_ptr film, shared_ptr node) +{ + list > c = node->node_children ("Content"); + for (list >::iterator i = c.begin(); i != c.end(); ++i) { + _content.push_back (content_factory (film, *i)); } - Changed (); + reconnect (); } -ContentAudioFrame -Playlist::audio_length () const +/** @param node node */ +void +Playlist::as_xml (xmlpp::Node* node) { - ContentAudioFrame len = 0; - - switch (_audio_from) { - case AUDIO_FFMPEG: - for (list >::const_iterator i = _video.begin(); i != _video.end(); ++i) { - shared_ptr fc = dynamic_pointer_cast (*i); - if (fc) { - len += fc->audio_length (); - } - } - break; - case AUDIO_SNDFILE: - for (list >::const_iterator i = _sndfile.begin(); i != _sndfile.end(); ++i) { - len += (*i)->audio_length (); - } - break; + for (ContentList::iterator i = _content.begin(); i != _content.end(); ++i) { + (*i)->as_xml (node->add_child ("Content")); } +} - return len; +void +Playlist::add (shared_ptr c) +{ + _content.push_back (c); + reconnect (); + Changed (); } -int -Playlist::audio_channels () const +void +Playlist::remove (shared_ptr c) { - int channels = 0; + ContentList::iterator i = _content.begin (); + while (i != _content.end() && *i != c) { + ++i; + } - switch (_audio_from) { - case AUDIO_FFMPEG: - for (list >::const_iterator i = _video.begin(); i != _video.end(); ++i) { - shared_ptr fc = dynamic_pointer_cast (*i); - if (fc) { - channels = max (channels, fc->audio_channels ()); - } - } - break; - case AUDIO_SNDFILE: - for (list >::const_iterator i = _sndfile.begin(); i != _sndfile.end(); ++i) { - channels += (*i)->audio_channels (); - } - break; + if (i != _content.end ()) { + _content.erase (i); + Changed (); } - - return channels; } -int -Playlist::audio_frame_rate () const +void +Playlist::remove (ContentList c) { - /* XXX: assuming that all content has the same rate */ + for (ContentList::iterator i = c.begin(); i != c.end(); ++i) { + ContentList::iterator j = _content.begin (); + while (j != _content.end() && *j != *i) { + ++j; + } - switch (_audio_from) { - case AUDIO_FFMPEG: - { - shared_ptr fc = first_ffmpeg (); - if (fc) { - return fc->audio_frame_rate (); + if (j != _content.end ()) { + _content.erase (j); } - break; - } - case AUDIO_SNDFILE: - return _sndfile.front()->audio_frame_rate (); } - return 0; + Changed (); } -int64_t -Playlist::audio_channel_layout () const +bool +Playlist::has_subtitles () const { - /* XXX: assuming that all content has the same layout */ - - switch (_audio_from) { - case AUDIO_FFMPEG: - { - shared_ptr fc = first_ffmpeg (); - if (fc) { - return fc->audio_channel_layout (); + for (ContentList::const_iterator i = _content.begin(); i != _content.end(); ++i) { + shared_ptr fc = dynamic_pointer_cast (*i); + if (fc && !fc->subtitle_streams().empty()) { + return true; } - break; - } - case AUDIO_SNDFILE: - /* XXX */ - return 0; } - return 0; + return false; } -float -Playlist::video_frame_rate () const +class FrameRateCandidate +{ +public: + FrameRateCandidate (float source_, int dcp_) + : source (source_) + , dcp (dcp_) + {} + + float source; + int dcp; +}; + +int +Playlist::best_dcp_frame_rate () const { - if (_video.empty ()) { - return 0; + list const allowed_dcp_frame_rates = Config::instance()->allowed_dcp_frame_rates (); + + /* Work out what rates we could manage, including those achieved by using skip / repeat. */ + list candidates; + + /* Start with the ones without skip / repeat so they will get matched in preference to skipped/repeated ones */ + for (list::const_iterator i = allowed_dcp_frame_rates.begin(); i != allowed_dcp_frame_rates.end(); ++i) { + candidates.push_back (FrameRateCandidate (*i, *i)); + } + + /* Then the skip/repeat ones */ + for (list::const_iterator i = allowed_dcp_frame_rates.begin(); i != allowed_dcp_frame_rates.end(); ++i) { + candidates.push_back (FrameRateCandidate (float (*i) / 2, *i)); + candidates.push_back (FrameRateCandidate (float (*i) * 2, *i)); + } + + /* Pick the best one */ + float error = std::numeric_limits::max (); + optional best; + list::iterator i = candidates.begin(); + while (i != candidates.end()) { + + float this_error = 0; + for (ContentList::const_iterator j = _content.begin(); j != _content.end(); ++j) { + shared_ptr vc = dynamic_pointer_cast (*j); + if (!vc) { + continue; + } + + /* Use the largest difference between DCP and source as the "error" */ + this_error = max (this_error, float (fabs (i->source - vc->video_frame_rate ()))); + } + + if (this_error < error) { + error = this_error; + best = *i; + } + + ++i; + } + + if (!best) { + return 24; } - /* XXX: assuming all the same */ - return _video.front()->video_frame_rate (); + return best->dcp; } -libdcp::Size -Playlist::video_size () const +Time +Playlist::length () const { - if (_video.empty ()) { - return libdcp::Size (); + Time len = 0; + for (ContentList::const_iterator i = _content.begin(); i != _content.end(); ++i) { + len = max (len, (*i)->end ()); } - /* XXX: assuming all the same */ - return _video.front()->video_size (); + return len; } -ContentVideoFrame -Playlist::video_length () const +void +Playlist::reconnect () { - ContentVideoFrame len = 0; - for (list >::const_iterator i = _video.begin(); i != _video.end(); ++i) { - len += (*i)->video_length (); + for (list::iterator i = _content_connections.begin(); i != _content_connections.end(); ++i) { + i->disconnect (); + } + + _content_connections.clear (); + + for (ContentList::iterator i = _content.begin(); i != _content.end(); ++i) { + _content_connections.push_back ((*i)->Changed.connect (bind (&Playlist::content_changed, this, _1, _2, _3))); } - - return len; } -bool -Playlist::has_audio () const +Time +Playlist::video_end () const { - /* XXX */ - return true; + Time end = 0; + for (ContentList::const_iterator i = _content.begin(); i != _content.end(); ++i) { + if (dynamic_pointer_cast (*i)) { + end = max (end, (*i)->end ()); + } + } + + return end; } void -Playlist::content_changed (weak_ptr c, int p) +Playlist::set_sequence_video (bool s) { - ContentChanged (c, p); + _sequence_video = s; } -shared_ptr -Playlist::first_ffmpeg () const +bool +ContentSorter::operator() (shared_ptr a, shared_ptr b) { - for (list >::const_iterator i = _video.begin(); i != _video.end(); ++i) { - shared_ptr fc = dynamic_pointer_cast (*i); - if (fc) { - return fc; - } - } + return a->position() < b->position(); +} - return shared_ptr (); +/** @return content in an undefined order */ +ContentList +Playlist::content () const +{ + return _content; } - -AudioMapping -Playlist::default_audio_mapping () const +void +Playlist::repeat (ContentList c, int n) { - AudioMapping m; - - switch (_audio_from) { - case AUDIO_FFMPEG: - { - shared_ptr fc = first_ffmpeg (); - if (!fc) { - break; - } - - /* XXX: assumes all the same */ - if (fc->audio_channels() == 1) { - /* Map mono sources to centre */ - m.add (AudioMapping::Channel (fc, 0), libdcp::CENTRE); - } else { - int const N = min (fc->audio_channels (), MAX_AUDIO_CHANNELS); - /* Otherwise just start with a 1:1 mapping */ - for (int i = 0; i < N; ++i) { - m.add (AudioMapping::Channel (fc, i), (libdcp::Channel) i); - } - } - break; + pair range (TIME_MAX, 0); + for (ContentList::iterator i = c.begin(); i != c.end(); ++i) { + range.first = min (range.first, (*i)->position ()); + range.second = max (range.second, (*i)->position ()); + range.first = min (range.first, (*i)->end ()); + range.second = max (range.second, (*i)->end ()); } - case AUDIO_SNDFILE: - { - int n = 0; - for (list >::const_iterator i = _sndfile.begin(); i != _sndfile.end(); ++i) { - for (int j = 0; j < (*i)->audio_channels(); ++j) { - m.add (AudioMapping::Channel (*i, j), (libdcp::Channel) n); - ++n; - if (n >= MAX_AUDIO_CHANNELS) { - break; - } - } - if (n >= MAX_AUDIO_CHANNELS) { - break; - } + Time pos = range.second; + for (int i = 0; i < n; ++i) { + for (ContentList::iterator i = c.begin(); i != c.end(); ++i) { + shared_ptr copy = (*i)->clone (); + copy->set_position (pos + copy->position() - range.first); + _content.push_back (copy); } - break; - } + pos += range.second - range.first; } - return m; + reconnect (); + Changed (); }