[BACK]Return to main.c CVS log [TXT][DIR] Up to [local] / src / usr.bin / rsync

Annotation of src/usr.bin/rsync/main.c, Revision 1.59

1.59    ! claudio     1: /*     $OpenBSD: main.c,v 1.58 2021/08/30 20:25:01 job 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.54      claudio    86:                err(ERR_NOMEM, NULL);
1.1       benno      87:
                     88:        f->sourcesz = argc - 1;
1.6       deraadt    89:        if ((f->sources = calloc(f->sourcesz, sizeof(char *))) == NULL)
1.54      claudio    90:                err(ERR_NOMEM, NULL);
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.54      claudio    94:                        err(ERR_NOMEM, NULL);
1.1       benno      95:
1.6       deraadt    96:        if ((f->sink = strdup(argv[i])) == NULL)
1.54      claudio    97:                err(ERR_NOMEM, NULL);
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.54      claudio   112:                        err(ERR_NOMEM, NULL);
1.1       benno     113:        }
                    114:
                    115:        if (fargs_is_remote(f->sources[0])) {
1.6       deraadt   116:                if (f->host != NULL)
1.54      claudio   117:                        errx(ERR_SYNTAX, "both source and destination "
                    118:                            "cannot be remote files");
1.1       benno     119:                f->mode = FARGS_RECEIVER;
1.6       deraadt   120:                if ((f->host = strdup(f->sources[0])) == NULL)
1.54      claudio   121:                        err(ERR_NOMEM, NULL);
1.1       benno     122:        }
                    123:
1.6       deraadt   124:        if (f->host != NULL) {
                    125:                if (strncasecmp(f->host, "rsync://", 8) == 0) {
1.30      benno     126:                        /* rsync://host[:port]/module[/path] */
1.1       benno     127:                        f->remote = 1;
                    128:                        len = strlen(f->host) - 8 + 1;
                    129:                        memmove(f->host, f->host + 8, len);
1.6       deraadt   130:                        if ((cp = strchr(f->host, '/')) == NULL)
1.54      claudio   131:                                errx(ERR_SYNTAX,
                    132:                                    "rsync protocol requires a module name");
1.1       benno     133:                        *cp++ = '\0';
                    134:                        f->module = cp;
1.6       deraadt   135:                        if ((cp = strchr(f->module, '/')) != NULL)
1.1       benno     136:                                *cp = '\0';
1.52      claudio   137:                        if ((cp = strchr(f->host, ':')) != NULL) {
1.26      deraadt   138:                                /* host:port --> extract port */
                    139:                                *cp++ = '\0';
                    140:                                opts->port = cp;
                    141:                        }
1.1       benno     142:                } else {
                    143:                        /* host:[/path] */
                    144:                        cp = strchr(f->host, ':');
1.6       deraadt   145:                        assert(cp != NULL);
1.1       benno     146:                        *cp++ = '\0';
1.6       deraadt   147:                        if (*cp == ':') {
1.1       benno     148:                                /* host::module[/path] */
                    149:                                f->remote = 1;
                    150:                                f->module = ++cp;
                    151:                                cp = strchr(f->module, '/');
1.6       deraadt   152:                                if (cp != NULL)
1.1       benno     153:                                        *cp = '\0';
                    154:                        }
                    155:                }
1.6       deraadt   156:                if ((len = strlen(f->host)) == 0)
1.54      claudio   157:                        errx(ERR_SYNTAX, "empty remote host");
1.6       deraadt   158:                if (f->remote && strlen(f->module) == 0)
1.54      claudio   159:                        errx(ERR_SYNTAX, "empty remote module");
1.1       benno     160:        }
                    161:
                    162:        /* Make sure we have the same "hostspec" for all files. */
                    163:
