void
Playlist::maybe_sequence_video ()
{
+ boost::mutex::scoped_lock lm (_mutex);
+
if (!_sequence_video || _sequencing_video) {
return;
}
string
Playlist::video_identifier () const
{
+ boost::mutex::scoped_lock lm (_mutex);
+
string t;
for (ContentList::const_iterator i = _content.begin(); i != _content.end(); ++i) {
void
Playlist::set_from_xml (shared_ptr<const Film> film, shared_ptr<const cxml::Node> node)
{
+ boost::mutex::scoped_lock lm (_mutex);
+
list<shared_ptr<cxml::Node> > c = node->node_children ("Content");
for (list<shared_ptr<cxml::Node> >::iterator i = c.begin(); i != c.end(); ++i) {
_content.push_back (content_factory (film, *i));
void
Playlist::as_xml (xmlpp::Node* node)
{
+ boost::mutex::scoped_lock lm (_mutex);
+
for (ContentList::iterator i = _content.begin(); i != _content.end(); ++i) {
(*i)->as_xml (node->add_child ("Content"));
}
void
Playlist::add (shared_ptr<Content> c)
{
- _content.push_back (c);
- reconnect ();
+ {
+ boost::mutex::scoped_lock lm (_mutex);
+ _content.push_back (c);
+ reconnect ();
+ }
+
Changed ();
}
void
Playlist::remove (shared_ptr<Content> c)
{
- ContentList::iterator i = _content.begin ();
- while (i != _content.end() && *i != c) {
- ++i;
- }
+ bool changed = false;
- if (i != _content.end ()) {
- _content.erase (i);
+ {
+ boost::mutex::scoped_lock lm (_mutex);
+ ContentList::iterator i = _content.begin ();
+ while (i != _content.end() && *i != c) {
+ ++i;
+ }
+
+ if (i != _content.end ()) {
+ _content.erase (i);
+ reconnect ();
+ changed = true;
+ }
+ }
+
+ if (changed) {
Changed ();
}
}
void
Playlist::remove (ContentList c)
{
- for (ContentList::iterator i = c.begin(); i != c.end(); ++i) {
- ContentList::iterator j = _content.begin ();
- while (j != _content.end() && *j != *i) {
- ++j;
+ bool changed = false;
+
+ {
+ boost::mutex::scoped_lock lm (_mutex);
+ for (ContentList::iterator i = c.begin(); i != c.end(); ++i) {
+ ContentList::iterator j = _content.begin ();
+ while (j != _content.end() && *j != *i) {
+ ++j;
+ }
+
+ if (j != _content.end ()) {
+ _content.erase (j);
+ changed = true;
+ }
}
-
- if (j != _content.end ()) {
- _content.erase (j);
+
+ if (changed) {
+ reconnect ();
}
}
- Changed ();
+ if (changed) {
+ Changed ();
+ }
}
bool
Playlist::has_subtitles () const
{
+ boost::mutex::scoped_lock lm (_mutex);
+
for (ContentList::const_iterator i = _content.begin(); i != _content.end(); ++i) {
shared_ptr<const FFmpegContent> fc = dynamic_pointer_cast<FFmpegContent> (*i);
if (fc && !fc->subtitle_streams().empty()) {
int
Playlist::best_dcp_frame_rate () const
{
+ boost::mutex::scoped_lock lm (_mutex);
+
list<int> 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. */
Time
Playlist::length () const
{
+ boost::mutex::scoped_lock lm (_mutex);
+
Time len = 0;
for (ContentList::const_iterator i = _content.begin(); i != _content.end(); ++i) {
len = max (len, (*i)->end ());
return len;
}
+/* Caller must hold a lock on _mutex */
void
Playlist::reconnect ()
{
Time
Playlist::video_end () const
{
+ boost::mutex::scoped_lock lm (_mutex);
+
Time end = 0;
for (ContentList::const_iterator i = _content.begin(); i != _content.end(); ++i) {
if (dynamic_pointer_cast<const VideoContent> (*i)) {
void
Playlist::set_sequence_video (bool s)
{
+ boost::mutex::scoped_lock lm (_mutex);
_sequence_video = s;
}
ContentList
Playlist::content () const
{
+ boost::mutex::scoped_lock lm (_mutex);
return _content;
}
void
Playlist::repeat (ContentList c, int n)
{
- pair<Time, Time> 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 ());
- }
-
- Time pos = range.second;
- for (int i = 0; i < n; ++i) {
+ {
+ boost::mutex::scoped_lock lm (_mutex);
+ pair<Time, Time> range (TIME_MAX, 0);
for (ContentList::iterator i = c.begin(); i != c.end(); ++i) {
- shared_ptr<Content> copy = (*i)->clone ();
- copy->set_position (pos + copy->position() - range.first);
- _content.push_back (copy);
+ 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 ());
+ }
+
+ Time pos = range.second;
+ for (int i = 0; i < n; ++i) {
+ for (ContentList::iterator i = c.begin(); i != c.end(); ++i) {
+ shared_ptr<Content> copy = (*i)->clone ();
+ copy->set_position (pos + copy->position() - range.first);
+ _content.push_back (copy);
+ }
+ pos += range.second - range.first;
}
- pos += range.second - range.first;
+
+ reconnect ();
}
-
- reconnect ();
+
Changed ();
}