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

Annotation of src/usr.bin/tip/cmds.c, Revision 1.34

1.34    ! nicm        1: /*     $OpenBSD: cmds.c,v 1.33 2010/06/29 16:41:56 nicm Exp $  */
1.5       millert     2: /*     $NetBSD: cmds.c,v 1.7 1997/02/11 09:24:03 mrg Exp $     */
1.1       deraadt     3:
                      4: /*
                      5:  * Copyright (c) 1983, 1993
                      6:  *     The Regents of the University of California.  All rights reserved.
                      7:  *
                      8:  * Redistribution and use in source and binary forms, with or without
                      9:  * modification, are permitted provided that the following conditions
                     10:  * are met:
                     11:  * 1. Redistributions of source code must retain the above copyright
                     12:  *    notice, this list of conditions and the following disclaimer.
                     13:  * 2. Redistributions in binary form must reproduce the above copyright
                     14:  *    notice, this list of conditions and the following disclaimer in the
                     15:  *    documentation and/or other materials provided with the distribution.
1.16      millert    16:  * 3. Neither the name of the University nor the names of its contributors
1.1       deraadt    17:  *    may be used to endorse or promote products derived from this software
                     18:  *    without specific prior written permission.
                     19:  *
                     20:  * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
                     21:  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
                     22:  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
                     23:  * ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
                     24:  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
                     25:  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
                     26:  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
                     27:  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
                     28:  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
                     29:  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
                     30:  * SUCH DAMAGE.
                     31:  */
                     32:
                     33: #include "tip.h"
                     34: #include "pathnames.h"
                     35:
1.11      millert    36: #include <vis.h>
                     37:
1.1       deraadt    38: /*
                     39:  * tip
                     40:  *
                     41:  * miscellaneous commands
                     42:  */
                     43:
                     44: int    quant[] = { 60, 60, 24 };
                     45:
                     46: char   null = '\0';
                     47: char   *sep[] = { "second", "minute", "hour" };
                     48: static char *argv[10];         /* argument vector for take and put */
                     49:
1.24      moritz     50: static void    transfer(char *, int, char *);
                     51: static void    stopsnd(int);   /* SIGINT handler during file transfers */
                     52: static void    intcopy(int);   /* interrupt routine for file transfers */
                     53: static void    transmit(FILE *, char *, char *);
                     54: static void    send(int);
                     55: static void    execute(char *);
                     56: static int     args(char *, char **, int);
                     57: static void    prtime(char *, time_t);
                     58: static void    tandem(char *);
                     59: static void    hardwareflow(char *);
1.26      deraadt    60: void           linedisc(char *);
1.24      moritz     61: static int     anyof(char *, char *);
1.1       deraadt    62:
                     63: /*
                     64:  * FTP - remote ==> local
                     65:  *  get a file from the remote host
                     66:  */
1.7       deraadt    67: void
1.24      moritz     68: getfl(int c)
1.1       deraadt    69: {
1.24      moritz     70:        char buf[256], *cp;
1.22      deraadt    71:
1.1       deraadt    72:        putchar(c);
                     73:        /*
                     74:         * get the UNIX receiving file's name
                     75:         */
1.6       millert    76:        if (prompt("Local file name? ", copyname, sizeof(copyname)))
1.1       deraadt    77:                return;
                     78:        cp = expand(copyname);
                     79:        if ((sfd = creat(cp, 0666)) < 0) {
                     80:                printf("\r\n%s: cannot creat\r\n", copyname);
                     81:                return;
                     82:        }
1.22      deraadt    83:
1.1       deraadt    84:        /*
                     85:         * collect parameters
                     86:         */
1.6       millert    87:        if (prompt("List command for remote system? ", buf, sizeof(buf))) {
1.1       deraadt    88:                unlink(copyname);
                     89:                return;
                     90:        }
                     91:        transfer(buf, sfd, value(EOFREAD));
                     92: }
                     93:
                     94: /*
                     95:  * Cu-like take command
                     96:  */
1.7       deraadt    97: void
1.24      moritz     98: cu_take(int c)
1.1       deraadt    99: {
                    100:        int fd, argc;
1.24      moritz    101:        char line[BUFSIZ], *cp;
1.1       deraadt   102:
1.6       millert   103:        if (prompt("[take] ", copyname, sizeof(copyname)))
1.1       deraadt   104:                return;
1.7       deraadt   105:        if ((argc = args(copyname, argv, sizeof(argv)/sizeof(argv[0]))) < 1 ||
                    106:            argc > 2) {
1.1       deraadt   107:                printf("usage: <take> from [to]\r\n");
                    108:                return;
                    109:        }
                    110:        if (argc == 1)
                    111:                argv[1] = argv[0];
                    112:        cp = expand(argv[1]);
                    113:        if ((fd = creat(cp, 0666)) < 0) {
                    114:                printf("\r\n%s: cannot create\r\n", argv[1]);
                    115:                return;
                    116:        }
1.21      otto      117:        (void)snprintf(line, sizeof(line), "cat %s;echo ''|tr '\\012' '\\01'", argv[0]);
1.1       deraadt   118:        transfer(line, fd, "\01");
                    119: }
                    120:
                    121: static jmp_buf intbuf;
1.7       deraadt   122:
1.1       deraadt   123: /*
                    124:  * Bulk transfer routine --
                    125:  *  used by getfl(), cu_take(), and pipefile()
                    126:  */