1.4       deraadt   164:        if (!f->remote) {
1.6       deraadt   165:                if (f->mode == FARGS_SENDER)
1.1       benno     166:                        for (i = 0; i < f->sourcesz; i++) {
1.4       deraadt   167:                                if (!fargs_is_remote(f->sources[i]))
1.1       benno     168:                                        continue;
1.54      claudio   169:                                errx(ERR_SYNTAX,
1.35      deraadt   170:                                    "remote file in list of local sources: %s",
                    171:                                    f->sources[i]);
1.1       benno     172:                        }
1.6       deraadt   173:                if (f->mode == FARGS_RECEIVER)
1.1       benno     174:                        for (i = 0; i < f->sourcesz; i++) {
                    175:                                if (fargs_is_remote(f->sources[i]) &&
1.4       deraadt   176:                                    !fargs_is_daemon(f->sources[i]))
1.1       benno     177:                                        continue;
                    178:                                if (fargs_is_daemon(f->sources[i]))
1.54      claudio   179:                                        errx(ERR_SYNTAX,
                    180:                                            "remote daemon in list of remote "
                    181:                                            "sources: %s", f->sources[i]);
                    182:                                errx(ERR_SYNTAX, "local file in list of "
                    183:                                    "remote sources: %s", f->sources[i]);
1.1       benno     184:                        }
                    185:        } else {
1.6       deraadt   186:                if (f->mode != FARGS_RECEIVER)
1.54      claudio   187:                        errx(ERR_SYNTAX, "sender mode for remote "
1.1       benno     188:                                "daemon receivers not yet supported");
                    189:                for (i = 0; i < f->sourcesz; i++) {
                    190:                        if (fargs_is_daemon(f->sources[i]))
                    191:                                continue;
1.54      claudio   192:                        errx(ERR_SYNTAX, "non-remote daemon file "
1.1       benno     193:                                "in list of remote daemon sources: "
                    194:                                "%s", f->sources[i]);
                    195:                }
                    196:        }
                    197:
                    198:        /*
                    199:         * If we're not remote and a sender, strip our hostname.
                    200:         * Then exit if we're a sender or a local connection.
                    201:         */
                    202:
1.4       deraadt   203:        if (!f->remote) {
1.6       deraadt   204:                if (f->host == NULL)
1.1       benno     205:                        return f;
1.6       deraadt   206:                if (f->mode == FARGS_SENDER) {
                    207:                        assert(f->host != NULL);
1.1       benno     208:                        assert(len > 0);
                    209:                        j = strlen(f->sink);
                    210:                        memmove(f->sink, f->sink + len + 1, j - len);
                    211:                        return f;
1.6       deraadt   212:                } else if (f->mode != FARGS_RECEIVER)
1.1       benno     213:                        return f;
                    214:        }
                    215:
                    216:        /*
                    217:         * Now strip the hostnames from the remote host.
                    218:         *   rsync://host/module/path -> module/path
                    219:         *   host::module/path -> module/path
                    220:         *   host:path -> path
                    221:         * Also make sure that the remote hosts are the same.
                    222:         */
                    223:
1.6       deraadt   224:        assert(f->host != NULL);
1.1       benno     225:        assert(len > 0);
                    226:
                    227:        for (i = 0; i < f->sourcesz; i++) {
                    228:                cp = f->sources[i];
                    229:                j = strlen(cp);
                    230:                if (f->remote &&
1.6       deraadt   231:                    strncasecmp(cp, "rsync://", 8) == 0) {
1.1       benno     232:                        /* rsync://path */
                    233:                        cp += 8;
1.29      benno     234:                        if ((ccp = strchr(cp, ':')))    /* skip :port */
1.26      deraadt   235:                                *ccp = '\0';
1.1       benno     236:                        if (strncmp(cp, f->host, len) ||
1.11      benno     237:                            (cp[len] != '/' && cp[len] != '\0'))
1.54      claudio   238:                                errx(ERR_SYNTAX, "different remote host: %s",
1.35      deraadt   239:                                    f->sources[i]);
1.1       benno     240:                        memmove(f->sources[i],
                    241:                                f->sources[i] + len + 8 + 1,
                    242:                                j - len - 8);
1.6       deraadt   243:                } else if (f->remote && strncmp(cp, "::", 2) == 0) {
1.1       benno     244:                        /* ::path */
                    245:                        memmove(f->sources[i],
                    246:                                f->sources[i] + 2, j - 1);
                    247:                } else if (f->remote) {
                    248:                        /* host::path */
                    249:                        if (strncmp(cp, f->host, len) ||
1.6       deraadt   250:                            (cp[len] != ':' && cp[len] != '\0'))
1.54      claudio   251:                                errx(ERR_SYNTAX, "different remote host: %s",
1.35      deraadt   252:                                    f->sources[i]);
1.11      benno     253:                        memmove(f->sources[i], f->sources[i] + len + 2,
                    254:                            j - len - 1);
1.6       deraadt   255:                } else if (cp[0] == ':') {
1.1       benno     256:                        /* :path */
                    257:                        memmove(f->sources[i], f->sources[i] + 1, j);
                    258:                } else {
                    259:                        /* host:path */
                    260:                        if (strncmp(cp, f->host, len) ||
1.6       deraadt   261:                            (cp[len] != ':' && cp[len] != '\0'))
1.54      claudio   262:                                errx(ERR_SYNTAX, "different remote host: %s",
1.35      deraadt   263:                                    f->sources[i]);
1.1       benno     264:                        memmove(f->sources[i],
                    265:                                f->sources[i] + len + 1, j - len);
                    266:                }
                    267:        }
                    268:
                    269:        return f;
                    270: }
                    271:
