X-Git-Url: https://git.carlh.net/gitweb/?a=blobdiff_plain;f=src%2Flib%2Fcheck_hashes_job.cc;h=478e4c91afc4649b995fcb5c74ba3686564ba8d5;hb=cbaed1119cdf3acb8662e5240f59706722437d94;hp=d64ccc866b921412dfc45d99729a35651322781b;hpb=d6e74fb7dbc5b01c9ce42f8fe780bb16262d13b1;p=dcpomatic.git diff --git a/src/lib/check_hashes_job.cc b/src/lib/check_hashes_job.cc index d64ccc866..478e4c91a 100644 --- a/src/lib/check_hashes_job.cc +++ b/src/lib/check_hashes_job.cc @@ -32,7 +32,8 @@ using namespace std; using namespace boost; CheckHashesJob::CheckHashesJob (shared_ptr s, shared_ptr o, Log* l, shared_ptr req) - : Job (s, o, l, req) + : Job (s, l, req) + , _opt (o) , _bad (0) { @@ -55,15 +56,24 @@ CheckHashesJob::run () string const j2k_file = _opt->frame_out_path (i, false); string const hash_file = j2k_file + ".md5"; - ifstream ref (hash_file.c_str ()); - string hash; - ref >> hash; - - if (hash != md5_digest (j2k_file)) { - _log->log ("Frame " + lexical_cast (i) + " has wrong hash; deleting."); - filesystem::remove (j2k_file); + if (!filesystem::exists (j2k_file)) { + _log->log (String::compose ("Frame %1 has a missing J2K file.", i)); filesystem::remove (hash_file); ++_bad; + } else if (!filesystem::exists (hash_file)) { + _log->log (String::compose ("Frame %1 has a missing hash file.", i)); + filesystem::remove (j2k_file); + ++_bad; + } else { + ifstream ref (hash_file.c_str ()); + string hash; + ref >> hash; + if (hash != md5_digest (j2k_file)) { + _log->log (String::compose ("Frame %1 has wrong hash; deleting.", i)); + filesystem::remove (j2k_file); + filesystem::remove (hash_file); + ++_bad; + } } set_progress (float (i) / _fs->length());