1.24      moritz    127: static void
1.22      deraadt   128: transfer(char *buf, int fd, char *eofchars)
1.1       deraadt   129: {
1.25      deraadt   130:        int ct, eof;
1.1       deraadt   131:        char c, buffer[BUFSIZ];
1.7       deraadt   132:        char *p = buffer;
1.25      deraadt   133:        size_t cnt;
1.1       deraadt   134:        time_t start;
                    135:        sig_t f;
                    136:        char r;
                    137:
1.21      otto      138:        if (number(value(FRAMESIZE)) > BUFSIZ || number(value(FRAMESIZE)) < 1) {
                    139:                printf("framesize must be >= 1 and <= %d\r\n", BUFSIZ);
                    140:                close(fd);
                    141:                return;
                    142:        }
                    143:
1.8       deraadt   144:        parwrite(FD, buf, size(buf));
1.1       deraadt   145:        quit = 0;
1.32      nicm      146:        write(tipout_fd, "W", 1);
1.29      nicm      147:        read(tipout_fd, (char *)&ccc, 1);  /* Wait until read process stops */
1.22      deraadt   148:
1.1       deraadt   149:        /*
                    150:         * finish command
                    151:         */
                    152:        r = '\r';
1.8       deraadt   153:        parwrite(FD, &r, 1);
1.1       deraadt   154:        do
1.22      deraadt   155:                read(FD, &c, 1);
1.2       deraadt   156:        while ((c&STRIP_PAR) != '\n');
                    157:        tcsetattr(0, TCSAFLUSH, &defchars);
1.22      deraadt   158:
1.1       deraadt   159:        (void) setjmp(intbuf);
                    160:        f = signal(SIGINT, intcopy);
                    161:        start = time(0);
                    162:        for (ct = 0; !quit;) {
                    163:                eof = read(FD, &c, 1) <= 0;
1.2       deraadt   164:                c &= STRIP_PAR;
1.1       deraadt   165:                if (quit)
                    166:                        continue;
                    167:                if (eof || any(c, eofchars))
                    168:                        break;
                    169:                if (c == 0)
                    170:                        continue;       /* ignore nulls */
                    171:                if (c == '\r')
                    172:                        continue;
                    173:                *p++ = c;
                    174:
                    175:                if (c == '\n' && boolean(value(VERBOSE)))
                    176:                        printf("\r%d", ++ct);
                    177:                if ((cnt = (p-buffer)) == number(value(FRAMESIZE))) {
                    178:                        if (write(fd, buffer, cnt) != cnt) {
                    179:                                printf("\r\nwrite error\r\n");
                    180:                                quit = 1;
                    181:                        }
                    182:                        p = buffer;
                    183:                }
                    184:        }
1.7       deraadt   185:        if ((cnt = (p-buffer)))
1.1       deraadt   186:                if (write(fd, buffer, cnt) != cnt)
                    187:                        printf("\r\nwrite error\r\n");
                    188:
                    189:        if (boolean(value(VERBOSE)))
                    190:                prtime(" lines transferred in ", time(0)-start);
1.2       deraadt   191:        tcsetattr(0, TCSAFLUSH, &term);
1.29      nicm      192:        write(tipout_fd, (char *)&ccc, 1);
1.1       deraadt   193:        signal(SIGINT, f);
                    194:        close(fd);
                    195: }
                    196:
                    197: /*
                    198:  * FTP - remote ==> local process
                    199:  *   send remote input to local process via pipe
                    200:  */
1.24      moritz    201: /*ARGSUSED*/
1.7       deraadt   202: void
1.24      moritz    203: pipefile(int c)
1.1       deraadt   204: {
1.15      mpech     205:        int pdes[2];
1.1       deraadt   206:        char buf[256];
                    207:        int status, p;
1.15      mpech     208:        pid_t cpid;
1.1       deraadt   209:
1.6       millert   210:        if (prompt("Local command? ", buf, sizeof(buf)))
1.1       deraadt   211:                return;
                    212:
                    213:        if (pipe(pdes)) {
                    214:                printf("can't establish pipe\r\n");
                    215:                return;
                    216:        }
                    217:
                    218:        if ((cpid = fork()) < 0) {
                    219:                printf("can't fork!\r\n");
                    220:                return;
                    221:        } else if (cpid) {
1.6       millert   222:                if (prompt("List command for remote system? ", buf, sizeof(buf))) {
1.1       deraadt   223:                        close(pdes[0]), close(pdes[1]);
                    224:                        kill (cpid, SIGKILL);
                    225:                } else {
                    226:                        close(pdes[0]);
                    227:                        signal(SIGPIPE, intcopy);
                    228:                        transfer(buf, pdes[1], value(EOFREAD));
                    229:                        signal(SIGPIPE, SIG_DFL);
                    230:                        while ((p = wait(&status)) > 0 && p != cpid)
                    231:                                ;
                    232:                }
                    233:        } else {
1.13      millert   234:                int f;
1.1       deraadt   235:
                    236:                dup2(pdes[0], 0);
                    237:                close(pdes[0]);
                    238:                for (f = 3; f < 20; f++)
                    239:                        close(f);
                    240:                execute(buf);
                    241:                printf("can't execl!\r\n");
                    242:                exit(0);
                    243:        }
                    244: }
                    245:
                    246: /*
                    247:  * Interrupt service routine for FTP
                    248:  */