1.56      claudio   272: static struct opts      opts;
                    273:
                    274: #define OP_ADDRESS     1000
                    275: #define OP_PORT                1001
                    276: #define OP_RSYNCPATH   1002
                    277: #define OP_TIMEOUT     1003
                    278: #define OP_VERSION     1004
1.57      claudio   279: #define OP_EXCLUDE     1005
                    280: #define OP_INCLUDE     1006
                    281: #define OP_EXCLUDE_FROM        1007
                    282: #define OP_INCLUDE_FROM        1008
1.56      claudio   283:
                    284: const struct option     lopts[] = {
                    285:     { "address",       required_argument, NULL,                OP_ADDRESS },
                    286:     { "archive",       no_argument,    NULL,                   'a' },
                    287:     { "compress",      no_argument,    NULL,                   'z' },
                    288:     { "del",           no_argument,    &opts.del,              1 },
                    289:     { "delete",                no_argument,    &opts.del,              1 },
                    290:     { "devices",       no_argument,    &opts.devices,          1 },
                    291:     { "no-devices",    no_argument,    &opts.devices,          0 },
                    292:     { "dry-run",       no_argument,    &opts.dry_run,          1 },
1.57      claudio   293:     { "exclude",       required_argument, NULL,                OP_EXCLUDE },
                    294:     { "exclude-from",  required_argument, NULL,                OP_EXCLUDE_FROM },
1.56      claudio   295:     { "group",         no_argument,    &opts.preserve_gids,    1 },
                    296:     { "no-group",      no_argument,    &opts.preserve_gids,    0 },
                    297:     { "help",          no_argument,    NULL,                   'h' },
1.57      claudio   298:     { "include",       required_argument, NULL,                OP_INCLUDE },
                    299:     { "include-from",  required_argument, NULL,                OP_INCLUDE_FROM },
1.56      claudio   300:     { "links",         no_argument,    &opts.preserve_links,   1 },
                    301:     { "no-links",      no_argument,    &opts.preserve_links,   0 },
                    302:     { "no-motd",       no_argument,    &opts.no_motd,          1 },
                    303:     { "numeric-ids",   no_argument,    &opts.numeric_ids,      1 },
                    304:     { "owner",         no_argument,    &opts.preserve_uids,    1 },
                    305:     { "no-owner",      no_argument,    &opts.preserve_uids,    0 },
                    306:     { "perms",         no_argument,    &opts.preserve_perms,   1 },
                    307:     { "no-perms",      no_argument,    &opts.preserve_perms,   0 },
                    308:     { "port",          required_argument, NULL,                OP_PORT },
                    309:     { "recursive",     no_argument,    &opts.recursive,        1 },
                    310:     { "no-recursive",  no_argument,    &opts.recursive,        0 },
                    311:     { "rsh",           required_argument, NULL,                'e' },
                    312:     { "rsync-path",    required_argument, NULL,                OP_RSYNCPATH },
                    313:     { "sender",                no_argument,    &opts.sender,           1 },
                    314:     { "server",                no_argument,    &opts.server,           1 },
                    315:     { "specials",      no_argument,    &opts.specials,         1 },
                    316:     { "no-specials",   no_argument,    &opts.specials,         0 },
                    317:     { "timeout",       required_argument, NULL,                OP_TIMEOUT },
                    318:     { "times",         no_argument,    &opts.preserve_times,   1 },
                    319:     { "no-times",      no_argument,    &opts.preserve_times,   0 },
                    320:     { "verbose",       no_argument,    &verbose,               1 },
                    321:     { "no-verbose",    no_argument,    &verbose,               0 },
                    322:     { "version",       no_argument,    NULL,                   OP_VERSION },
                    323:     { NULL,            0,              NULL,                   0 }
                    324: };
                    325:
