2 * Copyright (c) 1983, 1993
3 * The Regents of the University of California. All rights reserved.
6 * Redistribution and use in source and binary forms, with or without
7 * modification, are permitted provided that the following conditions
9 * 1. Redistributions of source code must retain the above copyright
10 * notice, this list of conditions and the following disclaimer.
11 * 2. Redistributions in binary form must reproduce the above copyright
12 * notice, this list of conditions and the following disclaimer in the
13 * documentation and/or other materials provided with the distribution.
14 * 4. Neither the name of the University nor the names of its contributors
15 * may be used to endorse or promote products derived from this software
16 * without specific prior written permission.
18 * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
19 * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
20 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
21 * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
22 * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
23 * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
24 * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
25 * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
26 * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
27 * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
32 static const char copyright[] =
33 "@(#) Copyright (c) 1983, 1993\n\
34 The Regents of the University of California. All rights reserved.\n";
39 static char sccsid[] = "@(#)cmds.c 8.2 (Berkeley) 4/28/95";
43 #include "lp.cdefs.h" /* A cross-platform version of <sys/cdefs.h> */
44 __FBSDID("$FreeBSD$");
47 * lpc -- line printer control program -- commands:
50 #include <sys/param.h>
68 #include "pathnames.h"
71 * Return values from kill_qtask().
73 #define KQT_LFERROR -2
74 #define KQT_KILLFAIL -1
75 #define KQT_NODAEMON 0
78 static char *args2line(int argc, char **argv);
79 static int doarg(char *_job);
80 static int doselect(const struct dirent *_d);
81 static int kill_qtask(const char *lf);
82 static int sortq(const struct dirent **a, const struct dirent **b);
83 static int touch(struct jobqueue *_jq);
84 static void unlinkf(char *_name);
85 static void upstat(struct printer *_pp, const char *_msg, int _notify);
86 static void wrapup_clean(int _laststatus);
89 * generic framework for commands which operate on all or a specified
92 enum qsel_val { /* how a given ptr was selected */
93 QSEL_UNKNOWN = -1, /* ... not selected yet */
94 QSEL_BYNAME = 0, /* ... user specifed it by name */
95 QSEL_ALL = 1 /* ... user wants "all" printers */
96 /* (with more to come) */
99 static enum qsel_val generic_qselect; /* indicates how ptr was selected */
100 static int generic_initerr; /* result of initrtn processing */
101 static char *generic_cmdname;
102 static char *generic_msg; /* if a -msg was specified */
103 static char *generic_nullarg;
104 static void (*generic_wrapup)(int _last_status); /* perform rtn wrap-up */
107 generic(void (*specificrtn)(struct printer *_pp), int cmdopts,
108 void (*initrtn)(int _argc, char *_argv[]), int argc, char *argv[])
110 int cmdstatus, more, targc;
111 struct printer myprinter, *pp;
112 char **margv, **targv;
116 * Usage needs a special case for 'down': The user must
117 * either include `-msg', or only the first parameter
118 * that they give will be processed as a printer name.
120 printf("usage: %s {all | printer ...}", argv[0]);
121 if (strcmp(argv[0], "down") == 0) {
122 printf(" -msg [<text> ...]\n");
123 printf(" or: down {all | printer} [<text> ...]");
124 } else if (cmdopts & LPC_MSGOPT)
125 printf(" [-msg <text> ...]");
130 /* The first argument is the command name. */
131 generic_cmdname = *argv++;
135 * The initialization routine for a command might set a generic
136 * "wrapup" routine, which should be called after processing all
137 * the printers in the command. This might print summary info.
139 * Note that the initialization routine may also parse (and
140 * nullify) some of the parameters given on the command, leaving
141 * only the parameters which have to do with printer names.
144 generic_wrapup = NULL;
145 generic_qselect = QSEL_UNKNOWN;
147 /* this just needs to be a distinct value of type 'char *' */
148 if (generic_nullarg == NULL)
149 generic_nullarg = strdup("");
152 * Some commands accept a -msg argument, which indicates that
153 * all remaining arguments should be combined into a string.
156 if (cmdopts & LPC_MSGOPT) {
159 for (; targc > 0; targc--, targv++) {
160 if (strcmp(*targv, "-msg") == 0) {
162 generic_msg = args2line(targc - 1, targv + 1);
167 printf("error: No printer name(s) specified before"
169 printf("usage: %s {all | printer ...}",
171 printf(" [-msg <text> ...]\n");
176 /* call initialization routine, if there is one for this cmd */
177 if (initrtn != NULL) {
179 (*initrtn)(argc, argv);
183 * The initrtn may have null'ed out some of the parameters.
184 * Compact the parameter list to remove those nulls, and
185 * correct the arg-count.
191 for (; targc > 0; targc--, targv++) {
192 if (*targv != generic_nullarg) {
201 if (argc == 1 && strcmp(*argv, "all") == 0) {
202 generic_qselect = QSEL_ALL;
203 more = firstprinter(pp, &cmdstatus);
209 more = nextprinter(pp, &cmdstatus);
213 printf("warning: %s: unresolved "
216 case PCAPERR_SUCCESS:
219 fatal(pp, "%s", pcaperr(cmdstatus));
221 } while (more && cmdstatus);
226 generic_qselect = QSEL_BYNAME; /* specifically-named ptrs */
227 for (; argc > 0; argc--, argv++) {
229 cmdstatus = getprintcap(*argv, pp);
232 fatal(pp, "%s", pcaperr(cmdstatus));
233 case PCAPERR_NOTFOUND:
234 printf("unknown printer %s\n", *argv);
237 printf("warning: %s: unresolved tc= reference(s)\n",
240 case PCAPERR_SUCCESS:
247 if (generic_wrapup) {
248 (*generic_wrapup)(cmdstatus);
256 * Convert an argv-array of character strings into a single string.
259 args2line(int argc, char **argv)
269 cend = buf + sizeof(buf) - 1; /* save room for '\0' */
270 while (--argc >= 0) {
272 while ((cp1 < cend) && (*cp1++ = *cp2++))
282 * Kill the current daemon, to stop printing of the active job.
285 kill_qtask(const char *lf)
289 int errsav, killres, lockres, res;
298 * If there is no lock file, then there is no daemon to
299 * kill. Any other error return means there is some
300 * kind of problem with the lock file.
302 if (errsav != ENOENT)
307 /* If the lock file is empty, then there is no daemon to kill */
308 if (getline(fp) == 0)
312 * If the file can be locked without blocking, then there
313 * no daemon to kill, or we should not try to kill it.
315 * XXX - not sure I understand the reasoning behind this...
317 lockres = flock(fileno(fp), LOCK_SH|LOCK_NB);
325 * If we got a negative pid, then the contents of the
326 * lock file is not valid.
333 killres = kill(pid, SIGTERM);
338 printf("\tdaemon (pid %d) killed\n", pid);
339 } else if (errno == ESRCH) {
343 printf("\tWarning: daemon (pid %d) not killed:\n", pid);
344 printf("\t %s\n", strerror(errsav));
350 printf("\tcannot open lock file: %s\n",
354 printf("\tno daemon to abort\n");
358 /* These two already printed messages to the user. */
361 printf("\t<internal error in kill_qtask>\n");
369 * Write a message into the status file.
372 upstat(struct printer *pp, const char *msg, int notifyuser)
375 char statfile[MAXPATHLEN];
377 status_file_name(pp, statfile, sizeof statfile);
380 fd = open(statfile, O_WRONLY|O_CREAT|O_EXLOCK, STAT_FILE_MODE);
383 printf("\tcannot create status file: %s\n", strerror(errno));
386 (void) ftruncate(fd, 0);
388 (void) write(fd, "\n", 1);
390 (void) write(fd, msg, strlen(msg));
393 if ((msg == (char *)NULL) || (strcmp(msg, "\n") == 0))
394 printf("\tstatus message is now set to nothing.\n");
396 printf("\tstatus message is now: %s", msg);
401 * kill an existing daemon and disable printing.
404 abort_q(struct printer *pp)
409 lock_file_name(pp, lf, sizeof lf);
410 printf("%s:\n", pp->printer);
413 * Turn on the owner execute bit of the lock file to disable printing.
415 setres = set_qstate(SQS_STOPP, lf);
418 * If set_qstate found that there already was a lock file, then
419 * call a routine which will read that lock file and kill the
420 * lpd-process which is listed in that lock file. If the lock
421 * file did not exist, then either there is no daemon running
422 * for this queue, or there is one running but *it* could not
423 * write a lock file (which means we can not determine the
424 * process id of that lpd-process).
429 /* Kill the process */
430 killres = kill_qtask(lf);
434 printf("\tno daemon to abort\n");
437 printf("\tassuming no daemon to abort\n");
440 printf("\t<unexpected result (%d) from set_qstate>\n",
446 upstat(pp, "printing disabled\n", 0);
450 * "global" variables for all the routines related to 'clean' and 'tclean'
452 static time_t cln_now; /* current time */
453 static double cln_minage; /* minimum age before file is removed */
454 static long cln_sizecnt; /* amount of space freed up */
455 static int cln_debug; /* print extra debugging msgs */
456 static int cln_filecnt; /* number of files destroyed */
457 static int cln_foundcore; /* found a core file! */
458 static int cln_queuecnt; /* number of queues checked */
459 static int cln_testonly; /* remove-files vs just-print-info */
462 doselect(const struct dirent *d)
464 int c = d->d_name[0];
466 if ((c == 'c' || c == 'd' || c == 'r' || c == 't') &&
470 if (!strcmp(d->d_name, "core"))
474 if (!strncmp(d->d_name, "errs.", 5))
481 * Comparison routine that clean_q() uses for scandir.
483 * The purpose of this sort is to have all `df' files end up immediately
484 * after the matching `cf' file. For files matching `cf', `df', `rf', or
485 * `tf', it sorts by job number and machine, then by `cf', `df', `rf', or
486 * `tf', and then by the sequence letter (which is A-Z, or a-z). This
487 * routine may also see filenames which do not start with `cf', `df', `rf',
488 * or `tf' (such as `errs.*'), and those are simply sorted by the full
492 * This assumes that all control files start with `cfA*', and it turns
493 * out there are a few implementations of lpr which will create `cfB*'
494 * filenames (they will have datafile names which start with `dfB*').
497 sortq(const struct dirent **a, const struct dirent **b)
499 const int a_lt_b = -1, a_gt_b = 1, cat_other = 10;
500 const char *fname_a, *fname_b, *jnum_a, *jnum_b;
501 int cat_a, cat_b, ch, res, seq_a, seq_b;
503 fname_a = (*a)->d_name;
504 fname_b = (*b)->d_name;
507 * First separate filenames into categories. Categories are
508 * legitimate `cf', `df', `rf' & `tf' filenames, and "other" - in
509 * that order. It is critical that the mapping be exactly the
510 * same for 'a' vs 'b', so define a macro for the job.
512 * [aside: the standard `cf' file has the jobnumber start in
513 * position 4, but some implementations have that as an extra
514 * file-sequence letter, and start the job number in position 5.]
516 #define MAP_TO_CAT(fname_X,cat_X,jnum_X,seq_X) do { \
518 ch = *(fname_X + 2); \
519 jnum_X = fname_X + 3; \
521 if ((*(fname_X + 1) == 'f') && (isalpha(ch))) { \
523 if (*fname_X == 'c') \
525 else if (*fname_X == 'd') \
527 else if (*fname_X == 'r') \
529 else if (*fname_X == 't') \
531 if (cat_X != cat_other) { \
533 if (!isdigit(ch)) { \
537 seq_X = (seq_X << 8) + ch; \
546 MAP_TO_CAT(fname_a, cat_a, jnum_a, seq_a);
547 MAP_TO_CAT(fname_b, cat_b, jnum_b, seq_b);
551 /* First handle all cases which have "other" files */
552 if ((cat_a >= cat_other) || (cat_b >= cat_other)) {
553 /* for two "other" files, just compare the full name */
555 res = strcmp(fname_a, fname_b);
556 else if (cat_a < cat_b)
564 * At this point, we know both files are legitimate `cf', `df', `rf',
565 * or `tf' files. Compare them by job-number and machine name.
567 res = strcmp(jnum_a, jnum_b);
572 * We have two files which belong to the same job. Sort based
573 * on the category of file (`c' before `d', etc).
578 } else if (cat_a > cat_b) {
584 * Two files in the same category for a single job. Sort based
585 * on the sequence letter(s). (usually `A' through `Z', etc).
590 } else if (seq_a > seq_b) {
596 * Given that the filenames in a directory are unique, this SHOULD
597 * never happen (unless there are logic errors in this routine).
598 * But if it does happen, we must return "is equal" or the caller
599 * might see inconsistent results in the sorting order, and that
600 * can trigger other problems.
602 printf("\t*** Error in sortq: %s == %s !\n", fname_a, fname_b);
603 printf("\t*** cat %d == %d ; seq = %d %d\n", cat_a, cat_b,
612 * Remove all spool files and temporaries from the spooling area.
614 * Remove incomplete jobs from spooling area.
618 clean_gi(int argc, char *argv[])
621 /* init some fields before 'clean' is called for each queue */
623 cln_now = time(NULL);
624 cln_minage = 3600.0; /* only delete files >1h old */
629 generic_wrapup = &wrapup_clean;
631 /* see if there are any options specified before the ptr list */
632 for (; argc > 0; argc--, argv++) {
635 if (strcmp(*argv, "-d") == 0) {
636 /* just an example of an option... */
638 *argv = generic_nullarg; /* "erase" it */
640 printf("Invalid option '%s'\n", *argv);
649 tclean_gi(int argc, char *argv[])
652 /* only difference between 'clean' and 'tclean' is one value */
653 /* (...and the fact that 'clean' is priv and 'tclean' is not) */
654 clean_gi(argc, argv);
661 clean_q(struct printer *pp)
664 struct dirent **queue;
666 int didhead, i, n, nitems, rmcp;
671 if (generic_qselect == QSEL_BYNAME) {
672 printf("%s:\n", pp->printer);
678 while (lp < &line[sizeof(line) - 1]) {
679 if ((*lp++ = *cp++) == 0)
683 linerem = sizeof(line) - (lp - line);
687 nitems = scandir(pp->spool_dir, &queue, doselect, sortq);
691 printf("%s:\n", pp->printer);
694 printf("\tcannot examine spool directory\n");
699 printf("%s:\n", pp->printer);
702 printf("\t** found a core file in %s !\n", pp->spool_dir);
707 printf("%s:\n", pp->printer);
709 printf("\t** ----- Sorted list of files being checked:\n");
712 cp = queue[i]->d_name;
713 printf("\t** [%3d] = %s\n", i, cp);
714 } while (++i < nitems);
715 printf("\t** ----- end of sorted list\n");
719 cp = queue[i]->d_name;
723 * A control file. Look for matching data-files.
726 * Note the logic here assumes that the hostname
727 * part of cf-filenames match the hostname part
728 * in df-filenames, and that is not necessarily
729 * true (eg: for multi-homed hosts). This needs
730 * some further thought...
733 while (i + 1 < nitems) {
734 cp1 = queue[i + 1]->d_name;
735 if (*cp1 != 'd' || strcmp(cp + 3, cp1 + 3))
743 } else if (*cp == 'e') {
745 * Must be an errrs or email temp file.
750 * Must be a df with no cf (otherwise, it would have
751 * been skipped above) or an rf or tf file (which can
752 * always be removed if it is old enough).
757 if (strlen(cp) >= linerem) {
758 printf("\t** internal error: 'line' overflow!\n");
759 printf("\t** spooldir = %s\n", pp->spool_dir);
760 printf("\t** cp = %s\n", cp);
763 strlcpy(lp, cp, linerem);
766 } while (++i < nitems);
770 wrapup_clean(int laststatus __unused)
773 printf("Checked %d queues, and ", cln_queuecnt);
774 if (cln_filecnt < 1) {
775 printf("no cruft was found\n");
779 printf("would have ");
781 printf("removed %d files (%ld bytes).\n", cln_filecnt, cln_sizecnt);
788 double agemod, agestat;
790 char linkbuf[BUFSIZ];
793 * We have to use lstat() instead of stat(), in case this is a df*
794 * "file" which is really a symlink due to 'lpr -s' processing. In
795 * that case, we need to check the last-mod time of the symlink, and
796 * not the file that the symlink is pointed at.
799 res = lstat(name, &stbuf);
802 printf("\terror return from stat(%s):\n", name);
803 printf("\t %s\n", strerror(errno));
807 agemod = difftime(cln_now, stbuf.st_mtime);
808 agestat = difftime(cln_now, stbuf.st_ctime);
810 /* this debugging-aid probably is not needed any more... */
811 printf("\t\t modify age=%g secs, stat age=%g secs\n",
814 if ((agemod <= cln_minage) && (agestat <= cln_minage))
818 * if this file is a symlink, then find out the target of the
819 * symlink before unlink-ing the file itself
821 if (S_ISLNK(stbuf.st_mode)) {
823 res = readlink(name, linkbuf, sizeof(linkbuf));
826 printf("\terror return from readlink(%s):\n", name);
827 printf("\t %s\n", strerror(errno));
830 if (res == sizeof(linkbuf))
836 cln_sizecnt += stbuf.st_size;
839 printf("\twould remove %s\n", name);
840 if (S_ISLNK(stbuf.st_mode)) {
841 printf("\t (which is a symlink to %s)\n", linkbuf);
848 printf("\tcannot remove %s (!)\n", name);
850 printf("\tremoved %s\n", name);
852 * Note that for a df* file, this code should also check to see
853 * if it is a symlink to some other file, and if the original
854 * lpr command included '-r' ("remove file"). Of course, this
855 * code would not be removing the df* file unless there was no
856 * matching cf* file, and without the cf* file it is currently
857 * impossible to determine if '-r' had been specified...
859 * As a result of this quandry, we may be leaving behind a
860 * user's file that was supposed to have been removed after
861 * being printed. This may effect services such as CAP or
862 * samba, if they were configured to use 'lpr -r', and if
863 * datafiles are not being properly removed.
865 if (S_ISLNK(stbuf.st_mode)) {
866 printf("\t (which was a symlink to %s)\n", linkbuf);
872 * Enable queuing to the printer (allow lpr to add new jobs to the queue).
875 enable_q(struct printer *pp)
880 lock_file_name(pp, lf, sizeof lf);
881 printf("%s:\n", pp->printer);
883 setres = set_qstate(SQS_ENABLEQ, lf);
890 disable_q(struct printer *pp)
895 lock_file_name(pp, lf, sizeof lf);
896 printf("%s:\n", pp->printer);
898 setres = set_qstate(SQS_DISABLEQ, lf);
902 * Disable queuing and printing and put a message into the status file
903 * (reason for being down). If the user specified `-msg', then use
904 * everything after that as the message for the status file. If the
905 * user did NOT specify `-msg', then the command should take the first
906 * parameter as the printer name, and all remaining parameters as the
907 * message for the status file. (This is to be compatible with the
908 * original definition of 'down', which was implemented long before
909 * `-msg' was around).
912 down_gi(int argc, char *argv[])
915 /* If `-msg' was specified, then this routine has nothing to do. */
916 if (generic_msg != NULL)
920 * If the user only gave one parameter, then use a default msg.
921 * (if argc == 1 at this point, then *argv == name of printer).
924 generic_msg = strdup("printing disabled\n");
929 * The user specified multiple parameters, and did not specify
930 * `-msg'. Build a message from all the parameters after the
931 * first one (and nullify those parameters so generic-processing
932 * will not process them as printer-queue names).
936 generic_msg = args2line(argc, argv);
937 for (; argc > 0; argc--, argv++)
938 *argv = generic_nullarg; /* "erase" it */
942 down_q(struct printer *pp)
947 lock_file_name(pp, lf, sizeof lf);
948 printf("%s:\n", pp->printer);
950 setres = set_qstate(SQS_DISABLEQ+SQS_STOPP, lf);
952 upstat(pp, generic_msg, 1);
959 quit(int argc __unused, char *argv[] __unused)
965 * Kill and restart the daemon.
968 restart_q(struct printer *pp)
970 int killres, setres, startok;
973 lock_file_name(pp, lf, sizeof lf);
974 printf("%s:\n", pp->printer);
976 killres = kill_qtask(lf);
979 * XXX - if the kill worked, we should probably sleep for
980 * a second or so before trying to restart the queue.
983 /* make sure the queue is set to print jobs */
984 setres = set_qstate(SQS_STARTP, lf);
987 startok = startdaemon(pp);
990 printf("\tcouldn't restart daemon\n");
992 printf("\tdaemon restarted\n");
996 * Set the status message of each queue listed. Requires a "-msg"
997 * parameter to indicate the end of the queue list and start of msg text.
1000 setstatus_gi(int argc __unused, char *argv[] __unused)
1003 if (generic_msg == NULL) {
1004 printf("You must specify '-msg' before the text of the new status message.\n");
1005 generic_initerr = 1;
1010 setstatus_q(struct printer *pp)
1014 char lf[MAXPATHLEN];
1016 lock_file_name(pp, lf, sizeof lf);
1017 printf("%s:\n", pp->printer);
1019 upstat(pp, generic_msg, 1);
1022 * Warn the user if 'lpq' will not display this new status-message.
1023 * Note that if lock file does not exist, then the queue is enabled
1024 * for both queuing and printing.
1027 if (stat(lf, &stbuf) >= 0) {
1028 if (stbuf.st_mode & LFM_PRINT_DIS)
1032 printf("\tnote: This queue currently has printing enabled,\n");
1033 printf("\t so this -msg will only be shown by 'lpq' if\n");
1034 printf("\t a job is actively printing on it.\n");
1039 * Enable printing on the specified printer and startup the daemon.
1042 start_q(struct printer *pp)
1044 int setres, startok;
1045 char lf[MAXPATHLEN];
1047 lock_file_name(pp, lf, sizeof lf);
1048 printf("%s:\n", pp->printer);
1050 setres = set_qstate(SQS_STARTP, lf);
1053 startok = startdaemon(pp);
1056 printf("\tcouldn't start daemon\n");
1058 printf("\tdaemon started\n");
1063 * Print the status of the printer queue.
1066 status(struct printer *pp)
1070 register struct dirent *dp;
1072 char file[MAXPATHLEN];
1074 printf("%s:\n", pp->printer);
1075 lock_file_name(pp, file, sizeof file);
1076 if (stat(file, &stbuf) >= 0) {
1077 printf("\tqueuing is %s\n",
1078 ((stbuf.st_mode & LFM_QUEUE_DIS) ? "disabled"
1080 printf("\tprinting is %s\n",
1081 ((stbuf.st_mode & LFM_PRINT_DIS) ? "disabled"
1084 printf("\tqueuing is enabled\n");
1085 printf("\tprinting is enabled\n");
1087 if ((dirp = opendir(pp->spool_dir)) == NULL) {
1088 printf("\tcannot examine spool directory\n");
1092 while ((dp = readdir(dirp)) != NULL) {
1093 if (*dp->d_name == 'c' && dp->d_name[1] == 'f')
1098 printf("\tno entries in spool area\n");
1100 printf("\t1 entry in spool area\n");
1102 printf("\t%d entries in spool area\n", i);
1103 fd = open(file, O_RDONLY);
1104 if (fd < 0 || flock(fd, LOCK_SH|LOCK_NB) == 0) {
1105 (void) close(fd); /* unlocks as well */
1106 printf("\tprinter idle\n");
1110 /* print out the contents of the status file, if it exists */
1111 status_file_name(pp, file, sizeof file);
1112 fd = open(file, O_RDONLY|O_SHLOCK);
1114 (void) fstat(fd, &stbuf);
1115 if (stbuf.st_size > 0) {
1117 while ((i = read(fd, line, sizeof(line))) > 0)
1118 (void) fwrite(line, 1, i, stdout);
1120 (void) close(fd); /* unlocks as well */
1125 * Stop the specified daemon after completing the current job and disable
1129 stop_q(struct printer *pp)
1132 char lf[MAXPATHLEN];
1134 lock_file_name(pp, lf, sizeof lf);
1135 printf("%s:\n", pp->printer);
1137 setres = set_qstate(SQS_STOPP, lf);
1140 upstat(pp, "printing disabled\n", 0);
1143 struct jobqueue **queue;
1148 * Put the specified jobs at the top of printer queue.
1151 topq(int argc, char *argv[])
1155 int cmdstatus, changed;
1156 struct printer myprinter, *pp = &myprinter;
1159 printf("usage: topq printer [jobnum ...] [user ...]\n");
1166 cmdstatus = getprintcap(*argv, pp);
1169 fatal(pp, "%s", pcaperr(cmdstatus));
1170 case PCAPERR_NOTFOUND:
1171 printf("unknown printer %s\n", *argv);
1173 case PCAPERR_TCOPEN:
1174 printf("warning: %s: unresolved tc= reference(s)", *argv);
1176 case PCAPERR_SUCCESS:
1179 printf("%s:\n", pp->printer);
1182 if (chdir(pp->spool_dir) < 0) {
1183 printf("\tcannot chdir to %s\n", pp->spool_dir);
1187 nitems = getq(pp, &queue);
1191 mtime = queue[0]->job_time;
1192 for (i = argc; --i; ) {
1193 if (doarg(argv[i]) == 0) {
1194 printf("\tjob %s is not in the queue\n", argv[i]);
1199 for (i = 0; i < nitems; i++)
1203 printf("\tqueue order unchanged\n");
1207 * Turn on the public execute bit of the lock file to
1208 * get lpd to rebuild the queue after the current job.
1211 if (changed && stat(pp->lock_file, &stbuf) >= 0)
1212 (void) chmod(pp->lock_file, stbuf.st_mode | LFM_RESET_QUE);
1219 * Reposition the job by changing the modification time of
1223 touch(struct jobqueue *jq)
1225 struct timeval tvp[2];
1228 tvp[0].tv_sec = tvp[1].tv_sec = --mtime;
1229 tvp[0].tv_usec = tvp[1].tv_usec = 0;
1231 ret = utimes(jq->job_cfname, tvp);
1237 * Checks if specified job name is in the printer's queue.
1238 * Returns: negative (-1) if argument name is not in the queue.
1243 register struct jobqueue **qq;
1244 register int jobnum, n;
1245 register char *cp, *machine;
1250 * Look for a job item consisting of system name, colon, number
1251 * (example: ucbarpa:114)
1253 if ((cp = strchr(job, ':')) != NULL) {
1261 * Check for job specified by number (example: 112 or 235ucbarpa).
1263 if (isdigit(*job)) {
1266 jobnum = jobnum * 10 + (*job++ - '0');
1267 while (isdigit(*job));
1268 for (qq = queue + nitems; --qq >= queue; ) {
1270 for (cp = (*qq)->job_cfname+3; isdigit(*cp); )
1271 n = n * 10 + (*cp++ - '0');
1274 if (*job && strcmp(job, cp) != 0)
1276 if (machine != NULL && strcmp(machine, cp) != 0)
1278 if (touch(*qq) == 0) {
1279 printf("\tmoved %s\n", (*qq)->job_cfname);
1286 * Process item consisting of owner's name (example: henry).
1288 for (qq = queue + nitems; --qq >= queue; ) {
1290 fp = fopen((*qq)->job_cfname, "r");
1294 while (getline(fp) > 0)
1298 if (line[0] != 'P' || strcmp(job, line+1) != 0)
1300 if (touch(*qq) == 0) {
1301 printf("\tmoved %s\n", (*qq)->job_cfname);
1309 * Enable both queuing & printing, and start printer (undo `down').
1312 up_q(struct printer *pp)
1314 int setres, startok;
1315 char lf[MAXPATHLEN];
1317 lock_file_name(pp, lf, sizeof lf);
1318 printf("%s:\n", pp->printer);
1320 setres = set_qstate(SQS_ENABLEQ+SQS_STARTP, lf);
1323 startok = startdaemon(pp);
1326 printf("\tcouldn't start daemon\n");
1328 printf("\tdaemon started\n");