1.22      deraadt   249: /*ARGSUSED*/
1.24      moritz    250: static void
1.22      deraadt   251: stopsnd(int signo)
1.1       deraadt   252: {
                    253:        stop = 1;
                    254:        signal(SIGINT, SIG_IGN);
                    255: }
                    256:
                    257: /*
                    258:  * FTP - local ==> remote
                    259:  *  send local file to remote host
                    260:  *  terminate transmission with pseudo EOF sequence
                    261:  */
1.7       deraadt   262: void
1.24      moritz    263: sendfile(int c)
1.1       deraadt   264: {
1.22      deraadt   265:        FILE *fp;
1.1       deraadt   266:        char *fnamex;
                    267:
1.24      moritz    268:        putchar(c);
1.1       deraadt   269:        /*
                    270:         * get file name
                    271:         */
1.6       millert   272:        if (prompt("Local file name? ", fname, sizeof(fname)))
1.1       deraadt   273:                return;
                    274:
                    275:        /*
                    276:         * look up file
                    277:         */
                    278:        fnamex = expand(fname);
1.22      deraadt   279:        if ((fp = fopen(fnamex, "r")) == NULL) {
1.1       deraadt   280:                printf("%s: cannot open\r\n", fname);
                    281:                return;
                    282:        }
1.22      deraadt   283:        transmit(fp, value(EOFWRITE), NULL);
1.2       deraadt   284:        if (!boolean(value(ECHOCHECK)))
                    285:                tcdrain(FD);
1.1       deraadt   286: }
                    287:
                    288: /*
                    289:  * Bulk transfer routine to remote host --
                    290:  *   used by sendfile() and cu_put()
                    291:  */
1.24      moritz    292: static void
1.22      deraadt   293: transmit(FILE *fp, char *eofchars, char *command)
1.1       deraadt   294: {
                    295:        char *pc, lastc;
                    296:        int c, ccount, lcount;
                    297:        time_t start_t, stop_t;
                    298:        sig_t f;
                    299:
1.32      nicm      300:        write(tipout_fd, "W", 1);       /* put TIPOUT into a wait state */
1.1       deraadt   301:        stop = 0;
                    302:        f = signal(SIGINT, stopsnd);
1.2       deraadt   303:        tcsetattr(0, TCSAFLUSH, &defchars);
1.29      nicm      304:        read(tipout_fd, (char *)&ccc, 1);
1.1       deraadt   305:        if (command != NULL) {
                    306:                for (pc = command; *pc; pc++)
                    307:                        send(*pc);
                    308:                if (boolean(value(ECHOCHECK)))
                    309:                        read(FD, (char *)&c, 1);        /* trailing \n */
                    310:                else {
1.2       deraadt   311:                        tcdrain(FD);
1.1       deraadt   312:                        sleep(5); /* wait for remote stty to take effect */
                    313:                }
                    314:        }
                    315:        lcount = 0;
                    316:        lastc = '\0';
                    317:        start_t = time(0);
                    318:        while (1) {
                    319:                ccount = 0;
                    320:                do {
1.22      deraadt   321:                        c = getc(fp);
1.1       deraadt   322:                        if (stop)
                    323:                                goto out;
                    324:                        if (c == EOF)
                    325:                                goto out;
                    326:                        if (c == 0177 && !boolean(value(RAWFTP)))
                    327:                                continue;
                    328:                        lastc = c;
                    329:                        if (c < 040) {
                    330:                                if (c == '\n') {
                    331:                                        if (!boolean(value(RAWFTP)))
                    332:                                                c = '\r';
1.22      deraadt   333:                                } else if (c == '\t') {
1.1       deraadt   334:                                        if (!boolean(value(RAWFTP))) {
                    335:                                                if (boolean(value(TABEXPAND))) {
                    336:                                                        send(' ');
                    337:                                                        while ((++ccount % 8) != 0)
                    338:                                                                send(' ');
                    339:                                                        continue;
                    340:                                                }
                    341:                                        }
                    342:                                } else
                    343:                                        if (!boolean(value(RAWFTP)))
                    344:                                                continue;
                    345:                        }
                    346:                        send(c);
                    347:                } while (c != '\r' && !boolean(value(RAWFTP)));
                    348:                if (boolean(value(VERBOSE)))
                    349:                        printf("\r%d", ++lcount);
                    350:                if (boolean(value(ECHOCHECK))) {
                    351:                        timedout = 0;
1.25      deraadt   352:                        alarm((unsigned int)lvalue(ETIMEOUT));
1.1       deraadt   353:                        do {    /* wait for prompt */
                    354:                                read(FD, (char *)&c, 1);
                    355:                                if (timedout || stop) {
                    356:                                        if (timedout)
                    357:                                                printf("\r\ntimed out at eol\r\n");
                    358:                                        alarm(0);
                    359:                                        goto out;
                    360:                                }
1.2       deraadt   361:                        } while ((c&STRIP_PAR) != character(value(PROMPT)));
1.1       deraadt   362:                        alarm(0);
                    363:                }
                    364:        }
                    365: out:
                    366:        if (lastc != '\n' && !boolean(value(RAWFTP)))
                    367:                send('\r');
                    368:        if (eofchars) {
                    369:                for (pc = eofchars; *pc; pc++)
                    370:                        send(*pc);
                    371:        }
                    372:        stop_t = time(0);
1.22      deraadt   373:        fclose(fp);
1.1       deraadt   374:        signal(SIGINT, f);
1.10      deraadt   375:        if (boolean(value(VERBOSE))) {
1.1       deraadt   376:                if (boolean(value(RAWFTP)))
                    377:                        prtime(" chars transferred in ", stop_t-start_t);
                    378:                else
                    379:                        prtime(" lines transferred in ", stop_t-start_t);
1.10      deraadt   380:        }
1.29      nicm      381:        write(tipout_fd, (char *)&ccc, 1);
1.2       deraadt   382:        tcsetattr(0, TCSAFLUSH, &term);
1.1       deraadt   383: }
                    384:
                    385: /*
                    386:  * Cu-like put command
                    387:  */
