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
34static 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
41static 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
81static char	*args2line(int argc, char **argv);
82static int	 doarg(char *_job);
83static int	 doselect(const struct dirent *_d);
84static int	 kill_qtask(const char *lf);
85static int	 sortq(const struct dirent **a, const struct dirent **b);
86static int	 touch(struct jobqueue *_jq);
87static void	 unlinkf(char *_name);
88static void	 upstat(struct printer *_pp, const char *_msg, int _notify);
89static void	 wrapup_clean(int _laststatus);
90
91/*
92 * generic framework for commands which operate on all or a specified
93 * set of printers
94 */
95enum	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
102static enum qsel_val generic_qselect;	/* indicates how ptr was selected */
103static int generic_initerr;		/* result of initrtn processing */
104static char *generic_cmdname;
105static char *generic_msg;		/* if a -msg was specified */
106static char *generic_nullarg;
107static void (*generic_wrapup)(int _last_status);   /* perform rtn wrap-up */
108
109void
110generic(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);
213looperr:
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
249wrapup:
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 */
261static char *
262args2line(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 */
287static int
288kill_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
350killdone:
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 */
374static void
375upstat(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 */
406void
407abort_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 */
455static time_t	 cln_now;		/* current time */
456static double	 cln_minage;		/* minimum age before file is removed */
457static long	 cln_sizecnt;		/* amount of space freed up */
458static int 	 cln_debug;		/* print extra debugging msgs */
459static int	 cln_filecnt;		/* number of files destroyed */
460static int	 cln_foundcore;		/* found a core file! */
461static int	 cln_queuecnt;		/* number of queues checked */
462static int 	 cln_testonly;		/* remove-files vs just-print-info */
463
464static int
465doselect(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 */
499static int
500sortq(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
610have_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
620void
621clean_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
651void
652tclean_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
663void
664clean_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
772static void
773wrapup_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
787static void
788unlinkf(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 */
877void
878enable_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 */
892void
893disable_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 */
914void
915down_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
944void
945down_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 */
961void
962quit(int argc __unused, char *argv[] __unused)
963{
964	exit(0);
965}
966
967/*
968 * Kill and restart the daemon.
969 */
970void
971restart_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 */
1002void
1003setstatus_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
1012void
1013setstatus_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 */
1044void
1045start_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 */
1068void
1069status(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 */
1131void
1132stop_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
1146struct	jobqueue **queue;
1147int	nitems;
1148time_t	mtime;
1149
1150/*
1151 * Put the specified jobs at the top of printer queue.
1152 */
1153void
1154topq(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
1217out:
1218	PRIV_END
1219}
1220
1221/*
1222 * Reposition the job by changing the modification time of
1223 * the control file.
1224 */
1225static int
1226touch(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 */
1243static int
1244doarg(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 */
1314void
1315up_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