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 *
remote_host_name(FILE * fp)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
fatal(FILE * fp,char * fmt,...)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
cleanup(char *** files,char ** cf)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 **
parse_cf(papi_service_t svc,char * cf,char ** files)130 parse_cf(papi_service_t svc, char *cf, char **files)
131 {
132 papi_attribute_t **list = NULL;
133 char previous = '\0';
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
submit_job(papi_service_t svc,FILE * ifp,char * printer,int rid,char * cf,char ** files)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 *
receive_control_file(papi_service_t svc,FILE * ifp,FILE * ofp,int size)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 *
receive_data_file(FILE * ifp,FILE * ofp,int size)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
berkeley_receive_files(papi_service_t svc,FILE * ifp,FILE * ofp,char * printer)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 != '\0') && (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
berkeley_transfer_files(papi_service_t svc,FILE * ifp,FILE * ofp,char * printer)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
cyclical_service_check(char * svc_name)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
main(int ac,char * av[])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