1.24      moritz    388: /*ARGSUSED*/
1.7       deraadt   389: void
1.24      moritz    390: cu_put(int c)
1.1       deraadt   391: {
1.22      deraadt   392:        FILE *fp;
1.1       deraadt   393:        char line[BUFSIZ];
                    394:        int argc;
                    395:        char *copynamex;
                    396:
1.6       millert   397:        if (prompt("[put] ", copyname, sizeof(copyname)))
1.1       deraadt   398:                return;
1.7       deraadt   399:        if ((argc = args(copyname, argv, sizeof(argv)/sizeof(argv[0]))) < 1 ||
                    400:            argc > 2) {
1.1       deraadt   401:                printf("usage: <put> from [to]\r\n");
                    402:                return;
                    403:        }
                    404:        if (argc == 1)
                    405:                argv[1] = argv[0];
                    406:        copynamex = expand(argv[0]);
1.22      deraadt   407:        if ((fp = fopen(copynamex, "r")) == NULL) {
1.1       deraadt   408:                printf("%s: cannot open\r\n", copynamex);
                    409:                return;
                    410:        }
                    411:        if (boolean(value(ECHOCHECK)))
1.5       millert   412:                (void)snprintf(line, sizeof(line), "cat>%s\r", argv[1]);
1.1       deraadt   413:        else
1.5       millert   414:                (void)snprintf(line, sizeof(line),
                    415:                    "stty -echo;cat>%s;stty echo\r", argv[1]);
1.22      deraadt   416:        transmit(fp, "\04", line);
1.1       deraadt   417: }
                    418:
                    419: /*
                    420:  * FTP - send single character
                    421:  *  wait for echo & handle timeout
                    422:  */
1.24      moritz    423: static void
1.19      deraadt   424: send(int c)
1.1       deraadt   425: {
                    426:        char cc;
                    427:        int retry = 0;
                    428:
                    429:        cc = c;
1.8       deraadt   430:        parwrite(FD, &cc, 1);
1.1       deraadt   431:        if (number(value(CDELAY)) > 0 && c != '\r')
1.18      deraadt   432:                usleep(number(value(CDELAY)));
1.1       deraadt   433:        if (!boolean(value(ECHOCHECK))) {
                    434:                if (number(value(LDELAY)) > 0 && c == '\r')
1.18      deraadt   435:                        usleep(number(value(LDELAY)));
1.1       deraadt   436:                return;
                    437:        }
                    438: tryagain:
                    439:        timedout = 0;
1.25      deraadt   440:        alarm((unsigned int)lvalue(ETIMEOUT));
1.1       deraadt   441:        read(FD, &cc, 1);
                    442:        alarm(0);
                    443:        if (timedout) {
                    444:                printf("\r\ntimeout error (%s)\r\n", ctrl(c));
                    445:                if (retry++ > 3)
                    446:                        return;
1.8       deraadt   447:                parwrite(FD, &null, 1); /* poke it */
1.1       deraadt   448:                goto tryagain;
                    449:        }
                    450: }
                    451:
1.25      deraadt   452: /*ARGSUSED*/
1.1       deraadt   453: void
1.22      deraadt   454: timeout(int signo)
1.1       deraadt   455: {
1.31      deraadt   456:        int saved_errno = errno;
                    457:
1.1       deraadt   458:        signal(SIGALRM, timeout);
                    459:        timedout = 1;
1.31      deraadt   460:
                    461:        errno = saved_errno;
1.1       deraadt   462: }
                    463:
                    464: /*
                    465:  * Stolen from consh() -- puts a remote file on the output of a local command.
                    466:  *     Identical to consh() except for where stdout goes.
                    467:  */
