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: lpd-cancel.c 155 2006-04-26 02:34:54Z ktou $ */
29
30#define	__EXTENSIONS__	/* for strtok_r() */
31#include <stdio.h>
32#include <stdlib.h>
33#include <unistd.h>
34#include <string.h>
35#include <papi_impl.h>
36
37papi_status_t
38lpd_cancel_job(service_t *svc, int id)
39{
40	papi_status_t status = PAPI_INTERNAL_ERROR;
41	int fd;
42	char *list[2];
43	char buf[128];	/* this should be overkill */
44
45	if (svc == NULL)
46		return (PAPI_BAD_ARGUMENT);
47
48	snprintf(buf, sizeof (buf), "%d", id);
49	list[0] = buf;
50	list[1] = NULL;
51
52	if ((fd = lpd_open(svc, 'c', list, 15)) < 0)
53		return (PAPI_INTERNAL_ERROR);
54
55	memset(buf, 0, sizeof (buf));
56	if (fdgets(buf, sizeof (buf), fd) != NULL) {
57		if (buf[0] == '\0')
58			status = PAPI_NOT_FOUND;
59		else if ((strstr(buf, "permission denied") != NULL) ||
60		    (strstr(buf, "not-authorized") != NULL))
61			status = PAPI_NOT_AUTHORIZED;
62		else if ((strstr(buf, "cancelled") != NULL) ||
63		    (strstr(buf, "removed") != NULL))
64			status = PAPI_OK;
65	} else
66		status = PAPI_NOT_FOUND;
67
68	close(fd);
69
70	return (status);
71}
72
73papi_status_t
74lpd_purge_jobs(service_t *svc, job_t ***jobs)
75{
76	papi_status_t status = PAPI_INTERNAL_ERROR;
77	int fd;
78	char *queue;
79	char buf[256];
80
81	if (svc == NULL)
82		return (PAPI_BAD_ARGUMENT);
83
84	if ((fd = lpd_open(svc, 'c', NULL, 15)) < 0)
85		return (PAPI_INTERNAL_ERROR);
86
87	queue = queue_name_from_uri(svc->uri);
88
89	status = PAPI_OK;
90	memset(buf, 0, sizeof (buf));
91	while (fdgets(buf, sizeof (buf), fd) != NULL) {
92		/* if we canceled it, add it to the list */
93		if ((strstr(buf, "cancelled") != NULL) ||
94		    (strstr(buf, "removed") != NULL)) {
95			job_t *job;
96			papi_attribute_t **attributes = NULL;
97			char *ptr, *iter = NULL;
98			int id;
99
100			ptr = strtok_r(buf, ":", &iter);
101			papiAttributeListAddString(&attributes, PAPI_ATTR_EXCL,
102			    "job-name", ptr);
103			id = atoi(ptr);
104			papiAttributeListAddInteger(&attributes, PAPI_ATTR_EXCL,
105			    "job-id", id);
106			papiAttributeListAddString(&attributes, PAPI_ATTR_EXCL,
107			    "job-printer", queue);
108
109			if ((job = (job_t *)calloc(1, (sizeof (*job))))
110			    != NULL) {
111				job->attributes = attributes;
112				list_append(jobs, job);
113			} else
114				papiAttributeListFree(attributes);
115		} else if (strstr(buf, "permission denied") != NULL)
116			status = PAPI_NOT_AUTHORIZED;
117	}
118	close(fd);
119
120	return (status);
121}
122