![[BACK]](/cvsweb/icons/back.gif){kind=icon}
Return to bscd.c CVS log ![[TXT]](/cvsweb/icons/text.gif){kind=icon}
![[DIR]](/cvsweb/icons/dir.gif){kind=icon}
Up to [Power 6/32 Unix Tahoe 4.2BSD] / cci / usr / src / usr.bin / bsc / cmd / batch|
Return to bscd.c CVS log | Up to [Power 6/32 Unix Tahoe 4.2BSD] / cci / usr / src / usr.bin / bsc / cmd / batch |
1.1 ! root 1: /* D.L.Buck and Associates, Inc. - %H% ! 2: * ! 3: * COPYRIGHT NOTICE: ! 4: * Copyright c %H% - An unpublished work by ! 5: * D.L.Buck and Associates, Inc. ! 6: * ! 7: * PROPRIETARY RIGHTS NOTICE: ! 8: * All rights reserved. This document and program contains ! 9: * proprietary information of D.L.Buck and Associates,Inc. ! 10: * of San Jose, California, U.S.A., embodying confidential ! 11: * information, ideas, and expressions, no part of which ! 12: * may be reproduced, or transmitted in any form or by any ! 13: * means, electronic, mechanical, or otherwise, without ! 14: * the written permission of D.L.Buck and Associates, Inc. ! 15: * NAME ! 16: * bscd - BISYNC communications daemon ! 17: * ! 18: * SYNOPSIS ! 19: * bscd ! 20: * ! 21: * DESCRIPTION ! 22: * bscd submits files queued by bscbatch to the BISYNC driver (bsc), ! 23: * which sends them to a specified remote host via 3780 or 2780 ! 24: * protocol over telephone lines. It is started by an entry in ! 25: * /usr/lib/crontab. ! 26: * ! 27: * ALGORITHM ! 28: * 0. try to create the bsclock file ! 29: * a. if already there, another bscd is running; exit ! 30: * 1. search all host queues for work ! 31: * 2. for each host having file(s) queued to send: ! 32: * a. call installation exit "connect" ! 33: * b. open bsc device ! 34: * c. set bsc device parameters via ioctl call ! 35: * d. while there's another queue control file: ! 36: * i. open control file ! 37: * ii. get control parameters ! 38: * iii. set bsc device parameters as directed by ! 39: * control file via ioctl call ! 40: * iv. close control file ! 41: * v. open actual file to be sent ! 42: * vi. while not eof: ! 43: * format a block ! 44: * submit it to the bsc driver via write ! 45: * if an error is encountered: ! 46: * close file (host is probably trying ! 47: * to send to you) ! 48: * goto 'e.' ! 49: * ! 50: * vii. close file ! 51: * viii. call installation exit "notefile" if requested by ! 52: * control file mail flag ! 53: * ix. remove control file if send successful ! 54: * e. try to receive files: ! 55: * i. while not eof: ! 56: * read a block from bsc device ! 57: * unformat the block ! 58: * write it either to a PR or PU file somehow ! 59: * ii. call installation exit "asgnfile" ! 60: * iii. repeat from 'i.' until read times out ! 61: * f. if another queue control file appeared, go back to step 'd' ! 62: * g. close device ! 63: * h. call installation exit "disconnect" ! 64: * i. unlink bsc lock file ! 65: * ! 66: * make note in the AUDIT file of host spool directory of each action ! 67: * as processing occurs ! 68: */ ! 69: ! 70: #include <stdio.h> ! 71: #include <sys/types.h> ! 72: #include <sys/dir.h> ! 73: #include <sys/ioctl.h> ! 74: #include <sys/stat.h> ! 75: #include <signal.h> ! 76: #include <errno.h> ! 77: #include "local.h" ! 78: #include <bsc/bscio.h> ! 79: #if defined BSD42 ! 80: #include <sys/time.h> ! 81: #else ! 82: #include <time.h> ! 83: #endif ! 84: ! 85: #define libpath "/usr/lib/bscbatch/" ! 86: #define spoolpath "/usr/spool/bscbatch/" ! 87: #define YES 1 ! 88: #define NO 0 ! 89: #define OK 2 ! 90: #define GS 0x1d /* group separator */ ! 91: ! 92: #ifndef lint ! 93: static char sccsid[] = "%W% %Q%"; ! 94: #endif ! 95: extern int errno; /* system error numbers get put in here */ ! 96: extern char *sys_errlist[]; /* Explanatory strings for error numbers */ ! 97: ! 98: char hostname[20]; /* contains host name */ ! 99: char audname[80]; /* temp audit pathname goes here */ ! 100: char auditlock[80]; /* audit lockfile pathname goes here */ ! 101: char new_audnm[80]; /* real audit name goes here */ ! 102: char spool[50]; /* contains host spool directory path */ ! 103: char hostid[20]; /* host id to check for */ ! 104: char signon[50]; /* host signon file */ ! 105: char signoff[50]; /* host signoff file */ ! 106: char lockfile[50]; /* bsc lock file name */ ! 107: char emsg[40]; /* contains error message for AUDIT */ ! 108: char delfile[50]; /* file to delete when through transmitting */ ! 109: char user[20]; /* user name */ ! 110: char sys_admin[20] = "/dev/console"; /* system administrator name ! 111: for problem mail */ ! 112: char df_string[40]; /* minspace check command */ ! 113: char sendfile[50]; /* full name of file to send */ ! 114: char note[100]; /* mail to system administrator goes in here */ ! 115: char dname[15]; /* contains name of device to check if ! 116: MINSPACE parameter set */ ! 117: ! 118: char *strcpy(); /* function copies one string to another */ ! 119: char *strcat(); /* function appends one string to another */ ! 120: char *index(); /* function looks for one string in another */ ! 121: ! 122: int chk_hostid; ! 123: int chk_termid; ! 124: int blksize; ! 125: int primary = BSCPRIM; ! 126: int recsize; ! 127: int recblk; ! 128: int recsep; ! 129: int rviab; ! 130: int ius; /* unit separator for 2780 used? */ ! 131: int pt_to_pt; ! 132: int son_file; /* is there a signon file to send? */ ! 133: int soff_file; /* is there a signoff file to send? */ ! 134: int mail = NO; /* send mail no matter what? */ ! 135: int trnsp = NO; /* force a file to be sent transparent? */ ! 136: int transp_ok = YES; /* transparent transmission ok for this host? */ ! 137: int blocks; /* tracks number of blocks written to bsc device */ ! 138: int ascii; /* ascii or ebcdic data? */ ! 139: int compress = YES; /* compress data ? */ ! 140: int devfd; /* bsc device file descriptor */ ! 141: int total_bl = 0; /* total blocks sent or received */ ! 142: int ctr = 0; /* used to supply unique names to received files */ ! 143: int set_trnsp = NO; /* have any of sendfile's blocks been sent in ! 144: transparent mode, if this is a normal file? */ ! 145: ! 146: int sigint(); /* signal interrupt routine */ ! 147: long maxfsize = 0; /* max size a receive file can be before it must ! 148: be truncated */ ! 149: long minspace = 0; /* minimum space required to receive files from a ! 150: host */ ! 151: long atol(); /* converts ascii to long */ ! 152: char devname[20]; ! 153: char ctlfile[50]; /* queue control file name */ ! 154: ! 155: FILE *fopen(); /* function opens files */ ! 156: FILE *popen(); /* initiate I/O to form a process */ ! 157: FILE *aud; /* host AUDIT file pointer */ ! 158: ! 159: struct tm *localtime(); /* function returns current time */ ! 160: struct tm *t; /* localtime returns time into here */ ! 161: ! 162: struct bscio c_params; /* current bsc driver parameters */ ! 163: struct bscio s_params; /* parameters bsc driver was set with */ ! 164: long time(); ! 165: long currtime; ! 166: void exit(); ! 167: #if defined BSD42 ! 168: DIR *libfd; /* Host Configuration directory fd */ ! 169: DIR *spoolfd; /* Spool directory fd */ ! 170: #else ! 171: int libfd; /* host config directory file descriptor */ ! 172: int spoolfd; /* spool directory file descriptor */ ! 173: #endif ! 174: ! 175: main() ! 176: { ! 177: int more = YES; ! 178: int contention = NO; /*contention error encountered? */ ! 179: int err; /* get_err or connect error code */ ! 180: int almost_done; /* are we almost done communicating with ! 181: this host? */ ! 182: ! 183: long lseek(); ! 184: #if defined BSD42 ! 185: struct direct *dir; /* points to libpath directory entry */ ! 186: struct direct *hdir; /* points to spoolpath directory entry */ ! 187: #else ! 188: struct direct dir; /* libpath directory entry */ ! 189: struct direct hdir; /* spoolpath directory entry */ ! 190: #endif ! 191: struct stat s; /* points to file status structure */ ! 192: ! 193: char cfg_name[50]; /* contains host configuration file name */ ! 194: char line[100]; /* line of file to be sent read in here */ ! 195: int lockfd; /* bsc lock file file descriptor */ ! 196: ! 197: FILE *pptr; /* stream ptr to be used with popen */ ! 198: ! 199: /* catch signals -- if bscd spawned as background process, ! 200: allow kill -15 (SIGTERM) to nicely make it go away. */ ! 201: if (isatty(0)) ! 202: signal(SIGINT,sigint); ! 203: else ! 204: signal(SIGTERM,sigint); ! 205: ! 206: /* 1. search all host queues for work */ ! 207: #if defined BSD42 ! 208: if ((libfd = opendir(libpath)) == NULL) { ! 209: #else ! 210: if ((libfd = open(libpath,0)) == -1) { ! 211: #endif ! 212: fprintf(stderr, ! 213: "bscd: can't open <%s> configuration directory\n", ! 214: libpath); ! 215: exit(1); ! 216: } ! 217: ! 218: #if defined BSD42 ! 219: while ((dir = readdir(libfd)) != NULL) { ! 220: if (dir->d_name[0] == '.') ! 221: continue; ! 222: strcpy(hostname,dir->d_name); ! 223: #else ! 224: while (read(libfd,&dir,sizeof dir) == sizeof dir) { ! 225: if (dir.d_name[0] == '.' || dir.d_ino == 0) ! 226: continue; ! 227: strcpy(hostname,dir.d_name); ! 228: #endif ! 229: sprintf(spool,"%s%s",spoolpath,hostname); ! 230: ! 231: /* try to access spool directory; if not there, continue */ ! 232: #if defined BSD42 ! 233: if ((spoolfd = opendir(spool)) == NULL) { ! 234: #else ! 235: if ((spoolfd = open(spool,0)) == -1) { ! 236: #endif ! 237: sprintf(note, ! 238: "bscd <%s>: directory <%s> not readable", ! 239: hostname,spool); ! 240: fputs(note,stderr); ! 241: /* send mail about the problem */ ! 242: post(); ! 243: continue; ! 244: } ! 245: ! 246: /* try to access the lock file -- if okay, another bscd is running; ! 247: abort. */ ! 248: sprintf(lockfile,"%s/%s",spool,"bsclock"); ! 249: if (access(lockfile,0) == 0) { ! 250: fprintf(stderr, ! 251: "bscd <%s>: another bscd process is currently running\n", ! 252: hostname); ! 253: lockfile[0] = '\0'; ! 254: continue; ! 255: } ! 256: /* Create the lock file */ ! 257: if ( (lockfd = creat(lockfile,0)) < 0) { ! 258: fprintf(stderr, ! 259: "bscd <%s>: can't create %s\n",hostname,lockfile); ! 260: exit(1); ! 261: } else ! 262: close(lockfd); ! 263: /* open the host directory and search for work */ ! 264: if (searchq(spoolfd) == NO) { ! 265: quithost(); ! 266: continue; ! 267: } ! 268: ! 269: /* get host configuration parameters */ ! 270: sprintf(cfg_name,"%s%s",libpath,hostname); ! 271: get_cnfg(cfg_name); ! 272: ! 273: /* construct AUDIT pathname, open AUDIT file */ ! 274: open_audit(); ! 275: ! 276: /* write "ready for connect" msg to AUDIT */ ! 277: sprintf (note,"Ready for connect via <%s>", ! 278: devname); ! 279: write_aud("C",note); ! 280: ! 281: /* call connect installation exit */ ! 282: if (err = connect (hostname, devname)) { ! 283: /* skip this host if there were problems */ ! 284: sprintf(note, "Connection failed, <%s>",emsg); ! 285: write_aud("C",note); ! 286: ! 287: /* send mail about it */ ! 288: post(); ! 289: quithost(); ! 290: continue; ! 291: } ! 292: ! 293: /* open bsc device */ ! 294: if ((devfd = open(devname,2)) == -1) { ! 295: if (errno == EBUSY) { ! 296: fprintf(stderr, ! 297: "bscd <%s>: <%s> being used.\n", ! 298: hostname, devname); ! 299: sprintf(note, ! 300: "Open failed, device <%s> busy.", devname); ! 301: write_aud("C", note); ! 302: ! 303: /* send mail about problem */ ! 304: post(); ! 305: quithost(); ! 306: goto Disconnect; ! 307: } ! 308: ! 309: sprintf(note, ! 310: "Connection failed, %s cannot be opened: %s", ! 311: devname,sys_errlist[errno]); ! 312: ! 313: fprintf(stderr, "bscd <%s>: %s\n", hostname, note); ! 314: ! 315: /* update AUDIT file with the news */ ! 316: write_aud("C",note); ! 317: ! 318: /* send mail about problem */ ! 319: post(); ! 320: quithost(); ! 321: goto Disconnect; ! 322: } ! 323: ! 324: /* write "connected" message to AUDIT file */ ! 325: strcpy(note,"Connected"); ! 326: if (chk_hostid) ! 327: sprintf(note,"%s - host id is %s",note,hostid); ! 328: ! 329: write_aud("C",note); ! 330: ! 331: /* set device parameters */ ! 332: ioctl(devfd,BSCSET,&s_params); ! 333: ! 334: /* if a signon file was specified, send it via send_son ! 335: (send_son.c) */ ! 336: if (son_file) { ! 337: if ((more = send_son(signon)) == NO) { ! 338: sprintf(note,"Disconnected, <%s>", ! 339: emsg); ! 340: write_aud("D",note); ! 341: goto Disconnect; ! 342: } ! 343: /* if there's a contention problem, abort sending */ ! 344: if (c_params.b_flags == BSCONTND) { ! 345: contention = YES; ! 346: goto Receive_Files; ! 347: } ! 348: ! 349: sprintf(note, ! 350: "Transmission of SIGNON file <%s> completed (%d blocks)", ! 351: signon,blocks); ! 352: write_aud("T",note); ! 353: total_bl += blocks; ! 354: blocks = 0; ! 355: } ! 356: ! 357: almost_done = NO; ! 358: Send_Files: /* get another queue control file while there is one */ ! 359: #if defined BSD42 ! 360: rewinddir(spoolfd); ! 361: while ((hdir = readdir(spoolfd)) != NULL) { ! 362: if (hdir->d_name[0] != 'C') ! 363: continue; ! 364: sprintf(ctlfile,"%s/%s",spool,hdir->d_name); ! 365: #else ! 366: lseek(spoolfd,0L,0); ! 367: while (read(spoolfd,&hdir,sizeof hdir) == sizeof hdir) { ! 368: if (hdir.d_ino == 0 || hdir.d_name[0] != 'C') ! 369: continue; ! 370: sprintf(ctlfile,"%s/%s",spool,hdir.d_name); ! 371: #endif ! 372: ! 373: /* get queue control parameters */ ! 374: if (get_params()) /* error */ ! 375: continue; ! 376: ! 377: /* if no sendfile, look for control file w/sendfile */ ! 378: if (!sendfile[0]) ! 379: continue; ! 380: ! 381: /* found something to send; just in case we were sent back ! 382: here after getting a receive timeout from the host and ! 383: almost_done is YES, we shall set almost_done back to NO. */ ! 384: almost_done = NO; ! 385: ! 386: /* set secondary ioctl parameters */ ! 387: if (trnsp) ! 388: ioctl(devfd,BSCTRNSP,0); ! 389: ! 390: /* send file */ ! 391: if (sendf(sendfile) == -1) { ! 392: /* get_errors determines error msg */ ! 393: more = get_errors(); ! 394: ! 395: if (!transp_ok && trnsp) { ! 396: sprintf(emsg, ! 397: "Attempt to send transparent to non-transparent host <%s>", ! 398: hostname); ! 399: more = NO; ! 400: } ! 401: ! 402: sprintf(note, ! 403: "bscd <%s> :Transmission of <%s> aborted, <%s>", ! 404: hostname,sendfile,emsg); ! 405: write_aud("S",note); ! 406: ! 407: /* if we got an rvi abort, remove queue control file ! 408: (and delfile, if any), and go down to receive */ ! 409: if (c_params.b_flags == BSCRVI) { ! 410: unlink(ctlfile); ! 411: if (delfile) ! 412: unlink(delfile); ! 413: contention = YES; ! 414: goto Receive_Files; ! 415: } ! 416: ! 417: /* if there's a contention problem, abort sending */ ! 418: if (c_params.b_flags == BSCONTND) { ! 419: contention = YES; ! 420: goto Receive_Files; ! 421: } ! 422: ! 423: /* send mail about problem */ ! 424: post(); ! 425: ! 426: if (more == NO) { ! 427: sprintf(note,"Disconnected, <%s>", ! 428: emsg); ! 429: write_aud("D",note); ! 430: goto Disconnect; ! 431: } else ! 432: continue; ! 433: } ! 434: ! 435: /* if send successful and q_ctl mail flag set, ! 436: call installation exit notefile */ ! 437: sprintf(note,"bscd: File <%s> sent successfully",sendfile); ! 438: notefile(user,sendfile,note); ! 439: ! 440: /* unlink q_ctl and delfile */ ! 441: unlink(ctlfile); ! 442: if (delfile) ! 443: unlink(delfile); ! 444: ! 445: /* tell the AUDIT file this file's all done */ ! 446: sprintf(note,set_trnsp? ! 447: "Transmission of <%s> completed (transparent,%d blocks)": ! 448: "Transmission of <%s> completed (%d blocks)", ! 449: sendfile,blocks); ! 450: ! 451: write_aud("S",note); ! 452: ! 453: total_bl += blocks; ! 454: blocks = 0; ! 455: set_trnsp = NO; ! 456: } /* End of while read hdir (host spool directory) */ ! 457: ! 458: /* if this isn't the first time we've been to Send_Files, ! 459: we got a receive timeout the last time we were in Receive_Files, ! 460: and there was nothing else to send, then almost_done will ! 461: be set. That means it's time to disconnect; write disconnect message ! 462: and goto Disconnect. */ ! 463: if (almost_done == 1) { ! 464: sprintf(note,"Disconnected, <Receive idle timeout>"); ! 465: write_aud("D",note); ! 466: goto Send_Signoff; ! 467: } ! 468: ! 469: /* get transmit status and write to AUDIT */ ! 470: ioctl(devfd,BSCGET,&c_params); ! 471: sprintf(note, ! 472: "EOT, sent %d blocks, did %d TTDs, had %d NAKs, %d timeouts, %d WACKs", ! 473: total_bl,c_params.b_nttd,c_params.b_nnak,c_params.b_nor, ! 474: c_params.b_nwack); ! 475: ! 476: write_aud("T",note); ! 477: ! 478: Receive_Files: ! 479: /* try to receive something (rcvf is receive function) */ ! 480: /* first check minimum space in user area if minspace set */ ! 481: if (minspace) { ! 482: pptr = popen(df_string,"r"); ! 483: fgets(line,sizeof line,pptr); ! 484: if (atol(&line[25]) < minspace) { ! 485: sprintf(note, ! 486: "bscd <%s>: file system <%s> has less than minimum blocks available. Processing aborted.", ! 487: hostname,dname); ! 488: ! 489: write_aud("D",note); ! 490: /* send mail about it all */ ! 491: post(); ! 492: ! 493: /* and now, do the disconnect stuff */ ! 494: goto Send_Signoff; ! 495: } ! 496: } ! 497: ! 498: total_bl = 0; ! 499: /* rcvf returns OK (2) if a file was received successfully; ! 500: NO (0) if nothing was received; ! 501: YES (1) if an error was encountered */ ! 502: while ((err = rcvf()) == OK || err == NO) { ! 503: if (minspace) { ! 504: pptr = popen(df_string,"r"); ! 505: fgets(line,sizeof line,pptr); ! 506: if (atol(&line[25]) < minspace) { ! 507: strcpy(note, ! 508: "Receiving aborted - minimum space unavailable"); ! 509: write_aud("D",note); ! 510: ! 511: /* send mail about it all */ ! 512: post(); ! 513: ! 514: } ! 515: } ! 516: if (contention) ! 517: break; ! 518: } ! 519: ! 520: /* if contention on the line, go back and try to send file again */ ! 521: if (contention) { ! 522: contention = NO; ! 523: goto Send_Files; ! 524: } ! 525: ! 526: if (err == YES) { /* rcvf reported problem */ ! 527: get_errors(); ! 528: ! 529: /* if receive timeout, go back to send to check if there's ! 530: anything else to transmit */ ! 531: if (c_params.b_flags == BSCRXTO) { ! 532: almost_done = 1; ! 533: /* update AUDIT with status of receive */ ! 534: ioctl(devfd,BSCGET,&c_params); ! 535: sprintf(note, ! 536: "EOT, received %d blocks, did %d WACKs and %d NAKs, had %d TTDs, %d overruns", ! 537: total_bl,c_params.b_nwack,c_params.b_nnak, ! 538: c_params.b_nttd,c_params.b_nor); ! 539: write_aud("T",note); ! 540: ! 541: goto Send_Files; ! 542: } ! 543: ! 544: sprintf(note,"Receiving aborted, <%s>",emsg); ! 545: write_aud("R",note); ! 546: sprintf(note,"Disconnected, <%s>",emsg); ! 547: write_aud("D",note); ! 548: goto Disconnect; ! 549: } ! 550: ! 551: /* update AUDIT with status of receive */ ! 552: ioctl(devfd,BSCGET,&c_params); ! 553: sprintf(note, ! 554: "EOT, received %d blocks, did %d WACKs and %d NAKs, had %d TTDs, %d overruns", ! 555: total_bl,c_params.b_nwack,c_params.b_nnak,c_params.b_nttd, ! 556: c_params.b_nor); ! 557: write_aud("T",note); ! 558: ! 559: /* if a new queue control file appeared, go back and send it */ ! 560: #if defined BSD42 ! 561: rewinddir(spoolfd); ! 562: #else ! 563: lseek(spoolfd,0L,0); /* rewind host directory */ ! 564: #endif ! 565: if (searchq(spoolfd) == YES) ! 566: { stat(ctlfile,&s); ! 567: if (s.st_size > 0) ! 568: goto Send_Files; ! 569: } ! 570: ! 571: Send_Signoff: ! 572: /* if there's a signoff file, send it (soff_send.c) */ ! 573: if (soff_file) { ! 574: total_bl = 0; ! 575: if ((more = soff_send(signoff)) == NO) { ! 576: sprintf(note,"Disconnected, <%s>", ! 577: emsg); ! 578: write_aud("D",note); ! 579: goto Disconnect; ! 580: } ! 581: sprintf(note, ! 582: "Transmission of SIGNOFF file <%s> completed (%d blocks)", ! 583: signoff,blocks); ! 584: write_aud("D",note); ! 585: total_bl += blocks; ! 586: ! 587: ioctl(devfd,BSCGET,&c_params); ! 588: sprintf(note, ! 589: "EOT, sent %d blocks, did %d TTDs, had %d NAKs, %d timeouts, %d WACKs", ! 590: total_bl,c_params.b_nttd,c_params.b_nnak, ! 591: c_params.b_nor,c_params.b_nwack); ! 592: ! 593: write_aud("T",note); ! 594: blocks = 0; ! 595: } ! 596: Disconnect: ! 597: quithost(); ! 598: } ! 599: } ! 600: ! 601: /* search the host directory for files queued to send */ ! 602: searchq(wfd) ! 603: #if defined BSD42 ! 604: DIR *wfd; ! 605: #else ! 606: int wfd; ! 607: #endif ! 608: { ! 609: int work = NO; ! 610: #if defined BSD42 ! 611: struct direct *d; ! 612: ! 613: while ((d = readdir(wfd)) != NULL) ! 614: if (d->d_name[0] == 'C') ! 615: { work = YES; ! 616: sprintf(ctlfile,"%s/%s",spool,d->d_name); ! 617: break; } ! 618: #else ! 619: struct direct d; ! 620: ! 621: while (read(wfd,&d,sizeof d) == sizeof d) ! 622: if (d.d_ino != 0 && d.d_name[0] == 'C') ! 623: { work = YES; ! 624: sprintf(ctlfile,"%s/%s",spool,d.d_name); ! 625: break; } ! 626: #endif ! 627: ! 628: return (work); ! 629: } ! 630: ! 631: /* quithost -- cleanup at end of host processing */ ! 632: quithost() ! 633: { ! 634: if (devfd > 0) { ! 635: close(devfd); ! 636: devfd = -1; ! 637: /* do any necessary disconnect cleanup */ ! 638: disconnect(hostname,devname); ! 639: } ! 640: ! 641: if (lockfile[0]) { ! 642: unlink(lockfile); ! 643: lockfile[0] = '\0'; ! 644: } ! 645: if (auditlock[0]) { ! 646: unlink(auditlock); ! 647: auditlock[0] = '\0'; ! 648: } ! 649: if (aud) { ! 650: fclose(aud); ! 651: aud = (FILE *)0; ! 652: if (link(audname,new_audnm) >= 0) { ! 653: unlink(audname); ! 654: } ! 655: } ! 656: #if defined BSD42 ! 657: if (spoolfd) { ! 658: closedir(spoolfd); ! 659: spoolfd = (DIR *)0; ! 660: } ! 661: #else ! 662: if (spoolfd > 0) { ! 663: close(spoolfd); ! 664: spoolfd = -1; ! 665: } ! 666: #endif ! 667: } ! 668: ! 669: /* sigint -- do signal interrupt processing */ ! 670: sigint(sig) ! 671: int sig; ! 672: { ! 673: char msg[80]; ! 674: sprintf(msg,"Signal %d received",sig); ! 675: /* update the audit file */ ! 676: write_aud("D",msg); ! 677: ! 678: quithost(); ! 679: exit(0); ! 680: } ! 681: ! 682: /* param_err - invalid keyword parameter error */ ! 683: param_err(kword,fname) ! 684: char *kword; ! 685: char *fname; ! 686: { ! 687: /* send mail about problem */ ! 688: sprintf(note,"Invalid parameter for keyword <%s>\n in <%s>\n", ! 689: kword,fname); ! 690: post(); ! 691: ! 692: fputs(note,stderr); ! 693: quithost(); ! 694: exit(1); ! 695: } ! 696: ! 697: /* post - post mail to the system administrator about problems encountered */ ! 698: post() ! 699: { ! 700: FILE *popen(),*pptr; ! 701: char address[50]; ! 702: ! 703: sprintf(address,"mail %s",sys_admin); ! 704: if (sys_admin[0] == '/') { ! 705: pptr = fopen(sys_admin,"a"); ! 706: fputs(note,pptr); ! 707: fclose(pptr); ! 708: } else { ! 709: pptr = popen(address,"w"); ! 710: fputs(note,pptr); ! 711: pclose(pptr); ! 712: } ! 713: } ! 714: ! 715: /* get_cnfg - get host configuration parameters ! 716: The function bcopy used herein does the same thing as strncpy, only ! 717: it actually does copy n characters, and doesn't stop at NULL. Very ! 718: convenient for binary or transparent data which contains NULLs... ! 719: bcopy(to,from,nbytes) */ ! 720: ! 721: get_cnfg(config_file) ! 722: char config_file[]; ! 723: { ! 724: FILE *fptr; /* file pointer returned by fopen */ ! 725: ! 726: int counter = 0; /* tracks line of config file being read */ ! 727: int i = 0; /* convenient index */ ! 728: ! 729: /* default b_flags parameter values */ ! 730: int halfdup = 0; ! 731: int irs = 0; ! 732: ! 733: char *index(); ! 734: char *pos; /* general buffer position pointer */ ! 735: char *dptr; /* dname position pointer */ ! 736: char cline[50]; /* contains one configuration line */ ! 737: ! 738: s_params.b_blks = 508; /* default block size */ ! 739: blksize = 508; /* as above */ ! 740: recsize = 503; ! 741: recblk = 503; ! 742: recsep = 0x1e; ! 743: rviab = BSCRVIABT; /* abort on receiving rvi */ ! 744: maxfsize = 0L; ! 745: minspace = 0L; ! 746: s_params.b_nbid = 0; /* default number of bids limit */ ! 747: s_params.b_nnak = 16; /* default number of naks allowed */ ! 748: s_params.b_nretry = 15; /* default number of retrys allowed */ ! 749: s_params.b_nttd = 120; /* default number of temp. txt delays */ ! 750: s_params.b_nwack = 120; /* default number of wacks allowed */ ! 751: s_params.b_nor = 60; /* default timeout */ ! 752: pt_to_pt = 0; ! 753: chk_hostid = NO; ! 754: son_file = NO; ! 755: soff_file = NO; ! 756: chk_termid = NO; ! 757: ! 758: strcpy(devname,"/dev/bsc"); /* default device name */ ! 759: strcpy(sys_admin,"/dev/console"); /* default system administrator ! 760: name for problem mail */ ! 761: ascii = NO; ! 762: compress = YES; ! 763: ! 764: /* read host configuration file for actual parameters */ ! 765: if ((fptr = fopen(config_file,"r")) == NULL) { ! 766: fprintf(stderr, ! 767: "bscd: can't open <%s> configuration file \n",hostname); ! 768: quithost(); ! 769: exit(1); ! 770: } ! 771: ! 772: while ((fgets(cline,sizeof cline,fptr)) != NULL) { ! 773: ++counter; ! 774: ! 775: if (strncmp(cline,"BLKSIZE=",8) == 0) { ! 776: pos = &cline[8]; ! 777: s_params.b_blks = atoi(pos); ! 778: blksize = s_params.b_blks; ! 779: if (s_params.b_blks < 32 || s_params.b_blks > 512) ! 780: param_err("BLKSIZE",config_file); ! 781: continue; ! 782: } ! 783: ! 784: if (strncmp(cline,"CODE=",5) == 0) { ! 785: pos = &cline[5]; ! 786: if(strncmp(pos,"ASCII",5) != 0 && ! 787: strncmp(pos,"EBCDIC",6) != 0) ! 788: param_err("CODE",config_file); ! 789: ascii = strncmp(pos,"ASCII",5) == 0?BSCASCII:NO; ! 790: continue; ! 791: } ! 792: ! 793: if (strncmp(cline,"COMPRESS=",9) == 0) { ! 794: pos = &cline[9]; ! 795: if (strncmp(pos,"YES",3) != 0 && ! 796: strncmp(pos,"NO",2) != 0) ! 797: param_err("COMPRESS",config_file); ! 798: compress =strncmp(pos,"YES",3)==0?YES:NO; ! 799: continue; ! 800: } ! 801: ! 802: if (strncmp(cline,"DEVICE=",7) == 0) { ! 803: pos = &cline[7]; ! 804: strcpy(devname,pos); ! 805: devname[strlen(devname)-1] = '\0'; ! 806: continue; ! 807: } ! 808: ! 809: if(strncmp(cline,"DUPLEX=",7) == 0) { ! 810: pos = &cline[7]; ! 811: if (strncmp(pos,"HALF",4) != 0 && ! 812: strncmp(pos,"FULL",4) != 0) ! 813: param_err("DUPLEX",config_file); ! 814: halfdup =strncmp(pos,"HALF",4)==0?0:BSCFDX; ! 815: continue; ! 816: } ! 817: ! 818: if (strncmp(cline,"IDCHECK=",8) ==0) { ! 819: pos = &cline[8]; ! 820: strcpy(s_params.b_hostid,pos); ! 821: chk_hostid = BSCCKHOST; ! 822: continue; ! 823: } ! 824: ! 825: if (strncmp(cline,"MAIL=",5) == 0) { ! 826: pos = &cline[5]; ! 827: strcpy(sys_admin,pos); ! 828: continue; ! 829: } ! 830: ! 831: if (strncmp(cline,"MAXFSIZE=",9) == 0) { ! 832: pos = &cline[9]; ! 833: maxfsize = atol(pos); ! 834: if (maxfsize > 1000000000L) ! 835: param_err("MAXFSIZE",config_file); ! 836: continue; ! 837: } ! 838: ! 839: if (strncmp(cline,"MINSPACE=",9) == 0) { ! 840: if ((pos = index(cline,',')) == NULL) ! 841: param_err("MINSPACE",config_file); ! 842: ++pos; ! 843: minspace = atol(pos); ! 844: if (minspace > 1000000000L) ! 845: param_err("MINSPACE",config_file); ! 846: pos = &cline[9]; ! 847: dptr = &dname[0]; ! 848: while(*pos != ',') ! 849: *dptr++ = *pos++; ! 850: *dptr = '\0'; ! 851: sprintf(df_string,"df -f %s\n",dname); ! 852: continue; ! 853: } ! 854: ! 855: if (strncmp(cline,"MPTADDR=",8) == 0) { ! 856: pos = &cline[8]; ! 857: strcpy(s_params.b_termid,pos); ! 858: pt_to_pt = BSCMPT; ! 859: continue; ! 860: } ! 861: ! 862: if (strncmp(cline,"NBID=",5) == 0) { ! 863: pos = &cline[5]; ! 864: s_params.b_nbid = atoi(pos); ! 865: if (s_params.b_nbid > 127 || s_params.b_nbid < 0) ! 866: param_err("NBID",config_file); ! 867: continue; ! 868: } ! 869: ! 870: if (strncmp(cline,"NNAK=",5) == 0) { ! 871: pos = &cline[5]; ! 872: s_params.b_nnak = atoi(pos); ! 873: if (s_params.b_nnak > 127 || s_params.b_nnak < 0) ! 874: param_err("NNAK",config_file); ! 875: continue; ! 876: } ! 877: ! 878: if (strncmp(cline,"NRETRY=",7) == 0) { ! 879: pos = &cline[7]; ! 880: s_params.b_nretry = atoi(pos); ! 881: if (s_params.b_nretry > 127 || s_params.b_nretry < 0) ! 882: param_err("NRETRY",config_file); ! 883: continue; ! 884: } ! 885: ! 886: if (strncmp(cline,"NTTD=",5) == 0) { ! 887: pos = &cline[5]; ! 888: s_params.b_nttd = atoi(pos); ! 889: if (s_params.b_nttd > 127 || s_params.b_nttd < 0) ! 890: param_err("NTTD",config_file); ! 891: continue; ! 892: } ! 893: ! 894: if (strncmp(cline,"NWACK=",6) == 0) { ! 895: pos = &cline[6]; ! 896: s_params.b_nwack = atoi(pos); ! 897: if (s_params.b_nwack > 127 || s_params.b_nwack < 0) ! 898: param_err("NWACK",config_file); ! 899: continue; ! 900: } ! 901: ! 902: if (strncmp(cline,"RECBLK=",7) == 0) { ! 903: pos = &cline[7]; ! 904: recblk = atoi(pos); ! 905: if (recblk > 507) ! 906: param_err("RECBLK",config_file); ! 907: continue; ! 908: } ! 909: ! 910: if (strncmp(cline,"RECSEP=",7) == 0) { ! 911: pos = &cline[7]; ! 912: irs =strncmp(pos,"IRS",3)==0?0:BSCIUS; ! 913: recsep = (irs == 0)?0x1e:0x19; ! 914: continue; ! 915: } ! 916: ! 917: if (strncmp(cline,"RECSIZE=",8) == 0) { ! 918: pos = &cline[8]; ! 919: recsize = atoi(pos); ! 920: if (recsize > 507) ! 921: recsize = 507; ! 922: continue; ! 923: } ! 924: ! 925: if (strncmp(cline,"RVIMODE=",8) == 0) { ! 926: pos = &cline[8]; ! 927: if (strncmp(pos,"ABORT",5) != 0 && ! 928: strncmp(pos,"IGNORE",6) != 0) ! 929: param_err("RVIMODE",config_file); ! 930: rviab =strncmp(pos,"ABORT",5)==0?BSCRVIABT:NO; ! 931: continue; ! 932: } ! 933: ! 934: if (strncmp(cline,"SIGNON=",7) == 0) { ! 935: strcpy(signon,&cline[7]); ! 936: signon[strlen(signon)-1] = '\0'; ! 937: son_file = YES; ! 938: continue; ! 939: } ! 940: ! 941: if (strncmp(cline,"SIGNOFF=",8) == 0) { ! 942: strcpy(signoff,&cline[8]); ! 943: signoff[strlen(signoff)-1] = '\0'; ! 944: soff_file = YES; ! 945: continue; ! 946: } ! 947: ! 948: if (strncmp(cline,"STATION=",8) == 0) { ! 949: pos = &cline[8]; ! 950: if (strncmp(pos,"PRIMARY",7) != 0 && ! 951: strncmp(pos,"SECONDARY",9) != 0) ! 952: param_err("STATION",config_file); ! 953: primary =strncmp(pos,"PRIMARY",7)==0?BSCPRIM:NO; ! 954: continue; ! 955: } ! 956: ! 957: if (strncmp(cline,"TERMID=",7) == 0) { ! 958: pos = &cline[7]; ! 959: bcopy(s_params.b_termid,pos,strlen(pos)-1); ! 960: chk_termid = YES; ! 961: continue; ! 962: } ! 963: ! 964: if (strncmp(cline,"TIMEOUT=",8) == 0) { ! 965: pos = &cline[8]; ! 966: i = atoi(pos); ! 967: if (i > 0 && i <= 3000) ! 968: s_params.b_nor = atoi(pos); ! 969: else ! 970: param_err("TIMEOUT",config_file); ! 971: continue; ! 972: } ! 973: ! 974: ! 975: if (strncmp(cline,"TRANSPARENT=",12) == 0) { ! 976: pos = &cline[12]; ! 977: if (strncmp(pos,"YES",3) != 0 && ! 978: strncmp(pos,"NO",2) != 0) ! 979: param_err("TRANSPARENT",config_file); ! 980: transp_ok =strncmp(pos,"YES",3)==0?YES:NO; ! 981: continue; ! 982: } ! 983: ! 984: if (strncmp(cline,"UNITSEP=",8) == 0) { ! 985: pos = &cline[8]; ! 986: ius = (strncmp(pos,"YES",3) == 0)? BSCIUS:NO; ! 987: continue; ! 988: } ! 989: ! 990: /* invalid keyword parameter error */ ! 991: sprintf(note, ! 992: "bscd <%s>: Unrecognized keyword, line %d in <%s>\n", ! 993: hostname,counter,config_file); ! 994: ! 995: fputs(note,stderr); ! 996: post(); ! 997: quithost(); ! 998: exit(1); ! 999: } ! 1000: ! 1001: /* insure that the record size is smaller than the block size */ ! 1002: if (recsize > blksize - 5) ! 1003: recsize = blksize - 5; ! 1004: ! 1005: s_params.b_flags = ascii | halfdup | ius | rviab | ! 1006: primary | chk_hostid | pt_to_pt; ! 1007: /* translate termid if one given and ebcdic */ ! 1008: if (!ascii && chk_termid) ! 1009: ascebc(s_params.b_termid,strlen(s_params.b_termid)); ! 1010: /* close configuration file */ ! 1011: fclose(fptr); ! 1012: } ! 1013: ! 1014: /* open_audit - open the host's AUDIT file */ ! 1015: open_audit() ! 1016: { ! 1017: int audfd; ! 1018: ! 1019: /* construct AUDIT file pathname */ ! 1020: sprintf(audname,"%s/%s",spool,"AUDIT"); ! 1021: sprintf(new_audnm,"%s/%s",spool,"AUDIT"); ! 1022: ! 1023: if (access(audname,0) == 0) { ! 1024: sprintf(auditlock,"%s/%s",spool,"auditlock"); ! 1025: if ((audfd = creat(auditlock,0)) < 0) { ! 1026: auditlock[0] = '\0'; ! 1027: bsc_audnm(); ! 1028: } else { ! 1029: close(audfd); ! 1030: aud = fopen(audname,"a"); ! 1031: } ! 1032: } ! 1033: } ! 1034: ! 1035: char *usr_name; /* ptr returned by getlogin */ ! 1036: /* write_aud - write message to audit file */ ! 1037: write_aud(type,msg) ! 1038: char *type; ! 1039: char *msg; ! 1040: { ! 1041: char *getlogin(); /* returns ptr to login name for this ! 1042: process */ ! 1043: ! 1044: if (aud == NULL) ! 1045: return; ! 1046: ! 1047: /* if first time, get login name */ ! 1048: if (usr_name == NULL) ! 1049: if ((usr_name=getlogin()) == NULL) ! 1050: usr_name="unknown"; ! 1051: ! 1052: /* get current time */ ! 1053: currtime = time((long*)0); ! 1054: t = localtime(&currtime); ! 1055: ! 1056: fprintf (aud, "%s %s %02d%02d%02d%02d%02d %s\n", ! 1057: usr_name, type, t->tm_year, (t->tm_mon) + 1, ! 1058: t->tm_mday, t->tm_hour, t->tm_min, msg); ! 1059: fflush(aud); ! 1060: } ! 1061: ! 1062: /* do_compress - replace blanks with group separator and count of blanks */ ! 1063: do_compress(string,llen) ! 1064: char *string; ! 1065: register int llen; /* line length */ ! 1066: { ! 1067: register int blanks; /* count of blanks */ ! 1068: ! 1069: register char *s, *r; ! 1070: char blank; ! 1071: ! 1072: blank = ascii?' ':0x40; ! 1073: ! 1074: r = s = string; ! 1075: ! 1076: while (1) { ! 1077: /* "copy" characters into string as long as they aren't blank */ ! 1078: while (llen > 0 && *s != blank) { ! 1079: --llen; ! 1080: *r++ = *s++; ! 1081: } ! 1082: ! 1083: if (llen == 0) /* no blanks were found */ ! 1084: break; ! 1085: ! 1086: /* skip over blanks in string, keep count to encode as group separator ! 1087: (GS) followed by number of blanks -- encode only if more than ! 1088: two blanks are found */ ! 1089: blanks = 0; ! 1090: while (llen > 0 && *s == blank){ ! 1091: ++blanks; ! 1092: --llen; ! 1093: ++s; ! 1094: } ! 1095: ! 1096: if (blanks > 2) ! 1097: { *r++ = GS; ! 1098: if (blanks <= 63) ! 1099: *r++ = 0x40 + blanks; ! 1100: else { ! 1101: *r++ = 0x40 + 63; ! 1102: *r++ = GS; ! 1103: *r++ = 0x40 + (blanks - 63); ! 1104: } ! 1105: continue; ! 1106: } ! 1107: else if (blanks == 2) ! 1108: *r++ = blank; ! 1109: ! 1110: *r++ = blank; ! 1111: } ! 1112: *r = '\0'; ! 1113: return(r-string); ! 1114: }
This archive runs on limited infrastructure. Preserving old code on modern bandwidth. Automated agents are requested to crawl responsibly.