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. 14dea673e9SRodney W. Grimes * 4. 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> 57dea673e9SRodney W. Grimes #include <errno.h> 58dea673e9SRodney W. Grimes #include <dirent.h> 59dea673e9SRodney W. Grimes #include <unistd.h> 60dea673e9SRodney W. Grimes #include <stdlib.h> 61dea673e9SRodney W. Grimes #include <stdio.h> 62dea673e9SRodney W. Grimes #include <ctype.h> 63dea673e9SRodney W. Grimes #include <string.h> 64dea673e9SRodney W. Grimes #include "lp.h" 65dea673e9SRodney W. Grimes #include "lp.local.h" 66dea673e9SRodney W. Grimes #include "lpc.h" 67dea673e9SRodney W. Grimes #include "extern.h" 68dea673e9SRodney W. Grimes #include "pathnames.h" 69dea673e9SRodney W. Grimes 70e8e715faSGarance A Drosehn /* 71e8e715faSGarance A Drosehn * Return values from kill_qtask(). 72e8e715faSGarance A Drosehn */ 73e8e715faSGarance A Drosehn #define KQT_LFERROR -2 74e8e715faSGarance A Drosehn #define KQT_KILLFAIL -1 75e8e715faSGarance A Drosehn #define KQT_NODAEMON 0 76e8e715faSGarance A Drosehn #define KQT_KILLOK 1 77e8e715faSGarance A Drosehn 7854032d11SGarance A Drosehn static char *args2line(int argc, char **argv); 79ba7a1ad7SGarance A Drosehn static int doarg(char *_job); 80ba7a1ad7SGarance A Drosehn static int doselect(struct dirent *_d); 81e8e715faSGarance A Drosehn static int kill_qtask(const char *lf); 82ba7a1ad7SGarance A Drosehn static int sortq(const void *_a, const void *_b); 83ba7a1ad7SGarance A Drosehn static int touch(struct jobqueue *_jq); 84ba7a1ad7SGarance A Drosehn static void unlinkf(char *_name); 8554032d11SGarance A Drosehn static void upstat(struct printer *_pp, const char *_msg, int _notify); 86004c9c5dSGarance A Drosehn static void wrapup_clean(int _laststatus); 874a1a0dbeSGarrett Wollman 884a1a0dbeSGarrett Wollman /* 894a1a0dbeSGarrett Wollman * generic framework for commands which operate on all or a specified 904a1a0dbeSGarrett Wollman * set of printers 914a1a0dbeSGarrett Wollman */ 92004c9c5dSGarance A Drosehn enum qsel_val { /* how a given ptr was selected */ 93004c9c5dSGarance A Drosehn QSEL_UNKNOWN = -1, /* ... not selected yet */ 94004c9c5dSGarance A Drosehn QSEL_BYNAME = 0, /* ... user specifed it by name */ 95004c9c5dSGarance A Drosehn QSEL_ALL = 1 /* ... user wants "all" printers */ 96004c9c5dSGarance A Drosehn /* (with more to come) */ 97004c9c5dSGarance A Drosehn }; 98004c9c5dSGarance A Drosehn 99004c9c5dSGarance A Drosehn static enum qsel_val generic_qselect; /* indicates how ptr was selected */ 100004c9c5dSGarance A Drosehn static int generic_initerr; /* result of initrtn processing */ 101e7f478b2SGarance A Drosehn static char *generic_cmdname; 10254032d11SGarance A Drosehn static char *generic_msg; /* if a -msg was specified */ 103004c9c5dSGarance A Drosehn static char *generic_nullarg; 104004c9c5dSGarance A Drosehn static void (*generic_wrapup)(int _last_status); /* perform rtn wrap-up */ 105004c9c5dSGarance A Drosehn 1064a1a0dbeSGarrett Wollman void 10754032d11SGarance A Drosehn generic(void (*specificrtn)(struct printer *_pp), int cmdopts, 108004c9c5dSGarance A Drosehn void (*initrtn)(int _argc, char *_argv[]), int argc, char *argv[]) 1094a1a0dbeSGarrett Wollman { 110004c9c5dSGarance A Drosehn int cmdstatus, more, targc; 111004c9c5dSGarance A Drosehn struct printer myprinter, *pp; 112e7f478b2SGarance A Drosehn char **margv, **targv; 1134a1a0dbeSGarrett Wollman 1144a1a0dbeSGarrett Wollman if (argc == 1) { 1155b1c34fbSGarance A Drosehn /* 1165b1c34fbSGarance A Drosehn * Usage needs a special case for 'down': The user must 1175b1c34fbSGarance A Drosehn * either include `-msg', or only the first parameter 1185b1c34fbSGarance A Drosehn * that they give will be processed as a printer name. 1195b1c34fbSGarance A Drosehn */ 12054032d11SGarance A Drosehn printf("usage: %s {all | printer ...}", argv[0]); 1215b1c34fbSGarance A Drosehn if (strcmp(argv[0], "down") == 0) { 1225b1c34fbSGarance A Drosehn printf(" -msg [<text> ...]\n"); 1235b1c34fbSGarance A Drosehn printf(" or: down {all | printer} [<text> ...]"); 1245b1c34fbSGarance A Drosehn } else if (cmdopts & LPC_MSGOPT) 12554032d11SGarance A Drosehn printf(" [-msg <text> ...]"); 12654032d11SGarance A Drosehn printf("\n"); 1274a1a0dbeSGarrett Wollman return; 1284a1a0dbeSGarrett Wollman } 129004c9c5dSGarance A Drosehn 130e7f478b2SGarance A Drosehn /* The first argument is the command name. */ 131e7f478b2SGarance A Drosehn generic_cmdname = *argv++; 132e7f478b2SGarance A Drosehn argc--; 133e7f478b2SGarance A Drosehn 134004c9c5dSGarance A Drosehn /* 135004c9c5dSGarance A Drosehn * The initialization routine for a command might set a generic 136004c9c5dSGarance A Drosehn * "wrapup" routine, which should be called after processing all 137004c9c5dSGarance A Drosehn * the printers in the command. This might print summary info. 138004c9c5dSGarance A Drosehn * 139004c9c5dSGarance A Drosehn * Note that the initialization routine may also parse (and 140004c9c5dSGarance A Drosehn * nullify) some of the parameters given on the command, leaving 141004c9c5dSGarance A Drosehn * only the parameters which have to do with printer names. 142004c9c5dSGarance A Drosehn */ 143004c9c5dSGarance A Drosehn pp = &myprinter; 144004c9c5dSGarance A Drosehn generic_wrapup = NULL; 145004c9c5dSGarance A Drosehn generic_qselect = QSEL_UNKNOWN; 146004c9c5dSGarance A Drosehn cmdstatus = 0; 147004c9c5dSGarance A Drosehn /* this just needs to be a distinct value of type 'char *' */ 148004c9c5dSGarance A Drosehn if (generic_nullarg == NULL) 149004c9c5dSGarance A Drosehn generic_nullarg = strdup(""); 150004c9c5dSGarance A Drosehn 15154032d11SGarance A Drosehn /* 15254032d11SGarance A Drosehn * Some commands accept a -msg argument, which indicates that 15354032d11SGarance A Drosehn * all remaining arguments should be combined into a string. 15454032d11SGarance A Drosehn */ 15554032d11SGarance A Drosehn generic_msg = NULL; 15654032d11SGarance A Drosehn if (cmdopts & LPC_MSGOPT) { 15754032d11SGarance A Drosehn targc = argc; 15854032d11SGarance A Drosehn targv = argv; 159e7f478b2SGarance A Drosehn for (; targc > 0; targc--, targv++) { 16054032d11SGarance A Drosehn if (strcmp(*targv, "-msg") == 0) { 16154032d11SGarance A Drosehn argc -= targc; 16254032d11SGarance A Drosehn generic_msg = args2line(targc - 1, targv + 1); 16354032d11SGarance A Drosehn break; 16454032d11SGarance A Drosehn } 16554032d11SGarance A Drosehn } 16654032d11SGarance A Drosehn } 16754032d11SGarance A Drosehn 168004c9c5dSGarance A Drosehn /* call initialization routine, if there is one for this cmd */ 169004c9c5dSGarance A Drosehn if (initrtn != NULL) { 170004c9c5dSGarance A Drosehn generic_initerr = 0; 171004c9c5dSGarance A Drosehn (*initrtn)(argc, argv); 172004c9c5dSGarance A Drosehn if (generic_initerr) 173004c9c5dSGarance A Drosehn return; 174e7f478b2SGarance A Drosehn /* 175e7f478b2SGarance A Drosehn * The initrtn may have null'ed out some of the parameters. 176e7f478b2SGarance A Drosehn * Compact the parameter list to remove those nulls, and 177e7f478b2SGarance A Drosehn * correct the arg-count. 178e7f478b2SGarance A Drosehn */ 179004c9c5dSGarance A Drosehn targc = argc; 180004c9c5dSGarance A Drosehn targv = argv; 181e7f478b2SGarance A Drosehn margv = argv; 182e7f478b2SGarance A Drosehn argc = 0; 183e7f478b2SGarance A Drosehn for (; targc > 0; targc--, targv++) { 184e7f478b2SGarance A Drosehn if (*targv != generic_nullarg) { 185e7f478b2SGarance A Drosehn if (targv != margv) 186e7f478b2SGarance A Drosehn *margv = *targv; 187e7f478b2SGarance A Drosehn margv++; 188e7f478b2SGarance A Drosehn argc++; 189004c9c5dSGarance A Drosehn } 190004c9c5dSGarance A Drosehn } 191004c9c5dSGarance A Drosehn } 192004c9c5dSGarance A Drosehn 193e7f478b2SGarance A Drosehn if (argc == 1 && strcmp(*argv, "all") == 0) { 194004c9c5dSGarance A Drosehn generic_qselect = QSEL_ALL; 195ba7a1ad7SGarance A Drosehn more = firstprinter(pp, &cmdstatus); 196ba7a1ad7SGarance A Drosehn if (cmdstatus) 1974a1a0dbeSGarrett Wollman goto looperr; 1984a1a0dbeSGarrett Wollman while (more) { 199ba7a1ad7SGarance A Drosehn (*specificrtn)(pp); 2004a1a0dbeSGarrett Wollman do { 201ba7a1ad7SGarance A Drosehn more = nextprinter(pp, &cmdstatus); 2024a1a0dbeSGarrett Wollman looperr: 203ba7a1ad7SGarance A Drosehn switch (cmdstatus) { 2044a1a0dbeSGarrett Wollman case PCAPERR_TCOPEN: 2054a1a0dbeSGarrett Wollman printf("warning: %s: unresolved " 2064a1a0dbeSGarrett Wollman "tc= reference(s) ", 2074a1a0dbeSGarrett Wollman pp->printer); 2084a1a0dbeSGarrett Wollman case PCAPERR_SUCCESS: 2094a1a0dbeSGarrett Wollman break; 2104a1a0dbeSGarrett Wollman default: 2116d39e1b7SGarance A Drosehn fatal(pp, "%s", pcaperr(cmdstatus)); 2124a1a0dbeSGarrett Wollman } 213ba7a1ad7SGarance A Drosehn } while (more && cmdstatus); 2144a1a0dbeSGarrett Wollman } 215004c9c5dSGarance A Drosehn goto wrapup; 2164a1a0dbeSGarrett Wollman } 217004c9c5dSGarance A Drosehn 218004c9c5dSGarance A Drosehn generic_qselect = QSEL_BYNAME; /* specifically-named ptrs */ 219e7f478b2SGarance A Drosehn for (; argc > 0; argc--, argv++) { 2204a1a0dbeSGarrett Wollman init_printer(pp); 221ba7a1ad7SGarance A Drosehn cmdstatus = getprintcap(*argv, pp); 222ba7a1ad7SGarance A Drosehn switch (cmdstatus) { 2234a1a0dbeSGarrett Wollman default: 2246d39e1b7SGarance A Drosehn fatal(pp, "%s", pcaperr(cmdstatus)); 2254a1a0dbeSGarrett Wollman case PCAPERR_NOTFOUND: 2264a1a0dbeSGarrett Wollman printf("unknown printer %s\n", *argv); 2274a1a0dbeSGarrett Wollman continue; 2284a1a0dbeSGarrett Wollman case PCAPERR_TCOPEN: 2294a1a0dbeSGarrett Wollman printf("warning: %s: unresolved tc= reference(s)\n", 2304a1a0dbeSGarrett Wollman *argv); 2314a1a0dbeSGarrett Wollman break; 2324a1a0dbeSGarrett Wollman case PCAPERR_SUCCESS: 2334a1a0dbeSGarrett Wollman break; 2344a1a0dbeSGarrett Wollman } 235ba7a1ad7SGarance A Drosehn (*specificrtn)(pp); 2364a1a0dbeSGarrett Wollman } 237004c9c5dSGarance A Drosehn 238004c9c5dSGarance A Drosehn wrapup: 239004c9c5dSGarance A Drosehn if (generic_wrapup) { 240004c9c5dSGarance A Drosehn (*generic_wrapup)(cmdstatus); 241004c9c5dSGarance A Drosehn } 242cc2b61b1SGarance A Drosehn free_printer(pp); 24354032d11SGarance A Drosehn if (generic_msg) 24454032d11SGarance A Drosehn free(generic_msg); 24554032d11SGarance A Drosehn } 246004c9c5dSGarance A Drosehn 24754032d11SGarance A Drosehn /* 24854032d11SGarance A Drosehn * Convert an argv-array of character strings into a single string. 24954032d11SGarance A Drosehn */ 25054032d11SGarance A Drosehn static char * 25154032d11SGarance A Drosehn args2line(int argc, char **argv) 25254032d11SGarance A Drosehn { 25354032d11SGarance A Drosehn char *cp1, *cend; 25454032d11SGarance A Drosehn const char *cp2; 25554032d11SGarance A Drosehn char buf[1024]; 25654032d11SGarance A Drosehn 25754032d11SGarance A Drosehn if (argc <= 0) 25854032d11SGarance A Drosehn return strdup("\n"); 25954032d11SGarance A Drosehn 26054032d11SGarance A Drosehn cp1 = buf; 26154032d11SGarance A Drosehn cend = buf + sizeof(buf) - 1; /* save room for '\0' */ 26254032d11SGarance A Drosehn while (--argc >= 0) { 26354032d11SGarance A Drosehn cp2 = *argv++; 26454032d11SGarance A Drosehn while ((cp1 < cend) && (*cp1++ = *cp2++)) 26554032d11SGarance A Drosehn ; 26654032d11SGarance A Drosehn cp1[-1] = ' '; 26754032d11SGarance A Drosehn } 26854032d11SGarance A Drosehn cp1[-1] = '\n'; 26954032d11SGarance A Drosehn *cp1 = '\0'; 27054032d11SGarance A Drosehn return strdup(buf); 2714a1a0dbeSGarrett Wollman } 272dea673e9SRodney W. Grimes 273dea673e9SRodney W. Grimes /* 274e8e715faSGarance A Drosehn * Kill the current daemon, to stop printing of the active job. 275e8e715faSGarance A Drosehn */ 276e8e715faSGarance A Drosehn static int 277e8e715faSGarance A Drosehn kill_qtask(const char *lf) 278e8e715faSGarance A Drosehn { 279e8e715faSGarance A Drosehn FILE *fp; 280e8e715faSGarance A Drosehn pid_t pid; 281e8e715faSGarance A Drosehn int errsav, killres, lockres, res; 282e8e715faSGarance A Drosehn 283e8e715faSGarance A Drosehn seteuid(euid); 284e8e715faSGarance A Drosehn fp = fopen(lf, "r"); 285e8e715faSGarance A Drosehn errsav = errno; 286e8e715faSGarance A Drosehn seteuid(uid); 287e8e715faSGarance A Drosehn res = KQT_NODAEMON; 288e8e715faSGarance A Drosehn if (fp == NULL) { 289e8e715faSGarance A Drosehn /* 290e8e715faSGarance A Drosehn * If there is no lock file, then there is no daemon to 291e8e715faSGarance A Drosehn * kill. Any other error return means there is some 292e8e715faSGarance A Drosehn * kind of problem with the lock file. 293e8e715faSGarance A Drosehn */ 294e8e715faSGarance A Drosehn if (errsav != ENOENT) 295e8e715faSGarance A Drosehn res = KQT_LFERROR; 296e8e715faSGarance A Drosehn goto killdone; 297e8e715faSGarance A Drosehn } 298e8e715faSGarance A Drosehn 299e8e715faSGarance A Drosehn /* If the lock file is empty, then there is no daemon to kill */ 300e8e715faSGarance A Drosehn if (getline(fp) == 0) 301e8e715faSGarance A Drosehn goto killdone; 302e8e715faSGarance A Drosehn 303e8e715faSGarance A Drosehn /* 304e8e715faSGarance A Drosehn * If the file can be locked without blocking, then there 305e8e715faSGarance A Drosehn * no daemon to kill, or we should not try to kill it. 306e8e715faSGarance A Drosehn * 307e8e715faSGarance A Drosehn * XXX - not sure I understand the reasoning behind this... 308e8e715faSGarance A Drosehn */ 309e8e715faSGarance A Drosehn lockres = flock(fileno(fp), LOCK_SH|LOCK_NB); 310e8e715faSGarance A Drosehn (void) fclose(fp); 311e8e715faSGarance A Drosehn if (lockres == 0) 312e8e715faSGarance A Drosehn goto killdone; 313e8e715faSGarance A Drosehn 314e8e715faSGarance A Drosehn pid = atoi(line); 315e8e715faSGarance A Drosehn if (pid < 0) { 316e8e715faSGarance A Drosehn /* 317e8e715faSGarance A Drosehn * If we got a negative pid, then the contents of the 318e8e715faSGarance A Drosehn * lock file is not valid. 319e8e715faSGarance A Drosehn */ 320e8e715faSGarance A Drosehn res = KQT_LFERROR; 321e8e715faSGarance A Drosehn goto killdone; 322e8e715faSGarance A Drosehn } 323e8e715faSGarance A Drosehn 324e8e715faSGarance A Drosehn seteuid(uid); 325e8e715faSGarance A Drosehn killres = kill(pid, SIGTERM); 326e8e715faSGarance A Drosehn errsav = errno; 327e8e715faSGarance A Drosehn seteuid(uid); 328e8e715faSGarance A Drosehn if (killres == 0) { 329e8e715faSGarance A Drosehn res = KQT_KILLOK; 330e8e715faSGarance A Drosehn printf("\tdaemon (pid %d) killed\n", pid); 331e8e715faSGarance A Drosehn } else if (errno == ESRCH) { 332e8e715faSGarance A Drosehn res = KQT_NODAEMON; 333e8e715faSGarance A Drosehn } else { 334e8e715faSGarance A Drosehn res = KQT_KILLFAIL; 335e8e715faSGarance A Drosehn printf("\tWarning: daemon (pid %d) not killed:\n", pid); 336e8e715faSGarance A Drosehn printf("\t %s\n", strerror(errsav)); 337e8e715faSGarance A Drosehn } 338e8e715faSGarance A Drosehn 339e8e715faSGarance A Drosehn killdone: 340e8e715faSGarance A Drosehn switch (res) { 341e8e715faSGarance A Drosehn case KQT_LFERROR: 342e8e715faSGarance A Drosehn printf("\tcannot open lock file: %s\n", 343e8e715faSGarance A Drosehn strerror(errsav)); 344e8e715faSGarance A Drosehn break; 345e8e715faSGarance A Drosehn case KQT_NODAEMON: 346e8e715faSGarance A Drosehn printf("\tno daemon to abort\n"); 347e8e715faSGarance A Drosehn break; 348e8e715faSGarance A Drosehn case KQT_KILLFAIL: 349e8e715faSGarance A Drosehn case KQT_KILLOK: 350e8e715faSGarance A Drosehn /* These two already printed messages to the user. */ 351e8e715faSGarance A Drosehn break; 352e8e715faSGarance A Drosehn default: 353e8e715faSGarance A Drosehn printf("\t<internal error in kill_qtask>\n"); 354e8e715faSGarance A Drosehn break; 355e8e715faSGarance A Drosehn } 356e8e715faSGarance A Drosehn 357e8e715faSGarance A Drosehn return (res); 358e8e715faSGarance A Drosehn } 359e8e715faSGarance A Drosehn 360e8e715faSGarance A Drosehn /* 361dea673e9SRodney W. Grimes * Write a message into the status file. 362dea673e9SRodney W. Grimes */ 363dea673e9SRodney W. Grimes static void 36454032d11SGarance A Drosehn upstat(struct printer *pp, const char *msg, int notifyuser) 365dea673e9SRodney W. Grimes { 36654032d11SGarance A Drosehn int fd; 3675f87a7b6SWarner Losh char statfile[MAXPATHLEN]; 368dea673e9SRodney W. Grimes 3694a1a0dbeSGarrett Wollman status_file_name(pp, statfile, sizeof statfile); 370dea673e9SRodney W. Grimes umask(0); 37154032d11SGarance A Drosehn seteuid(euid); 3724a1a0dbeSGarrett Wollman fd = open(statfile, O_WRONLY|O_CREAT|O_EXLOCK, STAT_FILE_MODE); 37354032d11SGarance A Drosehn seteuid(uid); 3744a1a0dbeSGarrett Wollman if (fd < 0) { 3754a1a0dbeSGarrett Wollman printf("\tcannot create status file: %s\n", strerror(errno)); 376dea673e9SRodney W. Grimes return; 377dea673e9SRodney W. Grimes } 378dea673e9SRodney W. Grimes (void) ftruncate(fd, 0); 379dea673e9SRodney W. Grimes if (msg == (char *)NULL) 380dea673e9SRodney W. Grimes (void) write(fd, "\n", 1); 381dea673e9SRodney W. Grimes else 382dea673e9SRodney W. Grimes (void) write(fd, msg, strlen(msg)); 383dea673e9SRodney W. Grimes (void) close(fd); 38454032d11SGarance A Drosehn if (notifyuser) { 38554032d11SGarance A Drosehn if ((msg == (char *)NULL) || (strcmp(msg, "\n") == 0)) 38654032d11SGarance A Drosehn printf("\tstatus message is now set to nothing.\n"); 38754032d11SGarance A Drosehn else 38854032d11SGarance A Drosehn printf("\tstatus message is now: %s", msg); 38954032d11SGarance A Drosehn } 390dea673e9SRodney W. Grimes } 391dea673e9SRodney W. Grimes 392004c9c5dSGarance A Drosehn /* 393e8e715faSGarance A Drosehn * kill an existing daemon and disable printing. 394e8e715faSGarance A Drosehn */ 395e8e715faSGarance A Drosehn void 396e8e715faSGarance A Drosehn abort_q(struct printer *pp) 397e8e715faSGarance A Drosehn { 398e8e715faSGarance A Drosehn int killres, setres; 399e8e715faSGarance A Drosehn char lf[MAXPATHLEN]; 400e8e715faSGarance A Drosehn 401e8e715faSGarance A Drosehn lock_file_name(pp, lf, sizeof lf); 402e8e715faSGarance A Drosehn printf("%s:\n", pp->printer); 403e8e715faSGarance A Drosehn 404e8e715faSGarance A Drosehn /* 405e8e715faSGarance A Drosehn * Turn on the owner execute bit of the lock file to disable printing. 406e8e715faSGarance A Drosehn */ 407e8e715faSGarance A Drosehn setres = set_qstate(SQS_STOPP, lf); 408e8e715faSGarance A Drosehn 409e8e715faSGarance A Drosehn /* 410e8e715faSGarance A Drosehn * If set_qstate found that there already was a lock file, then 411e8e715faSGarance A Drosehn * call a routine which will read that lock file and kill the 412e8e715faSGarance A Drosehn * lpd-process which is listed in that lock file. If the lock 413e8e715faSGarance A Drosehn * file did not exist, then either there is no daemon running 414e8e715faSGarance A Drosehn * for this queue, or there is one running but *it* could not 415e8e715faSGarance A Drosehn * write a lock file (which means we can not determine the 416e8e715faSGarance A Drosehn * process id of that lpd-process). 417e8e715faSGarance A Drosehn */ 418e8e715faSGarance A Drosehn switch (setres) { 419e8e715faSGarance A Drosehn case SQS_CHGOK: 420e8e715faSGarance A Drosehn case SQS_CHGFAIL: 421e8e715faSGarance A Drosehn /* Kill the process */ 422e8e715faSGarance A Drosehn killres = kill_qtask(lf); 423e8e715faSGarance A Drosehn break; 424e8e715faSGarance A Drosehn case SQS_CREOK: 425e8e715faSGarance A Drosehn case SQS_CREFAIL: 426e8e715faSGarance A Drosehn printf("\tno daemon to abort\n"); 427e8e715faSGarance A Drosehn break; 428e8e715faSGarance A Drosehn case SQS_STATFAIL: 429e8e715faSGarance A Drosehn printf("\tassuming no daemon to abort\n"); 430e8e715faSGarance A Drosehn break; 431e8e715faSGarance A Drosehn default: 432e8e715faSGarance A Drosehn printf("\t<unexpected result (%d) from set_qstate>\n", 433e8e715faSGarance A Drosehn setres); 434e8e715faSGarance A Drosehn break; 435e8e715faSGarance A Drosehn } 436e8e715faSGarance A Drosehn 43754032d11SGarance A Drosehn if (setres >= 0) 43854032d11SGarance A Drosehn upstat(pp, "printing disabled\n", 0); 439e8e715faSGarance A Drosehn } 440e8e715faSGarance A Drosehn 441e8e715faSGarance A Drosehn /* 442004c9c5dSGarance A Drosehn * "global" variables for all the routines related to 'clean' and 'tclean' 443004c9c5dSGarance A Drosehn */ 444004c9c5dSGarance A Drosehn static time_t cln_now; /* current time */ 445004c9c5dSGarance A Drosehn static double cln_minage; /* minimum age before file is removed */ 446004c9c5dSGarance A Drosehn static long cln_sizecnt; /* amount of space freed up */ 447004c9c5dSGarance A Drosehn static int cln_debug; /* print extra debugging msgs */ 448004c9c5dSGarance A Drosehn static int cln_filecnt; /* number of files destroyed */ 449004c9c5dSGarance A Drosehn static int cln_foundcore; /* found a core file! */ 450004c9c5dSGarance A Drosehn static int cln_queuecnt; /* number of queues checked */ 451004c9c5dSGarance A Drosehn static int cln_testonly; /* remove-files vs just-print-info */ 452004c9c5dSGarance A Drosehn 453dea673e9SRodney W. Grimes static int 454ba7a1ad7SGarance A Drosehn doselect(struct dirent *d) 455dea673e9SRodney W. Grimes { 456dea673e9SRodney W. Grimes int c = d->d_name[0]; 457dea673e9SRodney W. Grimes 4581fd731faSGarance A Drosehn if ((c == 'c' || c == 'd' || c == 'r' || c == 't') && 4591fd731faSGarance A Drosehn d->d_name[1] == 'f') 460004c9c5dSGarance A Drosehn return 1; 461004c9c5dSGarance A Drosehn if (c == 'c') { 462004c9c5dSGarance A Drosehn if (!strcmp(d->d_name, "core")) 463004c9c5dSGarance A Drosehn cln_foundcore = 1; 464004c9c5dSGarance A Drosehn } 465004c9c5dSGarance A Drosehn if (c == 'e') { 466004c9c5dSGarance A Drosehn if (!strncmp(d->d_name, "errs.", 5)) 467004c9c5dSGarance A Drosehn return 1; 468004c9c5dSGarance A Drosehn } 469004c9c5dSGarance A Drosehn return 0; 470dea673e9SRodney W. Grimes } 471dea673e9SRodney W. Grimes 472dea673e9SRodney W. Grimes /* 473ceeaedd3SGarance A Drosehn * Comparison routine that clean_q() uses for scandir. 474ceeaedd3SGarance A Drosehn * 475ceeaedd3SGarance A Drosehn * The purpose of this sort is to have all `df' files end up immediately 4761fd731faSGarance A Drosehn * after the matching `cf' file. For files matching `cf', `df', `rf', or 4771fd731faSGarance A Drosehn * `tf', it sorts by job number and machine, then by `cf', `df', `rf', or 4781fd731faSGarance A Drosehn * `tf', and then by the sequence letter (which is A-Z, or a-z). This 4791fd731faSGarance A Drosehn * routine may also see filenames which do not start with `cf', `df', `rf', 4801fd731faSGarance A Drosehn * or `tf' (such as `errs.*'), and those are simply sorted by the full 4811fd731faSGarance A Drosehn * filename. 4821fd731faSGarance A Drosehn * 4831fd731faSGarance A Drosehn * XXX 4841fd731faSGarance A Drosehn * This assumes that all control files start with `cfA*', and it turns 4851fd731faSGarance A Drosehn * out there are a few implementations of lpr which will create `cfB*' 4861fd731faSGarance A Drosehn * filenames (they will have datafile names which start with `dfB*'). 487dea673e9SRodney W. Grimes */ 488dea673e9SRodney W. Grimes static int 489ba7a1ad7SGarance A Drosehn sortq(const void *a, const void *b) 490dea673e9SRodney W. Grimes { 491ceeaedd3SGarance A Drosehn const int a_lt_b = -1, a_gt_b = 1, cat_other = 10; 492ceeaedd3SGarance A Drosehn const char *fname_a, *fname_b, *jnum_a, *jnum_b; 493ceeaedd3SGarance A Drosehn int cat_a, cat_b, ch, res, seq_a, seq_b; 494dea673e9SRodney W. Grimes 495f0baf665SGarance A Drosehn fname_a = (*(const struct dirent * const *)a)->d_name; 496f0baf665SGarance A Drosehn fname_b = (*(const struct dirent * const *)b)->d_name; 497ceeaedd3SGarance A Drosehn 498ceeaedd3SGarance A Drosehn /* 499*3df5ecacSUlrich Spörlein * First separate filenames into categories. Categories are 5001fd731faSGarance A Drosehn * legitimate `cf', `df', `rf' & `tf' filenames, and "other" - in 5011fd731faSGarance A Drosehn * that order. It is critical that the mapping be exactly the 5021fd731faSGarance A Drosehn * same for 'a' vs 'b', so define a macro for the job. 503ceeaedd3SGarance A Drosehn * 504ceeaedd3SGarance A Drosehn * [aside: the standard `cf' file has the jobnumber start in 505ceeaedd3SGarance A Drosehn * position 4, but some implementations have that as an extra 506ceeaedd3SGarance A Drosehn * file-sequence letter, and start the job number in position 5.] 507ceeaedd3SGarance A Drosehn */ 508ceeaedd3SGarance A Drosehn #define MAP_TO_CAT(fname_X,cat_X,jnum_X,seq_X) do { \ 509ceeaedd3SGarance A Drosehn cat_X = cat_other; \ 510ceeaedd3SGarance A Drosehn ch = *(fname_X + 2); \ 511ceeaedd3SGarance A Drosehn jnum_X = fname_X + 3; \ 5124f7f8234SGarance A Drosehn seq_X = 0; \ 513ceeaedd3SGarance A Drosehn if ((*(fname_X + 1) == 'f') && (isalpha(ch))) { \ 514ceeaedd3SGarance A Drosehn seq_X = ch; \ 515ceeaedd3SGarance A Drosehn if (*fname_X == 'c') \ 516ceeaedd3SGarance A Drosehn cat_X = 1; \ 517ceeaedd3SGarance A Drosehn else if (*fname_X == 'd') \ 518ceeaedd3SGarance A Drosehn cat_X = 2; \ 5191fd731faSGarance A Drosehn else if (*fname_X == 'r') \ 520ceeaedd3SGarance A Drosehn cat_X = 3; \ 5211fd731faSGarance A Drosehn else if (*fname_X == 't') \ 5221fd731faSGarance A Drosehn cat_X = 4; \ 523ceeaedd3SGarance A Drosehn if (cat_X != cat_other) { \ 524ceeaedd3SGarance A Drosehn ch = *jnum_X; \ 525ceeaedd3SGarance A Drosehn if (!isdigit(ch)) { \ 526ceeaedd3SGarance A Drosehn if (isalpha(ch)) { \ 527ceeaedd3SGarance A Drosehn jnum_X++; \ 528ceeaedd3SGarance A Drosehn ch = *jnum_X; \ 529ceeaedd3SGarance A Drosehn seq_X = (seq_X << 8) + ch; \ 530ceeaedd3SGarance A Drosehn } \ 531ceeaedd3SGarance A Drosehn if (!isdigit(ch)) \ 532ceeaedd3SGarance A Drosehn cat_X = cat_other; \ 533ceeaedd3SGarance A Drosehn } \ 534ceeaedd3SGarance A Drosehn } \ 535ceeaedd3SGarance A Drosehn } \ 536ceeaedd3SGarance A Drosehn } while (0) 537ceeaedd3SGarance A Drosehn 538ceeaedd3SGarance A Drosehn MAP_TO_CAT(fname_a, cat_a, jnum_a, seq_a); 539ceeaedd3SGarance A Drosehn MAP_TO_CAT(fname_b, cat_b, jnum_b, seq_b); 540ceeaedd3SGarance A Drosehn 541ceeaedd3SGarance A Drosehn #undef MAP_TO_CAT 542ceeaedd3SGarance A Drosehn 543ceeaedd3SGarance A Drosehn /* First handle all cases which have "other" files */ 544ceeaedd3SGarance A Drosehn if ((cat_a >= cat_other) || (cat_b >= cat_other)) { 545ceeaedd3SGarance A Drosehn /* for two "other" files, just compare the full name */ 546ceeaedd3SGarance A Drosehn if (cat_a == cat_b) 547ceeaedd3SGarance A Drosehn res = strcmp(fname_a, fname_b); 548ceeaedd3SGarance A Drosehn else if (cat_a < cat_b) 549ceeaedd3SGarance A Drosehn res = a_lt_b; 550ceeaedd3SGarance A Drosehn else 551ceeaedd3SGarance A Drosehn res = a_gt_b; 552ceeaedd3SGarance A Drosehn goto have_res; 553ceeaedd3SGarance A Drosehn } 554ceeaedd3SGarance A Drosehn 555ceeaedd3SGarance A Drosehn /* 5561fd731faSGarance A Drosehn * At this point, we know both files are legitimate `cf', `df', `rf', 557ceeaedd3SGarance A Drosehn * or `tf' files. Compare them by job-number and machine name. 558ceeaedd3SGarance A Drosehn */ 559ceeaedd3SGarance A Drosehn res = strcmp(jnum_a, jnum_b); 560ceeaedd3SGarance A Drosehn if (res != 0) 561ceeaedd3SGarance A Drosehn goto have_res; 562ceeaedd3SGarance A Drosehn 563ceeaedd3SGarance A Drosehn /* 564ceeaedd3SGarance A Drosehn * We have two files which belong to the same job. Sort based 565*3df5ecacSUlrich Spörlein * on the category of file (`c' before `d', etc). 566ceeaedd3SGarance A Drosehn */ 567ceeaedd3SGarance A Drosehn if (cat_a < cat_b) { 568ceeaedd3SGarance A Drosehn res = a_lt_b; 569ceeaedd3SGarance A Drosehn goto have_res; 570ceeaedd3SGarance A Drosehn } else if (cat_a > cat_b) { 571ceeaedd3SGarance A Drosehn res = a_gt_b; 572ceeaedd3SGarance A Drosehn goto have_res; 573ceeaedd3SGarance A Drosehn } 574ceeaedd3SGarance A Drosehn 575ceeaedd3SGarance A Drosehn /* 576*3df5ecacSUlrich Spörlein * Two files in the same category for a single job. Sort based 577*3df5ecacSUlrich Spörlein * on the sequence letter(s). (usually `A' through `Z', etc). 578ceeaedd3SGarance A Drosehn */ 579ceeaedd3SGarance A Drosehn if (seq_a < seq_b) { 580ceeaedd3SGarance A Drosehn res = a_lt_b; 581ceeaedd3SGarance A Drosehn goto have_res; 582ceeaedd3SGarance A Drosehn } else if (seq_a > seq_b) { 583ceeaedd3SGarance A Drosehn res = a_gt_b; 584ceeaedd3SGarance A Drosehn goto have_res; 585ceeaedd3SGarance A Drosehn } 586ceeaedd3SGarance A Drosehn 587ceeaedd3SGarance A Drosehn /* 588ceeaedd3SGarance A Drosehn * Given that the filenames in a directory are unique, this SHOULD 589ceeaedd3SGarance A Drosehn * never happen (unless there are logic errors in this routine). 590ceeaedd3SGarance A Drosehn * But if it does happen, we must return "is equal" or the caller 591ceeaedd3SGarance A Drosehn * might see inconsistent results in the sorting order, and that 592ceeaedd3SGarance A Drosehn * can trigger other problems. 593ceeaedd3SGarance A Drosehn */ 594ceeaedd3SGarance A Drosehn printf("\t*** Error in sortq: %s == %s !\n", fname_a, fname_b); 595ceeaedd3SGarance A Drosehn printf("\t*** cat %d == %d ; seq = %d %d\n", cat_a, cat_b, 596ceeaedd3SGarance A Drosehn seq_a, seq_b); 597ceeaedd3SGarance A Drosehn res = 0; 598ceeaedd3SGarance A Drosehn 599ceeaedd3SGarance A Drosehn have_res: 600ceeaedd3SGarance A Drosehn return res; 601dea673e9SRodney W. Grimes } 602dea673e9SRodney W. Grimes 603dea673e9SRodney W. Grimes /* 6044a1a0dbeSGarrett Wollman * Remove all spool files and temporaries from the spooling area. 6054a1a0dbeSGarrett Wollman * Or, perhaps: 606dea673e9SRodney W. Grimes * Remove incomplete jobs from spooling area. 607dea673e9SRodney W. Grimes */ 608dea673e9SRodney W. Grimes 609004c9c5dSGarance A Drosehn void 610c9cb13a0SGarance A Drosehn clean_gi(int argc, char *argv[]) 611004c9c5dSGarance A Drosehn { 612004c9c5dSGarance A Drosehn 613004c9c5dSGarance A Drosehn /* init some fields before 'clean' is called for each queue */ 614004c9c5dSGarance A Drosehn cln_queuecnt = 0; 615004c9c5dSGarance A Drosehn cln_now = time(NULL); 616004c9c5dSGarance A Drosehn cln_minage = 3600.0; /* only delete files >1h old */ 617004c9c5dSGarance A Drosehn cln_filecnt = 0; 618004c9c5dSGarance A Drosehn cln_sizecnt = 0; 619004c9c5dSGarance A Drosehn cln_debug = 0; 620004c9c5dSGarance A Drosehn cln_testonly = 0; 621004c9c5dSGarance A Drosehn generic_wrapup = &wrapup_clean; 622004c9c5dSGarance A Drosehn 623004c9c5dSGarance A Drosehn /* see if there are any options specified before the ptr list */ 624e7f478b2SGarance A Drosehn for (; argc > 0; argc--, argv++) { 625004c9c5dSGarance A Drosehn if (**argv != '-') 626004c9c5dSGarance A Drosehn break; 627004c9c5dSGarance A Drosehn if (strcmp(*argv, "-d") == 0) { 628004c9c5dSGarance A Drosehn /* just an example of an option... */ 629ceeaedd3SGarance A Drosehn cln_debug++; 630004c9c5dSGarance A Drosehn *argv = generic_nullarg; /* "erase" it */ 631004c9c5dSGarance A Drosehn } else { 632004c9c5dSGarance A Drosehn printf("Invalid option '%s'\n", *argv); 633004c9c5dSGarance A Drosehn generic_initerr = 1; 634004c9c5dSGarance A Drosehn } 635004c9c5dSGarance A Drosehn } 636004c9c5dSGarance A Drosehn 637004c9c5dSGarance A Drosehn return; 638004c9c5dSGarance A Drosehn } 639004c9c5dSGarance A Drosehn 640004c9c5dSGarance A Drosehn void 641c9cb13a0SGarance A Drosehn tclean_gi(int argc, char *argv[]) 642004c9c5dSGarance A Drosehn { 643004c9c5dSGarance A Drosehn 644004c9c5dSGarance A Drosehn /* only difference between 'clean' and 'tclean' is one value */ 645004c9c5dSGarance A Drosehn /* (...and the fact that 'clean' is priv and 'tclean' is not) */ 646c9cb13a0SGarance A Drosehn clean_gi(argc, argv); 647004c9c5dSGarance A Drosehn cln_testonly = 1; 648004c9c5dSGarance A Drosehn 649004c9c5dSGarance A Drosehn return; 650004c9c5dSGarance A Drosehn } 651004c9c5dSGarance A Drosehn 652004c9c5dSGarance A Drosehn void 653004c9c5dSGarance A Drosehn clean_q(struct printer *pp) 654004c9c5dSGarance A Drosehn { 655004c9c5dSGarance A Drosehn char *cp, *cp1, *lp; 656004c9c5dSGarance A Drosehn struct dirent **queue; 657004c9c5dSGarance A Drosehn size_t linerem; 658004c9c5dSGarance A Drosehn int didhead, i, n, nitems, rmcp; 659004c9c5dSGarance A Drosehn 660004c9c5dSGarance A Drosehn cln_queuecnt++; 661004c9c5dSGarance A Drosehn 662004c9c5dSGarance A Drosehn didhead = 0; 663004c9c5dSGarance A Drosehn if (generic_qselect == QSEL_BYNAME) { 6644a1a0dbeSGarrett Wollman printf("%s:\n", pp->printer); 665004c9c5dSGarance A Drosehn didhead = 1; 666004c9c5dSGarance A Drosehn } 667dea673e9SRodney W. Grimes 6684a1a0dbeSGarrett Wollman lp = line; 6694a1a0dbeSGarrett Wollman cp = pp->spool_dir; 6704a1a0dbeSGarrett Wollman while (lp < &line[sizeof(line) - 1]) { 6714a1a0dbeSGarrett Wollman if ((*lp++ = *cp++) == 0) 6724a1a0dbeSGarrett Wollman break; 6734a1a0dbeSGarrett Wollman } 674dea673e9SRodney W. Grimes lp[-1] = '/'; 675004c9c5dSGarance A Drosehn linerem = sizeof(line) - (lp - line); 676dea673e9SRodney W. Grimes 677004c9c5dSGarance A Drosehn cln_foundcore = 0; 678360d4ad5SWarner Losh seteuid(euid); 6794a1a0dbeSGarrett Wollman nitems = scandir(pp->spool_dir, &queue, doselect, sortq); 680360d4ad5SWarner Losh seteuid(uid); 681dea673e9SRodney W. Grimes if (nitems < 0) { 682004c9c5dSGarance A Drosehn if (!didhead) { 683004c9c5dSGarance A Drosehn printf("%s:\n", pp->printer); 684004c9c5dSGarance A Drosehn didhead = 1; 685004c9c5dSGarance A Drosehn } 686dea673e9SRodney W. Grimes printf("\tcannot examine spool directory\n"); 687dea673e9SRodney W. Grimes return; 688dea673e9SRodney W. Grimes } 689004c9c5dSGarance A Drosehn if (cln_foundcore) { 690004c9c5dSGarance A Drosehn if (!didhead) { 691004c9c5dSGarance A Drosehn printf("%s:\n", pp->printer); 692004c9c5dSGarance A Drosehn didhead = 1; 693004c9c5dSGarance A Drosehn } 694004c9c5dSGarance A Drosehn printf("\t** found a core file in %s !\n", pp->spool_dir); 695004c9c5dSGarance A Drosehn } 696dea673e9SRodney W. Grimes if (nitems == 0) 697dea673e9SRodney W. Grimes return; 698004c9c5dSGarance A Drosehn if (!didhead) 699004c9c5dSGarance A Drosehn printf("%s:\n", pp->printer); 700ceeaedd3SGarance A Drosehn if (cln_debug) { 701ceeaedd3SGarance A Drosehn printf("\t** ----- Sorted list of files being checked:\n"); 702ceeaedd3SGarance A Drosehn i = 0; 703ceeaedd3SGarance A Drosehn do { 704ceeaedd3SGarance A Drosehn cp = queue[i]->d_name; 705ceeaedd3SGarance A Drosehn printf("\t** [%3d] = %s\n", i, cp); 706ceeaedd3SGarance A Drosehn } while (++i < nitems); 707ceeaedd3SGarance A Drosehn printf("\t** ----- end of sorted list\n"); 708ceeaedd3SGarance A Drosehn } 709dea673e9SRodney W. Grimes i = 0; 710dea673e9SRodney W. Grimes do { 711dea673e9SRodney W. Grimes cp = queue[i]->d_name; 712004c9c5dSGarance A Drosehn rmcp = 0; 713dea673e9SRodney W. Grimes if (*cp == 'c') { 714004c9c5dSGarance A Drosehn /* 715004c9c5dSGarance A Drosehn * A control file. Look for matching data-files. 716004c9c5dSGarance A Drosehn */ 717004c9c5dSGarance A Drosehn /* XXX 718004c9c5dSGarance A Drosehn * Note the logic here assumes that the hostname 719004c9c5dSGarance A Drosehn * part of cf-filenames match the hostname part 720004c9c5dSGarance A Drosehn * in df-filenames, and that is not necessarily 721004c9c5dSGarance A Drosehn * true (eg: for multi-homed hosts). This needs 722004c9c5dSGarance A Drosehn * some further thought... 723004c9c5dSGarance A Drosehn */ 724dea673e9SRodney W. Grimes n = 0; 725dea673e9SRodney W. Grimes while (i + 1 < nitems) { 726dea673e9SRodney W. Grimes cp1 = queue[i + 1]->d_name; 727dea673e9SRodney W. Grimes if (*cp1 != 'd' || strcmp(cp + 3, cp1 + 3)) 728dea673e9SRodney W. Grimes break; 729dea673e9SRodney W. Grimes i++; 730dea673e9SRodney W. Grimes n++; 731dea673e9SRodney W. Grimes } 732dea673e9SRodney W. Grimes if (n == 0) { 733004c9c5dSGarance A Drosehn rmcp = 1; 734dea673e9SRodney W. Grimes } 735004c9c5dSGarance A Drosehn } else if (*cp == 'e') { 736004c9c5dSGarance A Drosehn /* 737004c9c5dSGarance A Drosehn * Must be an errrs or email temp file. 738004c9c5dSGarance A Drosehn */ 739004c9c5dSGarance A Drosehn rmcp = 1; 740dea673e9SRodney W. Grimes } else { 741dea673e9SRodney W. Grimes /* 742dea673e9SRodney W. Grimes * Must be a df with no cf (otherwise, it would have 7431fd731faSGarance A Drosehn * been skipped above) or an rf or tf file (which can 7441fd731faSGarance A Drosehn * always be removed if it is old enough). 745dea673e9SRodney W. Grimes */ 746004c9c5dSGarance A Drosehn rmcp = 1; 747004c9c5dSGarance A Drosehn } 748004c9c5dSGarance A Drosehn if (rmcp) { 749004c9c5dSGarance A Drosehn if (strlen(cp) >= linerem) { 750004c9c5dSGarance A Drosehn printf("\t** internal error: 'line' overflow!\n"); 751004c9c5dSGarance A Drosehn printf("\t** spooldir = %s\n", pp->spool_dir); 752004c9c5dSGarance A Drosehn printf("\t** cp = %s\n", cp); 753004c9c5dSGarance A Drosehn return; 754004c9c5dSGarance A Drosehn } 755004c9c5dSGarance A Drosehn strlcpy(lp, cp, linerem); 756dea673e9SRodney W. Grimes unlinkf(line); 757dea673e9SRodney W. Grimes } 758dea673e9SRodney W. Grimes } while (++i < nitems); 759dea673e9SRodney W. Grimes } 760dea673e9SRodney W. Grimes 761dea673e9SRodney W. Grimes static void 762004c9c5dSGarance A Drosehn wrapup_clean(int laststatus __unused) 763004c9c5dSGarance A Drosehn { 764004c9c5dSGarance A Drosehn 765004c9c5dSGarance A Drosehn printf("Checked %d queues, and ", cln_queuecnt); 766004c9c5dSGarance A Drosehn if (cln_filecnt < 1) { 767004c9c5dSGarance A Drosehn printf("no cruft was found\n"); 768004c9c5dSGarance A Drosehn return; 769004c9c5dSGarance A Drosehn } 770004c9c5dSGarance A Drosehn if (cln_testonly) { 771004c9c5dSGarance A Drosehn printf("would have "); 772004c9c5dSGarance A Drosehn } 773004c9c5dSGarance A Drosehn printf("removed %d files (%ld bytes).\n", cln_filecnt, cln_sizecnt); 774004c9c5dSGarance A Drosehn } 775004c9c5dSGarance A Drosehn 776004c9c5dSGarance A Drosehn static void 777ba7a1ad7SGarance A Drosehn unlinkf(char *name) 778dea673e9SRodney W. Grimes { 779004c9c5dSGarance A Drosehn struct stat stbuf; 780004c9c5dSGarance A Drosehn double agemod, agestat; 781004c9c5dSGarance A Drosehn int res; 782004c9c5dSGarance A Drosehn char linkbuf[BUFSIZ]; 783004c9c5dSGarance A Drosehn 784004c9c5dSGarance A Drosehn /* 785004c9c5dSGarance A Drosehn * We have to use lstat() instead of stat(), in case this is a df* 786004c9c5dSGarance A Drosehn * "file" which is really a symlink due to 'lpr -s' processing. In 787004c9c5dSGarance A Drosehn * that case, we need to check the last-mod time of the symlink, and 788004c9c5dSGarance A Drosehn * not the file that the symlink is pointed at. 789004c9c5dSGarance A Drosehn */ 790360d4ad5SWarner Losh seteuid(euid); 791004c9c5dSGarance A Drosehn res = lstat(name, &stbuf); 792004c9c5dSGarance A Drosehn seteuid(uid); 793004c9c5dSGarance A Drosehn if (res < 0) { 794004c9c5dSGarance A Drosehn printf("\terror return from stat(%s):\n", name); 795004c9c5dSGarance A Drosehn printf("\t %s\n", strerror(errno)); 796004c9c5dSGarance A Drosehn return; 797004c9c5dSGarance A Drosehn } 798004c9c5dSGarance A Drosehn 799004c9c5dSGarance A Drosehn agemod = difftime(cln_now, stbuf.st_mtime); 800004c9c5dSGarance A Drosehn agestat = difftime(cln_now, stbuf.st_ctime); 801ceeaedd3SGarance A Drosehn if (cln_debug > 1) { 802004c9c5dSGarance A Drosehn /* this debugging-aid probably is not needed any more... */ 803004c9c5dSGarance A Drosehn printf("\t\t modify age=%g secs, stat age=%g secs\n", 804004c9c5dSGarance A Drosehn agemod, agestat); 805004c9c5dSGarance A Drosehn } 806004c9c5dSGarance A Drosehn if ((agemod <= cln_minage) && (agestat <= cln_minage)) 807004c9c5dSGarance A Drosehn return; 808004c9c5dSGarance A Drosehn 809004c9c5dSGarance A Drosehn /* 810004c9c5dSGarance A Drosehn * if this file is a symlink, then find out the target of the 811004c9c5dSGarance A Drosehn * symlink before unlink-ing the file itself 812004c9c5dSGarance A Drosehn */ 813004c9c5dSGarance A Drosehn if (S_ISLNK(stbuf.st_mode)) { 814004c9c5dSGarance A Drosehn seteuid(euid); 815004c9c5dSGarance A Drosehn res = readlink(name, linkbuf, sizeof(linkbuf)); 816004c9c5dSGarance A Drosehn seteuid(uid); 817004c9c5dSGarance A Drosehn if (res < 0) { 818004c9c5dSGarance A Drosehn printf("\terror return from readlink(%s):\n", name); 819004c9c5dSGarance A Drosehn printf("\t %s\n", strerror(errno)); 820004c9c5dSGarance A Drosehn return; 821004c9c5dSGarance A Drosehn } 822004c9c5dSGarance A Drosehn if (res == sizeof(linkbuf)) 823004c9c5dSGarance A Drosehn res--; 824004c9c5dSGarance A Drosehn linkbuf[res] = '\0'; 825004c9c5dSGarance A Drosehn } 826004c9c5dSGarance A Drosehn 827004c9c5dSGarance A Drosehn cln_filecnt++; 828004c9c5dSGarance A Drosehn cln_sizecnt += stbuf.st_size; 829004c9c5dSGarance A Drosehn 830004c9c5dSGarance A Drosehn if (cln_testonly) { 831004c9c5dSGarance A Drosehn printf("\twould remove %s\n", name); 832004c9c5dSGarance A Drosehn if (S_ISLNK(stbuf.st_mode)) { 833004c9c5dSGarance A Drosehn printf("\t (which is a symlink to %s)\n", linkbuf); 834004c9c5dSGarance A Drosehn } 835004c9c5dSGarance A Drosehn } else { 836004c9c5dSGarance A Drosehn seteuid(euid); 837004c9c5dSGarance A Drosehn res = unlink(name); 838004c9c5dSGarance A Drosehn seteuid(uid); 839004c9c5dSGarance A Drosehn if (res < 0) 840004c9c5dSGarance A Drosehn printf("\tcannot remove %s (!)\n", name); 841dea673e9SRodney W. Grimes else 842dea673e9SRodney W. Grimes printf("\tremoved %s\n", name); 843004c9c5dSGarance A Drosehn /* XXX 844004c9c5dSGarance A Drosehn * Note that for a df* file, this code should also check to see 845004c9c5dSGarance A Drosehn * if it is a symlink to some other file, and if the original 846004c9c5dSGarance A Drosehn * lpr command included '-r' ("remove file"). Of course, this 847004c9c5dSGarance A Drosehn * code would not be removing the df* file unless there was no 848004c9c5dSGarance A Drosehn * matching cf* file, and without the cf* file it is currently 849004c9c5dSGarance A Drosehn * impossible to determine if '-r' had been specified... 850004c9c5dSGarance A Drosehn * 851004c9c5dSGarance A Drosehn * As a result of this quandry, we may be leaving behind a 852004c9c5dSGarance A Drosehn * user's file that was supposed to have been removed after 853004c9c5dSGarance A Drosehn * being printed. This may effect services such as CAP or 854004c9c5dSGarance A Drosehn * samba, if they were configured to use 'lpr -r', and if 855004c9c5dSGarance A Drosehn * datafiles are not being properly removed. 856004c9c5dSGarance A Drosehn */ 857004c9c5dSGarance A Drosehn if (S_ISLNK(stbuf.st_mode)) { 858004c9c5dSGarance A Drosehn printf("\t (which was a symlink to %s)\n", linkbuf); 859004c9c5dSGarance A Drosehn } 860004c9c5dSGarance A Drosehn } 861dea673e9SRodney W. Grimes } 862dea673e9SRodney W. Grimes 863dea673e9SRodney W. Grimes /* 864e8e715faSGarance A Drosehn * Enable queuing to the printer (allow lpr to add new jobs to the queue). 865e8e715faSGarance A Drosehn */ 866e8e715faSGarance A Drosehn void 867e8e715faSGarance A Drosehn enable_q(struct printer *pp) 868e8e715faSGarance A Drosehn { 869e8e715faSGarance A Drosehn int setres; 870e8e715faSGarance A Drosehn char lf[MAXPATHLEN]; 871e8e715faSGarance A Drosehn 872e8e715faSGarance A Drosehn lock_file_name(pp, lf, sizeof lf); 873e8e715faSGarance A Drosehn printf("%s:\n", pp->printer); 874e8e715faSGarance A Drosehn 875e8e715faSGarance A Drosehn setres = set_qstate(SQS_ENABLEQ, lf); 876e8e715faSGarance A Drosehn } 877e8e715faSGarance A Drosehn 878e8e715faSGarance A Drosehn /* 879dea673e9SRodney W. Grimes * Disable queuing. 880dea673e9SRodney W. Grimes */ 881dea673e9SRodney W. Grimes void 882e8e715faSGarance A Drosehn disable_q(struct printer *pp) 883e8e715faSGarance A Drosehn { 884e8e715faSGarance A Drosehn int setres; 885e8e715faSGarance A Drosehn char lf[MAXPATHLEN]; 886e8e715faSGarance A Drosehn 887e8e715faSGarance A Drosehn lock_file_name(pp, lf, sizeof lf); 888e8e715faSGarance A Drosehn printf("%s:\n", pp->printer); 889e8e715faSGarance A Drosehn 890e8e715faSGarance A Drosehn setres = set_qstate(SQS_DISABLEQ, lf); 891e8e715faSGarance A Drosehn } 892e8e715faSGarance A Drosehn 893e8e715faSGarance A Drosehn /* 894dea673e9SRodney W. Grimes * Disable queuing and printing and put a message into the status file 8955b1c34fbSGarance A Drosehn * (reason for being down). If the user specified `-msg', then use 8965b1c34fbSGarance A Drosehn * everything after that as the message for the status file. If the 8975b1c34fbSGarance A Drosehn * user did NOT specify `-msg', then the command should take the first 8985b1c34fbSGarance A Drosehn * parameter as the printer name, and all remaining parameters as the 8995b1c34fbSGarance A Drosehn * message for the status file. (This is to be compatible with the 9005b1c34fbSGarance A Drosehn * original definition of 'down', which was implemented long before 9015b1c34fbSGarance A Drosehn * `-msg' was around). 9025b1c34fbSGarance A Drosehn */ 9035b1c34fbSGarance A Drosehn void 9045b1c34fbSGarance A Drosehn down_gi(int argc, char *argv[]) 9055b1c34fbSGarance A Drosehn { 9065b1c34fbSGarance A Drosehn 9075b1c34fbSGarance A Drosehn /* If `-msg' was specified, then this routine has nothing to do. */ 9085b1c34fbSGarance A Drosehn if (generic_msg != NULL) 9095b1c34fbSGarance A Drosehn return; 9105b1c34fbSGarance A Drosehn 9115b1c34fbSGarance A Drosehn /* 9125b1c34fbSGarance A Drosehn * If the user only gave one parameter, then use a default msg. 9135b1c34fbSGarance A Drosehn * (if argc == 1 at this point, then *argv == name of printer). 9145b1c34fbSGarance A Drosehn */ 9155b1c34fbSGarance A Drosehn if (argc == 1) { 9165b1c34fbSGarance A Drosehn generic_msg = strdup("printing disabled\n"); 9175b1c34fbSGarance A Drosehn return; 9185b1c34fbSGarance A Drosehn } 9195b1c34fbSGarance A Drosehn 9205b1c34fbSGarance A Drosehn /* 9215b1c34fbSGarance A Drosehn * The user specified multiple parameters, and did not specify 9225b1c34fbSGarance A Drosehn * `-msg'. Build a message from all the parameters after the 9235b1c34fbSGarance A Drosehn * first one (and nullify those parameters so generic-processing 9245b1c34fbSGarance A Drosehn * will not process them as printer-queue names). 9255b1c34fbSGarance A Drosehn */ 9265b1c34fbSGarance A Drosehn argc--; 9275b1c34fbSGarance A Drosehn argv++; 9285b1c34fbSGarance A Drosehn generic_msg = args2line(argc, argv); 9295b1c34fbSGarance A Drosehn for (; argc > 0; argc--, argv++) 9305b1c34fbSGarance A Drosehn *argv = generic_nullarg; /* "erase" it */ 9315b1c34fbSGarance A Drosehn } 9325b1c34fbSGarance A Drosehn 9335b1c34fbSGarance A Drosehn void 9345b1c34fbSGarance A Drosehn down_q(struct printer *pp) 9355b1c34fbSGarance A Drosehn { 9365b1c34fbSGarance A Drosehn int setres; 9375b1c34fbSGarance A Drosehn char lf[MAXPATHLEN]; 9385b1c34fbSGarance A Drosehn 9395b1c34fbSGarance A Drosehn lock_file_name(pp, lf, sizeof lf); 9405b1c34fbSGarance A Drosehn printf("%s:\n", pp->printer); 9415b1c34fbSGarance A Drosehn 9425b1c34fbSGarance A Drosehn setres = set_qstate(SQS_DISABLEQ+SQS_STOPP, lf); 9435b1c34fbSGarance A Drosehn if (setres >= 0) 9445b1c34fbSGarance A Drosehn upstat(pp, generic_msg, 1); 9455b1c34fbSGarance A Drosehn } 9465b1c34fbSGarance A Drosehn 9475b1c34fbSGarance A Drosehn /* 948dea673e9SRodney W. Grimes * Exit lpc 949dea673e9SRodney W. Grimes */ 950dea673e9SRodney W. Grimes void 951ba7a1ad7SGarance A Drosehn quit(int argc __unused, char *argv[] __unused) 952dea673e9SRodney W. Grimes { 953dea673e9SRodney W. Grimes exit(0); 954dea673e9SRodney W. Grimes } 955dea673e9SRodney W. Grimes 956dea673e9SRodney W. Grimes /* 957dea673e9SRodney W. Grimes * Kill and restart the daemon. 958dea673e9SRodney W. Grimes */ 959dea673e9SRodney W. Grimes void 960e8e715faSGarance A Drosehn restart_q(struct printer *pp) 961e8e715faSGarance A Drosehn { 962e8e715faSGarance A Drosehn int killres, setres, startok; 963e8e715faSGarance A Drosehn char lf[MAXPATHLEN]; 964e8e715faSGarance A Drosehn 965e8e715faSGarance A Drosehn lock_file_name(pp, lf, sizeof lf); 966e8e715faSGarance A Drosehn printf("%s:\n", pp->printer); 967e8e715faSGarance A Drosehn 968e8e715faSGarance A Drosehn killres = kill_qtask(lf); 969e8e715faSGarance A Drosehn 970e8e715faSGarance A Drosehn /* 971e8e715faSGarance A Drosehn * XXX - if the kill worked, we should probably sleep for 972e8e715faSGarance A Drosehn * a second or so before trying to restart the queue. 973e8e715faSGarance A Drosehn */ 974e8e715faSGarance A Drosehn 975e8e715faSGarance A Drosehn /* make sure the queue is set to print jobs */ 976e8e715faSGarance A Drosehn setres = set_qstate(SQS_STARTP, lf); 977e8e715faSGarance A Drosehn 978e8e715faSGarance A Drosehn seteuid(euid); 979e8e715faSGarance A Drosehn startok = startdaemon(pp); 980e8e715faSGarance A Drosehn seteuid(uid); 981e8e715faSGarance A Drosehn if (!startok) 982e8e715faSGarance A Drosehn printf("\tcouldn't restart daemon\n"); 983e8e715faSGarance A Drosehn else 984e8e715faSGarance A Drosehn printf("\tdaemon restarted\n"); 985e8e715faSGarance A Drosehn } 986e8e715faSGarance A Drosehn 987e8e715faSGarance A Drosehn /* 98854032d11SGarance A Drosehn * Set the status message of each queue listed. Requires a "-msg" 98954032d11SGarance A Drosehn * parameter to indicate the end of the queue list and start of msg text. 99054032d11SGarance A Drosehn */ 99154032d11SGarance A Drosehn void 99254032d11SGarance A Drosehn setstatus_gi(int argc __unused, char *argv[] __unused) 99354032d11SGarance A Drosehn { 99454032d11SGarance A Drosehn 99554032d11SGarance A Drosehn if (generic_msg == NULL) { 99654032d11SGarance A Drosehn printf("You must specify '-msg' before the text of the new status message.\n"); 99754032d11SGarance A Drosehn generic_initerr = 1; 99854032d11SGarance A Drosehn } 99954032d11SGarance A Drosehn } 100054032d11SGarance A Drosehn 100154032d11SGarance A Drosehn void 100254032d11SGarance A Drosehn setstatus_q(struct printer *pp) 100354032d11SGarance A Drosehn { 100454032d11SGarance A Drosehn char lf[MAXPATHLEN]; 100554032d11SGarance A Drosehn 100654032d11SGarance A Drosehn lock_file_name(pp, lf, sizeof lf); 100754032d11SGarance A Drosehn printf("%s:\n", pp->printer); 100854032d11SGarance A Drosehn 100954032d11SGarance A Drosehn upstat(pp, generic_msg, 1); 101054032d11SGarance A Drosehn } 101154032d11SGarance A Drosehn 101254032d11SGarance A Drosehn /* 1013dea673e9SRodney W. Grimes * Enable printing on the specified printer and startup the daemon. 1014dea673e9SRodney W. Grimes */ 1015dea673e9SRodney W. Grimes void 1016e8e715faSGarance A Drosehn start_q(struct printer *pp) 1017e8e715faSGarance A Drosehn { 1018e8e715faSGarance A Drosehn int setres, startok; 1019e8e715faSGarance A Drosehn char lf[MAXPATHLEN]; 1020e8e715faSGarance A Drosehn 1021e8e715faSGarance A Drosehn lock_file_name(pp, lf, sizeof lf); 1022e8e715faSGarance A Drosehn printf("%s:\n", pp->printer); 1023e8e715faSGarance A Drosehn 1024e8e715faSGarance A Drosehn setres = set_qstate(SQS_STARTP, lf); 1025e8e715faSGarance A Drosehn 1026e8e715faSGarance A Drosehn seteuid(euid); 1027e8e715faSGarance A Drosehn startok = startdaemon(pp); 1028e8e715faSGarance A Drosehn seteuid(uid); 1029e8e715faSGarance A Drosehn if (!startok) 1030e8e715faSGarance A Drosehn printf("\tcouldn't start daemon\n"); 1031e8e715faSGarance A Drosehn else 1032e8e715faSGarance A Drosehn printf("\tdaemon started\n"); 1033e8e715faSGarance A Drosehn seteuid(uid); 1034e8e715faSGarance A Drosehn } 1035e8e715faSGarance A Drosehn 1036e8e715faSGarance A Drosehn /* 1037dea673e9SRodney W. Grimes * Print the status of the printer queue. 1038dea673e9SRodney W. Grimes */ 10394a1a0dbeSGarrett Wollman void 1040ba7a1ad7SGarance A Drosehn status(struct printer *pp) 1041dea673e9SRodney W. Grimes { 1042dea673e9SRodney W. Grimes struct stat stbuf; 1043dea673e9SRodney W. Grimes register int fd, i; 1044dea673e9SRodney W. Grimes register struct dirent *dp; 1045dea673e9SRodney W. Grimes DIR *dirp; 10464a1a0dbeSGarrett Wollman char file[MAXPATHLEN]; 1047dea673e9SRodney W. Grimes 10484a1a0dbeSGarrett Wollman printf("%s:\n", pp->printer); 10494a1a0dbeSGarrett Wollman lock_file_name(pp, file, sizeof file); 10504a1a0dbeSGarrett Wollman if (stat(file, &stbuf) >= 0) { 1051dea673e9SRodney W. Grimes printf("\tqueuing is %s\n", 10524a1a0dbeSGarrett Wollman ((stbuf.st_mode & LFM_QUEUE_DIS) ? "disabled" 10534a1a0dbeSGarrett Wollman : "enabled")); 1054dea673e9SRodney W. Grimes printf("\tprinting is %s\n", 10554a1a0dbeSGarrett Wollman ((stbuf.st_mode & LFM_PRINT_DIS) ? "disabled" 10564a1a0dbeSGarrett Wollman : "enabled")); 1057dea673e9SRodney W. Grimes } else { 1058dea673e9SRodney W. Grimes printf("\tqueuing is enabled\n"); 1059dea673e9SRodney W. Grimes printf("\tprinting is enabled\n"); 1060dea673e9SRodney W. Grimes } 10614a1a0dbeSGarrett Wollman if ((dirp = opendir(pp->spool_dir)) == NULL) { 1062dea673e9SRodney W. Grimes printf("\tcannot examine spool directory\n"); 1063dea673e9SRodney W. Grimes return; 1064dea673e9SRodney W. Grimes } 1065dea673e9SRodney W. Grimes i = 0; 1066dea673e9SRodney W. Grimes while ((dp = readdir(dirp)) != NULL) { 1067dea673e9SRodney W. Grimes if (*dp->d_name == 'c' && dp->d_name[1] == 'f') 1068dea673e9SRodney W. Grimes i++; 1069dea673e9SRodney W. Grimes } 1070dea673e9SRodney W. Grimes closedir(dirp); 1071dea673e9SRodney W. Grimes if (i == 0) 10724a1a0dbeSGarrett Wollman printf("\tno entries in spool area\n"); 1073dea673e9SRodney W. Grimes else if (i == 1) 1074dea673e9SRodney W. Grimes printf("\t1 entry in spool area\n"); 1075dea673e9SRodney W. Grimes else 1076dea673e9SRodney W. Grimes printf("\t%d entries in spool area\n", i); 10774a1a0dbeSGarrett Wollman fd = open(file, O_RDONLY); 1078dea673e9SRodney W. Grimes if (fd < 0 || flock(fd, LOCK_SH|LOCK_NB) == 0) { 1079dea673e9SRodney W. Grimes (void) close(fd); /* unlocks as well */ 1080bc407914SWarner Losh printf("\tprinter idle\n"); 1081dea673e9SRodney W. Grimes return; 1082dea673e9SRodney W. Grimes } 1083dea673e9SRodney W. Grimes (void) close(fd); 108436abea5dSBrian Somers /* print out the contents of the status file, if it exists */ 10854a1a0dbeSGarrett Wollman status_file_name(pp, file, sizeof file); 10864a1a0dbeSGarrett Wollman fd = open(file, O_RDONLY|O_SHLOCK); 1087dea673e9SRodney W. Grimes if (fd >= 0) { 108836abea5dSBrian Somers (void) fstat(fd, &stbuf); 108936abea5dSBrian Somers if (stbuf.st_size > 0) { 109036abea5dSBrian Somers putchar('\t'); 1091dea673e9SRodney W. Grimes while ((i = read(fd, line, sizeof(line))) > 0) 1092dea673e9SRodney W. Grimes (void) fwrite(line, 1, i, stdout); 109336abea5dSBrian Somers } 1094dea673e9SRodney W. Grimes (void) close(fd); /* unlocks as well */ 1095dea673e9SRodney W. Grimes } 1096dea673e9SRodney W. Grimes } 1097dea673e9SRodney W. Grimes 1098dea673e9SRodney W. Grimes /* 1099dea673e9SRodney W. Grimes * Stop the specified daemon after completing the current job and disable 1100dea673e9SRodney W. Grimes * printing. 1101dea673e9SRodney W. Grimes */ 1102dea673e9SRodney W. Grimes void 1103e8e715faSGarance A Drosehn stop_q(struct printer *pp) 1104e8e715faSGarance A Drosehn { 1105e8e715faSGarance A Drosehn int setres; 1106e8e715faSGarance A Drosehn char lf[MAXPATHLEN]; 1107e8e715faSGarance A Drosehn 1108e8e715faSGarance A Drosehn lock_file_name(pp, lf, sizeof lf); 1109e8e715faSGarance A Drosehn printf("%s:\n", pp->printer); 1110e8e715faSGarance A Drosehn 1111e8e715faSGarance A Drosehn setres = set_qstate(SQS_STOPP, lf); 1112e8e715faSGarance A Drosehn 111354032d11SGarance A Drosehn if (setres >= 0) 111454032d11SGarance A Drosehn upstat(pp, "printing disabled\n", 0); 1115e8e715faSGarance A Drosehn } 1116e8e715faSGarance A Drosehn 111730b4b758SGarance A Drosehn struct jobqueue **queue; 1118dea673e9SRodney W. Grimes int nitems; 1119dea673e9SRodney W. Grimes time_t mtime; 1120dea673e9SRodney W. Grimes 1121dea673e9SRodney W. Grimes /* 1122dea673e9SRodney W. Grimes * Put the specified jobs at the top of printer queue. 1123dea673e9SRodney W. Grimes */ 1124dea673e9SRodney W. Grimes void 1125ba7a1ad7SGarance A Drosehn topq(int argc, char *argv[]) 1126dea673e9SRodney W. Grimes { 1127dea673e9SRodney W. Grimes register int i; 1128dea673e9SRodney W. Grimes struct stat stbuf; 1129ba7a1ad7SGarance A Drosehn int cmdstatus, changed; 11304a1a0dbeSGarrett Wollman struct printer myprinter, *pp = &myprinter; 1131dea673e9SRodney W. Grimes 1132dea673e9SRodney W. Grimes if (argc < 3) { 1133d3974088SDag-Erling Smørgrav printf("usage: topq printer [jobnum ...] [user ...]\n"); 1134dea673e9SRodney W. Grimes return; 1135dea673e9SRodney W. Grimes } 1136dea673e9SRodney W. Grimes 1137dea673e9SRodney W. Grimes --argc; 11384a1a0dbeSGarrett Wollman ++argv; 11394a1a0dbeSGarrett Wollman init_printer(pp); 1140ba7a1ad7SGarance A Drosehn cmdstatus = getprintcap(*argv, pp); 1141ba7a1ad7SGarance A Drosehn switch(cmdstatus) { 11424a1a0dbeSGarrett Wollman default: 11436d39e1b7SGarance A Drosehn fatal(pp, "%s", pcaperr(cmdstatus)); 11444a1a0dbeSGarrett Wollman case PCAPERR_NOTFOUND: 11454a1a0dbeSGarrett Wollman printf("unknown printer %s\n", *argv); 1146dea673e9SRodney W. Grimes return; 11474a1a0dbeSGarrett Wollman case PCAPERR_TCOPEN: 11484a1a0dbeSGarrett Wollman printf("warning: %s: unresolved tc= reference(s)", *argv); 11494a1a0dbeSGarrett Wollman break; 11504a1a0dbeSGarrett Wollman case PCAPERR_SUCCESS: 11514a1a0dbeSGarrett Wollman break; 11524a1a0dbeSGarrett Wollman } 11534a1a0dbeSGarrett Wollman printf("%s:\n", pp->printer); 1154dea673e9SRodney W. Grimes 1155360d4ad5SWarner Losh seteuid(euid); 11564a1a0dbeSGarrett Wollman if (chdir(pp->spool_dir) < 0) { 11574a1a0dbeSGarrett Wollman printf("\tcannot chdir to %s\n", pp->spool_dir); 1158360d4ad5SWarner Losh goto out; 1159dea673e9SRodney W. Grimes } 1160360d4ad5SWarner Losh seteuid(uid); 11614a1a0dbeSGarrett Wollman nitems = getq(pp, &queue); 1162dea673e9SRodney W. Grimes if (nitems == 0) 1163dea673e9SRodney W. Grimes return; 1164dea673e9SRodney W. Grimes changed = 0; 116530b4b758SGarance A Drosehn mtime = queue[0]->job_time; 1166dea673e9SRodney W. Grimes for (i = argc; --i; ) { 1167dea673e9SRodney W. Grimes if (doarg(argv[i]) == 0) { 1168dea673e9SRodney W. Grimes printf("\tjob %s is not in the queue\n", argv[i]); 1169dea673e9SRodney W. Grimes continue; 1170dea673e9SRodney W. Grimes } else 1171dea673e9SRodney W. Grimes changed++; 1172dea673e9SRodney W. Grimes } 1173dea673e9SRodney W. Grimes for (i = 0; i < nitems; i++) 1174dea673e9SRodney W. Grimes free(queue[i]); 1175dea673e9SRodney W. Grimes free(queue); 1176dea673e9SRodney W. Grimes if (!changed) { 1177dea673e9SRodney W. Grimes printf("\tqueue order unchanged\n"); 1178dea673e9SRodney W. Grimes return; 1179dea673e9SRodney W. Grimes } 1180dea673e9SRodney W. Grimes /* 1181dea673e9SRodney W. Grimes * Turn on the public execute bit of the lock file to 1182dea673e9SRodney W. Grimes * get lpd to rebuild the queue after the current job. 1183dea673e9SRodney W. Grimes */ 1184360d4ad5SWarner Losh seteuid(euid); 11854a1a0dbeSGarrett Wollman if (changed && stat(pp->lock_file, &stbuf) >= 0) 11864a1a0dbeSGarrett Wollman (void) chmod(pp->lock_file, stbuf.st_mode | LFM_RESET_QUE); 1187360d4ad5SWarner Losh 1188360d4ad5SWarner Losh out: 1189360d4ad5SWarner Losh seteuid(uid); 1190dea673e9SRodney W. Grimes } 1191dea673e9SRodney W. Grimes 1192dea673e9SRodney W. Grimes /* 1193dea673e9SRodney W. Grimes * Reposition the job by changing the modification time of 1194dea673e9SRodney W. Grimes * the control file. 1195dea673e9SRodney W. Grimes */ 1196dea673e9SRodney W. Grimes static int 1197ba7a1ad7SGarance A Drosehn touch(struct jobqueue *jq) 1198dea673e9SRodney W. Grimes { 1199dea673e9SRodney W. Grimes struct timeval tvp[2]; 1200360d4ad5SWarner Losh int ret; 1201dea673e9SRodney W. Grimes 1202dea673e9SRodney W. Grimes tvp[0].tv_sec = tvp[1].tv_sec = --mtime; 1203dea673e9SRodney W. Grimes tvp[0].tv_usec = tvp[1].tv_usec = 0; 1204360d4ad5SWarner Losh seteuid(euid); 1205ba7a1ad7SGarance A Drosehn ret = utimes(jq->job_cfname, tvp); 1206360d4ad5SWarner Losh seteuid(uid); 1207360d4ad5SWarner Losh return (ret); 1208dea673e9SRodney W. Grimes } 1209dea673e9SRodney W. Grimes 1210dea673e9SRodney W. Grimes /* 1211dea673e9SRodney W. Grimes * Checks if specified job name is in the printer's queue. 1212dea673e9SRodney W. Grimes * Returns: negative (-1) if argument name is not in the queue. 1213dea673e9SRodney W. Grimes */ 1214dea673e9SRodney W. Grimes static int 1215ba7a1ad7SGarance A Drosehn doarg(char *job) 1216dea673e9SRodney W. Grimes { 121730b4b758SGarance A Drosehn register struct jobqueue **qq; 1218dea673e9SRodney W. Grimes register int jobnum, n; 1219dea673e9SRodney W. Grimes register char *cp, *machine; 1220dea673e9SRodney W. Grimes int cnt = 0; 1221dea673e9SRodney W. Grimes FILE *fp; 1222dea673e9SRodney W. Grimes 1223dea673e9SRodney W. Grimes /* 1224dea673e9SRodney W. Grimes * Look for a job item consisting of system name, colon, number 1225dea673e9SRodney W. Grimes * (example: ucbarpa:114) 1226dea673e9SRodney W. Grimes */ 1227f8eb25daSWarner Losh if ((cp = strchr(job, ':')) != NULL) { 1228dea673e9SRodney W. Grimes machine = job; 1229dea673e9SRodney W. Grimes *cp++ = '\0'; 1230dea673e9SRodney W. Grimes job = cp; 1231dea673e9SRodney W. Grimes } else 1232dea673e9SRodney W. Grimes machine = NULL; 1233dea673e9SRodney W. Grimes 1234dea673e9SRodney W. Grimes /* 1235dea673e9SRodney W. Grimes * Check for job specified by number (example: 112 or 235ucbarpa). 1236dea673e9SRodney W. Grimes */ 1237dea673e9SRodney W. Grimes if (isdigit(*job)) { 1238dea673e9SRodney W. Grimes jobnum = 0; 1239dea673e9SRodney W. Grimes do 1240dea673e9SRodney W. Grimes jobnum = jobnum * 10 + (*job++ - '0'); 1241dea673e9SRodney W. Grimes while (isdigit(*job)); 1242dea673e9SRodney W. Grimes for (qq = queue + nitems; --qq >= queue; ) { 1243dea673e9SRodney W. Grimes n = 0; 124430b4b758SGarance A Drosehn for (cp = (*qq)->job_cfname+3; isdigit(*cp); ) 1245dea673e9SRodney W. Grimes n = n * 10 + (*cp++ - '0'); 1246dea673e9SRodney W. Grimes if (jobnum != n) 1247dea673e9SRodney W. Grimes continue; 1248dea673e9SRodney W. Grimes if (*job && strcmp(job, cp) != 0) 1249dea673e9SRodney W. Grimes continue; 1250dea673e9SRodney W. Grimes if (machine != NULL && strcmp(machine, cp) != 0) 1251dea673e9SRodney W. Grimes continue; 1252dea673e9SRodney W. Grimes if (touch(*qq) == 0) { 125330b4b758SGarance A Drosehn printf("\tmoved %s\n", (*qq)->job_cfname); 1254dea673e9SRodney W. Grimes cnt++; 1255dea673e9SRodney W. Grimes } 1256dea673e9SRodney W. Grimes } 1257dea673e9SRodney W. Grimes return(cnt); 1258dea673e9SRodney W. Grimes } 1259dea673e9SRodney W. Grimes /* 1260dea673e9SRodney W. Grimes * Process item consisting of owner's name (example: henry). 1261dea673e9SRodney W. Grimes */ 1262dea673e9SRodney W. Grimes for (qq = queue + nitems; --qq >= queue; ) { 1263360d4ad5SWarner Losh seteuid(euid); 126430b4b758SGarance A Drosehn fp = fopen((*qq)->job_cfname, "r"); 1265360d4ad5SWarner Losh seteuid(uid); 1266360d4ad5SWarner Losh if (fp == NULL) 1267dea673e9SRodney W. Grimes continue; 1268dea673e9SRodney W. Grimes while (getline(fp) > 0) 1269dea673e9SRodney W. Grimes if (line[0] == 'P') 1270dea673e9SRodney W. Grimes break; 1271dea673e9SRodney W. Grimes (void) fclose(fp); 1272dea673e9SRodney W. Grimes if (line[0] != 'P' || strcmp(job, line+1) != 0) 1273dea673e9SRodney W. Grimes continue; 1274dea673e9SRodney W. Grimes if (touch(*qq) == 0) { 127530b4b758SGarance A Drosehn printf("\tmoved %s\n", (*qq)->job_cfname); 1276dea673e9SRodney W. Grimes cnt++; 1277dea673e9SRodney W. Grimes } 1278dea673e9SRodney W. Grimes } 1279dea673e9SRodney W. Grimes return(cnt); 1280dea673e9SRodney W. Grimes } 1281dea673e9SRodney W. Grimes 1282dea673e9SRodney W. Grimes /* 1283e8e715faSGarance A Drosehn * Enable both queuing & printing, and start printer (undo `down'). 1284e8e715faSGarance A Drosehn */ 1285e8e715faSGarance A Drosehn void 1286e8e715faSGarance A Drosehn up_q(struct printer *pp) 1287e8e715faSGarance A Drosehn { 1288e8e715faSGarance A Drosehn int setres, startok; 1289e8e715faSGarance A Drosehn char lf[MAXPATHLEN]; 1290e8e715faSGarance A Drosehn 1291e8e715faSGarance A Drosehn lock_file_name(pp, lf, sizeof lf); 1292e8e715faSGarance A Drosehn printf("%s:\n", pp->printer); 1293e8e715faSGarance A Drosehn 1294e8e715faSGarance A Drosehn setres = set_qstate(SQS_ENABLEQ+SQS_STARTP, lf); 1295e8e715faSGarance A Drosehn 1296e8e715faSGarance A Drosehn seteuid(euid); 1297e8e715faSGarance A Drosehn startok = startdaemon(pp); 1298e8e715faSGarance A Drosehn seteuid(uid); 1299e8e715faSGarance A Drosehn if (!startok) 1300e8e715faSGarance A Drosehn printf("\tcouldn't start daemon\n"); 1301e8e715faSGarance A Drosehn else 1302e8e715faSGarance A Drosehn printf("\tdaemon started\n"); 1303e8e715faSGarance A Drosehn } 1304