rcp.c revision 1.52 1 1.52 rin /* $NetBSD: rcp.c,v 1.52 2022/07/18 13:01:59 rin Exp $ */
2 1.9 cgd
3 1.1 cgd /*
4 1.9 cgd * Copyright (c) 1983, 1990, 1992, 1993
5 1.9 cgd * The Regents of the University of California. All rights reserved.
6 1.1 cgd *
7 1.1 cgd * Redistribution and use in source and binary forms, with or without
8 1.1 cgd * modification, are permitted provided that the following conditions
9 1.1 cgd * are met:
10 1.1 cgd * 1. Redistributions of source code must retain the above copyright
11 1.1 cgd * notice, this list of conditions and the following disclaimer.
12 1.1 cgd * 2. Redistributions in binary form must reproduce the above copyright
13 1.1 cgd * notice, this list of conditions and the following disclaimer in the
14 1.1 cgd * documentation and/or other materials provided with the distribution.
15 1.33 agc * 3. Neither the name of the University nor the names of its contributors
16 1.1 cgd * may be used to endorse or promote products derived from this software
17 1.1 cgd * without specific prior written permission.
18 1.1 cgd *
19 1.1 cgd * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
20 1.1 cgd * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
21 1.1 cgd * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
22 1.1 cgd * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
23 1.1 cgd * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
24 1.1 cgd * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
25 1.1 cgd * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
26 1.1 cgd * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
27 1.1 cgd * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
28 1.1 cgd * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
29 1.1 cgd * SUCH DAMAGE.
30 1.1 cgd */
31 1.1 cgd
32 1.15 christos #include <sys/cdefs.h>
33 1.1 cgd #ifndef lint
34 1.47 lukem __COPYRIGHT("@(#) Copyright (c) 1983, 1990, 1992, 1993\
35 1.47 lukem The Regents of the University of California. All rights reserved.");
36 1.1 cgd #endif /* not lint */
37 1.1 cgd
38 1.1 cgd #ifndef lint
39 1.9 cgd #if 0
40 1.9 cgd static char sccsid[] = "@(#)rcp.c 8.2 (Berkeley) 4/2/94";
41 1.9 cgd #else
42 1.52 rin __RCSID("$NetBSD: rcp.c,v 1.52 2022/07/18 13:01:59 rin Exp $");
43 1.9 cgd #endif
44 1.1 cgd #endif /* not lint */
45 1.1 cgd
46 1.1 cgd #include <sys/param.h>
47 1.1 cgd #include <sys/stat.h>
48 1.1 cgd #include <sys/time.h>
49 1.1 cgd #include <sys/socket.h>
50 1.1 cgd #include <netinet/in.h>
51 1.1 cgd #include <netinet/in_systm.h>
52 1.1 cgd #include <netinet/ip.h>
53 1.9 cgd
54 1.9 cgd #include <ctype.h>
55 1.1 cgd #include <dirent.h>
56 1.9 cgd #include <err.h>
57 1.9 cgd #include <errno.h>
58 1.1 cgd #include <fcntl.h>
59 1.46 christos #include <locale.h>
60 1.9 cgd #include <netdb.h>
61 1.51 rin #include <paths.h>
62 1.9 cgd #include <pwd.h>
63 1.1 cgd #include <signal.h>
64 1.1 cgd #include <stdio.h>
65 1.1 cgd #include <stdlib.h>
66 1.1 cgd #include <string.h>
67 1.9 cgd #include <unistd.h>
68 1.9 cgd
69 1.1 cgd #include "pathnames.h"
70 1.9 cgd #include "extern.h"
71 1.1 cgd
72 1.37 ginsbach #define OPTIONS "46dfprt"
73 1.1 cgd
74 1.1 cgd struct passwd *pwd;
75 1.19 christos char *pwname;
76 1.1 cgd u_short port;
77 1.1 cgd uid_t userid;
78 1.1 cgd int errs, rem;
79 1.1 cgd int pflag, iamremote, iamrecursive, targetshouldbedirectory;
80 1.37 ginsbach int family = AF_UNSPEC;
81 1.40 christos static char dot[] = ".";
82 1.1 cgd
83 1.51 rin static sig_atomic_t print_info = 0;
84 1.51 rin
85 1.1 cgd #define CMDNEEDS 64
86 1.1 cgd char cmd[CMDNEEDS]; /* must hold "rcp -r -p -d\0" */
87 1.1 cgd
88 1.36 xtraeme int response(void);
89 1.36 xtraeme void rsource(char *, struct stat *);
90 1.36 xtraeme void sink(int, char *[]);
91 1.36 xtraeme void source(int, char *[]);
92 1.36 xtraeme void tolocal(int, char *[]);
93 1.36 xtraeme void toremote(char *, int, char *[]);
94 1.36 xtraeme void usage(void);
95 1.51 rin static void got_siginfo(int);
96 1.51 rin static void progress(const char *, uintmax_t, uintmax_t);
97 1.1 cgd
98 1.6 cgd int
99 1.36 xtraeme main(int argc, char *argv[])
100 1.1 cgd {
101 1.1 cgd struct servent *sp;
102 1.1 cgd int ch, fflag, tflag;
103 1.40 christos char *targ;
104 1.40 christos const char *shell;
105 1.1 cgd
106 1.46 christos setprogname(argv[0]);
107 1.46 christos (void)setlocale(LC_ALL, "");
108 1.46 christos
109 1.1 cgd fflag = tflag = 0;
110 1.17 lukem while ((ch = getopt(argc, argv, OPTIONS)) != -1)
111 1.9 cgd switch(ch) { /* User-visible flags. */
112 1.37 ginsbach case '4':
113 1.37 ginsbach family = AF_INET;
114 1.37 ginsbach break;
115 1.37 ginsbach case '6':
116 1.37 ginsbach family = AF_INET6;
117 1.37 ginsbach break;
118 1.9 cgd case 'K':
119 1.1 cgd break;
120 1.9 cgd case 'p':
121 1.9 cgd pflag = 1;
122 1.9 cgd break;
123 1.9 cgd case 'r':
124 1.9 cgd iamrecursive = 1;
125 1.9 cgd break;
126 1.9 cgd /* Server options. */
127 1.1 cgd case 'd':
128 1.1 cgd targetshouldbedirectory = 1;
129 1.1 cgd break;
130 1.1 cgd case 'f': /* "from" */
131 1.1 cgd iamremote = 1;
132 1.1 cgd fflag = 1;
133 1.1 cgd break;
134 1.1 cgd case 't': /* "to" */
135 1.1 cgd iamremote = 1;
136 1.1 cgd tflag = 1;
137 1.1 cgd break;
138 1.1 cgd case '?':
139 1.1 cgd default:
140 1.1 cgd usage();
141 1.1 cgd }
142 1.1 cgd argc -= optind;
143 1.1 cgd argv += optind;
144 1.1 cgd
145 1.1 cgd sp = getservbyname(shell = "shell", "tcp");
146 1.9 cgd if (sp == NULL)
147 1.9 cgd errx(1, "%s/tcp: unknown service", shell);
148 1.1 cgd port = sp->s_port;
149 1.1 cgd
150 1.9 cgd if ((pwd = getpwuid(userid = getuid())) == NULL)
151 1.9 cgd errx(1, "unknown user %d", (int)userid);
152 1.9 cgd
153 1.19 christos if ((pwname = strdup(pwd->pw_name)) == NULL)
154 1.26 drochner err(1, NULL);
155 1.19 christos
156 1.9 cgd rem = STDIN_FILENO; /* XXX */
157 1.1 cgd
158 1.9 cgd if (fflag) { /* Follow "protocol", send data. */
159 1.1 cgd (void)response();
160 1.1 cgd source(argc, argv);
161 1.1 cgd exit(errs);
162 1.1 cgd }
163 1.1 cgd
164 1.9 cgd if (tflag) { /* Receive data. */
165 1.1 cgd sink(argc, argv);
166 1.1 cgd exit(errs);
167 1.1 cgd }
168 1.1 cgd
169 1.1 cgd if (argc < 2)
170 1.1 cgd usage();
171 1.1 cgd if (argc > 2)
172 1.1 cgd targetshouldbedirectory = 1;
173 1.1 cgd
174 1.1 cgd rem = -1;
175 1.9 cgd /* Command to be executed on remote system using "rsh". */
176 1.1 cgd (void)snprintf(cmd, sizeof(cmd), "rcp%s%s%s",
177 1.1 cgd iamrecursive ? " -r" : "", pflag ? " -p" : "",
178 1.1 cgd targetshouldbedirectory ? " -d" : "");
179 1.1 cgd
180 1.1 cgd (void)signal(SIGPIPE, lostconn);
181 1.51 rin (void)signal(SIGINFO, got_siginfo);
182 1.1 cgd
183 1.15 christos if ((targ = colon(argv[argc - 1])) != NULL)/* Dest is remote host. */
184 1.9 cgd toremote(targ, argc, argv);
185 1.1 cgd else {
186 1.9 cgd tolocal(argc, argv); /* Dest is local host. */
187 1.1 cgd if (targetshouldbedirectory)
188 1.1 cgd verifydir(argv[argc - 1]);
189 1.1 cgd }
190 1.1 cgd exit(errs);
191 1.21 mycroft /* NOTREACHED */
192 1.1 cgd }
193 1.1 cgd
194 1.6 cgd void
195 1.36 xtraeme toremote(char *targ, int argc, char *argv[])
196 1.1 cgd {
197 1.44 christos int i;
198 1.44 christos size_t len;
199 1.19 christos char *bp, *host, *src, *suser, *thost, *tuser;
200 1.1 cgd
201 1.1 cgd *targ++ = 0;
202 1.1 cgd if (*targ == 0)
203 1.40 christos targ = dot;
204 1.1 cgd
205 1.15 christos if ((thost = strchr(argv[argc - 1], '@')) != NULL) {
206 1.1 cgd /* user@host */
207 1.1 cgd *thost++ = 0;
208 1.1 cgd tuser = argv[argc - 1];
209 1.1 cgd if (*tuser == '\0')
210 1.1 cgd tuser = NULL;
211 1.22 mycroft else if (!okname(tuser))
212 1.1 cgd exit(1);
213 1.1 cgd } else {
214 1.1 cgd thost = argv[argc - 1];
215 1.1 cgd tuser = NULL;
216 1.1 cgd }
217 1.39 ginsbach thost = unbracket(thost);
218 1.1 cgd
219 1.1 cgd for (i = 0; i < argc - 1; i++) {
220 1.1 cgd src = colon(argv[i]);
221 1.1 cgd if (src) { /* remote to remote */
222 1.1 cgd *src++ = 0;
223 1.1 cgd if (*src == 0)
224 1.40 christos src = dot;
225 1.9 cgd host = strchr(argv[i], '@');
226 1.1 cgd len = strlen(_PATH_RSH) + strlen(argv[i]) +
227 1.1 cgd strlen(src) + (tuser ? strlen(tuser) : 0) +
228 1.1 cgd strlen(thost) + strlen(targ) + CMDNEEDS + 20;
229 1.1 cgd if (!(bp = malloc(len)))
230 1.26 drochner err(1, NULL);
231 1.1 cgd if (host) {
232 1.1 cgd *host++ = 0;
233 1.39 ginsbach host = unbracket(host);
234 1.1 cgd suser = argv[i];
235 1.1 cgd if (*suser == '\0')
236 1.19 christos suser = pwname;
237 1.41 ginsbach else if (!okname(suser)) {
238 1.41 ginsbach (void)free(bp);
239 1.1 cgd continue;
240 1.41 ginsbach }
241 1.1 cgd (void)snprintf(bp, len,
242 1.1 cgd "%s %s -l %s -n %s %s '%s%s%s:%s'",
243 1.1 cgd _PATH_RSH, host, suser, cmd, src,
244 1.1 cgd tuser ? tuser : "", tuser ? "@" : "",
245 1.1 cgd thost, targ);
246 1.39 ginsbach } else {
247 1.39 ginsbach host = unbracket(argv[i]);
248 1.1 cgd (void)snprintf(bp, len,
249 1.9 cgd "exec %s %s -n %s %s '%s%s%s:%s'",
250 1.1 cgd _PATH_RSH, argv[i], cmd, src,
251 1.1 cgd tuser ? tuser : "", tuser ? "@" : "",
252 1.1 cgd thost, targ);
253 1.39 ginsbach }
254 1.12 mrg (void)susystem(bp);
255 1.1 cgd (void)free(bp);
256 1.1 cgd } else { /* local to remote */
257 1.1 cgd if (rem == -1) {
258 1.1 cgd len = strlen(targ) + CMDNEEDS + 20;
259 1.1 cgd if (!(bp = malloc(len)))
260 1.26 drochner err(1, NULL);
261 1.1 cgd (void)snprintf(bp, len, "%s -t %s", cmd, targ);
262 1.1 cgd host = thost;
263 1.34 jdolecek rem = rcmd_af(&host, port, pwname,
264 1.19 christos tuser ? tuser : pwname,
265 1.37 ginsbach bp, NULL, family);
266 1.22 mycroft if (rem < 0)
267 1.1 cgd exit(1);
268 1.22 mycroft if (response() < 0)
269 1.1 cgd exit(1);
270 1.1 cgd (void)free(bp);
271 1.1 cgd }
272 1.1 cgd source(1, argv+i);
273 1.1 cgd }
274 1.1 cgd }
275 1.1 cgd }
276 1.1 cgd
277 1.6 cgd void
278 1.36 xtraeme tolocal(int argc, char *argv[])
279 1.1 cgd {
280 1.44 christos int i;
281 1.44 christos size_t len;
282 1.1 cgd char *bp, *host, *src, *suser;
283 1.1 cgd
284 1.1 cgd for (i = 0; i < argc - 1; i++) {
285 1.9 cgd if (!(src = colon(argv[i]))) { /* Local to local. */
286 1.1 cgd len = strlen(_PATH_CP) + strlen(argv[i]) +
287 1.1 cgd strlen(argv[argc - 1]) + 20;
288 1.1 cgd if (!(bp = malloc(len)))
289 1.26 drochner err(1, NULL);
290 1.9 cgd (void)snprintf(bp, len, "exec %s%s%s %s %s", _PATH_CP,
291 1.1 cgd iamrecursive ? " -r" : "", pflag ? " -p" : "",
292 1.1 cgd argv[i], argv[argc - 1]);
293 1.12 mrg if (susystem(bp))
294 1.9 cgd ++errs;
295 1.1 cgd (void)free(bp);
296 1.1 cgd continue;
297 1.1 cgd }
298 1.1 cgd *src++ = 0;
299 1.1 cgd if (*src == 0)
300 1.40 christos src = dot;
301 1.9 cgd if ((host = strchr(argv[i], '@')) == NULL) {
302 1.9 cgd host = argv[i];
303 1.19 christos suser = pwname;
304 1.9 cgd } else {
305 1.1 cgd *host++ = 0;
306 1.1 cgd suser = argv[i];
307 1.1 cgd if (*suser == '\0')
308 1.19 christos suser = pwname;
309 1.1 cgd else if (!okname(suser))
310 1.1 cgd continue;
311 1.1 cgd }
312 1.39 ginsbach host = unbracket(host);
313 1.1 cgd len = strlen(src) + CMDNEEDS + 20;
314 1.9 cgd if ((bp = malloc(len)) == NULL)
315 1.26 drochner err(1, NULL);
316 1.1 cgd (void)snprintf(bp, len, "%s -f %s", cmd, src);
317 1.9 cgd rem =
318 1.37 ginsbach rcmd_af(&host, port, pwname, suser, bp, NULL, family);
319 1.1 cgd (void)free(bp);
320 1.9 cgd if (rem < 0) {
321 1.9 cgd ++errs;
322 1.1 cgd continue;
323 1.9 cgd }
324 1.1 cgd sink(1, argv + argc - 1);
325 1.1 cgd (void)close(rem);
326 1.1 cgd rem = -1;
327 1.1 cgd }
328 1.1 cgd }
329 1.1 cgd
330 1.6 cgd void
331 1.36 xtraeme source(int argc, char *argv[])
332 1.1 cgd {
333 1.1 cgd struct stat stb;
334 1.1 cgd static BUF buffer;
335 1.1 cgd BUF *bp;
336 1.1 cgd off_t i;
337 1.44 christos off_t amt;
338 1.52 rin size_t resid;
339 1.52 rin ssize_t result;
340 1.52 rin int fd, haderr, indx;
341 1.52 rin char *last, *name, *cp, buf[BUFSIZ];
342 1.1 cgd
343 1.9 cgd for (indx = 0; indx < argc; ++indx) {
344 1.37 ginsbach name = argv[indx];
345 1.9 cgd if ((fd = open(name, O_RDONLY, 0)) < 0)
346 1.9 cgd goto syserr;
347 1.9 cgd if (fstat(fd, &stb)) {
348 1.9 cgd syserr: run_err("%s: %s", name, strerror(errno));
349 1.9 cgd goto next;
350 1.1 cgd }
351 1.7 mycroft switch (stb.st_mode & S_IFMT) {
352 1.1 cgd case S_IFREG:
353 1.1 cgd break;
354 1.1 cgd case S_IFDIR:
355 1.1 cgd if (iamrecursive) {
356 1.1 cgd rsource(name, &stb);
357 1.9 cgd goto next;
358 1.1 cgd }
359 1.1 cgd /* FALLTHROUGH */
360 1.1 cgd default:
361 1.9 cgd run_err("%s: not a regular file", name);
362 1.9 cgd goto next;
363 1.1 cgd }
364 1.9 cgd if ((last = strrchr(name, '/')) == NULL)
365 1.1 cgd last = name;
366 1.1 cgd else
367 1.9 cgd ++last;
368 1.1 cgd if (pflag) {
369 1.1 cgd /*
370 1.1 cgd * Make it compatible with possible future
371 1.1 cgd * versions expecting microseconds.
372 1.1 cgd */
373 1.45 dholland (void)snprintf(buf, sizeof(buf), "T%lld %ld %lld %ld\n",
374 1.45 dholland (long long)stb.st_mtimespec.tv_sec,
375 1.18 mycroft (long)stb.st_mtimespec.tv_nsec / 1000,
376 1.45 dholland (long long)stb.st_atimespec.tv_sec,
377 1.18 mycroft (long)stb.st_atimespec.tv_nsec / 1000);
378 1.9 cgd (void)write(rem, buf, strlen(buf));
379 1.9 cgd if (response() < 0)
380 1.9 cgd goto next;
381 1.9 cgd }
382 1.23 christos #define RCPMODEMASK (S_ISUID|S_ISGID|S_ISTXT|S_IRWXU|S_IRWXG|S_IRWXO)
383 1.27 lukem (void)snprintf(buf, sizeof(buf), "C%04o %lld %s\n",
384 1.23 christos stb.st_mode & RCPMODEMASK, (long long)stb.st_size, last);
385 1.9 cgd (void)write(rem, buf, strlen(buf));
386 1.9 cgd if (response() < 0)
387 1.9 cgd goto next;
388 1.9 cgd if ((bp = allocbuf(&buffer, fd, BUFSIZ)) == NULL) {
389 1.9 cgd next: (void)close(fd);
390 1.1 cgd continue;
391 1.1 cgd }
392 1.9 cgd
393 1.9 cgd /* Keep writing after an error so that we stay sync'd up. */
394 1.44 christos haderr = 0;
395 1.44 christos for (i = 0; i < stb.st_size; i += bp->cnt) {
396 1.51 rin if (print_info)
397 1.51 rin progress(name, i, stb.st_size);
398 1.1 cgd amt = bp->cnt;
399 1.1 cgd if (i + amt > stb.st_size)
400 1.1 cgd amt = stb.st_size - i;
401 1.52 rin for (resid = (size_t)amt, cp = bp->buf; resid > 0;
402 1.52 rin resid -= result, cp += result) {
403 1.52 rin result = read(fd, cp, resid);
404 1.52 rin if (result == -1) {
405 1.52 rin haderr = errno;
406 1.52 rin goto error;
407 1.52 rin }
408 1.52 rin }
409 1.52 rin for (resid = (size_t)amt, cp = bp->buf; resid > 0;
410 1.52 rin resid -= result, cp += result) {
411 1.52 rin result = write(rem, cp, resid);
412 1.52 rin if (result == -1) {
413 1.52 rin haderr = errno;
414 1.52 rin goto error;
415 1.52 rin }
416 1.9 cgd }
417 1.1 cgd }
418 1.52 rin error:
419 1.9 cgd if (close(fd) && !haderr)
420 1.9 cgd haderr = errno;
421 1.9 cgd if (!haderr)
422 1.1 cgd (void)write(rem, "", 1);
423 1.1 cgd else
424 1.9 cgd run_err("%s: %s", name, strerror(haderr));
425 1.1 cgd (void)response();
426 1.1 cgd }
427 1.1 cgd }
428 1.1 cgd
429 1.6 cgd void
430 1.36 xtraeme rsource(char *name, struct stat *statp)
431 1.1 cgd {
432 1.1 cgd DIR *dirp;
433 1.1 cgd struct dirent *dp;
434 1.1 cgd char *last, *vect[1], path[MAXPATHLEN];
435 1.1 cgd
436 1.1 cgd if (!(dirp = opendir(name))) {
437 1.9 cgd run_err("%s: %s", name, strerror(errno));
438 1.1 cgd return;
439 1.1 cgd }
440 1.9 cgd last = strrchr(name, '/');
441 1.1 cgd if (last == 0)
442 1.1 cgd last = name;
443 1.1 cgd else
444 1.1 cgd last++;
445 1.1 cgd if (pflag) {
446 1.45 dholland (void)snprintf(path, sizeof(path), "T%lld %ld %lld %ld\n",
447 1.45 dholland (long long)statp->st_mtimespec.tv_sec,
448 1.18 mycroft (long)statp->st_mtimespec.tv_nsec / 1000,
449 1.45 dholland (long long)statp->st_atimespec.tv_sec,
450 1.18 mycroft (long)statp->st_atimespec.tv_nsec / 1000);
451 1.9 cgd (void)write(rem, path, strlen(path));
452 1.1 cgd if (response() < 0) {
453 1.44 christos (void)closedir(dirp);
454 1.1 cgd return;
455 1.1 cgd }
456 1.1 cgd }
457 1.1 cgd (void)snprintf(path, sizeof(path),
458 1.24 christos "D%04o %d %s\n", statp->st_mode & RCPMODEMASK, 0, last);
459 1.9 cgd (void)write(rem, path, strlen(path));
460 1.1 cgd if (response() < 0) {
461 1.44 christos (void)closedir(dirp);
462 1.1 cgd return;
463 1.1 cgd }
464 1.15 christos while ((dp = readdir(dirp)) != NULL) {
465 1.1 cgd if (dp->d_ino == 0)
466 1.1 cgd continue;
467 1.40 christos if (!strcmp(dp->d_name, dot) || !strcmp(dp->d_name, ".."))
468 1.1 cgd continue;
469 1.1 cgd if (strlen(name) + 1 + strlen(dp->d_name) >= MAXPATHLEN - 1) {
470 1.9 cgd run_err("%s/%s: name too long", name, dp->d_name);
471 1.1 cgd continue;
472 1.1 cgd }
473 1.1 cgd (void)snprintf(path, sizeof(path), "%s/%s", name, dp->d_name);
474 1.1 cgd vect[0] = path;
475 1.1 cgd source(1, vect);
476 1.1 cgd }
477 1.9 cgd (void)closedir(dirp);
478 1.1 cgd (void)write(rem, "E\n", 2);
479 1.1 cgd (void)response();
480 1.1 cgd }
481 1.1 cgd
482 1.6 cgd void
483 1.36 xtraeme sink(int argc, char *argv[])
484 1.1 cgd {
485 1.1 cgd static BUF buffer;
486 1.1 cgd struct stat stb;
487 1.1 cgd struct timeval tv[2];
488 1.9 cgd BUF *bp;
489 1.52 rin size_t resid;
490 1.52 rin ssize_t result;
491 1.44 christos off_t i;
492 1.44 christos off_t amt;
493 1.44 christos int exists, first, ofd;
494 1.44 christos mode_t mask;
495 1.44 christos mode_t mode;
496 1.44 christos mode_t omode;
497 1.50 aymeric int setimes, targisdir, wrerr;
498 1.15 christos int wrerrno = 0; /* pacify gcc */
499 1.50 aymeric const char *wrcontext = NULL;
500 1.40 christos char ch, *cp, *np, *targ, *vect[1], buf[BUFSIZ];
501 1.40 christos const char *why;
502 1.30 ragge off_t size;
503 1.49 chs char *namebuf = NULL;
504 1.49 chs size_t cursize = 0;
505 1.1 cgd
506 1.1 cgd #define atime tv[0]
507 1.1 cgd #define mtime tv[1]
508 1.1 cgd #define SCREWUP(str) { why = str; goto screwup; }
509 1.20 mycroft
510 1.1 cgd setimes = targisdir = 0;
511 1.1 cgd mask = umask(0);
512 1.1 cgd if (!pflag)
513 1.1 cgd (void)umask(mask);
514 1.1 cgd if (argc != 1) {
515 1.9 cgd run_err("ambiguous target");
516 1.1 cgd exit(1);
517 1.1 cgd }
518 1.1 cgd targ = *argv;
519 1.1 cgd if (targetshouldbedirectory)
520 1.1 cgd verifydir(targ);
521 1.1 cgd (void)write(rem, "", 1);
522 1.8 mycroft if (stat(targ, &stb) == 0 && S_ISDIR(stb.st_mode))
523 1.1 cgd targisdir = 1;
524 1.1 cgd for (first = 1;; first = 0) {
525 1.1 cgd cp = buf;
526 1.1 cgd if (read(rem, cp, 1) <= 0)
527 1.49 chs goto out;
528 1.1 cgd if (*cp++ == '\n')
529 1.1 cgd SCREWUP("unexpected <newline>");
530 1.1 cgd do {
531 1.1 cgd if (read(rem, &ch, sizeof(ch)) != sizeof(ch))
532 1.1 cgd SCREWUP("lost connection");
533 1.1 cgd *cp++ = ch;
534 1.1 cgd } while (cp < &buf[BUFSIZ - 1] && ch != '\n');
535 1.1 cgd *cp = 0;
536 1.1 cgd
537 1.1 cgd if (buf[0] == '\01' || buf[0] == '\02') {
538 1.1 cgd if (iamremote == 0)
539 1.9 cgd (void)write(STDERR_FILENO,
540 1.9 cgd buf + 1, strlen(buf + 1));
541 1.22 mycroft if (buf[0] == '\02')
542 1.1 cgd exit(1);
543 1.9 cgd ++errs;
544 1.1 cgd continue;
545 1.1 cgd }
546 1.1 cgd if (buf[0] == 'E') {
547 1.1 cgd (void)write(rem, "", 1);
548 1.49 chs goto out;
549 1.1 cgd }
550 1.1 cgd
551 1.1 cgd if (ch == '\n')
552 1.1 cgd *--cp = 0;
553 1.1 cgd
554 1.23 christos #define getnum(t) (t) = 0; while (isdigit((unsigned char)*cp)) (t) = (t) * 10 + (*cp++ - '0');
555 1.1 cgd cp = buf;
556 1.1 cgd if (*cp == 'T') {
557 1.1 cgd setimes++;
558 1.1 cgd cp++;
559 1.1 cgd getnum(mtime.tv_sec);
560 1.1 cgd if (*cp++ != ' ')
561 1.1 cgd SCREWUP("mtime.sec not delimited");
562 1.1 cgd getnum(mtime.tv_usec);
563 1.1 cgd if (*cp++ != ' ')
564 1.1 cgd SCREWUP("mtime.usec not delimited");
565 1.1 cgd getnum(atime.tv_sec);
566 1.1 cgd if (*cp++ != ' ')
567 1.1 cgd SCREWUP("atime.sec not delimited");
568 1.1 cgd getnum(atime.tv_usec);
569 1.1 cgd if (*cp++ != '\0')
570 1.1 cgd SCREWUP("atime.usec not delimited");
571 1.1 cgd (void)write(rem, "", 1);
572 1.1 cgd continue;
573 1.1 cgd }
574 1.1 cgd if (*cp != 'C' && *cp != 'D') {
575 1.1 cgd /*
576 1.1 cgd * Check for the case "rcp remote:foo\* local:bar".
577 1.1 cgd * In this case, the line "No match." can be returned
578 1.1 cgd * by the shell before the rcp command on the remote is
579 1.1 cgd * executed so the ^Aerror_message convention isn't
580 1.1 cgd * followed.
581 1.1 cgd */
582 1.1 cgd if (first) {
583 1.9 cgd run_err("%s", cp);
584 1.1 cgd exit(1);
585 1.1 cgd }
586 1.1 cgd SCREWUP("expected control record");
587 1.1 cgd }
588 1.1 cgd mode = 0;
589 1.1 cgd for (++cp; cp < buf + 5; cp++) {
590 1.1 cgd if (*cp < '0' || *cp > '7')
591 1.1 cgd SCREWUP("bad mode");
592 1.1 cgd mode = (mode << 3) | (*cp - '0');
593 1.1 cgd }
594 1.1 cgd if (*cp++ != ' ')
595 1.1 cgd SCREWUP("mode not delimited");
596 1.9 cgd
597 1.23 christos for (size = 0; isdigit((unsigned char)*cp);)
598 1.1 cgd size = size * 10 + (*cp++ - '0');
599 1.1 cgd if (*cp++ != ' ')
600 1.1 cgd SCREWUP("size not delimited");
601 1.1 cgd if (targisdir) {
602 1.48 dholland char *newnamebuf;
603 1.1 cgd size_t need;
604 1.1 cgd
605 1.49 chs need = strlen(targ) + strlen(cp) + 2;
606 1.1 cgd if (need > cursize) {
607 1.49 chs need += 256;
608 1.48 dholland newnamebuf = realloc(namebuf, need);
609 1.48 dholland if (newnamebuf != NULL) {
610 1.48 dholland namebuf = newnamebuf;
611 1.48 dholland cursize = need;
612 1.48 dholland } else {
613 1.9 cgd run_err("%s", strerror(errno));
614 1.49 chs exit(1);
615 1.48 dholland }
616 1.1 cgd }
617 1.48 dholland (void)snprintf(namebuf, cursize, "%s%s%s", targ,
618 1.1 cgd *targ ? "/" : "", cp);
619 1.1 cgd np = namebuf;
620 1.9 cgd } else
621 1.1 cgd np = targ;
622 1.1 cgd exists = stat(np, &stb) == 0;
623 1.1 cgd if (buf[0] == 'D') {
624 1.9 cgd int mod_flag = pflag;
625 1.1 cgd if (exists) {
626 1.8 mycroft if (!S_ISDIR(stb.st_mode)) {
627 1.1 cgd errno = ENOTDIR;
628 1.1 cgd goto bad;
629 1.1 cgd }
630 1.1 cgd if (pflag)
631 1.1 cgd (void)chmod(np, mode);
632 1.9 cgd } else {
633 1.9 cgd /* Handle copying from a read-only directory */
634 1.9 cgd mod_flag = 1;
635 1.9 cgd if (mkdir(np, mode | S_IRWXU) < 0)
636 1.9 cgd goto bad;
637 1.9 cgd }
638 1.1 cgd vect[0] = np;
639 1.1 cgd sink(1, vect);
640 1.1 cgd if (setimes) {
641 1.1 cgd setimes = 0;
642 1.50 aymeric (void) utimes(np, tv);
643 1.1 cgd }
644 1.9 cgd if (mod_flag)
645 1.9 cgd (void)chmod(np, mode);
646 1.1 cgd continue;
647 1.1 cgd }
648 1.9 cgd omode = mode;
649 1.9 cgd mode |= S_IWRITE;
650 1.1 cgd if ((ofd = open(np, O_WRONLY|O_CREAT, mode)) < 0) {
651 1.9 cgd bad: run_err("%s: %s", np, strerror(errno));
652 1.1 cgd continue;
653 1.1 cgd }
654 1.1 cgd (void)write(rem, "", 1);
655 1.9 cgd if ((bp = allocbuf(&buffer, ofd, BUFSIZ)) == NULL) {
656 1.1 cgd (void)close(ofd);
657 1.1 cgd continue;
658 1.1 cgd }
659 1.50 aymeric wrerr = 0;
660 1.50 aymeric
661 1.50 aymeric /*
662 1.50 aymeric * Like run_err(), but don't send any message to the remote end.
663 1.50 aymeric * Instead, record the first error and send that in the end.
664 1.50 aymeric */
665 1.50 aymeric #define RUN_ERR(w_context) do { \
666 1.50 aymeric if (!wrerr) { \
667 1.50 aymeric wrerrno = errno; \
668 1.50 aymeric wrcontext = w_context; \
669 1.50 aymeric wrerr = 1; \
670 1.50 aymeric } \
671 1.50 aymeric } while(0)
672 1.50 aymeric
673 1.52 rin for (i = 0; i < size; i += bp->cnt) {
674 1.51 rin if (print_info)
675 1.51 rin progress(np, i, size);
676 1.52 rin amt = bp->cnt;
677 1.1 cgd if (i + amt > size)
678 1.1 cgd amt = size - i;
679 1.52 rin for (resid = (size_t)amt, cp = bp->buf; resid > 0;
680 1.52 rin resid -= result, cp += result) {
681 1.52 rin result = read(rem, cp, resid);
682 1.52 rin if (result == -1) {
683 1.52 rin run_err("%s", strerror(errno));
684 1.1 cgd exit(1);
685 1.1 cgd }
686 1.52 rin }
687 1.52 rin for (resid = (size_t)amt, cp = bp->buf; resid > 0;
688 1.52 rin resid -= result, cp += result) {
689 1.9 cgd /* Keep reading so we stay sync'd up. */
690 1.50 aymeric if (!wrerr) {
691 1.52 rin result = write(ofd, cp, resid);
692 1.52 rin if (result == -1) {
693 1.50 aymeric RUN_ERR("write");
694 1.52 rin goto error;
695 1.9 cgd }
696 1.9 cgd }
697 1.1 cgd }
698 1.1 cgd }
699 1.52 rin error:
700 1.50 aymeric if (ftruncate(ofd, size))
701 1.50 aymeric RUN_ERR("truncate");
702 1.50 aymeric
703 1.9 cgd if (pflag) {
704 1.9 cgd if (exists || omode != mode)
705 1.9 cgd if (fchmod(ofd, omode))
706 1.50 aymeric RUN_ERR("set mode");
707 1.9 cgd } else {
708 1.9 cgd if (!exists && omode != mode)
709 1.9 cgd if (fchmod(ofd, omode & ~mask))
710 1.50 aymeric RUN_ERR("set mode");
711 1.9 cgd }
712 1.23 christos #ifndef __SVR4
713 1.50 aymeric if (setimes && !wrerr) {
714 1.1 cgd setimes = 0;
715 1.50 aymeric if (futimes(ofd, tv) < 0)
716 1.50 aymeric RUN_ERR("set times");
717 1.1 cgd }
718 1.23 christos #endif
719 1.18 mycroft (void)close(ofd);
720 1.23 christos #ifdef __SVR4
721 1.50 aymeric if (setimes && !wrerr) {
722 1.23 christos setimes = 0;
723 1.50 aymeric if (utimes(np, tv) < 0)
724 1.50 aymeric RUN_ERR("set times");
725 1.23 christos }
726 1.23 christos #endif
727 1.18 mycroft (void)response();
728 1.50 aymeric if (wrerr)
729 1.50 aymeric run_err("%s: %s: %s", np, wrcontext, strerror(wrerrno));
730 1.50 aymeric else
731 1.1 cgd (void)write(rem, "", 1);
732 1.1 cgd }
733 1.49 chs
734 1.49 chs out:
735 1.49 chs if (namebuf) {
736 1.49 chs free(namebuf);
737 1.49 chs }
738 1.49 chs return;
739 1.49 chs
740 1.1 cgd screwup:
741 1.9 cgd run_err("protocol error: %s", why);
742 1.1 cgd exit(1);
743 1.21 mycroft /* NOTREACHED */
744 1.1 cgd }
745 1.1 cgd
746 1.1 cgd
747 1.9 cgd int
748 1.36 xtraeme response(void)
749 1.1 cgd {
750 1.9 cgd char ch, *cp, resp, rbuf[BUFSIZ];
751 1.9 cgd
752 1.9 cgd if (read(rem, &resp, sizeof(resp)) != sizeof(resp))
753 1.9 cgd lostconn(0);
754 1.1 cgd
755 1.9 cgd cp = rbuf;
756 1.9 cgd switch(resp) {
757 1.9 cgd case 0: /* ok */
758 1.9 cgd return (0);
759 1.9 cgd default:
760 1.9 cgd *cp++ = resp;
761 1.9 cgd /* FALLTHROUGH */
762 1.9 cgd case 1: /* error, followed by error msg */
763 1.9 cgd case 2: /* fatal error, "" */
764 1.9 cgd do {
765 1.9 cgd if (read(rem, &ch, sizeof(ch)) != sizeof(ch))
766 1.9 cgd lostconn(0);
767 1.9 cgd *cp++ = ch;
768 1.9 cgd } while (cp < &rbuf[BUFSIZ] && ch != '\n');
769 1.1 cgd
770 1.9 cgd if (!iamremote)
771 1.44 christos (void)write(STDERR_FILENO, rbuf, (size_t)(cp - rbuf));
772 1.9 cgd ++errs;
773 1.9 cgd if (resp == 1)
774 1.9 cgd return (-1);
775 1.9 cgd exit(1);
776 1.9 cgd }
777 1.9 cgd /* NOTREACHED */
778 1.1 cgd }
779 1.1 cgd
780 1.6 cgd void
781 1.36 xtraeme usage(void)
782 1.1 cgd {
783 1.1 cgd (void)fprintf(stderr,
784 1.38 wiz "usage: rcp [-46p] f1 f2; or: rcp [-46pr] f1 ... fn directory\n");
785 1.1 cgd exit(1);
786 1.21 mycroft /* NOTREACHED */
787 1.1 cgd }
788 1.1 cgd
789 1.9 cgd #include <stdarg.h>
790 1.9 cgd
791 1.1 cgd
792 1.9 cgd void
793 1.9 cgd run_err(const char *fmt, ...)
794 1.1 cgd {
795 1.9 cgd static FILE *fp;
796 1.9 cgd va_list ap;
797 1.28 wiz
798 1.28 wiz ++errs;
799 1.28 wiz if (fp == NULL && !(fp = fdopen(rem, "w")))
800 1.28 wiz return;
801 1.28 wiz
802 1.9 cgd va_start(ap, fmt);
803 1.1 cgd
804 1.9 cgd (void)fprintf(fp, "%c", 0x01);
805 1.9 cgd (void)fprintf(fp, "rcp: ");
806 1.9 cgd (void)vfprintf(fp, fmt, ap);
807 1.9 cgd (void)fprintf(fp, "\n");
808 1.9 cgd (void)fflush(fp);
809 1.28 wiz va_end(ap);
810 1.1 cgd
811 1.28 wiz if (!iamremote) {
812 1.28 wiz va_start(ap, fmt);
813 1.9 cgd vwarnx(fmt, ap);
814 1.28 wiz va_end(ap);
815 1.28 wiz }
816 1.1 cgd }
817 1.51 rin
818 1.51 rin static void
819 1.51 rin got_siginfo(int signo)
820 1.51 rin {
821 1.51 rin
822 1.51 rin print_info = 1;
823 1.51 rin }
824 1.51 rin
825 1.51 rin static void
826 1.51 rin progress(const char *file, uintmax_t done, uintmax_t total)
827 1.51 rin {
828 1.51 rin static int ttyfd = -2;
829 1.51 rin const double pcent = (100.0 * done) / total;
830 1.51 rin char buf[2048];
831 1.51 rin int n;
832 1.51 rin
833 1.51 rin if (ttyfd == -2)
834 1.51 rin ttyfd = open(_PATH_TTY, O_RDWR | O_CLOEXEC);
835 1.51 rin
836 1.51 rin if (ttyfd == -1)
837 1.51 rin return;
838 1.51 rin
839 1.51 rin n = snprintf(buf, sizeof(buf),
840 1.51 rin "%s: %s: %ju/%ju bytes %3.2f%% written\n",
841 1.51 rin getprogname(), file, done, total, pcent);
842 1.51 rin
843 1.51 rin if (n < 0)
844 1.51 rin return;
845 1.51 rin
846 1.51 rin write(ttyfd, buf, (size_t)n);
847 1.51 rin
848 1.51 rin print_info = 0;
849 1.51 rin }
850