1 /* $OpenBSD: scp.c,v 1.180 2014/06/24 02:21:01 djm Exp $ */
3 * scp - secure remote copy. This is basically patched BSD rcp which
4 * uses ssh to do the data transfer (instead of using rcmd).
6 * NOTE: This version should NOT be suid root. (This uses ssh to
7 * do the transfer and ssh has the necessary privileges.)
9 * 1995 Timo Rinne <tri@iki.fi>, Tatu Ylonen <ylo@cs.hut.fi>
11 * As far as I am concerned, the code I have written for this software
12 * can be used freely for any purpose. Any derived versions of this
13 * software must be clearly marked as such, and if the derived work is
14 * incompatible with the protocol description in the RFC file, it must be
15 * called by a name other than "ssh" or "Secure Shell".
18 * Copyright (c) 1999 Theo de Raadt. All rights reserved.
19 * Copyright (c) 1999 Aaron Campbell. All rights reserved.
21 * Redistribution and use in source and binary forms, with or without
22 * modification, are permitted provided that the following conditions
24 * 1. Redistributions of source code must retain the above copyright
25 * notice, this list of conditions and the following disclaimer.
26 * 2. Redistributions in binary form must reproduce the above copyright
27 * notice, this list of conditions and the following disclaimer in the
28 * documentation and/or other materials provided with the distribution.
30 * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
31 * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
32 * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
33 * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,
34 * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
35 * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
36 * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
37 * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
38 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
39 * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
45 * Copyright (c) 1983, 1990, 1992, 1993, 1995
46 * The Regents of the University of California. All rights reserved.
48 * Redistribution and use in source and binary forms, with or without
49 * modification, are permitted provided that the following conditions
51 * 1. Redistributions of source code must retain the above copyright
52 * notice, this list of conditions and the following disclaimer.
53 * 2. Redistributions in binary form must reproduce the above copyright
54 * notice, this list of conditions and the following disclaimer in the
55 * documentation and/or other materials provided with the distribution.
56 * 3. Neither the name of the University nor the names of its contributors
57 * may be used to endorse or promote products derived from this software
58 * without specific prior written permission.
60 * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
61 * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
62 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
63 * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
64 * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
65 * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
66 * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
67 * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
68 * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
69 * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
76 #include <sys/types.h>
77 #include <sys/param.h>
78 #ifdef HAVE_SYS_STAT_H
79 # include <sys/stat.h>
84 # ifdef HAVE_SYS_POLL_H
85 # include <sys/poll.h>
88 #ifdef HAVE_SYS_TIME_H
89 # include <sys/time.h>
106 #if defined(HAVE_STRNVIS) && defined(HAVE_VIS_H) && !defined(BROKEN_STRNVIS)
111 #include "atomicio.h"
112 #include "pathnames.h"
115 #include "progressmeter.h"
117 extern char *__progname
;
119 #define COPY_BUFLEN 16384
121 int do_cmd(char *host
, char *remuser
, char *cmd
, int *fdin
, int *fdout
);
122 int do_cmd2(char *host
, char *remuser
, char *cmd
, int fdin
, int fdout
);
124 /* Struct for addargs */
126 arglist remote_remote_args
;
128 /* Bandwidth limit */
129 long long limit_kbps
= 0;
130 struct bwlimit bwlimit
;
132 /* Name of current file being transferred. */
135 /* This is set to non-zero to enable verbose mode. */
136 int verbose_mode
= 0;
138 /* This is set to zero if the progressmeter is not desired. */
139 int showprogress
= 1;
142 * This is set to non-zero if remote-remote copy should be piped
143 * through this process.
145 int throughlocal
= 0;
147 /* This is the program to execute for the secured connection. ("ssh" or -S) */
148 char *ssh_program
= _PATH_SSH_PROGRAM
;
150 /* This is used to store the pid of ssh_program */
151 pid_t do_cmd_pid
= -1;
156 if (do_cmd_pid
> 1) {
157 kill(do_cmd_pid
, signo
? signo
: SIGTERM
);
158 waitpid(do_cmd_pid
, NULL
, 0);
171 if (do_cmd_pid
> 1) {
172 kill(do_cmd_pid
, signo
);
173 while (waitpid(do_cmd_pid
, &status
, WUNTRACED
) == -1 &&
176 kill(getpid(), SIGSTOP
);
181 do_local_cmd(arglist
*a
)
188 fatal("do_local_cmd: no arguments");
191 fprintf(stderr
, "Executing:");
192 for (i
= 0; i
< a
->num
; i
++)
193 fprintf(stderr
, " %s", a
->list
[i
]);
194 fprintf(stderr
, "\n");
196 if ((pid
= fork()) == -1)
197 fatal("do_local_cmd: fork: %s", strerror(errno
));
200 execvp(a
->list
[0], a
->list
);
206 signal(SIGTERM
, killchild
);
207 signal(SIGINT
, killchild
);
208 signal(SIGHUP
, killchild
);
210 while (waitpid(pid
, &status
, 0) == -1)
212 fatal("do_local_cmd: waitpid: %s", strerror(errno
));
216 if (!WIFEXITED(status
) || WEXITSTATUS(status
) != 0)
223 * This function executes the given command as the specified user on the
224 * given host. This returns < 0 if execution fails, and >= 0 otherwise. This
225 * assigns the input and output file descriptors on success.
229 do_cmd(char *host
, char *remuser
, char *cmd
, int *fdin
, int *fdout
)
231 int pin
[2], pout
[2], reserved
[2];
235 "Executing: program %s host %s, user %s, command %s\n",
237 remuser
? remuser
: "(unspecified)", cmd
);
240 * Reserve two descriptors so that the real pipes won't get
241 * descriptors 0 and 1 because that will screw up dup2 below.
243 if (pipe(reserved
) < 0)
244 fatal("pipe: %s", strerror(errno
));
246 /* Create a socket pair for communicating with ssh. */
248 fatal("pipe: %s", strerror(errno
));
250 fatal("pipe: %s", strerror(errno
));
252 /* Free the reserved descriptors. */
256 signal(SIGTSTP
, suspchild
);
257 signal(SIGTTIN
, suspchild
);
258 signal(SIGTTOU
, suspchild
);
260 /* Fork a child to execute the command on the remote host using ssh. */
262 if (do_cmd_pid
== 0) {
271 replacearg(&args
, 0, "%s", ssh_program
);
272 if (remuser
!= NULL
) {
273 addargs(&args
, "-l");
274 addargs(&args
, "%s", remuser
);
276 addargs(&args
, "--");
277 addargs(&args
, "%s", host
);
278 addargs(&args
, "%s", cmd
);
280 execvp(ssh_program
, args
.list
);
283 } else if (do_cmd_pid
== -1) {
284 fatal("fork: %s", strerror(errno
));
286 /* Parent. Close the other side, and return the local side. */
291 signal(SIGTERM
, killchild
);
292 signal(SIGINT
, killchild
);
293 signal(SIGHUP
, killchild
);
298 * This functions executes a command simlar to do_cmd(), but expects the
299 * input and output descriptors to be setup by a previous call to do_cmd().
300 * This way the input and output of two commands can be connected.
303 do_cmd2(char *host
, char *remuser
, char *cmd
, int fdin
, int fdout
)
310 "Executing: 2nd program %s host %s, user %s, command %s\n",
312 remuser
? remuser
: "(unspecified)", cmd
);
314 /* Fork a child to execute the command on the remote host using ssh. */
320 replacearg(&args
, 0, "%s", ssh_program
);
321 if (remuser
!= NULL
) {
322 addargs(&args
, "-l");
323 addargs(&args
, "%s", remuser
);
325 addargs(&args
, "--");
326 addargs(&args
, "%s", host
);
327 addargs(&args
, "%s", cmd
);
329 execvp(ssh_program
, args
.list
);
332 } else if (pid
== -1) {
333 fatal("fork: %s", strerror(errno
));
335 while (waitpid(pid
, &status
, 0) == -1)
337 fatal("do_cmd2: waitpid: %s", strerror(errno
));
346 BUF
*allocbuf(BUF
*, int, int);
349 void run_err(const char *,...);
350 void verifydir(char *);
354 int errs
, remin
, remout
;
355 int pflag
, iamremote
, iamrecursive
, targetshouldbedirectory
;
358 char cmd
[CMDNEEDS
]; /* must hold "rcp -r -p -d\0" */
361 void rsource(char *, struct stat
*);
362 void sink(int, char *[]);
363 void source(int, char *[]);
364 void tolocal(int, char *[]);
365 void toremote(char *, int, char *[]);
369 main(int argc
, char **argv
)
371 int ch
, fflag
, tflag
, status
, n
;
372 char *targ
, **newargv
;
377 /* Ensure that fds 0, 1 and 2 are open or directed to /dev/null */
380 /* Copy argv, because we modify it */
381 newargv
= xcalloc(MAX(argc
+ 1, 1), sizeof(*newargv
));
382 for (n
= 0; n
< argc
; n
++)
383 newargv
[n
] = xstrdup(argv
[n
]);
386 __progname
= ssh_get_progname(argv
[0]);
388 memset(&args
, '\0', sizeof(args
));
389 memset(&remote_remote_args
, '\0', sizeof(remote_remote_args
));
390 args
.list
= remote_remote_args
.list
= NULL
;
391 addargs(&args
, "%s", ssh_program
);
392 addargs(&args
, "-x");
393 addargs(&args
, "-oForwardAgent=no");
394 addargs(&args
, "-oPermitLocalCommand=no");
395 addargs(&args
, "-oClearAllForwardings=yes");
398 while ((ch
= getopt(argc
, argv
, "dfl:prtvBCc:i:P:q12346S:o:F:")) != -1)
400 /* User-visible flags. */
406 addargs(&args
, "-%c", ch
);
407 addargs(&remote_remote_args
, "-%c", ch
);
416 addargs(&remote_remote_args
, "-%c", ch
);
417 addargs(&remote_remote_args
, "%s", optarg
);
418 addargs(&args
, "-%c", ch
);
419 addargs(&args
, "%s", optarg
);
422 addargs(&remote_remote_args
, "-p");
423 addargs(&remote_remote_args
, "%s", optarg
);
424 addargs(&args
, "-p");
425 addargs(&args
, "%s", optarg
);
428 addargs(&remote_remote_args
, "-oBatchmode=yes");
429 addargs(&args
, "-oBatchmode=yes");
432 limit_kbps
= strtonum(optarg
, 1, 100 * 1024 * 1024,
436 limit_kbps
*= 1024; /* kbps */
437 bandwidth_limit_init(&bwlimit
, limit_kbps
, COPY_BUFLEN
);
446 ssh_program
= xstrdup(optarg
);
449 addargs(&args
, "-v");
450 addargs(&remote_remote_args
, "-v");
454 addargs(&args
, "-q");
455 addargs(&remote_remote_args
, "-q");
459 /* Server options. */
461 targetshouldbedirectory
= 1;
463 case 'f': /* "from" */
471 setmode(0, O_BINARY
);
480 if ((pwd
= getpwuid(userid
= getuid())) == NULL
)
481 fatal("unknown user %u", (u_int
) userid
);
483 if (!isatty(STDOUT_FILENO
))
486 remin
= STDIN_FILENO
;
487 remout
= STDOUT_FILENO
;
490 /* Follow "protocol", send data. */
503 targetshouldbedirectory
= 1;
507 /* Command to be executed on remote system using "ssh". */
508 (void) snprintf(cmd
, sizeof cmd
, "scp%s%s%s%s",
509 verbose_mode
? " -v" : "",
510 iamrecursive
? " -r" : "", pflag
? " -p" : "",
511 targetshouldbedirectory
? " -d" : "");
513 (void) signal(SIGPIPE
, lostconn
);
515 if ((targ
= colon(argv
[argc
- 1]))) /* Dest is remote host. */
516 toremote(targ
, argc
, argv
);
518 if (targetshouldbedirectory
)
519 verifydir(argv
[argc
- 1]);
520 tolocal(argc
, argv
); /* Dest is local host. */
523 * Finally check the exit status of the ssh process, if one was forked
524 * and no error has occurred yet
526 if (do_cmd_pid
!= -1 && errs
== 0) {
530 (void) close(remout
);
531 if (waitpid(do_cmd_pid
, &status
, 0) == -1)
534 if (!WIFEXITED(status
) || WEXITSTATUS(status
) != 0)
541 /* Callback from atomicio6 to update progress meter and limit bandwidth */
543 scpio(void *_cnt
, size_t s
)
545 off_t
*cnt
= (off_t
*)_cnt
;
549 bandwidth_limit(&bwlimit
, s
);
554 do_times(int fd
, int verb
, const struct stat
*sb
)
556 /* strlen(2^64) == 20; strlen(10^6) == 7 */
557 char buf
[(20 + 7 + 2) * 2 + 2];
559 (void)snprintf(buf
, sizeof(buf
), "T%llu 0 %llu 0\n",
560 (unsigned long long) (sb
->st_mtime
< 0 ? 0 : sb
->st_mtime
),
561 (unsigned long long) (sb
->st_atime
< 0 ? 0 : sb
->st_atime
));
563 fprintf(stderr
, "File mtime %lld atime %lld\n",
564 (long long)sb
->st_mtime
, (long long)sb
->st_atime
);
565 fprintf(stderr
, "Sending file timestamps: %s", buf
);
567 (void) atomicio(vwrite
, fd
, buf
, strlen(buf
));
572 toremote(char *targ
, int argc
, char **argv
)
574 char *bp
, *host
, *src
, *suser
, *thost
, *tuser
, *arg
;
579 memset(&alist
, '\0', sizeof(alist
));
586 arg
= xstrdup(argv
[argc
- 1]);
587 if ((thost
= strrchr(arg
, '@'))) {
598 if (tuser
!= NULL
&& !okname(tuser
)) {
603 for (i
= 0; i
< argc
- 1; i
++) {
604 src
= colon(argv
[i
]);
605 if (src
&& throughlocal
) { /* extended remote to remote */
609 host
= strrchr(argv
[i
], '@');
612 host
= cleanhostname(host
);
615 suser
= pwd
->pw_name
;
616 else if (!okname(suser
))
619 host
= cleanhostname(argv
[i
]);
622 xasprintf(&bp
, "%s -f %s%s", cmd
,
623 *src
== '-' ? "-- " : "", src
);
624 if (do_cmd(host
, suser
, bp
, &remin
, &remout
) < 0)
627 host
= cleanhostname(thost
);
628 xasprintf(&bp
, "%s -t %s%s", cmd
,
629 *targ
== '-' ? "-- " : "", targ
);
630 if (do_cmd2(host
, tuser
, bp
, remin
, remout
) < 0)
634 (void) close(remout
);
636 } else if (src
) { /* standard remote to remote */
638 addargs(&alist
, "%s", ssh_program
);
639 addargs(&alist
, "-x");
640 addargs(&alist
, "-oClearAllForwardings=yes");
641 addargs(&alist
, "-n");
642 for (j
= 0; j
< remote_remote_args
.num
; j
++) {
643 addargs(&alist
, "%s",
644 remote_remote_args
.list
[j
]);
649 host
= strrchr(argv
[i
], '@');
653 host
= cleanhostname(host
);
656 suser
= pwd
->pw_name
;
657 else if (!okname(suser
))
659 addargs(&alist
, "-l");
660 addargs(&alist
, "%s", suser
);
662 host
= cleanhostname(argv
[i
]);
664 addargs(&alist
, "--");
665 addargs(&alist
, "%s", host
);
666 addargs(&alist
, "%s", cmd
);
667 addargs(&alist
, "%s", src
);
668 addargs(&alist
, "%s%s%s:%s",
669 tuser
? tuser
: "", tuser
? "@" : "",
671 if (do_local_cmd(&alist
) != 0)
673 } else { /* local to remote */
675 xasprintf(&bp
, "%s -t %s%s", cmd
,
676 *targ
== '-' ? "-- " : "", targ
);
677 host
= cleanhostname(thost
);
678 if (do_cmd(host
, tuser
, bp
, &remin
,
692 tolocal(int argc
, char **argv
)
694 char *bp
, *host
, *src
, *suser
;
698 memset(&alist
, '\0', sizeof(alist
));
701 for (i
= 0; i
< argc
- 1; i
++) {
702 if (!(src
= colon(argv
[i
]))) { /* Local to local. */
704 addargs(&alist
, "%s", _PATH_CP
);
706 addargs(&alist
, "-r");
708 addargs(&alist
, "-p");
709 addargs(&alist
, "--");
710 addargs(&alist
, "%s", argv
[i
]);
711 addargs(&alist
, "%s", argv
[argc
-1]);
712 if (do_local_cmd(&alist
))
719 if ((host
= strrchr(argv
[i
], '@')) == NULL
) {
726 suser
= pwd
->pw_name
;
728 host
= cleanhostname(host
);
729 xasprintf(&bp
, "%s -f %s%s",
730 cmd
, *src
== '-' ? "-- " : "", src
);
731 if (do_cmd(host
, suser
, bp
, &remin
, &remout
) < 0) {
737 sink(1, argv
+ argc
- 1);
744 source(int argc
, char **argv
)
751 int fd
= -1, haderr
, indx
;
752 char *last
, *name
, buf
[2048], encname
[MAXPATHLEN
];
755 for (indx
= 0; indx
< argc
; ++indx
) {
759 while (len
> 1 && name
[len
-1] == '/')
761 if ((fd
= open(name
, O_RDONLY
|O_NONBLOCK
, 0)) < 0)
763 if (strchr(name
, '\n') != NULL
) {
764 strnvis(encname
, name
, sizeof(encname
), VIS_NL
);
767 if (fstat(fd
, &stb
) < 0) {
768 syserr
: run_err("%s: %s", name
, strerror(errno
));
771 if (stb
.st_size
< 0) {
772 run_err("%s: %s", name
, "Negative file size");
776 switch (stb
.st_mode
& S_IFMT
) {
786 run_err("%s: not a regular file", name
);
789 if ((last
= strrchr(name
, '/')) == NULL
)
795 if (do_times(remout
, verbose_mode
, &stb
) < 0)
798 #define FILEMODEMASK (S_ISUID|S_ISGID|S_IRWXU|S_IRWXG|S_IRWXO)
799 snprintf(buf
, sizeof buf
, "C%04o %lld %s\n",
800 (u_int
) (stb
.st_mode
& FILEMODEMASK
),
801 (long long)stb
.st_size
, last
);
803 fprintf(stderr
, "Sending file modes: %s", buf
);
805 (void) atomicio(vwrite
, remout
, buf
, strlen(buf
));
808 if ((bp
= allocbuf(&buffer
, fd
, COPY_BUFLEN
)) == NULL
) {
809 next
: if (fd
!= -1) {
816 start_progress_meter(curfile
, stb
.st_size
, &statbytes
);
817 set_nonblock(remout
);
818 for (haderr
= i
= 0; i
< stb
.st_size
; i
+= bp
->cnt
) {
820 if (i
+ (off_t
)amt
> stb
.st_size
)
821 amt
= stb
.st_size
- i
;
823 if ((nr
= atomicio(read
, fd
,
824 bp
->buf
, amt
)) != amt
) {
826 memset(bp
->buf
+ nr
, 0, amt
- nr
);
829 /* Keep writing after error to retain sync */
831 (void)atomicio(vwrite
, remout
, bp
->buf
, amt
);
832 memset(bp
->buf
, 0, amt
);
835 if (atomicio6(vwrite
, remout
, bp
->buf
, amt
, scpio
,
839 unset_nonblock(remout
);
841 stop_progress_meter();
844 if (close(fd
) < 0 && !haderr
)
849 (void) atomicio(vwrite
, remout
, "", 1);
851 run_err("%s: %s", name
, strerror(haderr
));
857 rsource(char *name
, struct stat
*statp
)
861 char *last
, *vect
[1], path
[MAXPATHLEN
];
863 if (!(dirp
= opendir(name
))) {
864 run_err("%s: %s", name
, strerror(errno
));
867 last
= strrchr(name
, '/');
873 if (do_times(remout
, verbose_mode
, statp
) < 0) {
878 (void) snprintf(path
, sizeof path
, "D%04o %d %.1024s\n",
879 (u_int
) (statp
->st_mode
& FILEMODEMASK
), 0, last
);
881 fprintf(stderr
, "Entering directory: %s", path
);
882 (void) atomicio(vwrite
, remout
, path
, strlen(path
));
883 if (response() < 0) {
887 while ((dp
= readdir(dirp
)) != NULL
) {
890 if (!strcmp(dp
->d_name
, ".") || !strcmp(dp
->d_name
, ".."))
892 if (strlen(name
) + 1 + strlen(dp
->d_name
) >= sizeof(path
) - 1) {
893 run_err("%s/%s: name too long", name
, dp
->d_name
);
896 (void) snprintf(path
, sizeof path
, "%s/%s", name
, dp
->d_name
);
900 (void) closedir(dirp
);
901 (void) atomicio(vwrite
, remout
, "E\n", 2);
906 sink(int argc
, char **argv
)
916 int amt
, exists
, first
, ofd
;
917 mode_t mode
, omode
, mask
;
918 off_t size
, statbytes
;
919 unsigned long long ull
;
920 int setimes
, targisdir
, wrerrno
= 0;
921 char ch
, *cp
, *np
, *targ
, *why
, *vect
[1], buf
[2048];
922 struct timeval tv
[2];
926 #define SCREWUP(str) { why = str; goto screwup; }
928 setimes
= targisdir
= 0;
933 run_err("ambiguous target");
937 if (targetshouldbedirectory
)
940 (void) atomicio(vwrite
, remout
, "", 1);
941 if (stat(targ
, &stb
) == 0 && S_ISDIR(stb
.st_mode
))
943 for (first
= 1;; first
= 0) {
945 if (atomicio(read
, remin
, cp
, 1) != 1)
948 SCREWUP("unexpected <newline>");
950 if (atomicio(read
, remin
, &ch
, sizeof(ch
)) != sizeof(ch
))
951 SCREWUP("lost connection");
953 } while (cp
< &buf
[sizeof(buf
) - 1] && ch
!= '\n');
956 fprintf(stderr
, "Sink: %s", buf
);
958 if (buf
[0] == '\01' || buf
[0] == '\02') {
960 (void) atomicio(vwrite
, STDERR_FILENO
,
961 buf
+ 1, strlen(buf
+ 1));
968 (void) atomicio(vwrite
, remout
, "", 1);
978 if (!isdigit((unsigned char)*cp
))
979 SCREWUP("mtime.sec not present");
980 ull
= strtoull(cp
, &cp
, 10);
981 if (!cp
|| *cp
++ != ' ')
982 SCREWUP("mtime.sec not delimited");
983 if ((time_t)ull
< 0 ||
984 (unsigned long long)(time_t)ull
!= ull
)
985 setimes
= 0; /* out of range */
987 mtime
.tv_usec
= strtol(cp
, &cp
, 10);
988 if (!cp
|| *cp
++ != ' ' || mtime
.tv_usec
< 0 ||
989 mtime
.tv_usec
> 999999)
990 SCREWUP("mtime.usec not delimited");
991 if (!isdigit((unsigned char)*cp
))
992 SCREWUP("atime.sec not present");
993 ull
= strtoull(cp
, &cp
, 10);
994 if (!cp
|| *cp
++ != ' ')
995 SCREWUP("atime.sec not delimited");
996 if ((time_t)ull
< 0 ||
997 (unsigned long long)(time_t)ull
!= ull
)
998 setimes
= 0; /* out of range */
1000 atime
.tv_usec
= strtol(cp
, &cp
, 10);
1001 if (!cp
|| *cp
++ != '\0' || atime
.tv_usec
< 0 ||
1002 atime
.tv_usec
> 999999)
1003 SCREWUP("atime.usec not delimited");
1004 (void) atomicio(vwrite
, remout
, "", 1);
1007 if (*cp
!= 'C' && *cp
!= 'D') {
1009 * Check for the case "rcp remote:foo\* local:bar".
1010 * In this case, the line "No match." can be returned
1011 * by the shell before the rcp command on the remote is
1012 * executed so the ^Aerror_message convention isn't
1019 SCREWUP("expected control record");
1022 for (++cp
; cp
< buf
+ 5; cp
++) {
1023 if (*cp
< '0' || *cp
> '7')
1024 SCREWUP("bad mode");
1025 mode
= (mode
<< 3) | (*cp
- '0');
1028 SCREWUP("mode not delimited");
1030 for (size
= 0; isdigit((unsigned char)*cp
);)
1031 size
= size
* 10 + (*cp
++ - '0');
1033 SCREWUP("size not delimited");
1034 if ((strchr(cp
, '/') != NULL
) || (strcmp(cp
, "..") == 0)) {
1035 run_err("error: unexpected filename: %s", cp
);
1039 static char *namebuf
;
1040 static size_t cursize
;
1043 need
= strlen(targ
) + strlen(cp
) + 250;
1044 if (need
> cursize
) {
1046 namebuf
= xmalloc(need
);
1049 (void) snprintf(namebuf
, need
, "%s%s%s", targ
,
1050 strcmp(targ
, "/") ? "/" : "", cp
);
1055 exists
= stat(np
, &stb
) == 0;
1056 if (buf
[0] == 'D') {
1057 int mod_flag
= pflag
;
1059 SCREWUP("received directory without -r");
1061 if (!S_ISDIR(stb
.st_mode
)) {
1066 (void) chmod(np
, mode
);
1068 /* Handle copying from a read-only
1071 if (mkdir(np
, mode
| S_IRWXU
) < 0)
1074 vect
[0] = xstrdup(np
);
1078 if (utimes(vect
[0], tv
) < 0)
1079 run_err("%s: set times: %s",
1080 vect
[0], strerror(errno
));
1083 (void) chmod(vect
[0], mode
);
1089 if ((ofd
= open(np
, O_WRONLY
|O_CREAT
, mode
)) < 0) {
1090 bad
: run_err("%s: %s", np
, strerror(errno
));
1093 (void) atomicio(vwrite
, remout
, "", 1);
1094 if ((bp
= allocbuf(&buffer
, ofd
, COPY_BUFLEN
)) == NULL
) {
1103 start_progress_meter(curfile
, size
, &statbytes
);
1104 set_nonblock(remin
);
1105 for (count
= i
= 0; i
< size
; i
+= bp
->cnt
) {
1111 j
= atomicio6(read
, remin
, cp
, amt
,
1114 run_err("%s", j
!= EPIPE
?
1116 "dropped connection");
1123 if (count
== bp
->cnt
) {
1124 /* Keep reading so we stay sync'd up. */
1126 if (atomicio(vwrite
, ofd
, bp
->buf
,
1136 unset_nonblock(remin
);
1138 stop_progress_meter();
1139 if (count
!= 0 && wrerr
== NO
&&
1140 atomicio(vwrite
, ofd
, bp
->buf
, count
) != count
) {
1144 if (wrerr
== NO
&& (!exists
|| S_ISREG(stb
.st_mode
)) &&
1145 ftruncate(ofd
, size
) != 0) {
1146 run_err("%s: truncate: %s", np
, strerror(errno
));
1150 if (exists
|| omode
!= mode
)
1152 if (fchmod(ofd
, omode
)) {
1153 #else /* HAVE_FCHMOD */
1154 if (chmod(np
, omode
)) {
1155 #endif /* HAVE_FCHMOD */
1156 run_err("%s: set mode: %s",
1157 np
, strerror(errno
));
1161 if (!exists
&& omode
!= mode
)
1163 if (fchmod(ofd
, omode
& ~mask
)) {
1164 #else /* HAVE_FCHMOD */
1165 if (chmod(np
, omode
& ~mask
)) {
1166 #endif /* HAVE_FCHMOD */
1167 run_err("%s: set mode: %s",
1168 np
, strerror(errno
));
1172 if (close(ofd
) == -1) {
1177 if (setimes
&& wrerr
== NO
) {
1179 if (utimes(np
, tv
) < 0) {
1180 run_err("%s: set times: %s",
1181 np
, strerror(errno
));
1187 run_err("%s: %s", np
, strerror(wrerrno
));
1190 (void) atomicio(vwrite
, remout
, "", 1);
1197 run_err("protocol error: %s", why
);
1204 char ch
, *cp
, resp
, rbuf
[2048];
1206 if (atomicio(read
, remin
, &resp
, sizeof(resp
)) != sizeof(resp
))
1216 case 1: /* error, followed by error msg */
1217 case 2: /* fatal error, "" */
1219 if (atomicio(read
, remin
, &ch
, sizeof(ch
)) != sizeof(ch
))
1222 } while (cp
< &rbuf
[sizeof(rbuf
) - 1] && ch
!= '\n');
1225 (void) atomicio(vwrite
, STDERR_FILENO
, rbuf
, cp
- rbuf
);
1237 (void) fprintf(stderr
,
1238 "usage: scp [-12346BCpqrv] [-c cipher] [-F ssh_config] [-i identity_file]\n"
1239 " [-l limit] [-o ssh_option] [-P port] [-S program]\n"
1240 " [[user@]host1:]file1 ... [[user@]host2:]file2\n");
1245 run_err(const char *fmt
,...)
1251 if (fp
!= NULL
|| (remout
!= -1 && (fp
= fdopen(remout
, "w")))) {
1252 (void) fprintf(fp
, "%c", 0x01);
1253 (void) fprintf(fp
, "scp: ");
1255 (void) vfprintf(fp
, fmt
, ap
);
1257 (void) fprintf(fp
, "\n");
1263 vfprintf(stderr
, fmt
, ap
);
1265 fprintf(stderr
, "\n");
1274 if (!stat(cp
, &stb
)) {
1275 if (S_ISDIR(stb
.st_mode
))
1279 run_err("%s: %s", cp
, strerror(errno
));
1294 if (!isalpha(c
) && !isdigit((unsigned char)c
)) {
1309 bad
: fprintf(stderr
, "%s: invalid user name\n", cp0
);
1314 allocbuf(BUF
*bp
, int fd
, int blksize
)
1317 #ifdef HAVE_STRUCT_STAT_ST_BLKSIZE
1320 if (fstat(fd
, &stb
) < 0) {
1321 run_err("fstat: %s", strerror(errno
));
1324 size
= roundup(stb
.st_blksize
, blksize
);
1327 #else /* HAVE_STRUCT_STAT_ST_BLKSIZE */
1329 #endif /* HAVE_STRUCT_STAT_ST_BLKSIZE */
1330 if (bp
->cnt
>= size
)
1332 if (bp
->buf
== NULL
)
1333 bp
->buf
= xmalloc(size
);
1335 bp
->buf
= xrealloc(bp
->buf
, 1, size
);
1336 memset(bp
->buf
, 0, size
);
1345 (void)write(STDERR_FILENO
, "lost connection\n", 16);