![[BACK]](/cvsweb/icons/back.gif){kind=icon}
Return to uux.c CVS log ![[TXT]](/cvsweb/icons/text.gif){kind=icon}
![[DIR]](/cvsweb/icons/dir.gif){kind=icon}
Up to [CSRG BSD Unix] / 43BSDTahoe / usr.bin / uucp|
Return to uux.c CVS log | Up to [CSRG BSD Unix] / 43BSDTahoe / usr.bin / uucp |
1.1 ! root 1: #ifndef lint ! 2: static char sccsid[] = "@(#)uux.c 5.13 (Berkeley) 7/22/88"; ! 3: #endif ! 4: ! 5: #include "uucp.h" ! 6: #include <sys/stat.h> ! 7: #include <sysexits.h> ! 8: ! 9: #define NOSYSPART 0 ! 10: #define HASSYSPART 1 ! 11: ! 12: #define LQUOTE '(' ! 13: #define RQUOTE ')' ! 14: ! 15: #define APPCMD(d) {\ ! 16: register char *p; for (p = d; *p != '\0';)\ ! 17: {*cmdp++ = *p++;\ ! 18: if(cmdp>(sizeof(cmd)+&cmd[0])){\ ! 19: fprintf(stderr,"argument list too long\n");\ ! 20: cleanup(EX_SOFTWARE);\ ! 21: }\ ! 22: }\ ! 23: *cmdp++ = ' '; *cmdp = '\0';} ! 24: ! 25: #define GENSEND(f, a, b, c, d, e) {\ ! 26: fprintf(f, "S %s %s %s -%s %s 0666\n", a, b, c, d, e); } ! 27: #define GENRCV(f, a, b, c) {fprintf(f, "R %s %s %s - \n", a, b, c);} ! 28: ! 29: struct timeb Now; ! 30: ! 31: main(argc, argv) ! 32: int argc; ! 33: char **argv; ! 34: { ! 35: char cfile[NAMESIZE]; /* send commands for files from here */ ! 36: char dfile[NAMESIZE]; /* used for all data files from here */ ! 37: char rxfile[NAMESIZE]; /* to be sent to xqt file (X. ...) */ ! 38: char tfile[NAMESIZE]; /* temporary file name */ ! 39: char tcfile[NAMESIZE]; /* temporary file name */ ! 40: char t2file[NAMESIZE]; /* temporary file name */ ! 41: int cflag = 0; /* commands in C. file flag */ ! 42: int rflag = 0; /* C. files for receiving flag */ ! 43: #ifdef DONTCOPY ! 44: int Copy = 0; /* Don't Copy spool files */ ! 45: #else !DONTCOPY ! 46: int Copy = 1; /* Copy spool files */ ! 47: #endif !DONTCOPY ! 48: int Linkit = 0; /* Try link before copy */ ! 49: char buf[2*BUFSIZ]; ! 50: char inargs[2*BUFSIZ]; ! 51: int pipein = 0; ! 52: int startjob = 1; ! 53: char Grade = 'A'; ! 54: long Gradedelta = 100000000L; /* "huge number" */ ! 55: long size = 0L; ! 56: char path[MAXFULLNAME]; ! 57: char cmd[2*BUFSIZ]; ! 58: char *ap, *cmdp; ! 59: char prm[2*BUFSIZ]; ! 60: char syspart[MAXBASENAME+1], rest[MAXFULLNAME]; ! 61: char Xsys[MAXBASENAME+1], local[MAXBASENAME+1]; ! 62: char *xsys = Xsys; ! 63: FILE *fprx, *fpc, *fpd, *fp; ! 64: extern char *getprm(), *lastpart(); ! 65: extern FILE *ufopen(); ! 66: int uid, ret, c; ! 67: char redir = '\0'; ! 68: int nonoti = 0; ! 69: int nonzero = 0; ! 70: int link_failed; ! 71: char *ReturnTo = NULL; ! 72: extern int LocalOnly; ! 73: extern char *optarg; ! 74: extern int optind; ! 75: ! 76: strcpy(Progname, "uux"); ! 77: uucpname(Myname); ! 78: umask(WFMASK); ! 79: Ofn = 1; ! 80: Ifn = 0; ! 81: #ifdef VMS ! 82: arg_fix(argc, argv); ! 83: #endif ! 84: while ((c = getopt(argc, argv, "-prclCg:x:nzLa:")) != EOF) ! 85: switch (c) { ! 86: case '-': ! 87: /* FALLTHROUGH */ ! 88: case 'p': ! 89: pipein = 1; ! 90: break; ! 91: case 'r': ! 92: startjob = 0; ! 93: break; ! 94: case 'c': ! 95: Copy = 0; ! 96: Linkit = 0; ! 97: break; ! 98: case 'l': ! 99: Copy = 0; ! 100: Linkit = 1; ! 101: break; ! 102: case 'C': ! 103: Copy = 1; ! 104: Linkit = 0; ! 105: break; ! 106: case 'g': ! 107: Grade = *optarg; ! 108: Gradedelta = atol(optarg+1); ! 109: break; ! 110: case 'x': ! 111: chkdebug(); ! 112: Debug = atoi(optarg); ! 113: if (Debug <= 0) ! 114: Debug = 1; ! 115: break; ! 116: case 'n': ! 117: nonoti = 1; ! 118: break; ! 119: case 'z': ! 120: nonzero = 1; ! 121: break; ! 122: case 'L': ! 123: LocalOnly++; ! 124: break; ! 125: case 'a': ! 126: ReturnTo = optarg; ! 127: if (prefix(Myname, ReturnTo) && ReturnTo[strlen(Myname)] == '!') ! 128: ReturnTo = index(ReturnTo, '!') + 1; ! 129: break; ! 130: case '?': ! 131: default: ! 132: break; ! 133: } ! 134: ! 135: ap = getwd(Wrkdir); ! 136: if (ap == 0) { ! 137: fprintf(stderr, "can't get working directory; will try to continue\n"); ! 138: strcpy(Wrkdir, "/UNKNOWN"); ! 139: } ! 140: ! 141: DEBUG(4, "\n\n** %s **\n", "START"); ! 142: ! 143: inargs[0] = '\0'; ! 144: while (optind < argc) { ! 145: DEBUG(4, "arg - %s:", argv[optind]); ! 146: strcat(inargs, " "); ! 147: strcat(inargs, argv[optind++]); ! 148: } ! 149: DEBUG(4, "arg - %s\n", inargs); ! 150: if (subchdir(Spool) < 0) { ! 151: syslog(LOG_WARNING, "chdir(%s) failed: %m", Spool); ! 152: cleanup(1); ! 153: } ! 154: uid = getuid(); ! 155: if (guinfo(uid, User, path) != SUCCESS) { ! 156: syslog(LOG_WARNING, "Can't find username for uid %d", uid); ! 157: DEBUG(1, "Using username", "uucp"); ! 158: strcpy(User, "uucp"); ! 159: } ! 160: ! 161: strncpy(local, Myname, MAXBASENAME); ! 162: cmdp = cmd; ! 163: *cmdp = '\0'; ! 164: gename(DATAPRE, local, 'X', rxfile); ! 165: fprx = ufopen(rxfile, "w"); ! 166: if (fprx == NULL) { ! 167: syslog(LOG_WARNING, "fopen(%s) failed: %m", rxfile); ! 168: cleanup(1); ! 169: } ! 170: gename(DATAPRE, local, 'T', tcfile); ! 171: fpc = ufopen(tcfile, "w"); ! 172: if (fpc == NULL) { ! 173: syslog(LOG_WARNING, "fopen(%s) failed: %m", tcfile); ! 174: cleanup(1); ! 175: } ! 176: fprintf(fprx, "%c %s %s\n", X_USER, User, local); ! 177: if (nonoti) ! 178: fprintf(fprx, "%c\n", X_NONOTI); ! 179: if (nonzero) ! 180: fprintf(fprx, "%c\n", X_NONZERO); ! 181: if (ReturnTo == NULL || *ReturnTo == '\0') ! 182: ReturnTo = User; ! 183: fprintf(fprx, "%c %s\n", X_RETURNTO, ReturnTo); ! 184: ! 185: /* find remote system name */ ! 186: ap = inargs; ! 187: xsys[0] = '\0'; ! 188: while ((ap = getprm(ap, prm)) != NULL) { ! 189: if (prm[0] == '>' || prm[0] == '<') { ! 190: ap = getprm(ap, prm); ! 191: continue; ! 192: } ! 193: ! 194: split(prm, xsys, rest); ! 195: break; ! 196: } ! 197: if (xsys[0] == '\0') ! 198: strcpy(xsys, local); ! 199: if (versys(&xsys) != 0) { ! 200: /* bad system name */ ! 201: fprintf(stderr, "bad system name: %s\n", xsys); ! 202: fclose(fprx); ! 203: fclose(fpc); ! 204: cleanup(EX_NOHOST); ! 205: } ! 206: ! 207: strncpy(Rmtname, xsys, MAXBASENAME); ! 208: DEBUG(4, "xsys %s\n", xsys); ! 209: ! 210: if (pipein) { ! 211: gename(DATAPRE, local, 'B', dfile); ! 212: fpd = ufopen(dfile, "w"); ! 213: if (fpd == NULL) { ! 214: syslog(LOG_WARNING, "fopen(%s) failed: %m", dfile); ! 215: cleanup(1); ! 216: } ! 217: while (!feof(stdin)) { ! 218: ret = fread(buf, 1, BUFSIZ, stdin); ! 219: fwrite(buf, 1, ret, fpd); ! 220: if (ferror(stdin)) { ! 221: perror("stdin"); ! 222: cleanup(EX_IOERR); ! 223: } ! 224: if (ferror(fpd)) { ! 225: perror(dfile); ! 226: cleanup(EX_IOERR); ! 227: } ! 228: size += ret; ! 229: } ! 230: fclose(fpd); ! 231: strcpy(tfile, dfile); ! 232: if (strcmp(local, xsys) != SAME) { ! 233: register int Len = strlen(local); ! 234: if (Len > SYSNSIZE) ! 235: Len = SYSNSIZE; ! 236: tfile[Len + 2] = 'S'; ! 237: GENSEND(fpc, dfile, tfile, User, "", dfile); ! 238: cflag++; ! 239: } ! 240: fprintf(fprx, "%c %s\n", X_RQDFILE, tfile); ! 241: fprintf(fprx, "%c %s\n", X_STDIN, tfile); ! 242: } ! 243: /* parse command */ ! 244: ap = inargs; ! 245: while ((ap = getprm(ap, prm)) != NULL) { ! 246: DEBUG(4, "prm - %s\n", prm); ! 247: if (prm[0] == '>' || prm[0] == '<') { ! 248: redir = prm[0]; ! 249: continue; ! 250: } ! 251: ! 252: if (prm[0] == ';') { ! 253: APPCMD(prm); ! 254: continue; ! 255: } ! 256: ! 257: if (prm[0] == '|' || prm[0] == '^') { ! 258: if (cmdp != cmd) ! 259: APPCMD(prm); ! 260: continue; ! 261: } ! 262: ! 263: /* process command or file or option */ ! 264: ret = split(prm, syspart, rest); ! 265: DEBUG(4, "s - %s, ", syspart); ! 266: DEBUG(4, "r - %s, ", rest); ! 267: DEBUG(4, "ret - %d\n", ret); ! 268: if (syspart[0] == '\0') ! 269: strcpy(syspart, local); ! 270: ! 271: if (cmdp == cmd && redir == '\0') { ! 272: /* command */ ! 273: APPCMD(rest); ! 274: continue; ! 275: } ! 276: ! 277: /* process file or option */ ! 278: DEBUG(4, "file s- %s, ", syspart); ! 279: DEBUG(4, "local - %s\n", local); ! 280: /* process file */ ! 281: if (redir == '>') { ! 282: if (rest[0] != '~') ! 283: if (ckexpf(rest)) ! 284: cleanup(EX_CANTCREAT); ! 285: fprintf(fprx, "%c %s %s\n", X_STDOUT, rest, ! 286: syspart); ! 287: redir = '\0'; ! 288: continue; ! 289: } ! 290: ! 291: if (ret == NOSYSPART && redir == '\0') { ! 292: /* option */ ! 293: APPCMD(rest); ! 294: continue; ! 295: } ! 296: ! 297: if (rest[0] != '\0') { ! 298: struct stat stbuf; ! 299: if (stat(rest, &stbuf) < 0) ! 300: DEBUG(4, "Can't stat %s\n", rest); ! 301: else ! 302: size += stbuf.st_size; ! 303: DEBUG(4, "size = %ld\n", size); ! 304: } ! 305: ! 306: if (strcmp(xsys, local) == SAME ! 307: && strcmp(xsys, syspart) == SAME) { ! 308: if (ckexpf(rest)) ! 309: cleanup(EX_CANTCREAT); ! 310: if (redir == '<') ! 311: fprintf(fprx, "%c %s\n", X_STDIN, rest); ! 312: else ! 313: APPCMD(rest); ! 314: redir = '\0'; ! 315: continue; ! 316: } ! 317: ! 318: if (strcmp(syspart, local) == SAME) { ! 319: /* generate send file */ ! 320: if (ckexpf(rest)) ! 321: cleanup(EX_CANTCREAT); ! 322: gename(DATAPRE, local, 'A', dfile); ! 323: DEBUG(4, "rest %s\n", rest); ! 324: if ((chkpth(User, "", rest) || anyread(rest)) != 0) { ! 325: fprintf(stderr, "permission denied %s\n", rest); ! 326: cleanup(EX_NOINPUT); ! 327: } ! 328: link_failed = 0; ! 329: if (Linkit) { ! 330: if (link(subfile(rest), subfile(dfile)) != 0) ! 331: link_failed++; ! 332: else ! 333: GENSEND(fpc, rest, dfile, User, "", dfile); ! 334: } ! 335: if (Copy || link_failed) { ! 336: if (xcp(rest, dfile) != 0) { ! 337: fprintf(stderr, "can't copy %s to %s\n", rest, dfile); ! 338: cleanup(EX_NOINPUT); ! 339: } ! 340: GENSEND(fpc, rest, dfile, User, "", dfile); ! 341: } ! 342: if (!Copy && !Linkit) { ! 343: GENSEND(fpc, rest, dfile, User, "c", "D.0"); ! 344: } ! 345: cflag++; ! 346: if (redir == '<') { ! 347: fprintf(fprx, "%c %s\n", X_STDIN, dfile); ! 348: fprintf(fprx, "%c %s\n", X_RQDFILE, dfile); ! 349: } else { ! 350: APPCMD(lastpart(rest)); ! 351: fprintf(fprx, "%c %s %s\n", X_RQDFILE, ! 352: dfile, lastpart(rest)); ! 353: } ! 354: redir = '\0'; ! 355: continue; ! 356: } ! 357: ! 358: if (strcmp(local, xsys) == SAME) { ! 359: /* generate local receive */ ! 360: gename(CMDPRE, syspart, 'R', tfile); ! 361: strcpy(dfile, tfile); ! 362: dfile[0] = DATAPRE; ! 363: fp = ufopen(tfile, "w"); ! 364: if (fp == NULL) { ! 365: syslog(LOG_WARNING, "fopen(%s) failed: %m", ! 366: tfile); ! 367: cleanup(1); ! 368: } ! 369: if (ckexpf(rest)) ! 370: cleanup(EX_CANTCREAT); ! 371: GENRCV(fp, rest, dfile, User); ! 372: fclose(fp); ! 373: rflag++; ! 374: if (rest[0] != '~') ! 375: if (ckexpf(rest)) ! 376: cleanup(EX_CANTCREAT); ! 377: if (redir == '<') { ! 378: fprintf(fprx, "%c %s\n", X_RQDFILE, dfile); ! 379: fprintf(fprx, "%c %s\n", X_STDIN, dfile); ! 380: } else { ! 381: fprintf(fprx, "%c %s %s\n", X_RQDFILE, dfile, ! 382: lastpart(rest)); ! 383: APPCMD(lastpart(rest)); ! 384: } ! 385: ! 386: redir = '\0'; ! 387: continue; ! 388: } ! 389: ! 390: if (strcmp(syspart, xsys) != SAME) { ! 391: /* generate remote receives */ ! 392: gename(DATAPRE, syspart, 'R', dfile); ! 393: strcpy(tfile, dfile); ! 394: tfile[0] = CMDPRE; ! 395: fpd = ufopen(dfile, "w"); ! 396: if (fpd == NULL) { ! 397: syslog(LOG_WARNING, "fopen(%s) failed: %m", ! 398: dfile); ! 399: cleanup(1); ! 400: } ! 401: gename(DATAPRE, local, 'T', t2file); ! 402: GENRCV(fpd, rest, t2file, User); ! 403: fclose(fpd); ! 404: GENSEND(fpc, dfile, tfile, User, "", dfile); ! 405: cflag++; ! 406: if (redir == '<') { ! 407: fprintf(fprx, "%c %s\n", X_RQDFILE, t2file); ! 408: fprintf(fprx, "%c %s\n", X_STDIN, t2file); ! 409: } else { ! 410: fprintf(fprx, "%c %s %s\n", X_RQDFILE, t2file, ! 411: lastpart(rest)); ! 412: APPCMD(lastpart(rest)); ! 413: } ! 414: redir = '\0'; ! 415: continue; ! 416: } ! 417: ! 418: /* file on remote system */ ! 419: if (rest[0] != '~') ! 420: if (ckexpf(rest)) ! 421: cleanup(EX_CANTCREAT); ! 422: if (redir == '<') ! 423: fprintf(fprx, "%c %s\n", X_STDIN, rest); ! 424: else ! 425: APPCMD(rest); ! 426: redir = '\0'; ! 427: continue; ! 428: ! 429: } ! 430: /* ! 431: * clean up trailing ' ' in command. ! 432: */ ! 433: if (cmdp > cmd && cmdp[0] == '\0' && cmdp[-1] == ' ') ! 434: *--cmdp = '\0'; ! 435: /* block multi-hop uux, which doesn't work */ ! 436: for (ap = cmd; *ap && *ap != ' '; ap++) ! 437: if (*ap == '!') { ! 438: fprintf(stderr, "uux handles only adjacent sites.\n"); ! 439: fprintf(stderr, "Try uusend for multi-hop delivery.\n"); ! 440: cleanup(EX_USAGE); ! 441: } ! 442: ! 443: fprintf(fprx, "%c %s\n", X_CMD, cmd); ! 444: if (ferror(fprx)) { ! 445: logent(cmd, "COULD NOT QUEUE XQT"); ! 446: cleanup(EX_IOERR); ! 447: } else ! 448: logent(cmd, "XQT QUE'D"); ! 449: fclose(fprx); ! 450: ! 451: if (size > 0 && Gradedelta > 0) { ! 452: DEBUG (4, "Grade changed from %c ", Grade); ! 453: Grade += size/Gradedelta; ! 454: if (Grade > 'z') ! 455: Grade = 'z'; ! 456: DEBUG(4, "to %c\n", Grade); ! 457: } ! 458: gename(XQTPRE, local, Grade, tfile); ! 459: if (strcmp(xsys, local) == SAME) { ! 460: /* rti!trt: xmv() works across filesystems, link(II) doesnt */ ! 461: xmv(rxfile, tfile); ! 462: if (startjob) ! 463: if (rflag) ! 464: xuucico(xsys); ! 465: else ! 466: xuuxqt(); ! 467: } ! 468: else { ! 469: GENSEND(fpc, rxfile, tfile, User, "", rxfile); ! 470: cflag++; ! 471: } ! 472: ! 473: if (ferror(fpc)) ! 474: cleanup(EX_IOERR); ! 475: fclose(fpc); ! 476: if (cflag) { ! 477: gename(CMDPRE, xsys, Grade, cfile); ! 478: /* rti!trt: use xmv() rather than link(II) */ ! 479: xmv(tcfile, cfile); ! 480: if (startjob) ! 481: xuucico(xsys); ! 482: cleanup(0); ! 483: } ! 484: else ! 485: unlink(subfile(tcfile)); ! 486: exit(0); ! 487: } ! 488: ! 489: #define FTABSIZE 30 ! 490: char Fname[FTABSIZE][NAMESIZE]; ! 491: int Fnamect = 0; ! 492: ! 493: /* ! 494: * cleanup and unlink if error ! 495: * ! 496: * return - none - do exit() ! 497: */ ! 498: ! 499: cleanup(code) ! 500: int code; ! 501: { ! 502: int i; ! 503: ! 504: logcls(); ! 505: rmlock(CNULL); ! 506: if (code) { ! 507: for (i = 0; i < Fnamect; i++) ! 508: unlink(subfile(Fname[i])); ! 509: fprintf(stderr, "uux failed. code %d\n", code); ! 510: } ! 511: DEBUG(1, "exit code %d\n", code); ! 512: exit(code); ! 513: } ! 514: ! 515: /* ! 516: * open file and record name ! 517: * ! 518: * return file pointer. ! 519: */ ! 520: ! 521: FILE *ufopen(file, mode) ! 522: char *file, *mode; ! 523: { ! 524: if (Fnamect < FTABSIZE) ! 525: strcpy(Fname[Fnamect++], file); ! 526: else ! 527: logent("Fname", "TABLE OVERFLOW"); ! 528: return fopen(subfile(file), mode); ! 529: } ! 530: #ifdef VMS ! 531: /* ! 532: * EUNICE bug: ! 533: * quotes are not stripped from DCL. Do it here. ! 534: * Note if we are running under Unix shell we don't ! 535: * do the right thing. ! 536: */ ! 537: arg_fix(argc, argv) ! 538: char **argv; ! 539: { ! 540: register char *cp, *tp; ! 541: ! 542: for (; argc > 0; --argc, argv++) { ! 543: cp = *argv; ! 544: if (cp == (char *)0 || *cp++ != '"') ! 545: continue; ! 546: tp = cp; ! 547: while (*tp++) ; ! 548: tp -= 2; ! 549: if (*tp == '"') { ! 550: *tp = '\0'; ! 551: *argv = cp; ! 552: } ! 553: } ! 554: } ! 555: #endif VMS ! 556: ! 557: /* ! 558: * split into system and file part ! 559: * ! 560: * return codes: ! 561: * NOSYSPART ! 562: * HASSYSPART ! 563: */ ! 564: ! 565: split(name, sys, rest) ! 566: register char *name, *rest; ! 567: char *sys; ! 568: { ! 569: register char *c; ! 570: ! 571: if (*name == LQUOTE) { ! 572: if ((c = index(name + 1, RQUOTE)) != NULL) { ! 573: /* strip off quotes */ ! 574: name++; ! 575: while (c != name) ! 576: *rest++ = *name++; ! 577: *rest = '\0'; ! 578: *sys = '\0'; ! 579: return NOSYSPART; ! 580: } ! 581: } ! 582: ! 583: if ((c = index(name, '!')) == NULL) { ! 584: strcpy(rest, name); ! 585: *sys = '\0'; ! 586: return NOSYSPART; ! 587: } ! 588: ! 589: *c++ = '\0'; ! 590: strncpy(sys, name, MAXBASENAME); ! 591: sys[MAXBASENAME] = '\0'; ! 592: ! 593: strcpy(rest, c); ! 594: return HASSYSPART; ! 595: }
This archive runs on limited infrastructure. Preserving old code on modern bandwidth. Automated agents are requested to crawl responsibly.