4 * Common backend network APIs for CUPS.
6 * Copyright 2007-2014 by Apple Inc.
7 * Copyright 2006-2007 by Easy Software Products, all rights reserved.
9 * These coded instructions, statements, and computer programs are the
10 * property of Apple Inc. and are protected by Federal copyright
11 * law. Distribution and use rights are outlined in the file "LICENSE.txt"
12 * "LICENSE" which should have been included with this file. If this
13 * file is missing or damaged, see the license at "http://www.cups.org/".
15 * This file is subject to the Apple OS-Developed Software exception.
19 * Include necessary headers.
22 #include "backend-private.h"
24 #include <sys/select.h>
28 * 'backendCheckSideChannel()' - Check the side-channel for pending requests.
33 backendCheckSideChannel(
34 int snmp_fd
, /* I - SNMP socket */
35 http_addr_t
*addr
) /* I - Address of device */
37 fd_set input
; /* Select input set */
38 struct timeval timeout
; /* Select timeout */
42 FD_SET(CUPS_SC_FD
, &input
);
44 timeout
.tv_sec
= timeout
.tv_usec
= 0;
46 if (select(CUPS_SC_FD
+ 1, &input
, NULL
, NULL
, &timeout
) > 0)
47 backendNetworkSideCB(-1, -1, snmp_fd
, addr
, 0);
52 * 'backendNetworkSideCB()' - Handle common network side-channel commands.
55 int /* O - -1 on error, 0 on success */
57 int print_fd
, /* I - Print file or -1 */
58 int device_fd
, /* I - Device file or -1 */
59 int snmp_fd
, /* I - SNMP socket */
60 http_addr_t
*addr
, /* I - Address of device */
61 int use_bc
) /* I - Use back-channel data? */
63 cups_sc_command_t command
; /* Request command */
64 cups_sc_status_t status
; /* Request/response status */
65 char data
[65536]; /* Request/response data */
66 int datalen
; /* Request/response data size */
67 const char *device_id
; /* 1284DEVICEID env var */
70 datalen
= sizeof(data
);
72 if (cupsSideChannelRead(&command
, &status
, data
, &datalen
, 1.0))
77 case CUPS_SC_CMD_DRAIN_OUTPUT
:
79 * Our sockets disable the Nagle algorithm and data is sent immediately.
83 status
= CUPS_SC_STATUS_NOT_IMPLEMENTED
;
84 else if (backendDrainOutput(print_fd
, device_fd
))
85 status
= CUPS_SC_STATUS_IO_ERROR
;
87 status
= CUPS_SC_STATUS_OK
;
92 case CUPS_SC_CMD_GET_BIDI
:
93 status
= CUPS_SC_STATUS_OK
;
94 data
[0] = (char)use_bc
;
98 case CUPS_SC_CMD_SNMP_GET
:
99 case CUPS_SC_CMD_SNMP_GET_NEXT
:
100 fprintf(stderr
, "DEBUG: CUPS_SC_CMD_SNMP_%s: %d (%s)\n",
101 command
== CUPS_SC_CMD_SNMP_GET
? "GET" : "GET_NEXT", datalen
,
106 status
= CUPS_SC_STATUS_BAD_MESSAGE
;
113 char *dataptr
; /* Pointer into data */
114 cups_snmp_t packet
; /* Packet from printer */
115 const char *snmp_value
; /* CUPS_SNMP_VALUE env var */
117 if ((snmp_value
= getenv("CUPS_SNMP_VALUE")) != NULL
)
119 const char *snmp_count
; /* CUPS_SNMP_COUNT env var */
120 int count
; /* Repetition count */
122 if ((snmp_count
= getenv("CUPS_SNMP_COUNT")) != NULL
)
124 if ((count
= atoi(snmp_count
)) <= 0)
130 for (dataptr
= data
+ strlen(data
) + 1;
131 count
> 0 && dataptr
< (data
+ sizeof(data
) - 1);
132 count
--, dataptr
+= strlen(dataptr
))
133 strlcpy(dataptr
, snmp_value
, sizeof(data
) - (size_t)(dataptr
- data
));
135 fprintf(stderr
, "DEBUG: Returning %s %s\n", data
,
136 data
+ strlen(data
) + 1);
138 status
= CUPS_SC_STATUS_OK
;
139 datalen
= (int)(dataptr
- data
);
143 if (!_cupsSNMPStringToOID(data
, packet
.object_name
, CUPS_SNMP_MAX_OID
))
145 status
= CUPS_SC_STATUS_BAD_MESSAGE
;
150 status
= CUPS_SC_STATUS_IO_ERROR
;
153 if (_cupsSNMPWrite(snmp_fd
, addr
, CUPS_SNMP_VERSION_1
,
154 _cupsSNMPDefaultCommunity(),
155 command
== CUPS_SC_CMD_SNMP_GET
?
156 CUPS_ASN1_GET_REQUEST
:
157 CUPS_ASN1_GET_NEXT_REQUEST
, 1,
160 if (_cupsSNMPRead(snmp_fd
, &packet
, 1.0))
162 size_t i
; /* Looping var */
165 if (!_cupsSNMPOIDToString(packet
.object_name
, data
, sizeof(data
)))
167 fputs("DEBUG: Bad OID returned!\n", stderr
);
171 datalen
= (int)strlen(data
) + 1;
172 dataptr
= data
+ datalen
;
174 switch (packet
.object_type
)
176 case CUPS_ASN1_BOOLEAN
:
177 snprintf(dataptr
, sizeof(data
) - (size_t)(dataptr
- data
), "%d", packet
.object_value
.boolean
);
178 datalen
+= strlen(dataptr
);
181 case CUPS_ASN1_INTEGER
:
182 snprintf(dataptr
, sizeof(data
) - (size_t)(dataptr
- data
), "%d",
183 packet
.object_value
.integer
);
184 datalen
+= strlen(dataptr
);
187 case CUPS_ASN1_BIT_STRING
:
188 case CUPS_ASN1_OCTET_STRING
:
189 if (packet
.object_value
.string
.num_bytes
< (sizeof(data
) - (size_t)(dataptr
- data
)))
190 i
= packet
.object_value
.string
.num_bytes
;
192 i
= sizeof(data
) - (size_t)(dataptr
- data
);
194 memcpy(dataptr
, packet
.object_value
.string
.bytes
, i
);
200 _cupsSNMPOIDToString(packet
.object_value
.oid
, dataptr
,
201 sizeof(data
) - (size_t)(dataptr
- data
));
202 datalen
+= strlen(dataptr
);
205 case CUPS_ASN1_HEX_STRING
:
207 i
< packet
.object_value
.string
.num_bytes
&&
208 dataptr
< (data
+ sizeof(data
) - 3);
210 sprintf(dataptr
, "%02X", packet
.object_value
.string
.bytes
[i
]);
211 datalen
+= strlen(dataptr
);
214 case CUPS_ASN1_COUNTER
:
215 snprintf(dataptr
, sizeof(data
) - (size_t)(dataptr
- data
), "%u", packet
.object_value
.counter
);
216 datalen
+= strlen(dataptr
);
219 case CUPS_ASN1_GAUGE
:
220 snprintf(dataptr
, sizeof(data
) - (size_t)(dataptr
- data
), "%u", packet
.object_value
.gauge
);
221 datalen
+= strlen(dataptr
);
224 case CUPS_ASN1_TIMETICKS
:
225 snprintf(dataptr
, sizeof(data
) - (size_t)(dataptr
- data
), "%u", packet
.object_value
.timeticks
);
226 datalen
+= strlen(dataptr
);
230 fprintf(stderr
, "DEBUG: Unknown OID value type %02X.\n", packet
.object_type
);
232 case CUPS_ASN1_NULL_VALUE
:
237 fprintf(stderr
, "DEBUG: Returning %s %s\n", data
, data
+ datalen
);
239 status
= CUPS_SC_STATUS_OK
;
242 fputs("DEBUG: SNMP read error...\n", stderr
);
245 fputs("DEBUG: SNMP write error...\n", stderr
);
249 status
= CUPS_SC_STATUS_NOT_IMPLEMENTED
;
253 case CUPS_SC_CMD_GET_DEVICE_ID
:
256 cups_snmp_t packet
; /* Packet from printer */
257 static const int ppmPrinterIEEE1284DeviceId
[] =
258 { CUPS_OID_ppmPrinterIEEE1284DeviceId
,1,-1 };
261 status
= CUPS_SC_STATUS_IO_ERROR
;
264 if (_cupsSNMPWrite(snmp_fd
, addr
, CUPS_SNMP_VERSION_1
,
265 _cupsSNMPDefaultCommunity(),
266 CUPS_ASN1_GET_REQUEST
, 1,
267 ppmPrinterIEEE1284DeviceId
))
269 if (_cupsSNMPRead(snmp_fd
, &packet
, 1.0) &&
270 packet
.object_type
== CUPS_ASN1_OCTET_STRING
)
272 strlcpy(data
, (char *)packet
.object_value
.string
.bytes
,
274 datalen
= (int)strlen(data
);
275 status
= CUPS_SC_STATUS_OK
;
282 if ((device_id
= getenv("1284DEVICEID")) != NULL
)
284 strlcpy(data
, device_id
, sizeof(data
));
285 datalen
= (int)strlen(data
);
286 status
= CUPS_SC_STATUS_OK
;
290 case CUPS_SC_CMD_GET_CONNECTED
:
291 status
= CUPS_SC_STATUS_OK
;
292 data
[0] = device_fd
!= -1;
297 status
= CUPS_SC_STATUS_NOT_IMPLEMENTED
;
302 return (cupsSideChannelWrite(command
, status
, data
, datalen
, 1.0));