Annotation of src/usr.bin/rsync/main.c, Revision 1.53
1.53 ! job 1: /* $Id: main.c,v 1.52 2021/03/22 11:16:05 claudio Exp $ */
1.1 benno 2: /*
3: * Copyright (c) 2019 Kristaps Dzonsons <kristaps@bsd.lv>
4: *
5: * Permission to use, copy, modify, and distribute this software for any
6: * purpose with or without fee is hereby granted, provided that the above
7: * copyright notice and this permission notice appear in all copies.
8: *
9: * THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
10: * WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
11: * MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
12: * ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
13: * WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
14: * ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
15: * OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
16: */
17: #include <sys/stat.h>
18: #include <sys/socket.h>
19: #include <sys/wait.h>
20:
21: #include <assert.h>
22: #include <err.h>
23: #include <getopt.h>
24: #include <stdint.h>
25: #include <stdio.h>
26: #include <stdlib.h>
27: #include <string.h>
28: #include <unistd.h>
29:
30: #include "extern.h"
31:
1.45 benno 32: int verbose;
1.50 claudio 33: int poll_timeout;
1.45 benno 34:
1.1 benno 35: /*
36: * A remote host is has a colon before the first path separator.
37: * This works for rsh remote hosts (host:/foo/bar), implicit rsync
38: * remote hosts (host::/foo/bar), and explicit (rsync://host/foo).
39: * Return zero if local, non-zero if remote.
40: */
41: static int
42: fargs_is_remote(const char *v)
43: {
44: size_t pos;
45:
46: pos = strcspn(v, ":/");
1.6 deraadt 47: return v[pos] == ':';
1.1 benno 48: }
49:
50: /*
51: * Test whether a remote host is specifically an rsync daemon.
52: * Return zero if not, non-zero if so.
53: */
54: static int
55: fargs_is_daemon(const char *v)
56: {
57: size_t pos;
58:
1.6 deraadt 59: if (strncasecmp(v, "rsync://", 8) == 0)
1.1 benno 60: return 1;
61:
62: pos = strcspn(v, ":/");
1.6 deraadt 63: return v[pos] == ':' && v[pos + 1] == ':';
1.1 benno 64: }
65:
66: /*
67: * Take the command-line filenames (e.g., rsync foo/ bar/ baz/) and
68: * determine our operating mode.
69: * For example, if the first argument is a remote file, this means that
70: * we're going to transfer from the remote to the local.
71: * We also make sure that the arguments are consistent, that is, if
72: * we're going to transfer from the local to the remote, that no
73: * filenames for the local transfer indicate remote hosts.
74: * Always returns the parsed and sanitised options.
75: */
76: static struct fargs *
1.26 deraadt 77: fargs_parse(size_t argc, char *argv[], struct opts *opts)
1.1 benno 78: {
79: struct fargs *f = NULL;
1.26 deraadt 80: char *cp, *ccp;
1.1 benno 81: size_t i, j, len = 0;
82:
83: /* Allocations. */
84:
1.6 deraadt 85: if ((f = calloc(1, sizeof(struct fargs))) == NULL)
1.29 benno 86: err(1, "calloc");
1.1 benno 87:
88: f->sourcesz = argc - 1;
1.6 deraadt 89: if ((f->sources = calloc(f->sourcesz, sizeof(char *))) == NULL)
1.29 benno 90: err(1, "calloc");
1.1 benno 91:
92: for (i = 0; i < argc - 1; i++)
1.6 deraadt 93: if ((f->sources[i] = strdup(argv[i])) == NULL)
1.29 benno 94: err(1, "strdup");
1.1 benno 95:
1.6 deraadt 96: if ((f->sink = strdup(argv[i])) == NULL)
1.29 benno 97: err(1, "strdup");
1.1 benno 98:
99: /*
100: * Test files for its locality.
101: * If the last is a remote host, then we're sending from the
102: * local to the remote host ("sender" mode).
103: * If the first, remote to local ("receiver" mode).
104: * If neither, a local transfer in sender style.
105: */
106:
107: f->mode = FARGS_SENDER;
108:
109: if (fargs_is_remote(f->sink)) {
110: f->mode = FARGS_SENDER;
1.6 deraadt 111: if ((f->host = strdup(f->sink)) == NULL)
1.29 benno 112: err(1, "strdup");
1.1 benno 113: }
114:
115: if (fargs_is_remote(f->sources[0])) {
1.6 deraadt 116: if (f->host != NULL)
1.35 deraadt 117: errx(1, "both source and destination cannot be remote files");
1.1 benno 118: f->mode = FARGS_RECEIVER;
1.6 deraadt 119: if ((f->host = strdup(f->sources[0])) == NULL)
1.29 benno 120: err(1, "strdup");
1.1 benno 121: }
122:
1.6 deraadt 123: if (f->host != NULL) {
124: if (strncasecmp(f->host, "rsync://", 8) == 0) {
1.30 benno 125: /* rsync://host[:port]/module[/path] */
1.1 benno 126: f->remote = 1;
127: len = strlen(f->host) - 8 + 1;
128: memmove(f->host, f->host + 8, len);
1.6 deraadt 129: if ((cp = strchr(f->host, '/')) == NULL)
1.35 deraadt 130: errx(1, "rsync protocol requires a module name");
1.1 benno 131: *cp++ = '\0';
132: f->module = cp;
1.6 deraadt 133: if ((cp = strchr(f->module, '/')) != NULL)
1.1 benno 134: *cp = '\0';
1.52 claudio 135: if ((cp = strchr(f->host, ':')) != NULL) {
1.26 deraadt 136: /* host:port --> extract port */
137: *cp++ = '\0';
138: opts->port = cp;
139: }
1.1 benno 140: } else {
141: /* host:[/path] */
142: cp = strchr(f->host, ':');
1.6 deraadt 143: assert(cp != NULL);
1.1 benno 144: *cp++ = '\0';
1.6 deraadt 145: if (*cp == ':') {
1.1 benno 146: /* host::module[/path] */
147: f->remote = 1;
148: f->module = ++cp;
149: cp = strchr(f->module, '/');
1.6 deraadt 150: if (cp != NULL)
1.1 benno 151: *cp = '\0';
152: }
153: }
1.6 deraadt 154: if ((len = strlen(f->host)) == 0)
1.29 benno 155: errx(1, "empty remote host");
1.6 deraadt 156: if (f->remote && strlen(f->module) == 0)
1.29 benno 157: errx(1, "empty remote module");
1.1 benno 158: }
159:
160: /* Make sure we have the same "hostspec" for all files. */
161:
1.4 deraadt 162: if (!f->remote) {
1.6 deraadt 163: if (f->mode == FARGS_SENDER)
1.1 benno 164: for (i = 0; i < f->sourcesz; i++) {
1.4 deraadt 165: if (!fargs_is_remote(f->sources[i]))
1.1 benno 166: continue;
1.35 deraadt 167: errx(1,
168: "remote file in list of local sources: %s",
169: f->sources[i]);
1.1 benno 170: }
1.6 deraadt 171: if (f->mode == FARGS_RECEIVER)
1.1 benno 172: for (i = 0; i < f->sourcesz; i++) {
173: if (fargs_is_remote(f->sources[i]) &&
1.4 deraadt 174: !fargs_is_daemon(f->sources[i]))
1.1 benno 175: continue;
176: if (fargs_is_daemon(f->sources[i]))
1.35 deraadt 177: errx(1, "remote daemon in list of "
178: "remote sources: %s",
179: f->sources[i]);
180: errx(1, "local file in list of remote sources: %s",
181: f->sources[i]);
1.1 benno 182: }
183: } else {
1.6 deraadt 184: if (f->mode != FARGS_RECEIVER)
1.29 benno 185: errx(1, "sender mode for remote "
1.1 benno 186: "daemon receivers not yet supported");
187: for (i = 0; i < f->sourcesz; i++) {
188: if (fargs_is_daemon(f->sources[i]))
189: continue;
1.29 benno 190: errx(1, "non-remote daemon file "
1.1 benno 191: "in list of remote daemon sources: "
192: "%s", f->sources[i]);
193: }
194: }
195:
196: /*
197: * If we're not remote and a sender, strip our hostname.
198: * Then exit if we're a sender or a local connection.
199: */
200:
1.4 deraadt 201: if (!f->remote) {
1.6 deraadt 202: if (f->host == NULL)
1.1 benno 203: return f;
1.6 deraadt 204: if (f->mode == FARGS_SENDER) {
205: assert(f->host != NULL);
1.1 benno 206: assert(len > 0);
207: j = strlen(f->sink);
208: memmove(f->sink, f->sink + len + 1, j - len);
209: return f;
1.6 deraadt 210: } else if (f->mode != FARGS_RECEIVER)
1.1 benno 211: return f;
212: }
213:
214: /*
215: * Now strip the hostnames from the remote host.
216: * rsync://host/module/path -> module/path
217: * host::module/path -> module/path
218: * host:path -> path
219: * Also make sure that the remote hosts are the same.
220: */
221:
1.6 deraadt 222: assert(f->host != NULL);
1.1 benno 223: assert(len > 0);
224:
225: for (i = 0; i < f->sourcesz; i++) {
226: cp = f->sources[i];
227: j = strlen(cp);
228: if (f->remote &&
1.6 deraadt 229: strncasecmp(cp, "rsync://", 8) == 0) {
1.1 benno 230: /* rsync://path */
231: cp += 8;
1.29 benno 232: if ((ccp = strchr(cp, ':'))) /* skip :port */
1.26 deraadt 233: *ccp = '\0';
1.1 benno 234: if (strncmp(cp, f->host, len) ||
1.11 benno 235: (cp[len] != '/' && cp[len] != '\0'))
1.35 deraadt 236: errx(1, "different remote host: %s",
237: f->sources[i]);
1.1 benno 238: memmove(f->sources[i],
239: f->sources[i] + len + 8 + 1,
240: j - len - 8);
1.6 deraadt 241: } else if (f->remote && strncmp(cp, "::", 2) == 0) {
1.1 benno 242: /* ::path */
243: memmove(f->sources[i],
244: f->sources[i] + 2, j - 1);
245: } else if (f->remote) {
246: /* host::path */
247: if (strncmp(cp, f->host, len) ||
1.6 deraadt 248: (cp[len] != ':' && cp[len] != '\0'))
1.35 deraadt 249: errx(1, "different remote host: %s",
250: f->sources[i]);
1.11 benno 251: memmove(f->sources[i], f->sources[i] + len + 2,
252: j - len - 1);
1.6 deraadt 253: } else if (cp[0] == ':') {
1.1 benno 254: /* :path */
255: memmove(f->sources[i], f->sources[i] + 1, j);
256: } else {
257: /* host:path */
258: if (strncmp(cp, f->host, len) ||
1.6 deraadt 259: (cp[len] != ':' && cp[len] != '\0'))
1.35 deraadt 260: errx(1, "different remote host: %s",
261: f->sources[i]);
1.1 benno 262: memmove(f->sources[i],
263: f->sources[i] + len + 1, j - len);
264: }
265: }
266:
267: return f;
268: }
269:
270: int
271: main(int argc, char *argv[])
272: {
273: struct opts opts;
1.2 benno 274: pid_t child;
1.46 deraadt 275: int fds[2], sd = -1, rc, c, st, i;
1.32 deraadt 276: struct sess sess;
1.1 benno 277: struct fargs *fargs;
1.32 deraadt 278: char **args;
1.50 claudio 279: const char *errstr;
280: const struct option lopts[] = {
1.26 deraadt 281: { "port", required_argument, NULL, 3 },
1.21 deraadt 282: { "rsh", required_argument, NULL, 'e' },
1.8 deraadt 283: { "rsync-path", required_argument, NULL, 1 },
284: { "sender", no_argument, &opts.sender, 1 },
285: { "server", no_argument, &opts.server, 1 },
1.20 deraadt 286: { "dry-run", no_argument, &opts.dry_run, 1 },
287: { "version", no_argument, NULL, 2 },
1.23 deraadt 288: { "archive", no_argument, NULL, 'a' },
1.21 deraadt 289: { "help", no_argument, NULL, 'h' },
1.36 deraadt 290: { "compress", no_argument, NULL, 'z' },
1.37 naddy 291: { "del", no_argument, &opts.del, 1 },
1.20 deraadt 292: { "delete", no_argument, &opts.del, 1 },
293: { "devices", no_argument, &opts.devices, 1 },
294: { "no-devices", no_argument, &opts.devices, 0 },
295: { "group", no_argument, &opts.preserve_gids, 1 },
296: { "no-group", no_argument, &opts.preserve_gids, 0 },
1.8 deraadt 297: { "links", no_argument, &opts.preserve_links, 1 },
1.20 deraadt 298: { "no-links", no_argument, &opts.preserve_links, 0 },
299: { "owner", no_argument, &opts.preserve_uids, 1 },
300: { "no-owner", no_argument, &opts.preserve_uids, 0 },
1.8 deraadt 301: { "perms", no_argument, &opts.preserve_perms, 1 },
1.20 deraadt 302: { "no-perms", no_argument, &opts.preserve_perms, 0 },
1.31 benno 303: { "numeric-ids", no_argument, &opts.numeric_ids, 1 },
1.8 deraadt 304: { "recursive", no_argument, &opts.recursive, 1 },
1.20 deraadt 305: { "no-recursive", no_argument, &opts.recursive, 0 },
1.19 florian 306: { "specials", no_argument, &opts.specials, 1 },
1.21 deraadt 307: { "no-specials", no_argument, &opts.specials, 0 },
1.50 claudio 308: { "timeout", required_argument, NULL, 5 },
1.20 deraadt 309: { "times", no_argument, &opts.preserve_times, 1 },
310: { "no-times", no_argument, &opts.preserve_times, 0 },
1.45 benno 311: { "verbose", no_argument, &verbose, 1 },
312: { "no-verbose", no_argument, &verbose, 0 },
1.48 claudio 313: { "address", required_argument, NULL, 4 },
1.53 ! job 314: { "no-motd", no_argument, NULL, 6 },
1.8 deraadt 315: { NULL, 0, NULL, 0 }};
1.1 benno 316:
317: /* Global pledge. */
318:
1.19 florian 319: if (pledge("stdio unix rpath wpath cpath dpath inet fattr chown dns getpw proc exec unveil",
1.6 deraadt 320: NULL) == -1)
1.29 benno 321: err(1, "pledge");
1.1 benno 322:
323: memset(&opts, 0, sizeof(struct opts));
324:
1.44 bket 325: while ((c = getopt_long(argc, argv, "Dae:ghlnoprtvxz", lopts, NULL))
1.30 benno 326: != -1) {
1.1 benno 327: switch (c) {
1.19 florian 328: case 'D':
329: opts.devices = 1;
330: opts.specials = 1;
331: break;
332: case 'a':
333: opts.recursive = 1;
334: opts.preserve_links = 1;
335: opts.preserve_perms = 1;
336: opts.preserve_times = 1;
337: opts.preserve_gids = 1;
338: opts.preserve_uids = 1;
339: opts.devices = 1;
340: opts.specials = 1;
341: break;
1.1 benno 342: case 'e':
1.9 deraadt 343: opts.ssh_prog = optarg;
1.1 benno 344: break;
1.10 benno 345: case 'g':
346: opts.preserve_gids = 1;
347: break;
1.1 benno 348: case 'l':
349: opts.preserve_links = 1;
350: break;
351: case 'n':
352: opts.dry_run = 1;
353: break;
1.13 florian 354: case 'o':
355: opts.preserve_uids = 1;
356: break;
1.1 benno 357: case 'p':
358: opts.preserve_perms = 1;
359: break;
360: case 'r':
361: opts.recursive = 1;
362: break;
363: case 't':
364: opts.preserve_times = 1;
365: break;
366: case 'v':
1.45 benno 367: verbose++;
1.1 benno 368: break;
1.44 bket 369: case 'x':
370: opts.one_file_system++;
371: break;
1.36 deraadt 372: case 'z':
373: fprintf(stderr, "%s: -z not supported yet\n", getprogname());
374: break;
1.1 benno 375: case 0:
376: /* Non-NULL flag values (e.g., --sender). */
377: break;
378: case 1:
379: opts.rsync_path = optarg;
380: break;
1.17 deraadt 381: case 2:
382: fprintf(stderr, "openrsync: protocol version %u\n",
383: RSYNC_PROTOCOL);
384: exit(0);
1.26 deraadt 385: case 3:
386: opts.port = optarg;
387: break;
1.48 claudio 388: case 4:
389: opts.address = optarg;
390: break;
1.50 claudio 391: case 5:
392: poll_timeout = strtonum(optarg, 0, 60*60, &errstr);
393: if (errstr != NULL)
394: errx(1, "timeout is %s: %s", errstr, optarg);
395: break;
1.53 ! job 396: case 6:
! 397: opts.no_motd = 1;
! 398: break;
1.21 deraadt 399: case 'h':
1.1 benno 400: default:
401: goto usage;
402: }
403: }
404:
405: argc -= optind;
406: argv += optind;
407:
408: /* FIXME: reference implementation rsync accepts this. */
409:
410: if (argc < 2)
411: goto usage;
412:
1.26 deraadt 413: if (opts.port == NULL)
1.29 benno 414: opts.port = "rsync";
1.26 deraadt 415:
1.51 claudio 416: /* by default and for --timeout=0 disable poll_timeout */
417: if (poll_timeout == 0)
418: poll_timeout = -1;
419: else
420: poll_timeout *= 1000;
421:
1.1 benno 422: /*
423: * This is what happens when we're started with the "hidden"
424: * --server option, which is invoked for the rsync on the remote
425: * host by the parent.
426: */
427:
1.32 deraadt 428: if (opts.server)
429: exit(rsync_server(&opts, (size_t)argc, argv));
1.50 claudio 430:
1.1 benno 431: /*
432: * Now we know that we're the client on the local machine
433: * invoking rsync(1).
434: * At this point, we need to start the client and server
435: * initiation logic.
436: * The client is what we continue running on this host; the
437: * server is what we'll use to connect to the remote and
438: * invoke rsync with the --server option.
439: */
440:
1.26 deraadt 441: fargs = fargs_parse(argc, argv, &opts);
1.6 deraadt 442: assert(fargs != NULL);
1.1 benno 443:
444: /*
445: * If we're contacting an rsync:// daemon, then we don't need to
446: * fork, because we won't start a server ourselves.
1.41 naddy 447: * Route directly into the socket code, unless a remote shell
448: * has explicitly been specified.
1.1 benno 449: */
450:
1.41 naddy 451: if (fargs->remote && opts.ssh_prog == NULL) {
1.6 deraadt 452: assert(fargs->mode == FARGS_RECEIVER);
1.47 naddy 453: if ((rc = rsync_connect(&opts, &sd, fargs)) == 0) {
1.41 naddy 454: rc = rsync_socket(&opts, sd, fargs);
1.47 naddy 455: close(sd);
456: }
1.41 naddy 457: exit(rc);
1.1 benno 458: }
459:
460: /* Drop the dns/inet possibility. */
461:
1.19 florian 462: if (pledge("stdio unix rpath wpath cpath dpath fattr chown getpw proc exec unveil",
1.6 deraadt 463: NULL) == -1)
1.29 benno 464: err(1, "pledge");
1.1 benno 465:
466: /* Create a bidirectional socket and start our child. */
467:
1.6 deraadt 468: if (socketpair(AF_UNIX, SOCK_STREAM | SOCK_NONBLOCK, 0, fds) == -1)
1.29 benno 469: err(1, "socketpair");
1.1 benno 470:
1.32 deraadt 471: switch ((child = fork())) {
472: case -1:
473: err(1, "fork");
474: case 0:
1.1 benno 475: close(fds[0]);
1.32 deraadt 476: if (pledge("stdio exec", NULL) == -1)
477: err(1, "pledge");
478:
479: memset(&sess, 0, sizeof(struct sess));
480: sess.opts = &opts;
1.1 benno 481:
1.41 naddy 482: if ((args = fargs_cmdline(&sess, fargs, NULL)) == NULL) {
1.45 benno 483: ERRX1("fargs_cmdline");
1.32 deraadt 484: _exit(1);
485: }
1.1 benno 486:
1.32 deraadt 487: for (i = 0; args[i] != NULL; i++)
1.45 benno 488: LOG2("exec[%d] = %s", i, args[i]);
1.1 benno 489:
1.32 deraadt 490: /* Make sure the child's stdin is from the sender. */
491: if (dup2(fds[1], STDIN_FILENO) == -1) {
1.45 benno 492: ERR("dup2");
1.32 deraadt 493: _exit(1);
1.39 deraadt 494: }
495: if (dup2(fds[1], STDOUT_FILENO) == -1) {
1.45 benno 496: ERR("dup2");
1.32 deraadt 497: _exit(1);
498: }
499: execvp(args[0], args);
500: _exit(1);
1.1 benno 501: /* NOTREACHED */
1.32 deraadt 502: default:
503: close(fds[1]);
1.41 naddy 504: if (!fargs->remote)
505: rc = rsync_client(&opts, fds[0], fargs);
506: else
507: rc = rsync_socket(&opts, fds[0], fargs);
1.32 deraadt 508: break;
1.1 benno 509: }
510:
1.47 naddy 511: close(fds[0]);
1.1 benno 512:
1.6 deraadt 513: if (waitpid(child, &st, 0) == -1)
1.29 benno 514: err(1, "waitpid");
1.34 deraadt 515:
516: /*
517: * If we don't already have an error (rc == 0), then inherit the
518: * error code of rsync_server() if it has exited.
519: * If it hasn't exited, it overrides our return value.
520: */
521:
522: if (WIFEXITED(st) && rc == 0)
523: rc = WEXITSTATUS(st);
524: else if (!WIFEXITED(st))
525: rc = 1;
526:
1.32 deraadt 527: exit(rc);
1.1 benno 528: usage:
1.42 schwarze 529: fprintf(stderr, "usage: %s"
1.49 deraadt 530: " [-aDglnoprtvx] [-e program] [--address=sourceaddr] [--del]\n"
1.53 ! job 531: "\t[--no-motd] [--numeric-ids] [--port=portnumber] "
! 532: "[--rsync-path=program]\n\t[--timeout=seconds] [--version] "
! 533: "source ... directory\n",
1.32 deraadt 534: getprogname());
535: exit(1);
1.1 benno 536: }
![[BACK]](/icons/back.gif){kind=icon}
Return to main.c CVS log ![[TXT]](/icons/text.gif){kind=icon}
![[DIR]](/icons/dir.gif){kind=icon}
Up to [local] / src / usr.bin / rsync