xref: /freebsd/usr.sbin/lpr/lpc/cmds.c (revision fbbd9655e5107c68e4e0146ff22b73d7350475bc)
1dea673e9SRodney W. Grimes /*
2dea673e9SRodney W. Grimes  * Copyright (c) 1983, 1993
3dea673e9SRodney W. Grimes  *	The Regents of the University of California.  All rights reserved.
4dea673e9SRodney W. Grimes  *
5dea673e9SRodney W. Grimes  *
6dea673e9SRodney W. Grimes  * Redistribution and use in source and binary forms, with or without
7dea673e9SRodney W. Grimes  * modification, are permitted provided that the following conditions
8dea673e9SRodney W. Grimes  * are met:
9dea673e9SRodney W. Grimes  * 1. Redistributions of source code must retain the above copyright
10dea673e9SRodney W. Grimes  *    notice, this list of conditions and the following disclaimer.
11dea673e9SRodney W. Grimes  * 2. Redistributions in binary form must reproduce the above copyright
12dea673e9SRodney W. Grimes  *    notice, this list of conditions and the following disclaimer in the
13dea673e9SRodney W. Grimes  *    documentation and/or other materials provided with the distribution.
14*fbbd9655SWarner Losh  * 3. Neither the name of the University nor the names of its contributors
15dea673e9SRodney W. Grimes  *    may be used to endorse or promote products derived from this software
16dea673e9SRodney W. Grimes  *    without specific prior written permission.
17dea673e9SRodney W. Grimes  *
18dea673e9SRodney W. Grimes  * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
19dea673e9SRodney W. Grimes  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
20dea673e9SRodney W. Grimes  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
21dea673e9SRodney W. Grimes  * ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
22dea673e9SRodney W. Grimes  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
23dea673e9SRodney W. Grimes  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
24dea673e9SRodney W. Grimes  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
25dea673e9SRodney W. Grimes  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
26dea673e9SRodney W. Grimes  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
27dea673e9SRodney W. Grimes  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
28dea673e9SRodney W. Grimes  * SUCH DAMAGE.
29dea673e9SRodney W. Grimes  */
30dea673e9SRodney W. Grimes 
31dea673e9SRodney W. Grimes #ifndef lint
324a1a0dbeSGarrett Wollman static const char copyright[] =
33dea673e9SRodney W. Grimes "@(#) Copyright (c) 1983, 1993\n\
34dea673e9SRodney W. Grimes 	The Regents of the University of California.  All rights reserved.\n";
35dea673e9SRodney W. Grimes #endif /* not lint */
36dea673e9SRodney W. Grimes 
37c44a6dceSGarance A Drosehn #if 0
38dea673e9SRodney W. Grimes #ifndef lint
395458e2f4SJoerg Wunsch static char sccsid[] = "@(#)cmds.c	8.2 (Berkeley) 4/28/95";
40dea673e9SRodney W. Grimes #endif /* not lint */
41c44a6dceSGarance A Drosehn #endif
42c44a6dceSGarance A Drosehn 
43c44a6dceSGarance A Drosehn #include "lp.cdefs.h"		/* A cross-platform version of <sys/cdefs.h> */
44c44a6dceSGarance A Drosehn __FBSDID("$FreeBSD$");
45dea673e9SRodney W. Grimes 
46dea673e9SRodney W. Grimes /*
47dea673e9SRodney W. Grimes  * lpc -- line printer control program -- commands:
48dea673e9SRodney W. Grimes  */
49dea673e9SRodney W. Grimes 
50dea673e9SRodney W. Grimes #include <sys/param.h>
51dea673e9SRodney W. Grimes #include <sys/time.h>
52dea673e9SRodney W. Grimes #include <sys/stat.h>
535458e2f4SJoerg Wunsch #include <sys/file.h>
54dea673e9SRodney W. Grimes 
55dea673e9SRodney W. Grimes #include <signal.h>
56dea673e9SRodney W. Grimes #include <fcntl.h>
571d1d4a47SEitan Adler #include <err.h>
58dea673e9SRodney W. Grimes #include <errno.h>
59dea673e9SRodney W. Grimes #include <dirent.h>
60dea673e9SRodney W. Grimes #include <unistd.h>
61dea673e9SRodney W. Grimes #include <stdlib.h>
62dea673e9SRodney W. Grimes #include <stdio.h>
63dea673e9SRodney W. Grimes #include <ctype.h>
64dea673e9SRodney W. Grimes #include <string.h>
65dea673e9SRodney W. Grimes #include "lp.h"
66dea673e9SRodney W. Grimes #include "lp.local.h"
67dea673e9SRodney W. Grimes #include "lpc.h"
68dea673e9SRodney W. Grimes #include "extern.h"
69dea673e9SRodney W. Grimes #include "pathnames.h"
70dea673e9SRodney W. Grimes 
71e8e715faSGarance A Drosehn /*
72e8e715faSGarance A Drosehn  * Return values from kill_qtask().
73e8e715faSGarance A Drosehn  */
74e8e715faSGarance A Drosehn #define KQT_LFERROR	-2
75e8e715faSGarance A Drosehn #define KQT_KILLFAIL	-1
76e8e715faSGarance A Drosehn #define KQT_NODAEMON	0
77e8e715faSGarance A Drosehn #define KQT_KILLOK	1
78e8e715faSGarance A Drosehn 
7954032d11SGarance A Drosehn static char	*args2line(int argc, char **argv);
80ba7a1ad7SGarance A Drosehn static int	 doarg(char *_job);
816e807fa6SKevin Lo static int	 doselect(const struct dirent *_d);
82e8e715faSGarance A Drosehn static int	 kill_qtask(const char *lf);
832c81fb6aSXin LI static int	 sortq(const struct dirent **a, const struct dirent **b);
84ba7a1ad7SGarance A Drosehn static int	 touch(struct jobqueue *_jq);
85ba7a1ad7SGarance A Drosehn static void	 unlinkf(char *_name);
8654032d11SGarance A Drosehn static void	 upstat(struct printer *_pp, const char *_msg, int _notify);
87004c9c5dSGarance A Drosehn static void	 wrapup_clean(int _laststatus);
884a1a0dbeSGarrett Wollman 
894a1a0dbeSGarrett Wollman /*
904a1a0dbeSGarrett Wollman  * generic framework for commands which operate on all or a specified
914a1a0dbeSGarrett Wollman  * set of printers
924a1a0dbeSGarrett Wollman  */
93004c9c5dSGarance A Drosehn enum	qsel_val {			/* how a given ptr was selected */
94004c9c5dSGarance A Drosehn 	QSEL_UNKNOWN = -1,		/* ... not selected yet */
95004c9c5dSGarance A Drosehn 	QSEL_BYNAME = 0,		/* ... user specifed it by name */
96004c9c5dSGarance A Drosehn 	QSEL_ALL = 1			/* ... user wants "all" printers */
97004c9c5dSGarance A Drosehn 					/*     (with more to come)    */
98004c9c5dSGarance A Drosehn };
99004c9c5dSGarance A Drosehn 
100004c9c5dSGarance A Drosehn static enum qsel_val generic_qselect;	/* indicates how ptr was selected */
101004c9c5dSGarance A Drosehn static int generic_initerr;		/* result of initrtn processing */
102e7f478b2SGarance A Drosehn static char *generic_cmdname;
10354032d11SGarance A Drosehn static char *generic_msg;		/* if a -msg was specified */
104004c9c5dSGarance A Drosehn static char *generic_nullarg;
105004c9c5dSGarance A Drosehn static void (*generic_wrapup)(int _last_status);   /* perform rtn wrap-up */
106004c9c5dSGarance A Drosehn 
1074a1a0dbeSGarrett Wollman void
10854032d11SGarance A Drosehn generic(void (*specificrtn)(struct printer *_pp), int cmdopts,
109004c9c5dSGarance A Drosehn     void (*initrtn)(int _argc, char *_argv[]), int argc, char *argv[])
1104a1a0dbeSGarrett Wollman {
111004c9c5dSGarance A Drosehn 	int cmdstatus, more, targc;
112004c9c5dSGarance A Drosehn 	struct printer myprinter, *pp;
113e7f478b2SGarance A Drosehn 	char **margv, **targv;
1144a1a0dbeSGarrett Wollman 
1154a1a0dbeSGarrett Wollman 	if (argc == 1) {
1165b1c34fbSGarance A Drosehn 		/*
1175b1c34fbSGarance A Drosehn 		 * Usage needs a special case for 'down': The user must
1185b1c34fbSGarance A Drosehn 		 * either include `-msg', or only the first parameter
1195b1c34fbSGarance A Drosehn 		 * that they give will be processed as a printer name.
1205b1c34fbSGarance A Drosehn 		 */
12154032d11SGarance A Drosehn 		printf("usage: %s  {all | printer ...}", argv[0]);
1225b1c34fbSGarance A Drosehn 		if (strcmp(argv[0], "down") == 0) {
1235b1c34fbSGarance A Drosehn 			printf(" -msg [<text> ...]\n");
1245b1c34fbSGarance A Drosehn 			printf("   or: down  {all | printer} [<text> ...]");
1255b1c34fbSGarance A Drosehn 		} else if (cmdopts & LPC_MSGOPT)
12654032d11SGarance A Drosehn 			printf(" [-msg <text> ...]");
12754032d11SGarance A Drosehn 		printf("\n");
1284a1a0dbeSGarrett Wollman 		return;
1294a1a0dbeSGarrett Wollman 	}
130004c9c5dSGarance A Drosehn 
131e7f478b2SGarance A Drosehn 	/* The first argument is the command name. */
132e7f478b2SGarance A Drosehn 	generic_cmdname = *argv++;
133e7f478b2SGarance A Drosehn 	argc--;
134e7f478b2SGarance A Drosehn 
135004c9c5dSGarance A Drosehn 	/*
136004c9c5dSGarance A Drosehn 	 * The initialization routine for a command might set a generic
137004c9c5dSGarance A Drosehn 	 * "wrapup" routine, which should be called after processing all
138004c9c5dSGarance A Drosehn 	 * the printers in the command.  This might print summary info.
139004c9c5dSGarance A Drosehn 	 *
140004c9c5dSGarance A Drosehn 	 * Note that the initialization routine may also parse (and
141004c9c5dSGarance A Drosehn 	 * nullify) some of the parameters given on the command, leaving
142004c9c5dSGarance A Drosehn 	 * only the parameters which have to do with printer names.
143004c9c5dSGarance A Drosehn 	 */
144004c9c5dSGarance A Drosehn 	pp = &myprinter;
145004c9c5dSGarance A Drosehn 	generic_wrapup = NULL;
146004c9c5dSGarance A Drosehn 	generic_qselect = QSEL_UNKNOWN;
147004c9c5dSGarance A Drosehn 	cmdstatus = 0;
148004c9c5dSGarance A Drosehn 	/* this just needs to be a distinct value of type 'char *' */
149004c9c5dSGarance A Drosehn 	if (generic_nullarg == NULL)
150004c9c5dSGarance A Drosehn 		generic_nullarg = strdup("");
151004c9c5dSGarance A Drosehn 
15254032d11SGarance A Drosehn 	/*
15354032d11SGarance A Drosehn 	 * Some commands accept a -msg argument, which indicates that
15454032d11SGarance A Drosehn 	 * all remaining arguments should be combined into a string.
15554032d11SGarance A Drosehn 	 */
15654032d11SGarance A Drosehn 	generic_msg = NULL;
15754032d11SGarance A Drosehn 	if (cmdopts & LPC_MSGOPT) {
15854032d11SGarance A Drosehn 		targc = argc;
15954032d11SGarance A Drosehn 		targv = argv;
160e7f478b2SGarance A Drosehn 		for (; targc > 0; targc--, targv++) {
16154032d11SGarance A Drosehn 			if (strcmp(*targv, "-msg") == 0) {
16254032d11SGarance A Drosehn 				argc -= targc;
16354032d11SGarance A Drosehn 				generic_msg = args2line(targc - 1, targv + 1);
16454032d11SGarance A Drosehn 				break;
16554032d11SGarance A Drosehn 			}
16654032d11SGarance A Drosehn 		}
167aa318fd7SGarance A Drosehn 		if (argc < 1) {
168aa318fd7SGarance A Drosehn 			printf("error: No printer name(s) specified before"
169aa318fd7SGarance A Drosehn 			    " '-msg'.\n");
170aa318fd7SGarance A Drosehn 			printf("usage: %s  {all | printer ...}",
171aa318fd7SGarance A Drosehn 			    generic_cmdname);
172aa318fd7SGarance A Drosehn 			printf(" [-msg <text> ...]\n");
173aa318fd7SGarance A Drosehn 			return;
174aa318fd7SGarance A Drosehn 		}
17554032d11SGarance A Drosehn 	}
17654032d11SGarance A Drosehn 
177004c9c5dSGarance A Drosehn 	/* call initialization routine, if there is one for this cmd */
178004c9c5dSGarance A Drosehn 	if (initrtn != NULL) {
179004c9c5dSGarance A Drosehn 		generic_initerr = 0;
180004c9c5dSGarance A Drosehn 		(*initrtn)(argc, argv);
181004c9c5dSGarance A Drosehn 		if (generic_initerr)
182004c9c5dSGarance A Drosehn 			return;
183e7f478b2SGarance A Drosehn 		/*
184e7f478b2SGarance A Drosehn 		 * The initrtn may have null'ed out some of the parameters.
185e7f478b2SGarance A Drosehn 		 * Compact the parameter list to remove those nulls, and
186e7f478b2SGarance A Drosehn 		 * correct the arg-count.
187e7f478b2SGarance A Drosehn 		 */
188004c9c5dSGarance A Drosehn 		targc = argc;
189004c9c5dSGarance A Drosehn 		targv = argv;
190e7f478b2SGarance A Drosehn 		margv = argv;
191e7f478b2SGarance A Drosehn 		argc = 0;
192e7f478b2SGarance A Drosehn 		for (; targc > 0; targc--, targv++) {
193e7f478b2SGarance A Drosehn 			if (*targv != generic_nullarg) {
194e7f478b2SGarance A Drosehn 				if (targv != margv)
195e7f478b2SGarance A Drosehn 					*margv = *targv;
196e7f478b2SGarance A Drosehn 				margv++;
197e7f478b2SGarance A Drosehn 				argc++;
198004c9c5dSGarance A Drosehn 			}
199004c9c5dSGarance A Drosehn 		}
200004c9c5dSGarance A Drosehn 	}
201004c9c5dSGarance A Drosehn 
202e7f478b2SGarance A Drosehn 	if (argc == 1 && strcmp(*argv, "all") == 0) {
203004c9c5dSGarance A Drosehn 		generic_qselect = QSEL_ALL;
204ba7a1ad7SGarance A Drosehn 		more = firstprinter(pp, &cmdstatus);
205ba7a1ad7SGarance A Drosehn 		if (cmdstatus)
2064a1a0dbeSGarrett Wollman 			goto looperr;
2074a1a0dbeSGarrett Wollman 		while (more) {
208ba7a1ad7SGarance A Drosehn 			(*specificrtn)(pp);
2094a1a0dbeSGarrett Wollman 			do {
210ba7a1ad7SGarance A Drosehn 				more = nextprinter(pp, &cmdstatus);
2114a1a0dbeSGarrett Wollman looperr:
212ba7a1ad7SGarance A Drosehn 				switch (cmdstatus) {
2134a1a0dbeSGarrett Wollman 				case PCAPERR_TCOPEN:
2144a1a0dbeSGarrett Wollman 					printf("warning: %s: unresolved "
2154a1a0dbeSGarrett Wollman 					       "tc= reference(s) ",
2164a1a0dbeSGarrett Wollman 					       pp->printer);
2174a1a0dbeSGarrett Wollman 				case PCAPERR_SUCCESS:
2184a1a0dbeSGarrett Wollman 					break;
2194a1a0dbeSGarrett Wollman 				default:
2206d39e1b7SGarance A Drosehn 					fatal(pp, "%s", pcaperr(cmdstatus));
2214a1a0dbeSGarrett Wollman 				}
222ba7a1ad7SGarance A Drosehn 			} while (more && cmdstatus);
2234a1a0dbeSGarrett Wollman 		}
224004c9c5dSGarance A Drosehn 		goto wrapup;
2254a1a0dbeSGarrett Wollman 	}
226004c9c5dSGarance A Drosehn 
227004c9c5dSGarance A Drosehn 	generic_qselect = QSEL_BYNAME;		/* specifically-named ptrs */
228e7f478b2SGarance A Drosehn 	for (; argc > 0; argc--, argv++) {
2294a1a0dbeSGarrett Wollman 		init_printer(pp);
230ba7a1ad7SGarance A Drosehn 		cmdstatus = getprintcap(*argv, pp);
231ba7a1ad7SGarance A Drosehn 		switch (cmdstatus) {
2324a1a0dbeSGarrett Wollman 		default:
2336d39e1b7SGarance A Drosehn 			fatal(pp, "%s", pcaperr(cmdstatus));
2344a1a0dbeSGarrett Wollman 		case PCAPERR_NOTFOUND:
2354a1a0dbeSGarrett Wollman 			printf("unknown printer %s\n", *argv);
2364a1a0dbeSGarrett Wollman 			continue;
2374a1a0dbeSGarrett Wollman 		case PCAPERR_TCOPEN:
2384a1a0dbeSGarrett Wollman 			printf("warning: %s: unresolved tc= reference(s)\n",
2394a1a0dbeSGarrett Wollman 			       *argv);
2404a1a0dbeSGarrett Wollman 			break;
2414a1a0dbeSGarrett Wollman 		case PCAPERR_SUCCESS:
2424a1a0dbeSGarrett Wollman 			break;
2434a1a0dbeSGarrett Wollman 		}
244ba7a1ad7SGarance A Drosehn 		(*specificrtn)(pp);
2454a1a0dbeSGarrett Wollman 	}
246004c9c5dSGarance A Drosehn 
247004c9c5dSGarance A Drosehn wrapup:
248004c9c5dSGarance A Drosehn 	if (generic_wrapup) {
249004c9c5dSGarance A Drosehn 		(*generic_wrapup)(cmdstatus);
250004c9c5dSGarance A Drosehn 	}
251cc2b61b1SGarance A Drosehn 	free_printer(pp);
25254032d11SGarance A Drosehn 	if (generic_msg)
25354032d11SGarance A Drosehn 		free(generic_msg);
25454032d11SGarance A Drosehn }
255004c9c5dSGarance A Drosehn 
25654032d11SGarance A Drosehn /*
25754032d11SGarance A Drosehn  * Convert an argv-array of character strings into a single string.
25854032d11SGarance A Drosehn  */
25954032d11SGarance A Drosehn static char *
26054032d11SGarance A Drosehn args2line(int argc, char **argv)
26154032d11SGarance A Drosehn {
26254032d11SGarance A Drosehn 	char *cp1, *cend;
26354032d11SGarance A Drosehn 	const char *cp2;
26454032d11SGarance A Drosehn 	char buf[1024];
26554032d11SGarance A Drosehn 
26654032d11SGarance A Drosehn 	if (argc <= 0)
26754032d11SGarance A Drosehn 		return strdup("\n");
26854032d11SGarance A Drosehn 
26954032d11SGarance A Drosehn 	cp1 = buf;
27054032d11SGarance A Drosehn 	cend = buf + sizeof(buf) - 1;		/* save room for '\0' */
27154032d11SGarance A Drosehn 	while (--argc >= 0) {
27254032d11SGarance A Drosehn 		cp2 = *argv++;
27354032d11SGarance A Drosehn 		while ((cp1 < cend) && (*cp1++ = *cp2++))
27454032d11SGarance A Drosehn 			;
27554032d11SGarance A Drosehn 		cp1[-1] = ' ';
27654032d11SGarance A Drosehn 	}
27754032d11SGarance A Drosehn 	cp1[-1] = '\n';
27854032d11SGarance A Drosehn 	*cp1 = '\0';
27954032d11SGarance A Drosehn 	return strdup(buf);
2804a1a0dbeSGarrett Wollman }
281dea673e9SRodney W. Grimes 
282dea673e9SRodney W. Grimes /*
283e8e715faSGarance A Drosehn  * Kill the current daemon, to stop printing of the active job.
284e8e715faSGarance A Drosehn  */
285e8e715faSGarance A Drosehn static int
286e8e715faSGarance A Drosehn kill_qtask(const char *lf)
287e8e715faSGarance A Drosehn {
288e8e715faSGarance A Drosehn 	FILE *fp;
289e8e715faSGarance A Drosehn 	pid_t pid;
290e8e715faSGarance A Drosehn 	int errsav, killres, lockres, res;
291e8e715faSGarance A Drosehn 
2921d1d4a47SEitan Adler 	PRIV_START
293e8e715faSGarance A Drosehn 	fp = fopen(lf, "r");
294e8e715faSGarance A Drosehn 	errsav = errno;
2951d1d4a47SEitan Adler 	PRIV_END
296e8e715faSGarance A Drosehn 	res = KQT_NODAEMON;
297e8e715faSGarance A Drosehn 	if (fp == NULL) {
298e8e715faSGarance A Drosehn 		/*
299e8e715faSGarance A Drosehn 		 * If there is no lock file, then there is no daemon to
300e8e715faSGarance A Drosehn 		 * kill.  Any other error return means there is some
301e8e715faSGarance A Drosehn 		 * kind of problem with the lock file.
302e8e715faSGarance A Drosehn 		 */
303e8e715faSGarance A Drosehn 		if (errsav != ENOENT)
304e8e715faSGarance A Drosehn 			res = KQT_LFERROR;
305e8e715faSGarance A Drosehn 		goto killdone;
306e8e715faSGarance A Drosehn 	}
307e8e715faSGarance A Drosehn 
308e8e715faSGarance A Drosehn 	/* If the lock file is empty, then there is no daemon to kill */
309a9c48188SBaptiste Daroussin 	if (get_line(fp) == 0)
310e8e715faSGarance A Drosehn 		goto killdone;
311e8e715faSGarance A Drosehn 
312e8e715faSGarance A Drosehn 	/*
313e8e715faSGarance A Drosehn 	 * If the file can be locked without blocking, then there
314e8e715faSGarance A Drosehn 	 * no daemon to kill, or we should not try to kill it.
315e8e715faSGarance A Drosehn 	 *
316e8e715faSGarance A Drosehn 	 * XXX - not sure I understand the reasoning behind this...
317e8e715faSGarance A Drosehn 	 */
318e8e715faSGarance A Drosehn 	lockres = flock(fileno(fp), LOCK_SH|LOCK_NB);
319e8e715faSGarance A Drosehn 	(void) fclose(fp);
320e8e715faSGarance A Drosehn 	if (lockres == 0)
321e8e715faSGarance A Drosehn 		goto killdone;
322e8e715faSGarance A Drosehn 
323e8e715faSGarance A Drosehn 	pid = atoi(line);
324e8e715faSGarance A Drosehn 	if (pid < 0) {
325e8e715faSGarance A Drosehn 		/*
326e8e715faSGarance A Drosehn 		 * If we got a negative pid, then the contents of the
327e8e715faSGarance A Drosehn 		 * lock file is not valid.
328e8e715faSGarance A Drosehn 		 */
329e8e715faSGarance A Drosehn 		res = KQT_LFERROR;
330e8e715faSGarance A Drosehn 		goto killdone;
331e8e715faSGarance A Drosehn 	}
332e8e715faSGarance A Drosehn 
3331d1d4a47SEitan Adler 	PRIV_END
334e8e715faSGarance A Drosehn 	killres = kill(pid, SIGTERM);
335e8e715faSGarance A Drosehn 	errsav = errno;
3361d1d4a47SEitan Adler 	PRIV_END
337e8e715faSGarance A Drosehn 	if (killres == 0) {
338e8e715faSGarance A Drosehn 		res = KQT_KILLOK;
339e8e715faSGarance A Drosehn 		printf("\tdaemon (pid %d) killed\n", pid);
340e8e715faSGarance A Drosehn 	} else if (errno == ESRCH) {
341e8e715faSGarance A Drosehn 		res = KQT_NODAEMON;
342e8e715faSGarance A Drosehn 	} else {
343e8e715faSGarance A Drosehn 		res = KQT_KILLFAIL;
344e8e715faSGarance A Drosehn 		printf("\tWarning: daemon (pid %d) not killed:\n", pid);
345e8e715faSGarance A Drosehn 		printf("\t    %s\n", strerror(errsav));
346e8e715faSGarance A Drosehn 	}
347e8e715faSGarance A Drosehn 
348e8e715faSGarance A Drosehn killdone:
349e8e715faSGarance A Drosehn 	switch (res) {
350e8e715faSGarance A Drosehn 	case KQT_LFERROR:
351e8e715faSGarance A Drosehn 		printf("\tcannot open lock file: %s\n",
352e8e715faSGarance A Drosehn 		    strerror(errsav));
353e8e715faSGarance A Drosehn 		break;
354e8e715faSGarance A Drosehn 	case KQT_NODAEMON:
355e8e715faSGarance A Drosehn 		printf("\tno daemon to abort\n");
356e8e715faSGarance A Drosehn 		break;
357e8e715faSGarance A Drosehn 	case KQT_KILLFAIL:
358e8e715faSGarance A Drosehn 	case KQT_KILLOK:
359e8e715faSGarance A Drosehn 		/* These two already printed messages to the user. */
360e8e715faSGarance A Drosehn 		break;
361e8e715faSGarance A Drosehn 	default:
362e8e715faSGarance A Drosehn 		printf("\t<internal error in kill_qtask>\n");
363e8e715faSGarance A Drosehn 		break;
364e8e715faSGarance A Drosehn 	}
365e8e715faSGarance A Drosehn 
366e8e715faSGarance A Drosehn 	return (res);
367e8e715faSGarance A Drosehn }
368e8e715faSGarance A Drosehn 
369e8e715faSGarance A Drosehn /*
370dea673e9SRodney W. Grimes  * Write a message into the status file.
371dea673e9SRodney W. Grimes  */
372dea673e9SRodney W. Grimes static void
37354032d11SGarance A Drosehn upstat(struct printer *pp, const char *msg, int notifyuser)
374dea673e9SRodney W. Grimes {
37554032d11SGarance A Drosehn 	int fd;
3765f87a7b6SWarner Losh 	char statfile[MAXPATHLEN];
377dea673e9SRodney W. Grimes 
3784a1a0dbeSGarrett Wollman 	status_file_name(pp, statfile, sizeof statfile);
379dea673e9SRodney W. Grimes 	umask(0);
3801d1d4a47SEitan Adler 	PRIV_START
3814a1a0dbeSGarrett Wollman 	fd = open(statfile, O_WRONLY|O_CREAT|O_EXLOCK, STAT_FILE_MODE);
3821d1d4a47SEitan Adler 	PRIV_END
3834a1a0dbeSGarrett Wollman 	if (fd < 0) {
3844a1a0dbeSGarrett Wollman 		printf("\tcannot create status file: %s\n", strerror(errno));
385dea673e9SRodney W. Grimes 		return;
386dea673e9SRodney W. Grimes 	}
387dea673e9SRodney W. Grimes 	(void) ftruncate(fd, 0);
3886e807fa6SKevin Lo 	if (msg == NULL)
389dea673e9SRodney W. Grimes 		(void) write(fd, "\n", 1);
390dea673e9SRodney W. Grimes 	else
391dea673e9SRodney W. Grimes 		(void) write(fd, msg, strlen(msg));
392dea673e9SRodney W. Grimes 	(void) close(fd);
39354032d11SGarance A Drosehn 	if (notifyuser) {
39454032d11SGarance A Drosehn 		if ((msg == (char *)NULL) || (strcmp(msg, "\n") == 0))
39554032d11SGarance A Drosehn 			printf("\tstatus message is now set to nothing.\n");
39654032d11SGarance A Drosehn 		else
39754032d11SGarance A Drosehn 			printf("\tstatus message is now: %s", msg);
39854032d11SGarance A Drosehn 	}
399dea673e9SRodney W. Grimes }
400dea673e9SRodney W. Grimes 
401004c9c5dSGarance A Drosehn /*
402e8e715faSGarance A Drosehn  * kill an existing daemon and disable printing.
403e8e715faSGarance A Drosehn  */
404e8e715faSGarance A Drosehn void
405e8e715faSGarance A Drosehn abort_q(struct printer *pp)
406e8e715faSGarance A Drosehn {
407e8e715faSGarance A Drosehn 	int killres, setres;
408e8e715faSGarance A Drosehn 	char lf[MAXPATHLEN];
409e8e715faSGarance A Drosehn 
410e8e715faSGarance A Drosehn 	lock_file_name(pp, lf, sizeof lf);
411e8e715faSGarance A Drosehn 	printf("%s:\n", pp->printer);
412e8e715faSGarance A Drosehn 
413e8e715faSGarance A Drosehn 	/*
414e8e715faSGarance A Drosehn 	 * Turn on the owner execute bit of the lock file to disable printing.
415e8e715faSGarance A Drosehn 	 */
416e8e715faSGarance A Drosehn 	setres = set_qstate(SQS_STOPP, lf);
417e8e715faSGarance A Drosehn 
418e8e715faSGarance A Drosehn 	/*
419e8e715faSGarance A Drosehn 	 * If set_qstate found that there already was a lock file, then
420e8e715faSGarance A Drosehn 	 * call a routine which will read that lock file and kill the
421e8e715faSGarance A Drosehn 	 * lpd-process which is listed in that lock file.  If the lock
422e8e715faSGarance A Drosehn 	 * file did not exist, then either there is no daemon running
423e8e715faSGarance A Drosehn 	 * for this queue, or there is one running but *it* could not
424e8e715faSGarance A Drosehn 	 * write a lock file (which means we can not determine the
425e8e715faSGarance A Drosehn 	 * process id of that lpd-process).
426e8e715faSGarance A Drosehn 	 */
427e8e715faSGarance A Drosehn 	switch (setres) {
428e8e715faSGarance A Drosehn 	case SQS_CHGOK:
429e8e715faSGarance A Drosehn 	case SQS_CHGFAIL:
430e8e715faSGarance A Drosehn 		/* Kill the process */
431e8e715faSGarance A Drosehn 		killres = kill_qtask(lf);
432e8e715faSGarance A Drosehn 		break;
433e8e715faSGarance A Drosehn 	case SQS_CREOK:
434e8e715faSGarance A Drosehn 	case SQS_CREFAIL:
435e8e715faSGarance A Drosehn 		printf("\tno daemon to abort\n");
436e8e715faSGarance A Drosehn 		break;
437e8e715faSGarance A Drosehn 	case SQS_STATFAIL:
438e8e715faSGarance A Drosehn 		printf("\tassuming no daemon to abort\n");
439e8e715faSGarance A Drosehn 		break;
440e8e715faSGarance A Drosehn 	default:
441e8e715faSGarance A Drosehn 		printf("\t<unexpected result (%d) from set_qstate>\n",
442e8e715faSGarance A Drosehn 		    setres);
443e8e715faSGarance A Drosehn 		break;
444e8e715faSGarance A Drosehn 	}
445e8e715faSGarance A Drosehn 
44654032d11SGarance A Drosehn 	if (setres >= 0)
44754032d11SGarance A Drosehn 		upstat(pp, "printing disabled\n", 0);
448e8e715faSGarance A Drosehn }
449e8e715faSGarance A Drosehn 
450e8e715faSGarance A Drosehn /*
451004c9c5dSGarance A Drosehn  * "global" variables for all the routines related to 'clean' and 'tclean'
452004c9c5dSGarance A Drosehn  */
453004c9c5dSGarance A Drosehn static time_t	 cln_now;		/* current time */
454004c9c5dSGarance A Drosehn static double	 cln_minage;		/* minimum age before file is removed */
455004c9c5dSGarance A Drosehn static long	 cln_sizecnt;		/* amount of space freed up */
456004c9c5dSGarance A Drosehn static int 	 cln_debug;		/* print extra debugging msgs */
457004c9c5dSGarance A Drosehn static int	 cln_filecnt;		/* number of files destroyed */
458004c9c5dSGarance A Drosehn static int	 cln_foundcore;		/* found a core file! */
459004c9c5dSGarance A Drosehn static int	 cln_queuecnt;		/* number of queues checked */
460004c9c5dSGarance A Drosehn static int 	 cln_testonly;		/* remove-files vs just-print-info */
461004c9c5dSGarance A Drosehn 
462dea673e9SRodney W. Grimes static int
4636e807fa6SKevin Lo doselect(const struct dirent *d)
464dea673e9SRodney W. Grimes {
465dea673e9SRodney W. Grimes 	int c = d->d_name[0];
466dea673e9SRodney W. Grimes 
4671fd731faSGarance A Drosehn 	if ((c == 'c' || c == 'd' || c == 'r' || c == 't') &&
4681fd731faSGarance A Drosehn 	    d->d_name[1] == 'f')
469004c9c5dSGarance A Drosehn 		return 1;
470004c9c5dSGarance A Drosehn 	if (c == 'c') {
471004c9c5dSGarance A Drosehn 		if (!strcmp(d->d_name, "core"))
472004c9c5dSGarance A Drosehn 			cln_foundcore = 1;
473004c9c5dSGarance A Drosehn 	}
474004c9c5dSGarance A Drosehn 	if (c == 'e') {
475004c9c5dSGarance A Drosehn 		if (!strncmp(d->d_name, "errs.", 5))
476004c9c5dSGarance A Drosehn 			return 1;
477004c9c5dSGarance A Drosehn 	}
478004c9c5dSGarance A Drosehn 	return 0;
479dea673e9SRodney W. Grimes }
480dea673e9SRodney W. Grimes 
481dea673e9SRodney W. Grimes /*
482ceeaedd3SGarance A Drosehn  * Comparison routine that clean_q() uses for scandir.
483ceeaedd3SGarance A Drosehn  *
484ceeaedd3SGarance A Drosehn  * The purpose of this sort is to have all `df' files end up immediately
4851fd731faSGarance A Drosehn  * after the matching `cf' file.  For files matching `cf', `df', `rf', or
4861fd731faSGarance A Drosehn  * `tf', it sorts by job number and machine, then by `cf', `df', `rf', or
4871fd731faSGarance A Drosehn  * `tf', and then by the sequence letter (which is A-Z, or a-z).    This
4881fd731faSGarance A Drosehn  * routine may also see filenames which do not start with `cf', `df', `rf',
4891fd731faSGarance A Drosehn  * or `tf' (such as `errs.*'), and those are simply sorted by the full
4901fd731faSGarance A Drosehn  * filename.
4911fd731faSGarance A Drosehn  *
4921fd731faSGarance A Drosehn  * XXX
4931fd731faSGarance A Drosehn  *   This assumes that all control files start with `cfA*', and it turns
4941fd731faSGarance A Drosehn  *   out there are a few implementations of lpr which will create `cfB*'
4951fd731faSGarance A Drosehn  *   filenames (they will have datafile names which start with `dfB*').
496dea673e9SRodney W. Grimes  */
497dea673e9SRodney W. Grimes static int
4982c81fb6aSXin LI sortq(const struct dirent **a, const struct dirent **b)
499dea673e9SRodney W. Grimes {
500ceeaedd3SGarance A Drosehn 	const int a_lt_b = -1, a_gt_b = 1, cat_other = 10;
501ceeaedd3SGarance A Drosehn 	const char *fname_a, *fname_b, *jnum_a, *jnum_b;
502ceeaedd3SGarance A Drosehn 	int cat_a, cat_b, ch, res, seq_a, seq_b;
503dea673e9SRodney W. Grimes 
5042c81fb6aSXin LI 	fname_a = (*a)->d_name;
5052c81fb6aSXin LI 	fname_b = (*b)->d_name;
506ceeaedd3SGarance A Drosehn 
507ceeaedd3SGarance A Drosehn 	/*
5083df5ecacSUlrich Spörlein 	 * First separate filenames into categories.  Categories are
5091fd731faSGarance A Drosehn 	 * legitimate `cf', `df', `rf' & `tf' filenames, and "other" - in
5101fd731faSGarance A Drosehn 	 * that order.  It is critical that the mapping be exactly the
5111fd731faSGarance A Drosehn 	 * same for 'a' vs 'b', so define a macro for the job.
512ceeaedd3SGarance A Drosehn 	 *
513ceeaedd3SGarance A Drosehn 	 * [aside: the standard `cf' file has the jobnumber start in
514ceeaedd3SGarance A Drosehn 	 * position 4, but some implementations have that as an extra
515ceeaedd3SGarance A Drosehn 	 * file-sequence letter, and start the job number in position 5.]
516ceeaedd3SGarance A Drosehn 	 */
517ceeaedd3SGarance A Drosehn #define MAP_TO_CAT(fname_X,cat_X,jnum_X,seq_X) do { \
518ceeaedd3SGarance A Drosehn 	cat_X = cat_other;    \
519ceeaedd3SGarance A Drosehn 	ch = *(fname_X + 2);  \
520ceeaedd3SGarance A Drosehn 	jnum_X = fname_X + 3; \
5214f7f8234SGarance A Drosehn 	seq_X = 0;            \
522ceeaedd3SGarance A Drosehn 	if ((*(fname_X + 1) == 'f') && (isalpha(ch))) { \
523ceeaedd3SGarance A Drosehn 		seq_X = ch; \
524ceeaedd3SGarance A Drosehn 		if (*fname_X == 'c') \
525ceeaedd3SGarance A Drosehn 			cat_X = 1; \
526ceeaedd3SGarance A Drosehn 		else if (*fname_X == 'd') \
527ceeaedd3SGarance A Drosehn 			cat_X = 2; \
5281fd731faSGarance A Drosehn 		else if (*fname_X == 'r') \
529ceeaedd3SGarance A Drosehn 			cat_X = 3; \
5301fd731faSGarance A Drosehn 		else if (*fname_X == 't') \
5311fd731faSGarance A Drosehn 			cat_X = 4; \
532ceeaedd3SGarance A Drosehn 		if (cat_X != cat_other) { \
533ceeaedd3SGarance A Drosehn 			ch = *jnum_X; \
534ceeaedd3SGarance A Drosehn 			if (!isdigit(ch)) { \
535ceeaedd3SGarance A Drosehn 				if (isalpha(ch)) { \
536ceeaedd3SGarance A Drosehn 					jnum_X++; \
537ceeaedd3SGarance A Drosehn 					ch = *jnum_X; \
538ceeaedd3SGarance A Drosehn 					seq_X = (seq_X << 8) + ch; \
539ceeaedd3SGarance A Drosehn 				} \
540ceeaedd3SGarance A Drosehn 				if (!isdigit(ch)) \
541ceeaedd3SGarance A Drosehn 					cat_X = cat_other; \
542ceeaedd3SGarance A Drosehn 			} \
543ceeaedd3SGarance A Drosehn 		} \
544ceeaedd3SGarance A Drosehn 	} \
545ceeaedd3SGarance A Drosehn } while (0)
546ceeaedd3SGarance A Drosehn 
547ceeaedd3SGarance A Drosehn 	MAP_TO_CAT(fname_a, cat_a, jnum_a, seq_a);
548ceeaedd3SGarance A Drosehn 	MAP_TO_CAT(fname_b, cat_b, jnum_b, seq_b);
549ceeaedd3SGarance A Drosehn 
550ceeaedd3SGarance A Drosehn #undef MAP_TO_CAT
551ceeaedd3SGarance A Drosehn 
552ceeaedd3SGarance A Drosehn 	/* First handle all cases which have "other" files */
553ceeaedd3SGarance A Drosehn 	if ((cat_a >= cat_other) || (cat_b >= cat_other)) {
554ceeaedd3SGarance A Drosehn 		/* for two "other" files, just compare the full name */
555ceeaedd3SGarance A Drosehn 		if (cat_a == cat_b)
556ceeaedd3SGarance A Drosehn 			res = strcmp(fname_a, fname_b);
557ceeaedd3SGarance A Drosehn 		else if (cat_a < cat_b)
558ceeaedd3SGarance A Drosehn 			res = a_lt_b;
559ceeaedd3SGarance A Drosehn 		else
560ceeaedd3SGarance A Drosehn 			res = a_gt_b;
561ceeaedd3SGarance A Drosehn 		goto have_res;
562ceeaedd3SGarance A Drosehn 	}
563ceeaedd3SGarance A Drosehn 
564ceeaedd3SGarance A Drosehn 	/*
5651fd731faSGarance A Drosehn 	 * At this point, we know both files are legitimate `cf', `df', `rf',
566ceeaedd3SGarance A Drosehn 	 * or `tf' files.  Compare them by job-number and machine name.
567ceeaedd3SGarance A Drosehn 	 */
568ceeaedd3SGarance A Drosehn 	res = strcmp(jnum_a, jnum_b);
569ceeaedd3SGarance A Drosehn 	if (res != 0)
570ceeaedd3SGarance A Drosehn 		goto have_res;
571ceeaedd3SGarance A Drosehn 
572ceeaedd3SGarance A Drosehn 	/*
573ceeaedd3SGarance A Drosehn 	 * We have two files which belong to the same job.  Sort based
5743df5ecacSUlrich Spörlein 	 * on the category of file (`c' before `d', etc).
575ceeaedd3SGarance A Drosehn 	 */
576ceeaedd3SGarance A Drosehn 	if (cat_a < cat_b) {
577ceeaedd3SGarance A Drosehn 		res = a_lt_b;
578ceeaedd3SGarance A Drosehn 		goto have_res;
579ceeaedd3SGarance A Drosehn 	} else if (cat_a > cat_b) {
580ceeaedd3SGarance A Drosehn 		res = a_gt_b;
581ceeaedd3SGarance A Drosehn 		goto have_res;
582ceeaedd3SGarance A Drosehn 	}
583ceeaedd3SGarance A Drosehn 
584ceeaedd3SGarance A Drosehn 	/*
5853df5ecacSUlrich Spörlein 	 * Two files in the same category for a single job.  Sort based
5863df5ecacSUlrich Spörlein 	 * on the sequence letter(s).  (usually `A' through `Z', etc).
587ceeaedd3SGarance A Drosehn 	 */
588ceeaedd3SGarance A Drosehn 	if (seq_a < seq_b) {
589ceeaedd3SGarance A Drosehn 		res = a_lt_b;
590ceeaedd3SGarance A Drosehn 		goto have_res;
591ceeaedd3SGarance A Drosehn 	} else if (seq_a > seq_b) {
592ceeaedd3SGarance A Drosehn 		res = a_gt_b;
593ceeaedd3SGarance A Drosehn 		goto have_res;
594ceeaedd3SGarance A Drosehn 	}
595ceeaedd3SGarance A Drosehn 
596ceeaedd3SGarance A Drosehn 	/*
597ceeaedd3SGarance A Drosehn 	 * Given that the filenames in a directory are unique, this SHOULD
598ceeaedd3SGarance A Drosehn 	 * never happen (unless there are logic errors in this routine).
599ceeaedd3SGarance A Drosehn 	 * But if it does happen, we must return "is equal" or the caller
600ceeaedd3SGarance A Drosehn 	 * might see inconsistent results in the sorting order, and that
601ceeaedd3SGarance A Drosehn 	 * can trigger other problems.
602ceeaedd3SGarance A Drosehn 	 */
603ceeaedd3SGarance A Drosehn 	printf("\t*** Error in sortq: %s == %s !\n", fname_a, fname_b);
604ceeaedd3SGarance A Drosehn 	printf("\t***       cat %d == %d ; seq = %d %d\n", cat_a, cat_b,
605ceeaedd3SGarance A Drosehn 	    seq_a, seq_b);
606ceeaedd3SGarance A Drosehn 	res = 0;
607ceeaedd3SGarance A Drosehn 
608ceeaedd3SGarance A Drosehn have_res:
609ceeaedd3SGarance A Drosehn 	return res;
610dea673e9SRodney W. Grimes }
611dea673e9SRodney W. Grimes 
612dea673e9SRodney W. Grimes /*
6134a1a0dbeSGarrett Wollman  * Remove all spool files and temporaries from the spooling area.
6144a1a0dbeSGarrett Wollman  * Or, perhaps:
615dea673e9SRodney W. Grimes  * Remove incomplete jobs from spooling area.
616dea673e9SRodney W. Grimes  */
617dea673e9SRodney W. Grimes 
618004c9c5dSGarance A Drosehn void
619c9cb13a0SGarance A Drosehn clean_gi(int argc, char *argv[])
620004c9c5dSGarance A Drosehn {
621004c9c5dSGarance A Drosehn 
622004c9c5dSGarance A Drosehn 	/* init some fields before 'clean' is called for each queue */
623004c9c5dSGarance A Drosehn 	cln_queuecnt = 0;
624004c9c5dSGarance A Drosehn 	cln_now = time(NULL);
625004c9c5dSGarance A Drosehn 	cln_minage = 3600.0;		/* only delete files >1h old */
626004c9c5dSGarance A Drosehn 	cln_filecnt = 0;
627004c9c5dSGarance A Drosehn 	cln_sizecnt = 0;
628004c9c5dSGarance A Drosehn 	cln_debug = 0;
629004c9c5dSGarance A Drosehn 	cln_testonly = 0;
630004c9c5dSGarance A Drosehn 	generic_wrapup = &wrapup_clean;
631004c9c5dSGarance A Drosehn 
632004c9c5dSGarance A Drosehn 	/* see if there are any options specified before the ptr list */
633e7f478b2SGarance A Drosehn 	for (; argc > 0; argc--, argv++) {
634004c9c5dSGarance A Drosehn 		if (**argv != '-')
635004c9c5dSGarance A Drosehn 			break;
636004c9c5dSGarance A Drosehn 		if (strcmp(*argv, "-d") == 0) {
637004c9c5dSGarance A Drosehn 			/* just an example of an option... */
638ceeaedd3SGarance A Drosehn 			cln_debug++;
639004c9c5dSGarance A Drosehn 			*argv = generic_nullarg;	/* "erase" it */
640004c9c5dSGarance A Drosehn 		} else {
641004c9c5dSGarance A Drosehn 			printf("Invalid option '%s'\n", *argv);
642004c9c5dSGarance A Drosehn 			generic_initerr = 1;
643004c9c5dSGarance A Drosehn 		}
644004c9c5dSGarance A Drosehn 	}
645004c9c5dSGarance A Drosehn 
646004c9c5dSGarance A Drosehn 	return;
647004c9c5dSGarance A Drosehn }
648004c9c5dSGarance A Drosehn 
649004c9c5dSGarance A Drosehn void
650c9cb13a0SGarance A Drosehn tclean_gi(int argc, char *argv[])
651004c9c5dSGarance A Drosehn {
652004c9c5dSGarance A Drosehn 
653004c9c5dSGarance A Drosehn 	/* only difference between 'clean' and 'tclean' is one value */
654004c9c5dSGarance A Drosehn 	/* (...and the fact that 'clean' is priv and 'tclean' is not) */
655c9cb13a0SGarance A Drosehn 	clean_gi(argc, argv);
656004c9c5dSGarance A Drosehn 	cln_testonly = 1;
657004c9c5dSGarance A Drosehn 
658004c9c5dSGarance A Drosehn 	return;
659004c9c5dSGarance A Drosehn }
660004c9c5dSGarance A Drosehn 
661004c9c5dSGarance A Drosehn void
662004c9c5dSGarance A Drosehn clean_q(struct printer *pp)
663004c9c5dSGarance A Drosehn {
664004c9c5dSGarance A Drosehn 	char *cp, *cp1, *lp;
665004c9c5dSGarance A Drosehn 	struct dirent **queue;
666004c9c5dSGarance A Drosehn 	size_t linerem;
667004c9c5dSGarance A Drosehn 	int didhead, i, n, nitems, rmcp;
668004c9c5dSGarance A Drosehn 
669004c9c5dSGarance A Drosehn 	cln_queuecnt++;
670004c9c5dSGarance A Drosehn 
671004c9c5dSGarance A Drosehn 	didhead = 0;
672004c9c5dSGarance A Drosehn 	if (generic_qselect == QSEL_BYNAME) {
6734a1a0dbeSGarrett Wollman 		printf("%s:\n", pp->printer);
674004c9c5dSGarance A Drosehn 		didhead = 1;
675004c9c5dSGarance A Drosehn 	}
676dea673e9SRodney W. Grimes 
6774a1a0dbeSGarrett Wollman 	lp = line;
6784a1a0dbeSGarrett Wollman 	cp = pp->spool_dir;
6794a1a0dbeSGarrett Wollman 	while (lp < &line[sizeof(line) - 1]) {
6804a1a0dbeSGarrett Wollman 		if ((*lp++ = *cp++) == 0)
6814a1a0dbeSGarrett Wollman 			break;
6824a1a0dbeSGarrett Wollman 	}
683dea673e9SRodney W. Grimes 	lp[-1] = '/';
684004c9c5dSGarance A Drosehn 	linerem = sizeof(line) - (lp - line);
685dea673e9SRodney W. Grimes 
686004c9c5dSGarance A Drosehn 	cln_foundcore = 0;
6871d1d4a47SEitan Adler 	PRIV_START
6884a1a0dbeSGarrett Wollman 	nitems = scandir(pp->spool_dir, &queue, doselect, sortq);
6891d1d4a47SEitan Adler 	PRIV_END
690dea673e9SRodney W. Grimes 	if (nitems < 0) {
691004c9c5dSGarance A Drosehn 		if (!didhead) {
692004c9c5dSGarance A Drosehn 			printf("%s:\n", pp->printer);
693004c9c5dSGarance A Drosehn 			didhead = 1;
694004c9c5dSGarance A Drosehn 		}
695dea673e9SRodney W. Grimes 		printf("\tcannot examine spool directory\n");
696dea673e9SRodney W. Grimes 		return;
697dea673e9SRodney W. Grimes 	}
698004c9c5dSGarance A Drosehn 	if (cln_foundcore) {
699004c9c5dSGarance A Drosehn 		if (!didhead) {
700004c9c5dSGarance A Drosehn 			printf("%s:\n", pp->printer);
701004c9c5dSGarance A Drosehn 			didhead = 1;
702004c9c5dSGarance A Drosehn 		}
703004c9c5dSGarance A Drosehn 		printf("\t** found a core file in %s !\n", pp->spool_dir);
704004c9c5dSGarance A Drosehn 	}
705dea673e9SRodney W. Grimes 	if (nitems == 0)
706dea673e9SRodney W. Grimes 		return;
707004c9c5dSGarance A Drosehn 	if (!didhead)
708004c9c5dSGarance A Drosehn 		printf("%s:\n", pp->printer);
709ceeaedd3SGarance A Drosehn 	if (cln_debug) {
710ceeaedd3SGarance A Drosehn 		printf("\t** ----- Sorted list of files being checked:\n");
711ceeaedd3SGarance A Drosehn 		i = 0;
712ceeaedd3SGarance A Drosehn 		do {
713ceeaedd3SGarance A Drosehn 			cp = queue[i]->d_name;
714ceeaedd3SGarance A Drosehn 			printf("\t** [%3d] = %s\n", i, cp);
715ceeaedd3SGarance A Drosehn 		} while (++i < nitems);
716ceeaedd3SGarance A Drosehn 		printf("\t** ----- end of sorted list\n");
717ceeaedd3SGarance A Drosehn 	}
718dea673e9SRodney W. Grimes 	i = 0;
719dea673e9SRodney W. Grimes 	do {
720dea673e9SRodney W. Grimes 		cp = queue[i]->d_name;
721004c9c5dSGarance A Drosehn 		rmcp = 0;
722dea673e9SRodney W. Grimes 		if (*cp == 'c') {
723004c9c5dSGarance A Drosehn 			/*
724004c9c5dSGarance A Drosehn 			 * A control file.  Look for matching data-files.
725004c9c5dSGarance A Drosehn 			 */
726004c9c5dSGarance A Drosehn 			/* XXX
727004c9c5dSGarance A Drosehn 			 *  Note the logic here assumes that the hostname
728004c9c5dSGarance A Drosehn 			 *  part of cf-filenames match the hostname part
729004c9c5dSGarance A Drosehn 			 *  in df-filenames, and that is not necessarily
730004c9c5dSGarance A Drosehn 			 *  true (eg: for multi-homed hosts).  This needs
731004c9c5dSGarance A Drosehn 			 *  some further thought...
732004c9c5dSGarance A Drosehn 			 */
733dea673e9SRodney W. Grimes 			n = 0;
734dea673e9SRodney W. Grimes 			while (i + 1 < nitems) {
735dea673e9SRodney W. Grimes 				cp1 = queue[i + 1]->d_name;
736dea673e9SRodney W. Grimes 				if (*cp1 != 'd' || strcmp(cp + 3, cp1 + 3))
737dea673e9SRodney W. Grimes 					break;
738dea673e9SRodney W. Grimes 				i++;
739dea673e9SRodney W. Grimes 				n++;
740dea673e9SRodney W. Grimes 			}
741dea673e9SRodney W. Grimes 			if (n == 0) {
742004c9c5dSGarance A Drosehn 				rmcp = 1;
743dea673e9SRodney W. Grimes 			}
744004c9c5dSGarance A Drosehn 		} else if (*cp == 'e') {
745004c9c5dSGarance A Drosehn 			/*
746004c9c5dSGarance A Drosehn 			 * Must be an errrs or email temp file.
747004c9c5dSGarance A Drosehn 			 */
748004c9c5dSGarance A Drosehn 			rmcp = 1;
749dea673e9SRodney W. Grimes 		} else {
750dea673e9SRodney W. Grimes 			/*
751dea673e9SRodney W. Grimes 			 * Must be a df with no cf (otherwise, it would have
7521fd731faSGarance A Drosehn 			 * been skipped above) or an rf or tf file (which can
7531fd731faSGarance A Drosehn 			 * always be removed if it is old enough).
754dea673e9SRodney W. Grimes 			 */
755004c9c5dSGarance A Drosehn 			rmcp = 1;
756004c9c5dSGarance A Drosehn 		}
757004c9c5dSGarance A Drosehn 		if (rmcp) {
758004c9c5dSGarance A Drosehn 			if (strlen(cp) >= linerem) {
759004c9c5dSGarance A Drosehn 				printf("\t** internal error: 'line' overflow!\n");
760004c9c5dSGarance A Drosehn 				printf("\t**   spooldir = %s\n", pp->spool_dir);
761004c9c5dSGarance A Drosehn 				printf("\t**   cp = %s\n", cp);
762004c9c5dSGarance A Drosehn 				return;
763004c9c5dSGarance A Drosehn 			}
764004c9c5dSGarance A Drosehn 			strlcpy(lp, cp, linerem);
765dea673e9SRodney W. Grimes 			unlinkf(line);
766dea673e9SRodney W. Grimes 		}
767dea673e9SRodney W. Grimes      	} while (++i < nitems);
768dea673e9SRodney W. Grimes }
769dea673e9SRodney W. Grimes 
770dea673e9SRodney W. Grimes static void
771004c9c5dSGarance A Drosehn wrapup_clean(int laststatus __unused)
772004c9c5dSGarance A Drosehn {
773004c9c5dSGarance A Drosehn 
774004c9c5dSGarance A Drosehn 	printf("Checked %d queues, and ", cln_queuecnt);
775004c9c5dSGarance A Drosehn 	if (cln_filecnt < 1) {
776004c9c5dSGarance A Drosehn 		printf("no cruft was found\n");
777004c9c5dSGarance A Drosehn 		return;
778004c9c5dSGarance A Drosehn 	}
779004c9c5dSGarance A Drosehn 	if (cln_testonly) {
780004c9c5dSGarance A Drosehn 		printf("would have ");
781004c9c5dSGarance A Drosehn 	}
782004c9c5dSGarance A Drosehn 	printf("removed %d files (%ld bytes).\n", cln_filecnt, cln_sizecnt);
783004c9c5dSGarance A Drosehn }
784004c9c5dSGarance A Drosehn 
785004c9c5dSGarance A Drosehn static void
786ba7a1ad7SGarance A Drosehn unlinkf(char *name)
787dea673e9SRodney W. Grimes {
788004c9c5dSGarance A Drosehn 	struct stat stbuf;
789004c9c5dSGarance A Drosehn 	double agemod, agestat;
790004c9c5dSGarance A Drosehn 	int res;
791004c9c5dSGarance A Drosehn 	char linkbuf[BUFSIZ];
792004c9c5dSGarance A Drosehn 
793004c9c5dSGarance A Drosehn 	/*
794004c9c5dSGarance A Drosehn 	 * We have to use lstat() instead of stat(), in case this is a df*
795004c9c5dSGarance A Drosehn 	 * "file" which is really a symlink due to 'lpr -s' processing.  In
796004c9c5dSGarance A Drosehn 	 * that case, we need to check the last-mod time of the symlink, and
797004c9c5dSGarance A Drosehn 	 * not the file that the symlink is pointed at.
798004c9c5dSGarance A Drosehn 	 */
7991d1d4a47SEitan Adler 	PRIV_START
800004c9c5dSGarance A Drosehn 	res = lstat(name, &stbuf);
8011d1d4a47SEitan Adler 	PRIV_END
802004c9c5dSGarance A Drosehn 	if (res < 0) {
803004c9c5dSGarance A Drosehn 		printf("\terror return from stat(%s):\n", name);
804004c9c5dSGarance A Drosehn 		printf("\t      %s\n", strerror(errno));
805004c9c5dSGarance A Drosehn 		return;
806004c9c5dSGarance A Drosehn 	}
807004c9c5dSGarance A Drosehn 
808004c9c5dSGarance A Drosehn 	agemod = difftime(cln_now, stbuf.st_mtime);
809004c9c5dSGarance A Drosehn 	agestat = difftime(cln_now,  stbuf.st_ctime);
810ceeaedd3SGarance A Drosehn 	if (cln_debug > 1) {
811004c9c5dSGarance A Drosehn 		/* this debugging-aid probably is not needed any more... */
812004c9c5dSGarance A Drosehn 		printf("\t\t  modify age=%g secs, stat age=%g secs\n",
813004c9c5dSGarance A Drosehn 		    agemod, agestat);
814004c9c5dSGarance A Drosehn 	}
815004c9c5dSGarance A Drosehn 	if ((agemod <= cln_minage) && (agestat <= cln_minage))
816004c9c5dSGarance A Drosehn 		return;
817004c9c5dSGarance A Drosehn 
818004c9c5dSGarance A Drosehn 	/*
819004c9c5dSGarance A Drosehn 	 * if this file is a symlink, then find out the target of the
820004c9c5dSGarance A Drosehn 	 * symlink before unlink-ing the file itself
821004c9c5dSGarance A Drosehn 	 */
822004c9c5dSGarance A Drosehn 	if (S_ISLNK(stbuf.st_mode)) {
8231d1d4a47SEitan Adler 		PRIV_START
824004c9c5dSGarance A Drosehn 		res = readlink(name, linkbuf, sizeof(linkbuf));
8251d1d4a47SEitan Adler 		PRIV_END
826004c9c5dSGarance A Drosehn 		if (res < 0) {
827004c9c5dSGarance A Drosehn 			printf("\terror return from readlink(%s):\n", name);
828004c9c5dSGarance A Drosehn 			printf("\t      %s\n", strerror(errno));
829004c9c5dSGarance A Drosehn 			return;
830004c9c5dSGarance A Drosehn 		}
831004c9c5dSGarance A Drosehn 		if (res == sizeof(linkbuf))
832004c9c5dSGarance A Drosehn 			res--;
833004c9c5dSGarance A Drosehn 		linkbuf[res] = '\0';
834004c9c5dSGarance A Drosehn 	}
835004c9c5dSGarance A Drosehn 
836004c9c5dSGarance A Drosehn 	cln_filecnt++;
837004c9c5dSGarance A Drosehn 	cln_sizecnt += stbuf.st_size;
838004c9c5dSGarance A Drosehn 
839004c9c5dSGarance A Drosehn 	if (cln_testonly) {
840004c9c5dSGarance A Drosehn 		printf("\twould remove %s\n", name);
841004c9c5dSGarance A Drosehn 		if (S_ISLNK(stbuf.st_mode)) {
842004c9c5dSGarance A Drosehn 			printf("\t    (which is a symlink to %s)\n", linkbuf);
843004c9c5dSGarance A Drosehn 		}
844004c9c5dSGarance A Drosehn 	} else {
8451d1d4a47SEitan Adler 		PRIV_START
846004c9c5dSGarance A Drosehn 		res = unlink(name);
8471d1d4a47SEitan Adler 		PRIV_END
848004c9c5dSGarance A Drosehn 		if (res < 0)
849004c9c5dSGarance A Drosehn 			printf("\tcannot remove %s (!)\n", name);
850dea673e9SRodney W. Grimes 		else
851dea673e9SRodney W. Grimes 			printf("\tremoved %s\n", name);
852004c9c5dSGarance A Drosehn 		/* XXX
853004c9c5dSGarance A Drosehn 		 *  Note that for a df* file, this code should also check to see
854004c9c5dSGarance A Drosehn 		 *  if it is a symlink to some other file, and if the original
855004c9c5dSGarance A Drosehn 		 *  lpr command included '-r' ("remove file").  Of course, this
856004c9c5dSGarance A Drosehn 		 *  code would not be removing the df* file unless there was no
857004c9c5dSGarance A Drosehn 		 *  matching cf* file, and without the cf* file it is currently
858004c9c5dSGarance A Drosehn 		 *  impossible to determine if '-r' had been specified...
859004c9c5dSGarance A Drosehn 		 *
860004c9c5dSGarance A Drosehn 		 *  As a result of this quandry, we may be leaving behind a
861004c9c5dSGarance A Drosehn 		 *  user's file that was supposed to have been removed after
862004c9c5dSGarance A Drosehn 		 *  being printed.  This may effect services such as CAP or
863004c9c5dSGarance A Drosehn 		 *  samba, if they were configured to use 'lpr -r', and if
864004c9c5dSGarance A Drosehn 		 *  datafiles are not being properly removed.
865004c9c5dSGarance A Drosehn 		*/
866004c9c5dSGarance A Drosehn 		if (S_ISLNK(stbuf.st_mode)) {
867004c9c5dSGarance A Drosehn 			printf("\t    (which was a symlink to %s)\n", linkbuf);
868004c9c5dSGarance A Drosehn 		}
869004c9c5dSGarance A Drosehn 	}
870dea673e9SRodney W. Grimes }
871dea673e9SRodney W. Grimes 
872dea673e9SRodney W. Grimes /*
873e8e715faSGarance A Drosehn  * Enable queuing to the printer (allow lpr to add new jobs to the queue).
874e8e715faSGarance A Drosehn  */
875e8e715faSGarance A Drosehn void
876e8e715faSGarance A Drosehn enable_q(struct printer *pp)
877e8e715faSGarance A Drosehn {
878e8e715faSGarance A Drosehn 	int setres;
879e8e715faSGarance A Drosehn 	char lf[MAXPATHLEN];
880e8e715faSGarance A Drosehn 
881e8e715faSGarance A Drosehn 	lock_file_name(pp, lf, sizeof lf);
882e8e715faSGarance A Drosehn 	printf("%s:\n", pp->printer);
883e8e715faSGarance A Drosehn 
884e8e715faSGarance A Drosehn 	setres = set_qstate(SQS_ENABLEQ, lf);
885e8e715faSGarance A Drosehn }
886e8e715faSGarance A Drosehn 
887e8e715faSGarance A Drosehn /*
888dea673e9SRodney W. Grimes  * Disable queuing.
889dea673e9SRodney W. Grimes  */
890dea673e9SRodney W. Grimes void
891e8e715faSGarance A Drosehn disable_q(struct printer *pp)
892e8e715faSGarance A Drosehn {
893e8e715faSGarance A Drosehn 	int setres;
894e8e715faSGarance A Drosehn 	char lf[MAXPATHLEN];
895e8e715faSGarance A Drosehn 
896e8e715faSGarance A Drosehn 	lock_file_name(pp, lf, sizeof lf);
897e8e715faSGarance A Drosehn 	printf("%s:\n", pp->printer);
898e8e715faSGarance A Drosehn 
899e8e715faSGarance A Drosehn 	setres = set_qstate(SQS_DISABLEQ, lf);
900e8e715faSGarance A Drosehn }
901e8e715faSGarance A Drosehn 
902e8e715faSGarance A Drosehn /*
903dea673e9SRodney W. Grimes  * Disable queuing and printing and put a message into the status file
9045b1c34fbSGarance A Drosehn  * (reason for being down).  If the user specified `-msg', then use
9055b1c34fbSGarance A Drosehn  * everything after that as the message for the status file.  If the
9065b1c34fbSGarance A Drosehn  * user did NOT specify `-msg', then the command should take the first
9075b1c34fbSGarance A Drosehn  * parameter as the printer name, and all remaining parameters as the
9085b1c34fbSGarance A Drosehn  * message for the status file.  (This is to be compatible with the
9095b1c34fbSGarance A Drosehn  * original definition of 'down', which was implemented long before
9105b1c34fbSGarance A Drosehn  * `-msg' was around).
9115b1c34fbSGarance A Drosehn  */
9125b1c34fbSGarance A Drosehn void
9135b1c34fbSGarance A Drosehn down_gi(int argc, char *argv[])
9145b1c34fbSGarance A Drosehn {
9155b1c34fbSGarance A Drosehn 
9165b1c34fbSGarance A Drosehn 	/* If `-msg' was specified, then this routine has nothing to do. */
9175b1c34fbSGarance A Drosehn 	if (generic_msg != NULL)
9185b1c34fbSGarance A Drosehn 		return;
9195b1c34fbSGarance A Drosehn 
9205b1c34fbSGarance A Drosehn 	/*
9215b1c34fbSGarance A Drosehn 	 * If the user only gave one parameter, then use a default msg.
9225b1c34fbSGarance A Drosehn 	 * (if argc == 1 at this point, then *argv == name of printer).
9235b1c34fbSGarance A Drosehn 	 */
9245b1c34fbSGarance A Drosehn 	if (argc == 1) {
9255b1c34fbSGarance A Drosehn 		generic_msg = strdup("printing disabled\n");
9265b1c34fbSGarance A Drosehn 		return;
9275b1c34fbSGarance A Drosehn 	}
9285b1c34fbSGarance A Drosehn 
9295b1c34fbSGarance A Drosehn 	/*
9305b1c34fbSGarance A Drosehn 	 * The user specified multiple parameters, and did not specify
9315b1c34fbSGarance A Drosehn 	 * `-msg'.  Build a message from all the parameters after the
9325b1c34fbSGarance A Drosehn 	 * first one (and nullify those parameters so generic-processing
9335b1c34fbSGarance A Drosehn 	 * will not process them as printer-queue names).
9345b1c34fbSGarance A Drosehn 	 */
9355b1c34fbSGarance A Drosehn 	argc--;
9365b1c34fbSGarance A Drosehn 	argv++;
9375b1c34fbSGarance A Drosehn 	generic_msg = args2line(argc, argv);
9385b1c34fbSGarance A Drosehn 	for (; argc > 0; argc--, argv++)
9395b1c34fbSGarance A Drosehn 		*argv = generic_nullarg;	/* "erase" it */
9405b1c34fbSGarance A Drosehn }
9415b1c34fbSGarance A Drosehn 
9425b1c34fbSGarance A Drosehn void
9435b1c34fbSGarance A Drosehn down_q(struct printer *pp)
9445b1c34fbSGarance A Drosehn {
9455b1c34fbSGarance A Drosehn 	int setres;
9465b1c34fbSGarance A Drosehn 	char lf[MAXPATHLEN];
9475b1c34fbSGarance A Drosehn 
9485b1c34fbSGarance A Drosehn 	lock_file_name(pp, lf, sizeof lf);
9495b1c34fbSGarance A Drosehn 	printf("%s:\n", pp->printer);
9505b1c34fbSGarance A Drosehn 
9515b1c34fbSGarance A Drosehn 	setres = set_qstate(SQS_DISABLEQ+SQS_STOPP, lf);
9525b1c34fbSGarance A Drosehn 	if (setres >= 0)
9535b1c34fbSGarance A Drosehn 		upstat(pp, generic_msg, 1);
9545b1c34fbSGarance A Drosehn }
9555b1c34fbSGarance A Drosehn 
9565b1c34fbSGarance A Drosehn /*
957dea673e9SRodney W. Grimes  * Exit lpc
958dea673e9SRodney W. Grimes  */
959dea673e9SRodney W. Grimes void
960ba7a1ad7SGarance A Drosehn quit(int argc __unused, char *argv[] __unused)
961dea673e9SRodney W. Grimes {
962dea673e9SRodney W. Grimes 	exit(0);
963dea673e9SRodney W. Grimes }
964dea673e9SRodney W. Grimes 
965dea673e9SRodney W. Grimes /*
966dea673e9SRodney W. Grimes  * Kill and restart the daemon.
967dea673e9SRodney W. Grimes  */
968dea673e9SRodney W. Grimes void
969e8e715faSGarance A Drosehn restart_q(struct printer *pp)
970e8e715faSGarance A Drosehn {
971e8e715faSGarance A Drosehn 	int killres, setres, startok;
972e8e715faSGarance A Drosehn 	char lf[MAXPATHLEN];
973e8e715faSGarance A Drosehn 
974e8e715faSGarance A Drosehn 	lock_file_name(pp, lf, sizeof lf);
975e8e715faSGarance A Drosehn 	printf("%s:\n", pp->printer);
976e8e715faSGarance A Drosehn 
977e8e715faSGarance A Drosehn 	killres = kill_qtask(lf);
978e8e715faSGarance A Drosehn 
979e8e715faSGarance A Drosehn 	/*
980e8e715faSGarance A Drosehn 	 * XXX - if the kill worked, we should probably sleep for
981e8e715faSGarance A Drosehn 	 *      a second or so before trying to restart the queue.
982e8e715faSGarance A Drosehn 	 */
983e8e715faSGarance A Drosehn 
984e8e715faSGarance A Drosehn 	/* make sure the queue is set to print jobs */
985e8e715faSGarance A Drosehn 	setres = set_qstate(SQS_STARTP, lf);
986e8e715faSGarance A Drosehn 
9871d1d4a47SEitan Adler 	PRIV_START
988e8e715faSGarance A Drosehn 	startok = startdaemon(pp);
9891d1d4a47SEitan Adler 	PRIV_END
990e8e715faSGarance A Drosehn 	if (!startok)
991e8e715faSGarance A Drosehn 		printf("\tcouldn't restart daemon\n");
992e8e715faSGarance A Drosehn 	else
993e8e715faSGarance A Drosehn 		printf("\tdaemon restarted\n");
994e8e715faSGarance A Drosehn }
995e8e715faSGarance A Drosehn 
996e8e715faSGarance A Drosehn /*
99754032d11SGarance A Drosehn  * Set the status message of each queue listed.  Requires a "-msg"
99854032d11SGarance A Drosehn  * parameter to indicate the end of the queue list and start of msg text.
99954032d11SGarance A Drosehn  */
100054032d11SGarance A Drosehn void
100154032d11SGarance A Drosehn setstatus_gi(int argc __unused, char *argv[] __unused)
100254032d11SGarance A Drosehn {
100354032d11SGarance A Drosehn 
100454032d11SGarance A Drosehn 	if (generic_msg == NULL) {
100554032d11SGarance A Drosehn 		printf("You must specify '-msg' before the text of the new status message.\n");
100654032d11SGarance A Drosehn 		generic_initerr = 1;
100754032d11SGarance A Drosehn 	}
100854032d11SGarance A Drosehn }
100954032d11SGarance A Drosehn 
101054032d11SGarance A Drosehn void
101154032d11SGarance A Drosehn setstatus_q(struct printer *pp)
101254032d11SGarance A Drosehn {
10137574a1c1SGarance A Drosehn 	struct stat stbuf;
10147574a1c1SGarance A Drosehn 	int not_shown;
101554032d11SGarance A Drosehn 	char lf[MAXPATHLEN];
101654032d11SGarance A Drosehn 
101754032d11SGarance A Drosehn 	lock_file_name(pp, lf, sizeof lf);
101854032d11SGarance A Drosehn 	printf("%s:\n", pp->printer);
101954032d11SGarance A Drosehn 
102054032d11SGarance A Drosehn 	upstat(pp, generic_msg, 1);
10217574a1c1SGarance A Drosehn 
10227574a1c1SGarance A Drosehn 	/*
10237574a1c1SGarance A Drosehn 	 * Warn the user if 'lpq' will not display this new status-message.
10247574a1c1SGarance A Drosehn 	 * Note that if lock file does not exist, then the queue is enabled
10257574a1c1SGarance A Drosehn 	 * for both queuing and printing.
10267574a1c1SGarance A Drosehn 	 */
10277574a1c1SGarance A Drosehn 	not_shown = 1;
10287574a1c1SGarance A Drosehn 	if (stat(lf, &stbuf) >= 0) {
10297574a1c1SGarance A Drosehn 		if (stbuf.st_mode & LFM_PRINT_DIS)
10307574a1c1SGarance A Drosehn 			not_shown = 0;
10317574a1c1SGarance A Drosehn 	}
10327574a1c1SGarance A Drosehn 	if (not_shown) {
10337574a1c1SGarance A Drosehn 		printf("\tnote: This queue currently has printing enabled,\n");
10347574a1c1SGarance A Drosehn 		printf("\t    so this -msg will only be shown by 'lpq' if\n");
10357574a1c1SGarance A Drosehn 		printf("\t    a job is actively printing on it.\n");
10367574a1c1SGarance A Drosehn 	}
103754032d11SGarance A Drosehn }
103854032d11SGarance A Drosehn 
103954032d11SGarance A Drosehn /*
1040dea673e9SRodney W. Grimes  * Enable printing on the specified printer and startup the daemon.
1041dea673e9SRodney W. Grimes  */
1042dea673e9SRodney W. Grimes void
1043e8e715faSGarance A Drosehn start_q(struct printer *pp)
1044e8e715faSGarance A Drosehn {
1045e8e715faSGarance A Drosehn 	int setres, startok;
1046e8e715faSGarance A Drosehn 	char lf[MAXPATHLEN];
1047e8e715faSGarance A Drosehn 
1048e8e715faSGarance A Drosehn 	lock_file_name(pp, lf, sizeof lf);
1049e8e715faSGarance A Drosehn 	printf("%s:\n", pp->printer);
1050e8e715faSGarance A Drosehn 
1051e8e715faSGarance A Drosehn 	setres = set_qstate(SQS_STARTP, lf);
1052e8e715faSGarance A Drosehn 
10531d1d4a47SEitan Adler 	PRIV_START
1054e8e715faSGarance A Drosehn 	startok = startdaemon(pp);
10551d1d4a47SEitan Adler 	PRIV_END
1056e8e715faSGarance A Drosehn 	if (!startok)
1057e8e715faSGarance A Drosehn 		printf("\tcouldn't start daemon\n");
1058e8e715faSGarance A Drosehn 	else
1059e8e715faSGarance A Drosehn 		printf("\tdaemon started\n");
10601d1d4a47SEitan Adler 	PRIV_END
1061e8e715faSGarance A Drosehn }
1062e8e715faSGarance A Drosehn 
1063e8e715faSGarance A Drosehn /*
1064dea673e9SRodney W. Grimes  * Print the status of the printer queue.
1065dea673e9SRodney W. Grimes  */
10664a1a0dbeSGarrett Wollman void
1067ba7a1ad7SGarance A Drosehn status(struct printer *pp)
1068dea673e9SRodney W. Grimes {
1069dea673e9SRodney W. Grimes 	struct stat stbuf;
1070dea673e9SRodney W. Grimes 	register int fd, i;
1071dea673e9SRodney W. Grimes 	register struct dirent *dp;
1072dea673e9SRodney W. Grimes 	DIR *dirp;
10734a1a0dbeSGarrett Wollman 	char file[MAXPATHLEN];
1074dea673e9SRodney W. Grimes 
10754a1a0dbeSGarrett Wollman 	printf("%s:\n", pp->printer);
10764a1a0dbeSGarrett Wollman 	lock_file_name(pp, file, sizeof file);
10774a1a0dbeSGarrett Wollman 	if (stat(file, &stbuf) >= 0) {
1078dea673e9SRodney W. Grimes 		printf("\tqueuing is %s\n",
10794a1a0dbeSGarrett Wollman 		       ((stbuf.st_mode & LFM_QUEUE_DIS) ? "disabled"
10804a1a0dbeSGarrett Wollman 			: "enabled"));
1081dea673e9SRodney W. Grimes 		printf("\tprinting is %s\n",
10824a1a0dbeSGarrett Wollman 		       ((stbuf.st_mode & LFM_PRINT_DIS) ? "disabled"
10834a1a0dbeSGarrett Wollman 			: "enabled"));
1084dea673e9SRodney W. Grimes 	} else {
1085dea673e9SRodney W. Grimes 		printf("\tqueuing is enabled\n");
1086dea673e9SRodney W. Grimes 		printf("\tprinting is enabled\n");
1087dea673e9SRodney W. Grimes 	}
10884a1a0dbeSGarrett Wollman 	if ((dirp = opendir(pp->spool_dir)) == NULL) {
1089dea673e9SRodney W. Grimes 		printf("\tcannot examine spool directory\n");
1090dea673e9SRodney W. Grimes 		return;
1091dea673e9SRodney W. Grimes 	}
1092dea673e9SRodney W. Grimes 	i = 0;
1093dea673e9SRodney W. Grimes 	while ((dp = readdir(dirp)) != NULL) {
1094dea673e9SRodney W. Grimes 		if (*dp->d_name == 'c' && dp->d_name[1] == 'f')
1095dea673e9SRodney W. Grimes 			i++;
1096dea673e9SRodney W. Grimes 	}
1097dea673e9SRodney W. Grimes 	closedir(dirp);
1098dea673e9SRodney W. Grimes 	if (i == 0)
10994a1a0dbeSGarrett Wollman 		printf("\tno entries in spool area\n");
1100dea673e9SRodney W. Grimes 	else if (i == 1)
1101dea673e9SRodney W. Grimes 		printf("\t1 entry in spool area\n");
1102dea673e9SRodney W. Grimes 	else
1103dea673e9SRodney W. Grimes 		printf("\t%d entries in spool area\n", i);
11044a1a0dbeSGarrett Wollman 	fd = open(file, O_RDONLY);
1105dea673e9SRodney W. Grimes 	if (fd < 0 || flock(fd, LOCK_SH|LOCK_NB) == 0) {
1106dea673e9SRodney W. Grimes 		(void) close(fd);	/* unlocks as well */
1107bc407914SWarner Losh 		printf("\tprinter idle\n");
1108dea673e9SRodney W. Grimes 		return;
1109dea673e9SRodney W. Grimes 	}
1110dea673e9SRodney W. Grimes 	(void) close(fd);
111136abea5dSBrian Somers 	/* print out the contents of the status file, if it exists */
11124a1a0dbeSGarrett Wollman 	status_file_name(pp, file, sizeof file);
11134a1a0dbeSGarrett Wollman 	fd = open(file, O_RDONLY|O_SHLOCK);
1114dea673e9SRodney W. Grimes 	if (fd >= 0) {
111536abea5dSBrian Somers 		(void) fstat(fd, &stbuf);
111636abea5dSBrian Somers 		if (stbuf.st_size > 0) {
111736abea5dSBrian Somers 			putchar('\t');
1118dea673e9SRodney W. Grimes 			while ((i = read(fd, line, sizeof(line))) > 0)
1119dea673e9SRodney W. Grimes 				(void) fwrite(line, 1, i, stdout);
112036abea5dSBrian Somers 		}
1121dea673e9SRodney W. Grimes 		(void) close(fd);	/* unlocks as well */
1122dea673e9SRodney W. Grimes 	}
1123dea673e9SRodney W. Grimes }
1124dea673e9SRodney W. Grimes 
1125dea673e9SRodney W. Grimes /*
1126dea673e9SRodney W. Grimes  * Stop the specified daemon after completing the current job and disable
1127dea673e9SRodney W. Grimes  * printing.
1128dea673e9SRodney W. Grimes  */
1129dea673e9SRodney W. Grimes void
1130e8e715faSGarance A Drosehn stop_q(struct printer *pp)
1131e8e715faSGarance A Drosehn {
1132e8e715faSGarance A Drosehn 	int setres;
1133e8e715faSGarance A Drosehn 	char lf[MAXPATHLEN];
1134e8e715faSGarance A Drosehn 
1135e8e715faSGarance A Drosehn 	lock_file_name(pp, lf, sizeof lf);
1136e8e715faSGarance A Drosehn 	printf("%s:\n", pp->printer);
1137e8e715faSGarance A Drosehn 
1138e8e715faSGarance A Drosehn 	setres = set_qstate(SQS_STOPP, lf);
1139e8e715faSGarance A Drosehn 
114054032d11SGarance A Drosehn 	if (setres >= 0)
114154032d11SGarance A Drosehn 		upstat(pp, "printing disabled\n", 0);
1142e8e715faSGarance A Drosehn }
1143e8e715faSGarance A Drosehn 
114430b4b758SGarance A Drosehn struct	jobqueue **queue;
1145dea673e9SRodney W. Grimes int	nitems;
1146dea673e9SRodney W. Grimes time_t	mtime;
1147dea673e9SRodney W. Grimes 
1148dea673e9SRodney W. Grimes /*
1149dea673e9SRodney W. Grimes  * Put the specified jobs at the top of printer queue.
1150dea673e9SRodney W. Grimes  */
1151dea673e9SRodney W. Grimes void
1152ba7a1ad7SGarance A Drosehn topq(int argc, char *argv[])
1153dea673e9SRodney W. Grimes {
1154dea673e9SRodney W. Grimes 	register int i;
1155dea673e9SRodney W. Grimes 	struct stat stbuf;
1156ba7a1ad7SGarance A Drosehn 	int cmdstatus, changed;
11574a1a0dbeSGarrett Wollman 	struct printer myprinter, *pp = &myprinter;
1158dea673e9SRodney W. Grimes 
1159dea673e9SRodney W. Grimes 	if (argc < 3) {
1160d3974088SDag-Erling Smørgrav 		printf("usage: topq printer [jobnum ...] [user ...]\n");
1161dea673e9SRodney W. Grimes 		return;
1162dea673e9SRodney W. Grimes 	}
1163dea673e9SRodney W. Grimes 
1164dea673e9SRodney W. Grimes 	--argc;
11654a1a0dbeSGarrett Wollman 	++argv;
11664a1a0dbeSGarrett Wollman 	init_printer(pp);
1167ba7a1ad7SGarance A Drosehn 	cmdstatus = getprintcap(*argv, pp);
1168ba7a1ad7SGarance A Drosehn 	switch(cmdstatus) {
11694a1a0dbeSGarrett Wollman 	default:
11706d39e1b7SGarance A Drosehn 		fatal(pp, "%s", pcaperr(cmdstatus));
11714a1a0dbeSGarrett Wollman 	case PCAPERR_NOTFOUND:
11724a1a0dbeSGarrett Wollman 		printf("unknown printer %s\n", *argv);
1173dea673e9SRodney W. Grimes 		return;
11744a1a0dbeSGarrett Wollman 	case PCAPERR_TCOPEN:
11754a1a0dbeSGarrett Wollman 		printf("warning: %s: unresolved tc= reference(s)", *argv);
11764a1a0dbeSGarrett Wollman 		break;
11774a1a0dbeSGarrett Wollman 	case PCAPERR_SUCCESS:
11784a1a0dbeSGarrett Wollman 		break;
11794a1a0dbeSGarrett Wollman 	}
11804a1a0dbeSGarrett Wollman 	printf("%s:\n", pp->printer);
1181dea673e9SRodney W. Grimes 
11821d1d4a47SEitan Adler 	PRIV_START
11834a1a0dbeSGarrett Wollman 	if (chdir(pp->spool_dir) < 0) {
11844a1a0dbeSGarrett Wollman 		printf("\tcannot chdir to %s\n", pp->spool_dir);
1185360d4ad5SWarner Losh 		goto out;
1186dea673e9SRodney W. Grimes 	}
11871d1d4a47SEitan Adler 	PRIV_END
11884a1a0dbeSGarrett Wollman 	nitems = getq(pp, &queue);
1189dea673e9SRodney W. Grimes 	if (nitems == 0)
1190dea673e9SRodney W. Grimes 		return;
1191dea673e9SRodney W. Grimes 	changed = 0;
119230b4b758SGarance A Drosehn 	mtime = queue[0]->job_time;
1193dea673e9SRodney W. Grimes 	for (i = argc; --i; ) {
1194dea673e9SRodney W. Grimes 		if (doarg(argv[i]) == 0) {
1195dea673e9SRodney W. Grimes 			printf("\tjob %s is not in the queue\n", argv[i]);
1196dea673e9SRodney W. Grimes 			continue;
1197dea673e9SRodney W. Grimes 		} else
1198dea673e9SRodney W. Grimes 			changed++;
1199dea673e9SRodney W. Grimes 	}
1200dea673e9SRodney W. Grimes 	for (i = 0; i < nitems; i++)
1201dea673e9SRodney W. Grimes 		free(queue[i]);
1202dea673e9SRodney W. Grimes 	free(queue);
1203dea673e9SRodney W. Grimes 	if (!changed) {
1204dea673e9SRodney W. Grimes 		printf("\tqueue order unchanged\n");
1205dea673e9SRodney W. Grimes 		return;
1206dea673e9SRodney W. Grimes 	}
1207dea673e9SRodney W. Grimes 	/*
1208dea673e9SRodney W. Grimes 	 * Turn on the public execute bit of the lock file to
1209dea673e9SRodney W. Grimes 	 * get lpd to rebuild the queue after the current job.
1210dea673e9SRodney W. Grimes 	 */
12111d1d4a47SEitan Adler 	PRIV_START
12124a1a0dbeSGarrett Wollman 	if (changed && stat(pp->lock_file, &stbuf) >= 0)
12134a1a0dbeSGarrett Wollman 		(void) chmod(pp->lock_file, stbuf.st_mode | LFM_RESET_QUE);
1214360d4ad5SWarner Losh 
1215360d4ad5SWarner Losh out:
12161d1d4a47SEitan Adler 	PRIV_END
1217dea673e9SRodney W. Grimes }
1218dea673e9SRodney W. Grimes 
1219dea673e9SRodney W. Grimes /*
1220dea673e9SRodney W. Grimes  * Reposition the job by changing the modification time of
1221dea673e9SRodney W. Grimes  * the control file.
1222dea673e9SRodney W. Grimes  */
1223dea673e9SRodney W. Grimes static int
1224ba7a1ad7SGarance A Drosehn touch(struct jobqueue *jq)
1225dea673e9SRodney W. Grimes {
1226dea673e9SRodney W. Grimes 	struct timeval tvp[2];
1227360d4ad5SWarner Losh 	int ret;
1228dea673e9SRodney W. Grimes 
1229dea673e9SRodney W. Grimes 	tvp[0].tv_sec = tvp[1].tv_sec = --mtime;
1230dea673e9SRodney W. Grimes 	tvp[0].tv_usec = tvp[1].tv_usec = 0;
12311d1d4a47SEitan Adler 	PRIV_START
1232ba7a1ad7SGarance A Drosehn 	ret = utimes(jq->job_cfname, tvp);
12331d1d4a47SEitan Adler 	PRIV_END
1234360d4ad5SWarner Losh 	return (ret);
1235dea673e9SRodney W. Grimes }
1236dea673e9SRodney W. Grimes 
1237dea673e9SRodney W. Grimes /*
1238dea673e9SRodney W. Grimes  * Checks if specified job name is in the printer's queue.
1239dea673e9SRodney W. Grimes  * Returns:  negative (-1) if argument name is not in the queue.
1240dea673e9SRodney W. Grimes  */
1241dea673e9SRodney W. Grimes static int
1242ba7a1ad7SGarance A Drosehn doarg(char *job)
1243dea673e9SRodney W. Grimes {
124430b4b758SGarance A Drosehn 	register struct jobqueue **qq;
1245dea673e9SRodney W. Grimes 	register int jobnum, n;
1246dea673e9SRodney W. Grimes 	register char *cp, *machine;
1247dea673e9SRodney W. Grimes 	int cnt = 0;
1248dea673e9SRodney W. Grimes 	FILE *fp;
1249dea673e9SRodney W. Grimes 
1250dea673e9SRodney W. Grimes 	/*
1251dea673e9SRodney W. Grimes 	 * Look for a job item consisting of system name, colon, number
1252dea673e9SRodney W. Grimes 	 * (example: ucbarpa:114)
1253dea673e9SRodney W. Grimes 	 */
1254f8eb25daSWarner Losh 	if ((cp = strchr(job, ':')) != NULL) {
1255dea673e9SRodney W. Grimes 		machine = job;
1256dea673e9SRodney W. Grimes 		*cp++ = '\0';
1257dea673e9SRodney W. Grimes 		job = cp;
1258dea673e9SRodney W. Grimes 	} else
1259dea673e9SRodney W. Grimes 		machine = NULL;
1260dea673e9SRodney W. Grimes 
1261dea673e9SRodney W. Grimes 	/*
1262dea673e9SRodney W. Grimes 	 * Check for job specified by number (example: 112 or 235ucbarpa).
1263dea673e9SRodney W. Grimes 	 */
1264dea673e9SRodney W. Grimes 	if (isdigit(*job)) {
1265dea673e9SRodney W. Grimes 		jobnum = 0;
1266dea673e9SRodney W. Grimes 		do
1267dea673e9SRodney W. Grimes 			jobnum = jobnum * 10 + (*job++ - '0');
1268dea673e9SRodney W. Grimes 		while (isdigit(*job));
1269dea673e9SRodney W. Grimes 		for (qq = queue + nitems; --qq >= queue; ) {
1270dea673e9SRodney W. Grimes 			n = 0;
127130b4b758SGarance A Drosehn 			for (cp = (*qq)->job_cfname+3; isdigit(*cp); )
1272dea673e9SRodney W. Grimes 				n = n * 10 + (*cp++ - '0');
1273dea673e9SRodney W. Grimes 			if (jobnum != n)
1274dea673e9SRodney W. Grimes 				continue;
1275dea673e9SRodney W. Grimes 			if (*job && strcmp(job, cp) != 0)
1276dea673e9SRodney W. Grimes 				continue;
1277dea673e9SRodney W. Grimes 			if (machine != NULL && strcmp(machine, cp) != 0)
1278dea673e9SRodney W. Grimes 				continue;
1279dea673e9SRodney W. Grimes 			if (touch(*qq) == 0) {
128030b4b758SGarance A Drosehn 				printf("\tmoved %s\n", (*qq)->job_cfname);
1281dea673e9SRodney W. Grimes 				cnt++;
1282dea673e9SRodney W. Grimes 			}
1283dea673e9SRodney W. Grimes 		}
1284dea673e9SRodney W. Grimes 		return(cnt);
1285dea673e9SRodney W. Grimes 	}
1286dea673e9SRodney W. Grimes 	/*
1287dea673e9SRodney W. Grimes 	 * Process item consisting of owner's name (example: henry).
1288dea673e9SRodney W. Grimes 	 */
1289dea673e9SRodney W. Grimes 	for (qq = queue + nitems; --qq >= queue; ) {
12901d1d4a47SEitan Adler 		PRIV_START
129130b4b758SGarance A Drosehn 		fp = fopen((*qq)->job_cfname, "r");
12921d1d4a47SEitan Adler 		PRIV_END
1293360d4ad5SWarner Losh 		if (fp == NULL)
1294dea673e9SRodney W. Grimes 			continue;
1295a9c48188SBaptiste Daroussin 		while (get_line(fp) > 0)
1296dea673e9SRodney W. Grimes 			if (line[0] == 'P')
1297dea673e9SRodney W. Grimes 				break;
1298dea673e9SRodney W. Grimes 		(void) fclose(fp);
1299dea673e9SRodney W. Grimes 		if (line[0] != 'P' || strcmp(job, line+1) != 0)
1300dea673e9SRodney W. Grimes 			continue;
1301dea673e9SRodney W. Grimes 		if (touch(*qq) == 0) {
130230b4b758SGarance A Drosehn 			printf("\tmoved %s\n", (*qq)->job_cfname);
1303dea673e9SRodney W. Grimes 			cnt++;
1304dea673e9SRodney W. Grimes 		}
1305dea673e9SRodney W. Grimes 	}
1306dea673e9SRodney W. Grimes 	return(cnt);
1307dea673e9SRodney W. Grimes }
1308dea673e9SRodney W. Grimes 
1309dea673e9SRodney W. Grimes /*
1310e8e715faSGarance A Drosehn  * Enable both queuing & printing, and start printer (undo `down').
1311e8e715faSGarance A Drosehn  */
1312e8e715faSGarance A Drosehn void
1313e8e715faSGarance A Drosehn up_q(struct printer *pp)
1314e8e715faSGarance A Drosehn {
1315e8e715faSGarance A Drosehn 	int setres, startok;
1316e8e715faSGarance A Drosehn 	char lf[MAXPATHLEN];
1317e8e715faSGarance A Drosehn 
1318e8e715faSGarance A Drosehn 	lock_file_name(pp, lf, sizeof lf);
1319e8e715faSGarance A Drosehn 	printf("%s:\n", pp->printer);
1320e8e715faSGarance A Drosehn 
1321e8e715faSGarance A Drosehn 	setres = set_qstate(SQS_ENABLEQ+SQS_STARTP, lf);
1322e8e715faSGarance A Drosehn 
13231d1d4a47SEitan Adler 	PRIV_START
1324e8e715faSGarance A Drosehn 	startok = startdaemon(pp);
13251d1d4a47SEitan Adler 	PRIV_END
1326e8e715faSGarance A Drosehn 	if (!startok)
1327e8e715faSGarance A Drosehn 		printf("\tcouldn't start daemon\n");
1328e8e715faSGarance A Drosehn 	else
1329e8e715faSGarance A Drosehn 		printf("\tdaemon started\n");
1330e8e715faSGarance A Drosehn }
1331