Head

GCC Code Coverage Report

Directory:	./		Exec	Total	Coverage
File:	usr.sbin/lpr/lpq/../common_source/common.c	Lines:	0	202	0.0 %
Date:	2017-11-07	Branches:	0	127	0.0 %


/*	$OpenBSD: common.c,v 1.41 2016/02/29 17:26:01 jca Exp $	*/
/*	$NetBSD: common.c,v 1.21 2000/08/09 14:28:50 itojun Exp $	*/

/*
 * Copyright (c) 1983, 1993
 *	The Regents of the University of California.  All rights reserved.
 * (c) UNIX System Laboratories, Inc.
 * All or some portions of this file are derived from material licensed
 * to the University of California by American Telephone and Telegraph
 * Co. or Unix System Laboratories, Inc. and are reproduced herein with
 * the permission of UNIX System Laboratories, Inc.
 *
 * Redistribution and use in source and binary forms, with or without
 * modification, are permitted provided that the following conditions
 * are met:
 * 1. Redistributions of source code must retain the above copyright
 *    notice, this list of conditions and the following disclaimer.
 * 2. Redistributions in binary form must reproduce the above copyright
 *    notice, this list of conditions and the following disclaimer in the
 *    documentation and/or other materials provided with the distribution.
 * 3. Neither the name of the University nor the names of its contributors
 *    may be used to endorse or promote products derived from this software
 *    without specific prior written permission.
 *
 * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
 * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
 * ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
 * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
 * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
 * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
 * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
 * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
 * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
 * SUCH DAMAGE.
 */

#include <sys/stat.h>
#include <sys/time.h>

#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <netdb.h>

#include <dirent.h>
#include <errno.h>
#include <fcntl.h>
#include <unistd.h>
#include <limits.h>
#include <stdlib.h>
#include <stdio.h>
#include <string.h>
#include <signal.h>
#include <stdarg.h>
#include <ifaddrs.h>
#include "lp.h"
#include "pathnames.h"

/*
 * Routines and data common to all the line printer functions.
 */

char	*AF;		/* accounting file */
long	 BR;		/* baud rate if lp is a tty */
char	*CF;		/* name of cifplot filter (per job) */
char	*DF;		/* name of tex filter (per job) */
long	 DU;		/* daemon user-id */
char	*FF;		/* form feed string */
char	*GF;		/* name of graph(1G) filter (per job) */
long	 HL;		/* print header last */
char	*IF;		/* name of input filter (created per job) */
char	*LF;		/* log file for error messages */
char	*LO;		/* lock file name */
char	*LP;		/* line printer device name */
long	 MC;		/* maximum number of copies allowed */
char	*MS;		/* stty flags to set if lp is a tty */
long	 MX;		/* maximum number of blocks to copy */
char	*NF;		/* name of ditroff filter (per job) */
char	*OF;		/* name of output filter (created once) */
long	 PL;		/* page length */
long	 PW;		/* page width */
long	 PX;		/* page width in pixels */
long	 PY;		/* page length in pixels */
char	*RF;		/* name of fortran text filter (per job) */
char    *RG;		/* restricted group */
char	*RM;		/* remote machine name */
char	*RP;		/* remote printer name */
long	 RS;		/* restricted to those with local accounts */
long	 RW;		/* open LP for reading and writing */
long	 SB;		/* short banner instead of normal header */
long	 SC;		/* suppress multiple copies */
char	*SD;		/* spool directory */
long	 SF;		/* suppress FF on each print job */
long	 SH;		/* suppress header page */
char	*ST;		/* status file name */
char	*TF;		/* name of troff filter (per job) */
char	*TR;		/* trailer string to be output when Q empties */
char	*VF;		/* name of vplot filter (per job) */

char	line[BUFSIZ];
int	remote;		/* true if sending files to a remote host */

static int compar(const void *, const void *);