1.1       benno     326: int
                    327: main(int argc, char *argv[])
                    328: {
1.2       benno     329:        pid_t            child;
1.46      deraadt   330:        int              fds[2], sd = -1, rc, c, st, i;
1.32      deraadt   331:        struct sess       sess;
1.1       benno     332:        struct fargs    *fargs;
1.32      deraadt   333:        char            **args;
1.50      claudio   334:        const char      *errstr;
1.57      claudio   335:
1.1       benno     336:        /* Global pledge. */
                    337:
1.19      florian   338:        if (pledge("stdio unix rpath wpath cpath dpath inet fattr chown dns getpw proc exec unveil",
1.6       deraadt   339:            NULL) == -1)
1.54      claudio   340:                err(ERR_IPC, "pledge");
1.1       benno     341:
1.44      bket      342:        while ((c = getopt_long(argc, argv, "Dae:ghlnoprtvxz", lopts, NULL))
1.30      benno     343:            != -1) {
1.1       benno     344:                switch (c) {
1.19      florian   345:                case 'D':
                    346:                        opts.devices = 1;
                    347:                        opts.specials = 1;
                    348:                        break;
                    349:                case 'a':
                    350:                        opts.recursive = 1;
                    351:                        opts.preserve_links = 1;
                    352:                        opts.preserve_perms = 1;
                    353:                        opts.preserve_times = 1;
                    354:                        opts.preserve_gids = 1;
                    355:                        opts.preserve_uids = 1;
                    356:                        opts.devices = 1;
                    357:                        opts.specials = 1;
                    358:                        break;
1.1       benno     359:                case 'e':
1.9       deraadt   360:                        opts.ssh_prog = optarg;
1.1       benno     361:                        break;
1.10      benno     362:                case 'g':
                    363:                        opts.preserve_gids = 1;
                    364:                        break;
1.1       benno     365:                case 'l':
                    366:                        opts.preserve_links = 1;
                    367:                        break;
                    368:                case 'n':
                    369:                        opts.dry_run = 1;
                    370:                        break;
1.13      florian   371:                case 'o':
                    372:                        opts.preserve_uids = 1;
                    373:                        break;
1.1       benno     374:                case 'p':
                    375:                        opts.preserve_perms = 1;
                    376:                        break;
                    377:                case 'r':
                    378:                        opts.recursive = 1;
                    379:                        break;
                    380:                case 't':
                    381:                        opts.preserve_times = 1;
                    382:                        break;
                    383:                case 'v':
1.45      benno     384:                        verbose++;
1.1       benno     385:                        break;
1.44      bket      386:                case 'x':
                    387:                        opts.one_file_system++;
                    388:                        break;
1.36      deraadt   389:                case 'z':
                    390:                        fprintf(stderr, "%s: -z not supported yet\n", getprogname());
                    391:                        break;
1.1       benno     392:                case 0:
                    393:                        /* Non-NULL flag values (e.g., --sender). */
                    394:                        break;
1.56      claudio   395:                case OP_ADDRESS:
                    396:                        opts.address = optarg;
1.1       benno     397:                        break;
1.56      claudio   398:                case OP_PORT:
1.26      deraadt   399:                        opts.port = optarg;
                    400:                        break;
1.56      claudio   401:                case OP_RSYNCPATH:
                    402:                        opts.rsync_path = optarg;
1.48      claudio   403:                        break;
1.56      claudio   404:                case OP_TIMEOUT:
1.50      claudio   405:                        poll_timeout = strtonum(optarg, 0, 60*60, &errstr);
                    406:                        if (errstr != NULL)
1.54      claudio   407:                                errx(ERR_SYNTAX, "timeout is %s: %s",
                    408:                                    errstr, optarg);
1.57      claudio   409:                        break;
                    410:                case OP_EXCLUDE:
                    411:                        if (parse_rule(optarg, RULE_EXCLUDE) == -1)
                    412:                                errx(ERR_SYNTAX, "syntax error in exclude: %s",
                    413:                                    optarg);
                    414:                        break;
                    415:                case OP_INCLUDE:
                    416:                        if (parse_rule(optarg, RULE_INCLUDE) == -1)
                    417:                                errx(ERR_SYNTAX, "syntax error in include: %s",
                    418:                                    optarg);
                    419:                        break;
                    420:                case OP_EXCLUDE_FROM:
1.59    ! claudio   421:                        parse_file(optarg, RULE_EXCLUDE);
1.57      claudio   422:                        break;
                    423:                case OP_INCLUDE_FROM:
1.59    ! claudio   424:                        parse_file(optarg, RULE_INCLUDE);
1.50      claudio   425:                        break;
1.56      claudio   426:                case OP_VERSION:
                    427:                        fprintf(stderr, "openrsync: protocol version %u\n",
                    428:                            RSYNC_PROTOCOL);
                    429:                        exit(0);
1.21      deraadt   430:                case 'h':
1.1       benno     431:                default:
                    432:                        goto usage;
                    433:                }
                    434:        }
                    435:
                    436:        argc -= optind;
                    437:        argv += optind;
                    438:
                    439:        /* FIXME: reference implementation rsync accepts this. */
                    440:
                    441:        if (argc < 2)
                    442:                goto usage;
                    443:
1.26      deraadt   444:        if (opts.port == NULL)
1.29      benno     445:                opts.port = "rsync";
1.26      deraadt   446:
1.51      claudio   447:        /* by default and for --timeout=0 disable poll_timeout */
                    448:        if (poll_timeout == 0)
1.59    ! claudio   449:                poll_timeout = -1; else
1.51      claudio   450:                poll_timeout *= 1000;
                    451:
1.1       benno     452:        /*
                    453:         * This is what happens when we're started with the "hidden"
                    454:         * --server option, which is invoked for the rsync on the remote
                    455:         * host by the parent.
                    456:         */
                    457:
1.32      deraadt   458:        if (opts.server)
                    459:                exit(rsync_server(&opts, (size_t)argc, argv));
1.50      claudio   460:
1.1       benno     461:        /*
                    462:         * Now we know that we're the client on the local machine
                    463:         * invoking rsync(1).
                    464:         * At this point, we need to start the client and server
                    465:         * initiation logic.
                    466:         * The client is what we continue running on this host; the
                    467:         * server is what we'll use to connect to the remote and
                    468:         * invoke rsync with the --server option.
                    469:         */
                    470:
1.26      deraadt   471:        fargs = fargs_parse(argc, argv, &opts);
1.6       deraadt   472:        assert(fargs != NULL);
1.1       benno     473:
                    474:        /*
                    475:         * If we're contacting an rsync:// daemon, then we don't need to
                    476:         * fork, because we won't start a server ourselves.
1.41      naddy     477:         * Route directly into the socket code, unless a remote shell
                    478:         * has explicitly been specified.
1.1       benno     479:         */
                    480:
1.41      naddy     481:        if (fargs->remote && opts.ssh_prog == NULL) {
1.6       deraadt   482:                assert(fargs->mode == FARGS_RECEIVER);
1.47      naddy     483:                if ((rc = rsync_connect(&opts, &sd, fargs)) == 0) {
1.41      naddy     484:                        rc = rsync_socket(&opts, sd, fargs);
1.47      naddy     485:                        close(sd);
                    486:                }
1.41      naddy     487:                exit(rc);
1.1       benno     488:        }
                    489:
                    490:        /* Drop the dns/inet possibility. */
                    491:
1.19      florian   492:        if (pledge("stdio unix rpath wpath cpath dpath fattr chown getpw proc exec unveil",
1.6       deraadt   493:            NULL) == -1)
1.54      claudio   494:                err(ERR_IPC, "pledge");
1.1       benno     495:
                    496:        /* Create a bidirectional socket and start our child. */
                    497:
1.6       deraadt   498:        if (socketpair(AF_UNIX, SOCK_STREAM | SOCK_NONBLOCK, 0, fds) == -1)
1.54      claudio   499:                err(ERR_IPC, "socketpair");
1.1       benno     500:
1.32      deraadt   501:        switch ((child = fork())) {
                    502:        case -1:
1.54      claudio   503:                err(ERR_IPC, "fork");
1.32      deraadt   504:        case 0:
1.1       benno     505:                close(fds[0]);
1.32      deraadt   506:                if (pledge("stdio exec", NULL) == -1)
1.54      claudio   507:                        err(ERR_IPC, "pledge");
1.32      deraadt   508:
                    509:                memset(&sess, 0, sizeof(struct sess));
                    510:                sess.opts = &opts;
1.1       benno     511:
1.54      claudio   512:                args = fargs_cmdline(&sess, fargs, NULL);
1.1       benno     513:
1.32      deraadt   514:                for (i = 0; args[i] != NULL; i++)
1.45      benno     515:                        LOG2("exec[%d] = %s", i, args[i]);
1.1       benno     516:
1.32      deraadt   517:                /* Make sure the child's stdin is from the sender. */
1.54      claudio   518:                if (dup2(fds[1], STDIN_FILENO) == -1)
                    519:                        err(ERR_IPC, "dup2");
                    520:                if (dup2(fds[1], STDOUT_FILENO) == -1)
                    521:                        err(ERR_IPC, "dup2");
1.32      deraadt   522:                execvp(args[0], args);
1.54      claudio   523:                _exit(ERR_IPC);
1.1       benno     524:                /* NOTREACHED */
1.32      deraadt   525:        default:
                    526:                close(fds[1]);
1.41      naddy     527:                if (!fargs->remote)
                    528:                        rc = rsync_client(&opts, fds[0], fargs);
                    529:                else
                    530:                        rc = rsync_socket(&opts, fds[0], fargs);
1.32      deraadt   531:                break;
1.1       benno     532:        }
                    533:
1.47      naddy     534:        close(fds[0]);
1.1       benno     535:
1.6       deraadt   536:        if (waitpid(child, &st, 0) == -1)
1.54      claudio   537:                err(ERR_WAITPID, "waitpid");
1.34      deraadt   538:
                    539:        /*
                    540:         * If we don't already have an error (rc == 0), then inherit the
                    541:         * error code of rsync_server() if it has exited.
                    542:         * If it hasn't exited, it overrides our return value.
                    543:         */
                    544:
1.54      claudio   545:        if (rc == 0) {
                    546:                if (WIFEXITED(st))
                    547:                        rc = WEXITSTATUS(st);
                    548:                else if (WIFSIGNALED(st))
                    549:                        rc = ERR_TERMIMATED;
                    550:                else
                    551:                        rc = ERR_WAITPID;
                    552:        }
1.34      deraadt   553:
1.32      deraadt   554:        exit(rc);
1.1       benno     555: usage:
1.42      schwarze  556:        fprintf(stderr, "usage: %s"
1.49      deraadt   557:            " [-aDglnoprtvx] [-e program] [--address=sourceaddr] [--del]\n"
1.58      job       558:            "\t[--exclude] [--exclude-from=file] [--include] "
                    559:            "[--include-from=file]\n"
1.53      job       560:            "\t[--no-motd] [--numeric-ids] [--port=portnumber] "
                    561:            "[--rsync-path=program]\n\t[--timeout=seconds] [--version] "
                    562:             "source ... directory\n",
1.32      deraadt   563:            getprogname());
1.54      claudio   564:        exit(ERR_SYNTAX);
1.1       benno     565: }