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 * 3. All advertising materials mentioning features or use of this software 15dea673e9SRodney W. Grimes * must display the following acknowledgement: 16dea673e9SRodney W. Grimes * This product includes software developed by the University of 17dea673e9SRodney W. Grimes * California, Berkeley and its contributors. 18dea673e9SRodney W. Grimes * 4. Neither the name of the University nor the names of its contributors 19dea673e9SRodney W. Grimes * may be used to endorse or promote products derived from this software 20dea673e9SRodney W. Grimes * without specific prior written permission. 21dea673e9SRodney W. Grimes * 22dea673e9SRodney W. Grimes * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND 23dea673e9SRodney W. Grimes * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE 24dea673e9SRodney W. Grimes * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE 25dea673e9SRodney W. Grimes * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE 26dea673e9SRodney W. Grimes * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL 27dea673e9SRodney W. Grimes * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS 28dea673e9SRodney W. Grimes * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) 29dea673e9SRodney W. Grimes * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT 30dea673e9SRodney W. Grimes * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY 31dea673e9SRodney W. Grimes * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF 32dea673e9SRodney W. Grimes * SUCH DAMAGE. 33dea673e9SRodney W. Grimes */ 34dea673e9SRodney W. Grimes 35dea673e9SRodney W. Grimes #ifndef lint 364a1a0dbeSGarrett Wollman static const char copyright[] = 37dea673e9SRodney W. Grimes "@(#) Copyright (c) 1983, 1993\n\ 38dea673e9SRodney W. Grimes The Regents of the University of California. All rights reserved.\n"; 39dea673e9SRodney W. Grimes #endif /* not lint */ 40dea673e9SRodney W. Grimes 41c44a6dceSGarance A Drosehn #if 0 42dea673e9SRodney W. Grimes #ifndef lint 435458e2f4SJoerg Wunsch static char sccsid[] = "@(#)cmds.c 8.2 (Berkeley) 4/28/95"; 44dea673e9SRodney W. Grimes #endif /* not lint */ 45c44a6dceSGarance A Drosehn #endif 46c44a6dceSGarance A Drosehn 47c44a6dceSGarance A Drosehn #include "lp.cdefs.h" /* A cross-platform version of <sys/cdefs.h> */ 48c44a6dceSGarance A Drosehn __FBSDID("$FreeBSD$"); 49dea673e9SRodney W. Grimes 50dea673e9SRodney W. Grimes /* 51dea673e9SRodney W. Grimes * lpc -- line printer control program -- commands: 52dea673e9SRodney W. Grimes */ 53dea673e9SRodney W. Grimes 54dea673e9SRodney W. Grimes #include <sys/param.h> 55dea673e9SRodney W. Grimes #include <sys/time.h> 56dea673e9SRodney W. Grimes #include <sys/stat.h> 575458e2f4SJoerg Wunsch #include <sys/file.h> 58dea673e9SRodney W. Grimes 59dea673e9SRodney W. Grimes #include <signal.h> 60dea673e9SRodney W. Grimes #include <fcntl.h> 61dea673e9SRodney W. Grimes #include <errno.h> 62dea673e9SRodney W. Grimes #include <dirent.h> 63dea673e9SRodney W. Grimes #include <unistd.h> 64dea673e9SRodney W. Grimes #include <stdlib.h> 65dea673e9SRodney W. Grimes #include <stdio.h> 66dea673e9SRodney W. Grimes #include <ctype.h> 67dea673e9SRodney W. Grimes #include <string.h> 68dea673e9SRodney W. Grimes #include "lp.h" 69dea673e9SRodney W. Grimes #include "lp.local.h" 70dea673e9SRodney W. Grimes #include "lpc.h" 71dea673e9SRodney W. Grimes #include "extern.h" 72dea673e9SRodney W. Grimes #include "pathnames.h" 73dea673e9SRodney W. Grimes 74e8e715faSGarance A Drosehn /* 75e8e715faSGarance A Drosehn * Return values from kill_qtask(). 76e8e715faSGarance A Drosehn */ 77e8e715faSGarance A Drosehn #define KQT_LFERROR -2 78e8e715faSGarance A Drosehn #define KQT_KILLFAIL -1 79e8e715faSGarance A Drosehn #define KQT_NODAEMON 0 80e8e715faSGarance A Drosehn #define KQT_KILLOK 1 81e8e715faSGarance A Drosehn 8254032d11SGarance A Drosehn static char *args2line(int argc, char **argv); 83ba7a1ad7SGarance A Drosehn static int doarg(char *_job); 84ba7a1ad7SGarance A Drosehn static int doselect(struct dirent *_d); 85e8e715faSGarance A Drosehn static int kill_qtask(const char *lf); 86ba7a1ad7SGarance A Drosehn static int sortq(const void *_a, const void *_b); 87ba7a1ad7SGarance A Drosehn static int touch(struct jobqueue *_jq); 88ba7a1ad7SGarance A Drosehn static void unlinkf(char *_name); 8954032d11SGarance A Drosehn static void upstat(struct printer *_pp, const char *_msg, int _notify); 90004c9c5dSGarance A Drosehn static void wrapup_clean(int _laststatus); 914a1a0dbeSGarrett Wollman 924a1a0dbeSGarrett Wollman /* 934a1a0dbeSGarrett Wollman * generic framework for commands which operate on all or a specified 944a1a0dbeSGarrett Wollman * set of printers 954a1a0dbeSGarrett Wollman */ 96004c9c5dSGarance A Drosehn enum qsel_val { /* how a given ptr was selected */ 97004c9c5dSGarance A Drosehn QSEL_UNKNOWN = -1, /* ... not selected yet */ 98004c9c5dSGarance A Drosehn QSEL_BYNAME = 0, /* ... user specifed it by name */ 99004c9c5dSGarance A Drosehn QSEL_ALL = 1 /* ... user wants "all" printers */ 100004c9c5dSGarance A Drosehn /* (with more to come) */ 101004c9c5dSGarance A Drosehn }; 102004c9c5dSGarance A Drosehn 103004c9c5dSGarance A Drosehn static enum qsel_val generic_qselect; /* indicates how ptr was selected */ 104004c9c5dSGarance A Drosehn static int generic_initerr; /* result of initrtn processing */ 105e7f478b2SGarance A Drosehn static char *generic_cmdname; 10654032d11SGarance A Drosehn static char *generic_msg; /* if a -msg was specified */ 107004c9c5dSGarance A Drosehn static char *generic_nullarg; 108004c9c5dSGarance A Drosehn static void (*generic_wrapup)(int _last_status); /* perform rtn wrap-up */ 109004c9c5dSGarance A Drosehn 1104a1a0dbeSGarrett Wollman void 11154032d11SGarance A Drosehn generic(void (*specificrtn)(struct printer *_pp), int cmdopts, 112004c9c5dSGarance A Drosehn void (*initrtn)(int _argc, char *_argv[]), int argc, char *argv[]) 1134a1a0dbeSGarrett Wollman { 114004c9c5dSGarance A Drosehn int cmdstatus, more, targc; 115004c9c5dSGarance A Drosehn struct printer myprinter, *pp; 116e7f478b2SGarance A Drosehn char **margv, **targv; 1174a1a0dbeSGarrett Wollman 1184a1a0dbeSGarrett Wollman if (argc == 1) { 1195b1c34fbSGarance A Drosehn /* 1205b1c34fbSGarance A Drosehn * Usage needs a special case for 'down': The user must 1215b1c34fbSGarance A Drosehn * either include `-msg', or only the first parameter 1225b1c34fbSGarance A Drosehn * that they give will be processed as a printer name. 1235b1c34fbSGarance A Drosehn */ 12454032d11SGarance A Drosehn printf("usage: %s {all | printer ...}", argv[0]); 1255b1c34fbSGarance A Drosehn if (strcmp(argv[0], "down") == 0) { 1265b1c34fbSGarance A Drosehn printf(" -msg [<text> ...]\n"); 1275b1c34fbSGarance A Drosehn printf(" or: down {all | printer} [<text> ...]"); 1285b1c34fbSGarance A Drosehn } else if (cmdopts & LPC_MSGOPT) 12954032d11SGarance A Drosehn printf(" [-msg <text> ...]"); 13054032d11SGarance A Drosehn printf("\n"); 1314a1a0dbeSGarrett Wollman return; 1324a1a0dbeSGarrett Wollman } 133004c9c5dSGarance A Drosehn 134e7f478b2SGarance A Drosehn /* The first argument is the command name. */ 135e7f478b2SGarance A Drosehn generic_cmdname = *argv++; 136e7f478b2SGarance A Drosehn argc--; 137e7f478b2SGarance A Drosehn 138004c9c5dSGarance A Drosehn /* 139004c9c5dSGarance A Drosehn * The initialization routine for a command might set a generic 140004c9c5dSGarance A Drosehn * "wrapup" routine, which should be called after processing all 141004c9c5dSGarance A Drosehn * the printers in the command. This might print summary info. 142004c9c5dSGarance A Drosehn * 143004c9c5dSGarance A Drosehn * Note that the initialization routine may also parse (and 144004c9c5dSGarance A Drosehn * nullify) some of the parameters given on the command, leaving 145004c9c5dSGarance A Drosehn * only the parameters which have to do with printer names. 146004c9c5dSGarance A Drosehn */ 147004c9c5dSGarance A Drosehn pp = &myprinter; 148004c9c5dSGarance A Drosehn generic_wrapup = NULL; 149004c9c5dSGarance A Drosehn generic_qselect = QSEL_UNKNOWN; 150004c9c5dSGarance A Drosehn cmdstatus = 0; 151004c9c5dSGarance A Drosehn /* this just needs to be a distinct value of type 'char *' */ 152004c9c5dSGarance A Drosehn if (generic_nullarg == NULL) 153004c9c5dSGarance A Drosehn generic_nullarg = strdup(""); 154004c9c5dSGarance A Drosehn 15554032d11SGarance A Drosehn /* 15654032d11SGarance A Drosehn * Some commands accept a -msg argument, which indicates that 15754032d11SGarance A Drosehn * all remaining arguments should be combined into a string. 15854032d11SGarance A Drosehn */ 15954032d11SGarance A Drosehn generic_msg = NULL; 16054032d11SGarance A Drosehn if (cmdopts & LPC_MSGOPT) { 16154032d11SGarance A Drosehn targc = argc; 16254032d11SGarance A Drosehn targv = argv; 163e7f478b2SGarance A Drosehn for (; targc > 0; targc--, targv++) { 16454032d11SGarance A Drosehn if (strcmp(*targv, "-msg") == 0) { 16554032d11SGarance A Drosehn argc -= targc; 16654032d11SGarance A Drosehn generic_msg = args2line(targc - 1, targv + 1); 16754032d11SGarance A Drosehn break; 16854032d11SGarance A Drosehn } 16954032d11SGarance A Drosehn } 17054032d11SGarance A Drosehn } 17154032d11SGarance A Drosehn 172004c9c5dSGarance A Drosehn /* call initialization routine, if there is one for this cmd */ 173004c9c5dSGarance A Drosehn if (initrtn != NULL) { 174004c9c5dSGarance A Drosehn generic_initerr = 0; 175004c9c5dSGarance A Drosehn (*initrtn)(argc, argv); 176004c9c5dSGarance A Drosehn if (generic_initerr) 177004c9c5dSGarance A Drosehn return; 178e7f478b2SGarance A Drosehn /* 179e7f478b2SGarance A Drosehn * The initrtn may have null'ed out some of the parameters. 180e7f478b2SGarance A Drosehn * Compact the parameter list to remove those nulls, and 181e7f478b2SGarance A Drosehn * correct the arg-count. 182e7f478b2SGarance A Drosehn */ 183004c9c5dSGarance A Drosehn targc = argc; 184004c9c5dSGarance A Drosehn targv = argv; 185e7f478b2SGarance A Drosehn margv = argv; 186e7f478b2SGarance A Drosehn argc = 0; 187e7f478b2SGarance A Drosehn for (; targc > 0; targc--, targv++) { 188e7f478b2SGarance A Drosehn if (*targv != generic_nullarg) { 189e7f478b2SGarance A Drosehn if (targv != margv) 190e7f478b2SGarance A Drosehn *margv = *targv; 191e7f478b2SGarance A Drosehn margv++; 192e7f478b2SGarance A Drosehn argc++; 193004c9c5dSGarance A Drosehn } 194004c9c5dSGarance A Drosehn } 195004c9c5dSGarance A Drosehn } 196004c9c5dSGarance A Drosehn 197e7f478b2SGarance A Drosehn if (argc == 1 && strcmp(*argv, "all") == 0) { 198004c9c5dSGarance A Drosehn generic_qselect = QSEL_ALL; 199ba7a1ad7SGarance A Drosehn more = firstprinter(pp, &cmdstatus); 200ba7a1ad7SGarance A Drosehn if (cmdstatus) 2014a1a0dbeSGarrett Wollman goto looperr; 2024a1a0dbeSGarrett Wollman while (more) { 203ba7a1ad7SGarance A Drosehn (*specificrtn)(pp); 2044a1a0dbeSGarrett Wollman do { 205ba7a1ad7SGarance A Drosehn more = nextprinter(pp, &cmdstatus); 2064a1a0dbeSGarrett Wollman looperr: 207ba7a1ad7SGarance A Drosehn switch (cmdstatus) { 2084a1a0dbeSGarrett Wollman case PCAPERR_TCOPEN: 2094a1a0dbeSGarrett Wollman printf("warning: %s: unresolved " 2104a1a0dbeSGarrett Wollman "tc= reference(s) ", 2114a1a0dbeSGarrett Wollman pp->printer); 2124a1a0dbeSGarrett Wollman case PCAPERR_SUCCESS: 2134a1a0dbeSGarrett Wollman break; 2144a1a0dbeSGarrett Wollman default: 2156d39e1b7SGarance A Drosehn fatal(pp, "%s", pcaperr(cmdstatus)); 2164a1a0dbeSGarrett Wollman } 217ba7a1ad7SGarance A Drosehn } while (more && cmdstatus); 2184a1a0dbeSGarrett Wollman } 219004c9c5dSGarance A Drosehn goto wrapup; 2204a1a0dbeSGarrett Wollman } 221004c9c5dSGarance A Drosehn 222004c9c5dSGarance A Drosehn generic_qselect = QSEL_BYNAME; /* specifically-named ptrs */ 223e7f478b2SGarance A Drosehn for (; argc > 0; argc--, argv++) { 2244a1a0dbeSGarrett Wollman init_printer(pp); 225ba7a1ad7SGarance A Drosehn cmdstatus = getprintcap(*argv, pp); 226ba7a1ad7SGarance A Drosehn switch (cmdstatus) { 2274a1a0dbeSGarrett Wollman default: 2286d39e1b7SGarance A Drosehn fatal(pp, "%s", pcaperr(cmdstatus)); 2294a1a0dbeSGarrett Wollman case PCAPERR_NOTFOUND: 2304a1a0dbeSGarrett Wollman printf("unknown printer %s\n", *argv); 2314a1a0dbeSGarrett Wollman continue; 2324a1a0dbeSGarrett Wollman case PCAPERR_TCOPEN: 2334a1a0dbeSGarrett Wollman printf("warning: %s: unresolved tc= reference(s)\n", 2344a1a0dbeSGarrett Wollman *argv); 2354a1a0dbeSGarrett Wollman break; 2364a1a0dbeSGarrett Wollman case PCAPERR_SUCCESS: 2374a1a0dbeSGarrett Wollman break; 2384a1a0dbeSGarrett Wollman } 239ba7a1ad7SGarance A Drosehn (*specificrtn)(pp); 2404a1a0dbeSGarrett Wollman } 241004c9c5dSGarance A Drosehn 242004c9c5dSGarance A Drosehn wrapup: 243004c9c5dSGarance A Drosehn if (generic_wrapup) { 244004c9c5dSGarance A Drosehn (*generic_wrapup)(cmdstatus); 245004c9c5dSGarance A Drosehn } 246cc2b61b1SGarance A Drosehn free_printer(pp); 24754032d11SGarance A Drosehn if (generic_msg) 24854032d11SGarance A Drosehn free(generic_msg); 24954032d11SGarance A Drosehn } 250004c9c5dSGarance A Drosehn 25154032d11SGarance A Drosehn /* 25254032d11SGarance A Drosehn * Convert an argv-array of character strings into a single string. 25354032d11SGarance A Drosehn */ 25454032d11SGarance A Drosehn static char * 25554032d11SGarance A Drosehn args2line(int argc, char **argv) 25654032d11SGarance A Drosehn { 25754032d11SGarance A Drosehn char *cp1, *cend; 25854032d11SGarance A Drosehn const char *cp2; 25954032d11SGarance A Drosehn char buf[1024]; 26054032d11SGarance A Drosehn 26154032d11SGarance A Drosehn if (argc <= 0) 26254032d11SGarance A Drosehn return strdup("\n"); 26354032d11SGarance A Drosehn 26454032d11SGarance A Drosehn cp1 = buf; 26554032d11SGarance A Drosehn cend = buf + sizeof(buf) - 1; /* save room for '\0' */ 26654032d11SGarance A Drosehn while (--argc >= 0) { 26754032d11SGarance A Drosehn cp2 = *argv++; 26854032d11SGarance A Drosehn while ((cp1 < cend) && (*cp1++ = *cp2++)) 26954032d11SGarance A Drosehn ; 27054032d11SGarance A Drosehn cp1[-1] = ' '; 27154032d11SGarance A Drosehn } 27254032d11SGarance A Drosehn cp1[-1] = '\n'; 27354032d11SGarance A Drosehn *cp1 = '\0'; 27454032d11SGarance A Drosehn return strdup(buf); 2754a1a0dbeSGarrett Wollman } 276dea673e9SRodney W. Grimes 277dea673e9SRodney W. Grimes /* 278e8e715faSGarance A Drosehn * Kill the current daemon, to stop printing of the active job. 279e8e715faSGarance A Drosehn */ 280e8e715faSGarance A Drosehn static int 281e8e715faSGarance A Drosehn kill_qtask(const char *lf) 282e8e715faSGarance A Drosehn { 283e8e715faSGarance A Drosehn FILE *fp; 284e8e715faSGarance A Drosehn pid_t pid; 285e8e715faSGarance A Drosehn int errsav, killres, lockres, res; 286e8e715faSGarance A Drosehn 287e8e715faSGarance A Drosehn seteuid(euid); 288e8e715faSGarance A Drosehn fp = fopen(lf, "r"); 289e8e715faSGarance A Drosehn errsav = errno; 290e8e715faSGarance A Drosehn seteuid(uid); 291e8e715faSGarance A Drosehn res = KQT_NODAEMON; 292e8e715faSGarance A Drosehn if (fp == NULL) { 293e8e715faSGarance A Drosehn /* 294e8e715faSGarance A Drosehn * If there is no lock file, then there is no daemon to 295e8e715faSGarance A Drosehn * kill. Any other error return means there is some 296e8e715faSGarance A Drosehn * kind of problem with the lock file. 297e8e715faSGarance A Drosehn */ 298e8e715faSGarance A Drosehn if (errsav != ENOENT) 299e8e715faSGarance A Drosehn res = KQT_LFERROR; 300e8e715faSGarance A Drosehn goto killdone; 301e8e715faSGarance A Drosehn } 302e8e715faSGarance A Drosehn 303e8e715faSGarance A Drosehn /* If the lock file is empty, then there is no daemon to kill */ 304e8e715faSGarance A Drosehn if (getline(fp) == 0) 305e8e715faSGarance A Drosehn goto killdone; 306e8e715faSGarance A Drosehn 307e8e715faSGarance A Drosehn /* 308e8e715faSGarance A Drosehn * If the file can be locked without blocking, then there 309e8e715faSGarance A Drosehn * no daemon to kill, or we should not try to kill it. 310e8e715faSGarance A Drosehn * 311e8e715faSGarance A Drosehn * XXX - not sure I understand the reasoning behind this... 312e8e715faSGarance A Drosehn */ 313e8e715faSGarance A Drosehn lockres = flock(fileno(fp), LOCK_SH|LOCK_NB); 314e8e715faSGarance A Drosehn (void) fclose(fp); 315e8e715faSGarance A Drosehn if (lockres == 0) 316e8e715faSGarance A Drosehn goto killdone; 317e8e715faSGarance A Drosehn 318e8e715faSGarance A Drosehn pid = atoi(line); 319e8e715faSGarance A Drosehn if (pid < 0) { 320e8e715faSGarance A Drosehn /* 321e8e715faSGarance A Drosehn * If we got a negative pid, then the contents of the 322e8e715faSGarance A Drosehn * lock file is not valid. 323e8e715faSGarance A Drosehn */ 324e8e715faSGarance A Drosehn res = KQT_LFERROR; 325e8e715faSGarance A Drosehn goto killdone; 326e8e715faSGarance A Drosehn } 327e8e715faSGarance A Drosehn 328e8e715faSGarance A Drosehn seteuid(uid); 329e8e715faSGarance A Drosehn killres = kill(pid, SIGTERM); 330e8e715faSGarance A Drosehn errsav = errno; 331e8e715faSGarance A Drosehn seteuid(uid); 332e8e715faSGarance A Drosehn if (killres == 0) { 333e8e715faSGarance A Drosehn res = KQT_KILLOK; 334e8e715faSGarance A Drosehn printf("\tdaemon (pid %d) killed\n", pid); 335e8e715faSGarance A Drosehn } else if (errno == ESRCH) { 336e8e715faSGarance A Drosehn res = KQT_NODAEMON; 337e8e715faSGarance A Drosehn } else { 338e8e715faSGarance A Drosehn res = KQT_KILLFAIL; 339e8e715faSGarance A Drosehn printf("\tWarning: daemon (pid %d) not killed:\n", pid); 340e8e715faSGarance A Drosehn printf("\t %s\n", strerror(errsav)); 341e8e715faSGarance A Drosehn } 342e8e715faSGarance A Drosehn 343e8e715faSGarance A Drosehn killdone: 344e8e715faSGarance A Drosehn switch (res) { 345e8e715faSGarance A Drosehn case KQT_LFERROR: 346e8e715faSGarance A Drosehn printf("\tcannot open lock file: %s\n", 347e8e715faSGarance A Drosehn strerror(errsav)); 348e8e715faSGarance A Drosehn break; 349e8e715faSGarance A Drosehn case KQT_NODAEMON: 350e8e715faSGarance A Drosehn printf("\tno daemon to abort\n"); 351e8e715faSGarance A Drosehn break; 352e8e715faSGarance A Drosehn case KQT_KILLFAIL: 353e8e715faSGarance A Drosehn case KQT_KILLOK: 354e8e715faSGarance A Drosehn /* These two already printed messages to the user. */ 355e8e715faSGarance A Drosehn break; 356e8e715faSGarance A Drosehn default: 357e8e715faSGarance A Drosehn printf("\t<internal error in kill_qtask>\n"); 358e8e715faSGarance A Drosehn break; 359e8e715faSGarance A Drosehn } 360e8e715faSGarance A Drosehn 361e8e715faSGarance A Drosehn return (res); 362e8e715faSGarance A Drosehn } 363e8e715faSGarance A Drosehn 364e8e715faSGarance A Drosehn /* 365dea673e9SRodney W. Grimes * Write a message into the status file. 366dea673e9SRodney W. Grimes */ 367dea673e9SRodney W. Grimes static void 36854032d11SGarance A Drosehn upstat(struct printer *pp, const char *msg, int notifyuser) 369dea673e9SRodney W. Grimes { 37054032d11SGarance A Drosehn int fd; 3715f87a7b6SWarner Losh char statfile[MAXPATHLEN]; 372dea673e9SRodney W. Grimes 3734a1a0dbeSGarrett Wollman status_file_name(pp, statfile, sizeof statfile); 374dea673e9SRodney W. Grimes umask(0); 37554032d11SGarance A Drosehn seteuid(euid); 3764a1a0dbeSGarrett Wollman fd = open(statfile, O_WRONLY|O_CREAT|O_EXLOCK, STAT_FILE_MODE); 37754032d11SGarance A Drosehn seteuid(uid); 3784a1a0dbeSGarrett Wollman if (fd < 0) { 3794a1a0dbeSGarrett Wollman printf("\tcannot create status file: %s\n", strerror(errno)); 380dea673e9SRodney W. Grimes return; 381dea673e9SRodney W. Grimes } 382dea673e9SRodney W. Grimes (void) ftruncate(fd, 0); 383dea673e9SRodney W. Grimes if (msg == (char *)NULL) 384dea673e9SRodney W. Grimes (void) write(fd, "\n", 1); 385dea673e9SRodney W. Grimes else 386dea673e9SRodney W. Grimes (void) write(fd, msg, strlen(msg)); 387dea673e9SRodney W. Grimes (void) close(fd); 38854032d11SGarance A Drosehn if (notifyuser) { 38954032d11SGarance A Drosehn if ((msg == (char *)NULL) || (strcmp(msg, "\n") == 0)) 39054032d11SGarance A Drosehn printf("\tstatus message is now set to nothing.\n"); 39154032d11SGarance A Drosehn else 39254032d11SGarance A Drosehn printf("\tstatus message is now: %s", msg); 39354032d11SGarance A Drosehn } 394dea673e9SRodney W. Grimes } 395dea673e9SRodney W. Grimes 396004c9c5dSGarance A Drosehn /* 397e8e715faSGarance A Drosehn * kill an existing daemon and disable printing. 398e8e715faSGarance A Drosehn */ 399e8e715faSGarance A Drosehn void 400e8e715faSGarance A Drosehn abort_q(struct printer *pp) 401e8e715faSGarance A Drosehn { 402e8e715faSGarance A Drosehn int killres, setres; 403e8e715faSGarance A Drosehn char lf[MAXPATHLEN]; 404e8e715faSGarance A Drosehn 405e8e715faSGarance A Drosehn lock_file_name(pp, lf, sizeof lf); 406e8e715faSGarance A Drosehn printf("%s:\n", pp->printer); 407e8e715faSGarance A Drosehn 408e8e715faSGarance A Drosehn /* 409e8e715faSGarance A Drosehn * Turn on the owner execute bit of the lock file to disable printing. 410e8e715faSGarance A Drosehn */ 411e8e715faSGarance A Drosehn setres = set_qstate(SQS_STOPP, lf); 412e8e715faSGarance A Drosehn 413e8e715faSGarance A Drosehn /* 414e8e715faSGarance A Drosehn * If set_qstate found that there already was a lock file, then 415e8e715faSGarance A Drosehn * call a routine which will read that lock file and kill the 416e8e715faSGarance A Drosehn * lpd-process which is listed in that lock file. If the lock 417e8e715faSGarance A Drosehn * file did not exist, then either there is no daemon running 418e8e715faSGarance A Drosehn * for this queue, or there is one running but *it* could not 419e8e715faSGarance A Drosehn * write a lock file (which means we can not determine the 420e8e715faSGarance A Drosehn * process id of that lpd-process). 421e8e715faSGarance A Drosehn */ 422e8e715faSGarance A Drosehn switch (setres) { 423e8e715faSGarance A Drosehn case SQS_CHGOK: 424e8e715faSGarance A Drosehn case SQS_CHGFAIL: 425e8e715faSGarance A Drosehn /* Kill the process */ 426e8e715faSGarance A Drosehn killres = kill_qtask(lf); 427e8e715faSGarance A Drosehn break; 428e8e715faSGarance A Drosehn case SQS_CREOK: 429e8e715faSGarance A Drosehn case SQS_CREFAIL: 430e8e715faSGarance A Drosehn printf("\tno daemon to abort\n"); 431e8e715faSGarance A Drosehn break; 432e8e715faSGarance A Drosehn case SQS_STATFAIL: 433e8e715faSGarance A Drosehn printf("\tassuming no daemon to abort\n"); 434e8e715faSGarance A Drosehn break; 435e8e715faSGarance A Drosehn default: 436e8e715faSGarance A Drosehn printf("\t<unexpected result (%d) from set_qstate>\n", 437e8e715faSGarance A Drosehn setres); 438e8e715faSGarance A Drosehn break; 439e8e715faSGarance A Drosehn } 440e8e715faSGarance A Drosehn 44154032d11SGarance A Drosehn if (setres >= 0) 44254032d11SGarance A Drosehn upstat(pp, "printing disabled\n", 0); 443e8e715faSGarance A Drosehn } 444e8e715faSGarance A Drosehn 445e8e715faSGarance A Drosehn /* 446004c9c5dSGarance A Drosehn * "global" variables for all the routines related to 'clean' and 'tclean' 447004c9c5dSGarance A Drosehn */ 448004c9c5dSGarance A Drosehn static time_t cln_now; /* current time */ 449004c9c5dSGarance A Drosehn static double cln_minage; /* minimum age before file is removed */ 450004c9c5dSGarance A Drosehn static long cln_sizecnt; /* amount of space freed up */ 451004c9c5dSGarance A Drosehn static int cln_debug; /* print extra debugging msgs */ 452004c9c5dSGarance A Drosehn static int cln_filecnt; /* number of files destroyed */ 453004c9c5dSGarance A Drosehn static int cln_foundcore; /* found a core file! */ 454004c9c5dSGarance A Drosehn static int cln_queuecnt; /* number of queues checked */ 455004c9c5dSGarance A Drosehn static int cln_testonly; /* remove-files vs just-print-info */ 456004c9c5dSGarance A Drosehn 457dea673e9SRodney W. Grimes static int 458ba7a1ad7SGarance A Drosehn doselect(struct dirent *d) 459dea673e9SRodney W. Grimes { 460dea673e9SRodney W. Grimes int c = d->d_name[0]; 461dea673e9SRodney W. Grimes 4621fd731faSGarance A Drosehn if ((c == 'c' || c == 'd' || c == 'r' || c == 't') && 4631fd731faSGarance A Drosehn d->d_name[1] == 'f') 464004c9c5dSGarance A Drosehn return 1; 465004c9c5dSGarance A Drosehn if (c == 'c') { 466004c9c5dSGarance A Drosehn if (!strcmp(d->d_name, "core")) 467004c9c5dSGarance A Drosehn cln_foundcore = 1; 468004c9c5dSGarance A Drosehn } 469004c9c5dSGarance A Drosehn if (c == 'e') { 470004c9c5dSGarance A Drosehn if (!strncmp(d->d_name, "errs.", 5)) 471004c9c5dSGarance A Drosehn return 1; 472004c9c5dSGarance A Drosehn } 473004c9c5dSGarance A Drosehn return 0; 474dea673e9SRodney W. Grimes } 475dea673e9SRodney W. Grimes 476dea673e9SRodney W. Grimes /* 477ceeaedd3SGarance A Drosehn * Comparison routine that clean_q() uses for scandir. 478ceeaedd3SGarance A Drosehn * 479ceeaedd3SGarance A Drosehn * The purpose of this sort is to have all `df' files end up immediately 4801fd731faSGarance A Drosehn * after the matching `cf' file. For files matching `cf', `df', `rf', or 4811fd731faSGarance A Drosehn * `tf', it sorts by job number and machine, then by `cf', `df', `rf', or 4821fd731faSGarance A Drosehn * `tf', and then by the sequence letter (which is A-Z, or a-z). This 4831fd731faSGarance A Drosehn * routine may also see filenames which do not start with `cf', `df', `rf', 4841fd731faSGarance A Drosehn * or `tf' (such as `errs.*'), and those are simply sorted by the full 4851fd731faSGarance A Drosehn * filename. 4861fd731faSGarance A Drosehn * 4871fd731faSGarance A Drosehn * XXX 4881fd731faSGarance A Drosehn * This assumes that all control files start with `cfA*', and it turns 4891fd731faSGarance A Drosehn * out there are a few implementations of lpr which will create `cfB*' 4901fd731faSGarance A Drosehn * filenames (they will have datafile names which start with `dfB*'). 491dea673e9SRodney W. Grimes */ 492dea673e9SRodney W. Grimes static int 493ba7a1ad7SGarance A Drosehn sortq(const void *a, const void *b) 494dea673e9SRodney W. Grimes { 495ceeaedd3SGarance A Drosehn const int a_lt_b = -1, a_gt_b = 1, cat_other = 10; 496ceeaedd3SGarance A Drosehn const char *fname_a, *fname_b, *jnum_a, *jnum_b; 497ceeaedd3SGarance A Drosehn int cat_a, cat_b, ch, res, seq_a, seq_b; 498dea673e9SRodney W. Grimes 499f0baf665SGarance A Drosehn fname_a = (*(const struct dirent * const *)a)->d_name; 500f0baf665SGarance A Drosehn fname_b = (*(const struct dirent * const *)b)->d_name; 501ceeaedd3SGarance A Drosehn 502ceeaedd3SGarance A Drosehn /* 503ceeaedd3SGarance A Drosehn * First separate filenames into cagatories. Catagories are 5041fd731faSGarance A Drosehn * legitimate `cf', `df', `rf' & `tf' filenames, and "other" - in 5051fd731faSGarance A Drosehn * that order. It is critical that the mapping be exactly the 5061fd731faSGarance A Drosehn * same for 'a' vs 'b', so define a macro for the job. 507ceeaedd3SGarance A Drosehn * 508ceeaedd3SGarance A Drosehn * [aside: the standard `cf' file has the jobnumber start in 509ceeaedd3SGarance A Drosehn * position 4, but some implementations have that as an extra 510ceeaedd3SGarance A Drosehn * file-sequence letter, and start the job number in position 5.] 511ceeaedd3SGarance A Drosehn */ 512ceeaedd3SGarance A Drosehn #define MAP_TO_CAT(fname_X,cat_X,jnum_X,seq_X) do { \ 513ceeaedd3SGarance A Drosehn cat_X = cat_other; \ 514ceeaedd3SGarance A Drosehn ch = *(fname_X + 2); \ 515ceeaedd3SGarance A Drosehn jnum_X = fname_X + 3; \ 5164f7f8234SGarance A Drosehn seq_X = 0; \ 517ceeaedd3SGarance A Drosehn if ((*(fname_X + 1) == 'f') && (isalpha(ch))) { \ 518ceeaedd3SGarance A Drosehn seq_X = ch; \ 519ceeaedd3SGarance A Drosehn if (*fname_X == 'c') \ 520ceeaedd3SGarance A Drosehn cat_X = 1; \ 521ceeaedd3SGarance A Drosehn else if (*fname_X == 'd') \ 522ceeaedd3SGarance A Drosehn cat_X = 2; \ 5231fd731faSGarance A Drosehn else if (*fname_X == 'r') \ 524ceeaedd3SGarance A Drosehn cat_X = 3; \ 5251fd731faSGarance A Drosehn else if (*fname_X == 't') \ 5261fd731faSGarance A Drosehn cat_X = 4; \ 527ceeaedd3SGarance A Drosehn if (cat_X != cat_other) { \ 528ceeaedd3SGarance A Drosehn ch = *jnum_X; \ 529ceeaedd3SGarance A Drosehn if (!isdigit(ch)) { \ 530ceeaedd3SGarance A Drosehn if (isalpha(ch)) { \ 531ceeaedd3SGarance A Drosehn jnum_X++; \ 532ceeaedd3SGarance A Drosehn ch = *jnum_X; \ 533ceeaedd3SGarance A Drosehn seq_X = (seq_X << 8) + ch; \ 534ceeaedd3SGarance A Drosehn } \ 535ceeaedd3SGarance A Drosehn if (!isdigit(ch)) \ 536ceeaedd3SGarance A Drosehn cat_X = cat_other; \ 537ceeaedd3SGarance A Drosehn } \ 538ceeaedd3SGarance A Drosehn } \ 539ceeaedd3SGarance A Drosehn } \ 540ceeaedd3SGarance A Drosehn } while (0) 541ceeaedd3SGarance A Drosehn 542ceeaedd3SGarance A Drosehn MAP_TO_CAT(fname_a, cat_a, jnum_a, seq_a); 543ceeaedd3SGarance A Drosehn MAP_TO_CAT(fname_b, cat_b, jnum_b, seq_b); 544ceeaedd3SGarance A Drosehn 545ceeaedd3SGarance A Drosehn #undef MAP_TO_CAT 546ceeaedd3SGarance A Drosehn 547ceeaedd3SGarance A Drosehn /* First handle all cases which have "other" files */ 548ceeaedd3SGarance A Drosehn if ((cat_a >= cat_other) || (cat_b >= cat_other)) { 549ceeaedd3SGarance A Drosehn /* for two "other" files, just compare the full name */ 550ceeaedd3SGarance A Drosehn if (cat_a == cat_b) 551ceeaedd3SGarance A Drosehn res = strcmp(fname_a, fname_b); 552ceeaedd3SGarance A Drosehn else if (cat_a < cat_b) 553ceeaedd3SGarance A Drosehn res = a_lt_b; 554ceeaedd3SGarance A Drosehn else 555ceeaedd3SGarance A Drosehn res = a_gt_b; 556ceeaedd3SGarance A Drosehn goto have_res; 557ceeaedd3SGarance A Drosehn } 558ceeaedd3SGarance A Drosehn 559ceeaedd3SGarance A Drosehn /* 5601fd731faSGarance A Drosehn * At this point, we know both files are legitimate `cf', `df', `rf', 561ceeaedd3SGarance A Drosehn * or `tf' files. Compare them by job-number and machine name. 562ceeaedd3SGarance A Drosehn */ 563ceeaedd3SGarance A Drosehn res = strcmp(jnum_a, jnum_b); 564ceeaedd3SGarance A Drosehn if (res != 0) 565ceeaedd3SGarance A Drosehn goto have_res; 566ceeaedd3SGarance A Drosehn 567ceeaedd3SGarance A Drosehn /* 568ceeaedd3SGarance A Drosehn * We have two files which belong to the same job. Sort based 569ceeaedd3SGarance A Drosehn * on the catagory of file (`c' before `d', etc). 570ceeaedd3SGarance A Drosehn */ 571ceeaedd3SGarance A Drosehn if (cat_a < cat_b) { 572ceeaedd3SGarance A Drosehn res = a_lt_b; 573ceeaedd3SGarance A Drosehn goto have_res; 574ceeaedd3SGarance A Drosehn } else if (cat_a > cat_b) { 575ceeaedd3SGarance A Drosehn res = a_gt_b; 576ceeaedd3SGarance A Drosehn goto have_res; 577ceeaedd3SGarance A Drosehn } 578ceeaedd3SGarance A Drosehn 579ceeaedd3SGarance A Drosehn /* 580ceeaedd3SGarance A Drosehn * Two files in the same catagory for a single job. Sort based 581ceeaedd3SGarance A Drosehn * on the sequence letter(s). (usually `A' thru `Z', etc). 582ceeaedd3SGarance A Drosehn */ 583ceeaedd3SGarance A Drosehn if (seq_a < seq_b) { 584ceeaedd3SGarance A Drosehn res = a_lt_b; 585ceeaedd3SGarance A Drosehn goto have_res; 586ceeaedd3SGarance A Drosehn } else if (seq_a > seq_b) { 587ceeaedd3SGarance A Drosehn res = a_gt_b; 588ceeaedd3SGarance A Drosehn goto have_res; 589ceeaedd3SGarance A Drosehn } 590ceeaedd3SGarance A Drosehn 591ceeaedd3SGarance A Drosehn /* 592ceeaedd3SGarance A Drosehn * Given that the filenames in a directory are unique, this SHOULD 593ceeaedd3SGarance A Drosehn * never happen (unless there are logic errors in this routine). 594ceeaedd3SGarance A Drosehn * But if it does happen, we must return "is equal" or the caller 595ceeaedd3SGarance A Drosehn * might see inconsistent results in the sorting order, and that 596ceeaedd3SGarance A Drosehn * can trigger other problems. 597ceeaedd3SGarance A Drosehn */ 598ceeaedd3SGarance A Drosehn printf("\t*** Error in sortq: %s == %s !\n", fname_a, fname_b); 599ceeaedd3SGarance A Drosehn printf("\t*** cat %d == %d ; seq = %d %d\n", cat_a, cat_b, 600ceeaedd3SGarance A Drosehn seq_a, seq_b); 601ceeaedd3SGarance A Drosehn res = 0; 602ceeaedd3SGarance A Drosehn 603ceeaedd3SGarance A Drosehn have_res: 604ceeaedd3SGarance A Drosehn return res; 605dea673e9SRodney W. Grimes } 606dea673e9SRodney W. Grimes 607dea673e9SRodney W. Grimes /* 6084a1a0dbeSGarrett Wollman * Remove all spool files and temporaries from the spooling area. 6094a1a0dbeSGarrett Wollman * Or, perhaps: 610dea673e9SRodney W. Grimes * Remove incomplete jobs from spooling area. 611dea673e9SRodney W. Grimes */ 612dea673e9SRodney W. Grimes 613004c9c5dSGarance A Drosehn void 614c9cb13a0SGarance A Drosehn clean_gi(int argc, char *argv[]) 615004c9c5dSGarance A Drosehn { 616004c9c5dSGarance A Drosehn 617004c9c5dSGarance A Drosehn /* init some fields before 'clean' is called for each queue */ 618004c9c5dSGarance A Drosehn cln_queuecnt = 0; 619004c9c5dSGarance A Drosehn cln_now = time(NULL); 620004c9c5dSGarance A Drosehn cln_minage = 3600.0; /* only delete files >1h old */ 621004c9c5dSGarance A Drosehn cln_filecnt = 0; 622004c9c5dSGarance A Drosehn cln_sizecnt = 0; 623004c9c5dSGarance A Drosehn cln_debug = 0; 624004c9c5dSGarance A Drosehn cln_testonly = 0; 625004c9c5dSGarance A Drosehn generic_wrapup = &wrapup_clean; 626004c9c5dSGarance A Drosehn 627004c9c5dSGarance A Drosehn /* see if there are any options specified before the ptr list */ 628e7f478b2SGarance A Drosehn for (; argc > 0; argc--, argv++) { 629004c9c5dSGarance A Drosehn if (**argv != '-') 630004c9c5dSGarance A Drosehn break; 631004c9c5dSGarance A Drosehn if (strcmp(*argv, "-d") == 0) { 632004c9c5dSGarance A Drosehn /* just an example of an option... */ 633ceeaedd3SGarance A Drosehn cln_debug++; 634004c9c5dSGarance A Drosehn *argv = generic_nullarg; /* "erase" it */ 635004c9c5dSGarance A Drosehn } else { 636004c9c5dSGarance A Drosehn printf("Invalid option '%s'\n", *argv); 637004c9c5dSGarance A Drosehn generic_initerr = 1; 638004c9c5dSGarance A Drosehn } 639004c9c5dSGarance A Drosehn } 640004c9c5dSGarance A Drosehn 641004c9c5dSGarance A Drosehn return; 642004c9c5dSGarance A Drosehn } 643004c9c5dSGarance A Drosehn 644004c9c5dSGarance A Drosehn void 645c9cb13a0SGarance A Drosehn tclean_gi(int argc, char *argv[]) 646004c9c5dSGarance A Drosehn { 647004c9c5dSGarance A Drosehn 648004c9c5dSGarance A Drosehn /* only difference between 'clean' and 'tclean' is one value */ 649004c9c5dSGarance A Drosehn /* (...and the fact that 'clean' is priv and 'tclean' is not) */ 650c9cb13a0SGarance A Drosehn clean_gi(argc, argv); 651004c9c5dSGarance A Drosehn cln_testonly = 1; 652004c9c5dSGarance A Drosehn 653004c9c5dSGarance A Drosehn return; 654004c9c5dSGarance A Drosehn } 655004c9c5dSGarance A Drosehn 656004c9c5dSGarance A Drosehn void 657004c9c5dSGarance A Drosehn clean_q(struct printer *pp) 658004c9c5dSGarance A Drosehn { 659004c9c5dSGarance A Drosehn char *cp, *cp1, *lp; 660004c9c5dSGarance A Drosehn struct dirent **queue; 661004c9c5dSGarance A Drosehn size_t linerem; 662004c9c5dSGarance A Drosehn int didhead, i, n, nitems, rmcp; 663004c9c5dSGarance A Drosehn 664004c9c5dSGarance A Drosehn cln_queuecnt++; 665004c9c5dSGarance A Drosehn 666004c9c5dSGarance A Drosehn didhead = 0; 667004c9c5dSGarance A Drosehn if (generic_qselect == QSEL_BYNAME) { 6684a1a0dbeSGarrett Wollman printf("%s:\n", pp->printer); 669004c9c5dSGarance A Drosehn didhead = 1; 670004c9c5dSGarance A Drosehn } 671dea673e9SRodney W. Grimes 6724a1a0dbeSGarrett Wollman lp = line; 6734a1a0dbeSGarrett Wollman cp = pp->spool_dir; 6744a1a0dbeSGarrett Wollman while (lp < &line[sizeof(line) - 1]) { 6754a1a0dbeSGarrett Wollman if ((*lp++ = *cp++) == 0) 6764a1a0dbeSGarrett Wollman break; 6774a1a0dbeSGarrett Wollman } 678dea673e9SRodney W. Grimes lp[-1] = '/'; 679004c9c5dSGarance A Drosehn linerem = sizeof(line) - (lp - line); 680dea673e9SRodney W. Grimes 681004c9c5dSGarance A Drosehn cln_foundcore = 0; 682360d4ad5SWarner Losh seteuid(euid); 6834a1a0dbeSGarrett Wollman nitems = scandir(pp->spool_dir, &queue, doselect, sortq); 684360d4ad5SWarner Losh seteuid(uid); 685dea673e9SRodney W. Grimes if (nitems < 0) { 686004c9c5dSGarance A Drosehn if (!didhead) { 687004c9c5dSGarance A Drosehn printf("%s:\n", pp->printer); 688004c9c5dSGarance A Drosehn didhead = 1; 689004c9c5dSGarance A Drosehn } 690dea673e9SRodney W. Grimes printf("\tcannot examine spool directory\n"); 691dea673e9SRodney W. Grimes return; 692dea673e9SRodney W. Grimes } 693004c9c5dSGarance A Drosehn if (cln_foundcore) { 694004c9c5dSGarance A Drosehn if (!didhead) { 695004c9c5dSGarance A Drosehn printf("%s:\n", pp->printer); 696004c9c5dSGarance A Drosehn didhead = 1; 697004c9c5dSGarance A Drosehn } 698004c9c5dSGarance A Drosehn printf("\t** found a core file in %s !\n", pp->spool_dir); 699004c9c5dSGarance A Drosehn } 700dea673e9SRodney W. Grimes if (nitems == 0) 701dea673e9SRodney W. Grimes return; 702004c9c5dSGarance A Drosehn if (!didhead) 703004c9c5dSGarance A Drosehn printf("%s:\n", pp->printer); 704ceeaedd3SGarance A Drosehn if (cln_debug) { 705ceeaedd3SGarance A Drosehn printf("\t** ----- Sorted list of files being checked:\n"); 706ceeaedd3SGarance A Drosehn i = 0; 707ceeaedd3SGarance A Drosehn do { 708ceeaedd3SGarance A Drosehn cp = queue[i]->d_name; 709ceeaedd3SGarance A Drosehn printf("\t** [%3d] = %s\n", i, cp); 710ceeaedd3SGarance A Drosehn } while (++i < nitems); 711ceeaedd3SGarance A Drosehn printf("\t** ----- end of sorted list\n"); 712ceeaedd3SGarance A Drosehn } 713dea673e9SRodney W. Grimes i = 0; 714dea673e9SRodney W. Grimes do { 715dea673e9SRodney W. Grimes cp = queue[i]->d_name; 716004c9c5dSGarance A Drosehn rmcp = 0; 717dea673e9SRodney W. Grimes if (*cp == 'c') { 718004c9c5dSGarance A Drosehn /* 719004c9c5dSGarance A Drosehn * A control file. Look for matching data-files. 720004c9c5dSGarance A Drosehn */ 721004c9c5dSGarance A Drosehn /* XXX 722004c9c5dSGarance A Drosehn * Note the logic here assumes that the hostname 723004c9c5dSGarance A Drosehn * part of cf-filenames match the hostname part 724004c9c5dSGarance A Drosehn * in df-filenames, and that is not necessarily 725004c9c5dSGarance A Drosehn * true (eg: for multi-homed hosts). This needs 726004c9c5dSGarance A Drosehn * some further thought... 727004c9c5dSGarance A Drosehn */ 728dea673e9SRodney W. Grimes n = 0; 729dea673e9SRodney W. Grimes while (i + 1 < nitems) { 730dea673e9SRodney W. Grimes cp1 = queue[i + 1]->d_name; 731dea673e9SRodney W. Grimes if (*cp1 != 'd' || strcmp(cp + 3, cp1 + 3)) 732dea673e9SRodney W. Grimes break; 733dea673e9SRodney W. Grimes i++; 734dea673e9SRodney W. Grimes n++; 735dea673e9SRodney W. Grimes } 736dea673e9SRodney W. Grimes if (n == 0) { 737004c9c5dSGarance A Drosehn rmcp = 1; 738dea673e9SRodney W. Grimes } 739004c9c5dSGarance A Drosehn } else if (*cp == 'e') { 740004c9c5dSGarance A Drosehn /* 741004c9c5dSGarance A Drosehn * Must be an errrs or email temp file. 742004c9c5dSGarance A Drosehn */ 743004c9c5dSGarance A Drosehn rmcp = 1; 744dea673e9SRodney W. Grimes } else { 745dea673e9SRodney W. Grimes /* 746dea673e9SRodney W. Grimes * Must be a df with no cf (otherwise, it would have 7471fd731faSGarance A Drosehn * been skipped above) or an rf or tf file (which can 7481fd731faSGarance A Drosehn * always be removed if it is old enough). 749dea673e9SRodney W. Grimes */ 750004c9c5dSGarance A Drosehn rmcp = 1; 751004c9c5dSGarance A Drosehn } 752004c9c5dSGarance A Drosehn if (rmcp) { 753004c9c5dSGarance A Drosehn if (strlen(cp) >= linerem) { 754004c9c5dSGarance A Drosehn printf("\t** internal error: 'line' overflow!\n"); 755004c9c5dSGarance A Drosehn printf("\t** spooldir = %s\n", pp->spool_dir); 756004c9c5dSGarance A Drosehn printf("\t** cp = %s\n", cp); 757004c9c5dSGarance A Drosehn return; 758004c9c5dSGarance A Drosehn } 759004c9c5dSGarance A Drosehn strlcpy(lp, cp, linerem); 760dea673e9SRodney W. Grimes unlinkf(line); 761dea673e9SRodney W. Grimes } 762dea673e9SRodney W. Grimes } while (++i < nitems); 763dea673e9SRodney W. Grimes } 764dea673e9SRodney W. Grimes 765dea673e9SRodney W. Grimes static void 766004c9c5dSGarance A Drosehn wrapup_clean(int laststatus __unused) 767004c9c5dSGarance A Drosehn { 768004c9c5dSGarance A Drosehn 769004c9c5dSGarance A Drosehn printf("Checked %d queues, and ", cln_queuecnt); 770004c9c5dSGarance A Drosehn if (cln_filecnt < 1) { 771004c9c5dSGarance A Drosehn printf("no cruft was found\n"); 772004c9c5dSGarance A Drosehn return; 773004c9c5dSGarance A Drosehn } 774004c9c5dSGarance A Drosehn if (cln_testonly) { 775004c9c5dSGarance A Drosehn printf("would have "); 776004c9c5dSGarance A Drosehn } 777004c9c5dSGarance A Drosehn printf("removed %d files (%ld bytes).\n", cln_filecnt, cln_sizecnt); 778004c9c5dSGarance A Drosehn } 779004c9c5dSGarance A Drosehn 780004c9c5dSGarance A Drosehn static void 781ba7a1ad7SGarance A Drosehn unlinkf(char *name) 782dea673e9SRodney W. Grimes { 783004c9c5dSGarance A Drosehn struct stat stbuf; 784004c9c5dSGarance A Drosehn double agemod, agestat; 785004c9c5dSGarance A Drosehn int res; 786004c9c5dSGarance A Drosehn char linkbuf[BUFSIZ]; 787004c9c5dSGarance A Drosehn 788004c9c5dSGarance A Drosehn /* 789004c9c5dSGarance A Drosehn * We have to use lstat() instead of stat(), in case this is a df* 790004c9c5dSGarance A Drosehn * "file" which is really a symlink due to 'lpr -s' processing. In 791004c9c5dSGarance A Drosehn * that case, we need to check the last-mod time of the symlink, and 792004c9c5dSGarance A Drosehn * not the file that the symlink is pointed at. 793004c9c5dSGarance A Drosehn */ 794360d4ad5SWarner Losh seteuid(euid); 795004c9c5dSGarance A Drosehn res = lstat(name, &stbuf); 796004c9c5dSGarance A Drosehn seteuid(uid); 797004c9c5dSGarance A Drosehn if (res < 0) { 798004c9c5dSGarance A Drosehn printf("\terror return from stat(%s):\n", name); 799004c9c5dSGarance A Drosehn printf("\t %s\n", strerror(errno)); 800004c9c5dSGarance A Drosehn return; 801004c9c5dSGarance A Drosehn } 802004c9c5dSGarance A Drosehn 803004c9c5dSGarance A Drosehn agemod = difftime(cln_now, stbuf.st_mtime); 804004c9c5dSGarance A Drosehn agestat = difftime(cln_now, stbuf.st_ctime); 805ceeaedd3SGarance A Drosehn if (cln_debug > 1) { 806004c9c5dSGarance A Drosehn /* this debugging-aid probably is not needed any more... */ 807004c9c5dSGarance A Drosehn printf("\t\t modify age=%g secs, stat age=%g secs\n", 808004c9c5dSGarance A Drosehn agemod, agestat); 809004c9c5dSGarance A Drosehn } 810004c9c5dSGarance A Drosehn if ((agemod <= cln_minage) && (agestat <= cln_minage)) 811004c9c5dSGarance A Drosehn return; 812004c9c5dSGarance A Drosehn 813004c9c5dSGarance A Drosehn /* 814004c9c5dSGarance A Drosehn * if this file is a symlink, then find out the target of the 815004c9c5dSGarance A Drosehn * symlink before unlink-ing the file itself 816004c9c5dSGarance A Drosehn */ 817004c9c5dSGarance A Drosehn if (S_ISLNK(stbuf.st_mode)) { 818004c9c5dSGarance A Drosehn seteuid(euid); 819004c9c5dSGarance A Drosehn res = readlink(name, linkbuf, sizeof(linkbuf)); 820004c9c5dSGarance A Drosehn seteuid(uid); 821004c9c5dSGarance A Drosehn if (res < 0) { 822004c9c5dSGarance A Drosehn printf("\terror return from readlink(%s):\n", name); 823004c9c5dSGarance A Drosehn printf("\t %s\n", strerror(errno)); 824004c9c5dSGarance A Drosehn return; 825004c9c5dSGarance A Drosehn } 826004c9c5dSGarance A Drosehn if (res == sizeof(linkbuf)) 827004c9c5dSGarance A Drosehn res--; 828004c9c5dSGarance A Drosehn linkbuf[res] = '\0'; 829004c9c5dSGarance A Drosehn } 830004c9c5dSGarance A Drosehn 831004c9c5dSGarance A Drosehn cln_filecnt++; 832004c9c5dSGarance A Drosehn cln_sizecnt += stbuf.st_size; 833004c9c5dSGarance A Drosehn 834004c9c5dSGarance A Drosehn if (cln_testonly) { 835004c9c5dSGarance A Drosehn printf("\twould remove %s\n", name); 836004c9c5dSGarance A Drosehn if (S_ISLNK(stbuf.st_mode)) { 837004c9c5dSGarance A Drosehn printf("\t (which is a symlink to %s)\n", linkbuf); 838004c9c5dSGarance A Drosehn } 839004c9c5dSGarance A Drosehn } else { 840004c9c5dSGarance A Drosehn seteuid(euid); 841004c9c5dSGarance A Drosehn res = unlink(name); 842004c9c5dSGarance A Drosehn seteuid(uid); 843004c9c5dSGarance A Drosehn if (res < 0) 844004c9c5dSGarance A Drosehn printf("\tcannot remove %s (!)\n", name); 845dea673e9SRodney W. Grimes else 846dea673e9SRodney W. Grimes printf("\tremoved %s\n", name); 847004c9c5dSGarance A Drosehn /* XXX 848004c9c5dSGarance A Drosehn * Note that for a df* file, this code should also check to see 849004c9c5dSGarance A Drosehn * if it is a symlink to some other file, and if the original 850004c9c5dSGarance A Drosehn * lpr command included '-r' ("remove file"). Of course, this 851004c9c5dSGarance A Drosehn * code would not be removing the df* file unless there was no 852004c9c5dSGarance A Drosehn * matching cf* file, and without the cf* file it is currently 853004c9c5dSGarance A Drosehn * impossible to determine if '-r' had been specified... 854004c9c5dSGarance A Drosehn * 855004c9c5dSGarance A Drosehn * As a result of this quandry, we may be leaving behind a 856004c9c5dSGarance A Drosehn * user's file that was supposed to have been removed after 857004c9c5dSGarance A Drosehn * being printed. This may effect services such as CAP or 858004c9c5dSGarance A Drosehn * samba, if they were configured to use 'lpr -r', and if 859004c9c5dSGarance A Drosehn * datafiles are not being properly removed. 860004c9c5dSGarance A Drosehn */ 861004c9c5dSGarance A Drosehn if (S_ISLNK(stbuf.st_mode)) { 862004c9c5dSGarance A Drosehn printf("\t (which was a symlink to %s)\n", linkbuf); 863004c9c5dSGarance A Drosehn } 864004c9c5dSGarance A Drosehn } 865dea673e9SRodney W. Grimes } 866dea673e9SRodney W. Grimes 867dea673e9SRodney W. Grimes /* 868e8e715faSGarance A Drosehn * Enable queuing to the printer (allow lpr to add new jobs to the queue). 869e8e715faSGarance A Drosehn */ 870e8e715faSGarance A Drosehn void 871e8e715faSGarance A Drosehn enable_q(struct printer *pp) 872e8e715faSGarance A Drosehn { 873e8e715faSGarance A Drosehn int setres; 874e8e715faSGarance A Drosehn char lf[MAXPATHLEN]; 875e8e715faSGarance A Drosehn 876e8e715faSGarance A Drosehn lock_file_name(pp, lf, sizeof lf); 877e8e715faSGarance A Drosehn printf("%s:\n", pp->printer); 878e8e715faSGarance A Drosehn 879e8e715faSGarance A Drosehn setres = set_qstate(SQS_ENABLEQ, lf); 880e8e715faSGarance A Drosehn } 881e8e715faSGarance A Drosehn 882e8e715faSGarance A Drosehn /* 883dea673e9SRodney W. Grimes * Disable queuing. 884dea673e9SRodney W. Grimes */ 885dea673e9SRodney W. Grimes void 886e8e715faSGarance A Drosehn disable_q(struct printer *pp) 887e8e715faSGarance A Drosehn { 888e8e715faSGarance A Drosehn int setres; 889e8e715faSGarance A Drosehn char lf[MAXPATHLEN]; 890e8e715faSGarance A Drosehn 891e8e715faSGarance A Drosehn lock_file_name(pp, lf, sizeof lf); 892e8e715faSGarance A Drosehn printf("%s:\n", pp->printer); 893e8e715faSGarance A Drosehn 894e8e715faSGarance A Drosehn setres = set_qstate(SQS_DISABLEQ, lf); 895e8e715faSGarance A Drosehn } 896e8e715faSGarance A Drosehn 897e8e715faSGarance A Drosehn /* 898dea673e9SRodney W. Grimes * Disable queuing and printing and put a message into the status file 8995b1c34fbSGarance A Drosehn * (reason for being down). If the user specified `-msg', then use 9005b1c34fbSGarance A Drosehn * everything after that as the message for the status file. If the 9015b1c34fbSGarance A Drosehn * user did NOT specify `-msg', then the command should take the first 9025b1c34fbSGarance A Drosehn * parameter as the printer name, and all remaining parameters as the 9035b1c34fbSGarance A Drosehn * message for the status file. (This is to be compatible with the 9045b1c34fbSGarance A Drosehn * original definition of 'down', which was implemented long before 9055b1c34fbSGarance A Drosehn * `-msg' was around). 9065b1c34fbSGarance A Drosehn */ 9075b1c34fbSGarance A Drosehn void 9085b1c34fbSGarance A Drosehn down_gi(int argc, char *argv[]) 9095b1c34fbSGarance A Drosehn { 9105b1c34fbSGarance A Drosehn 9115b1c34fbSGarance A Drosehn /* If `-msg' was specified, then this routine has nothing to do. */ 9125b1c34fbSGarance A Drosehn if (generic_msg != NULL) 9135b1c34fbSGarance A Drosehn return; 9145b1c34fbSGarance A Drosehn 9155b1c34fbSGarance A Drosehn /* 9165b1c34fbSGarance A Drosehn * If the user only gave one parameter, then use a default msg. 9175b1c34fbSGarance A Drosehn * (if argc == 1 at this point, then *argv == name of printer). 9185b1c34fbSGarance A Drosehn */ 9195b1c34fbSGarance A Drosehn if (argc == 1) { 9205b1c34fbSGarance A Drosehn generic_msg = strdup("printing disabled\n"); 9215b1c34fbSGarance A Drosehn return; 9225b1c34fbSGarance A Drosehn } 9235b1c34fbSGarance A Drosehn 9245b1c34fbSGarance A Drosehn /* 9255b1c34fbSGarance A Drosehn * The user specified multiple parameters, and did not specify 9265b1c34fbSGarance A Drosehn * `-msg'. Build a message from all the parameters after the 9275b1c34fbSGarance A Drosehn * first one (and nullify those parameters so generic-processing 9285b1c34fbSGarance A Drosehn * will not process them as printer-queue names). 9295b1c34fbSGarance A Drosehn */ 9305b1c34fbSGarance A Drosehn argc--; 9315b1c34fbSGarance A Drosehn argv++; 9325b1c34fbSGarance A Drosehn generic_msg = args2line(argc, argv); 9335b1c34fbSGarance A Drosehn for (; argc > 0; argc--, argv++) 9345b1c34fbSGarance A Drosehn *argv = generic_nullarg; /* "erase" it */ 9355b1c34fbSGarance A Drosehn } 9365b1c34fbSGarance A Drosehn 9375b1c34fbSGarance A Drosehn void 9385b1c34fbSGarance A Drosehn down_q(struct printer *pp) 9395b1c34fbSGarance A Drosehn { 9405b1c34fbSGarance A Drosehn int setres; 9415b1c34fbSGarance A Drosehn char lf[MAXPATHLEN]; 9425b1c34fbSGarance A Drosehn 9435b1c34fbSGarance A Drosehn lock_file_name(pp, lf, sizeof lf); 9445b1c34fbSGarance A Drosehn printf("%s:\n", pp->printer); 9455b1c34fbSGarance A Drosehn 9465b1c34fbSGarance A Drosehn setres = set_qstate(SQS_DISABLEQ+SQS_STOPP, lf); 9475b1c34fbSGarance A Drosehn if (setres >= 0) 9485b1c34fbSGarance A Drosehn upstat(pp, generic_msg, 1); 9495b1c34fbSGarance A Drosehn } 9505b1c34fbSGarance A Drosehn 9515b1c34fbSGarance A Drosehn /* 952dea673e9SRodney W. Grimes * Exit lpc 953dea673e9SRodney W. Grimes */ 954dea673e9SRodney W. Grimes void 955ba7a1ad7SGarance A Drosehn quit(int argc __unused, char *argv[] __unused) 956dea673e9SRodney W. Grimes { 957dea673e9SRodney W. Grimes exit(0); 958dea673e9SRodney W. Grimes } 959dea673e9SRodney W. Grimes 960dea673e9SRodney W. Grimes /* 961dea673e9SRodney W. Grimes * Kill and restart the daemon. 962dea673e9SRodney W. Grimes */ 963dea673e9SRodney W. Grimes void 964e8e715faSGarance A Drosehn restart_q(struct printer *pp) 965e8e715faSGarance A Drosehn { 966e8e715faSGarance A Drosehn int killres, setres, startok; 967e8e715faSGarance A Drosehn char lf[MAXPATHLEN]; 968e8e715faSGarance A Drosehn 969e8e715faSGarance A Drosehn lock_file_name(pp, lf, sizeof lf); 970e8e715faSGarance A Drosehn printf("%s:\n", pp->printer); 971e8e715faSGarance A Drosehn 972e8e715faSGarance A Drosehn killres = kill_qtask(lf); 973e8e715faSGarance A Drosehn 974e8e715faSGarance A Drosehn /* 975e8e715faSGarance A Drosehn * XXX - if the kill worked, we should probably sleep for 976e8e715faSGarance A Drosehn * a second or so before trying to restart the queue. 977e8e715faSGarance A Drosehn */ 978e8e715faSGarance A Drosehn 979e8e715faSGarance A Drosehn /* make sure the queue is set to print jobs */ 980e8e715faSGarance A Drosehn setres = set_qstate(SQS_STARTP, lf); 981e8e715faSGarance A Drosehn 982e8e715faSGarance A Drosehn seteuid(euid); 983e8e715faSGarance A Drosehn startok = startdaemon(pp); 984e8e715faSGarance A Drosehn seteuid(uid); 985e8e715faSGarance A Drosehn if (!startok) 986e8e715faSGarance A Drosehn printf("\tcouldn't restart daemon\n"); 987e8e715faSGarance A Drosehn else 988e8e715faSGarance A Drosehn printf("\tdaemon restarted\n"); 989e8e715faSGarance A Drosehn } 990e8e715faSGarance A Drosehn 991e8e715faSGarance A Drosehn /* 99254032d11SGarance A Drosehn * Set the status message of each queue listed. Requires a "-msg" 99354032d11SGarance A Drosehn * parameter to indicate the end of the queue list and start of msg text. 99454032d11SGarance A Drosehn */ 99554032d11SGarance A Drosehn void 99654032d11SGarance A Drosehn setstatus_gi(int argc __unused, char *argv[] __unused) 99754032d11SGarance A Drosehn { 99854032d11SGarance A Drosehn 99954032d11SGarance A Drosehn if (generic_msg == NULL) { 100054032d11SGarance A Drosehn printf("You must specify '-msg' before the text of the new status message.\n"); 100154032d11SGarance A Drosehn generic_initerr = 1; 100254032d11SGarance A Drosehn } 100354032d11SGarance A Drosehn } 100454032d11SGarance A Drosehn 100554032d11SGarance A Drosehn void 100654032d11SGarance A Drosehn setstatus_q(struct printer *pp) 100754032d11SGarance A Drosehn { 100854032d11SGarance A Drosehn char lf[MAXPATHLEN]; 100954032d11SGarance A Drosehn 101054032d11SGarance A Drosehn lock_file_name(pp, lf, sizeof lf); 101154032d11SGarance A Drosehn printf("%s:\n", pp->printer); 101254032d11SGarance A Drosehn 101354032d11SGarance A Drosehn upstat(pp, generic_msg, 1); 101454032d11SGarance A Drosehn } 101554032d11SGarance A Drosehn 101654032d11SGarance A Drosehn /* 1017dea673e9SRodney W. Grimes * Enable printing on the specified printer and startup the daemon. 1018dea673e9SRodney W. Grimes */ 1019dea673e9SRodney W. Grimes void 1020e8e715faSGarance A Drosehn start_q(struct printer *pp) 1021e8e715faSGarance A Drosehn { 1022e8e715faSGarance A Drosehn int setres, startok; 1023e8e715faSGarance A Drosehn char lf[MAXPATHLEN]; 1024e8e715faSGarance A Drosehn 1025e8e715faSGarance A Drosehn lock_file_name(pp, lf, sizeof lf); 1026e8e715faSGarance A Drosehn printf("%s:\n", pp->printer); 1027e8e715faSGarance A Drosehn 1028e8e715faSGarance A Drosehn setres = set_qstate(SQS_STARTP, lf); 1029e8e715faSGarance A Drosehn 1030e8e715faSGarance A Drosehn seteuid(euid); 1031e8e715faSGarance A Drosehn startok = startdaemon(pp); 1032e8e715faSGarance A Drosehn seteuid(uid); 1033e8e715faSGarance A Drosehn if (!startok) 1034e8e715faSGarance A Drosehn printf("\tcouldn't start daemon\n"); 1035e8e715faSGarance A Drosehn else 1036e8e715faSGarance A Drosehn printf("\tdaemon started\n"); 1037e8e715faSGarance A Drosehn seteuid(uid); 1038e8e715faSGarance A Drosehn } 1039e8e715faSGarance A Drosehn 1040e8e715faSGarance A Drosehn /* 1041dea673e9SRodney W. Grimes * Print the status of the printer queue. 1042dea673e9SRodney W. Grimes */ 10434a1a0dbeSGarrett Wollman void 1044ba7a1ad7SGarance A Drosehn status(struct printer *pp) 1045dea673e9SRodney W. Grimes { 1046dea673e9SRodney W. Grimes struct stat stbuf; 1047dea673e9SRodney W. Grimes register int fd, i; 1048dea673e9SRodney W. Grimes register struct dirent *dp; 1049dea673e9SRodney W. Grimes DIR *dirp; 10504a1a0dbeSGarrett Wollman char file[MAXPATHLEN]; 1051dea673e9SRodney W. Grimes 10524a1a0dbeSGarrett Wollman printf("%s:\n", pp->printer); 10534a1a0dbeSGarrett Wollman lock_file_name(pp, file, sizeof file); 10544a1a0dbeSGarrett Wollman if (stat(file, &stbuf) >= 0) { 1055dea673e9SRodney W. Grimes printf("\tqueuing is %s\n", 10564a1a0dbeSGarrett Wollman ((stbuf.st_mode & LFM_QUEUE_DIS) ? "disabled" 10574a1a0dbeSGarrett Wollman : "enabled")); 1058dea673e9SRodney W. Grimes printf("\tprinting is %s\n", 10594a1a0dbeSGarrett Wollman ((stbuf.st_mode & LFM_PRINT_DIS) ? "disabled" 10604a1a0dbeSGarrett Wollman : "enabled")); 1061dea673e9SRodney W. Grimes } else { 1062dea673e9SRodney W. Grimes printf("\tqueuing is enabled\n"); 1063dea673e9SRodney W. Grimes printf("\tprinting is enabled\n"); 1064dea673e9SRodney W. Grimes } 10654a1a0dbeSGarrett Wollman if ((dirp = opendir(pp->spool_dir)) == NULL) { 1066dea673e9SRodney W. Grimes printf("\tcannot examine spool directory\n"); 1067dea673e9SRodney W. Grimes return; 1068dea673e9SRodney W. Grimes } 1069dea673e9SRodney W. Grimes i = 0; 1070dea673e9SRodney W. Grimes while ((dp = readdir(dirp)) != NULL) { 1071dea673e9SRodney W. Grimes if (*dp->d_name == 'c' && dp->d_name[1] == 'f') 1072dea673e9SRodney W. Grimes i++; 1073dea673e9SRodney W. Grimes } 1074dea673e9SRodney W. Grimes closedir(dirp); 1075dea673e9SRodney W. Grimes if (i == 0) 10764a1a0dbeSGarrett Wollman printf("\tno entries in spool area\n"); 1077dea673e9SRodney W. Grimes else if (i == 1) 1078dea673e9SRodney W. Grimes printf("\t1 entry in spool area\n"); 1079dea673e9SRodney W. Grimes else 1080dea673e9SRodney W. Grimes printf("\t%d entries in spool area\n", i); 10814a1a0dbeSGarrett Wollman fd = open(file, O_RDONLY); 1082dea673e9SRodney W. Grimes if (fd < 0 || flock(fd, LOCK_SH|LOCK_NB) == 0) { 1083dea673e9SRodney W. Grimes (void) close(fd); /* unlocks as well */ 1084bc407914SWarner Losh printf("\tprinter idle\n"); 1085dea673e9SRodney W. Grimes return; 1086dea673e9SRodney W. Grimes } 1087dea673e9SRodney W. Grimes (void) close(fd); 108836abea5dSBrian Somers /* print out the contents of the status file, if it exists */ 10894a1a0dbeSGarrett Wollman status_file_name(pp, file, sizeof file); 10904a1a0dbeSGarrett Wollman fd = open(file, O_RDONLY|O_SHLOCK); 1091dea673e9SRodney W. Grimes if (fd >= 0) { 109236abea5dSBrian Somers (void) fstat(fd, &stbuf); 109336abea5dSBrian Somers if (stbuf.st_size > 0) { 109436abea5dSBrian Somers putchar('\t'); 1095dea673e9SRodney W. Grimes while ((i = read(fd, line, sizeof(line))) > 0) 1096dea673e9SRodney W. Grimes (void) fwrite(line, 1, i, stdout); 109736abea5dSBrian Somers } 1098dea673e9SRodney W. Grimes (void) close(fd); /* unlocks as well */ 1099dea673e9SRodney W. Grimes } 1100dea673e9SRodney W. Grimes } 1101dea673e9SRodney W. Grimes 1102dea673e9SRodney W. Grimes /* 1103dea673e9SRodney W. Grimes * Stop the specified daemon after completing the current job and disable 1104dea673e9SRodney W. Grimes * printing. 1105dea673e9SRodney W. Grimes */ 1106dea673e9SRodney W. Grimes void 1107e8e715faSGarance A Drosehn stop_q(struct printer *pp) 1108e8e715faSGarance A Drosehn { 1109e8e715faSGarance A Drosehn int setres; 1110e8e715faSGarance A Drosehn char lf[MAXPATHLEN]; 1111e8e715faSGarance A Drosehn 1112e8e715faSGarance A Drosehn lock_file_name(pp, lf, sizeof lf); 1113e8e715faSGarance A Drosehn printf("%s:\n", pp->printer); 1114e8e715faSGarance A Drosehn 1115e8e715faSGarance A Drosehn setres = set_qstate(SQS_STOPP, lf); 1116e8e715faSGarance A Drosehn 111754032d11SGarance A Drosehn if (setres >= 0) 111854032d11SGarance A Drosehn upstat(pp, "printing disabled\n", 0); 1119e8e715faSGarance A Drosehn } 1120e8e715faSGarance A Drosehn 112130b4b758SGarance A Drosehn struct jobqueue **queue; 1122dea673e9SRodney W. Grimes int nitems; 1123dea673e9SRodney W. Grimes time_t mtime; 1124dea673e9SRodney W. Grimes 1125dea673e9SRodney W. Grimes /* 1126dea673e9SRodney W. Grimes * Put the specified jobs at the top of printer queue. 1127dea673e9SRodney W. Grimes */ 1128dea673e9SRodney W. Grimes void 1129ba7a1ad7SGarance A Drosehn topq(int argc, char *argv[]) 1130dea673e9SRodney W. Grimes { 1131dea673e9SRodney W. Grimes register int i; 1132dea673e9SRodney W. Grimes struct stat stbuf; 1133ba7a1ad7SGarance A Drosehn int cmdstatus, changed; 11344a1a0dbeSGarrett Wollman struct printer myprinter, *pp = &myprinter; 1135dea673e9SRodney W. Grimes 1136dea673e9SRodney W. Grimes if (argc < 3) { 1137d3974088SDag-Erling Smørgrav printf("usage: topq printer [jobnum ...] [user ...]\n"); 1138dea673e9SRodney W. Grimes return; 1139dea673e9SRodney W. Grimes } 1140dea673e9SRodney W. Grimes 1141dea673e9SRodney W. Grimes --argc; 11424a1a0dbeSGarrett Wollman ++argv; 11434a1a0dbeSGarrett Wollman init_printer(pp); 1144ba7a1ad7SGarance A Drosehn cmdstatus = getprintcap(*argv, pp); 1145ba7a1ad7SGarance A Drosehn switch(cmdstatus) { 11464a1a0dbeSGarrett Wollman default: 11476d39e1b7SGarance A Drosehn fatal(pp, "%s", pcaperr(cmdstatus)); 11484a1a0dbeSGarrett Wollman case PCAPERR_NOTFOUND: 11494a1a0dbeSGarrett Wollman printf("unknown printer %s\n", *argv); 1150dea673e9SRodney W. Grimes return; 11514a1a0dbeSGarrett Wollman case PCAPERR_TCOPEN: 11524a1a0dbeSGarrett Wollman printf("warning: %s: unresolved tc= reference(s)", *argv); 11534a1a0dbeSGarrett Wollman break; 11544a1a0dbeSGarrett Wollman case PCAPERR_SUCCESS: 11554a1a0dbeSGarrett Wollman break; 11564a1a0dbeSGarrett Wollman } 11574a1a0dbeSGarrett Wollman printf("%s:\n", pp->printer); 1158dea673e9SRodney W. Grimes 1159360d4ad5SWarner Losh seteuid(euid); 11604a1a0dbeSGarrett Wollman if (chdir(pp->spool_dir) < 0) { 11614a1a0dbeSGarrett Wollman printf("\tcannot chdir to %s\n", pp->spool_dir); 1162360d4ad5SWarner Losh goto out; 1163dea673e9SRodney W. Grimes } 1164360d4ad5SWarner Losh seteuid(uid); 11654a1a0dbeSGarrett Wollman nitems = getq(pp, &queue); 1166dea673e9SRodney W. Grimes if (nitems == 0) 1167dea673e9SRodney W. Grimes return; 1168dea673e9SRodney W. Grimes changed = 0; 116930b4b758SGarance A Drosehn mtime = queue[0]->job_time; 1170dea673e9SRodney W. Grimes for (i = argc; --i; ) { 1171dea673e9SRodney W. Grimes if (doarg(argv[i]) == 0) { 1172dea673e9SRodney W. Grimes printf("\tjob %s is not in the queue\n", argv[i]); 1173dea673e9SRodney W. Grimes continue; 1174dea673e9SRodney W. Grimes } else 1175dea673e9SRodney W. Grimes changed++; 1176dea673e9SRodney W. Grimes } 1177dea673e9SRodney W. Grimes for (i = 0; i < nitems; i++) 1178dea673e9SRodney W. Grimes free(queue[i]); 1179dea673e9SRodney W. Grimes free(queue); 1180dea673e9SRodney W. Grimes if (!changed) { 1181dea673e9SRodney W. Grimes printf("\tqueue order unchanged\n"); 1182dea673e9SRodney W. Grimes return; 1183dea673e9SRodney W. Grimes } 1184dea673e9SRodney W. Grimes /* 1185dea673e9SRodney W. Grimes * Turn on the public execute bit of the lock file to 1186dea673e9SRodney W. Grimes * get lpd to rebuild the queue after the current job. 1187dea673e9SRodney W. Grimes */ 1188360d4ad5SWarner Losh seteuid(euid); 11894a1a0dbeSGarrett Wollman if (changed && stat(pp->lock_file, &stbuf) >= 0) 11904a1a0dbeSGarrett Wollman (void) chmod(pp->lock_file, stbuf.st_mode | LFM_RESET_QUE); 1191360d4ad5SWarner Losh 1192360d4ad5SWarner Losh out: 1193360d4ad5SWarner Losh seteuid(uid); 1194dea673e9SRodney W. Grimes } 1195dea673e9SRodney W. Grimes 1196dea673e9SRodney W. Grimes /* 1197dea673e9SRodney W. Grimes * Reposition the job by changing the modification time of 1198dea673e9SRodney W. Grimes * the control file. 1199dea673e9SRodney W. Grimes */ 1200dea673e9SRodney W. Grimes static int 1201ba7a1ad7SGarance A Drosehn touch(struct jobqueue *jq) 1202dea673e9SRodney W. Grimes { 1203dea673e9SRodney W. Grimes struct timeval tvp[2]; 1204360d4ad5SWarner Losh int ret; 1205dea673e9SRodney W. Grimes 1206dea673e9SRodney W. Grimes tvp[0].tv_sec = tvp[1].tv_sec = --mtime; 1207dea673e9SRodney W. Grimes tvp[0].tv_usec = tvp[1].tv_usec = 0; 1208360d4ad5SWarner Losh seteuid(euid); 1209ba7a1ad7SGarance A Drosehn ret = utimes(jq->job_cfname, tvp); 1210360d4ad5SWarner Losh seteuid(uid); 1211360d4ad5SWarner Losh return (ret); 1212dea673e9SRodney W. Grimes } 1213dea673e9SRodney W. Grimes 1214dea673e9SRodney W. Grimes /* 1215dea673e9SRodney W. Grimes * Checks if specified job name is in the printer's queue. 1216dea673e9SRodney W. Grimes * Returns: negative (-1) if argument name is not in the queue. 1217dea673e9SRodney W. Grimes */ 1218dea673e9SRodney W. Grimes static int 1219ba7a1ad7SGarance A Drosehn doarg(char *job) 1220dea673e9SRodney W. Grimes { 122130b4b758SGarance A Drosehn register struct jobqueue **qq; 1222dea673e9SRodney W. Grimes register int jobnum, n; 1223dea673e9SRodney W. Grimes register char *cp, *machine; 1224dea673e9SRodney W. Grimes int cnt = 0; 1225dea673e9SRodney W. Grimes FILE *fp; 1226dea673e9SRodney W. Grimes 1227dea673e9SRodney W. Grimes /* 1228dea673e9SRodney W. Grimes * Look for a job item consisting of system name, colon, number 1229dea673e9SRodney W. Grimes * (example: ucbarpa:114) 1230dea673e9SRodney W. Grimes */ 1231f8eb25daSWarner Losh if ((cp = strchr(job, ':')) != NULL) { 1232dea673e9SRodney W. Grimes machine = job; 1233dea673e9SRodney W. Grimes *cp++ = '\0'; 1234dea673e9SRodney W. Grimes job = cp; 1235dea673e9SRodney W. Grimes } else 1236dea673e9SRodney W. Grimes machine = NULL; 1237dea673e9SRodney W. Grimes 1238dea673e9SRodney W. Grimes /* 1239dea673e9SRodney W. Grimes * Check for job specified by number (example: 112 or 235ucbarpa). 1240dea673e9SRodney W. Grimes */ 1241dea673e9SRodney W. Grimes if (isdigit(*job)) { 1242dea673e9SRodney W. Grimes jobnum = 0; 1243dea673e9SRodney W. Grimes do 1244dea673e9SRodney W. Grimes jobnum = jobnum * 10 + (*job++ - '0'); 1245dea673e9SRodney W. Grimes while (isdigit(*job)); 1246dea673e9SRodney W. Grimes for (qq = queue + nitems; --qq >= queue; ) { 1247dea673e9SRodney W. Grimes n = 0; 124830b4b758SGarance A Drosehn for (cp = (*qq)->job_cfname+3; isdigit(*cp); ) 1249dea673e9SRodney W. Grimes n = n * 10 + (*cp++ - '0'); 1250dea673e9SRodney W. Grimes if (jobnum != n) 1251dea673e9SRodney W. Grimes continue; 1252dea673e9SRodney W. Grimes if (*job && strcmp(job, cp) != 0) 1253dea673e9SRodney W. Grimes continue; 1254dea673e9SRodney W. Grimes if (machine != NULL && strcmp(machine, cp) != 0) 1255dea673e9SRodney W. Grimes continue; 1256dea673e9SRodney W. Grimes if (touch(*qq) == 0) { 125730b4b758SGarance A Drosehn printf("\tmoved %s\n", (*qq)->job_cfname); 1258dea673e9SRodney W. Grimes cnt++; 1259dea673e9SRodney W. Grimes } 1260dea673e9SRodney W. Grimes } 1261dea673e9SRodney W. Grimes return(cnt); 1262dea673e9SRodney W. Grimes } 1263dea673e9SRodney W. Grimes /* 1264dea673e9SRodney W. Grimes * Process item consisting of owner's name (example: henry). 1265dea673e9SRodney W. Grimes */ 1266dea673e9SRodney W. Grimes for (qq = queue + nitems; --qq >= queue; ) { 1267360d4ad5SWarner Losh seteuid(euid); 126830b4b758SGarance A Drosehn fp = fopen((*qq)->job_cfname, "r"); 1269360d4ad5SWarner Losh seteuid(uid); 1270360d4ad5SWarner Losh if (fp == NULL) 1271dea673e9SRodney W. Grimes continue; 1272dea673e9SRodney W. Grimes while (getline(fp) > 0) 1273dea673e9SRodney W. Grimes if (line[0] == 'P') 1274dea673e9SRodney W. Grimes break; 1275dea673e9SRodney W. Grimes (void) fclose(fp); 1276dea673e9SRodney W. Grimes if (line[0] != 'P' || strcmp(job, line+1) != 0) 1277dea673e9SRodney W. Grimes continue; 1278dea673e9SRodney W. Grimes if (touch(*qq) == 0) { 127930b4b758SGarance A Drosehn printf("\tmoved %s\n", (*qq)->job_cfname); 1280dea673e9SRodney W. Grimes cnt++; 1281dea673e9SRodney W. Grimes } 1282dea673e9SRodney W. Grimes } 1283dea673e9SRodney W. Grimes return(cnt); 1284dea673e9SRodney W. Grimes } 1285dea673e9SRodney W. Grimes 1286dea673e9SRodney W. Grimes /* 1287e8e715faSGarance A Drosehn * Enable both queuing & printing, and start printer (undo `down'). 1288e8e715faSGarance A Drosehn */ 1289e8e715faSGarance A Drosehn void 1290e8e715faSGarance A Drosehn up_q(struct printer *pp) 1291e8e715faSGarance A Drosehn { 1292e8e715faSGarance A Drosehn int setres, startok; 1293e8e715faSGarance A Drosehn char lf[MAXPATHLEN]; 1294e8e715faSGarance A Drosehn 1295e8e715faSGarance A Drosehn lock_file_name(pp, lf, sizeof lf); 1296e8e715faSGarance A Drosehn printf("%s:\n", pp->printer); 1297e8e715faSGarance A Drosehn 1298e8e715faSGarance A Drosehn setres = set_qstate(SQS_ENABLEQ+SQS_STARTP, lf); 1299e8e715faSGarance A Drosehn 1300e8e715faSGarance A Drosehn seteuid(euid); 1301e8e715faSGarance A Drosehn startok = startdaemon(pp); 1302e8e715faSGarance A Drosehn seteuid(uid); 1303e8e715faSGarance A Drosehn if (!startok) 1304e8e715faSGarance A Drosehn printf("\tcouldn't start daemon\n"); 1305e8e715faSGarance A Drosehn else 1306e8e715faSGarance A Drosehn printf("\tdaemon started\n"); 1307e8e715faSGarance A Drosehn } 1308