+++ /dev/null
-/*
- * scp.c - Scp (Secure Copy) client for PuTTY.
- * Joris van Rantwijk, Simon Tatham
- *
- * This is mainly based on ssh-1.2.26/scp.c by Timo Rinne & Tatu Ylonen.
- * They, in turn, used stuff from BSD rcp.
- *
- * (SGT, 2001-09-10: Joris van Rantwijk assures me that although
- * this file as originally submitted was inspired by, and
- * _structurally_ based on, ssh-1.2.26's scp.c, there wasn't any
- * actual code duplicated, so the above comment shouldn't give rise
- * to licensing issues.)
- */
-
-#include <stdlib.h>
-#include <stdio.h>
-#include <string.h>
-#include <limits.h>
-#include <time.h>
-#include <assert.h>
-
-#define PUTTY_DO_GLOBALS
-#include "putty.h"
-#include "psftp.h"
-#include "ssh.h"
-#include "sftp.h"
-#include "storage.h"
-
-static int list = 0;
-static int verbose = 0;
-static int recursive = 0;
-static int preserve = 0;
-static int targetshouldbedirectory = 0;
-static int statistics = 1;
-static int prev_stats_len = 0;
-static int scp_unsafe_mode = 0;
-static int errs = 0;
-static int gui_mode = 0;
-static int try_scp = 1;
-static int try_sftp = 1;
-static int main_cmd_is_sftp = 0;
-static int fallback_cmd_is_sftp = 0;
-static int using_sftp = 0;
-
-static Backend *back;
-static void *backhandle;
-static Config cfg;
-
-static void source(char *src);
-static void rsource(char *src);
-static void sink(char *targ, char *src);
-
-/*
- * The maximum amount of queued data we accept before we stop and
- * wait for the server to process some.
- */
-#define MAX_SCP_BUFSIZE 16384
-
-void ldisc_send(void *handle, char *buf, int len, int interactive)
-{
- /*
- * This is only here because of the calls to ldisc_send(NULL,
- * 0) in ssh.c. Nothing in PSCP actually needs to use the ldisc
- * as an ldisc. So if we get called with any real data, I want
- * to know about it.
- */
- assert(len == 0);
-}
-
-static void tell_char(FILE * stream, char c)
-{
- if (!gui_mode)
- fputc(c, stream);
- else
- gui_send_char(stream == stderr, c);
-}
-
-static void tell_str(FILE * stream, char *str)
-{
- unsigned int i;
-
- for (i = 0; i < strlen(str); ++i)
- tell_char(stream, str[i]);
-}
-
-static void tell_user(FILE * stream, char *fmt, ...)
-{
- char *str, *str2;
- va_list ap;
- va_start(ap, fmt);
- str = dupvprintf(fmt, ap);
- va_end(ap);
- str2 = dupcat(str, "\n", NULL);
- sfree(str);
- tell_str(stream, str2);
- sfree(str2);
-}
-
-/*
- * Print an error message and perform a fatal exit.
- */
-void fatalbox(char *fmt, ...)
-{
- char *str, *str2;
- va_list ap;
- va_start(ap, fmt);
- str = dupvprintf(fmt, ap);
- str2 = dupcat("Fatal: ", str, "\n", NULL);
- sfree(str);
- va_end(ap);
- tell_str(stderr, str2);
- sfree(str2);
- errs++;
-
- if (gui_mode)
- gui_send_errcount(list, errs);
-
- cleanup_exit(1);
-}
-void modalfatalbox(char *fmt, ...)
-{
- char *str, *str2;
- va_list ap;
- va_start(ap, fmt);
- str = dupvprintf(fmt, ap);
- str2 = dupcat("Fatal: ", str, "\n", NULL);
- sfree(str);
- va_end(ap);
- tell_str(stderr, str2);
- sfree(str2);
- errs++;
-
- if (gui_mode)
- gui_send_errcount(list, errs);
-
- cleanup_exit(1);
-}
-void connection_fatal(void *frontend, char *fmt, ...)
-{
- char *str, *str2;
- va_list ap;
- va_start(ap, fmt);
- str = dupvprintf(fmt, ap);
- str2 = dupcat("Fatal: ", str, "\n", NULL);
- sfree(str);
- va_end(ap);
- tell_str(stderr, str2);
- sfree(str2);
- errs++;
-
- if (gui_mode)
- gui_send_errcount(list, errs);
-
- cleanup_exit(1);
-}
-
-/*
- * In pscp, all agent requests should be synchronous, so this is a
- * never-called stub.
- */
-void agent_schedule_callback(void (*callback)(void *, void *, int),
- void *callback_ctx, void *data, int len)
-{
- assert(!"We shouldn't be here");
-}
-
-/*
- * Receive a block of data from the SSH link. Block until all data
- * is available.
- *
- * To do this, we repeatedly call the SSH protocol module, with our
- * own trap in from_backend() to catch the data that comes back. We
- * do this until we have enough data.
- */
-
-static unsigned char *outptr; /* where to put the data */
-static unsigned outlen; /* how much data required */
-static unsigned char *pending = NULL; /* any spare data */
-static unsigned pendlen = 0, pendsize = 0; /* length and phys. size of buffer */
-int from_backend(void *frontend, int is_stderr, const char *data, int datalen)
-{
- unsigned char *p = (unsigned char *) data;
- unsigned len = (unsigned) datalen;
-
- /*
- * stderr data is just spouted to local stderr and otherwise
- * ignored.
- */
- if (is_stderr) {
- if (len > 0)
- fwrite(data, 1, len, stderr);
- return 0;
- }
-
- /*
- * If this is before the real session begins, just return.
- */
- if (!outptr)
- return 0;
-
- if ((outlen > 0) && (len > 0)) {
- unsigned used = outlen;
- if (used > len)
- used = len;
- memcpy(outptr, p, used);
- outptr += used;
- outlen -= used;
- p += used;
- len -= used;
- }
-
- if (len > 0) {
- if (pendsize < pendlen + len) {
- pendsize = pendlen + len + 4096;
- pending = sresize(pending, pendsize, unsigned char);
- if (!pending)
- fatalbox("Out of memory");
- }
- memcpy(pending + pendlen, p, len);
- pendlen += len;
- }
-
- return 0;
-}
-static int ssh_scp_recv(unsigned char *buf, int len)
-{
- outptr = buf;
- outlen = len;
-
- /*
- * See if the pending-input block contains some of what we
- * need.
- */
- if (pendlen > 0) {
- unsigned pendused = pendlen;
- if (pendused > outlen)
- pendused = outlen;
- memcpy(outptr, pending, pendused);
- memmove(pending, pending + pendused, pendlen - pendused);
- outptr += pendused;
- outlen -= pendused;
- pendlen -= pendused;
- if (pendlen == 0) {
- pendsize = 0;
- sfree(pending);
- pending = NULL;
- }
- if (outlen == 0)
- return len;
- }
-
- while (outlen > 0) {
- if (ssh_sftp_loop_iteration() < 0)
- return 0; /* doom */
- }
-
- return len;
-}
-
-/*
- * Loop through the ssh connection and authentication process.
- */
-static void ssh_scp_init(void)
-{
- while (!back->sendok(backhandle)) {
- if (ssh_sftp_loop_iteration() < 0)
- return; /* doom */
- }
-
- /* Work out which backend we ended up using. */
- if (!ssh_fallback_cmd(backhandle))
- using_sftp = main_cmd_is_sftp;
- else
- using_sftp = fallback_cmd_is_sftp;
-
- if (verbose) {
- if (using_sftp)
- tell_user(stderr, "Using SFTP");
- else
- tell_user(stderr, "Using SCP1");
- }
-}
-
-/*
- * Print an error message and exit after closing the SSH link.
- */
-static void bump(char *fmt, ...)
-{
- char *str, *str2;
- va_list ap;
- va_start(ap, fmt);
- str = dupvprintf(fmt, ap);
- va_end(ap);
- str2 = dupcat(str, "\n", NULL);
- sfree(str);
- tell_str(stderr, str2);
- sfree(str2);
- errs++;
-
- if (back != NULL && back->socket(backhandle) != NULL) {
- char ch;
- back->special(backhandle, TS_EOF);
- ssh_scp_recv((unsigned char *) &ch, 1);
- }
-
- if (gui_mode)
- gui_send_errcount(list, errs);
-
- cleanup_exit(1);
-}
-
-/*
- * Open an SSH connection to user@host and execute cmd.
- */
-static void do_cmd(char *host, char *user, char *cmd)
-{
- const char *err;
- char *realhost;
- void *logctx;
-
- if (host == NULL || host[0] == '\0')
- bump("Empty host name");
-
- /*
- * If we haven't loaded session details already (e.g., from -load),
- * try looking for a session called "host".
- */
- if (!loaded_session) {
- /* Try to load settings for `host' into a temporary config */
- Config cfg2;
- cfg2.host[0] = '\0';
- do_defaults(host, &cfg2);
- if (cfg2.host[0] != '\0') {
- /* Settings present and include hostname */
- /* Re-load data into the real config. */
- do_defaults(host, &cfg);
- } else {
- /* Session doesn't exist or mention a hostname. */
- /* Use `host' as a bare hostname. */
- strncpy(cfg.host, host, sizeof(cfg.host) - 1);
- cfg.host[sizeof(cfg.host) - 1] = '\0';
- }
- } else {
- /* Patch in hostname `host' to session details. */
- strncpy(cfg.host, host, sizeof(cfg.host) - 1);
- cfg.host[sizeof(cfg.host) - 1] = '\0';
- }
-
- /*
- * Force use of SSH. (If they got the protocol wrong we assume the
- * port is useless too.)
- */
- if (cfg.protocol != PROT_SSH) {
- cfg.protocol = PROT_SSH;
- cfg.port = 22;
- }
-
- /*
- * Enact command-line overrides.
- */
- cmdline_run_saved(&cfg);
-
- /*
- * Trim leading whitespace off the hostname if it's there.
- */
- {
- int space = strspn(cfg.host, " \t");
- memmove(cfg.host, cfg.host+space, 1+strlen(cfg.host)-space);
- }
-
- /* See if host is of the form user@host */
- if (cfg.host[0] != '\0') {
- char *atsign = strrchr(cfg.host, '@');
- /* Make sure we're not overflowing the user field */
- if (atsign) {
- if (atsign - cfg.host < sizeof cfg.username) {
- strncpy(cfg.username, cfg.host, atsign - cfg.host);
- cfg.username[atsign - cfg.host] = '\0';
- }
- memmove(cfg.host, atsign + 1, 1 + strlen(atsign + 1));
- }
- }
-
- /*
- * Trim a colon suffix off the hostname if it's there.
- */
- cfg.host[strcspn(cfg.host, ":")] = '\0';
-
- /*
- * Remove any remaining whitespace from the hostname.
- */
- {
- int p1 = 0, p2 = 0;
- while (cfg.host[p2] != '\0') {
- if (cfg.host[p2] != ' ' && cfg.host[p2] != '\t') {
- cfg.host[p1] = cfg.host[p2];
- p1++;
- }
- p2++;
- }
- cfg.host[p1] = '\0';
- }
-
- /* Set username */
- if (user != NULL && user[0] != '\0') {
- strncpy(cfg.username, user, sizeof(cfg.username) - 1);
- cfg.username[sizeof(cfg.username) - 1] = '\0';
- } else if (cfg.username[0] == '\0') {
- user = get_username();
- if (!user)
- bump("Empty user name");
- else {
- if (verbose)
- tell_user(stderr, "Guessing user name: %s", user);
- strncpy(cfg.username, user, sizeof(cfg.username) - 1);
- cfg.username[sizeof(cfg.username) - 1] = '\0';
- sfree(user);
- }
- }
-
- /*
- * Disable scary things which shouldn't be enabled for simple
- * things like SCP and SFTP: agent forwarding, port forwarding,
- * X forwarding.
- */
- cfg.x11_forward = 0;
- cfg.agentfwd = 0;
- cfg.portfwd[0] = cfg.portfwd[1] = '\0';
-
- /*
- * Set up main and possibly fallback command depending on
- * options specified by user.
- * Attempt to start the SFTP subsystem as a first choice,
- * falling back to the provided scp command if that fails.
- */
- cfg.remote_cmd_ptr2 = NULL;
- if (try_sftp) {
- /* First choice is SFTP subsystem. */
- main_cmd_is_sftp = 1;
- strcpy(cfg.remote_cmd, "sftp");
- cfg.ssh_subsys = TRUE;
- if (try_scp) {
- /* Fallback is to use the provided scp command. */
- fallback_cmd_is_sftp = 0;
- cfg.remote_cmd_ptr2 = cmd;
- cfg.ssh_subsys2 = FALSE;
- } else {
- /* Since we're not going to try SCP, we may as well try
- * harder to find an SFTP server, since in the current
- * implementation we have a spare slot. */
- fallback_cmd_is_sftp = 1;
- /* see psftp.c for full explanation of this kludge */
- cfg.remote_cmd_ptr2 =
- "test -x /usr/lib/sftp-server && exec /usr/lib/sftp-server\n"
- "test -x /usr/local/lib/sftp-server && exec /usr/local/lib/sftp-server\n"
- "exec sftp-server";
- cfg.ssh_subsys2 = FALSE;
- }
- } else {
- /* Don't try SFTP at all; just try the scp command. */
- main_cmd_is_sftp = 0;
- cfg.remote_cmd_ptr = cmd;
- cfg.ssh_subsys = FALSE;
- }
- cfg.nopty = TRUE;
-
- back = &ssh_backend;
-
- err = back->init(NULL, &backhandle, &cfg, cfg.host, cfg.port, &realhost,
- 0, cfg.tcp_keepalives);
- if (err != NULL)
- bump("ssh_init: %s", err);
- logctx = log_init(NULL, &cfg);
- back->provide_logctx(backhandle, logctx);
- console_provide_logctx(logctx);
- ssh_scp_init();
- if (verbose && realhost != NULL)
- tell_user(stderr, "Connected to %s\n", realhost);
- sfree(realhost);
-}
-
-/*
- * Update statistic information about current file.
- */
-static void print_stats(char *name, unsigned long size, unsigned long done,
- time_t start, time_t now)
-{
- float ratebs;
- unsigned long eta;
- char *etastr;
- int pct;
- int len;
- int elap;
-
- elap = (unsigned long) difftime(now, start);
-
- if (now > start)
- ratebs = (float) done / elap;
- else
- ratebs = (float) done;
-
- if (ratebs < 1.0)
- eta = size - done;
- else
- eta = (unsigned long) ((size - done) / ratebs);
- etastr = dupprintf("%02ld:%02ld:%02ld",
- eta / 3600, (eta % 3600) / 60, eta % 60);
-
- pct = (int) (100 * (done * 1.0 / size));
-
- if (gui_mode) {
- gui_update_stats(name, size, pct, elap, done, eta,
- (unsigned long) ratebs);
- } else {
- len = printf("\r%-25.25s | %10ld kB | %5.1f kB/s | ETA: %8s | %3d%%",
- name, done / 1024, ratebs / 1024.0, etastr, pct);
- if (len < prev_stats_len)
- printf("%*s", prev_stats_len - len, "");
- prev_stats_len = len;
-
- if (done == size)
- printf("\n");
-
- fflush(stdout);
- }
-
- free(etastr);
-}
-
-/*
- * Find a colon in str and return a pointer to the colon.
- * This is used to separate hostname from filename.
- */
-static char *colon(char *str)
-{
- /* We ignore a leading colon, since the hostname cannot be
- empty. We also ignore a colon as second character because
- of filenames like f:myfile.txt. */
- if (str[0] == '\0' || str[0] == ':' || str[1] == ':')
- return (NULL);
- while (*str != '\0' && *str != ':' && *str != '/' && *str != '\\')
- str++;
- if (*str == ':')
- return (str);
- else
- return (NULL);
-}
-
-/*
- * Return a pointer to the portion of str that comes after the last
- * slash (or backslash or colon, if `local' is TRUE).
- */
-static char *stripslashes(char *str, int local)
-{
- char *p;
-
- if (local) {
- p = strchr(str, ':');
- if (p) str = p+1;
- }
-
- p = strrchr(str, '/');
- if (p) str = p+1;
-
- if (local) {
- p = strrchr(str, '\\');
- if (p) str = p+1;
- }
-
- return str;
-}
-
-/*
- * Determine whether a string is entirely composed of dots.
- */
-static int is_dots(char *str)
-{
- return str[strspn(str, ".")] == '\0';
-}
-
-/*
- * Wait for a response from the other side.
- * Return 0 if ok, -1 if error.
- */
-static int response(void)
-{
- char ch, resp, rbuf[2048];
- int p;
-
- if (ssh_scp_recv((unsigned char *) &resp, 1) <= 0)
- bump("Lost connection");
-
- p = 0;
- switch (resp) {
- case 0: /* ok */
- return (0);
- default:
- rbuf[p++] = resp;
- /* fallthrough */
- case 1: /* error */
- case 2: /* fatal error */
- do {
- if (ssh_scp_recv((unsigned char *) &ch, 1) <= 0)
- bump("Protocol error: Lost connection");
- rbuf[p++] = ch;
- } while (p < sizeof(rbuf) && ch != '\n');
- rbuf[p - 1] = '\0';
- if (resp == 1)
- tell_user(stderr, "%s\n", rbuf);
- else
- bump("%s", rbuf);
- errs++;
- return (-1);
- }
-}
-
-int sftp_recvdata(char *buf, int len)
-{
- return ssh_scp_recv((unsigned char *) buf, len);
-}
-int sftp_senddata(char *buf, int len)
-{
- back->send(backhandle, buf, len);
- return 1;
-}
-
-/* ----------------------------------------------------------------------
- * sftp-based replacement for the hacky `pscp -ls'.
- */
-static int sftp_ls_compare(const void *av, const void *bv)
-{
- const struct fxp_name *a = (const struct fxp_name *) av;
- const struct fxp_name *b = (const struct fxp_name *) bv;
- return strcmp(a->filename, b->filename);
-}
-void scp_sftp_listdir(char *dirname)
-{
- struct fxp_handle *dirh;
- struct fxp_names *names;
- struct fxp_name *ournames;
- struct sftp_packet *pktin;
- struct sftp_request *req, *rreq;
- int nnames, namesize;
- int i;
-
- if (!fxp_init()) {
- tell_user(stderr, "unable to initialise SFTP: %s", fxp_error());
- errs++;
- return;
- }
-
- printf("Listing directory %s\n", dirname);
-
- sftp_register(req = fxp_opendir_send(dirname));
- rreq = sftp_find_request(pktin = sftp_recv());
- assert(rreq == req);
- dirh = fxp_opendir_recv(pktin, rreq);
-
- if (dirh == NULL) {
- printf("Unable to open %s: %s\n", dirname, fxp_error());
- } else {
- nnames = namesize = 0;
- ournames = NULL;
-
- while (1) {
-
- sftp_register(req = fxp_readdir_send(dirh));
- rreq = sftp_find_request(pktin = sftp_recv());
- assert(rreq == req);
- names = fxp_readdir_recv(pktin, rreq);
-
- if (names == NULL) {
- if (fxp_error_type() == SSH_FX_EOF)
- break;
- printf("Reading directory %s: %s\n", dirname, fxp_error());
- break;
- }
- if (names->nnames == 0) {
- fxp_free_names(names);
- break;
- }
-
- if (nnames + names->nnames >= namesize) {
- namesize += names->nnames + 128;
- ournames = sresize(ournames, namesize, struct fxp_name);
- }
-
- for (i = 0; i < names->nnames; i++)
- ournames[nnames++] = names->names[i];
-
- names->nnames = 0; /* prevent free_names */
- fxp_free_names(names);
- }
- sftp_register(req = fxp_close_send(dirh));
- rreq = sftp_find_request(pktin = sftp_recv());
- assert(rreq == req);
- fxp_close_recv(pktin, rreq);
-
- /*
- * Now we have our filenames. Sort them by actual file
- * name, and then output the longname parts.
- */
- qsort(ournames, nnames, sizeof(*ournames), sftp_ls_compare);
-
- /*
- * And print them.
- */
- for (i = 0; i < nnames; i++)
- printf("%s\n", ournames[i].longname);
- }
-}
-
-/* ----------------------------------------------------------------------
- * Helper routines that contain the actual SCP protocol elements,
- * implemented both as SCP1 and SFTP.
- */
-
-static struct scp_sftp_dirstack {
- struct scp_sftp_dirstack *next;
- struct fxp_name *names;
- int namepos, namelen;
- char *dirpath;
- char *wildcard;
- int matched_something; /* wildcard match set was non-empty */
-} *scp_sftp_dirstack_head;
-static char *scp_sftp_remotepath, *scp_sftp_currentname;
-static char *scp_sftp_wildcard;
-static int scp_sftp_targetisdir, scp_sftp_donethistarget;
-static int scp_sftp_preserve, scp_sftp_recursive;
-static unsigned long scp_sftp_mtime, scp_sftp_atime;
-static int scp_has_times;
-static struct fxp_handle *scp_sftp_filehandle;
-static struct fxp_xfer *scp_sftp_xfer;
-static uint64 scp_sftp_fileoffset;
-
-void scp_source_setup(char *target, int shouldbedir)
-{
- if (using_sftp) {
- /*
- * Find out whether the target filespec is in fact a
- * directory.
- */
- struct sftp_packet *pktin;
- struct sftp_request *req, *rreq;
- struct fxp_attrs attrs;
- int ret;
-
- if (!fxp_init()) {
- tell_user(stderr, "unable to initialise SFTP: %s", fxp_error());
- errs++;
- return;
- }
-
- sftp_register(req = fxp_stat_send(target));
- rreq = sftp_find_request(pktin = sftp_recv());
- assert(rreq == req);
- ret = fxp_stat_recv(pktin, rreq, &attrs);
-
- if (!ret || !(attrs.flags & SSH_FILEXFER_ATTR_PERMISSIONS))
- scp_sftp_targetisdir = 0;
- else
- scp_sftp_targetisdir = (attrs.permissions & 0040000) != 0;
-
- if (shouldbedir && !scp_sftp_targetisdir) {
- bump("pscp: remote filespec %s: not a directory\n", target);
- }
-
- scp_sftp_remotepath = dupstr(target);
-
- scp_has_times = 0;
- } else {
- (void) response();
- }
-}
-
-int scp_send_errmsg(char *str)
-{
- if (using_sftp) {
- /* do nothing; we never need to send our errors to the server */
- } else {
- back->send(backhandle, "\001", 1);/* scp protocol error prefix */
- back->send(backhandle, str, strlen(str));
- }
- return 0; /* can't fail */
-}
-
-int scp_send_filetimes(unsigned long mtime, unsigned long atime)
-{
- if (using_sftp) {
- scp_sftp_mtime = mtime;
- scp_sftp_atime = atime;
- scp_has_times = 1;
- return 0;
- } else {
- char buf[80];
- sprintf(buf, "T%lu 0 %lu 0\n", mtime, atime);
- back->send(backhandle, buf, strlen(buf));
- return response();
- }
-}
-
-int scp_send_filename(char *name, unsigned long size, int modes)
-{
- if (using_sftp) {
- char *fullname;
- struct sftp_packet *pktin;
- struct sftp_request *req, *rreq;
-
- if (scp_sftp_targetisdir) {
- fullname = dupcat(scp_sftp_remotepath, "/", name, NULL);
- } else {
- fullname = dupstr(scp_sftp_remotepath);
- }
-
- sftp_register(req = fxp_open_send(fullname, SSH_FXF_WRITE |
- SSH_FXF_CREAT | SSH_FXF_TRUNC));
- rreq = sftp_find_request(pktin = sftp_recv());
- assert(rreq == req);
- scp_sftp_filehandle = fxp_open_recv(pktin, rreq);
-
- if (!scp_sftp_filehandle) {
- tell_user(stderr, "pscp: unable to open %s: %s",
- fullname, fxp_error());
- errs++;
- return 1;
- }
- scp_sftp_fileoffset = uint64_make(0, 0);
- scp_sftp_xfer = xfer_upload_init(scp_sftp_filehandle,
- scp_sftp_fileoffset);
- sfree(fullname);
- return 0;
- } else {
- char buf[40];
- sprintf(buf, "C%04o %lu ", modes, size);
- back->send(backhandle, buf, strlen(buf));
- back->send(backhandle, name, strlen(name));
- back->send(backhandle, "\n", 1);
- return response();
- }
-}
-
-int scp_send_filedata(char *data, int len)
-{
- if (using_sftp) {
- int ret;
- struct sftp_packet *pktin;
-
- if (!scp_sftp_filehandle) {
- return 1;
- }
-
- while (!xfer_upload_ready(scp_sftp_xfer)) {
- pktin = sftp_recv();
- ret = xfer_upload_gotpkt(scp_sftp_xfer, pktin);
- if (!ret) {
- tell_user(stderr, "error while writing: %s\n", fxp_error());
- errs++;
- return 1;
- }
- }
-
- xfer_upload_data(scp_sftp_xfer, data, len);
-
- scp_sftp_fileoffset = uint64_add32(scp_sftp_fileoffset, len);
- return 0;
- } else {
- int bufsize = back->send(backhandle, data, len);
-
- /*
- * If the network transfer is backing up - that is, the
- * remote site is not accepting data as fast as we can
- * produce it - then we must loop on network events until
- * we have space in the buffer again.
- */
- while (bufsize > MAX_SCP_BUFSIZE) {
- if (ssh_sftp_loop_iteration() < 0)
- return 1;
- bufsize = back->sendbuffer(backhandle);
- }
-
- return 0;
- }
-}
-
-int scp_send_finish(void)
-{
- if (using_sftp) {
- struct fxp_attrs attrs;
- struct sftp_packet *pktin;
- struct sftp_request *req, *rreq;
- int ret;
-
- while (!xfer_done(scp_sftp_xfer)) {
- pktin = sftp_recv();
- xfer_upload_gotpkt(scp_sftp_xfer, pktin);
- }
- xfer_cleanup(scp_sftp_xfer);
-
- if (!scp_sftp_filehandle) {
- return 1;
- }
- if (scp_has_times) {
- attrs.flags = SSH_FILEXFER_ATTR_ACMODTIME;
- attrs.atime = scp_sftp_atime;
- attrs.mtime = scp_sftp_mtime;
- sftp_register(req = fxp_fsetstat_send(scp_sftp_filehandle, attrs));
- rreq = sftp_find_request(pktin = sftp_recv());
- assert(rreq == req);
- ret = fxp_fsetstat_recv(pktin, rreq);
- if (!ret) {
- tell_user(stderr, "unable to set file times: %s\n", fxp_error());
- errs++;
- }
- }
- sftp_register(req = fxp_close_send(scp_sftp_filehandle));
- rreq = sftp_find_request(pktin = sftp_recv());
- assert(rreq == req);
- fxp_close_recv(pktin, rreq);
- scp_has_times = 0;
- return 0;
- } else {
- back->send(backhandle, "", 1);
- return response();
- }
-}
-
-char *scp_save_remotepath(void)
-{
- if (using_sftp)
- return scp_sftp_remotepath;
- else
- return NULL;
-}
-
-void scp_restore_remotepath(char *data)
-{
- if (using_sftp)
- scp_sftp_remotepath = data;
-}
-
-int scp_send_dirname(char *name, int modes)
-{
- if (using_sftp) {
- char *fullname;
- char const *err;
- struct fxp_attrs attrs;
- struct sftp_packet *pktin;
- struct sftp_request *req, *rreq;
- int ret;
-
- if (scp_sftp_targetisdir) {
- fullname = dupcat(scp_sftp_remotepath, "/", name, NULL);
- } else {
- fullname = dupstr(scp_sftp_remotepath);
- }
-
- /*
- * We don't worry about whether we managed to create the
- * directory, because if it exists already it's OK just to
- * use it. Instead, we will stat it afterwards, and if it
- * exists and is a directory we will assume we were either
- * successful or it didn't matter.
- */
- sftp_register(req = fxp_mkdir_send(fullname));
- rreq = sftp_find_request(pktin = sftp_recv());
- assert(rreq == req);
- ret = fxp_mkdir_recv(pktin, rreq);
-
- if (!ret)
- err = fxp_error();
- else
- err = "server reported no error";
-
- sftp_register(req = fxp_stat_send(fullname));
- rreq = sftp_find_request(pktin = sftp_recv());
- assert(rreq == req);
- ret = fxp_stat_recv(pktin, rreq, &attrs);
-
- if (!ret || !(attrs.flags & SSH_FILEXFER_ATTR_PERMISSIONS) ||
- !(attrs.permissions & 0040000)) {
- tell_user(stderr, "unable to create directory %s: %s",
- fullname, err);
- errs++;
- return 1;
- }
-
- scp_sftp_remotepath = fullname;
-
- return 0;
- } else {
- char buf[40];
- sprintf(buf, "D%04o 0 ", modes);
- back->send(backhandle, buf, strlen(buf));
- back->send(backhandle, name, strlen(name));
- back->send(backhandle, "\n", 1);
- return response();
- }
-}
-
-int scp_send_enddir(void)
-{
- if (using_sftp) {
- sfree(scp_sftp_remotepath);
- return 0;
- } else {
- back->send(backhandle, "E\n", 2);
- return response();
- }
-}
-
-/*
- * Yes, I know; I have an scp_sink_setup _and_ an scp_sink_init.
- * That's bad. The difference is that scp_sink_setup is called once
- * right at the start, whereas scp_sink_init is called to
- * initialise every level of recursion in the protocol.
- */
-int scp_sink_setup(char *source, int preserve, int recursive)
-{
- if (using_sftp) {
- char *newsource;
-
- if (!fxp_init()) {
- tell_user(stderr, "unable to initialise SFTP: %s", fxp_error());
- errs++;
- return 1;
- }
- /*
- * It's possible that the source string we've been given
- * contains a wildcard. If so, we must split the directory
- * away from the wildcard itself (throwing an error if any
- * wildcardness comes before the final slash) and arrange
- * things so that a dirstack entry will be set up.
- */
- newsource = snewn(1+strlen(source), char);
- if (!wc_unescape(newsource, source)) {
- /* Yes, here we go; it's a wildcard. Bah. */
- char *dupsource, *lastpart, *dirpart, *wildcard;
- dupsource = dupstr(source);
- lastpart = stripslashes(dupsource, 0);
- wildcard = dupstr(lastpart);
- *lastpart = '\0';
- if (*dupsource && dupsource[1]) {
- /*
- * The remains of dupsource are at least two
- * characters long, meaning the pathname wasn't
- * empty or just `/'. Hence, we remove the trailing
- * slash.
- */
- lastpart[-1] = '\0';
- } else if (!*dupsource) {
- /*
- * The remains of dupsource are _empty_ - the whole
- * pathname was a wildcard. Hence we need to
- * replace it with ".".
- */
- sfree(dupsource);
- dupsource = dupstr(".");
- }
-
- /*
- * Now we have separated our string into dupsource (the
- * directory part) and wildcard. Both of these will
- * need freeing at some point. Next step is to remove
- * wildcard escapes from the directory part, throwing
- * an error if it contains a real wildcard.
- */
- dirpart = snewn(1+strlen(dupsource), char);
- if (!wc_unescape(dirpart, dupsource)) {
- tell_user(stderr, "%s: multiple-level wildcards unsupported",
- source);
- errs++;
- sfree(dirpart);
- sfree(wildcard);
- sfree(dupsource);
- return 1;
- }
-
- /*
- * Now we have dirpart (unescaped, ie a valid remote
- * path), and wildcard (a wildcard). This will be
- * sufficient to arrange a dirstack entry.
- */
- scp_sftp_remotepath = dirpart;
- scp_sftp_wildcard = wildcard;
- sfree(dupsource);
- } else {
- scp_sftp_remotepath = newsource;
- scp_sftp_wildcard = NULL;
- }
- scp_sftp_preserve = preserve;
- scp_sftp_recursive = recursive;
- scp_sftp_donethistarget = 0;
- scp_sftp_dirstack_head = NULL;
- }
- return 0;
-}
-
-int scp_sink_init(void)
-{
- if (!using_sftp) {
- back->send(backhandle, "", 1);
- }
- return 0;
-}
-
-#define SCP_SINK_FILE 1
-#define SCP_SINK_DIR 2
-#define SCP_SINK_ENDDIR 3
-#define SCP_SINK_RETRY 4 /* not an action; just try again */
-struct scp_sink_action {
- int action; /* FILE, DIR, ENDDIR */
- char *buf; /* will need freeing after use */
- char *name; /* filename or dirname (not ENDDIR) */
- int mode; /* access mode (not ENDDIR) */
- unsigned long size; /* file size (not ENDDIR) */
- int settime; /* 1 if atime and mtime are filled */
- unsigned long atime, mtime; /* access times for the file */
-};
-
-int scp_get_sink_action(struct scp_sink_action *act)
-{
- if (using_sftp) {
- char *fname;
- int must_free_fname;
- struct fxp_attrs attrs;
- struct sftp_packet *pktin;
- struct sftp_request *req, *rreq;
- int ret;
-
- if (!scp_sftp_dirstack_head) {
- if (!scp_sftp_donethistarget) {
- /*
- * Simple case: we are only dealing with one file.
- */
- fname = scp_sftp_remotepath;
- must_free_fname = 0;
- scp_sftp_donethistarget = 1;
- } else {
- /*
- * Even simpler case: one file _which we've done_.
- * Return 1 (finished).
- */
- return 1;
- }
- } else {
- /*
- * We're now in the middle of stepping through a list
- * of names returned from fxp_readdir(); so let's carry
- * on.
- */
- struct scp_sftp_dirstack *head = scp_sftp_dirstack_head;
- while (head->namepos < head->namelen &&
- (is_dots(head->names[head->namepos].filename) ||
- (head->wildcard &&
- !wc_match(head->wildcard,
- head->names[head->namepos].filename))))
- head->namepos++; /* skip . and .. */
- if (head->namepos < head->namelen) {
- head->matched_something = 1;
- fname = dupcat(head->dirpath, "/",
- head->names[head->namepos++].filename,
- NULL);
- must_free_fname = 1;
- } else {
- /*
- * We've come to the end of the list; pop it off
- * the stack and return an ENDDIR action (or RETRY
- * if this was a wildcard match).
- */
- if (head->wildcard) {
- act->action = SCP_SINK_RETRY;
- if (!head->matched_something) {
- tell_user(stderr, "pscp: wildcard '%s' matched "
- "no files", head->wildcard);
- errs++;
- }
- sfree(head->wildcard);
-
- } else {
- act->action = SCP_SINK_ENDDIR;
- }
-
- sfree(head->dirpath);
- sfree(head->names);
- scp_sftp_dirstack_head = head->next;
- sfree(head);
-
- return 0;
- }
- }
-
- /*
- * Now we have a filename. Stat it, and see if it's a file
- * or a directory.
- */
- sftp_register(req = fxp_stat_send(fname));
- rreq = sftp_find_request(pktin = sftp_recv());
- assert(rreq == req);
- ret = fxp_stat_recv(pktin, rreq, &attrs);
-
- if (!ret || !(attrs.flags & SSH_FILEXFER_ATTR_PERMISSIONS)) {
- tell_user(stderr, "unable to identify %s: %s", fname,
- ret ? "file type not supplied" : fxp_error());
- errs++;
- return 1;
- }
-
- if (attrs.permissions & 0040000) {
- struct scp_sftp_dirstack *newitem;
- struct fxp_handle *dirhandle;
- int nnames, namesize;
- struct fxp_name *ournames;
- struct fxp_names *names;
-
- /*
- * It's a directory. If we're not in recursive mode,
- * this merits a complaint (which is fatal if the name
- * was specified directly, but not if it was matched by
- * a wildcard).
- *
- * We skip this complaint completely if
- * scp_sftp_wildcard is set, because that's an
- * indication that we're not actually supposed to
- * _recursively_ transfer the dir, just scan it for
- * things matching the wildcard.
- */
- if (!scp_sftp_recursive && !scp_sftp_wildcard) {
- tell_user(stderr, "pscp: %s: is a directory", fname);
- errs++;
- if (must_free_fname) sfree(fname);
- if (scp_sftp_dirstack_head) {
- act->action = SCP_SINK_RETRY;
- return 0;
- } else {
- return 1;
- }
- }
-
- /*
- * Otherwise, the fun begins. We must fxp_opendir() the
- * directory, slurp the filenames into memory, return
- * SCP_SINK_DIR (unless this is a wildcard match), and
- * set targetisdir. The next time we're called, we will
- * run through the list of filenames one by one,
- * matching them against a wildcard if present.
- *
- * If targetisdir is _already_ set (meaning we're
- * already in the middle of going through another such
- * list), we must push the other (target,namelist) pair
- * on a stack.
- */
- sftp_register(req = fxp_opendir_send(fname));
- rreq = sftp_find_request(pktin = sftp_recv());
- assert(rreq == req);
- dirhandle = fxp_opendir_recv(pktin, rreq);
-
- if (!dirhandle) {
- tell_user(stderr, "scp: unable to open directory %s: %s",
- fname, fxp_error());
- if (must_free_fname) sfree(fname);
- errs++;
- return 1;
- }
- nnames = namesize = 0;
- ournames = NULL;
- while (1) {
- int i;
-
- sftp_register(req = fxp_readdir_send(dirhandle));
- rreq = sftp_find_request(pktin = sftp_recv());
- assert(rreq == req);
- names = fxp_readdir_recv(pktin, rreq);
-
- if (names == NULL) {
- if (fxp_error_type() == SSH_FX_EOF)
- break;
- tell_user(stderr, "scp: reading directory %s: %s\n",
- fname, fxp_error());
- if (must_free_fname) sfree(fname);
- sfree(ournames);
- errs++;
- return 1;
- }
- if (names->nnames == 0) {
- fxp_free_names(names);
- break;
- }
- if (nnames + names->nnames >= namesize) {
- namesize += names->nnames + 128;
- ournames = sresize(ournames, namesize, struct fxp_name);
- }
- for (i = 0; i < names->nnames; i++)
- ournames[nnames++] = names->names[i];
- names->nnames = 0; /* prevent free_names */
- fxp_free_names(names);
- }
- sftp_register(req = fxp_close_send(dirhandle));
- rreq = sftp_find_request(pktin = sftp_recv());
- assert(rreq == req);
- fxp_close_recv(pktin, rreq);
-
- newitem = snew(struct scp_sftp_dirstack);
- newitem->next = scp_sftp_dirstack_head;
- newitem->names = ournames;
- newitem->namepos = 0;
- newitem->namelen = nnames;
- if (must_free_fname)
- newitem->dirpath = fname;
- else
- newitem->dirpath = dupstr(fname);
- if (scp_sftp_wildcard) {
- newitem->wildcard = scp_sftp_wildcard;
- newitem->matched_something = 0;
- scp_sftp_wildcard = NULL;
- } else {
- newitem->wildcard = NULL;
- }
- scp_sftp_dirstack_head = newitem;
-
- if (newitem->wildcard) {
- act->action = SCP_SINK_RETRY;
- } else {
- act->action = SCP_SINK_DIR;
- act->buf = dupstr(stripslashes(fname, 0));
- act->name = act->buf;
- act->size = 0; /* duhh, it's a directory */
- act->mode = 07777 & attrs.permissions;
- if (scp_sftp_preserve &&
- (attrs.flags & SSH_FILEXFER_ATTR_ACMODTIME)) {
- act->atime = attrs.atime;
- act->mtime = attrs.mtime;
- act->settime = 1;
- } else
- act->settime = 0;
- }
- return 0;
-
- } else {
- /*
- * It's a file. Return SCP_SINK_FILE.
- */
- act->action = SCP_SINK_FILE;
- act->buf = dupstr(stripslashes(fname, 0));
- act->name = act->buf;
- if (attrs.flags & SSH_FILEXFER_ATTR_SIZE) {
- if (uint64_compare(attrs.size,
- uint64_make(0, ULONG_MAX)) > 0) {
- act->size = ULONG_MAX; /* *boggle* */
- } else
- act->size = attrs.size.lo;
- } else
- act->size = ULONG_MAX; /* no idea */
- act->mode = 07777 & attrs.permissions;
- if (scp_sftp_preserve &&
- (attrs.flags & SSH_FILEXFER_ATTR_ACMODTIME)) {
- act->atime = attrs.atime;
- act->mtime = attrs.mtime;
- act->settime = 1;
- } else
- act->settime = 0;
- if (must_free_fname)
- scp_sftp_currentname = fname;
- else
- scp_sftp_currentname = dupstr(fname);
- return 0;
- }
-
- } else {
- int done = 0;
- int i, bufsize;
- int action;
- char ch;
-
- act->settime = 0;
- act->buf = NULL;
- bufsize = 0;
-
- while (!done) {
- if (ssh_scp_recv((unsigned char *) &ch, 1) <= 0)
- return 1;
- if (ch == '\n')
- bump("Protocol error: Unexpected newline");
- i = 0;
- action = ch;
- do {
- if (ssh_scp_recv((unsigned char *) &ch, 1) <= 0)
- bump("Lost connection");
- if (i >= bufsize) {
- bufsize = i + 128;
- act->buf = sresize(act->buf, bufsize, char);
- }
- act->buf[i++] = ch;
- } while (ch != '\n');
- act->buf[i - 1] = '\0';
- switch (action) {
- case '\01': /* error */
- tell_user(stderr, "%s\n", act->buf);
- errs++;
- continue; /* go round again */
- case '\02': /* fatal error */
- bump("%s", act->buf);
- case 'E':
- back->send(backhandle, "", 1);
- act->action = SCP_SINK_ENDDIR;
- return 0;
- case 'T':
- if (sscanf(act->buf, "%ld %*d %ld %*d",
- &act->mtime, &act->atime) == 2) {
- act->settime = 1;
- back->send(backhandle, "", 1);
- continue; /* go round again */
- }
- bump("Protocol error: Illegal time format");
- case 'C':
- case 'D':
- act->action = (action == 'C' ? SCP_SINK_FILE : SCP_SINK_DIR);
- break;
- default:
- bump("Protocol error: Expected control record");
- }
- /*
- * We will go round this loop only once, unless we hit
- * `continue' above.
- */
- done = 1;
- }
-
- /*
- * If we get here, we must have seen SCP_SINK_FILE or
- * SCP_SINK_DIR.
- */
- if (sscanf(act->buf, "%o %lu %n", &act->mode, &act->size, &i) != 2)
- bump("Protocol error: Illegal file descriptor format");
- act->name = act->buf + i;
- return 0;
- }
-}
-
-int scp_accept_filexfer(void)
-{
- if (using_sftp) {
- struct sftp_packet *pktin;
- struct sftp_request *req, *rreq;
-
- sftp_register(req = fxp_open_send(scp_sftp_currentname, SSH_FXF_READ));
- rreq = sftp_find_request(pktin = sftp_recv());
- assert(rreq == req);
- scp_sftp_filehandle = fxp_open_recv(pktin, rreq);
-
- if (!scp_sftp_filehandle) {
- tell_user(stderr, "pscp: unable to open %s: %s",
- scp_sftp_currentname, fxp_error());
- errs++;
- return 1;
- }
- scp_sftp_fileoffset = uint64_make(0, 0);
- scp_sftp_xfer = xfer_download_init(scp_sftp_filehandle,
- scp_sftp_fileoffset);
- sfree(scp_sftp_currentname);
- return 0;
- } else {
- back->send(backhandle, "", 1);
- return 0; /* can't fail */
- }
-}
-
-int scp_recv_filedata(char *data, int len)
-{
- if (using_sftp) {
- struct sftp_packet *pktin;
- int ret, actuallen;
- void *vbuf;
-
- xfer_download_queue(scp_sftp_xfer);
- pktin = sftp_recv();
- ret = xfer_download_gotpkt(scp_sftp_xfer, pktin);
-
- if (ret < 0) {
- tell_user(stderr, "pscp: error while reading: %s", fxp_error());
- errs++;
- return -1;
- }
-
- if (xfer_download_data(scp_sftp_xfer, &vbuf, &actuallen)) {
- /*
- * This assertion relies on the fact that the natural
- * block size used in the xfer manager is at most that
- * used in this module. I don't like crossing layers in
- * this way, but it'll do for now.
- */
- assert(actuallen <= len);
- memcpy(data, vbuf, actuallen);
- sfree(vbuf);
- } else
- actuallen = 0;
-
- scp_sftp_fileoffset = uint64_add32(scp_sftp_fileoffset, actuallen);
-
- return actuallen;
- } else {
- return ssh_scp_recv((unsigned char *) data, len);
- }
-}
-
-int scp_finish_filerecv(void)
-{
- if (using_sftp) {
- struct sftp_packet *pktin;
- struct sftp_request *req, *rreq;
-
- /*
- * Ensure that xfer_done() will work correctly, so we can
- * clean up any outstanding requests from the file
- * transfer.
- */
- xfer_set_error(scp_sftp_xfer);
- while (!xfer_done(scp_sftp_xfer)) {
- void *vbuf;
- int len;
-
- pktin = sftp_recv();
- xfer_download_gotpkt(scp_sftp_xfer, pktin);
- if (xfer_download_data(scp_sftp_xfer, &vbuf, &len))
- sfree(vbuf);
- }
- xfer_cleanup(scp_sftp_xfer);
-
- sftp_register(req = fxp_close_send(scp_sftp_filehandle));
- rreq = sftp_find_request(pktin = sftp_recv());
- assert(rreq == req);
- fxp_close_recv(pktin, rreq);
- return 0;
- } else {
- back->send(backhandle, "", 1);
- return response();
- }
-}
-
-/* ----------------------------------------------------------------------
- * Send an error message to the other side and to the screen.
- * Increment error counter.
- */
-static void run_err(const char *fmt, ...)
-{
- char *str, *str2;
- va_list ap;
- va_start(ap, fmt);
- errs++;
- str = dupvprintf(fmt, ap);
- str2 = dupcat("scp: ", str, "\n", NULL);
- sfree(str);
- scp_send_errmsg(str2);
- tell_user(stderr, "%s", str2);
- va_end(ap);
- sfree(str2);
-}
-
-/*
- * Execute the source part of the SCP protocol.
- */
-static void source(char *src)
-{
- unsigned long size;
- unsigned long mtime, atime;
- char *last;
- RFile *f;
- int attr;
- unsigned long i;
- unsigned long stat_bytes;
- time_t stat_starttime, stat_lasttime;
-
- attr = file_type(src);
- if (attr == FILE_TYPE_NONEXISTENT ||
- attr == FILE_TYPE_WEIRD) {
- run_err("%s: %s file or directory", src,
- (attr == FILE_TYPE_WEIRD ? "Not a" : "No such"));
- return;
- }
-
- if (attr == FILE_TYPE_DIRECTORY) {
- if (recursive) {
- /*
- * Avoid . and .. directories.
- */
- char *p;
- p = strrchr(src, '/');
- if (!p)
- p = strrchr(src, '\\');
- if (!p)
- p = src;
- else
- p++;
- if (!strcmp(p, ".") || !strcmp(p, ".."))
- /* skip . and .. */ ;
- else
- rsource(src);
- } else {
- run_err("%s: not a regular file", src);
- }
- return;
- }
-
- if ((last = strrchr(src, '/')) == NULL)
- last = src;
- else
- last++;
- if (strrchr(last, '\\') != NULL)
- last = strrchr(last, '\\') + 1;
- if (last == src && strchr(src, ':') != NULL)
- last = strchr(src, ':') + 1;
-
- f = open_existing_file(src, &size, &mtime, &atime);
- if (f == NULL) {
- run_err("%s: Cannot open file", src);
- return;
- }
- if (preserve) {
- if (scp_send_filetimes(mtime, atime))
- return;
- }
-
- if (verbose)
- tell_user(stderr, "Sending file %s, size=%lu", last, size);
- if (scp_send_filename(last, size, 0644))
- return;
-
- stat_bytes = 0;
- stat_starttime = time(NULL);
- stat_lasttime = 0;
-
- for (i = 0; i < size; i += 4096) {
- char transbuf[4096];
- int j, k = 4096;
-
- if (i + k > size)
- k = size - i;
- if ((j = read_from_file(f, transbuf, k)) != k) {
- if (statistics)
- printf("\n");
- bump("%s: Read error", src);
- }
- if (scp_send_filedata(transbuf, k))
- bump("%s: Network error occurred", src);
-
- if (statistics) {
- stat_bytes += k;
- if (time(NULL) != stat_lasttime || i + k == size) {
- stat_lasttime = time(NULL);
- print_stats(last, size, stat_bytes,
- stat_starttime, stat_lasttime);
- }
- }
-
- }
- close_rfile(f);
-
- (void) scp_send_finish();
-}
-
-/*
- * Recursively send the contents of a directory.
- */
-static void rsource(char *src)
-{
- char *last;
- char *save_target;
- DirHandle *dir;
-
- if ((last = strrchr(src, '/')) == NULL)
- last = src;
- else
- last++;
- if (strrchr(last, '\\') != NULL)
- last = strrchr(last, '\\') + 1;
- if (last == src && strchr(src, ':') != NULL)
- last = strchr(src, ':') + 1;
-
- /* maybe send filetime */
-
- save_target = scp_save_remotepath();
-
- if (verbose)
- tell_user(stderr, "Entering directory: %s", last);
- if (scp_send_dirname(last, 0755))
- return;
-
- dir = open_directory(src);
- if (dir != NULL) {
- char *filename;
- while ((filename = read_filename(dir)) != NULL) {
- char *foundfile = dupcat(src, "/", filename, NULL);
- source(foundfile);
- sfree(foundfile);
- sfree(filename);
- }
- }
- close_directory(dir);
-
- (void) scp_send_enddir();
-
- scp_restore_remotepath(save_target);
-}
-
-/*
- * Execute the sink part of the SCP protocol.
- */
-static void sink(char *targ, char *src)
-{
- char *destfname;
- int targisdir = 0;
- int exists;
- int attr;
- WFile *f;
- unsigned long received;
- int wrerror = 0;
- unsigned long stat_bytes;
- time_t stat_starttime, stat_lasttime;
- char *stat_name;
-
- attr = file_type(targ);
- if (attr == FILE_TYPE_DIRECTORY)
- targisdir = 1;
-
- if (targetshouldbedirectory && !targisdir)
- bump("%s: Not a directory", targ);
-
- scp_sink_init();
- while (1) {
- struct scp_sink_action act;
- if (scp_get_sink_action(&act))
- return;
-
- if (act.action == SCP_SINK_ENDDIR)
- return;
-
- if (act.action == SCP_SINK_RETRY)
- continue;
-
- if (targisdir) {
- /*
- * Prevent the remote side from maliciously writing to
- * files outside the target area by sending a filename
- * containing `../'. In fact, it shouldn't be sending
- * filenames with any slashes or colons in at all; so
- * we'll find the last slash, backslash or colon in the
- * filename and use only the part after that. (And
- * warn!)
- *
- * In addition, we also ensure here that if we're
- * copying a single file and the target is a directory
- * (common usage: `pscp host:filename .') the remote
- * can't send us a _different_ file name. We can
- * distinguish this case because `src' will be non-NULL
- * and the last component of that will fail to match
- * (the last component of) the name sent.
- *
- * Well, not always; if `src' is a wildcard, we do
- * expect to get back filenames that don't correspond
- * exactly to it. Ideally in this case, we would like
- * to ensure that the returned filename actually
- * matches the wildcard pattern - but one of SCP's
- * protocol infelicities is that wildcard matching is
- * done at the server end _by the server's rules_ and
- * so in general this is infeasible. Hence, we only
- * accept filenames that don't correspond to `src' if
- * unsafe mode is enabled or we are using SFTP (which
- * resolves remote wildcards on the client side and can
- * be trusted).
- */
- char *striptarget, *stripsrc;
-
- striptarget = stripslashes(act.name, 1);
- if (striptarget != act.name) {
- tell_user(stderr, "warning: remote host sent a compound"
- " pathname '%s'", act.name);
- tell_user(stderr, " renaming local file to '%s'",
- striptarget);
- }
-
- /*
- * Also check to see if the target filename is '.' or
- * '..', or indeed '...' and so on because Windows
- * appears to interpret those like '..'.
- */
- if (is_dots(striptarget)) {
- bump("security violation: remote host attempted to write to"
- " a '.' or '..' path!");
- }
-
- if (src) {
- stripsrc = stripslashes(src, 1);
- if (strcmp(striptarget, stripsrc) &&
- !using_sftp && !scp_unsafe_mode) {
- tell_user(stderr, "warning: remote host tried to write "
- "to a file called '%s'", striptarget);
- tell_user(stderr, " when we requested a file "
- "called '%s'.", stripsrc);
- tell_user(stderr, " If this is a wildcard, "
- "consider upgrading to SSH 2 or using");
- tell_user(stderr, " the '-unsafe' option. Renaming"
- " of this file has been disallowed.");
- /* Override the name the server provided with our own. */
- striptarget = stripsrc;
- }
- }
-
- if (targ[0] != '\0')
- destfname = dir_file_cat(targ, striptarget);
- else
- destfname = dupstr(striptarget);
- } else {
- /*
- * In this branch of the if, the target area is a
- * single file with an explicitly specified name in any
- * case, so there's no danger.
- */
- destfname = dupstr(targ);
- }
- attr = file_type(destfname);
- exists = (attr != FILE_TYPE_NONEXISTENT);
-
- if (act.action == SCP_SINK_DIR) {
- if (exists && attr != FILE_TYPE_DIRECTORY) {
- run_err("%s: Not a directory", destfname);
- continue;
- }
- if (!exists) {
- if (!create_directory(destfname)) {
- run_err("%s: Cannot create directory", destfname);
- continue;
- }
- }
- sink(destfname, NULL);
- /* can we set the timestamp for directories ? */
- continue;
- }
-
- f = open_new_file(destfname);
- if (f == NULL) {
- run_err("%s: Cannot create file", destfname);
- continue;
- }
-
- if (scp_accept_filexfer())
- return;
-
- stat_bytes = 0;
- stat_starttime = time(NULL);
- stat_lasttime = 0;
- stat_name = stripslashes(destfname, 1);
-
- received = 0;
- while (received < act.size) {
- char transbuf[4096];
- unsigned long blksize;
- int read;
- blksize = 4096;
- if (blksize > (act.size - received))
- blksize = act.size - received;
- read = scp_recv_filedata(transbuf, (int)blksize);
- if (read <= 0)
- bump("Lost connection");
- if (wrerror)
- continue;
- if (write_to_file(f, transbuf, read) != (int)read) {
- wrerror = 1;
- /* FIXME: in sftp we can actually abort the transfer */
- if (statistics)
- printf("\r%-25.25s | %50s\n",
- stat_name,
- "Write error.. waiting for end of file");
- continue;
- }
- if (statistics) {
- stat_bytes += read;
- if (time(NULL) > stat_lasttime ||
- received + read == act.size) {
- stat_lasttime = time(NULL);
- print_stats(stat_name, act.size, stat_bytes,
- stat_starttime, stat_lasttime);
- }
- }
- received += read;
- }
- if (act.settime) {
- set_file_times(f, act.mtime, act.atime);
- }
-
- close_wfile(f);
- if (wrerror) {
- run_err("%s: Write error", destfname);
- continue;
- }
- (void) scp_finish_filerecv();
- sfree(destfname);
- sfree(act.buf);
- }
-}
-
-/*
- * We will copy local files to a remote server.
- */
-static void toremote(int argc, char *argv[])
-{
- char *src, *targ, *host, *user;
- char *cmd;
- int i, wc_type;
-
- targ = argv[argc - 1];
-
- /* Separate host from filename */
- host = targ;
- targ = colon(targ);
- if (targ == NULL)
- bump("targ == NULL in toremote()");
- *targ++ = '\0';
- if (*targ == '\0')
- targ = ".";
- /* Substitute "." for emtpy target */
-
- /* Separate host and username */
- user = host;
- host = strrchr(host, '@');
- if (host == NULL) {
- host = user;
- user = NULL;
- } else {
- *host++ = '\0';
- if (*user == '\0')
- user = NULL;
- }
-
- if (argc == 2) {
- if (colon(argv[0]) != NULL)
- bump("%s: Remote to remote not supported", argv[0]);
-
- wc_type = test_wildcard(argv[0], 1);
- if (wc_type == WCTYPE_NONEXISTENT)
- bump("%s: No such file or directory\n", argv[0]);
- else if (wc_type == WCTYPE_WILDCARD)
- targetshouldbedirectory = 1;
- }
-
- cmd = dupprintf("scp%s%s%s%s -t %s",
- verbose ? " -v" : "",
- recursive ? " -r" : "",
- preserve ? " -p" : "",
- targetshouldbedirectory ? " -d" : "", targ);
- do_cmd(host, user, cmd);
- sfree(cmd);
-
- scp_source_setup(targ, targetshouldbedirectory);
-
- for (i = 0; i < argc - 1; i++) {
- src = argv[i];
- if (colon(src) != NULL) {
- tell_user(stderr, "%s: Remote to remote not supported\n", src);
- errs++;
- continue;
- }
-
- wc_type = test_wildcard(src, 1);
- if (wc_type == WCTYPE_NONEXISTENT) {
- run_err("%s: No such file or directory", src);
- continue;
- } else if (wc_type == WCTYPE_FILENAME) {
- source(src);
- continue;
- } else {
- WildcardMatcher *wc;
- char *filename;
-
- wc = begin_wildcard_matching(src);
- if (wc == NULL) {
- run_err("%s: No such file or directory", src);
- continue;
- }
-
- while ((filename = wildcard_get_filename(wc)) != NULL) {
- source(filename);
- sfree(filename);
- }
-
- finish_wildcard_matching(wc);
- }
- }
-}
-
-/*
- * We will copy files from a remote server to the local machine.
- */
-static void tolocal(int argc, char *argv[])
-{
- char *src, *targ, *host, *user;
- char *cmd;
-
- if (argc != 2)
- bump("More than one remote source not supported");
-
- src = argv[0];
- targ = argv[1];
-
- /* Separate host from filename */
- host = src;
- src = colon(src);
- if (src == NULL)
- bump("Local to local copy not supported");
- *src++ = '\0';
- if (*src == '\0')
- src = ".";
- /* Substitute "." for empty filename */
-
- /* Separate username and hostname */
- user = host;
- host = strrchr(host, '@');
- if (host == NULL) {
- host = user;
- user = NULL;
- } else {
- *host++ = '\0';
- if (*user == '\0')
- user = NULL;
- }
-
- cmd = dupprintf("scp%s%s%s%s -f %s",
- verbose ? " -v" : "",
- recursive ? " -r" : "",
- preserve ? " -p" : "",
- targetshouldbedirectory ? " -d" : "", src);
- do_cmd(host, user, cmd);
- sfree(cmd);
-
- if (scp_sink_setup(src, preserve, recursive))
- return;
-
- sink(targ, src);
-}
-
-/*
- * We will issue a list command to get a remote directory.
- */
-static void get_dir_list(int argc, char *argv[])
-{
- char *src, *host, *user;
- char *cmd, *p, *q;
- char c;
-
- src = argv[0];
-
- /* Separate host from filename */
- host = src;
- src = colon(src);
- if (src == NULL)
- bump("Local to local copy not supported");
- *src++ = '\0';
- if (*src == '\0')
- src = ".";
- /* Substitute "." for empty filename */
-
- /* Separate username and hostname */
- user = host;
- host = strrchr(host, '@');
- if (host == NULL) {
- host = user;
- user = NULL;
- } else {
- *host++ = '\0';
- if (*user == '\0')
- user = NULL;
- }
-
- cmd = snewn(4 * strlen(src) + 100, char);
- strcpy(cmd, "ls -la '");
- p = cmd + strlen(cmd);
- for (q = src; *q; q++) {
- if (*q == '\'') {
- *p++ = '\'';
- *p++ = '\\';
- *p++ = '\'';
- *p++ = '\'';
- } else {
- *p++ = *q;
- }
- }
- *p++ = '\'';
- *p = '\0';
-
- do_cmd(host, user, cmd);
- sfree(cmd);
-
- if (using_sftp) {
- scp_sftp_listdir(src);
- } else {
- while (ssh_scp_recv((unsigned char *) &c, 1) > 0)
- tell_char(stdout, c);
- }
-}
-
-/*
- * Short description of parameters.
- */
-static void usage(void)
-{
- printf("PuTTY Secure Copy client\n");
- printf("%s\n", ver);
- printf("Usage: pscp [options] [user@]host:source target\n");
- printf
- (" pscp [options] source [source...] [user@]host:target\n");
- printf(" pscp [options] -ls [user@]host:filespec\n");
- printf("Options:\n");
- printf(" -p preserve file attributes\n");
- printf(" -q quiet, don't show statistics\n");
- printf(" -r copy directories recursively\n");
- printf(" -v show verbose messages\n");
- printf(" -load sessname Load settings from saved session\n");
- printf(" -P port connect to specified port\n");
- printf(" -l user connect with specified username\n");
- printf(" -pw passw login with specified password\n");
- printf(" -1 -2 force use of particular SSH protocol version\n");
- printf(" -C enable compression\n");
- printf(" -i key private key file for authentication\n");
- printf(" -batch disable all interactive prompts\n");
- printf(" -unsafe allow server-side wildcards (DANGEROUS)\n");
- printf(" -V print version information\n");
- printf(" -sftp force use of SFTP protocol\n");
- printf(" -scp force use of SCP protocol\n");
-#if 0
- /*
- * -gui is an internal option, used by GUI front ends to get
- * pscp to pass progress reports back to them. It's not an
- * ordinary user-accessible option, so it shouldn't be part of
- * the command-line help. The only people who need to know
- * about it are programmers, and they can read the source.
- */
- printf
- (" -gui hWnd GUI mode with the windows handle for receiving messages\n");
-#endif
- cleanup_exit(1);
-}
-
-void version(void)
-{
- printf("pscp: %s\n", ver);
- cleanup_exit(1);
-}
-
-void cmdline_error(char *p, ...)
-{
- va_list ap;
- fprintf(stderr, "pscp: ");
- va_start(ap, p);
- vfprintf(stderr, p, ap);
- va_end(ap);
- fprintf(stderr, "\n try typing just \"pscp\" for help\n");
- exit(1);
-}
-
-/*
- * Main program. (Called `psftp_main' because it gets called from
- * *sftp.c; bit silly, I know, but it had to be called _something_.)
- */
-int psftp_main(int argc, char *argv[])
-{
- int i;
-
- default_protocol = PROT_TELNET;
-
- flags = FLAG_STDERR
-#ifdef FLAG_SYNCAGENT
- | FLAG_SYNCAGENT
-#endif
- ;
- cmdline_tooltype = TOOLTYPE_FILETRANSFER;
- ssh_get_line = &console_get_line;
- sk_init();
-
- /* Load Default Settings before doing anything else. */
- do_defaults(NULL, &cfg);
- loaded_session = FALSE;
-
- for (i = 1; i < argc; i++) {
- int ret;
- if (argv[i][0] != '-')
- break;
- ret = cmdline_process_param(argv[i], i+1<argc?argv[i+1]:NULL, 1, &cfg);
- if (ret == -2) {
- cmdline_error("option \"%s\" requires an argument", argv[i]);
- } else if (ret == 2) {
- i++; /* skip next argument */
- } else if (ret == 1) {
- /* We have our own verbosity in addition to `flags'. */
- if (flags & FLAG_VERBOSE)
- verbose = 1;
- } else if (strcmp(argv[i], "-r") == 0) {
- recursive = 1;
- } else if (strcmp(argv[i], "-p") == 0) {
- preserve = 1;
- } else if (strcmp(argv[i], "-q") == 0) {
- statistics = 0;
- } else if (strcmp(argv[i], "-h") == 0 || strcmp(argv[i], "-?") == 0) {
- usage();
- } else if (strcmp(argv[i], "-V") == 0) {
- version();
- } else if (strcmp(argv[i], "-gui") == 0 && i + 1 < argc) {
- gui_enable(argv[++i]);
- gui_mode = 1;
- console_batch_mode = TRUE;
- } else if (strcmp(argv[i], "-ls") == 0) {
- list = 1;
- } else if (strcmp(argv[i], "-batch") == 0) {
- console_batch_mode = 1;
- } else if (strcmp(argv[i], "-unsafe") == 0) {
- scp_unsafe_mode = 1;
- } else if (strcmp(argv[i], "-sftp") == 0) {
- try_scp = 0; try_sftp = 1;
- } else if (strcmp(argv[i], "-scp") == 0) {
- try_scp = 1; try_sftp = 0;
- } else if (strcmp(argv[i], "--") == 0) {
- i++;
- break;
- } else {
- cmdline_error("unknown option \"%s\"", argv[i]);
- }
- }
- argc -= i;
- argv += i;
- back = NULL;
-
- if (list) {
- if (argc != 1)
- usage();
- get_dir_list(argc, argv);
-
- } else {
-
- if (argc < 2)
- usage();
- if (argc > 2)
- targetshouldbedirectory = 1;
-
- if (colon(argv[argc - 1]) != NULL)
- toremote(argc, argv);
- else
- tolocal(argc, argv);
- }
-
- if (back != NULL && back->socket(backhandle) != NULL) {
- char ch;
- back->special(backhandle, TS_EOF);
- ssh_scp_recv((unsigned char *) &ch, 1);
- }
- random_save_seed();
-
- if (gui_mode)
- gui_send_errcount(list, errs);
-
- cmdline_cleanup();
- console_provide_logctx(NULL);
- back->free(backhandle);
- backhandle = NULL;
- back = NULL;
- sk_cleanup();
- return (errs == 0 ? 0 : 1);
-}
-
-/* end */
projects / u / mdw / putty / blobdiff