X-Git-Url: https://main.carlh.net/gitweb/?a=blobdiff_plain;f=src%2Flib%2Fupload_job.cc;h=113e3a7e88bd8740456b6e8a30b7ace771f38621;hb=2b92a5fbae6ae11d6d751470b4a44252067ad077;hp=44114b8a89c45c731c0cc1cdb7aac3a20123d31b;hpb=1d5462ef8d6a32b964f0335e3dd68aac31075d14;p=dcpomatic.git diff --git a/src/lib/upload_job.cc b/src/lib/upload_job.cc index 44114b8a8..113e3a7e8 100644 --- a/src/lib/upload_job.cc +++ b/src/lib/upload_job.cc @@ -1,43 +1,50 @@ /* - Copyright (C) 2012-2015 Carl Hetherington + Copyright (C) 2012-2021 Carl Hetherington - This program is free software; you can redistribute it and/or modify + This file is part of DCP-o-matic. + + DCP-o-matic is free software; you can redistribute it and/or modify it under the terms of the GNU General Public License as published by the Free Software Foundation; either version 2 of the License, or (at your option) any later version. - This program is distributed in the hope that it will be useful, + DCP-o-matic is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for more details. You should have received a copy of the GNU General Public License - along with this program; if not, write to the Free Software - Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA. + along with DCP-o-matic. If not, see . */ + /** @file src/upload_job.cc * @brief A job to copy DCPs to a server using libcurl. */ + #include "compose.hpp" -#include "upload_job.h" #include "config.h" -#include "log.h" +#include "curl_uploader.h" +#include "dcpomatic_log.h" #include "film.h" +#include "log.h" #include "scp_uploader.h" -#include "curl_uploader.h" +#include "upload_job.h" #include #include "i18n.h" -#define LOG_GENERAL_NC(...) _film->log()->log (__VA_ARGS__, Log::TYPE_GENERAL); using std::string; using std::min; -using boost::shared_ptr; +using std::shared_ptr; using boost::scoped_ptr; +#if BOOST_VERSION >= 106100 +using namespace boost::placeholders; +#endif + UploadJob::UploadJob (shared_ptr film) : Job (film) @@ -46,51 +53,62 @@ UploadJob::UploadJob (shared_ptr film) } + +UploadJob::~UploadJob () +{ + stop_thread (); +} + + string UploadJob::name () const { return _("Copy DCP to TMS"); } + string UploadJob::json_name () const { return N_("upload"); } + void UploadJob::run () { LOG_GENERAL_NC (N_("Upload job starting")); scoped_ptr uploader; - switch (Config::instance()->tms_protocol ()) { - case PROTOCOL_SCP: - uploader.reset (new SCPUploader (bind (&UploadJob::set_status, this, _1), bind (&UploadJob::set_progress, this, _1, false))); + switch (Config::instance()->tms_protocol()) { + case FileTransferProtocol::SCP: + uploader.reset (new SCPUploader(bind (&UploadJob::set_status, this, _1), bind(&UploadJob::set_progress, this, _1, false))); break; - case PROTOCOL_FTP: - uploader.reset (new CurlUploader (bind (&UploadJob::set_status, this, _1), bind (&UploadJob::set_progress, this, _1, false))); + case FileTransferProtocol::FTP: + uploader.reset (new CurlUploader(bind (&UploadJob::set_status, this, _1), bind(&UploadJob::set_progress, this, _1, false))); break; } - uploader->upload (_film->dir (_film->dcp_name ())); + uploader->upload (_film->dir(_film->dcp_name())); set_progress (1); set_status (N_("")); set_state (FINISHED_OK); } + string UploadJob::status () const { boost::mutex::scoped_lock lm (_status_mutex); - string s = Job::status (); - if (!_status.empty () && !finished_in_error ()) { + auto s = Job::status (); + if (!_status.empty() && !finished_in_error()) { s += N_("; ") + _status; } return s; } + void UploadJob::set_status (string s) {