Home | History | Annotate | Download | only in bsd-sysv-commands
      1 /*
      2  * CDDL HEADER START
      3  *
      4  * The contents of this file are subject to the terms of the
      5  * Common Development and Distribution License (the "License").
      6  * You may not use this file except in compliance with the License.
      7  *
      8  * You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE
      9  * or http://www.opensolaris.org/os/licensing.
     10  * See the License for the specific language governing permissions
     11  * and limitations under the License.
     12  *
     13  * When distributing Covered Code, include this CDDL HEADER in each
     14  * file and include the License file at usr/src/OPENSOLARIS.LICENSE.
     15  * If applicable, add the following below this CDDL HEADER, with the
     16  * fields enclosed by brackets "[]" replaced with your own identifying
     17  * information: Portions Copyright [yyyy] [name of copyright owner]
     18  *
     19  * CDDL HEADER END
     20  */
     21 
     22 /*
     23  * Copyright 2009 Sun Microsystems, Inc.  All rights reserved.
     24  * Use is subject to license terms.
     25  *
     26  */
     27 
     28 /* $Id: in.lpd.c 170 2006-05-20 05:58:49Z njacobs $ */
     29 
     30 #include <stdio.h>
     31 #include <stdlib.h>
     32 #include <unistd.h>
     33 #include <fcntl.h>
     34 #include <stdarg.h>
     35 #include <string.h>
     36 #include <ctype.h>
     37 #include <errno.h>
     38 #include <syslog.h>
     39 #include <libintl.h>
     40 #include <pwd.h>
     41 #include <grp.h>
     42 #include <sys/types.h>
     43 #include <sys/stat.h>
     44 #include <sys/socket.h>
     45 #include <netinet/in.h>
     46 #include <arpa/inet.h>
     47 #include <netdb.h>
     48 #include <sys/systeminfo.h>
     49 
     50 #include <papi.h>
     51 #include <uri.h>
     52 #include "common.h"
     53 
     54 #define	ACK(fp)		{ (void) fputc('\0', fp); (void) fflush(fp); }
     55 #define	NACK(fp)	{ (void) fputc('\1', fp); (void) fflush(fp); }
     56 
     57 /*
     58  * This file contains the front-end of the BSD Print Protocol adaptor.  This
     59  * code assumes a BSD Socket interface to the networking side.
     60  */
     61 
     62 static char *
     63 remote_host_name(FILE *fp)
     64 {
     65 	struct hostent *hp;
     66 	struct sockaddr_in6 peer;
     67 	socklen_t peer_len = sizeof (peer);
     68 	int fd = fileno(fp);
     69 	int error_num;
     70 	char tmp_buf[INET6_ADDRSTRLEN];
     71 	char *hostname;
     72 
     73 	/* who is our peer ? */
     74 	if (getpeername(fd, (struct sockaddr *)&peer, &peer_len) < 0) {
     75 		if ((errno != ENOTSOCK) && (errno != EINVAL))
     76 			return (NULL);
     77 		else
     78 			return (strdup("localhost"));
     79 	}
     80 
     81 	/* get their name or return a string containing their address */
     82 	if ((hp = getipnodebyaddr((const char *)&peer.sin6_addr,
     83 	    sizeof (struct in6_addr), AF_INET6,
     84 	    &error_num)) == NULL) {
     85 		return (strdup(inet_ntop(peer.sin6_family,
     86 		    &peer.sin6_addr, tmp_buf, sizeof (tmp_buf))));
     87 	}
     88 
     89 	hostname = strdup(hp->h_name);
     90 	if (is_localhost(hp->h_name) != 0)
     91 		return (strdup("localhost"));
     92 
     93 	/* It must be someone else */
     94 	return (hostname);
     95 }
     96 
     97 static void
     98 fatal(FILE *fp, char *fmt, ...)
     99 {
    100 	va_list ap;
    101 
    102 	va_start(ap, fmt);
    103 	vsyslog(LOG_DEBUG, fmt, ap);
    104 	vfprintf(fp, fmt, ap);
    105 	va_end(ap);
    106 	exit(1);
    107 }
    108 
    109 static void
    110 cleanup(char ***files, char **cf)
    111 {
    112 	if (*files != NULL) {
    113 		int i;
    114 
    115 		for (i = 0; (*files)[i] != NULL; i++) {
    116 			(void) unlink((*files)[i]);
    117 			free((*files)[i]);
    118 		}
    119 		free(*files);
    120 		*files = NULL;
    121 	}
    122 
    123 	if (*cf != NULL) {
    124 		free(*cf);
    125 		*cf = NULL;
    126 	}
    127 }
    128 
    129 static papi_attribute_t **
    130 parse_cf(papi_service_t svc, char *cf, char **files)
    131 {
    132 	papi_attribute_t **list = NULL;
    133 	char	previous = NULL;
    134 	char	*entry;
    135 	int	copies_set = 0;
    136 	int	copies = 0;
    137 
    138 	for (entry = strtok(cf, "\n"); entry != NULL;
    139 	    entry = strtok(NULL, "\n")) {
    140 		char *format = NULL;
    141 
    142 		/* count the copies */
    143 		if ((entry[0] >= 'a') && (entry[0] <= 'z') &&
    144 		    (copies_set == 0) && (previous == entry[0]))
    145 			copies++;
    146 		else if ((previous >= 'a') && (previous <= 'z'))
    147 			copies_set = 1;
    148 		previous = entry[0];
    149 
    150 		/* process the control message */
    151 		switch (entry[0]) {
    152 		/* RFC-1179 options */
    153 		case 'J':	/* RFC-1179 Banner Job Name */
    154 			papiAttributeListAddString(&list, PAPI_ATTR_EXCL,
    155 			    "job-name", ++entry);
    156 			break;
    157 		case 'C':	/* RFC-1179 Banner Class Name */
    158 			papiAttributeListAddString(&list, PAPI_ATTR_EXCL,
    159 			    "rfc-1179-class", ++entry);
    160 			break;
    161 		case 'L':	/* RFC-1179 Banner toggle  */
    162 			papiAttributeListAddString(&list, PAPI_ATTR_EXCL,
    163 			    "job-sheets", "standard");
    164 			break;
    165 		case 'T':	/* RFC-1179 Title (pr)  */
    166 			papiAttributeListAddString(&list, PAPI_ATTR_EXCL,
    167 			    "pr-title", ++entry);
    168 			break;
    169 		case 'H':	/* RFC-1179 Host */
    170 			/*
    171 			 * use the host as known by us, not by them
    172 			 *
    173 			 * papiAttributeListAddString(&list, PAPI_ATTR_EXCL,
    174 			 *		"job-originating-host-name", ++entry);
    175 			 */
    176 			break;
    177 		case 'P':	/* RFC-1179 User */
    178 			++entry;
    179 			papiAttributeListAddString(&list, PAPI_ATTR_EXCL,
    180 			    "job-originating-user-name", entry);
    181 			papiServiceSetUserName(svc, entry);
    182 			break;
    183 		case 'M':	/* RFC-1179 Mail to User */
    184 			papiAttributeListAddBoolean(&list, PAPI_ATTR_EXCL,
    185 			    "rfc-1179-mail", 1);
    186 			break;
    187 		case 'W':	/* RFC-1179 Width (pr) */
    188 			papiAttributeListAddInteger(&list, PAPI_ATTR_EXCL,
    189 			    "pr-width", atoi(++entry));
    190 			break;
    191 		case 'I':	/* RFC-1179 Indent (pr) */
    192 			papiAttributeListAddInteger(&list, PAPI_ATTR_EXCL,
    193 			    "pr-indent", atoi(++entry));
    194 			break;
    195 		case 'N':	/* RFC-1179 Filename */
    196 			/* could have HPUX extension embedded */
    197 			if (entry[1] != ' ') {	/* real pathname */
    198 #ifdef DEBUG
    199 				papiAttributeListAddString(&list,
    200 				    PAPI_ATTR_EXCL,
    201 				    "flist", ++entry);
    202 #endif
    203 			} else if (entry[2] == 'O') /* HPUX lp -o options */
    204 				papiAttributeListFromString(&list,
    205 				    PAPI_ATTR_APPEND, ++entry);
    206 			break;
    207 		case 'U':	/* RFC-1179 Unlink */
    208 			break;	/* ignored */
    209 		case '1':	/* RFC-1179 TROFF Font R */
    210 			papiAttributeListAddString(&list, PAPI_ATTR_EXCL,
    211 			    "rfc-1179-font-r", ++entry);
    212 			break;
    213 		case '2':	/* RFC-1179 TROFF Font I */
    214 			papiAttributeListAddString(&list, PAPI_ATTR_EXCL,
    215 			    "rfc-1179-font-i", ++entry);
    216 			break;
    217 		case '3':	/* RFC-1179 TROFF Font B */
    218 			papiAttributeListAddString(&list, PAPI_ATTR_EXCL,
    219 			    "rfc-1179-font-b", ++entry);
    220 			break;
    221 		case '4':	/* RFC-1179 TROFF Font S */
    222 			papiAttributeListAddString(&list, PAPI_ATTR_EXCL,
    223 			    "rfc-1179-font-s", ++entry);
    224 			break;
    225 		case 'f':	/* RFC-1179 ASCII file (print) */
    226 			format = "text/plain";
    227 			if (is_postscript(files[0]) == 1)
    228 				format = "application/postscript";
    229 			break;
    230 		case 'l':	/* RFC-1179 CATV file (print) */
    231 			format = "application/octet-stream";
    232 			if (is_postscript(files[0]) == 1)
    233 				format = "application/postscript";
    234 			break;
    235 		case 'o':	/* RFC-1179 Postscript file (print) */
    236 			format = "application/postscript";
    237 			break;
    238 		case 'p':	/* RFC-1179 PR file (print) */
    239 			format = "application/x-pr";
    240 			papiAttributeListAddBoolean(&list, PAPI_ATTR_EXCL,
    241 			    "pr-filter", 1);
    242 			break;
    243 		case 't':	/* RFC-1179 TROFF file (print) */
    244 			format = "application/x-troff";
    245 			break;
    246 		case 'n':	/* RFC-1179 DITROFF file (print) */
    247 			format = "application/x-ditroff";
    248 			break;
    249 		case 'd':	/* RFC-1179 DVI file (print) */
    250 			format = "application/x-dvi";
    251 			break;
    252 		case 'g':	/* RFC-1179 GRAPH file (print) */
    253 			format = "application/x-plot";
    254 			break;
    255 		case 'c':	/* RFC-1179 CIF file (print) */
    256 			format = "application/x-cif";
    257 			break;
    258 		case 'v':	/* RFC-1179 RASTER file (print) */
    259 			format = "application/x-raster";
    260 			break;
    261 		case 'r':	/* RFC-1179 FORTRAN file (print) */
    262 			format = "application/x-fortran";
    263 			break;
    264 		/* Sun Solaris Extensions */
    265 		case 'O':
    266 			++entry;
    267 			{
    268 				int rd, wr;
    269 
    270 				for (rd = wr = 0; entry[rd] != '\0'; rd++) {
    271 					if (entry[rd] == '"')
    272 						continue;
    273 					if (rd != wr)
    274 						entry[wr] = entry[rd];
    275 					wr++;
    276 				}
    277 				entry[wr] = '\0';
    278 
    279 				papiAttributeListFromString(&list,
    280 				    PAPI_ATTR_APPEND, entry);
    281 			}
    282 			break;
    283 		case '5':
    284 			++entry;
    285 			switch (entry[0]) {
    286 			case 'f':	/* Solaris form */
    287 				papiAttributeListAddString(&list,
    288 				    PAPI_ATTR_EXCL,
    289 				    "form", ++entry);
    290 				break;
    291 			case 'H':	/* Solaris handling */
    292 				++entry;
    293 				if (strcasecmp(entry, "hold") == 0)
    294 					papiAttributeListAddString(&list,
    295 					    PAPI_ATTR_EXCL,
    296 					    "job-hold-until", "indefinite");
    297 				else if (strcasecmp(entry, "immediate") == 0)
    298 					papiAttributeListAddString(&list,
    299 					    PAPI_ATTR_EXCL,
    300 					    "job-hold-until", "no-hold");
    301 				else
    302 					papiAttributeListAddString(&list,
    303 					    PAPI_ATTR_EXCL,
    304 					    "job-hold-until", entry);
    305 				break;
    306 			case 'p':	/* Solaris notification */
    307 				papiAttributeListAddBoolean(&list,
    308 				    PAPI_ATTR_EXCL, "rfc-1179-mail", 1);
    309 				break;
    310 			case 'P': {	/* Solaris page list */
    311 				char buf[BUFSIZ];
    312 
    313 				snprintf(buf, sizeof (buf), "page-ranges=%s",
    314 				    ++entry);
    315 				papiAttributeListFromString(&list,
    316 				    PAPI_ATTR_EXCL, buf);
    317 				}
    318 				break;
    319 			case 'q': {	/* Solaris priority */
    320 				int i = atoi(++entry);
    321 
    322 				i = 100 - (i * 2.5);
    323 				if ((i < 1) || (i > 100))
    324 					i = 50;
    325 				papiAttributeListAddInteger(&list,
    326 				    PAPI_ATTR_EXCL, "job-priority", i);
    327 				}
    328 				break;
    329 			case 'S':	/* Solaris character set */
    330 				papiAttributeListAddString(&list,
    331 				    PAPI_ATTR_EXCL, "lp-charset",
    332 				    ++entry);
    333 				break;
    334 			case 'T':	/* Solaris type */
    335 				format = lp_type_to_mime_type(++entry);
    336 				break;
    337 			case 'y':	/* Solaris mode */
    338 				papiAttributeListAddString(&list,
    339 				    PAPI_ATTR_APPEND, "lp-modes", ++entry);
    340 				break;
    341 			default:
    342 				syslog(LOG_INFO|LOG_DEBUG,
    343 				    "Warning: cf message (%s) ignored",
    344 				    entry);
    345 				break;
    346 			}
    347 			break;
    348 		/* Undefined Extensions: SCO, Ultrix, AIX, ... */
    349 
    350 		default:
    351 			syslog(LOG_INFO|LOG_DEBUG,
    352 			    "Warning: cf message (%s) ignored", entry);
    353 			break;
    354 		}
    355 
    356 		if (format != NULL)
    357 			papiAttributeListAddString(&list, PAPI_ATTR_EXCL,
    358 			    "document-format", format);
    359 	}
    360 
    361 	papiAttributeListAddInteger(&list, PAPI_ATTR_EXCL,
    362 	    "copies", ++copies);
    363 	papiAttributeListAddString(&list, PAPI_ATTR_EXCL,
    364 	    "job-sheets", "none");
    365 
    366 	return (list);
    367 }
    368 
    369 static papi_status_t
    370 submit_job(papi_service_t svc, FILE *ifp, char *printer, int rid, char *cf,
    371 		char **files)
    372 {
    373 	papi_attribute_t **list = NULL;
    374 	papi_status_t status;
    375 	papi_job_t job = NULL;
    376 	char *format = "";
    377 
    378 	if ((list = parse_cf(svc, cf, files)) != NULL) {
    379 		/* use the host as known by us, not by them */
    380 		char *host = remote_host_name(ifp);
    381 
    382 		if (host != NULL) {
    383 			papiAttributeListAddString(&list, PAPI_ATTR_REPLACE,
    384 			    "job-originating-host-name", host);
    385 			free(host);
    386 		}
    387 		if (rid >= 0) {
    388 			papiAttributeListAddInteger(&list, PAPI_ATTR_EXCL,
    389 			    "job-id-requested", rid);
    390 		}
    391 	}
    392 
    393 	status = papiJobSubmit(svc, printer, list, NULL, files, &job);
    394 	syslog(LOG_DEBUG, "submit: %s", papiStatusString(status));
    395 	if (status != PAPI_OK) {
    396 		char *tmp = papiServiceGetStatusMessage(svc);
    397 
    398 		syslog(LOG_DEBUG, "submit-detail: %s", tmp ? tmp : "none");
    399 	}
    400 	papiJobFree(job);
    401 
    402 	return (status);
    403 }
    404 
    405 static char *
    406 receive_control_file(papi_service_t svc, FILE *ifp, FILE *ofp, int size)
    407 {
    408 	char *ptr, *cf_data;
    409 
    410 	if ((ptr = cf_data = calloc(1, size + 1)) == NULL) {
    411 		NACK(ofp);
    412 		return (NULL);
    413 	} else
    414 		ACK(ofp);
    415 
    416 	while (size > 0) {
    417 		int rc;
    418 
    419 		if (((rc = fread(ptr, 1, size, ifp)) == 0) &&
    420 		    (feof(ifp) != 0)) {
    421 			free(cf_data);
    422 			return (NULL);
    423 		} else {
    424 			ptr += rc;
    425 			size -= rc;
    426 		}
    427 	}
    428 	syslog(LOG_DEBUG, "cf_data(%s)", cf_data);
    429 
    430 	if (fgetc(ifp) != 0) {
    431 		free(cf_data);
    432 		return (NULL);
    433 	}
    434 	ACK(ofp);
    435 
    436 	return (cf_data);
    437 }
    438 
    439 static char *
    440 receive_data_file(FILE *ifp, FILE *ofp, int size)
    441 {
    442 	char file[] = "lpdXXXXXX";
    443 	char buf[BUFSIZ];
    444 	int fd;
    445 
    446 	if ((fd = mkstemp(file)) < 0) {
    447 		NACK(ofp);
    448 		return (NULL);
    449 	} else
    450 		ACK(ofp);
    451 
    452 	while (size > 0) {
    453 		int rc = ((size > BUFSIZ) ? BUFSIZ : size);
    454 
    455 		if (((rc = fread(buf, 1, rc, ifp)) == 0) &&
    456 		    (feof(ifp) != 0)) {
    457 			close(fd);
    458 			unlink(file);
    459 			return (NULL);
    460 		} else {
    461 			char *ptr = buf;
    462 
    463 			while (rc > 0) {
    464 				int wrc = write(fd, ptr, rc);
    465 
    466 				if (wrc < 0) {
    467 					close(fd);
    468 					unlink(file);
    469 					return (NULL);
    470 				}
    471 
    472 				ptr += wrc;
    473 				size -= wrc;
    474 				rc -= wrc;
    475 			}
    476 		}
    477 	}
    478 	close(fd);
    479 	if (fgetc(ifp) != 0) {
    480 		unlink(file);
    481 		return (NULL);
    482 	}
    483 	ACK(ofp);
    484 
    485 	return (strdup(file));
    486 }
    487 
    488 static papi_status_t
    489 berkeley_receive_files(papi_service_t svc, FILE *ifp, FILE *ofp, char *printer)
    490 {
    491 	papi_status_t status = PAPI_OK;
    492 	char *file, **files = NULL;	/* the job data files */
    493 	char *cf = NULL;
    494 	int rid = 0;
    495 	char buf[BUFSIZ];
    496 
    497 	while (fgets(buf, sizeof (buf), ifp) != NULL) {
    498 		int size;
    499 
    500 		syslog(LOG_DEBUG, "XFER CMD: (%d)%s\n", buf[0], &buf[1]);
    501 #ifdef DEBUG	/* translate [1-3]... messages to \[1-3] to run by hand */
    502 		if ((buf[0] > '0') && (buf[0] < '4'))
    503 			buf[0] -= '0';
    504 #endif
    505 		switch (buf[0]) {
    506 		case 0x01:	/* Abort */
    507 			cleanup(&files, &cf);
    508 			break;
    509 		case 0x02: {	/* Receive control file */
    510 			if (((cf = strchr(buf, ' ')) != NULL) &&
    511 			    (strlen(cf) > 4)) {
    512 				while ((*cf != NULL) && (isdigit(*cf) == 0))
    513 					cf++;
    514 				rid = atoi(cf);
    515 			}
    516 			cf = receive_control_file(svc, ifp, ofp, atoi(&buf[1]));
    517 			if (cf == NULL) {
    518 				cleanup(&files, &cf);
    519 				return (PAPI_BAD_REQUEST);
    520 			} else if (files != NULL) {
    521 				status = submit_job(svc, ifp, printer, rid, cf,
    522 				    files);
    523 				cleanup(&files, &cf);
    524 			}
    525 			}
    526 			break;
    527 		case 0x03: {	/* Receive data file */
    528 			file = receive_data_file(ifp, ofp, atoi(&buf[1]));
    529 			if (file == NULL) {
    530 				cleanup(&files, &cf);
    531 				return (PAPI_TEMPORARY_ERROR);
    532 			}
    533 			list_append(&files, file);
    534 			}
    535 			break;
    536 		default:
    537 			cleanup(&files, &cf);
    538 			fatal(ofp, "protocol screwup");
    539 			break;
    540 		}
    541 	}
    542 
    543 	if ((cf != NULL) && (files != NULL))
    544 		status = submit_job(svc, ifp, printer, rid, cf, files);
    545 
    546 	cleanup(&files, &cf);
    547 
    548 	return (status);
    549 }
    550 
    551 static papi_status_t
    552 berkeley_transfer_files(papi_service_t svc, FILE *ifp, FILE *ofp,
    553 		char *printer)
    554 {
    555 	papi_status_t status;
    556 	papi_printer_t p = NULL;
    557 	char *keys[] = { "printer-is-accepting-jobs", NULL };
    558 
    559 	status = papiPrinterQuery(svc, printer, keys, NULL, &p);
    560 	if ((status == PAPI_OK) && (p != NULL)) {
    561 		papi_attribute_t **attrs = papiPrinterGetAttributeList(p);
    562 		char accepting = PAPI_FALSE;
    563 
    564 		papiAttributeListGetBoolean(attrs, NULL,
    565 		    "printer-is-accepting-jobs", &accepting);
    566 
    567 		if (accepting == PAPI_TRUE) {
    568 			ACK(ofp);
    569 			status = berkeley_receive_files(svc, ifp, ofp, printer);
    570 		} else
    571 			NACK(ofp);
    572 
    573 		papiPrinterFree(p);
    574 	} else
    575 		NACK(ofp);
    576 
    577 	return (status);
    578 }
    579 
    580 static int
    581 cyclical_service_check(char *svc_name)
    582 {
    583 	papi_attribute_t **list;
    584 	uri_t *uri = NULL;
    585 	char *s = NULL;
    586 
    587 	/* was there a printer? */
    588 	if (svc_name == NULL)
    589 		return (0);
    590 
    591 	if ((list = getprinterbyname(svc_name, NULL)) == NULL)
    592 		return (0);	/* if it doesnt' resolve, we will fail later */
    593 
    594 	papiAttributeListGetString(list, NULL, "printer-uri-supported", &s);
    595 	if ((s == NULL) || (strcasecmp(svc_name, s) != 0))
    596 		return (0);	/* they don't match */
    597 
    598 	/* is it in uri form? */
    599 	if (uri_from_string(s, &uri) < 0)
    600 		return (0);
    601 
    602 	if ((uri == NULL) || (uri->scheme == NULL) || (uri->host == NULL)) {
    603 		uri_free(uri);
    604 		return (0);
    605 	}
    606 
    607 	/* is it in lpd form? */
    608 	if (strcasecmp(uri->scheme, "lpd") != 0) {
    609 		uri_free(uri);
    610 		return (0);
    611 	}
    612 
    613 	/* is it the local host? */
    614 	if (is_localhost(uri->host) != 0) {
    615 		uri_free(uri);
    616 		return (0);
    617 	}
    618 
    619 	uri_free(uri);
    620 	return (1);
    621 }
    622 
    623 
    624 /*
    625  * This is the entry point for this program.  The program takes the
    626  * following options:
    627  * 	(none)
    628  */
    629 int
    630 main(int ac, char *av[])
    631 {
    632 	papi_status_t status;
    633 	papi_service_t svc = NULL;
    634 	papi_encryption_t encryption = PAPI_ENCRYPT_NEVER;
    635 	FILE	*ifp = stdin;
    636 	FILE	*ofp = stdout;
    637 	int	c;
    638 	char	buf[BUFSIZ];
    639 	char	**args;
    640 	char	*printer;
    641 	char	*run_dir = "/var/run/in.lpd";
    642 	char	*run_user = NULL;
    643 	struct passwd *pw = NULL;
    644 
    645 	(void) chdir("/tmp");		/* run in /tmp by default */
    646 	openlog("bsd-gw", LOG_PID, LOG_LPR);
    647 
    648 	while ((c = getopt(ac, av, "Ed:u:")) != EOF)
    649 		switch (c) {
    650 		case 'E':
    651 			encryption = PAPI_ENCRYPT_ALWAYS;
    652 			break;
    653 		case 'd':	/* run where they tell you */
    654 			run_dir = optarg;
    655 			break;
    656 		case 'u':	/* run as */
    657 			run_user = optarg;
    658 			break;
    659 		default:
    660 			;
    661 		}
    662 
    663 	if (run_user != NULL)	/* get the requested user info */
    664 		pw = getpwnam(run_user);
    665 
    666 	if (run_dir != NULL) {	/* setup the run_dir */
    667 		(void) mkdir(run_dir, 0700);
    668 		if (pw != NULL)
    669 			(void) chown(run_dir, pw->pw_uid, pw->pw_gid);
    670 	}
    671 
    672 	if (pw != NULL) {	/* run as the requested user */
    673 		syslog(LOG_DEBUG, "name: %s, uid: %d, gid: %d",
    674 		    pw->pw_name, pw->pw_uid, pw->pw_gid);
    675 		initgroups(pw->pw_name, pw->pw_gid);
    676 		setgid(pw->pw_gid);
    677 		setuid(pw->pw_uid);
    678 	}
    679 
    680 	if (run_dir != NULL)	/* move to the run_dir */
    681 		if (chdir(run_dir) < 0) {
    682 			syslog(LOG_DEBUG, "failed to chdir(%s)", run_dir);
    683 			exit(1);
    684 		}
    685 
    686 	syslog(LOG_DEBUG, "$CWD = %s", getwd(NULL));
    687 
    688 	if (fgets(buf, sizeof (buf), ifp) == NULL) {
    689 		if (feof(ifp) == 0)
    690 			syslog(LOG_ERR, "Error reading from connection: %s",
    691 			    strerror(errno));
    692 		exit(1);
    693 	}
    694 
    695 	syslog(LOG_DEBUG, "CMD: (%d)%s\n", buf[0], &buf[1]);
    696 
    697 #ifdef DEBUG	/* translate [1-5]... messages to \[1-5] to run by hand */
    698 	if ((buf[0] > '0') && (buf[0] < '6'))
    699 		buf[0] -= '0';
    700 #endif
    701 
    702 	if ((buf[0] < 1) || (buf[0] > 5)) {
    703 		fatal(ofp, "Invalid protocol request (%d): %c%s\n",
    704 		    buf[0], buf[0], buf);
    705 		exit(1);
    706 	}
    707 
    708 	args = strsplit(&buf[1], "\t\n ");
    709 	printer = *args++;
    710 
    711 	if (printer == NULL) {
    712 		fatal(ofp, "Can't determine requested printer");
    713 		exit(1);
    714 	}
    715 
    716 	if (cyclical_service_check(printer) != 0) {
    717 		fatal(ofp, "%s is cyclical\n", printer);
    718 		exit(1);
    719 	}
    720 
    721 	status = papiServiceCreate(&svc, printer, NULL, NULL, NULL,
    722 	    encryption, NULL);
    723 	if (status != PAPI_OK) {
    724 		fatal(ofp, "Failed to contact service for %s: %s\n", printer,
    725 		    verbose_papi_message(svc, status));
    726 		exit(1);
    727 	}
    728 
    729 	/*
    730 	 * Trusted Solaris can't be trusting of intermediaries.  Pass
    731 	 * the socket connection to the print service to retrieve the
    732 	 * sensativity label off of a multi-level port.
    733 	 */
    734 	(void) papiServiceSetPeer(svc, fileno(ifp));
    735 
    736 	switch (buf[0]) {
    737 	case '\1':	/* restart printer */
    738 		ACK(ofp);	/* there is no equivalent */
    739 		break;
    740 	case '\2':	/* transfer job(s) */
    741 		status = berkeley_transfer_files(svc, ifp, ofp, printer);
    742 		break;
    743 	case '\3':	/* show queue (short) */
    744 	case '\4': {	/* show queue (long) */
    745 		int count;
    746 
    747 		for (count = 0; args[count] != 0; count++) {}
    748 
    749 		berkeley_queue_report(svc, ofp, printer, buf[0], count, args);
    750 		}
    751 		break;
    752 	case '\5': {	/* cancel job(s) */
    753 		char *user = *args++;
    754 		char *host = remote_host_name(ifp);
    755 		int count;
    756 
    757 		if (host != NULL) {
    758 			char buf[BUFSIZ];
    759 
    760 			snprintf(buf, sizeof (buf), "%s@%s", user, host);
    761 			status = papiServiceSetUserName(svc, buf);
    762 		} else
    763 			status = papiServiceSetUserName(svc, user);
    764 
    765 		for (count = 0; args[count] != 0; count++) {}
    766 
    767 		berkeley_cancel_request(svc, ofp, printer, count, args);
    768 		}
    769 		break;
    770 	default:
    771 		fatal(ofp, "unsupported protocol request (%c), %s",
    772 		    buf[0], &buf[1]);
    773 	}
    774 
    775 	(void) fflush(ofp);
    776 
    777 	syslog(LOG_DEBUG, "protocol request(%d) for %s completed: %s",
    778 	    buf[0], printer, papiStatusString(status));
    779 	if (status != PAPI_OK)
    780 		syslog(LOG_DEBUG, "detail: %s",
    781 		    verbose_papi_message(svc, status));
    782 
    783 	papiServiceDestroy(svc);
    784 
    785 	return (0);
    786 }
    787