Fix typo in log message.
[dcpomatic.git] / src / lib / content.cc
index 40790bdc09ca84a82d97614c38e056c5a0f4daa2..ed0e9af6db855da97f095d134679dc8c421fd192 100644 (file)
 
 */
 
+
 /** @file  src/lib/content.cc
  *  @brief Content class.
  */
 
-#include "content.h"
+
+#include "audio_content.h"
 #include "change_signaller.h"
-#include "util.h"
+#include "compose.hpp"
+#include "content.h"
 #include "content_factory.h"
-#include "video_content.h"
-#include "audio_content.h"
-#include "text_content.h"
 #include "exceptions.h"
 #include "film.h"
 #include "job.h"
-#include "compose.hpp"
+#include "text_content.h"
+#include "util.h"
+#include "video_content.h"
 #include <dcp/locale_convert.h>
 #include <dcp/raw_convert.h>
 #include <libcxml/cxml.h>
 
 #include "i18n.h"
 
-using std::string;
-using std::list;
+
 using std::cout;
-using std::vector;
-using std::max;
-using std::pair;
+using std::list;
+using std::make_shared;
 using std::shared_ptr;
+using std::string;
+using std::vector;
 using boost::optional;
-using dcp::raw_convert;
 using dcp::locale_convert;
+using dcp::raw_convert;
 using namespace dcpomatic;
 
+
 int const ContentProperty::PATH = 400;
 int const ContentProperty::POSITION = 401;
 int const ContentProperty::LENGTH = 402;
@@ -61,33 +64,29 @@ int const ContentProperty::TRIM_START = 403;
 int const ContentProperty::TRIM_END = 404;
 int const ContentProperty::VIDEO_FRAME_RATE = 405;
 
+
 Content::Content ()
-       : _position (0)
-       , _trim_start (0)
-       , _trim_end (0)
-       , _change_signals_frequent (false)
+       : _change_signals_frequent (false)
 {
 
 }
 
+
 Content::Content (DCPTime p)
        : _position (p)
-       , _trim_start (0)
-       , _trim_end (0)
        , _change_signals_frequent (false)
 {
 
 }
 
+
 Content::Content (boost::filesystem::path p)
-       : _position (0)
-       , _trim_start (0)
-       , _trim_end (0)
-       , _change_signals_frequent (false)
+       : _change_signals_frequent (false)
 {
        add_path (p);
 }
 
+
 Content::Content (cxml::ConstNodePtr node)
        : _change_signals_frequent (false)
 {
@@ -96,10 +95,10 @@ Content::Content (cxml::ConstNodePtr node)
                auto const mod = i->optional_number_attribute<time_t>("mtime");
                if (mod) {
                        _last_write_times.push_back (*mod);
-               } else if (boost::filesystem::exists(i->content())) {
-                       _last_write_times.push_back (boost::filesystem::last_write_time(i->content()));
                } else {
-                       _last_write_times.push_back (0);
+                       boost::system::error_code ec;
+                       auto last_write = boost::filesystem::last_write_time(i->content(), ec);
+                       _last_write_times.push_back (ec ? 0 : last_write);
                }
        }
        _digest = node->optional_string_child ("Digest").get_value_or ("X");
@@ -109,10 +108,11 @@ Content::Content (cxml::ConstNodePtr node)
        _video_frame_rate = node->optional_number_child<double> ("VideoFrameRate");
 }
 
-Content::Content (vector<shared_ptr<Content> > c)
-       : _position (c.front()->position ())
-       , _trim_start (c.front()->trim_start ())
-       , _trim_end (c.back()->trim_end ())
+
+Content::Content (vector<shared_ptr<Content>> c)
+       : _position (c.front()->position())
+       , _trim_start (c.front()->trim_start())
+       , _trim_end (c.back()->trim_end())
        , _video_frame_rate (c.front()->video_frame_rate())
        , _change_signals_frequent (false)
 {
@@ -143,6 +143,7 @@ Content::Content (vector<shared_ptr<Content> > c)
        }
 }
 
+
 void
 Content::as_xml (xmlpp::Node* node, bool with_paths) const
 {
@@ -150,34 +151,32 @@ Content::as_xml (xmlpp::Node* node, bool with_paths) const
 
        if (with_paths) {
                for (size_t i = 0; i < _paths.size(); ++i) {
-                       xmlpp::Element* p = node->add_child("Path");
+                       auto p = node->add_child("Path");
                        p->add_child_text (_paths[i].string());
                        p->set_attribute ("mtime", raw_convert<string>(_last_write_times[i]));
                }
        }
-       node->add_child("Digest")->add_child_text (_digest);
-       node->add_child("Position")->add_child_text (raw_convert<string> (_position.get ()));
-       node->add_child("TrimStart")->add_child_text (raw_convert<string> (_trim_start.get ()));
-       node->add_child("TrimEnd")->add_child_text (raw_convert<string> (_trim_end.get ()));
+       node->add_child("Digest")->add_child_text(_digest);
+       node->add_child("Position")->add_child_text(raw_convert<string>(_position.get()));
+       node->add_child("TrimStart")->add_child_text(raw_convert<string>(_trim_start.get()));
+       node->add_child("TrimEnd")->add_child_text(raw_convert<string>(_trim_end.get()));
        if (_video_frame_rate) {
-               node->add_child("VideoFrameRate")->add_child_text (raw_convert<string> (_video_frame_rate.get()));
+               node->add_child("VideoFrameRate")->add_child_text(raw_convert<string>(_video_frame_rate.get()));
        }
 }
 