1.7       deraadt   468: void
1.22      deraadt   469: pipeout(int c)
1.1       deraadt   470: {
                    471:        char buf[256];
1.15      mpech     472:        int status, p;
                    473:        pid_t cpid;
1.7       deraadt   474:        time_t start = time(NULL);
1.1       deraadt   475:
                    476:        putchar(c);
1.6       millert   477:        if (prompt("Local command? ", buf, sizeof(buf)))
1.1       deraadt   478:                return;
1.32      nicm      479:        write(tipout_fd, "W", 1);       /* put TIPOUT into a wait state */
1.1       deraadt   480:        signal(SIGINT, SIG_IGN);
                    481:        signal(SIGQUIT, SIG_IGN);
1.2       deraadt   482:        tcsetattr(0, TCSAFLUSH, &defchars);
1.29      nicm      483:        read(tipout_fd, (char *)&ccc, 1);
1.1       deraadt   484:        /*
                    485:         * Set up file descriptors in the child and
                    486:         *  let it go...
                    487:         */
                    488:        if ((cpid = fork()) < 0)
                    489:                printf("can't fork!\r\n");
                    490:        else if (cpid) {
1.7       deraadt   491:                start = time(NULL);
1.1       deraadt   492:                while ((p = wait(&status)) > 0 && p != cpid)
                    493:                        ;
                    494:        } else {
1.13      millert   495:                int i;
1.1       deraadt   496:
                    497:                dup2(FD, 1);
                    498:                for (i = 3; i < 20; i++)
                    499:                        close(i);
                    500:                signal(SIGINT, SIG_DFL);
                    501:                signal(SIGQUIT, SIG_DFL);
                    502:                execute(buf);
                    503:                printf("can't find `%s'\r\n", buf);
                    504:                exit(0);
                    505:        }
                    506:        if (boolean(value(VERBOSE)))
                    507:                prtime("away for ", time(0)-start);
1.29      nicm      508:        write(tipout_fd, (char *)&ccc, 1);
1.2       deraadt   509:        tcsetattr(0, TCSAFLUSH, &term);
1.1       deraadt   510:        signal(SIGINT, SIG_DFL);
                    511:        signal(SIGQUIT, SIG_DFL);
                    512: }
                    513:
                    514: /*
                    515:  * Fork a program with:
                    516:  *  0 <-> remote tty in
                    517:  *  1 <-> remote tty out
1.20      otto      518:  *  2 <-> local tty stderr
1.1       deraadt   519:  */
1.7       deraadt   520: void
1.19      deraadt   521: consh(int c)
1.1       deraadt   522: {
                    523:        char buf[256];
1.15      mpech     524:        int status, p;
                    525:        pid_t cpid;
1.7       deraadt   526:        time_t start = time(NULL);
1.1       deraadt   527:
                    528:        putchar(c);
1.6       millert   529:        if (prompt("Local command? ", buf, sizeof(buf)))
1.1       deraadt   530:                return;
1.32      nicm      531:        write(tipout_fd, "W", 1);       /* put TIPOUT into a wait state */
1.1       deraadt   532:        signal(SIGINT, SIG_IGN);
                    533:        signal(SIGQUIT, SIG_IGN);
1.2       deraadt   534:        tcsetattr(0, TCSAFLUSH, &defchars);
1.29      nicm      535:        read(tipout_fd, (char *)&ccc, 1);
1.1       deraadt   536:        /*
                    537:         * Set up file descriptors in the child and
                    538:         *  let it go...
                    539:         */
                    540:        if ((cpid = fork()) < 0)
                    541:                printf("can't fork!\r\n");
                    542:        else if (cpid) {
                    543:                start = time(0);
                    544:                while ((p = wait(&status)) > 0 && p != cpid)
                    545:                        ;
                    546:        } else {
                    547:                dup2(FD, 0);
                    548:                dup2(3, 1);
1.20      otto      549:                closefrom(3);
1.1       deraadt   550:                signal(SIGINT, SIG_DFL);
                    551:                signal(SIGQUIT, SIG_DFL);
                    552:                execute(buf);
                    553:                printf("can't find `%s'\r\n", buf);
                    554:                exit(0);
                    555:        }
                    556:        if (boolean(value(VERBOSE)))
                    557:                prtime("away for ", time(0)-start);
1.29      nicm      558:        write(tipout_fd, (char *)&ccc, 1);
1.2       deraadt   559:        tcsetattr(0, TCSAFLUSH, &term);
1.1       deraadt   560:        signal(SIGINT, SIG_DFL);
                    561:        signal(SIGQUIT, SIG_DFL);
                    562: }
                    563:
                    564: /*
                    565:  * Escape to local shell
                    566:  */
1.24      moritz    567: /*ARGSUSED*/
1.7       deraadt   568: void
1.24      moritz    569: shell(int c)
1.1       deraadt   570: {
1.15      mpech     571:        int status;
1.1       deraadt   572:        char *cp;
1.15      mpech     573:        pid_t shpid;
1.1       deraadt   574:
                    575:        printf("[sh]\r\n");
                    576:        signal(SIGINT, SIG_IGN);
                    577:        signal(SIGQUIT, SIG_IGN);
                    578:        unraw();
1.7       deraadt   579:        if ((shpid = fork())) {
1.1       deraadt   580:                while (shpid != wait(&status));
                    581:                raw();
                    582:                printf("\r\n!\r\n");
                    583:                signal(SIGINT, SIG_DFL);
                    584:                signal(SIGQUIT, SIG_DFL);
                    585:                return;
                    586:        } else {
                    587:                signal(SIGQUIT, SIG_DFL);
                    588:                signal(SIGINT, SIG_DFL);
1.4       millert   589:                if ((cp = strrchr(value(SHELL), '/')) == NULL)
1.1       deraadt   590:                        cp = value(SHELL);
                    591:                else
                    592:                        cp++;
1.9       deraadt   593:                execl(value(SHELL), cp, (char *)NULL);
1.1       deraadt   594:                printf("\r\ncan't execl!\r\n");
                    595:                exit(1);
                    596:        }
                    597: }
                    598:
                    599: /*
                    600:  * TIPIN portion of scripting
                    601:  *   initiate the conversation with TIPOUT
                    602:  */
