/* * $Source: /afs/sipb.mit.edu/project/sipb-athena/repository/src/lpr/printjob.c,v $ * $Author: svalente $ * $Locker: $ * $Header: /afs/sipb.mit.edu/project/sipb-athena/repository/src/lpr/printjob.c,v 1.2 1995/03/27 02:26:50 svalente Exp $ */ /* * Copyright (c) 1983 Regents of the University of California. * All rights reserved. The Berkeley software License Agreement * specifies the terms and conditions for redistribution. */ #ifndef lint static char sccsid[] = "@(#)printjob.c 5.2 (Berkeley) 9/17/85"; static char *rcsid_printjob_c = "$Id: printjob.c,v 1.2 1995/03/27 02:26:50 svalente Exp $"; #endif /* * printjob -- print jobs in the queue. * * NOTE: the lock file is used to pass information to lpq and lprm. * it does not need to be removed because file locks are dynamic. */ #if defined _AUX_SOURCE || defined POSIX #define posix_termios #endif #include "lp.h" #ifdef _AUX_SOURCE #include #endif #ifdef POSIX #include #endif #define DORETURN 0 /* absorb fork error */ #define DOABORT 1 /* abort if dofork fails */ /* * Error tokens */ #define DEFER -4 /* Defer printing file till later */ #define REPRINT -2 #define ERROR -1 #define OK 0 #define FATALERR 1 #define NOACCT 2 #define FILTERERR 3 #define ACCESS 4 static int network; /* true if network access to printer */ #ifdef ZEPHYR #undef STAT #include #if defined POSIX || defined _IBMR2 #define wait_type int #define wait_uses_int #else #define wait_type union wait #endif #if defined POSIX #define signal_type void #else #define signal_type int #endif #define ZCLASS "MESSAGE" #define ZINSTANCE "PERSONAL" #define ZSENDER "Printer Daemon" #define ZDEFAULTFORMAT "$message" ZNotice_t notice; char zrecipient[40+REALM_SZ]; char *zmessage[6]; char zmessagetext[BUFSIZ]; int zerrno; int zflag = 0; static char *zerrtext[]={"Document printing has been deferred", "This is impossible", "Attempting to reprint document", "Generic error", "Document has finished printing successfully", "Fatal error", "No local account, document not printed", "Error in document output filter", "Error accessing symlinked file"}; static char *zerrtoken[]={"DEFER","IMPOSSIBLE","REPRINT","ERROR","OK", "FATALERR","NOACCT","FILTERERR","ACCESS"}; #endif ZEPHYR char title[80]; /* ``pr'' title */ FILE *cfp = NULL; /* control file */ int pfd; /* printer file descriptor */ int ofd; /* output filter file descriptor */ int lfd = -1; /* lock file descriptor */ int pid; /* pid of lpd process */ int prchild; /* id of pr process */ int child; /* id of any filters */ int ofilter; /* id of output filter, if any */ int tof; /* true if at top of form */ int remote; /* true if sending files to remote */ dev_t fdev; /* device of file pointed to by symlink */ ino_t fino; /* inode of file pointed to by symlink */ char fromhost[32]; /* user's host machine */ #ifdef KERBEROS char logname[ANAME_SZ + INST_SZ + REALM_SZ + 3]; #else char logname[32]; /* user's login name */ #endif KERBEROS char jobname[100]; /* job or file name */ char class[32]; /* classification field */ char width[10] = "-w"; /* page width in characters */ char length[10] = "-l"; /* page length in lines */ char pxwidth[10] = "-x"; /* page width in pixels */ char pxlength[10] = "-y"; /* page length in pixels */ char indent[10] = "-i0"; /* indentation size in characters */ char cost[10] = "-m"; /* Cost/page option */ char qacct[128] = "-a"; char tempfile[] = "errsXXXXXX"; /* file name for filter output */ int lflag; /* Log info flag */ int account_flag = 0; printjob() { struct stat stb; register struct queue *q, **qp; struct queue **queue; register int i, nitems; long pidoff; int count = 0; extern signal_type abortpr(); init(); /* set up capabilities */ (void) write(1, "", 1); /* ack that daemon is started */ setgid(getegid()); pid = getpid(); /* for use with lprm */ setpgrp(0, pid); signal(SIGHUP, abortpr); signal(SIGINT, abortpr); signal(SIGQUIT, abortpr); signal(SIGTERM, abortpr); (void) mktemp(tempfile); /* * uses short form file names */ if (chdir(SD) < 0) { syslog(LOG_ERR, "%s: %m", SD); exit(1); } if (stat(LO, &stb) == 0 && (stb.st_mode & 0100)) exit(0); /* printing disabled */ lfd = open(LO, O_WRONLY|O_CREAT, 0644); if (lfd < 0) { syslog(LOG_ERR, "%s: %s: %m", printer, LO); exit(1); } if (flock(lfd, LOCK_EX|LOCK_NB) < 0) { if (errno == EWOULDBLOCK) /* active daemon present */ exit(0); syslog(LOG_ERR, "%s: %s: %m", printer, LO); exit(1); } ftruncate(lfd, 0); /* * write process id for others to know */ sprintf(line, "%u\n", pid); pidoff = i = strlen(line); if (write(lfd, line, i) != i) { syslog(LOG_ERR, "%s: %s: %m", printer, LO); exit(1); } /* * search the spool directory for work and sort by queue order. */ if ((nitems = getq(&queue)) < 0) { syslog(LOG_ERR, "%s: can't scan %s", printer, SD); exit(1); } if (nitems == 0) /* no work to do */ { if (lflag) syslog(LOG_INFO, "No work on %s.", printer); exit(0); } if (stb.st_mode & 01) { /* reset queue flag */ if (fchmod(lfd, stb.st_mode & 0776) < 0) syslog(LOG_ERR, "%s: %s: %m", printer, LO); } if(lflag) syslog("Opening printer on %s", printer); openpr(); /* open printer or remote */ again: /* * we found something to do now do it -- * write the name of the current control file into the lock file * so the spool queue program can tell what we're working on */ if (lflag)syslog(LOG_INFO,"Got something to print.."); for (qp = queue; nitems--; free((char *) q)) { q = *qp++; if (stat(q->q_name, &stb) < 0) { continue; } restart: (void) lseek(lfd, (off_t)pidoff, 0); (void) sprintf(line, "%s\n", q->q_name); i = strlen(line); if (write(lfd, line, i) != i) syslog(LOG_ERR, "%s: %s: %m", printer, LO); if (!remote) i = printit(q->q_name); else i = sendit(q->q_name); /* * Check to see if we are supposed to stop printing or * if we are to rebuild the queue. */ if (fstat(lfd, &stb) == 0) { /* stop printing before starting next job? */ if (stb.st_mode & 0100) goto done; /* rebuild queue (after lpc topq) */ if (stb.st_mode & 01) { for (free((char *) q); nitems--; free((char *) q)) q = *qp++; if (fchmod(lfd, stb.st_mode & 0776) < 0) syslog(LOG_WARNING, "%s: %s: %m", printer, LO); break; } if (i == DEFER) { if (fchmod(lfd, stb.st_mode | 001) < 0) syslog(LOG_WARNING, "%s: %s: %m", printer, LO); continue; } } if (i == OK) /* file ok and printed */ count++; else if (i == REPRINT) { /* try reprinting the job */ if (lflag)syslog(LOG_INFO, "restarting %s", printer); if (ofilter > 0) { kill(ofilter, SIGCONT); /* to be sure */ (void) close(ofd); while ((i = wait(0)) > 0 && i != ofilter) ; ofilter = 0; } (void) close(pfd); /* close printer */ if (ftruncate(lfd, pidoff) < 0) syslog(LOG_WARNING, "%s: %s: %m", printer, LO); openpr(); /* try to reopen printer */ goto restart; } } free((char *) queue); /* * search the spool directory for more work. */ if ((nitems = getq(&queue)) < 0) { syslog(LOG_ERR, "%s: can't scan %s", printer, SD); exit(1); } if (nitems == 0) { /* no more work to do */ done: if (count > 0) { /* Files actually printed */ if (!SF && !tof) (void) write(ofd, FF, strlen(FF)); if (TR != NULL) /* output trailer */ (void) write(ofd, TR, strlen(TR)); } (void) UNLINK(tempfile); exit(0); } goto again; } char fonts[4][50]; /* fonts for troff */ char ifonts[4][18] = { "/usr/lib/vfont/R", "/usr/lib/vfont/I", "/usr/lib/vfont/B", "/usr/lib/vfont/S" }; /* * The remaining part is the reading of the control file (cf) * and performing the various actions. */ printit(file) char *file; { register int i; char *cp; int bombed = OK; /* * open control file; ignore if no longer there. */ if ((cfp = fopen(file, "r")) == NULL) { syslog(LOG_INFO, "%s: %s: %m", printer, file); return(OK); } /* * Try to lock control file. If we fail, defer processing * this file till later */ if (!network && (flock(fileno(cfp), LOCK_EX|LOCK_NB) < 0)) { if (errno == EWOULDBLOCK) { /* * We couldn't get the lock. Probably lprm * has locked it, in preparation for blowing * it away. So we defer it till later; * usually it won't be there, but just in * case some other bozo locks the file.... */ fclose(cfp); cfp = NULL; return(DEFER); } syslog(LOG_ERR, "%s: %s: %m", printer, file); exit(1); } /* * Reset troff fonts. */ for (i = 0; i < 4; i++) strcpy(fonts[i], ifonts[i]); sprintf(&width[2], "%d", PW); strcpy(indent+2, "0"); qacct[2] = NULL; jobname[0] = '\0'; /* * read the control file for work to do * * file format -- first character in the line is a command * rest of the line is the argument. * valid commands are: * * S -- "stat info" for symbolic link protection * J -- "job name" on banner page * C -- "class name" on banner page * L -- "literal" user's name to print on banner * T -- "title" for pr * H -- "host name" of machine where lpr was done * P -- "person" user's login name * W -- "width" width of page * I -- "indent" amount to indent output * f -- "file name" name of text file to print * l -- "file name" text file with control chars * p -- "file name" text file to print with pr(1) * t -- "file name" troff(1) file to print * n -- "file name" ditroff(1) file to print * d -- "file name" dvi file to print * g -- "file name" plot(1G) file to print * v -- "file name" plain raster file to print * c -- "file name" cifplot file to print * 1 -- "R font file" for troff * 2 -- "I font file" for troff * 3 -- "B font file" for troff * 4 -- "S font file" for troff * N -- "name" of file (used by lpq) * U -- "unlink" name of file to remove * (after we print it. (Pass 2 only)). * M -- "mail" to user when done printing * * Additions: (Ilham) * Z -- send zephyr message to user * Q -- Account number for quota management * getline reads a line and expands tabs to blanks */ /* pass 1 */ account_flag = 0; while (getline(cfp)) switch (line[0]) { case 'H': strcpy(fromhost, line+1); if (class[0] == '\0') strncpy(class, line+1, sizeof(class)-1); continue; case 'P': strncpy(logname, line+1, sizeof(logname)-1); if (RS) { /* restricted */ if (getpwnam(logname) == (struct passwd *)0) { bombed = NOACCT; #ifdef ZEPHYR sendzephyr(line+1, bombed); #else sendmail(line+1, bombed); #endif ZEPHYR goto pass2; } } continue; case 'A': /* For old client compatibility */ case 'Q': if (line[1] != '\0') { strcpy(&qacct[2], line+1); account_flag = 1; } continue; case 'S': cp = line+1; i = 0; while (*cp >= '0' && *cp <= '9') i = i * 10 + (*cp++ - '0'); fdev = i; cp++; i = 0; while (*cp >= '0' && *cp <= '9') i = i * 10 + (*cp++ - '0'); fino = i; continue; case 'J': if (line[1] != '\0') strncpy(jobname, line+1, sizeof(jobname)-1); else strcpy(jobname, " "); continue; case 'C': if (line[1] != '\0') strncpy(class, line+1, sizeof(class)-1); else if (class[0] == '\0') { struct hostent *hp; gethostname(class, sizeof(class)); hp = gethostbyname(class); if (hp) strcpy(class, hp -> h_name); } continue; case 'T': /* header title for pr */ strncpy(title, line+1, sizeof(title)-1); continue; case 'L': /* identification line */ if (!SH && !HL) banner(line+1, jobname); continue; case '1': /* troff fonts */ case '2': case '3': case '4': if (line[1] != '\0') strcpy(fonts[line[0]-'1'], line+1); continue; case 'W': /* page width */ strncpy(width+2, line+1, sizeof(width)-3); continue; case 'I': /* indent amount */ strncpy(indent+2, line+1, sizeof(indent)-3); continue; default: /* some file to print */ switch (i = print(line[0], line+1)) { case ERROR: if (bombed == OK) bombed = FATALERR; break; case REPRINT: (void) fclose(cfp); cfp = NULL; return(REPRINT); case FILTERERR: case ACCESS: bombed = i; #ifdef ZEPHYR sendzephyr(logname, bombed); #else sendmail(logname, bombed); #endif ZEPHYR } title[0] = '\0'; continue; case 'N': case 'U': case 'M': case 'Z': case 'E': /* From multics days */ continue; } /* pass 2 */ pass2: fseek(cfp, 0L, 0); while (getline(cfp)) switch (line[0]) { case 'L': /* identification line */ if (!SH && HL) banner(line+1, jobname); continue; case 'M': if (bombed < NOACCT) /* already sent if >= NOACCT */ sendmail(line+1, bombed); continue; case 'U': (void) UNLINK(line+1); continue; #ifdef ZEPHYR case 'Z': if (bombed < NOACCT) /* already sent if >= NOACCT */ sendzephyr(line+1, bombed); continue; #endif ZEPHYR } /* * clean-up in case another control file exists */ (void) fclose(cfp); cfp = NULL; (void) UNLINK(file); return(bombed == OK ? OK : ERROR); } /* * Print a file. * Set up the chain [ PR [ | {IF, OF} ] ] or {IF, RF, TF, NF, DF, CF, VF}. * Return -1 if a non-recoverable error occured, * 2 if the filter detected some errors (but printed the job anyway), * 1 if we should try to reprint this job and * 0 if all is well. * Note: all filters take stdin as the file, stdout as the printer, * stderr as the log file, and must not ignore SIGINT. */ print(format, file) int format; char *file; { register int n; register char *prog; int fi, fo; char *av[15], buf[BUFSIZ]; int pid, p[2], stopped = 0; wait_type status; struct stat stb; if (lstat(file, &stb) < 0 || (fi = open(file, O_RDONLY)) < 0) return(ERROR); /* * Check to see if data file is a symbolic link. If so, it should * still point to the same file or someone is trying to print * something he shouldn't. */ if ((stb.st_mode & S_IFMT) == S_IFLNK && fstat(fi, &stb) == 0 && (stb.st_dev != fdev || stb.st_ino != fino)) return(ACCESS); if (!SF && !tof) { /* start on a fresh page */ (void) write(ofd, FF, strlen(FF)); tof = 1; } if (IF == NULL && (format == 'f' || format == 'l')) { tof = 0; while ((n = read(fi, buf, BUFSIZ)) > 0) if (write(ofd, buf, n) != n) { (void) close(fi); return(REPRINT); } (void) close(fi); return(OK); } switch (format) { case 'p': /* print file using 'pr' */ if (IF == NULL) { /* use output filter */ prog = PR; av[0] = "pr"; av[1] = width; av[2] = length; av[3] = "-h"; av[4] = *title ? title : " "; av[5] = 0; fo = ofd; goto start; } pipe(p); if ((prchild = dofork(DORETURN)) == 0) { /* child */ dup2(fi, 0); /* file is stdin */ dup2(p[1], 1); /* pipe is stdout */ for (n = 3; n < NOFILE; n++) (void) close(n); execl(PR, "pr", width, length, "-h", *title ? title : " ", 0); syslog(LOG_ERR, "cannot execl %s", PR); exit(2); } (void) close(p[1]); /* close output side */ (void) close(fi); if (prchild < 0) { prchild = 0; (void) close(p[0]); return(ERROR); } fi = p[0]; /* use pipe for input */ case 'f': /* print plain text file */ prog = IF; av[1] = width; av[2] = length; av[3] = indent; n = 4; break; case 'l': /* like 'f' but pass control characters */ prog = IF; av[1] = "-c"; av[2] = width; av[3] = length; av[4] = indent; n = 5; break; case 'r': /* print a fortran text file */ prog = RF; av[1] = width; av[2] = length; n = 3; break; case 't': /* print troff output */ case 'n': /* print ditroff output */ case 'd': /* print tex output */ (void) UNLINK(".railmag"); if ((fo = creat(".railmag", FILMOD)) < 0) { syslog(LOG_ERR, "%s: cannot create .railmag", printer); (void) UNLINK(".railmag"); } else { for (n = 0; n < 4; n++) { if (fonts[n][0] != '/') (void) write(fo, "/usr/lib/vfont/", 15); (void) write(fo, fonts[n], strlen(fonts[n])); (void) write(fo, "\n", 1); } (void) close(fo); } prog = (format == 't') ? TF : (format == 'n') ? NF : DF; av[1] = pxwidth; av[2] = pxlength; n = 3; break; case 'c': /* print cifplot output */ prog = CF; av[1] = pxwidth; av[2] = pxlength; n = 3; break; case 'g': /* print plot(1G) output */ prog = GF; av[1] = pxwidth; av[2] = pxlength; n = 3; break; case 'v': /* print raster output */ prog = VF; av[1] = pxwidth; av[2] = pxlength; n = 3; break; default: (void) close(fi); syslog(LOG_ERR, "%s: illegal format character '%c'", printer, format); return(ERROR); } if ((av[0] = rindex(prog, '/')) != NULL) av[0]++; else av[0] = prog; av[n++] = "-n"; av[n++] = logname; av[n++] = "-h"; av[n++] = fromhost; av[n++] = cost; if (account_flag) av[n++] = qacct; av[n++] = AF; av[n] = 0; fo = pfd; if (ofilter > 0) { /* stop output filter */ write(ofd, "\031\1", 2); while ((pid = wait3(&status, WUNTRACED, 0)) > 0 && pid != ofilter) ; if (pid == -1 || !WIFSTOPPED(status)) { (void) close(fi); syslog(LOG_WARNING, "%s: output filter died (%d)", printer, status); return(REPRINT); } stopped++; } start: if ((child = dofork(DORETURN)) == 0) { /* child */ dup2(fi, 0); dup2(fo, 1); n = open(tempfile, O_WRONLY|O_CREAT|O_TRUNC, 0664); if (n >= 0) dup2(n, 2); for (n = 3; n < NOFILE; n++) (void) close(n); execv(prog, av); syslog(LOG_ERR, "cannot execv %s", prog); exit(2); } (void) close(fi); if (child < 0) #ifdef wait_uses_int status= 100; #else status.w_retcode = 100; #endif else while ((pid = wait(&status)) > 0 && pid != child) ; child = 0; prchild = 0; if (stopped) { /* restart output filter */ if (kill(ofilter, SIGCONT) < 0) { syslog(LOG_ERR, "cannot restart output filter"); exit(1); } } tof = 0; #ifdef _AUX_SOURCE /* WIFEXITED on the MAC with POSIX_SOURCE uses wrong macro */ if (!(((status).w_stopval != WSTOPPED && (status).w_termsig == 0))) { #else if (!WIFEXITED(status)) { #endif syslog(LOG_WARNING, "%s: Daemon filter '%c' terminated (%d)", printer, format, WTERMSIG(status)); return(ERROR); } switch (WEXITSTATUS(status)) { case 0: tof = 1; return(OK); case 1: return(REPRINT); default: syslog(LOG_WARNING, "%s: Daemon filter '%c' exited (%d)", printer, format, WEXITSTATUS(status)); case 2: return(ERROR); } } /* * Send the daemon control file (cf) and any data files. * Return -1 if a non-recoverable error occured, 1 if a recoverable error and * 0 if all is well. */ sendit(file) char *file; { register int i, err = OK; char *cp, last[BUFSIZ]; /* * open control file */ if ((cfp = fopen(file, "r")) == NULL) return(OK); /* * read the control file for work to do * * file format -- first character in the line is a command * rest of the line is the argument. * commands of interest are: * * a-z -- "file name" name of file to print * U -- "unlink" name of file to remove * (after we print it. (Pass 2 only)). */ /* * pass 1 */ while (getline(cfp)) { again: if (line[0] == 'S') { cp = line+1; i = 0; while (*cp >= '0' && *cp <= '9') i = i * 10 + (*cp++ - '0'); fdev = i; cp++; i = 0; while (*cp >= '0' && *cp <= '9') i = i * 10 + (*cp++ - '0'); fino = i; continue; } if (line[0] >= 'a' && line[0] <= 'z') { strcpy(last, line); while (i = getline(cfp)) if (strcmp(last, line)) break; switch (sendfile('\3', last+1)) { case OK: if (i) goto again; break; case REPRINT: (void) fclose(cfp); cfp = NULL; return(REPRINT); case ACCESS: #ifdef ZEPHYR sendmail(logname, ACCESS); #else sendzephyr(logname, ACCESS); #endif ZEPHYR case ERROR: err = ERROR; } break; } } if (err == OK && sendfile('\2', file) > 0) { (void) fclose(cfp); cfp = NULL; return(REPRINT); } /* * pass 2 */ fseek(cfp, 0L, 0); while (getline(cfp)) if (line[0] == 'U') (void) UNLINK(line+1); /* * clean-up in case another control file exists */ (void) fclose(cfp); cfp = NULL; (void) UNLINK(file); return(err); } /* * Send a data file to the remote machine and spool it. * Return positive if we should try resending. */ sendfile(type, file) char type, *file; { register int f, i, amt; struct stat stb; char buf[BUFSIZ]; int sizerr, resp; if (lstat(file, &stb) < 0 || (f = open(file, O_RDONLY)) < 0) return(ERROR); /* * Check to see if data file is a symbolic link. If so, it should * still point to the same file or someone is trying to print something * he shouldn't. */ if ((stb.st_mode & S_IFMT) == S_IFLNK && fstat(f, &stb) == 0 && (stb.st_dev != fdev || stb.st_ino != fino)) return(ACCESS); (void) sprintf(buf, "%c%d %s\n", type, stb.st_size, file); amt = strlen(buf); for (i = 0; ; i++) { if (write(pfd, buf, amt) != amt || (resp = response()) < 0 || resp == '\1') { (void) close(f); return(REPRINT); } else if (resp == '\0') break; if (i == 0) status("no space on remote; waiting for queue to drain"); if (i == 10) syslog(LOG_ALERT, "%s: can't send to %s; queue full", printer, RM); sleep(5 * 60); } if (i) status("sending to %s", RM); sizerr = 0; for (i = 0; i < stb.st_size; i += BUFSIZ) { amt = BUFSIZ; if (i + amt > stb.st_size) amt = stb.st_size - i; if (sizerr == 0 && read(f, buf, amt) != amt) sizerr = 1; if (write(pfd, buf, amt) != amt) { (void) close(f); return(REPRINT); } } (void) close(f); if (sizerr) { syslog(LOG_INFO, "%s: %s: changed size", printer, file); /* tell recvjob to ignore this file */ (void) write(pfd, "\1", 1); return(ERROR); } if (write(pfd, "", 1) != 1 || response()) return(REPRINT); return(OK); } /* * Check to make sure there have been no errors and that both programs * are in sync with eachother. * Return non-zero if the connection was lost. */ response() { char resp; if (read(pfd, &resp, 1) != 1) { syslog(LOG_INFO, "%s: lost connection", printer); return(-1); } return(resp); } /* * Banner printing stuff */ banner(name1, name2) char *name1, *name2; { time_t tvec; extern char *ctime(); time(&tvec); if (!SF && !tof) (void) write(ofd, FF, strlen(FF)); if (SB) { /* short banner only */ if (class[0]) { (void) write(ofd, class, strlen(class)); (void) write(ofd, ":", 1); } (void) write(ofd, name1, strlen(name1)); (void) write(ofd, " Job: ", 7); (void) write(ofd, name2, strlen(name2)); (void) write(ofd, " Date: ", 8); (void) write(ofd, ctime(&tvec), 24); (void) write(ofd, "\n", 1); } else { /* normal banner */ (void) write(ofd, "\n\n\n", 3); scan_out(ofd, name1, '\0'); (void) write(ofd, "\n\n", 2); scan_out(ofd, name2, '\0'); if (class[0]) { register char *cp; (void) write(ofd,"\n\n\n",3); /* Take out domain names, if any */ if (cp = index(class, '.')) *cp = '\0'; scan_out(ofd, class, '\0'); } (void) write(ofd, "\n\n\n\n\t\t\t\tJob: ", 17); (void) write(ofd, name2, strlen(name2)); (void) write(ofd, "\n\t\t\t\tUser: ", 14); if (logname[0]) (void) write (ofd, logname, strlen(logname)); else (void) write(ofd, name1, strlen(name1)); if (class[0] || fromhost[0]) { (void) write (ofd, "@", 1); if (fromhost[0]) { (void) write (ofd, fromhost, strlen(fromhost)); } else { (void) write (ofd, class, strlen(class)); } } (void) write(ofd, "\n\t\t\t\tDate: ", 14); (void) write(ofd, ctime(&tvec), 24); if (printer != (char *) NULL && *printer != '\0') { (void) write (ofd, "\n\t\t\t\tPrinter: ", 14); (void) write (ofd, printer, strlen(printer)); if (host != (char *) NULL && *host != '\0') { (void) write (ofd, " (on ", 5); (void) write (ofd, host, strlen(host)); (void) write (ofd, ")", 1); } } (void) write(ofd, "\n", 1); } if (!SF) (void) write(ofd, FF, strlen(FF)); tof = 1; } char * scnline(key, p, c) register char key, *p; char c; { register int scnwidth; for (scnwidth = WIDTH; --scnwidth;) { key <<= 1; *p++ = key & 0200 ? c : BACKGND; } return (p); } #define TRC(q) (((q)-' ')&0177) scan_out(scfd, scsp, dlm) int scfd; char *scsp, dlm; { register char *strp; register nchrs, j; char outbuf[LINELEN+1], *sp, c, cc; int d, scnhgt; extern char scnkey[][HEIGHT]; /* in lpdchar.c */ for (scnhgt = 0; scnhgt++ < HEIGHT+DROP; ) { strp = &outbuf[0]; sp = scsp; for (nchrs = 0; ; ) { d = dropit(c = TRC(cc = *sp++)); if ((!d && scnhgt > HEIGHT) || (scnhgt <= DROP && d)) for (j = WIDTH; --j;) *strp++ = BACKGND; else strp = scnline(scnkey[c][scnhgt-1-d], strp, cc); if (*sp == dlm || *sp == '\0' || nchrs++ >= PW/(WIDTH+1)-1) break; *strp++ = BACKGND; *strp++ = BACKGND; } while (*--strp == BACKGND && strp >= outbuf) ; strp++; *strp++ = '\n'; (void) write(scfd, outbuf, strp-outbuf); } } dropit(c) char c; { switch(c) { case TRC('_'): case TRC(';'): case TRC(','): case TRC('g'): case TRC('j'): case TRC('p'): case TRC('q'): case TRC('y'): return (DROP); default: return (0); } } /* * sendmail --- * tell people about job completion */ sendmail(user, bombed) char *user; int bombed; { register int i; int p[2], s; register char *cp; char buf[100]; struct stat stb; FILE *fp; #ifdef ALLOW_MAIL pipe(p); if ((s = dofork(DORETURN)) == 0) { /* child */ dup2(p[0], 0); for (i = 3; i < NOFILE; i++) (void) close(i); if ((cp = rindex(MAIL, '/')) != NULL) cp++; else cp = MAIL; sprintf(buf, "%s@%s", user, fromhost); execl(MAIL, cp, buf, 0); exit(0); } else if (s > 0) { /* parent */ dup2(p[1], 1); printf("To: %s@%s\n", user, fromhost); printf("Subject: printer job\n\n"); printf("Your printer job "); if (*jobname) printf("(%s) ", jobname); switch (bombed) { case OK: printf("\ncompleted successfully\n"); break; default: case FATALERR: printf("\ncould not be printed\n"); break; case NOACCT: printf("\ncould not be printed without an account on %s\n", host); break; case FILTERERR: if (stat(tempfile, &stb) < 0 || stb.st_size == 0 || (fp = fopen(tempfile, "r")) == NULL) { printf("\nwas printed but had some errors\n"); break; } printf("\nwas printed but had the following errors:\n"); while ((i = getc(fp)) != EOF) putchar(i); (void) fclose(fp); break; case ACCESS: printf("\nwas not printed because it was not linked to the original file\n"); } fflush(stdout); (void) close(1); } (void) close(p[0]); (void) close(p[1]); wait(&s); #endif } #ifdef ZEPHYR sendzephyr(user, bombed) char *user; int bombed; { notice.z_kind=UNACKED; notice.z_port=0; notice.z_class=ZCLASS; notice.z_class_inst=ZINSTANCE; notice.z_opcode=""; notice.z_sender=ZSENDER; strcpy(zrecipient,logname); notice.z_recipient=zrecipient; notice.z_default_format=ZDEFAULTFORMAT; notice.z_num_other_fields=0; if(*jobname) sprintf(zmessagetext,"Printer status for %s:\n\nJob name: %s\n%s", printer,jobname,zerrtext[bombed+4]); else sprintf(zmessagetext,"Printer status for %s:\n\n%s", printer,zerrtext[bombed+4]); zmessage[0]="Printer Daemon"; zmessage[1]=zmessagetext; zmessage[2]=printer; zmessage[3]=line+1; zmessage[4]=zerrtext[bombed+4]; zmessage[5]=zerrtoken[bombed+4]; if (zerrno=ZSendList(¬ice,zmessage,6,ZNOAUTH)) syslog(LOG_ERR,"Error sending zephyr notification: zerrno=%d", zerrno); } #endif ZEPHYR /* * dofork - fork with retries on failure */ dofork(action) int action; { register int i, pid; for (i = 0; i < 20; i++) { if ((pid = fork()) < 0) { sleep((unsigned)(i*i)); continue; } /* * Child should run as daemon instead of root */ if (pid == 0) setuid(DU); return(pid); } syslog(LOG_ERR, "can't fork"); switch (action) { case DORETURN: return (-1); default: syslog(LOG_ERR, "bad action (%d) to dofork", action); /*FALL THRU*/ case DOABORT: exit(1); } /*NOTREACHED*/ } /* * Kill child processes to abort current job. */ signal_type abortpr() { signal_type hard_kill(); /* Drop the lock on the control file, if necessary */ if (cfp) (void) fclose(cfp); /* Drop lock on lock file as well */ if (lfd > 0) (void) close(lfd); (void) UNLINK(tempfile); kill(0, SIGINT); if (ofilter > 0) kill(ofilter, SIGCONT); signal(SIGALRM, hard_kill); alarm(30); while (wait(0) > 0) ; exit(0); } signal_type hard_kill() { kill(0, SIGKILL); } init() { int status; #ifdef HESIOD if ((status = pgetent(line, printer)) <= 0) { if (pralias(alibuf, printer)) printer = alibuf; if ((status = hpgetent(line, printer)) < 1) fatal("unknown printer"); } #else if ((status = pgetent(line, printer)) < 0) { fatal("can't open printer description file"); } else if (status == 0) fatal("unknown printer"); #endif HESIOD if ((LP = pgetstr("lp", &bp)) == NULL) LP = DEFDEVLP; if ((RP = pgetstr("rp", &bp)) == NULL) RP = DEFLP; if ((LO = pgetstr("lo", &bp)) == NULL) LO = DEFLOCK; if ((ST = pgetstr("st", &bp)) == NULL) ST = DEFSTAT; if ((LF = pgetstr("lf", &bp)) == NULL) LF = DEFLOGF; if ((SD = pgetstr("sd", &bp)) == NULL) SD = DEFSPOOL; if ((DU = pgetnum("du")) < 0) DU = DEFUID; if ((FF = pgetstr("ff", &bp)) == NULL) FF = DEFFF; if ((PW = pgetnum("pw")) < 0) PW = DEFWIDTH; sprintf(&width[2], "%d", PW); if ((PL = pgetnum("pl")) < 0) PL = DEFLENGTH; sprintf(&length[2], "%d", PL); #ifdef PQUOTA if ((CP = pgetnum("pc")) < 0) CP = DEFPC; sprintf(&cost[2], "%d", CP); #endif if ((PX = pgetnum("px")) < 0) PX = 0; sprintf(&pxwidth[2], "%d", PX); if ((PY = pgetnum("py")) < 0) PY = 0; sprintf(&pxlength[2], "%d", PY); RM = pgetstr("rm", &bp); /* * Figure out whether the local machine is the same as the remote * machine entry (if it exists). If not, then ignore the local * queue information. */ if (RM != (char *) NULL) { char name[255]; struct hostent *hp; /* get the name of the local host */ gethostname (name, sizeof(name) - 1); name[sizeof(name)-1] = '\0'; /* get the network standard name of the local host */ hp = gethostbyname (name); if (hp == (struct hostent *) NULL) { printf ("unable to get hostname for local machine %s\n", name); } else { strcpy (name, hp->h_name); /* get the network standard name of RM */ hp = gethostbyname (RM); if (hp == (struct hostent *) NULL) { printf ("unable to get hostname for remote machine %s\n", RM); } /* if printer is not on local machine, ignore LP */ else if (strcasecmp(name, hp->h_name) != 0) *LP = '\0'; } } localcheck_done: AF = pgetstr("af", &bp); OF = pgetstr("of", &bp); IF = pgetstr("if", &bp); RF = pgetstr("rf", &bp); TF = pgetstr("tf", &bp); NF = pgetstr("nf", &bp); DF = pgetstr("df", &bp); GF = pgetstr("gf", &bp); VF = pgetstr("vf", &bp); CF = pgetstr("cf", &bp); TR = pgetstr("tr", &bp); RS = pgetflag("rs"); SF = pgetflag("sf"); SH = pgetflag("sh"); SB = pgetflag("sb"); HL = pgetflag("hl"); RW = pgetflag("rw"); BR = pgetnum("br"); if ((FC = pgetnum("fc")) < 0) FC = 0; if ((FS = pgetnum("fs")) < 0) FS = 0; if ((XC = pgetnum("xc")) < 0) XC = 0; if ((XS = pgetnum("xs")) < 0) XS = 0; tof = !pgetflag("fo"); } /* * Acquire line printer or remote connection. */ openpr() { register int i, n; int resp; if (lflag)syslog(LOG_INFO, "Opening printer (LP = \"%s\")", LP); if (*LP) { for (i = 1; ; i = i < 32 ? i << 1 : i) { if (LP[0] == '@') { pfd = tcp_conn(&LP[1]); network = 1; } else { pfd = open(LP, RW ? O_RDWR : O_WRONLY); network = 0; } if (lflag) syslog(LOG_INFO, "LP opened."); if (pfd >= 0) break; if (errno == ENOENT) { syslog(LOG_ERR, "%s: %m", LP); exit(1); } else syslog(LOG_ERR, "%s: %m", LP); if (i == 1) status("waiting for %s (%s) to become ready (offline ?)", printer, LP); sleep(i); } if (isatty(pfd)) setty(); status("%s is ready and printing", printer); /* * Start up an output filter, if needed. */ if (OF) { int p[2]; char *cp; if (lflag) syslog(LOG_INFO, "Starting filter on %s", LP); pipe(p); if ((ofilter = dofork(DOABORT)) == 0) { /* child */ dup2(p[0], 0); /* pipe is std in */ dup2(pfd, 1); /* printer is std out */ for (i = 3; i < NOFILE; i++) (void) close(i); if ((cp = rindex(OF, '/')) == NULL) cp = OF; else cp++; execl(OF, cp, width, length, 0); syslog(LOG_ERR, "%s: %s: %m", printer, OF); exit(1); } (void) close(p[0]); /* close input side */ ofd = p[1]; /* use pipe for output */ } else { ofd = pfd; ofilter = 0; } } else if (RM != NULL) { if (lflag) syslog(LOG_INFO, "Connecting to %s..", RM); for (i = 1; ; i = i < 256 ? i << 1 : i) { resp = -1; pfd = getport(RM); if (pfd >= 0) { (void) sprintf(line, "\2%s\n", RP); n = strlen(line); if (write(pfd, line, n) == n && (resp = response()) == '\0') break; (void) close(pfd); } if (i == 1) { if (resp < 0) status("waiting for %s to come up", RM); else { status("waiting for queue to be enabled on %s", RM); i = 256; } } sleep(i); } if (lflag) syslog(LOG_INFO, "Sending to %s..", RM); status("sending to %s", RM); remote = 1; ofd = pfd; ofilter = 0; } else { syslog(LOG_ERR, "%s: no line printer device or host name", printer); exit(1); } } struct bauds { int baud; int speed; } bauds[] = { 50, B50, 75, B75, 110, B110, 134, B134, 150, B150, 200, B200, 300, B300, 600, B600, 1200, B1200, 1800, B1800, 2400, B2400, 4800, B4800, 9600, B9600, 19200, EXTA, 38400, EXTB, 0, 0 }; /* * setup tty lines. */ setty() { #ifndef posix_termios struct sgttyb ttybuf; #else struct termio ttybuf; #endif register struct bauds *bp; #ifndef posix_termios /* I cannot determine if under AUX you can open a line exclusively */ if (ioctl(pfd, TIOCEXCL, (char *)0) < 0) { syslog(LOG_ERR, "%s: ioctl(TIOCEXCL): %m", printer); exit(1); } #endif #ifndef posix_termios if (ioctl(pfd, TIOCGETP, (char *)&ttybuf) < 0) { syslog(LOG_ERR, "%s: ioctl(TIOCGETP): %m", printer); exit(1); } #else if (ioctl(pfd, TCGETA, (char *)&ttybuf) < 0) { syslog(LOG_ERR, "%s: ioctl(TCGETA): %m", printer); exit(1); } #endif if (BR > 0) { for (bp = bauds; bp->baud; bp++) if (BR == bp->baud) break; if (!bp->baud) { syslog(LOG_ERR, "%s: illegal baud rate %d", printer, BR); exit(1); } #ifndef posix_termios ttybuf.sg_ispeed = ttybuf.sg_ospeed = bp->speed; #else ttybuf.c_cflag &= ~CBAUD; ttybuf.c_cflag |= bp->speed; if (XC) ttybuf.c_lflag &= ~XC; if (XS) ttybuf.c_lflag |= XS; #endif } #ifndef posix_termios ttybuf.sg_flags &= ~FC; ttybuf.sg_flags |= FS; if (ioctl(pfd, TIOCSETP, (char *)&ttybuf) < 0) { syslog(LOG_INFO, "SETP failed.."); syslog(LOG_ERR, "%s: ioctl(TIOCSETP): %m", printer); exit(1); } #else ttybuf.c_cflag &= ~FC; ttybuf.c_cflag |= FS; if (ioctl(pfd, TCSETA, (char *)&ttybuf) < 0) { syslog(LOG_INFO, "SETA failed.."); syslog(LOG_ERR, "%s: ioctl(TCSETA): %m", printer); exit(1); } #endif /*posix_termios */ #ifndef posix_termios /* AUX does not appear to have old/new line disciplines that do anything */ if (XC || XS) { int ldisc = NTTYDISC; if (ioctl(pfd, TIOCSETD, &ldisc) < 0) { syslog(LOG_ERR, "%s: ioctl(TIOCSETD): %m", printer); exit(1); } } /* For AUX, XC and XS handled above */ if (XC) { if (ioctl(pfd, TIOCLBIC, &XC) < 0) { syslog(LOG_ERR, "%s: ioctl(TIOCLBIC): %m", printer); exit(1); } } if (XS) { if (ioctl(pfd, TIOCLBIS, &XS) < 0) { syslog(LOG_ERR, "%s: ioctl(TIOCLBIS): %m", printer); exit(1); } } #endif } /*VARARGS1*/ status(msg, a1, a2, a3) char *msg; { register int fd; char buf[BUFSIZ]; umask(0); fd = open(ST, O_WRONLY|O_CREAT, 0664); if (fd < 0 || flock(fd, LOCK_EX) < 0) { syslog(LOG_ERR, "%s: %s: %m", printer, ST); exit(1); } ftruncate(fd, 0); sprintf(buf, msg, a1, a2, a3); strcat(buf, "\n"); (void) write(fd, buf, strlen(buf)); (void) close(fd); }