+
 string
 Content::calculate_digest () const
 {
-       boost::mutex::scoped_lock lm (_mutex);
-       auto p = _paths;
-       lm.unlock ();
-
        /* Some content files are very big, so we use a poor man's
           digest here: a digest of the first and last 1e6 bytes with the
           size of the first file tacked on the end as a string.
        */
-       return digest_head_tail(p, 1000000) + raw_convert<string>(boost::filesystem::file_size(p.front()));
+       return simple_digest (paths());
 }
 
+
 void
 Content::examine (shared_ptr<const Film>, shared_ptr<Job> job)
 {
@@ -192,10 +191,13 @@ Content::examine (shared_ptr<const Film>, shared_ptr<Job> job)
 
        _last_write_times.clear ();
        for (auto i: _paths) {
-               _last_write_times.push_back (boost::filesystem::last_write_time(i));
+               boost::system::error_code ec;
+               auto last_write = boost::filesystem::last_write_time(i, ec);
+               _last_write_times.push_back (ec ? 0 : last_write);
        }
 }
 
+
 void
 Content::signal_change (ChangeType c, int p)
 {
@@ -210,6 +212,7 @@ Content::signal_change (ChangeType c, int p)
        }
 }
 
+
 void
 Content::set_position (shared_ptr<const Film> film, DCPTime p, bool force_emit)
 {
@@ -229,7 +232,7 @@ Content::set_position (shared_ptr<const Film> film, DCPTime p, bool force_emit)
                audio->modify_position (film, p);
        }
 
-       ChangeSignaller<Content> cc (this, ContentProperty::POSITION);
+       ContentChangeSignaller cc (this, ContentProperty::POSITION);
 
        {
                boost::mutex::scoped_lock lm (_mutex);
@@ -242,9 +245,12 @@ Content::set_position (shared_ptr<const Film> film, DCPTime p, bool force_emit)
        }
 }
 
+
 void
 Content::set_trim_start (ContentTime t)
 {
+       DCPOMATIC_ASSERT (t.get() >= 0);
+
        /* video and audio content can modify its start trim */
 
        if (video) {
@@ -256,7 +262,7 @@ Content::set_trim_start (ContentTime t)
                audio->modify_trim_start (t);
        }
 
-       ChangeSignaller<Content> cc (this, ContentProperty::TRIM_START);
+       ContentChangeSignaller cc (this, ContentProperty::TRIM_START);
 
        {
                boost::mutex::scoped_lock lm (_mutex);
@@ -264,10 +270,13 @@ Content::set_trim_start (ContentTime t)
        }
 }
 
+
 void
 Content::set_trim_end (ContentTime t)
 {
-       ChangeSignaller<Content> cc (this, ContentProperty::TRIM_END);
+       DCPOMATIC_ASSERT (t.get() >= 0);
+
+       ContentChangeSignaller cc (this, ContentProperty::TRIM_END);
 
        {
                boost::mutex::scoped_lock lm (_mutex);
@@ -286,9 +295,10 @@ Content::clone () const
 
        /* notes is unused here (we assume) */
        list<string> notes;
-       return content_factory (cxml::NodePtr(new cxml::Node(node)), Film::current_state_version, notes);
+       return content_factory (make_shared<cxml::Node>(node), Film::current_state_version, notes);
 }
 
+
 string
 Content::technical_summary () const
 {
@@ -299,6 +309,7 @@ Content::technical_summary () const
        return s;
 }
 
+
 DCPTime
 Content::length_after_trim (shared_ptr<const Film> film) const
 {
@@ -309,6 +320,7 @@ Content::length_after_trim (shared_ptr<const Film> film) const
        return length;
 }
 
+
 /** @return string which changes when something about this content changes which affects
  *  the appearance of its video.
  */
@@ -323,6 +335,7 @@ Content::identifier () const
        return buffer;
 }
 
+
 bool
 Content::paths_valid () const
 {
@@ -335,21 +348,25 @@ Content::paths_valid () const
        return true;
 }
 