/*
 * Create a TCP connection to host "rhost" at port "rport".
 * If rport == 0, then use the printer service port.
 * Most of this code comes from rcmd.c.
 */
int
getport(char *rhost, int rport)
{
	struct addrinfo hints, *res, *r;
	u_int timo = 1;
	int s, lport = IPPORT_RESERVED - 1;
	int error;
	int refuse, trial;
	char pbuf[NI_MAXSERV];

	/*
	 * Get the host address and port number to connect to.
	 */
	if (rhost == NULL)
		fatal("no remote host to connect to");
	memset(&hints, 0, sizeof(hints));
	hints.ai_family = PF_UNSPEC;
	hints.ai_socktype = SOCK_STREAM;
	if (rport)
		snprintf(pbuf, sizeof(pbuf), "%d", rport);
	else
		snprintf(pbuf, sizeof(pbuf), "printer");
	siginterrupt(SIGINT, 1);
	error = getaddrinfo(rhost, pbuf, &hints, &res);
	siginterrupt(SIGINT, 0);
	if (error)
		fatal("printer/tcp: %s", gai_strerror(error));

	/*
	 * Try connecting to the server.
	 */
retry:
	s = -1;
	refuse = trial = 0;
	for (r = res; r; r = r->ai_next) {
		trial++;
retryport:
		PRIV_START;
		s = rresvport_af(&lport, r->ai_family);
		PRIV_END;
		if (s < 0) {
			/* fall back to non-privileged port */
			if (errno != EACCES ||
			    (s = socket(r->ai_family, SOCK_STREAM, 0)) < 0) {
				freeaddrinfo(res);
				return(-1);
			}
		}
		siginterrupt(SIGINT, 1);
		if (connect(s, r->ai_addr, r->ai_addrlen) < 0) {
			error = errno;
			siginterrupt(SIGINT, 0);
			(void)close(s);
			s = -1;
			errno = error;
			if (errno == EADDRINUSE) {
				lport--;
				goto retryport;
			} else if (errno == ECONNREFUSED)
				refuse++;
			continue;
		} else {
			siginterrupt(SIGINT, 0);
			break;
		}
	}
	if (s < 0 && trial == refuse && timo <= 16) {
		sleep(timo);
		timo *= 2;
		goto retry;
	}
	if (res)
		freeaddrinfo(res);

	/* Don't worry if we get an error from setsockopt(). */
	trial = 1;
	setsockopt(s, SOL_SOCKET, SO_KEEPALIVE, &trial, sizeof(trial));

	return(s);
}

/*
 * Getline reads a line from the control file cfp, removes tabs, converts
 *  new-line to null and leaves it in line.
 * Returns 0 at EOF or the number of characters read.
 */
int
get_line(FILE *cfp)
{
	int linel = 0;
	char *lp = line;
	int c;

	while ((c = getc(cfp)) != '\n' && linel+1<sizeof(line)) {
		if (c == EOF)
			return(0);
		if (c == '\t') {
			do {
				*lp++ = ' ';
				linel++;
			} while ((linel & 07) != 0 && linel+1 < sizeof(line));
			continue;
		}
		*lp++ = c;
		linel++;
	}
	*lp++ = '\0';
	return(linel);
}

/*
 * Scan the current directory and make a list of daemon files sorted by
 * creation time.
 * Return the number of entries and a pointer to the list.
 */
