summaryrefslogtreecommitdiff
path: root/src/lib/scp_uploader.cc
diff options
context:
space:
mode:
authorCarl Hetherington <cth@carlh.net>2025-04-28 22:46:12 +0200
committerCarl Hetherington <cth@carlh.net>2025-04-28 22:46:12 +0200
commitf4e1b8558e1c3b7356a7d49bfab3a686601b00f4 (patch)
treef2c7ceb1fdf6f8f3dd18143d812e2a32ab2e9102 /src/lib/scp_uploader.cc
parentfb1c15c5403abbf4ec967874daa518c71aa5477c (diff)
Whitespace: {curl_,scp_,}uploader.{cc,h}
Diffstat (limited to 'src/lib/scp_uploader.cc')
-rw-r--r--src/lib/scp_uploader.cc66
1 files changed, 33 insertions, 33 deletions
diff --git a/src/lib/scp_uploader.cc b/src/lib/scp_uploader.cc
index 6c63a6c3e..78ab1e7a4 100644
--- a/src/lib/scp_uploader.cc
+++ b/src/lib/scp_uploader.cc
@@ -39,110 +39,110 @@ using std::shared_ptr;
using std::string;
-SCPUploader::SCPUploader (function<void (string)> set_status, function<void (float)> set_progress)
- : Uploader (set_status, set_progress)
+SCPUploader::SCPUploader(function<void (string)> set_status, function<void (float)> set_progress)
+ : Uploader(set_status, set_progress)
{
- _session = ssh_new ();
+ _session = ssh_new();
if (!_session) {
- throw NetworkError (String::compose(_("SSH error [%1]"), "ssh_new"));
+ throw NetworkError(String::compose(_("SSH error [%1]"), "ssh_new"));
}
- ssh_options_set (_session, SSH_OPTIONS_HOST, Config::instance()->tms_ip().c_str());
- ssh_options_set (_session, SSH_OPTIONS_USER, Config::instance()->tms_user().c_str());
+ ssh_options_set(_session, SSH_OPTIONS_HOST, Config::instance()->tms_ip().c_str());
+ ssh_options_set(_session, SSH_OPTIONS_USER, Config::instance()->tms_user().c_str());
int const port = 22;
- ssh_options_set (_session, SSH_OPTIONS_PORT, &port);
+ ssh_options_set(_session, SSH_OPTIONS_PORT, &port);
- int r = ssh_connect (_session);
+ int r = ssh_connect(_session);
if (r != SSH_OK) {
- throw NetworkError (String::compose(_("Could not connect to server %1 (%2)"), Config::instance()->tms_ip(), ssh_get_error(_session)));
+ throw NetworkError(String::compose(_("Could not connect to server %1 (%2)"), Config::instance()->tms_ip(), ssh_get_error(_session)));
}
LIBDCP_DISABLE_WARNINGS
- r = ssh_is_server_known (_session);
+ r = ssh_is_server_known(_session);
if (r == SSH_SERVER_ERROR) {
- throw NetworkError (String::compose(_("SSH error [%1] (%2)"), "ssh_is_server_known", ssh_get_error(_session)));
+ throw NetworkError(String::compose(_("SSH error [%1] (%2)"), "ssh_is_server_known", ssh_get_error(_session)));
}
LIBDCP_ENABLE_WARNINGS
- r = ssh_userauth_password (_session, 0, Config::instance()->tms_password().c_str ());
+ r = ssh_userauth_password(_session, 0, Config::instance()->tms_password().c_str());
if (r != SSH_AUTH_SUCCESS) {
- throw NetworkError (String::compose(_("Failed to authenticate with server (%1)"), ssh_get_error(_session)));
+ throw NetworkError(String::compose(_("Failed to authenticate with server (%1)"), ssh_get_error(_session)));
}
LIBDCP_DISABLE_WARNINGS
- _scp = ssh_scp_new (_session, SSH_SCP_WRITE | SSH_SCP_RECURSIVE, Config::instance()->tms_path().c_str());
+ _scp = ssh_scp_new(_session, SSH_SCP_WRITE | SSH_SCP_RECURSIVE, Config::instance()->tms_path().c_str());
LIBDCP_ENABLE_WARNINGS
if (!_scp) {
- throw NetworkError (String::compose(_("SSH error [%1] (%2)"), "ssh_scp_new", ssh_get_error(_session)));
+ throw NetworkError(String::compose(_("SSH error [%1] (%2)"), "ssh_scp_new", ssh_get_error(_session)));
}
LIBDCP_DISABLE_WARNINGS
- r = ssh_scp_init (_scp);
+ r = ssh_scp_init(_scp);
LIBDCP_ENABLE_WARNINGS
if (r != SSH_OK) {
- throw NetworkError (String::compose(_("SSH error [%1] (%2)"), "ssh_scp_init", ssh_get_error(_session)));
+ throw NetworkError(String::compose(_("SSH error [%1] (%2)"), "ssh_scp_init", ssh_get_error(_session)));
}
}
-SCPUploader::~SCPUploader ()
+SCPUploader::~SCPUploader()
{
LIBDCP_DISABLE_WARNINGS
- ssh_scp_free (_scp);
+ ssh_scp_free(_scp);
LIBDCP_ENABLE_WARNINGS
- ssh_disconnect (_session);
- ssh_free (_session);
+ ssh_disconnect(_session);
+ ssh_free(_session);
}
void
-SCPUploader::create_directory (boost::filesystem::path directory)
+SCPUploader::create_directory(boost::filesystem::path directory)
{
/* Use generic_string so that we get forward-slashes in the path, even on Windows */
LIBDCP_DISABLE_WARNINGS
- int const r = ssh_scp_push_directory (_scp, directory.generic_string().c_str(), S_IRWXU);
+ int const r = ssh_scp_push_directory(_scp, directory.generic_string().c_str(), S_IRWXU);
LIBDCP_ENABLE_WARNINGS
if (r != SSH_OK) {
- throw NetworkError (String::compose(_("Could not create remote directory %1 (%2)"), directory, ssh_get_error(_session)));
+ throw NetworkError(String::compose(_("Could not create remote directory %1 (%2)"), directory, ssh_get_error(_session)));
}
}
void
-SCPUploader::upload_file (boost::filesystem::path from, boost::filesystem::path to, boost::uintmax_t& transferred, boost::uintmax_t total_size)
+SCPUploader::upload_file(boost::filesystem::path from, boost::filesystem::path to, boost::uintmax_t& transferred, boost::uintmax_t total_size)
{
auto to_do = dcp::filesystem::file_size(from);
/* Use generic_string so that we get forward-slashes in the path, even on Windows */
LIBDCP_DISABLE_WARNINGS
- ssh_scp_push_file (_scp, to.generic_string().c_str(), to_do, S_IRUSR | S_IWUSR);
+ ssh_scp_push_file(_scp, to.generic_string().c_str(), to_do, S_IRUSR | S_IWUSR);
LIBDCP_ENABLE_WARNINGS
dcp::File f(from, "rb");
if (!f) {
- throw NetworkError (String::compose(_("Could not open %1 to send"), from));
+ throw NetworkError(String::compose(_("Could not open %1 to send"), from));
}
boost::uintmax_t buffer_size = 64 * 1024;
char buffer[buffer_size];
while (to_do > 0) {
- int const t = min (to_do, buffer_size);
+ int const t = min(to_do, buffer_size);
size_t const read = f.read(buffer, 1, t);
- if (read != size_t (t)) {
- throw ReadFileError (from);
+ if (read != size_t(t)) {
+ throw ReadFileError(from);
}
LIBDCP_DISABLE_WARNINGS
- int const r = ssh_scp_write (_scp, buffer, t);
+ int const r = ssh_scp_write(_scp, buffer, t);
LIBDCP_ENABLE_WARNINGS
if (r != SSH_OK) {
- throw NetworkError (String::compose(_("Could not write to remote file (%1)"), ssh_get_error(_session)));
+ throw NetworkError(String::compose(_("Could not write to remote file (%1)"), ssh_get_error(_session)));
}
to_do -= t;
transferred += t;
if (total_size > 0) {
- _set_progress ((double) transferred / total_size);
+ _set_progress((double) transferred / total_size);
}
}
}