![[BACK]](/cvsweb/icons/back.gif){kind=icon}
Return to vpd.c CVS log ![[TXT]](/cvsweb/icons/text.gif){kind=icon}
![[DIR]](/cvsweb/icons/dir.gif){kind=icon}
Up to [CSRG BSD Unix] / 43BSD / old / vpr|
Return to vpd.c CVS log | Up to [CSRG BSD Unix] / 43BSD / old / vpr |
1.1 root 1: #define CONSOLE "/dev/console"
2: #define dprcons if (debug) prcons
3: /*
4: * vpd.c updated 11/18/82
5: * Varian or Versatec printer daemon
6: */
7: char vpdSCCSid[] = "@(#)vpd.c 1.4\t11/18/82";
8:
9: #include <stdio.h>
10: #include <sys/param.h>
11: #include <dir.h>
12: #include <signal.h>
13: #include <stat.h>
14: #include <sgtty.h>
15: #include <errno.h>
16: #include <sys/vcmd.h>
17: #include <wait.h>
18:
19: int debug;
20: extern int errno;
21:
22: #define VRAST "/usr/local/lib/vrast"
23: #define VDMP "/usr/lib/vdmp"
24: #define VPLTDMP "/usr/lib/vpltdmp"
25:
26: #ifdef VARIAN
27: #define DEVICE "/dev/va0"
28: #define DFNAME "/usr/spool/vad/"
29: #define SPOOLDIR "/usr/spool/vad"
30: #define NAME "Varian"
31: #endif
32:
33: #ifdef VERSATEC
34: #define DEVICE "/dev/vp0"
35: #define DFNAME "/usr/spool/vpd/"
36: #define SPOOLDIR "/usr/spool/vpd"
37: #define NAME "Versatec"
38: #endif
39:
40: int prtmode[] = {VPRINT, 0, 0};
41:
42: char line[128];
43: char linep[127];
44: char banbuf[64];
45: char banner[512];
46: char printflag;
47: int linel;
48: FILE *dfb;
49: char dfname[33] = DFNAME;
50: int waittm = 6;
51: int onalrm ();
52: char tmplock[] = "lockXXXXXX";
53: char fonts[4][50] = {
54: "/usr/lib/vfont/R",
55: "/usr/lib/vfont/I",
56: "/usr/lib/vfont/B",
57: "/usr/lib/vfont/S"
58: };
59:
60: main(argc, argv)
61: int argc;
62: char **argv;
63: {
64: char n;
65: register char *p1, *p2;
66: register int df;
67: register struct direct *dirp;
68: DIR *dp;
69: struct stat stb;
70: int offline = 0;
71: int i, okreque = 1;
72:
73: while (argc > 1) {
74: argc--;
75: argv++;
76: if (argv[0][0] != '-')
77: continue;
78: switch (argv[0][1]) {
79: case 'n':
80: if (argc < 2)
81: break;
82: argv++;
83: argc--;
84: nice(atol(argv[0]));
85: break;
86: }
87: }
88: setuid(getuid());
89: signal(SIGHUP, SIG_IGN);
90: signal(SIGINT, SIG_IGN);
91: signal(SIGQUIT, SIG_IGN);
92: signal(SIGTERM, SIG_IGN);
93: begin:
94: /*
95: * Close all files, open root as 0, 1, 2
96: * to assure standard environment
97: */
98: for (df = 0; df <= 15; df++)
99: close(df);
100: open("/", 0);
101: dup(0);
102: dup(0);
103: if (chdir(SPOOLDIR) < 0 || (df = creat(mktemp(tmplock), 0)) < 0) {
104: close(1);
105: prcons("%s: error accessing %s\n", NAME, SPOOLDIR);
106: exit(1);
107: }
108: if (link(tmplock, "lock") < 0) {
109: unlink(tmplock);
110: exit(0);
111: }
112: unlink(tmplock);
113: close(df);
114: floop:
115: dprcons("floop\n");
116: i = fork();
117: if (i < 0) {
118: sleep(5);
119: goto floop;
120: }
121: if (i != 0)
122: exit(0);
123: reopen:
124: dprcons("reopen\n");
125: for (;;) {
126: if (open(DEVICE, 1) == 3)
127: break;
128: if (errno != EIO) {
129: extern char *sys_errlist[];
130: prcons("%s: %s: %s\n", NAME, DEVICE, sys_errlist[errno]);
131: unlink("lock");
132: exit(1);
133: }
134: if (offline == 0) {
135: int f = open("/dev/tty", 1);
136:
137: offline++;
138: if (f > 0) {
139: write(f, NAME, strlen(NAME));
140: write(f, " is offline\n", 12);
141: close(f);
142: }
143: dprcons("offline\n");
144: }
145: sleep(10);
146: }
147: dp = opendir(".");
148: search:
149: dprcons("search\n");
150: if (okreque == 1) {
151: rewinddir(dp);
152: do {
153: dirp = readdir(dp);
154: if (dirp == NULL) {
155: if (printflag)
156: lastpage();
157: unlink("lock");
158: dprcons("nomore\n");
159: if (printflag==0) {
160: dprcons("bye\n");
161: exit(0);
162: }
163: dprcons("one last time\n");
164: printflag = 0;
165: close(3);
166: closedir(dp);
167: sleep(30);
168: goto begin;
169: }
170: } while (dirp->d_name[0] != 'd' || dirp->d_name[1] != 'f');
171: strcpy(&dfname[15], dirp->d_name);
172: dprcons("found %s\n", dirp->d_name);
173: }
174: dprcons("trying %s\n", dfname);
175: printflag = 1;
176: if (okreque == 0)
177: feedpage();
178: if (trysend(dfname, okreque)) {
179: okreque = 0;
180: closedir(dp);
181: printf("reque %s\n", dfname);
182: close(3);
183: goto reopen;
184: }
185: dprcons("ok\n");
186: okreque = 1;
187: goto search;
188: }
189:
190: trysend(file, okreque)
191: char *file;
192: int okreque;
193: {
194: register int i;
195: char plot;
196: union wait status;
197: int bomb = 0;
198:
199: resfonts();
200: dfb = fopen(file, "r");
201: if (dfb == NULL) {
202: unlink(file);
203: return (0);
204: }
205: banner[0] = '\0';
206: for(*banbuf= plot= 0; getline();) switch(line[0]) {
207:
208: case 'L':
209: strcpy(banbuf, line + 1);
210: continue;
211:
212: case 'B': /* banner */
213: if(banner[0] == '\0')
214: strcat(banner, line + 1);
215: else {
216: strcat(banner,"\n");
217: strcat(banner, line+1);
218: }
219: continue;
220:
221: case '1':
222: case '2':
223: case '3':
224: case '4':
225: strcpy(fonts[line[0]-'1'], line + 1);
226: continue;
227:
228: case 'C': /* called by cifplot */
229: case 'V': /* called by vplot */
230: case 'F':
231: case 'G': /* Like f, but invoke vpf with -l flag. */
232: case 'T':
233: status.w_status = send(line[0]);
234: break;
235:
236: case 'P':
237: if (plot) {
238: plot = 0;
239: status.w_status = send(line[0]);
240: break;
241: }
242: strcpy(linep, line + 1);
243: plot++;
244: continue;
245:
246: case 'U':
247: continue;
248:
249: case 'M':
250: continue;
251: }
252: /*
253: * If the process that did the work did an exit(1),
254: * we should requeue the file.
255: */
256: if (!WIFEXITED(status) || status.w_retcode > 1) {
257: ioctl(3, VSETSTATE, prtmode);
258: write(3, "\nDAEMON MALFUNCTION\n", 20);
259: feedpage();
260: bomb++;
261: } else if (status.w_retcode == 1 && okreque)
262: return (1);
263: /*
264: * All done, for better or for worse.
265: */
266: fseek(dfb, 0, 0);
267: while (getline()) switch (*line) {
268:
269: default:
270: continue;
271:
272: case 'U':
273: unlink(line + 1);
274: continue;
275:
276: case 'M':
277: sendmail(bomb);
278: continue;
279: }
280: remret:
281: fclose(dfb);
282: unlink(file);
283: return (0);
284: }
285:
286: static char ifonts[4][50] = {
287: "/usr/lib/vfont/R",
288: "/usr/lib/vfont/I",
289: "/usr/lib/vfont/B",
290: "/usr/lib/vfont/S"
291: };
292:
293: resfonts()
294: {
295: int i;
296: for (i = 0; i < 4; i++)
297: strcpy(fonts[i], ifonts[i]);
298: }
299:
300: sendmail(bomb)
301: int bomb;
302: {
303: static int p[2];
304: register i;
305: int stat;
306:
307: pipe(p);
308: if (fork() == 0) {
309: alarm(0);
310: close(0);
311: dup(p[0]);
312: for (i = 3; i <= 15; i++)
313: close(i);
314: execl("/bin/mail", "mail", &line[1], 0);
315: exit(0);
316: }
317: close(1);
318: dup(p[1]);
319: printf("Your %s job %s\n", NAME, bomb ? "screwed up" : "is done");
320: close(1);
321: close(p[0]);
322: close(p[1]);
323: open("/", 0);
324: wait(&stat);
325: }
326:
327: getline()
328: {
329: register char *lp;
330: register int c;
331:
332: lp = line;
333: linel = 0;
334: while ((c = getc (dfb)) != '\n') {
335: if (c < 0)
336: return (0);
337: if (c == '\t') {
338: do {
339: *lp++ = ' ';
340: linel++;
341: } while ((linel & 07) != 0);
342: continue;
343: }
344: *lp++ = c;
345: linel++;
346: }
347: *lp++ = 0;
348: return (1);
349: }
350:
351: int pid;
352:
353: send (c)
354: char c;
355: {
356: int p, i, rm;
357:
358: if (pid = fork ()) {
359: if (pid == -1)
360: return (1);
361: setexit();
362: signal(SIGALRM, onalrm);
363: alarm(30);
364: wait(&p);
365: alarm(0);
366: return(p);
367: }
368: ioctl (3, VSETSTATE, prtmode);
369: switch (c) {
370:
371: case 'F':
372: if (banbuf[0]) {
373: execl ("/usr/lib/vpf", "vpf",
374: #ifdef VERSATEC
375: "-W",
376: #endif
377: "-b", banbuf, line+1, 0);
378: break;
379: }
380: execl ("/usr/lib/vpf", "vpf",
381: #ifdef VERSATEC
382: "-W",
383: #endif
384: line, 0);
385: break;
386:
387: case 'G': /* Like F (vpf), but passes through -l
388: flag to vpf (print control chars). */
389: if (banbuf[0]) {
390: execl ("/usr/lib/vpf", "vpf", "-l",
391: #ifdef VERSATEC
392: "-W",
393: #endif
394: "-b", banbuf, line+1, 0);
395: break;
396: }
397: execl ("/usr/lib/vpf", "vpf", "-l",
398: #ifdef VERSATEC
399: "-W",
400: #endif
401: line, 0);
402: break;
403:
404: case 'T':
405: unlink(".railmag");
406: rm = creat(".railmag", 0666);
407: for (i = 0; i < 4; i++) {
408: if (fonts[i][0] != '/')
409: write(rm, "/usr/lib/vfont/", 15);
410: write(rm, fonts[i], strlen (fonts[i]));
411: write(rm, "\n", 1);
412: }
413: close(rm);
414: if (banbuf[0]) {
415: #ifdef VARIAN
416: execl("/usr/lib/rvcat", "rvcat",
417: #endif
418: #ifdef VERSATEC
419: execl("/usr/lib/vcat", "rvcat",
420: "-W",
421: #endif
422: "-3", "-b", banbuf, line+1, 0);
423: break;
424: }
425: #ifdef VARIAN
426: execl("/usr/lib/rvcat", "rvcat",
427: #endif
428: #ifdef VERSATEC
429: execl("/usr/lib/vcat", "rvcat",
430: "-W",
431: #endif
432: "-3", line+1, 0);
433: break;
434:
435: case 'P':
436: close(1);
437: dup(3);
438: if (banbuf[0]) {
439: execl(VRAST, "vrast",
440: #ifdef VERSATEC
441: "-W",
442: #endif
443: "-v", "-b", banbuf, line+1, linep, 0);
444: break;
445: }
446: execl(VRAST, "vrast",
447: #ifdef VERSATEC
448: "-W",
449: #endif
450: "-v", line+1, linep, 0);
451: break;
452: case 'C':
453: execl(VDMP,"vdmp","-n",banbuf,"-b",banner,
454: #ifdef VERSATEC
455: "-W",
456: #endif
457: line+1,0);
458: break;
459: case 'V':
460: execl(VPLTDMP,"vpltdmp","-n",banbuf,"-b",banner,
461: #ifdef VERSATEC
462: "-W",
463: #endif
464: line+1,0);
465: break;
466: }
467: exit(2); /* execl failed or not one of above cases. */
468: }
469:
470: onalrm()
471: {
472: struct stat stb;
473:
474: signal(SIGALRM, onalrm);
475: if (stat(dfname, &stb) < 0)
476: kill(pid, SIGEMT);
477: reset();
478: }
479:
480: /*
481: * skip 16 inches or do two formfeeds.
482: */
483: lastpage()
484: {
485: register int i;
486:
487: ioctl(3, VSETSTATE, prtmode);
488: #ifdef VARIAN
489: write(3, "\014\014", 2);
490: #endif
491: #ifdef VERSATEC
492: for (i = 0; i < 18; i++)
493: write(3, "\n\n\n\n\n\n\n\n", 8);
494: #endif
495: }
496:
497: feedpage()
498: {
499:
500: ioctl(3, VSETSTATE, prtmode);
501: #ifdef VARIAN
502: write(3, "\014\0", 2);
503: #endif
504: #ifdef VERSATEC
505: write(3, "\n\n\n", 8);
506: #endif
507: }
508:
509: prcons(cp, a1, a2, a3, a4, a5)
510: char *cp;
511: {
512: char buf[BUFSIZ];
513: int f = open(CONSOLE, 1);
514:
515: sprintf(buf, cp, a1, a2, a3, a4, a5);
516: write(f, buf, strlen(buf));
517: close(f);
518: }
This archive runs on limited infrastructure. Preserving old code on modern bandwidth. Automated agents are requested to crawl responsibly.