int
getq(struct queue ***namelist)
{
	struct dirent *d;
	struct queue *q, **queue = NULL;
	size_t nitems = 0, arraysz;
	struct stat stbuf;
	DIR *dirp;

	PRIV_START;
	dirp = opendir(SD);
	PRIV_END;
	if (dirp == NULL)
		return(-1);
	if (fstat(dirfd(dirp), &stbuf) < 0)
		goto errdone;

	/*
	 * Estimate the array size by taking the size of the directory file
	 * and dividing it by a multiple of the minimum size entry.
	 */
	arraysz = (stbuf.st_size / 24);
	queue = calloc(arraysz, sizeof(struct queue *));
	if (queue == NULL)
		goto errdone;

	while ((d = readdir(dirp)) != NULL) {
		if (d->d_name[0] != 'c' || d->d_name[1] != 'f')
			continue;	/* daemon control files only */
		PRIV_START;
		if (stat(d->d_name, &stbuf) < 0) {
			PRIV_END;
			continue;	/* Doesn't exist */
		}
		PRIV_END;
		q = malloc(sizeof(struct queue));
		if (q == NULL)
			goto errdone;
		q->q_time = stbuf.st_mtime;
		strlcpy(q->q_name, d->d_name, sizeof(q->q_name));

		/*
		 * Check to make sure the array has space left and
		 * realloc the maximum size.
		 */
		if (nitems == arraysz) {
			struct queue **newqueue;
			newqueue = reallocarray(queue,
			    arraysz, 2 * sizeof(struct queue *));
			if (newqueue == NULL) {
				free(q);
				goto errdone;
			}
			arraysz *= 2;
			queue = newqueue;
		}
		queue[nitems++] = q;
	}
	closedir(dirp);
	if (nitems)
		qsort(queue, nitems, sizeof(struct queue *), compar);
	*namelist = queue;
	return(nitems);

errdone:
	if (queue != NULL) {
		while (nitems--)
			free(queue[nitems]);
		free(queue);
	}
	closedir(dirp);
	return(-1);
}

/*
 * Compare modification times.
 */
static int
compar(const void *v1, const void *v2)
{
	struct queue *p1 = *(struct queue **)v1;
	struct queue *p2 = *(struct queue **)v2;

	return(p1->q_time - p2->q_time);
}

/*
 * Figure out whether the local machine is the same
 * as the remote machine (RM) entry (if it exists).
 */
char *
checkremote(void)
{
	char lname[NI_MAXHOST], rname[NI_MAXHOST];
	struct addrinfo hints, *res, *res0;
	static char errbuf[128];
	int error;
	struct ifaddrs *ifap, *ifa;
	const int niflags = NI_NUMERICHOST;
#ifdef __KAME__
	struct sockaddr_in6 sin6;
	struct sockaddr_in6 *sin6p;
#endif

	remote = 0;	/* assume printer is local on failure */

	if (RM == NULL || *RM == '\0')
		return NULL;

	/* get the local interface addresses */
	siginterrupt(SIGINT, 1);
	if (getifaddrs(&ifap) < 0) {
		(void)snprintf(errbuf, sizeof(errbuf),
		    "unable to get local interface address: %s",
		    strerror(errno));
		siginterrupt(SIGINT, 0);
		return errbuf;
	}
	siginterrupt(SIGINT, 0);

	/* get the remote host addresses (RM) */
	memset(&hints, 0, sizeof(hints));
	hints.ai_flags = AI_CANONNAME;
	hints.ai_family = PF_UNSPEC;
	hints.ai_socktype = SOCK_STREAM;
	res = NULL;
	siginterrupt(SIGINT, 1);
	error = getaddrinfo(RM, NULL, &hints, &res0);
	siginterrupt(SIGINT, 0);
	if (error) {
		(void)snprintf(errbuf, sizeof(errbuf),
		    "unable to resolve remote machine %s: %s",
		    RM, gai_strerror(error));
		freeifaddrs(ifap);
		return errbuf;
	}

	remote = 1;	/* assume printer is remote */

	for (res = res0; res; res = res->ai_next) {
		siginterrupt(SIGINT, 1);
		error = getnameinfo(res->ai_addr, res->ai_addrlen,
		    rname, sizeof(rname), NULL, 0, niflags);
		siginterrupt(SIGINT, 0);
		if (error != 0)
			continue;
		for (ifa = ifap; ifa; ifa = ifa->ifa_next) {
#ifdef __KAME__
			sin6p = (struct sockaddr_in6 *)ifa->ifa_addr;
			if (ifa->ifa_addr->sa_family == AF_INET6 &&
			    ifa->ifa_addr->sa_len == sizeof(sin6) &&
			    IN6_IS_ADDR_LINKLOCAL(&sin6p->sin6_addr) &&
			    *(u_int16_t *)&sin6p->sin6_addr.s6_addr[2]) {
				/* kame scopeid hack */
				memcpy(&sin6, ifa->ifa_addr, sizeof(sin6));
				sin6.sin6_scope_id =
				    ntohs(*(u_int16_t *)&sin6p->sin6_addr.s6_addr[2]);
				sin6.sin6_addr.s6_addr[2] = 0;
				sin6.sin6_addr.s6_addr[3] = 0;
				siginterrupt(SIGINT, 1);
				error = getnameinfo((struct sockaddr *)&sin6,
				    sin6.sin6_len, lname, sizeof(lname),
				    NULL, 0, niflags);
				siginterrupt(SIGINT, 0);
				if (error != 0)
					continue;
			} else
#endif
			siginterrupt(SIGINT, 1);
			error = getnameinfo(ifa->ifa_addr,
			    ifa->ifa_addr->sa_len, lname, sizeof(lname), NULL,
			    0, niflags);
			siginterrupt(SIGINT, 0);
			if (error != 0)
				continue;

			if (strcmp(rname, lname) == 0) {
				remote = 0;
				goto done;
			}
		}
	}
done:
	freeaddrinfo(res0);
	freeifaddrs(ifap);
	return NULL;
}