1.7       deraadt   603: void
1.22      deraadt   604: setscript(void)
1.1       deraadt   605: {
                    606:        char c;
1.25      deraadt   607:
1.1       deraadt   608:        /*
                    609:         * enable TIPOUT side for dialogue
                    610:         */
1.32      nicm      611:        write(tipout_fd, "S", 1);
1.1       deraadt   612:        if (boolean(value(SCRIPT)))
1.29      nicm      613:                write(tipout_fd, value(RECORD), size(value(RECORD)));
                    614:        write(tipout_fd, "\n", 1);
1.1       deraadt   615:        /*
                    616:         * wait for TIPOUT to finish
                    617:         */
1.29      nicm      618:        read(tipout_fd, &c, 1);
1.1       deraadt   619:        if (c == 'n')
                    620:                printf("can't create %s\r\n", value(RECORD));
                    621: }
                    622:
                    623: /*
                    624:  * Change current working directory of
                    625:  *   local portion of tip
                    626:  */
1.24      moritz    627: /*ARGSUSED*/
1.7       deraadt   628: void
1.24      moritz    629: chdirectory(int c)
1.1       deraadt   630: {
1.6       millert   631:        char dirname[PATH_MAX];
1.13      millert   632:        char *cp = dirname;
1.1       deraadt   633:
1.6       millert   634:        if (prompt("[cd] ", dirname, sizeof(dirname))) {
1.1       deraadt   635:                if (stoprompt)
                    636:                        return;
                    637:                cp = value(HOME);
                    638:        }
                    639:        if (chdir(cp) < 0)
                    640:                printf("%s: bad directory\r\n", cp);
                    641:        printf("!\r\n");
                    642: }
                    643:
1.7       deraadt   644: void
1.22      deraadt   645: tipabort(char *msg)
1.1       deraadt   646: {
                    647:
1.21      otto      648:        signal(SIGTERM, SIG_IGN);
1.19      deraadt   649:        kill(tipout_pid, SIGTERM);
1.33      nicm      650:        logent(value(HOST), DV, "call terminated");
1.27      moritz    651:        if (msg != NULL)
1.1       deraadt   652:                printf("\r\n%s", msg);
                    653:        printf("\r\n[EOT]\r\n");
                    654:        (void)uu_unlock(uucplock);
                    655:        unraw();
                    656:        exit(0);
                    657: }
                    658:
1.24      moritz    659: /*ARGSUSED*/
1.7       deraadt   660: void
1.24      moritz    661: finish(int c)
1.1       deraadt   662: {
                    663:        char *dismsg;
                    664:
1.27      moritz    665:        if ((dismsg = value(DISCONNECT)) != NULL) {
1.1       deraadt   666:                write(FD, dismsg, strlen(dismsg));
                    667:                sleep(5);
                    668:        }
1.27      moritz    669:        tipabort(NULL);
1.1       deraadt   670: }
                    671:
1.25      deraadt   672: /*ARGSUSED*/
1.24      moritz    673: static void
1.22      deraadt   674: intcopy(int signo)
1.1       deraadt   675: {
                    676:        raw();
                    677:        quit = 1;
                    678:        longjmp(intbuf, 1);
                    679: }
                    680:
1.24      moritz    681: static void
1.22      deraadt   682: execute(char *s)
1.1       deraadt   683: {
1.13      millert   684:        char *cp;
1.1       deraadt   685:
1.4       millert   686:        if ((cp = strrchr(value(SHELL), '/')) == NULL)
1.1       deraadt   687:                cp = value(SHELL);
                    688:        else
                    689:                cp++;
1.9       deraadt   690:        execl(value(SHELL), cp, "-c", s, (char *)NULL);
1.1       deraadt   691: }
                    692:
1.24      moritz    693: static int
1.22      deraadt   694: args(char *buf, char *a[], int num)
1.1       deraadt   695: {
1.13      millert   696:        char *p = buf, *start;
                    697:        char **parg = a;
                    698:        int n = 0;
1.1       deraadt   699:
                    700:        do {
                    701:                while (*p && (*p == ' ' || *p == '\t'))
                    702:                        p++;
                    703:                start = p;
                    704:                if (*p)
                    705:                        *parg = p;
                    706:                while (*p && (*p != ' ' && *p != '\t'))
                    707:                        p++;
                    708:                if (p != start)
                    709:                        parg++, n++;
                    710:                if (*p)
                    711:                        *p++ = '\0';
1.7       deraadt   712:        } while (*p && n < num);
1.1       deraadt   713:
                    714:        return(n);
                    715: }
                    716:
1.24      moritz    717: static void
1.22      deraadt   718: prtime(char *s, time_t a)
1.1       deraadt   719: {
1.13      millert   720:        int i;
1.1       deraadt   721:        int nums[3];
                    722:
                    723:        for (i = 0; i < 3; i++) {
                    724:                nums[i] = (int)(a % quant[i]);
                    725:                a /= quant[i];
                    726:        }
                    727:        printf("%s", s);
                    728:        while (--i >= 0)
1.14      hugh      729:                if (nums[i] || (i == 0 && nums[1] == 0 && nums[2] == 0))
1.1       deraadt   730:                        printf("%d %s%c ", nums[i], sep[i],
                    731:                                nums[i] == 1 ? '\0' : 's');
                    732:        printf("\r\n!\r\n");
                    733: }
                    734:
