Cleanup: remove unused include.
[dcpomatic.git] / src / lib / scp_uploader.cc
index 9c349f233084efadcd370e91001141346c71d07b..dbe82b67f5987bd100474a8706e0b58d7ac17a37 100644 (file)
@@ -25,7 +25,8 @@
 #include "config.h"
 #include "cross.h"
 #include "compose.hpp"
-#include "warnings.h"
+#include <dcp/file.h>
+#include <dcp/warnings.h>
 #include <sys/stat.h>
 
 #include "i18n.h"
@@ -55,24 +56,28 @@ SCPUploader::SCPUploader (function<void (string)> set_status, function<void (flo
                throw NetworkError (String::compose(_("Could not connect to server %1 (%2)"), Config::instance()->tms_ip(), ssh_get_error(_session)));
        }
 
-DCPOMATIC_DISABLE_WARNINGS
+LIBDCP_DISABLE_WARNINGS
        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)));
        }
-DCPOMATIC_ENABLE_WARNINGS
+LIBDCP_ENABLE_WARNINGS
 
        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)));
        }
 
+LIBDCP_DISABLE_WARNINGS
        _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)));
        }
 
+LIBDCP_DISABLE_WARNINGS
        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)));
        }
@@ -81,7 +86,9 @@ DCPOMATIC_ENABLE_WARNINGS
 
 SCPUploader::~SCPUploader ()
 {
+LIBDCP_DISABLE_WARNINGS
        ssh_scp_free (_scp);
+LIBDCP_ENABLE_WARNINGS
        ssh_disconnect (_session);
        ssh_free (_session);
 }
@@ -91,7 +98,9 @@ void
 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);
+LIBDCP_ENABLE_WARNINGS
        if (r != SSH_OK) {
                throw NetworkError (String::compose(_("Could not create remote directory %1 (%2)"), directory, ssh_get_error(_session)));
        }
@@ -103,10 +112,12 @@ SCPUploader::upload_file (boost::filesystem::path from, boost::filesystem::path
 {
        auto to_do = boost::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);
+LIBDCP_ENABLE_WARNINGS
 
-       auto f = fopen_boost (from, "rb");
-       if (f == nullptr) {
+       dcp::File f(from, "rb");
+       if (!f) {
                throw NetworkError (String::compose(_("Could not open %1 to send"), from));
        }
 
@@ -115,15 +126,15 @@ SCPUploader::upload_file (boost::filesystem::path from, boost::filesystem::path
 
        while (to_do > 0) {
                int const t = min (to_do, buffer_size);
-               size_t const read = fread (buffer, 1, t, f);
+               size_t const read = f.read(buffer, 1, t);
                if (read != size_t (t)) {
-                       fclose (f);
                        throw ReadFileError (from);
                }
 
+LIBDCP_DISABLE_WARNINGS
                int const r = ssh_scp_write (_scp, buffer, t);
+LIBDCP_ENABLE_WARNINGS
                if (r != SSH_OK) {
-                       fclose (f);
                        throw NetworkError (String::compose(_("Could not write to remote file (%1)"), ssh_get_error(_session)));
                }
                to_do -= t;
@@ -133,6 +144,4 @@ SCPUploader::upload_file (boost::filesystem::path from, boost::filesystem::path
                        _set_progress ((double) transferred / total_size);
                }
        }
-
-       fclose (f);
 }