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