/* * CDDL HEADER START * * The contents of this file are subject to the terms of the * Common Development and Distribution License (the "License"). * You may not use this file except in compliance with the License. * * You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE * or http://www.opensolaris.org/os/licensing. * See the License for the specific language governing permissions * and limitations under the License. * * When distributing Covered Code, include this CDDL HEADER in each * file and include the License file at usr/src/OPENSOLARIS.LICENSE. * If applicable, add the following below this CDDL HEADER, with the * fields enclosed by brackets "[]" replaced with your own identifying * information: Portions Copyright [yyyy] [name of copyright owner] * * CDDL HEADER END */ /* * Copyright 2009 Sun Microsystems, Inc. All rights reserved. * Use is subject to license terms. * */ /* $Id: in.lpd.c 170 2006-05-20 05:58:49Z njacobs $ */ #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include "common.h" #define ACK(fp) { (void) fputc('\0', fp); (void) fflush(fp); } #define NACK(fp) { (void) fputc('\1', fp); (void) fflush(fp); } /* * This file contains the front-end of the BSD Print Protocol adaptor. This * code assumes a BSD Socket interface to the networking side. */ static char * remote_host_name(FILE *fp) { struct hostent *hp; struct sockaddr_in6 peer; socklen_t peer_len = sizeof (peer); int fd = fileno(fp); int error_num; char tmp_buf[INET6_ADDRSTRLEN]; char *hostname; /* who is our peer ? */ if (getpeername(fd, (struct sockaddr *)&peer, &peer_len) < 0) { if ((errno != ENOTSOCK) && (errno != EINVAL)) return (NULL); else return (strdup("localhost")); } /* get their name or return a string containing their address */ if ((hp = getipnodebyaddr((const char *)&peer.sin6_addr, sizeof (struct in6_addr), AF_INET6, &error_num)) == NULL) { return (strdup(inet_ntop(peer.sin6_family, &peer.sin6_addr, tmp_buf, sizeof (tmp_buf)))); } hostname = strdup(hp->h_name); if (is_localhost(hp->h_name) != 0) return (strdup("localhost")); /* It must be someone else */ return (hostname); } static void fatal(FILE *fp, char *fmt, ...) { va_list ap; va_start(ap, fmt); vsyslog(LOG_DEBUG, fmt, ap); vfprintf(fp, fmt, ap); va_end(ap); exit(1); } static void cleanup(char ***files, char **cf) { if (*files != NULL) { int i; for (i = 0; (*files)[i] != NULL; i++) { (void) unlink((*files)[i]); free((*files)[i]); } free(*files); *files = NULL; } if (*cf != NULL) { free(*cf); *cf = NULL; } } static papi_attribute_t ** parse_cf(papi_service_t svc, char *cf, char **files) { papi_attribute_t **list = NULL; char previous = NULL; char *entry; int copies_set = 0; int copies = 0; for (entry = strtok(cf, "\n"); entry != NULL; entry = strtok(NULL, "\n")) { char *format = NULL; /* count the copies */ if ((entry[0] >= 'a') && (entry[0] <= 'z') && (copies_set == 0) && (previous == entry[0])) copies++; else if ((previous >= 'a') && (previous <= 'z')) copies_set = 1; previous = entry[0]; /* process the control message */ switch (entry[0]) { /* RFC-1179 options */ case 'J': /* RFC-1179 Banner Job Name */ papiAttributeListAddString(&list, PAPI_ATTR_EXCL, "job-name", ++entry); break; case 'C': /* RFC-1179 Banner Class Name */ papiAttributeListAddString(&list, PAPI_ATTR_EXCL, "rfc-1179-class", ++entry); break; case 'L': /* RFC-1179 Banner toggle */ papiAttributeListAddString(&list, PAPI_ATTR_EXCL, "job-sheets", "standard"); break; case 'T': /* RFC-1179 Title (pr) */ papiAttributeListAddString(&list, PAPI_ATTR_EXCL, "pr-title", ++entry); break; case 'H': /* RFC-1179 Host */ /* * use the host as known by us, not by them * * papiAttributeListAddString(&list, PAPI_ATTR_EXCL, * "job-originating-host-name", ++entry); */ break; case 'P': /* RFC-1179 User */ ++entry; papiAttributeListAddString(&list, PAPI_ATTR_EXCL, "job-originating-user-name", entry); papiServiceSetUserName(svc, entry); break; case 'M': /* RFC-1179 Mail to User */ papiAttributeListAddBoolean(&list, PAPI_ATTR_EXCL, "rfc-1179-mail", 1); break; case 'W': /* RFC-1179 Width (pr) */ papiAttributeListAddInteger(&list, PAPI_ATTR_EXCL, "pr-width", atoi(++entry)); break; case 'I': /* RFC-1179 Indent (pr) */ papiAttributeListAddInteger(&list, PAPI_ATTR_EXCL, "pr-indent", atoi(++entry)); break; case 'N': /* RFC-1179 Filename */ /* could have HPUX extension embedded */ if (entry[1] != ' ') { /* real pathname */ #ifdef DEBUG papiAttributeListAddString(&list, PAPI_ATTR_EXCL, "flist", ++entry); #endif } else if (entry[2] == 'O') /* HPUX lp -o options */ papiAttributeListFromString(&list, PAPI_ATTR_APPEND, ++entry); break; case 'U': /* RFC-1179 Unlink */ break; /* ignored */ case '1': /* RFC-1179 TROFF Font R */ papiAttributeListAddString(&list, PAPI_ATTR_EXCL, "rfc-1179-font-r", ++entry); break; case '2': /* RFC-1179 TROFF Font I */ papiAttributeListAddString(&list, PAPI_ATTR_EXCL, "rfc-1179-font-i", ++entry); break; case '3': /* RFC-1179 TROFF Font B */ papiAttributeListAddString(&list, PAPI_ATTR_EXCL, "rfc-1179-font-b", ++entry); break; case '4': /* RFC-1179 TROFF Font S */ papiAttributeListAddString(&list, PAPI_ATTR_EXCL, "rfc-1179-font-s", ++entry); break; case 'f': /* RFC-1179 ASCII file (print) */ format = "text/plain"; if (is_postscript(files[0]) == 1) format = "application/postscript"; break; case 'l': /* RFC-1179 CATV file (print) */ format = "application/octet-stream"; if (is_postscript(files[0]) == 1) format = "application/postscript"; break; case 'o': /* RFC-1179 Postscript file (print) */ format = "application/postscript"; break; case 'p': /* RFC-1179 PR file (print) */ format = "application/x-pr"; papiAttributeListAddBoolean(&list, PAPI_ATTR_EXCL, "pr-filter", 1); break; case 't': /* RFC-1179 TROFF file (print) */ format = "application/x-troff"; break; case 'n': /* RFC-1179 DITROFF file (print) */ format = "application/x-ditroff"; break; case 'd': /* RFC-1179 DVI file (print) */ format = "application/x-dvi"; break; case 'g': /* RFC-1179 GRAPH file (print) */ format = "application/x-plot"; break; case 'c': /* RFC-1179 CIF file (print) */ format = "application/x-cif"; break; case 'v': /* RFC-1179 RASTER file (print) */ format = "application/x-raster"; break; case 'r': /* RFC-1179 FORTRAN file (print) */ format = "application/x-fortran"; break; /* Sun Solaris Extensions */ case 'O': ++entry; { int rd, wr; for (rd = wr = 0; entry[rd] != '\0'; rd++) { if (entry[rd] == '"') continue; if (rd != wr) entry[wr] = entry[rd]; wr++; } entry[wr] = '\0'; papiAttributeListFromString(&list, PAPI_ATTR_APPEND, entry); } break; case '5': ++entry; switch (entry[0]) { case 'f': /* Solaris form */ papiAttributeListAddString(&list, PAPI_ATTR_EXCL, "form", ++entry); break; case 'H': /* Solaris handling */ ++entry; if (strcasecmp(entry, "hold") == 0) papiAttributeListAddString(&list, PAPI_ATTR_EXCL, "job-hold-until", "indefinite"); else if (strcasecmp(entry, "immediate") == 0) papiAttributeListAddString(&list, PAPI_ATTR_EXCL, "job-hold-until", "no-hold"); else papiAttributeListAddString(&list, PAPI_ATTR_EXCL, "job-hold-until", entry); break; case 'p': /* Solaris notification */ papiAttributeListAddBoolean(&list, PAPI_ATTR_EXCL, "rfc-1179-mail", 1); break; case 'P': { /* Solaris page list */ char buf[BUFSIZ]; snprintf(buf, sizeof (buf), "page-ranges=%s", ++entry); papiAttributeListFromString(&list, PAPI_ATTR_EXCL, buf); } break; case 'q': { /* Solaris priority */ int i = atoi(++entry); i = 100 - (i * 2.5); if ((i < 1) || (i > 100)) i = 50; papiAttributeListAddInteger(&list, PAPI_ATTR_EXCL, "job-priority", i); } break; case 'S': /* Solaris character set */ papiAttributeListAddString(&list, PAPI_ATTR_EXCL, "lp-charset", ++entry); break; case 'T': /* Solaris type */ format = lp_type_to_mime_type(++entry); break; case 'y': /* Solaris mode */ papiAttributeListAddString(&list, PAPI_ATTR_APPEND, "lp-modes", ++entry); break; default: syslog(LOG_INFO|LOG_DEBUG, "Warning: cf message (%s) ignored", entry); break; } break; /* Undefined Extensions: SCO, Ultrix, AIX, ... */ default: syslog(LOG_INFO|LOG_DEBUG, "Warning: cf message (%s) ignored", entry); break; } if (format != NULL) papiAttributeListAddString(&list, PAPI_ATTR_EXCL, "document-format", format); } papiAttributeListAddInteger(&list, PAPI_ATTR_EXCL, "copies", ++copies); papiAttributeListAddString(&list, PAPI_ATTR_EXCL, "job-sheets", "none"); return (list); } static papi_status_t submit_job(papi_service_t svc, FILE *ifp, char *printer, int rid, char *cf, char **files) { papi_attribute_t **list = NULL; papi_status_t status; papi_job_t job = NULL; char *format = ""; if ((list = parse_cf(svc, cf, files)) != NULL) { /* use the host as known by us, not by them */ char *host = remote_host_name(ifp); if (host != NULL) { papiAttributeListAddString(&list, PAPI_ATTR_REPLACE, "job-originating-host-name", host); free(host); } if (rid >= 0) { papiAttributeListAddInteger(&list, PAPI_ATTR_EXCL, "job-id-requested", rid); } } status = papiJobSubmit(svc, printer, list, NULL, files, &job); syslog(LOG_DEBUG, "submit: %s", papiStatusString(status)); if (status != PAPI_OK) { char *tmp = papiServiceGetStatusMessage(svc); syslog(LOG_DEBUG, "submit-detail: %s", tmp ? tmp : "none"); } papiJobFree(job); return (status); } static char * receive_control_file(papi_service_t svc, FILE *ifp, FILE *ofp, int size) { char *ptr, *cf_data; if ((ptr = cf_data = calloc(1, size + 1)) == NULL) { NACK(ofp); return (NULL); } else ACK(ofp); while (size > 0) { int rc; if (((rc = fread(ptr, 1, size, ifp)) == 0) && (feof(ifp) != 0)) { free(cf_data); return (NULL); } else { ptr += rc; size -= rc; } } syslog(LOG_DEBUG, "cf_data(%s)", cf_data); if (fgetc(ifp) != 0) { free(cf_data); return (NULL); } ACK(ofp); return (cf_data); } static char * receive_data_file(FILE *ifp, FILE *ofp, int size) { char file[] = "lpdXXXXXX"; char buf[BUFSIZ]; int fd; if ((fd = mkstemp(file)) < 0) { NACK(ofp); return (NULL); } else ACK(ofp); while (size > 0) { int rc = ((size > BUFSIZ) ? BUFSIZ : size); if (((rc = fread(buf, 1, rc, ifp)) == 0) && (feof(ifp) != 0)) { close(fd); unlink(file); return (NULL); } else { char *ptr = buf; while (rc > 0) { int wrc = write(fd, ptr, rc); if (wrc < 0) { close(fd); unlink(file); return (NULL); } ptr += wrc; size -= wrc; rc -= wrc; } } } close(fd); if (fgetc(ifp) != 0) { unlink(file); return (NULL); } ACK(ofp); return (strdup(file)); } static papi_status_t berkeley_receive_files(papi_service_t svc, FILE *ifp, FILE *ofp, char *printer) { papi_status_t status = PAPI_OK; char *file, **files = NULL; /* the job data files */ char *cf = NULL; int rid = 0; char buf[BUFSIZ]; while (fgets(buf, sizeof (buf), ifp) != NULL) { int size; syslog(LOG_DEBUG, "XFER CMD: (%d)%s\n", buf[0], &buf[1]); #ifdef DEBUG /* translate [1-3]... messages to \[1-3] to run by hand */ if ((buf[0] > '0') && (buf[0] < '4')) buf[0] -= '0'; #endif switch (buf[0]) { case 0x01: /* Abort */ cleanup(&files, &cf); break; case 0x02: { /* Receive control file */ if (((cf = strchr(buf, ' ')) != NULL) && (strlen(cf) > 4)) { while ((*cf != NULL) && (isdigit(*cf) == 0)) cf++; rid = atoi(cf); } cf = receive_control_file(svc, ifp, ofp, atoi(&buf[1])); if (cf == NULL) { cleanup(&files, &cf); return (PAPI_BAD_REQUEST); } else if (files != NULL) { status = submit_job(svc, ifp, printer, rid, cf, files); cleanup(&files, &cf); } } break; case 0x03: { /* Receive data file */ file = receive_data_file(ifp, ofp, atoi(&buf[1])); if (file == NULL) { cleanup(&files, &cf); return (PAPI_TEMPORARY_ERROR); } list_append(&files, file); } break; default: cleanup(&files, &cf); fatal(ofp, "protocol screwup"); break; } } if ((cf != NULL) && (files != NULL)) status = submit_job(svc, ifp, printer, rid, cf, files); cleanup(&files, &cf); return (status); } static papi_status_t berkeley_transfer_files(papi_service_t svc, FILE *ifp, FILE *ofp, char *printer) { papi_status_t status; papi_printer_t p = NULL; char *keys[] = { "printer-is-accepting-jobs", NULL }; status = papiPrinterQuery(svc, printer, keys, NULL, &p); if ((status == PAPI_OK) && (p != NULL)) { papi_attribute_t **attrs = papiPrinterGetAttributeList(p); char accepting = PAPI_FALSE; papiAttributeListGetBoolean(attrs, NULL, "printer-is-accepting-jobs", &accepting); if (accepting == PAPI_TRUE) { ACK(ofp); status = berkeley_receive_files(svc, ifp, ofp, printer); } else NACK(ofp); papiPrinterFree(p); } else NACK(ofp); return (status); } static int cyclical_service_check(char *svc_name) { papi_attribute_t **list; uri_t *uri = NULL; char *s = NULL; /* was there a printer? */ if (svc_name == NULL) return (0); if ((list = getprinterbyname(svc_name, NULL)) == NULL) return (0); /* if it doesnt' resolve, we will fail later */ papiAttributeListGetString(list, NULL, "printer-uri-supported", &s); if ((s == NULL) || (strcasecmp(svc_name, s) != 0)) return (0); /* they don't match */ /* is it in uri form? */ if (uri_from_string(s, &uri) < 0) return (0); if ((uri == NULL) || (uri->scheme == NULL) || (uri->host == NULL)) { uri_free(uri); return (0); } /* is it in lpd form? */ if (strcasecmp(uri->scheme, "lpd") != 0) { uri_free(uri); return (0); } /* is it the local host? */ if (is_localhost(uri->host) != 0) { uri_free(uri); return (0); } uri_free(uri); return (1); } /* * This is the entry point for this program. The program takes the * following options: * (none) */ int main(int ac, char *av[]) { papi_status_t status; papi_service_t svc = NULL; papi_encryption_t encryption = PAPI_ENCRYPT_NEVER; FILE *ifp = stdin; FILE *ofp = stdout; int c; char buf[BUFSIZ]; char **args; char *printer; char *run_dir = "/var/run/in.lpd"; char *run_user = NULL; struct passwd *pw = NULL; (void) chdir("/tmp"); /* run in /tmp by default */ openlog("bsd-gw", LOG_PID, LOG_LPR); while ((c = getopt(ac, av, "Ed:u:")) != EOF) switch (c) { case 'E': encryption = PAPI_ENCRYPT_ALWAYS; break; case 'd': /* run where they tell you */ run_dir = optarg; break; case 'u': /* run as */ run_user = optarg; break; default: ; } if (run_user != NULL) /* get the requested user info */ pw = getpwnam(run_user); if (run_dir != NULL) { /* setup the run_dir */ (void) mkdir(run_dir, 0700); if (pw != NULL) (void) chown(run_dir, pw->pw_uid, pw->pw_gid); } if (pw != NULL) { /* run as the requested user */ syslog(LOG_DEBUG, "name: %s, uid: %d, gid: %d", pw->pw_name, pw->pw_uid, pw->pw_gid); initgroups(pw->pw_name, pw->pw_gid); setgid(pw->pw_gid); setuid(pw->pw_uid); } if (run_dir != NULL) /* move to the run_dir */ if (chdir(run_dir) < 0) { syslog(LOG_DEBUG, "failed to chdir(%s)", run_dir); exit(1); } syslog(LOG_DEBUG, "$CWD = %s", getwd(NULL)); if (fgets(buf, sizeof (buf), ifp) == NULL) { if (feof(ifp) == 0) syslog(LOG_ERR, "Error reading from connection: %s", strerror(errno)); exit(1); } syslog(LOG_DEBUG, "CMD: (%d)%s\n", buf[0], &buf[1]); #ifdef DEBUG /* translate [1-5]... messages to \[1-5] to run by hand */ if ((buf[0] > '0') && (buf[0] < '6')) buf[0] -= '0'; #endif if ((buf[0] < 1) || (buf[0] > 5)) { fatal(ofp, "Invalid protocol request (%d): %c%s\n", buf[0], buf[0], buf); exit(1); } args = strsplit(&buf[1], "\t\n "); printer = *args++; if (printer == NULL) { fatal(ofp, "Can't determine requested printer"); exit(1); } if (cyclical_service_check(printer) != 0) { fatal(ofp, "%s is cyclical\n", printer); exit(1); } status = papiServiceCreate(&svc, printer, NULL, NULL, NULL, encryption, NULL); if (status != PAPI_OK) { fatal(ofp, "Failed to contact service for %s: %s\n", printer, verbose_papi_message(svc, status)); exit(1); } /* * Trusted Solaris can't be trusting of intermediaries. Pass * the socket connection to the print service to retrieve the * sensativity label off of a multi-level port. */ (void) papiServiceSetPeer(svc, fileno(ifp)); switch (buf[0]) { case '\1': /* restart printer */ ACK(ofp); /* there is no equivalent */ break; case '\2': /* transfer job(s) */ status = berkeley_transfer_files(svc, ifp, ofp, printer); break; case '\3': /* show queue (short) */ case '\4': { /* show queue (long) */ int count; for (count = 0; args[count] != 0; count++) {} berkeley_queue_report(svc, ofp, printer, buf[0], count, args); } break; case '\5': { /* cancel job(s) */ char *user = *args++; char *host = remote_host_name(ifp); int count; if (host != NULL) { char buf[BUFSIZ]; snprintf(buf, sizeof (buf), "%s@%s", user, host); status = papiServiceSetUserName(svc, buf); } else status = papiServiceSetUserName(svc, user); for (count = 0; args[count] != 0; count++) {} berkeley_cancel_request(svc, ofp, printer, count, args); } break; default: fatal(ofp, "unsupported protocol request (%c), %s", buf[0], &buf[1]); } (void) fflush(ofp); syslog(LOG_DEBUG, "protocol request(%d) for %s completed: %s", buf[0], printer, papiStatusString(status)); if (status != PAPI_OK) syslog(LOG_DEBUG, "detail: %s", verbose_papi_message(svc, status)); papiServiceDestroy(svc); return (0); }