-0e86c9ee06ab902e4a59ca7e866d7df5bfa29cc5
aa3c14f5093f8c228bc9763d601dc6f4aafd1a0a
3cee9121d9cda951e3fb15a53a792b682a27a01b
e48f13a1fc46fb469417d602acfe4b3fa57d5aa2
Content::examine (job, calculate_digest);
- shared_ptr<FFmpegExaminer> examiner (new FFmpegExaminer (shared_from_this ()));
+ shared_ptr<FFmpegExaminer> examiner (new FFmpegExaminer (shared_from_this (), job));
take_from_video_examiner (examiner);
shared_ptr<const Film> film = _film.lock ();
}
#include "ffmpeg_examiner.h"
#include "ffmpeg_content.h"
+#include "job.h"
#include "ffmpeg_audio_stream.h"
#include "ffmpeg_subtitle_stream.h"
#include "util.h"
using boost::shared_ptr;
using boost::optional;
-FFmpegExaminer::FFmpegExaminer (shared_ptr<const FFmpegContent> c)
+/** @param job job that the examiner is operating in, or 0 */
+FFmpegExaminer::FFmpegExaminer (shared_ptr<const FFmpegContent> c, shared_ptr<Job> job)
: FFmpeg (c)
, _need_video_length (false)
{
_need_video_length = _format_context->duration == AV_NOPTS_VALUE;
if (!_need_video_length) {
_video_length = ContentTime::from_seconds (double (_format_context->duration) / AV_TIME_BASE);
+ } else if (job) {
+ job->sub (_("Finding length"));
+ job->set_progress_unknown ();
}
/* Run through until we find:
/*
- Copyright (C) 2013 Carl Hetherington <cth@carlh.net>
+ Copyright (C) 2013-2015 Carl Hetherington <cth@carlh.net>
This program is free software; you can redistribute it and/or modify
it under the terms of the GNU General Public License as published by
class FFmpegExaminer : public FFmpeg, public VideoExaminer
{
public:
- FFmpegExaminer (boost::shared_ptr<const FFmpegContent>);
+ FFmpegExaminer (boost::shared_ptr<const FFmpegContent>, boost::shared_ptr<Job> job = boost::shared_ptr<Job> ());
boost::optional<float> video_frame_rate () const;
dcp::Size video_size () const;
/*
- Copyright (C) 2012-2014 Carl Hetherington <cth@carlh.net>
+ Copyright (C) 2012-2015 Carl Hetherington <cth@carlh.net>
This program is free software; you can redistribute it and/or modify
it under the terms of the GNU General Public License as published by
using std::list;
using std::cout;
using boost::shared_ptr;
+using boost::optional;
#define LOG_ERROR_NC(...) _film->log()->log (__VA_ARGS__, Log::TYPE_ERROR);
void
Job::set_progress (float p, bool force)
{
- if (!force && fabs (p - progress()) < 0.01) {
+ if (!force && fabs (p - progress().get_value_or(0)) < 0.01) {
/* Calm excessive progress reporting */
return;
}
}
}
-/** @return fractional progress of the current sub-job, or -1 if not known */
-float
+/** @return fractional progress of the current sub-job, if known */
+optional<float>
Job::progress () const
{
boost::mutex::scoped_lock lm (_progress_mutex);
- return _progress.get_value_or (-1);
+ return _progress;
}
void
{
boost::mutex::scoped_lock lm (_progress_mutex);
_progress.reset ();
+ lm.unlock ();
+
+ if (ui_signaller) {
+ ui_signaller->emit (boost::bind (boost::ref (Progress)));
+ }
}
/** @return Human-readable status of this job */
string
Job::status () const
{
- float const p = progress ();
+ optional<float> p = progress ();
int const t = elapsed_time ();
int const r = remaining_time ();
- int pc = rint (p * 100);
- if (pc == 100) {
- /* 100% makes it sound like we've finished when we haven't */
- pc = 99;
- }
-
SafeStringStream s;
- if (!finished ()) {
+ if (!finished () && p) {
+ int pc = rint (p.get() * 100);
+ if (pc == 100) {
+ /* 100% makes it sound like we've finished when we haven't */
+ pc = 99;
+ }
+
s << pc << N_("%");
- if (p >= 0 && t > 10 && r > 0) {
+
+ if (t > 10 && r > 0) {
/// TRANSLATORS: remaining here follows an amount of time that is remaining
/// on an operation.
s << "; " << seconds_to_approximate_hms (r) << " " << _("remaining");
int
Job::remaining_time () const
{
- return elapsed_time() / progress() - elapsed_time();
+ if (progress().get_value_or(0) == 0) {
+ return elapsed_time ();
+ }
+
+ return elapsed_time() / progress().get() - elapsed_time();
}
void
void set_progress_unknown ();
void set_progress (float, bool force = false);
void sub (std::string);
- float progress () const;
- bool progress_unknown () const {
- return !_progress;
- }
+ boost::optional<float> progress () const;
boost::shared_ptr<const Film> film () const {
return _film;
if (progress) {
cout << (*i)->name() << ": ";
- float const p = (*i)->progress ();
-
- if (p >= 0) {
+ if ((*i)->progress ()) {
cout << (*i)->status() << " \n";
} else {
cout << ": Running \n";
/*
- Copyright (C) 2012 Carl Hetherington <cth@carlh.net>
+ Copyright (C) 2012-2015 Carl Hetherington <cth@carlh.net>
This program is free software; you can redistribute it and/or modify
it under the terms of the GNU General Public License as published by
void maybe_pulse ()
{
- if (_job->running() && _job->progress_unknown ()) {
+ if (_job->running() && !_job->progress ()) {
_gauge->Pulse ();
}
}
void progress ()
{
- float const p = _job->progress ();
- if (p >= 0) {
- checked_set (_message, _job->status ());
- update_job_name ();
- int const pp = min (100.0f, p * 100);
- _gauge->SetValue (pp);
- }
-
+ checked_set (_message, _job->status ());
+ update_job_name ();
+ if (_job->progress ()) {
+ _gauge->SetValue (min (100.0f, _job->progress().get() * 100));
+ }
_table->Layout ();
_window->FitInside ();
}