1 /*-
2 * SPDX-License-Identifier: BSD-3-Clause
3 *
4 * Copyright (c) 1983, 1993
5 * The Regents of the University of California. All rights reserved.
6 *
7 *
8 * Redistribution and use in source and binary forms, with or without
9 * modification, are permitted provided that the following conditions
10 * are met:
11 * 1. Redistributions of source code must retain the above copyright
12 * notice, this list of conditions and the following disclaimer.
13 * 2. Redistributions in binary form must reproduce the above copyright
14 * notice, this list of conditions and the following disclaimer in the
15 * documentation and/or other materials provided with the distribution.
16 * 3. Neither the name of the University nor the names of its contributors
17 * may be used to endorse or promote products derived from this software
18 * without specific prior written permission.
19 *
20 * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
21 * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
22 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
23 * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
24 * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
25 * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
26 * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
27 * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
28 * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
29 * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
30 * SUCH DAMAGE.
31 */
32
33 #ifndef lint
34 static const char copyright[] =
35 "@(#) Copyright (c) 1983, 1993\n\
36 The Regents of the University of California. All rights reserved.\n";
37 #endif /* not lint */
38
39 #if 0
40 #ifndef lint
41 static char sccsid[] = "@(#)cmds.c 8.2 (Berkeley) 4/28/95";
42 #endif /* not lint */
43 #endif
44
45 #include "lp.cdefs.h" /* A cross-platform version of <sys/cdefs.h> */
46 __FBSDID("$FreeBSD$");
47
48 /*
49 * lpc -- line printer control program -- commands:
50 */
51
52 #include <sys/param.h>
53 #include <sys/time.h>
54 #include <sys/stat.h>
55 #include <sys/file.h>
56
57 #include <signal.h>
58 #include <fcntl.h>
59 #include <err.h>
60 #include <errno.h>
61 #include <dirent.h>
62 #include <unistd.h>
63 #include <stdlib.h>
64 #include <stdio.h>
65 #include <ctype.h>
66 #include <string.h>
67 #include "lp.h"
68 #include "lp.local.h"
69 #include "lpc.h"
70 #include "extern.h"
71 #include "pathnames.h"
72
73 /*
74 * Return values from kill_qtask().
75 */
76 #define KQT_LFERROR -2
77 #define KQT_KILLFAIL -1
78 #define KQT_NODAEMON 0
79 #define KQT_KILLOK 1
80
81 static char *args2line(int argc, char **argv);
82 static int doarg(char *_job);
83 static int doselect(const struct dirent *_d);
84 static int kill_qtask(const char *lf);
85 static int sortq(const struct dirent **a, const struct dirent **b);
86 static int touch(struct jobqueue *_jq);
87 static void unlinkf(char *_name);
88 static void upstat(struct printer *_pp, const char *_msg, int _notify);
89 static void wrapup_clean(int _laststatus);
90
91 /*
92 * generic framework for commands which operate on all or a specified
93 * set of printers
94 */
95 enum qsel_val { /* how a given ptr was selected */
96 QSEL_UNKNOWN = -1, /* ... not selected yet */
97 QSEL_BYNAME = 0, /* ... user specifed it by name */
98 QSEL_ALL = 1 /* ... user wants "all" printers */
99 /* (with more to come) */
100 };
101
102 static enum qsel_val generic_qselect; /* indicates how ptr was selected */
103 static int generic_initerr; /* result of initrtn processing */
104 static char *generic_cmdname;
105 static char *generic_msg; /* if a -msg was specified */
106 static char *generic_nullarg;
107 static void (*generic_wrapup)(int _last_status); /* perform rtn wrap-up */
108
109 void
generic(void (* specificrtn)(struct printer * _pp),int cmdopts,void (* initrtn)(int _argc,char * _argv[]),int argc,char * argv[])110 generic(void (*specificrtn)(struct printer *_pp), int cmdopts,
111 void (*initrtn)(int _argc, char *_argv[]), int argc, char *argv[])
112 {
113 int cmdstatus, more, targc;
114 struct printer myprinter, *pp;
115 char **margv, **targv;
116
117 if (argc == 1) {
118 /*
119 * Usage needs a special case for 'down': The user must
120 * either include `-msg', or only the first parameter
121 * that they give will be processed as a printer name.
122 */
123 printf("usage: %s {all | printer ...}", argv[0]);
124 if (strcmp(argv[0], "down") == 0) {
125 printf(" -msg [<text> ...]\n");
126 printf(" or: down {all | printer} [<text> ...]");
127 } else if (cmdopts & LPC_MSGOPT)
128 printf(" [-msg <text> ...]");
129 printf("\n");
130 return;
131 }
132
133 /* The first argument is the command name. */
134 generic_cmdname = *argv++;
135 argc--;
136
137 /*
138 * The initialization routine for a command might set a generic
139 * "wrapup" routine, which should be called after processing all
140 * the printers in the command. This might print summary info.
141 *
142 * Note that the initialization routine may also parse (and
143 * nullify) some of the parameters given on the command, leaving
144 * only the parameters which have to do with printer names.
145 */
146 pp = &myprinter;
147 generic_wrapup = NULL;
148 generic_qselect = QSEL_UNKNOWN;
149 cmdstatus = 0;
150 /* this just needs to be a distinct value of type 'char *' */
151 if (generic_nullarg == NULL)
152 generic_nullarg = strdup("");
153
154 /*
155 * Some commands accept a -msg argument, which indicates that
156 * all remaining arguments should be combined into a string.
157 */
158 generic_msg = NULL;
159 if (cmdopts & LPC_MSGOPT) {
160 targc = argc;
161 targv = argv;
162 for (; targc > 0; targc--, targv++) {
163 if (strcmp(*targv, "-msg") == 0) {
164 argc -= targc;
165 generic_msg = args2line(targc - 1, targv + 1);
166 break;
167 }
168 }
169 if (argc < 1) {
170 printf("error: No printer name(s) specified before"
171 " '-msg'.\n");
172 printf("usage: %s {all | printer ...}",
173 generic_cmdname);
174 printf(" [-msg <text> ...]\n");
175 return;
176 }
177 }
178
179 /* call initialization routine, if there is one for this cmd */
180 if (initrtn != NULL) {
181 generic_initerr = 0;
182 (*initrtn)(argc, argv);
183 if (generic_initerr)
184 return;
185 /*
186 * The initrtn may have null'ed out some of the parameters.
187 * Compact the parameter list to remove those nulls, and
188 * correct the arg-count.
189 */
190 targc = argc;
191 targv = argv;
192 margv = argv;
193 argc = 0;
194 for (; targc > 0; targc--, targv++) {
195 if (*targv != generic_nullarg) {
196 if (targv != margv)
197 *margv = *targv;
198 margv++;
199 argc++;
200 }
201 }
202 }
203
204 if (argc == 1 && strcmp(*argv, "all") == 0) {
205 generic_qselect = QSEL_ALL;
206 more = firstprinter(pp, &cmdstatus);
207 if (cmdstatus)
208 goto looperr;
209 while (more) {
210 (*specificrtn)(pp);
211 do {
212 more = nextprinter(pp, &cmdstatus);
213 looperr:
214 switch (cmdstatus) {
215 case PCAPERR_TCOPEN:
216 printf("warning: %s: unresolved "
217 "tc= reference(s) ",
218 pp->printer);
219 case PCAPERR_SUCCESS:
220 break;
221 default:
222 fatal(pp, "%s", pcaperr(cmdstatus));
223 }
224 } while (more && cmdstatus);
225 }
226 goto wrapup;
227 }
228
229 generic_qselect = QSEL_BYNAME; /* specifically-named ptrs */
230 for (; argc > 0; argc--, argv++) {
231 init_printer(pp);
232 cmdstatus = getprintcap(*argv, pp);
233 switch (cmdstatus) {
234 default:
235 fatal(pp, "%s", pcaperr(cmdstatus));
236 case PCAPERR_NOTFOUND:
237 printf("unknown printer %s\n", *argv);
238 continue;
239 case PCAPERR_TCOPEN:
240 printf("warning: %s: unresolved tc= reference(s)\n",
241 *argv);
242 break;
243 case PCAPERR_SUCCESS:
244 break;
245 }
246 (*specificrtn)(pp);
247 }
248
249 wrapup:
250 if (generic_wrapup) {
251 (*generic_wrapup)(cmdstatus);
252 }
253 free_printer(pp);
254 if (generic_msg)
255 free(generic_msg);
256 }
257
258 /*
259 * Convert an argv-array of character strings into a single string.
260 */
261 static char *
args2line(int argc,char ** argv)262 args2line(int argc, char **argv)
263 {
264 char *cp1, *cend;
265 const char *cp2;
266 char buf[1024];
267
268 if (argc <= 0)
269 return strdup("\n");
270
271 cp1 = buf;
272 cend = buf + sizeof(buf) - 1; /* save room for '\0' */
273 while (--argc >= 0) {
274 cp2 = *argv++;
275 while ((cp1 < cend) && (*cp1++ = *cp2++))
276 ;
277 cp1[-1] = ' ';
278 }
279 cp1[-1] = '\n';
280 *cp1 = '\0';
281 return strdup(buf);
282 }
283
284 /*
285 * Kill the current daemon, to stop printing of the active job.
286 */
287 static int
kill_qtask(const char * lf)288 kill_qtask(const char *lf)
289 {
290 FILE *fp;
291 pid_t pid;
292 int errsav, killres, lockres, res;
293
294 PRIV_START
295 fp = fopen(lf, "r");
296 errsav = errno;
297 PRIV_END
298 res = KQT_NODAEMON;
299 if (fp == NULL) {
300 /*
301 * If there is no lock file, then there is no daemon to
302 * kill. Any other error return means there is some
303 * kind of problem with the lock file.
304 */
305 if (errsav != ENOENT)
306 res = KQT_LFERROR;
307 goto killdone;
308 }
309
310 /* If the lock file is empty, then there is no daemon to kill */
311 if (get_line(fp) == 0)
312 goto killdone;
313
314 /*
315 * If the file can be locked without blocking, then there
316 * no daemon to kill, or we should not try to kill it.
317 *
318 * XXX - not sure I understand the reasoning behind this...
319 */
320 lockres = flock(fileno(fp), LOCK_SH|LOCK_NB);
321 (void) fclose(fp);
322 if (lockres == 0)
323 goto killdone;
324
325 pid = atoi(line);
326 if (pid < 0) {
327 /*
328 * If we got a negative pid, then the contents of the
329 * lock file is not valid.
330 */
331 res = KQT_LFERROR;
332 goto killdone;
333 }
334
335 PRIV_END
336 killres = kill(pid, SIGTERM);
337 errsav = errno;
338 PRIV_END
339 if (killres == 0) {
340 res = KQT_KILLOK;
341 printf("\tdaemon (pid %d) killed\n", pid);
342 } else if (errno == ESRCH) {
343 res = KQT_NODAEMON;
344 } else {
345 res = KQT_KILLFAIL;
346 printf("\tWarning: daemon (pid %d) not killed:\n", pid);
347 printf("\t %s\n", strerror(errsav));
348 }
349
350 killdone:
351 switch (res) {
352 case KQT_LFERROR:
353 printf("\tcannot open lock file: %s\n",
354 strerror(errsav));
355 break;
356 case KQT_NODAEMON:
357 printf("\tno daemon to abort\n");
358 break;
359 case KQT_KILLFAIL:
360 case KQT_KILLOK:
361 /* These two already printed messages to the user. */
362 break;
363 default:
364 printf("\t<internal error in kill_qtask>\n");
365 break;
366 }
367
368 return (res);
369 }
370
371 /*
372 * Write a message into the status file.
373 */
374 static void
upstat(struct printer * pp,const char * msg,int notifyuser)375 upstat(struct printer *pp, const char *msg, int notifyuser)
376 {
377 int fd;
378 char statfile[MAXPATHLEN];
379
380 status_file_name(pp, statfile, sizeof statfile);
381 umask(0);
382 PRIV_START
383 fd = open(statfile, O_WRONLY|O_CREAT|O_EXLOCK, STAT_FILE_MODE);
384 PRIV_END
385 if (fd < 0) {
386 printf("\tcannot create status file: %s\n", strerror(errno));
387 return;
388 }
389 (void) ftruncate(fd, 0);
390 if (msg == NULL)
391 (void) write(fd, "\n", 1);
392 else
393 (void) write(fd, msg, strlen(msg));
394 (void) close(fd);
395 if (notifyuser) {
396 if ((msg == (char *)NULL) || (strcmp(msg, "\n") == 0))
397 printf("\tstatus message is now set to nothing.\n");
398 else
399 printf("\tstatus message is now: %s", msg);
400 }
401 }
402
403 /*
404 * kill an existing daemon and disable printing.
405 */
406 void
abort_q(struct printer * pp)407 abort_q(struct printer *pp)
408 {
409 int killres, setres;
410 char lf[MAXPATHLEN];
411
412 lock_file_name(pp, lf, sizeof lf);
413 printf("%s:\n", pp->printer);
414
415 /*
416 * Turn on the owner execute bit of the lock file to disable printing.
417 */
418 setres = set_qstate(SQS_STOPP, lf);
419
420 /*
421 * If set_qstate found that there already was a lock file, then
422 * call a routine which will read that lock file and kill the
423 * lpd-process which is listed in that lock file. If the lock
424 * file did not exist, then either there is no daemon running
425 * for this queue, or there is one running but *it* could not
426 * write a lock file (which means we can not determine the
427 * process id of that lpd-process).
428 */
429 switch (setres) {
430 case SQS_CHGOK:
431 case SQS_CHGFAIL:
432 /* Kill the process */
433 killres = kill_qtask(lf);
434 break;
435 case SQS_CREOK:
436 case SQS_CREFAIL:
437 printf("\tno daemon to abort\n");
438 break;
439 case SQS_STATFAIL:
440 printf("\tassuming no daemon to abort\n");
441 break;
442 default:
443 printf("\t<unexpected result (%d) from set_qstate>\n",
444 setres);
445 break;
446 }
447
448 if (setres >= 0)
449 upstat(pp, "printing disabled\n", 0);
450 }
451
452 /*
453 * "global" variables for all the routines related to 'clean' and 'tclean'
454 */
455 static time_t cln_now; /* current time */
456 static double cln_minage; /* minimum age before file is removed */
457 static long cln_sizecnt; /* amount of space freed up */
458 static int cln_debug; /* print extra debugging msgs */
459 static int cln_filecnt; /* number of files destroyed */
460 static int cln_foundcore; /* found a core file! */
461 static int cln_queuecnt; /* number of queues checked */
462 static int cln_testonly; /* remove-files vs just-print-info */
463
464 static int
doselect(const struct dirent * d)465 doselect(const struct dirent *d)
466 {
467 int c = d->d_name[0];
468
469 if ((c == 'c' || c == 'd' || c == 'r' || c == 't') &&
470 d->d_name[1] == 'f')
471 return 1;
472 if (c == 'c') {
473 if (!strcmp(d->d_name, "core"))
474 cln_foundcore = 1;
475 }
476 if (c == 'e') {
477 if (!strncmp(d->d_name, "errs.", 5))
478 return 1;
479 }
480 return 0;
481 }
482
483 /*
484 * Comparison routine that clean_q() uses for scandir.
485 *
486 * The purpose of this sort is to have all `df' files end up immediately
487 * after the matching `cf' file. For files matching `cf', `df', `rf', or
488 * `tf', it sorts by job number and machine, then by `cf', `df', `rf', or
489 * `tf', and then by the sequence letter (which is A-Z, or a-z). This
490 * routine may also see filenames which do not start with `cf', `df', `rf',
491 * or `tf' (such as `errs.*'), and those are simply sorted by the full
492 * filename.
493 *
494 * XXX
495 * This assumes that all control files start with `cfA*', and it turns
496 * out there are a few implementations of lpr which will create `cfB*'
497 * filenames (they will have datafile names which start with `dfB*').
498 */
499 static int
sortq(const struct dirent ** a,const struct dirent ** b)500 sortq(const struct dirent **a, const struct dirent **b)
501 {
502 const int a_lt_b = -1, a_gt_b = 1, cat_other = 10;
503 const char *fname_a, *fname_b, *jnum_a, *jnum_b;
504 int cat_a, cat_b, ch, res, seq_a, seq_b;
505
506 fname_a = (*a)->d_name;
507 fname_b = (*b)->d_name;
508
509 /*
510 * First separate filenames into categories. Categories are
511 * legitimate `cf', `df', `rf' & `tf' filenames, and "other" - in
512 * that order. It is critical that the mapping be exactly the
513 * same for 'a' vs 'b', so define a macro for the job.
514 *
515 * [aside: the standard `cf' file has the jobnumber start in
516 * position 4, but some implementations have that as an extra
517 * file-sequence letter, and start the job number in position 5.]
518 */
519 #define MAP_TO_CAT(fname_X,cat_X,jnum_X,seq_X) do { \
520 cat_X = cat_other; \
521 ch = *(fname_X + 2); \
522 jnum_X = fname_X + 3; \
523 seq_X = 0; \
524 if ((*(fname_X + 1) == 'f') && (isalpha(ch))) { \
525 seq_X = ch; \
526 if (*fname_X == 'c') \
527 cat_X = 1; \
528 else if (*fname_X == 'd') \
529 cat_X = 2; \
530 else if (*fname_X == 'r') \
531 cat_X = 3; \
532 else if (*fname_X == 't') \
533 cat_X = 4; \
534 if (cat_X != cat_other) { \
535 ch = *jnum_X; \
536 if (!isdigit(ch)) { \
537 if (isalpha(ch)) { \
538 jnum_X++; \
539 ch = *jnum_X; \
540 seq_X = (seq_X << 8) + ch; \
541 } \
542 if (!isdigit(ch)) \
543 cat_X = cat_other; \
544 } \
545 } \
546 } \
547 } while (0)
548
549 MAP_TO_CAT(fname_a, cat_a, jnum_a, seq_a);
550 MAP_TO_CAT(fname_b, cat_b, jnum_b, seq_b);
551
552 #undef MAP_TO_CAT
553
554 /* First handle all cases which have "other" files */
555 if ((cat_a >= cat_other) || (cat_b >= cat_other)) {
556 /* for two "other" files, just compare the full name */
557 if (cat_a == cat_b)
558 res = strcmp(fname_a, fname_b);
559 else if (cat_a < cat_b)
560 res = a_lt_b;
561 else
562 res = a_gt_b;
563 goto have_res;
564 }
565
566 /*
567 * At this point, we know both files are legitimate `cf', `df', `rf',
568 * or `tf' files. Compare them by job-number and machine name.
569 */
570 res = strcmp(jnum_a, jnum_b);
571 if (res != 0)
572 goto have_res;
573
574 /*
575 * We have two files which belong to the same job. Sort based
576 * on the category of file (`c' before `d', etc).
577 */
578 if (cat_a < cat_b) {
579 res = a_lt_b;
580 goto have_res;
581 } else if (cat_a > cat_b) {
582 res = a_gt_b;
583 goto have_res;
584 }
585
586 /*
587 * Two files in the same category for a single job. Sort based
588 * on the sequence letter(s). (usually `A' through `Z', etc).
589 */
590 if (seq_a < seq_b) {
591 res = a_lt_b;
592 goto have_res;
593 } else if (seq_a > seq_b) {
594 res = a_gt_b;
595 goto have_res;
596 }
597
598 /*
599 * Given that the filenames in a directory are unique, this SHOULD
600 * never happen (unless there are logic errors in this routine).
601 * But if it does happen, we must return "is equal" or the caller
602 * might see inconsistent results in the sorting order, and that
603 * can trigger other problems.
604 */
605 printf("\t*** Error in sortq: %s == %s !\n", fname_a, fname_b);
606 printf("\t*** cat %d == %d ; seq = %d %d\n", cat_a, cat_b,
607 seq_a, seq_b);
608 res = 0;
609
610 have_res:
611 return res;
612 }
613
614 /*
615 * Remove all spool files and temporaries from the spooling area.
616 * Or, perhaps:
617 * Remove incomplete jobs from spooling area.
618 */
619
620 void
clean_gi(int argc,char * argv[])621 clean_gi(int argc, char *argv[])
622 {
623
624 /* init some fields before 'clean' is called for each queue */
625 cln_queuecnt = 0;
626 cln_now = time(NULL);
627 cln_minage = 3600.0; /* only delete files >1h old */
628 cln_filecnt = 0;
629 cln_sizecnt = 0;
630 cln_debug = 0;
631 cln_testonly = 0;
632 generic_wrapup = &wrapup_clean;
633
634 /* see if there are any options specified before the ptr list */
635 for (; argc > 0; argc--, argv++) {
636 if (**argv != '-')
637 break;
638 if (strcmp(*argv, "-d") == 0) {
639 /* just an example of an option... */
640 cln_debug++;
641 *argv = generic_nullarg; /* "erase" it */
642 } else {
643 printf("Invalid option '%s'\n", *argv);
644 generic_initerr = 1;
645 }
646 }
647
648 return;
649 }
650
651 void
tclean_gi(int argc,char * argv[])652 tclean_gi(int argc, char *argv[])
653 {
654
655 /* only difference between 'clean' and 'tclean' is one value */
656 /* (...and the fact that 'clean' is priv and 'tclean' is not) */
657 clean_gi(argc, argv);
658 cln_testonly = 1;
659
660 return;
661 }
662
663 void
clean_q(struct printer * pp)664 clean_q(struct printer *pp)
665 {
666 char *cp, *cp1, *lp;
667 struct dirent **queue;
668 size_t linerem;
669 int didhead, i, n, nitems, rmcp;
670
671 cln_queuecnt++;
672
673 didhead = 0;
674 if (generic_qselect == QSEL_BYNAME) {
675 printf("%s:\n", pp->printer);
676 didhead = 1;
677 }
678
679 lp = line;
680 cp = pp->spool_dir;
681 while (lp < &line[sizeof(line) - 1]) {
682 if ((*lp++ = *cp++) == 0)
683 break;
684 }
685 lp[-1] = '/';
686 linerem = sizeof(line) - (lp - line);
687
688 cln_foundcore = 0;
689 PRIV_START
690 nitems = scandir(pp->spool_dir, &queue, doselect, sortq);
691 PRIV_END
692 if (nitems < 0) {
693 if (!didhead) {
694 printf("%s:\n", pp->printer);
695 didhead = 1;
696 }
697 printf("\tcannot examine spool directory\n");
698 return;
699 }
700 if (cln_foundcore) {
701 if (!didhead) {
702 printf("%s:\n", pp->printer);
703 didhead = 1;
704 }
705 printf("\t** found a core file in %s !\n", pp->spool_dir);
706 }
707 if (nitems == 0)
708 return;
709 if (!didhead)
710 printf("%s:\n", pp->printer);
711 if (cln_debug) {
712 printf("\t** ----- Sorted list of files being checked:\n");
713 i = 0;
714 do {
715 cp = queue[i]->d_name;
716 printf("\t** [%3d] = %s\n", i, cp);
717 } while (++i < nitems);
718 printf("\t** ----- end of sorted list\n");
719 }
720 i = 0;
721 do {
722 cp = queue[i]->d_name;
723 rmcp = 0;
724 if (*cp == 'c') {
725 /*
726 * A control file. Look for matching data-files.
727 */
728 /* XXX
729 * Note the logic here assumes that the hostname
730 * part of cf-filenames match the hostname part
731 * in df-filenames, and that is not necessarily
732 * true (eg: for multi-homed hosts). This needs
733 * some further thought...
734 */
735 n = 0;
736 while (i + 1 < nitems) {
737 cp1 = queue[i + 1]->d_name;
738 if (*cp1 != 'd' || strcmp(cp + 3, cp1 + 3))
739 break;
740 i++;
741 n++;
742 }
743 if (n == 0) {
744 rmcp = 1;
745 }
746 } else if (*cp == 'e') {
747 /*
748 * Must be an errrs or email temp file.
749 */
750 rmcp = 1;
751 } else {
752 /*
753 * Must be a df with no cf (otherwise, it would have
754 * been skipped above) or an rf or tf file (which can
755 * always be removed if it is old enough).
756 */
757 rmcp = 1;
758 }
759 if (rmcp) {
760 if (strlen(cp) >= linerem) {
761 printf("\t** internal error: 'line' overflow!\n");
762 printf("\t** spooldir = %s\n", pp->spool_dir);
763 printf("\t** cp = %s\n", cp);
764 return;
765 }
766 strlcpy(lp, cp, linerem);
767 unlinkf(line);
768 }
769 } while (++i < nitems);
770 }
771
772 static void
wrapup_clean(int laststatus __unused)773 wrapup_clean(int laststatus __unused)
774 {
775
776 printf("Checked %d queues, and ", cln_queuecnt);
777 if (cln_filecnt < 1) {
778 printf("no cruft was found\n");
779 return;
780 }
781 if (cln_testonly) {
782 printf("would have ");
783 }
784 printf("removed %d files (%ld bytes).\n", cln_filecnt, cln_sizecnt);
785 }
786
787 static void
unlinkf(char * name)788 unlinkf(char *name)
789 {
790 struct stat stbuf;
791 double agemod, agestat;
792 int res;
793 char linkbuf[BUFSIZ];
794
795 /*
796 * We have to use lstat() instead of stat(), in case this is a df*
797 * "file" which is really a symlink due to 'lpr -s' processing. In
798 * that case, we need to check the last-mod time of the symlink, and
799 * not the file that the symlink is pointed at.
800 */
801 PRIV_START
802 res = lstat(name, &stbuf);
803 PRIV_END
804 if (res < 0) {
805 printf("\terror return from stat(%s):\n", name);
806 printf("\t %s\n", strerror(errno));
807 return;
808 }
809
810 agemod = difftime(cln_now, stbuf.st_mtime);
811 agestat = difftime(cln_now, stbuf.st_ctime);
812 if (cln_debug > 1) {
813 /* this debugging-aid probably is not needed any more... */
814 printf("\t\t modify age=%g secs, stat age=%g secs\n",
815 agemod, agestat);
816 }
817 if ((agemod <= cln_minage) && (agestat <= cln_minage))
818 return;
819
820 /*
821 * if this file is a symlink, then find out the target of the
822 * symlink before unlink-ing the file itself
823 */
824 if (S_ISLNK(stbuf.st_mode)) {
825 PRIV_START
826 res = readlink(name, linkbuf, sizeof(linkbuf));
827 PRIV_END
828 if (res < 0) {
829 printf("\terror return from readlink(%s):\n", name);
830 printf("\t %s\n", strerror(errno));
831 return;
832 }
833 if (res == sizeof(linkbuf))
834 res--;
835 linkbuf[res] = '\0';
836 }
837
838 cln_filecnt++;
839 cln_sizecnt += stbuf.st_size;
840
841 if (cln_testonly) {
842 printf("\twould remove %s\n", name);
843 if (S_ISLNK(stbuf.st_mode)) {
844 printf("\t (which is a symlink to %s)\n", linkbuf);
845 }
846 } else {
847 PRIV_START
848 res = unlink(name);
849 PRIV_END
850 if (res < 0)
851 printf("\tcannot remove %s (!)\n", name);
852 else
853 printf("\tremoved %s\n", name);
854 /* XXX
855 * Note that for a df* file, this code should also check to see
856 * if it is a symlink to some other file, and if the original
857 * lpr command included '-r' ("remove file"). Of course, this
858 * code would not be removing the df* file unless there was no
859 * matching cf* file, and without the cf* file it is currently
860 * impossible to determine if '-r' had been specified...
861 *
862 * As a result of this quandry, we may be leaving behind a
863 * user's file that was supposed to have been removed after
864 * being printed. This may effect services such as CAP or
865 * samba, if they were configured to use 'lpr -r', and if
866 * datafiles are not being properly removed.
867 */
868 if (S_ISLNK(stbuf.st_mode)) {
869 printf("\t (which was a symlink to %s)\n", linkbuf);
870 }
871 }
872 }
873
874 /*
875 * Enable queuing to the printer (allow lpr to add new jobs to the queue).
876 */
877 void
enable_q(struct printer * pp)878 enable_q(struct printer *pp)
879 {
880 int setres;
881 char lf[MAXPATHLEN];
882
883 lock_file_name(pp, lf, sizeof lf);
884 printf("%s:\n", pp->printer);
885
886 setres = set_qstate(SQS_ENABLEQ, lf);
887 }
888
889 /*
890 * Disable queuing.
891 */
892 void
disable_q(struct printer * pp)893 disable_q(struct printer *pp)
894 {
895 int setres;
896 char lf[MAXPATHLEN];
897
898 lock_file_name(pp, lf, sizeof lf);
899 printf("%s:\n", pp->printer);
900
901 setres = set_qstate(SQS_DISABLEQ, lf);
902 }
903
904 /*
905 * Disable queuing and printing and put a message into the status file
906 * (reason for being down). If the user specified `-msg', then use
907 * everything after that as the message for the status file. If the
908 * user did NOT specify `-msg', then the command should take the first
909 * parameter as the printer name, and all remaining parameters as the
910 * message for the status file. (This is to be compatible with the
911 * original definition of 'down', which was implemented long before
912 * `-msg' was around).
913 */
914 void
down_gi(int argc,char * argv[])915 down_gi(int argc, char *argv[])
916 {
917
918 /* If `-msg' was specified, then this routine has nothing to do. */
919 if (generic_msg != NULL)
920 return;
921
922 /*
923 * If the user only gave one parameter, then use a default msg.
924 * (if argc == 1 at this point, then *argv == name of printer).
925 */
926 if (argc == 1) {
927 generic_msg = strdup("printing disabled\n");
928 return;
929 }
930
931 /*
932 * The user specified multiple parameters, and did not specify
933 * `-msg'. Build a message from all the parameters after the
934 * first one (and nullify those parameters so generic-processing
935 * will not process them as printer-queue names).
936 */
937 argc--;
938 argv++;
939 generic_msg = args2line(argc, argv);
940 for (; argc > 0; argc--, argv++)
941 *argv = generic_nullarg; /* "erase" it */
942 }
943
944 void
down_q(struct printer * pp)945 down_q(struct printer *pp)
946 {
947 int setres;
948 char lf[MAXPATHLEN];
949
950 lock_file_name(pp, lf, sizeof lf);
951 printf("%s:\n", pp->printer);
952
953 setres = set_qstate(SQS_DISABLEQ+SQS_STOPP, lf);
954 if (setres >= 0)
955 upstat(pp, generic_msg, 1);
956 }
957
958 /*
959 * Exit lpc
960 */
961 void
quit(int argc __unused,char * argv[]__unused)962 quit(int argc __unused, char *argv[] __unused)
963 {
964 exit(0);
965 }
966
967 /*
968 * Kill and restart the daemon.
969 */
970 void
restart_q(struct printer * pp)971 restart_q(struct printer *pp)
972 {
973 int killres, setres, startok;
974 char lf[MAXPATHLEN];
975
976 lock_file_name(pp, lf, sizeof lf);
977 printf("%s:\n", pp->printer);
978
979 killres = kill_qtask(lf);
980
981 /*
982 * XXX - if the kill worked, we should probably sleep for
983 * a second or so before trying to restart the queue.
984 */
985
986 /* make sure the queue is set to print jobs */
987 setres = set_qstate(SQS_STARTP, lf);
988
989 PRIV_START
990 startok = startdaemon(pp);
991 PRIV_END
992 if (!startok)
993 printf("\tcouldn't restart daemon\n");
994 else
995 printf("\tdaemon restarted\n");
996 }
997
998 /*
999 * Set the status message of each queue listed. Requires a "-msg"
1000 * parameter to indicate the end of the queue list and start of msg text.
1001 */
1002 void
setstatus_gi(int argc __unused,char * argv[]__unused)1003 setstatus_gi(int argc __unused, char *argv[] __unused)
1004 {
1005
1006 if (generic_msg == NULL) {
1007 printf("You must specify '-msg' before the text of the new status message.\n");
1008 generic_initerr = 1;
1009 }
1010 }
1011
1012 void
setstatus_q(struct printer * pp)1013 setstatus_q(struct printer *pp)
1014 {
1015 struct stat stbuf;
1016 int not_shown;
1017 char lf[MAXPATHLEN];
1018
1019 lock_file_name(pp, lf, sizeof lf);
1020 printf("%s:\n", pp->printer);
1021
1022 upstat(pp, generic_msg, 1);
1023
1024 /*
1025 * Warn the user if 'lpq' will not display this new status-message.
1026 * Note that if lock file does not exist, then the queue is enabled
1027 * for both queuing and printing.
1028 */
1029 not_shown = 1;
1030 if (stat(lf, &stbuf) >= 0) {
1031 if (stbuf.st_mode & LFM_PRINT_DIS)
1032 not_shown = 0;
1033 }
1034 if (not_shown) {
1035 printf("\tnote: This queue currently has printing enabled,\n");
1036 printf("\t so this -msg will only be shown by 'lpq' if\n");
1037 printf("\t a job is actively printing on it.\n");
1038 }
1039 }
1040
1041 /*
1042 * Enable printing on the specified printer and startup the daemon.
1043 */
1044 void
start_q(struct printer * pp)1045 start_q(struct printer *pp)
1046 {
1047 int setres, startok;
1048 char lf[MAXPATHLEN];
1049
1050 lock_file_name(pp, lf, sizeof lf);
1051 printf("%s:\n", pp->printer);
1052
1053 setres = set_qstate(SQS_STARTP, lf);
1054
1055 PRIV_START
1056 startok = startdaemon(pp);
1057 PRIV_END
1058 if (!startok)
1059 printf("\tcouldn't start daemon\n");
1060 else
1061 printf("\tdaemon started\n");
1062 PRIV_END
1063 }
1064
1065 /*
1066 * Print the status of the printer queue.
1067 */
1068 void
status(struct printer * pp)1069 status(struct printer *pp)
1070 {
1071 struct stat stbuf;
1072 register int fd, i;
1073 register struct dirent *dp;
1074 DIR *dirp;
1075 char file[MAXPATHLEN];
1076
1077 printf("%s:\n", pp->printer);
1078 lock_file_name(pp, file, sizeof file);
1079 if (stat(file, &stbuf) >= 0) {
1080 printf("\tqueuing is %s\n",
1081 ((stbuf.st_mode & LFM_QUEUE_DIS) ? "disabled"
1082 : "enabled"));
1083 printf("\tprinting is %s\n",
1084 ((stbuf.st_mode & LFM_PRINT_DIS) ? "disabled"
1085 : "enabled"));
1086 } else {
1087 printf("\tqueuing is enabled\n");
1088 printf("\tprinting is enabled\n");
1089 }
1090 if ((dirp = opendir(pp->spool_dir)) == NULL) {
1091 printf("\tcannot examine spool directory\n");
1092 return;
1093 }
1094 i = 0;
1095 while ((dp = readdir(dirp)) != NULL) {
1096 if (*dp->d_name == 'c' && dp->d_name[1] == 'f')
1097 i++;
1098 }
1099 closedir(dirp);
1100 if (i == 0)
1101 printf("\tno entries in spool area\n");
1102 else if (i == 1)
1103 printf("\t1 entry in spool area\n");
1104 else
1105 printf("\t%d entries in spool area\n", i);
1106 fd = open(file, O_RDONLY);
1107 if (fd < 0 || flock(fd, LOCK_SH|LOCK_NB) == 0) {
1108 (void) close(fd); /* unlocks as well */
1109 printf("\tprinter idle\n");
1110 return;
1111 }
1112 (void) close(fd);
1113 /* print out the contents of the status file, if it exists */
1114 status_file_name(pp, file, sizeof file);
1115 fd = open(file, O_RDONLY|O_SHLOCK);
1116 if (fd >= 0) {
1117 (void) fstat(fd, &stbuf);
1118 if (stbuf.st_size > 0) {
1119 putchar('\t');
1120 while ((i = read(fd, line, sizeof(line))) > 0)
1121 (void) fwrite(line, 1, i, stdout);
1122 }
1123 (void) close(fd); /* unlocks as well */
1124 }
1125 }
1126
1127 /*
1128 * Stop the specified daemon after completing the current job and disable
1129 * printing.
1130 */
1131 void
stop_q(struct printer * pp)1132 stop_q(struct printer *pp)
1133 {
1134 int setres;
1135 char lf[MAXPATHLEN];
1136
1137 lock_file_name(pp, lf, sizeof lf);
1138 printf("%s:\n", pp->printer);
1139
1140 setres = set_qstate(SQS_STOPP, lf);
1141
1142 if (setres >= 0)
1143 upstat(pp, "printing disabled\n", 0);
1144 }
1145
1146 struct jobqueue **queue;
1147 int nitems;
1148 time_t mtime;
1149
1150 /*
1151 * Put the specified jobs at the top of printer queue.
1152 */
1153 void
topq(int argc,char * argv[])1154 topq(int argc, char *argv[])
1155 {
1156 register int i;
1157 struct stat stbuf;
1158 int cmdstatus, changed;
1159 struct printer myprinter, *pp = &myprinter;
1160
1161 if (argc < 3) {
1162 printf("usage: topq printer [jobnum ...] [user ...]\n");
1163 return;
1164 }
1165
1166 --argc;
1167 ++argv;
1168 init_printer(pp);
1169 cmdstatus = getprintcap(*argv, pp);
1170 switch(cmdstatus) {
1171 default:
1172 fatal(pp, "%s", pcaperr(cmdstatus));
1173 case PCAPERR_NOTFOUND:
1174 printf("unknown printer %s\n", *argv);
1175 return;
1176 case PCAPERR_TCOPEN:
1177 printf("warning: %s: unresolved tc= reference(s)", *argv);
1178 break;
1179 case PCAPERR_SUCCESS:
1180 break;
1181 }
1182 printf("%s:\n", pp->printer);
1183
1184 PRIV_START
1185 if (chdir(pp->spool_dir) < 0) {
1186 printf("\tcannot chdir to %s\n", pp->spool_dir);
1187 goto out;
1188 }
1189 PRIV_END
1190 nitems = getq(pp, &queue);
1191 if (nitems == 0)
1192 return;
1193 changed = 0;
1194 mtime = queue[0]->job_time;
1195 for (i = argc; --i; ) {
1196 if (doarg(argv[i]) == 0) {
1197 printf("\tjob %s is not in the queue\n", argv[i]);
1198 continue;
1199 } else
1200 changed++;
1201 }
1202 for (i = 0; i < nitems; i++)
1203 free(queue[i]);
1204 free(queue);
1205 if (!changed) {
1206 printf("\tqueue order unchanged\n");
1207 return;
1208 }
1209 /*
1210 * Turn on the public execute bit of the lock file to
1211 * get lpd to rebuild the queue after the current job.
1212 */
1213 PRIV_START
1214 if (changed && stat(pp->lock_file, &stbuf) >= 0)
1215 (void) chmod(pp->lock_file, stbuf.st_mode | LFM_RESET_QUE);
1216
1217 out:
1218 PRIV_END
1219 }
1220
1221 /*
1222 * Reposition the job by changing the modification time of
1223 * the control file.
1224 */
1225 static int
touch(struct jobqueue * jq)1226 touch(struct jobqueue *jq)
1227 {
1228 struct timeval tvp[2];
1229 int ret;
1230
1231 tvp[0].tv_sec = tvp[1].tv_sec = --mtime;
1232 tvp[0].tv_usec = tvp[1].tv_usec = 0;
1233 PRIV_START
1234 ret = utimes(jq->job_cfname, tvp);
1235 PRIV_END
1236 return (ret);
1237 }
1238
1239 /*
1240 * Checks if specified job name is in the printer's queue.
1241 * Returns: negative (-1) if argument name is not in the queue.
1242 */
1243 static int
doarg(char * job)1244 doarg(char *job)
1245 {
1246 register struct jobqueue **qq;
1247 register int jobnum, n;
1248 register char *cp, *machine;
1249 int cnt = 0;
1250 FILE *fp;
1251
1252 /*
1253 * Look for a job item consisting of system name, colon, number
1254 * (example: ucbarpa:114)
1255 */
1256 if ((cp = strchr(job, ':')) != NULL) {
1257 machine = job;
1258 *cp++ = '\0';
1259 job = cp;
1260 } else
1261 machine = NULL;
1262
1263 /*
1264 * Check for job specified by number (example: 112 or 235ucbarpa).
1265 */
1266 if (isdigit(*job)) {
1267 jobnum = 0;
1268 do
1269 jobnum = jobnum * 10 + (*job++ - '0');
1270 while (isdigit(*job));
1271 for (qq = queue + nitems; --qq >= queue; ) {
1272 n = 0;
1273 for (cp = (*qq)->job_cfname+3; isdigit(*cp); )
1274 n = n * 10 + (*cp++ - '0');
1275 if (jobnum != n)
1276 continue;
1277 if (*job && strcmp(job, cp) != 0)
1278 continue;
1279 if (machine != NULL && strcmp(machine, cp) != 0)
1280 continue;
1281 if (touch(*qq) == 0) {
1282 printf("\tmoved %s\n", (*qq)->job_cfname);
1283 cnt++;
1284 }
1285 }
1286 return(cnt);
1287 }
1288 /*
1289 * Process item consisting of owner's name (example: henry).
1290 */
1291 for (qq = queue + nitems; --qq >= queue; ) {
1292 PRIV_START
1293 fp = fopen((*qq)->job_cfname, "r");
1294 PRIV_END
1295 if (fp == NULL)
1296 continue;
1297 while (get_line(fp) > 0)
1298 if (line[0] == 'P')
1299 break;
1300 (void) fclose(fp);
1301 if (line[0] != 'P' || strcmp(job, line+1) != 0)
1302 continue;
1303 if (touch(*qq) == 0) {
1304 printf("\tmoved %s\n", (*qq)->job_cfname);
1305 cnt++;
1306 }
1307 }
1308 return(cnt);
1309 }
1310
1311 /*
1312 * Enable both queuing & printing, and start printer (undo `down').
1313 */
1314 void
up_q(struct printer * pp)1315 up_q(struct printer *pp)
1316 {
1317 int setres, startok;
1318 char lf[MAXPATHLEN];
1319
1320 lock_file_name(pp, lf, sizeof lf);
1321 printf("%s:\n", pp->printer);
1322
1323 setres = set_qstate(SQS_ENABLEQ+SQS_STARTP, lf);
1324
1325 PRIV_START
1326 startok = startdaemon(pp);
1327 PRIV_END
1328 if (!startok)
1329 printf("\tcouldn't start daemon\n");
1330 else
1331 printf("\tdaemon started\n");
1332 }
1333