xref: /freebsd/usr.sbin/lpr/lpc/cmds.c (revision 82725ba9bf1fd59746a4006a06f24d4d61d142f2)
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
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 *
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
962 quit(int argc __unused, char *argv[] __unused)
963 {
964 	exit(0);
965 }
966 
967 /*
968  * Kill and restart the daemon.
969  */
970 void
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
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
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
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
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
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
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
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
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
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