__dead void
fatal(const char *msg, ...)
{
	extern char *__progname;
	va_list ap;

	va_start(ap, msg);
	if (from != host)
		(void)printf("%s: ", host);
	(void)printf("%s: ", __progname);
	if (printer)
		(void)printf("%s: ", printer);
	(void)vprintf(msg, ap);
	va_end(ap);
	(void)putchar('\n');
	exit(1);
}

int
safe_open(const char *path, int flags, mode_t mode)
{
	int fd, serrno;
	struct stat stbuf;

	if ((fd = open(path, flags|O_NONBLOCK, mode)) < 0 ||
	    fstat(fd, &stbuf) < 0) {
		if (fd >= 0) {
			serrno = errno;
			close(fd);
			errno = serrno;
		}
		return (-1);
	}
	if (!S_ISREG(stbuf.st_mode)) {
		close(fd);
		errno = EACCES;
		return (-1);
	}
	if (mode)
		(void)fchmod(fd, mode);
	return (fd);
}

/*
 * Make sure there's some work to do before forking off a child - lpd
 * Check to see if anything in queue - lpq
 */
int
ckqueue(char *cap)
{
	struct dirent *d;
	DIR *dirp;
	char *spooldir;

	if (cgetstr(cap, "sd", &spooldir) >= 0) {
		dirp = opendir(spooldir);
		free(spooldir);
	} else
		dirp = opendir(_PATH_DEFSPOOL);

	if (dirp == NULL)
		return (-1);
	while ((d = readdir(dirp)) != NULL) {
		if (d->d_name[0] == 'c' && d->d_name[1] == 'f') {
			closedir(dirp);
			return (1);		/* found a cf file */
		}
	}
	closedir(dirp);
	return (0);
}


Generated by: GCOVR (Version 3.3)