+
 void
 Content::set_paths (vector<boost::filesystem::path> paths)
 {
-       ChangeSignaller<Content> cc (this, ContentProperty::PATH);
+       ContentChangeSignaller cc (this, ContentProperty::PATH);
 
        {
                boost::mutex::scoped_lock lm (_mutex);
                _paths = paths;
                _last_write_times.clear ();
                for (auto i: _paths) {
-                       _last_write_times.push_back (boost::filesystem::last_write_time(i));
+                       boost::system::error_code ec;
+                       auto last_write = boost::filesystem::last_write_time(i, ec);
+                       _last_write_times.push_back (ec ? 0 : last_write);
                }
        }
 }
 
+
 string
 Content::path_summary () const
 {
@@ -365,6 +382,7 @@ Content::path_summary () const
        return s;
 }
 
+
 /** @return a list of properties that might be interesting to the user */
 list<UserProperty>
 Content::user_properties (shared_ptr<const Film> film) const
@@ -374,6 +392,7 @@ Content::user_properties (shared_ptr<const Film> film) const
        return p;
 }
 
+
 /** @return DCP times of points within this content where a reel split could occur */
 list<DCPTime>
 Content::reel_split_points (shared_ptr<const Film>) const
@@ -386,10 +405,11 @@ Content::reel_split_points (shared_ptr<const Film>) const
        return t;
 }
 
+
 void
 Content::set_video_frame_rate (double r)
 {
-       ChangeSignaller<Content> cc (this, ContentProperty::VIDEO_FRAME_RATE);
+       ContentChangeSignaller cc (this, ContentProperty::VIDEO_FRAME_RATE);
 
        {
                boost::mutex::scoped_lock lm (_mutex);
@@ -405,10 +425,11 @@ Content::set_video_frame_rate (double r)
        }
 }
 
+
 void
 Content::unset_video_frame_rate ()
 {
-       ChangeSignaller<Content> cc (this, ContentProperty::VIDEO_FRAME_RATE);
+       ContentChangeSignaller cc (this, ContentProperty::VIDEO_FRAME_RATE);
 
        {
                boost::mutex::scoped_lock lm (_mutex);
@@ -416,6 +437,7 @@ Content::unset_video_frame_rate ()
        }
 }
 
+
 double
 Content::active_video_frame_rate (shared_ptr<const Film> film) const
 {
@@ -433,10 +455,28 @@ Content::active_video_frame_rate (shared_ptr<const Film> film) const
        return film->active_frame_rate_change(position()).source;
 }
 
+
 void
 Content::add_properties (shared_ptr<const Film>, list<UserProperty>& p) const
 {
-       p.push_back (UserProperty (UserProperty::GENERAL, _("Filename"), path(0).string ()));
+       auto paths_to_show = std::min(number_of_paths(), size_t{8});
+       string paths = "";
+       for (auto i = size_t{0}; i < paths_to_show; ++i) {
+               paths += path(i).string();
+               if (i < (paths_to_show - 1)) {
+                       paths += "\n";
+               }
+       }
+       if (paths_to_show < number_of_paths()) {
+               paths += String::compose("... and %1 more", number_of_paths() - paths_to_show);
+       }
+       p.push_back (
+               UserProperty(
+                       UserProperty::GENERAL,
+                       paths_to_show > 1 ? _("Filenames") : _("Filename"),
+                       paths
+                       )
+               );
 
        if (_video_frame_rate) {
                if (video) {
@@ -461,6 +501,7 @@ Content::add_properties (shared_ptr<const Film>, list<UserProperty>& p) const
        }
 }
 
+
 /** Take settings from the given content if it is of the correct type */
 void
 Content::take_settings_from (shared_ptr<const Content> c)
@@ -481,16 +522,18 @@ Content::take_settings_from (shared_ptr<const Content> c)
        }
 }
 
+
 shared_ptr<TextContent>
 Content::only_text () const
 {
        DCPOMATIC_ASSERT (text.size() < 2);
-       if (text.empty ()) {
-               return shared_ptr<TextContent> ();
+       if (text.empty()) {
+               return {};
        }
        return text.front ();
 }
 
+
 shared_ptr<TextContent>
 Content::text_of_original_type (TextType type) const
 {
@@ -500,13 +543,31 @@ Content::text_of_original_type (TextType type) const
                }
        }
 
-       return shared_ptr<TextContent> ();
+       return {};
 }
 
+
 void
 Content::add_path (boost::filesystem::path p)
 {
        boost::mutex::scoped_lock lm (_mutex);
        _paths.push_back (p);
-       _last_write_times.push_back (boost::filesystem::last_write_time(p));
+       boost::system::error_code ec;
+       auto last_write = boost::filesystem::last_write_time(p, ec);
+       _last_write_times.push_back (ec ? 0 : last_write);
+}
+
+
+bool
+Content::changed () const
+{
+       bool write_time_changed = false;
+       for (auto i = 0U; i < _paths.size(); ++i) {
+               if (boost::filesystem::last_write_time(_paths[i]) != last_write_time(i)) {
+                       write_time_changed = true;
+                       break;
+               }
+       }
+
+       return (write_time_changed || calculate_digest() != digest());
 }