1.24      moritz    735: /*ARGSUSED*/
1.7       deraadt   736: void
1.24      moritz    737: variable(int c)
1.1       deraadt   738: {
                    739:        char    buf[256];
                    740:
1.6       millert   741:        if (prompt("[set] ", buf, sizeof(buf)))
1.1       deraadt   742:                return;
                    743:        vlex(buf);
                    744:        if (vtable[BEAUTIFY].v_access&CHANGED) {
                    745:                vtable[BEAUTIFY].v_access &= ~CHANGED;
1.32      nicm      746:                write(tipout_fd, "B", 1);
1.1       deraadt   747:        }
                    748:        if (vtable[SCRIPT].v_access&CHANGED) {
                    749:                vtable[SCRIPT].v_access &= ~CHANGED;
                    750:                setscript();
                    751:                /*
                    752:                 * So that "set record=blah script" doesn't
                    753:                 *  cause two transactions to occur.
                    754:                 */
                    755:                if (vtable[RECORD].v_access&CHANGED)
                    756:                        vtable[RECORD].v_access &= ~CHANGED;
                    757:        }
                    758:        if (vtable[RECORD].v_access&CHANGED) {
                    759:                vtable[RECORD].v_access &= ~CHANGED;
                    760:                if (boolean(value(SCRIPT)))
                    761:                        setscript();
                    762:        }
                    763:        if (vtable[TAND].v_access&CHANGED) {
                    764:                vtable[TAND].v_access &= ~CHANGED;
                    765:                if (boolean(value(TAND)))
                    766:                        tandem("on");
                    767:                else
                    768:                        tandem("off");
                    769:        }
1.22      deraadt   770:        if (vtable[LECHO].v_access&CHANGED) {
                    771:                vtable[LECHO].v_access &= ~CHANGED;
                    772:                HD = boolean(value(LECHO));
                    773:        }
1.1       deraadt   774:        if (vtable[PARITY].v_access&CHANGED) {
                    775:                vtable[PARITY].v_access &= ~CHANGED;
1.27      moritz    776:                setparity(NULL);
1.1       deraadt   777:        }
1.17      millert   778:        if (vtable[HARDWAREFLOW].v_access&CHANGED) {
                    779:                vtable[HARDWAREFLOW].v_access &= ~CHANGED;
                    780:                if (boolean(value(HARDWAREFLOW)))
                    781:                        hardwareflow("on");
                    782:                else
                    783:                        hardwareflow("off");
                    784:        }
1.26      deraadt   785:        if (vtable[LINEDISC].v_access&CHANGED) {
                    786:                vtable[LINEDISC].v_access &= ~CHANGED;
1.27      moritz    787:                linedisc(NULL);
1.26      deraadt   788:        }
1.11      millert   789: }
                    790:
1.24      moritz    791: /*ARGSUSED*/
1.11      millert   792: void
1.24      moritz    793: listvariables(int c)
1.11      millert   794: {
                    795:        value_t *p;
                    796:        char buf[BUFSIZ];
                    797:
                    798:        puts("v\r");
                    799:        for (p = vtable; p->v_name; p++) {
                    800:                fputs(p->v_name, stdout);
                    801:                switch (p->v_type&TMASK) {
                    802:                case STRING:
                    803:                        if (p->v_value) {
                    804:                                strnvis(buf, p->v_value, sizeof(buf),
                    805:                                    VIS_WHITE|VIS_OCTAL);
                    806:                                printf(" %s", buf);
                    807:                        }
                    808:                        putchar('\r');
                    809:                        putchar('\n');
                    810:                        break;
                    811:                case NUMBER:
1.12      pvalchev  812:                        printf(" %ld\r\n", number(p->v_value));
1.11      millert   813:                        break;
                    814:                case BOOL:
                    815:                        printf(" %s\r\n",
1.17      millert   816:                            !boolean(p->v_value) ? "false" : "true");
1.11      millert   817:                        break;
                    818:                case CHAR:
                    819:                        vis(buf, character(p->v_value), VIS_WHITE|VIS_OCTAL, 0);
                    820:                        printf(" %s\r\n", buf);
                    821:                        break;
                    822:                }
1.22      deraadt   823:        }
1.1       deraadt   824: }
                    825:
                    826: /*
                    827:  * Turn tandem mode on or off for remote tty.
                    828:  */
1.24      moritz    829: static void
1.22      deraadt   830: tandem(char *option)
1.1       deraadt   831: {
1.2       deraadt   832:        struct termios  rmtty;
1.1       deraadt   833:
1.2       deraadt   834:        tcgetattr(FD, &rmtty);
                    835:        if (strcmp(option, "on") == 0) {
                    836:                rmtty.c_iflag |= IXOFF;
                    837:                term.c_iflag |= IXOFF;
1.1       deraadt   838:        } else {
1.2       deraadt   839:                rmtty.c_iflag &= ~IXOFF;
                    840:                term.c_iflag &= ~IXOFF;
1.1       deraadt   841:        }
1.2       deraadt   842:        tcsetattr(FD, TCSADRAIN, &rmtty);
                    843:        tcsetattr(0, TCSADRAIN, &term);
1.17      millert   844: }
                    845:
                    846: /*
                    847:  * Turn hardware flow control on or off for remote tty.
                    848:  */