Line	Branch	Exec	Source
1			/* $OpenBSD: common.c,v 1.41 2016/02/29 17:26:01 jca Exp $ */
2			/* $NetBSD: common.c,v 1.21 2000/08/09 14:28:50 itojun Exp $ */
3
4			/*
5			* Copyright (c) 1983, 1993
6			* The Regents of the University of California. All rights reserved.
7			* (c) UNIX System Laboratories, Inc.
8			* All or some portions of this file are derived from material licensed
9			* to the University of California by American Telephone and Telegraph
10			* Co. or Unix System Laboratories, Inc. and are reproduced herein with
11			* the permission of UNIX System Laboratories, Inc.
12			*
13			* Redistribution and use in source and binary forms, with or without
14			* modification, are permitted provided that the following conditions
15			* are met:
16			* 1. Redistributions of source code must retain the above copyright
17			* notice, this list of conditions and the following disclaimer.
18			* 2. Redistributions in binary form must reproduce the above copyright
19			* notice, this list of conditions and the following disclaimer in the
20			* documentation and/or other materials provided with the distribution.
21			* 3. Neither the name of the University nor the names of its contributors
22			* may be used to endorse or promote products derived from this software
23			* without specific prior written permission.
24			*
25			* THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
26			* ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
27			* IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
28			* ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
29			* FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
30			* DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
31			* OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
32			* HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
33			* LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
34			* OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
35			* SUCH DAMAGE.
36			*/
37
38			#include <sys/stat.h>
39			#include <sys/time.h>
40
41			#include <sys/socket.h>
42			#include <netinet/in.h>
43			#include <arpa/inet.h>
44			#include <netdb.h>
45
46			#include <dirent.h>
47			#include <errno.h>
48			#include <fcntl.h>
49			#include <unistd.h>
50			#include <limits.h>
51			#include <stdlib.h>
52			#include <stdio.h>
53			#include <string.h>
54			#include <signal.h>
55			#include <stdarg.h>
56			#include <ifaddrs.h>
57			#include "lp.h"
58			#include "pathnames.h"
59
60			/*
61			* Routines and data common to all the line printer functions.
62			*/
63
64			char AF; / accounting file */
65			long BR; /* baud rate if lp is a tty */
66			char CF; / name of cifplot filter (per job) */
67			char DF; / name of tex filter (per job) */
68			long DU; /* daemon user-id */
69			char FF; / form feed string */
70			char GF; / name of graph(1G) filter (per job) */
71			long HL; /* print header last */
72			char IF; / name of input filter (created per job) */
73			char LF; / log file for error messages */
74			char LO; / lock file name */
75			char LP; / line printer device name */
76			long MC; /* maximum number of copies allowed */
77			char MS; / stty flags to set if lp is a tty */
78			long MX; /* maximum number of blocks to copy */
79			char NF; / name of ditroff filter (per job) */
80			char OF; / name of output filter (created once) */
81			long PL; /* page length */
82			long PW; /* page width */
83			long PX; /* page width in pixels */
84			long PY; /* page length in pixels */
85			char RF; / name of fortran text filter (per job) */
86			char RG; / restricted group */
87			char RM; / remote machine name */
88			char RP; / remote printer name */
89			long RS; /* restricted to those with local accounts */
90			long RW; /* open LP for reading and writing */
91			long SB; /* short banner instead of normal header */
92			long SC; /* suppress multiple copies */
93			char SD; / spool directory */
94			long SF; /* suppress FF on each print job */
95			long SH; /* suppress header page */
96			char ST; / status file name */
97			char TF; / name of troff filter (per job) */
98			char TR; / trailer string to be output when Q empties */
99			char VF; / name of vplot filter (per job) */
100
101			char line[BUFSIZ];
102			int remote; /* true if sending files to a remote host */
103
104			static int compar(const void , const void );
105
106			/*
107			* Create a TCP connection to host "rhost" at port "rport".
108			* If rport == 0, then use the printer service port.
109			* Most of this code comes from rcmd.c.
110			*/
111			int
112			getport(char *rhost, int rport)
113			{
114			struct addrinfo hints, res, r;
115			u_int timo = 1;
116			int s, lport = IPPORT_RESERVED - 1;
117			int error;
118			int refuse, trial;
119			char pbuf[NI_MAXSERV];
120
121			/*
122			* Get the host address and port number to connect to.
123			*/
124			if (rhost == NULL)
125			fatal("no remote host to connect to");
126			memset(&hints, 0, sizeof(hints));
127			hints.ai_family = PF_UNSPEC;
128			hints.ai_socktype = SOCK_STREAM;
129			if (rport)
130			snprintf(pbuf, sizeof(pbuf), "%d", rport);
131			else
132			snprintf(pbuf, sizeof(pbuf), "printer");
133			siginterrupt(SIGINT, 1);
134			error = getaddrinfo(rhost, pbuf, &hints, &res);
135			siginterrupt(SIGINT, 0);
136			if (error)
137			fatal("printer/tcp: %s", gai_strerror(error));
138
139			/*
140			* Try connecting to the server.
141			*/
142			retry:
143			s = -1;
144			refuse = trial = 0;
145			for (r = res; r; r = r->ai_next) {
146			trial++;
147			retryport:
148			PRIV_START;
149			s = rresvport_af(&lport, r->ai_family);
150			PRIV_END;
151			if (s < 0) {
152			/* fall back to non-privileged port */
153			if (errno != EACCES \|\|
154			(s = socket(r->ai_family, SOCK_STREAM, 0)) < 0) {
155			freeaddrinfo(res);
156			return(-1);
157			}
158			}
159			siginterrupt(SIGINT, 1);
160			if (connect(s, r->ai_addr, r->ai_addrlen) < 0) {
161			error = errno;
162			siginterrupt(SIGINT, 0);
163			(void)close(s);
164			s = -1;
165			errno = error;
166			if (errno == EADDRINUSE) {
167			lport--;
168			goto retryport;
169			} else if (errno == ECONNREFUSED)
170			refuse++;
171			continue;
172			} else {
173			siginterrupt(SIGINT, 0);
174			break;
175			}
176			}
177			if (s < 0 && trial == refuse && timo <= 16) {
178			sleep(timo);
179			timo *= 2;
180			goto retry;
181			}
182			if (res)
183			freeaddrinfo(res);
184
185			/* Don't worry if we get an error from setsockopt(). */
186			trial = 1;
187			setsockopt(s, SOL_SOCKET, SO_KEEPALIVE, &trial, sizeof(trial));
188
189			return(s);
190			}
191
192			/*
193			* Getline reads a line from the control file cfp, removes tabs, converts
194			* new-line to null and leaves it in line.
195			* Returns 0 at EOF or the number of characters read.
196			*/
197			int
198			get_line(FILE *cfp)
199			{
200			int linel = 0;
201			char *lp = line;
202			int c;
203
204			while ((c = getc(cfp)) != '\n' && linel+1<sizeof(line)) {
205			if (c == EOF)
206			return(0);
207			if (c == '\t') {
208			do {
209			*lp++ = ' ';
210			linel++;
211			} while ((linel & 07) != 0 && linel+1 < sizeof(line));
212			continue;
213			}
214			*lp++ = c;
215			linel++;
216			}
217			*lp++ = '\0';
218			return(linel);
219			}
220
221			/*
222			* Scan the current directory and make a list of daemon files sorted by
223			* creation time.
224			* Return the number of entries and a pointer to the list.
225			*/
226			int
227			getq(struct queue ***namelist)
228			{
229			struct dirent *d;
230			struct queue q, *queue = NULL;
231			size_t nitems = 0, arraysz;
232			struct stat stbuf;
233			DIR *dirp;
234
235			PRIV_START;
236			dirp = opendir(SD);
237			PRIV_END;
238			if (dirp == NULL)
239			return(-1);
240			if (fstat(dirfd(dirp), &stbuf) < 0)
241			goto errdone;
242
243			/*
244			* Estimate the array size by taking the size of the directory file
245			* and dividing it by a multiple of the minimum size entry.
246			*/
247			arraysz = (stbuf.st_size / 24);
248			queue = calloc(arraysz, sizeof(struct queue *));
249			if (queue == NULL)
250			goto errdone;
251
252			while ((d = readdir(dirp)) != NULL) {
253			if (d->d_name[0] != 'c' \|\| d->d_name[1] != 'f')
254			continue; /* daemon control files only */
255			PRIV_START;
256			if (stat(d->d_name, &stbuf) < 0) {
257			PRIV_END;
258			continue; /* Doesn't exist */
259			}
260			PRIV_END;
261			q = malloc(sizeof(struct queue));
262			if (q == NULL)
263			goto errdone;
264			q->q_time = stbuf.st_mtime;
265			strlcpy(q->q_name, d->d_name, sizeof(q->q_name));
266
267			/*
268			* Check to make sure the array has space left and
269			* realloc the maximum size.
270			*/
271			if (nitems == arraysz) {
272			struct queue **newqueue;
273			newqueue = reallocarray(queue,
274			arraysz, 2 * sizeof(struct queue *));
275			if (newqueue == NULL) {
276			free(q);
277			goto errdone;
278			}
279			arraysz *= 2;
280			queue = newqueue;
281			}
282			queue[nitems++] = q;
283			}
284			closedir(dirp);
285			if (nitems)
286			qsort(queue, nitems, sizeof(struct queue *), compar);
287			*namelist = queue;
288			return(nitems);
289
290			errdone:
291			if (queue != NULL) {
292			while (nitems--)
293			free(queue[nitems]);
294			free(queue);
295			}
296			closedir(dirp);
297			return(-1);
298			}
299
300			/*
301			* Compare modification times.
302			*/
303			static int
304			compar(const void v1, const void v2)
305			{
306			struct queue p1 = (struct queue **)v1;
307			struct queue p2 = (struct queue **)v2;
308
309			return(p1->q_time - p2->q_time);
310			}
311
312			/*
313			* Figure out whether the local machine is the same
314			* as the remote machine (RM) entry (if it exists).
315			*/
316			char *
317			checkremote(void)
318			{
319			char lname[NI_MAXHOST], rname[NI_MAXHOST];
320			struct addrinfo hints, res, res0;
321			static char errbuf[128];
322			int error;
323			struct ifaddrs ifap, ifa;
324			const int niflags = NI_NUMERICHOST;
325			#ifdef __KAME__
326			struct sockaddr_in6 sin6;
327			struct sockaddr_in6 *sin6p;
328			#endif
329
330			remote = 0; /* assume printer is local on failure */
331
332			if (RM == NULL \|\| *RM == '\0')
333			return NULL;
334
335			/* get the local interface addresses */
336			siginterrupt(SIGINT, 1);
337			if (getifaddrs(&ifap) < 0) {
338			(void)snprintf(errbuf, sizeof(errbuf),
339			"unable to get local interface address: %s",
340			strerror(errno));
341			siginterrupt(SIGINT, 0);
342			return errbuf;
343			}
344			siginterrupt(SIGINT, 0);
345
346			/* get the remote host addresses (RM) */
347			memset(&hints, 0, sizeof(hints));
348			hints.ai_flags = AI_CANONNAME;
349			hints.ai_family = PF_UNSPEC;
350			hints.ai_socktype = SOCK_STREAM;
351			res = NULL;
352			siginterrupt(SIGINT, 1);
353			error = getaddrinfo(RM, NULL, &hints, &res0);
354			siginterrupt(SIGINT, 0);
355			if (error) {
356			(void)snprintf(errbuf, sizeof(errbuf),
357			"unable to resolve remote machine %s: %s",
358			RM, gai_strerror(error));
359			freeifaddrs(ifap);
360			return errbuf;
361			}
362
363			remote = 1; /* assume printer is remote */
364
365			for (res = res0; res; res = res->ai_next) {
366			siginterrupt(SIGINT, 1);
367			error = getnameinfo(res->ai_addr, res->ai_addrlen,
368			rname, sizeof(rname), NULL, 0, niflags);
369			siginterrupt(SIGINT, 0);
370			if (error != 0)
371			continue;
372			for (ifa = ifap; ifa; ifa = ifa->ifa_next) {
373			#ifdef __KAME__
374			sin6p = (struct sockaddr_in6 *)ifa->ifa_addr;
375			if (ifa->ifa_addr->sa_family == AF_INET6 &&
376			ifa->ifa_addr->sa_len == sizeof(sin6) &&
377			IN6_IS_ADDR_LINKLOCAL(&sin6p->sin6_addr) &&
378			(u_int16_t )&sin6p->sin6_addr.s6_addr[2]) {
379			/* kame scopeid hack */
380			memcpy(&sin6, ifa->ifa_addr, sizeof(sin6));
381			sin6.sin6_scope_id =
382			ntohs((u_int16_t )&sin6p->sin6_addr.s6_addr[2]);
383			sin6.sin6_addr.s6_addr[2] = 0;
384			sin6.sin6_addr.s6_addr[3] = 0;
385			siginterrupt(SIGINT, 1);
386			error = getnameinfo((struct sockaddr *)&sin6,
387			sin6.sin6_len, lname, sizeof(lname),
388			NULL, 0, niflags);
389			siginterrupt(SIGINT, 0);
390			if (error != 0)
391			continue;
392			} else
393			#endif
394			siginterrupt(SIGINT, 1);
395			error = getnameinfo(ifa->ifa_addr,
396			ifa->ifa_addr->sa_len, lname, sizeof(lname), NULL,
397			0, niflags);
398			siginterrupt(SIGINT, 0);
399			if (error != 0)
400			continue;
401
402			if (strcmp(rname, lname) == 0) {
403			remote = 0;
404			goto done;
405			}
406			}
407			}
408			done:
409			freeaddrinfo(res0);
410			freeifaddrs(ifap);
411			return NULL;
412			}
413
414			__dead void
415			fatal(const char *msg, ...)
416			{
417			extern char *__progname;
418			va_list ap;
419
420			va_start(ap, msg);
421			if (from != host)
422			(void)printf("%s: ", host);
423			(void)printf("%s: ", __progname);
424			if (printer)
425			(void)printf("%s: ", printer);
426			(void)vprintf(msg, ap);
427			va_end(ap);
428			(void)putchar('\n');
429			exit(1);
430			}
431
432			int
433			safe_open(const char *path, int flags, mode_t mode)
434			{
435			int fd, serrno;
436			struct stat stbuf;
437
438			if ((fd = open(path, flags\|O_NONBLOCK, mode)) < 0 \|\|
439			fstat(fd, &stbuf) < 0) {
440			if (fd >= 0) {
441			serrno = errno;
442			close(fd);
443			errno = serrno;
444			}
445			return (-1);
446			}
447			if (!S_ISREG(stbuf.st_mode)) {
448			close(fd);
449			errno = EACCES;
450			return (-1);
451			}
452			if (mode)
453			(void)fchmod(fd, mode);
454			return (fd);
455			}
456
457			/*
458			* Make sure there's some work to do before forking off a child - lpd
459			* Check to see if anything in queue - lpq
460			*/
461			int
462			ckqueue(char *cap)
463			{
464			struct dirent *d;
465			DIR *dirp;
466			char *spooldir;
467
468			if (cgetstr(cap, "sd", &spooldir) >= 0) {
469			dirp = opendir(spooldir);
470			free(spooldir);
471			} else
472			dirp = opendir(_PATH_DEFSPOOL);
473
474			if (dirp == NULL)
475			return (-1);
476			while ((d = readdir(dirp)) != NULL) {
477			if (d->d_name[0] == 'c' && d->d_name[1] == 'f') {
478			closedir(dirp);
479			return (1); /* found a cf file */
480			}
481			}
482			closedir(dirp);
483			return (0);
484			}