1.24      moritz    849: static void
1.22      deraadt   850: hardwareflow(char *option)
1.17      millert   851: {
                    852:        struct termios  rmtty;
                    853:
                    854:        tcgetattr(FD, &rmtty);
                    855:        if (strcmp(option, "on") == 0)
                    856:                rmtty.c_iflag |= CRTSCTS;
                    857:        else
                    858:                rmtty.c_iflag &= ~CRTSCTS;
                    859:        tcsetattr(FD, TCSADRAIN, &rmtty);
1.26      deraadt   860: }
                    861:
                    862: /*
                    863:  * Change line discipline to the specified one.
                    864:  */
                    865: void
                    866: linedisc(char *option)
                    867: {
                    868:        int ld = (int)value(LINEDISC);
                    869:
                    870:        ioctl(FD, TIOCSETD, &ld);
1.1       deraadt   871: }
                    872:
                    873: /*
                    874:  * Send a break.
                    875:  */
1.24      moritz    876: /*ARGSUSED*/
1.7       deraadt   877: void
1.24      moritz    878: genbrk(int c)
1.1       deraadt   879: {
                    880:        ioctl(FD, TIOCSBRK, NULL);
                    881:        sleep(1);
                    882:        ioctl(FD, TIOCCBRK, NULL);
                    883: }
                    884:
                    885: /*
                    886:  * Suspend tip
                    887:  */
1.7       deraadt   888: void
1.24      moritz    889: suspend(int c)
1.1       deraadt   890: {
                    891:        unraw();
                    892:        kill(c == CTRL('y') ? getpid() : 0, SIGTSTP);
                    893:        raw();
                    894: }
                    895:
                    896: /*
                    897:  *     expand a file name if it includes shell meta characters
                    898:  */
                    899: char *
1.22      deraadt   900: expand(char name[])
1.1       deraadt   901: {
                    902:        static char xname[BUFSIZ];
                    903:        char cmdbuf[BUFSIZ];
1.15      mpech     904:        int l;
1.13      millert   905:        char *cp, *Shell;
1.7       deraadt   906:        int s, pivec[2];
1.15      mpech     907:        pid_t pid;
1.1       deraadt   908:
                    909:        if (!anyof(name, "~{[*?$`'\"\\"))
                    910:                return(name);
                    911:        /* sigint = signal(SIGINT, SIG_IGN); */
                    912:        if (pipe(pivec) < 0) {
                    913:                perror("pipe");
                    914:                /* signal(SIGINT, sigint) */
                    915:                return(name);
                    916:        }
1.5       millert   917:        (void)snprintf(cmdbuf, sizeof(cmdbuf), "echo %s", name);
1.1       deraadt   918:        if ((pid = vfork()) == 0) {
                    919:                Shell = value(SHELL);
1.27      moritz    920:                if (Shell == NULL)
1.1       deraadt   921:                        Shell = _PATH_BSHELL;
                    922:                close(pivec[0]);
                    923:                close(1);
                    924:                dup(pivec[1]);
                    925:                close(pivec[1]);
                    926:                close(2);
1.9       deraadt   927:                execl(Shell, Shell, "-c", cmdbuf, (char *)NULL);
1.1       deraadt   928:                _exit(1);
                    929:        }
                    930:        if (pid == -1) {
                    931:                perror("fork");
                    932:                close(pivec[0]);
                    933:                close(pivec[1]);
1.27      moritz    934:                return(NULL);
1.1       deraadt   935:        }
                    936:        close(pivec[1]);
                    937:        l = read(pivec[0], xname, BUFSIZ);
                    938:        close(pivec[0]);
                    939:        while (wait(&s) != pid);
                    940:                ;
                    941:        s &= 0377;
                    942:        if (s != 0 && s != SIGPIPE) {
                    943:                fprintf(stderr, "\"Echo\" failed\n");
1.27      moritz    944:                return(NULL);
1.1       deraadt   945:        }
                    946:        if (l < 0) {
                    947:                perror("read");
1.27      moritz    948:                return(NULL);
1.1       deraadt   949:        }
                    950:        if (l == 0) {
                    951:                fprintf(stderr, "\"%s\": No match\n", name);
1.27      moritz    952:                return(NULL);
1.1       deraadt   953:        }
                    954:        if (l == BUFSIZ) {
                    955:                fprintf(stderr, "Buffer overflow expanding \"%s\"\n", name);
1.27      moritz    956:                return(NULL);
1.1       deraadt   957:        }
                    958:        xname[l] = 0;
                    959:        for (cp = &xname[l-1]; *cp == '\n' && cp > xname; cp--)
                    960:                ;
                    961:        *++cp = '\0';
                    962:        return(xname);
                    963: }
                    964:
                    965: /*
                    966:  * Are any of the characters in the two strings the same?
                    967:  */
1.24      moritz    968: static int
1.22      deraadt   969: anyof(char *s1, char *s2)
1.1       deraadt   970: {
1.13      millert   971:        int c;
1.1       deraadt   972:
1.7       deraadt   973:        while ((c = *s1++))
1.1       deraadt   974:                if (any(c, s2))
                    975:                        return(1);
                    976:        return(0);
                    977: }