]> git.ipfire.org Git - thirdparty/cups.git/blame - cups/snmp.c
Merge changes from CUPS 1.4svn-r8067 (tentative CUPS 1.4b1)
[thirdparty/cups.git] / cups / snmp.c
CommitLineData
91c84a35
MS
1/*
2 * "$Id$"
3 *
4 * SNMP functions for the Common UNIX Printing System (CUPS).
5 *
6 * Copyright 2007-2008 by Apple Inc.
7 * Copyright 2006-2007 by Easy Software Products, all rights reserved.
8 *
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/".
14 *
15 * This file is subject to the Apple OS-Developed Software exception.
16 *
17 * Contents:
18 *
7a14d768
MS
19 * _cupsSNMPClose() - Close a SNMP socket.
20 * _cupsSNMPCopyOID() - Copy an OID.
21 * _cupsSNMPDefaultCommunity() - Get the default SNMP community name.
22 * _cupsSNMPIsOID() - Test whether a SNMP response contains the
23 * specified OID.
24 * _cupsSNMPIsOIDPrefixed() - Test whether a SNMP response uses the
25 * specified OID prefix.
20fbc903 26 * _cupsSNMPOIDToString() - Convert an OID to a string.
7a14d768
MS
27 * _cupsSNMPOpen() - Open a SNMP socket.
28 * _cupsSNMPRead() - Read and parse a SNMP response.
29 * _cupsSNMPSetDebug() - Enable/disable debug logging to stderr.
20fbc903 30 * _cupsSNMPStringToOID() - Convert a numeric OID string to an OID array.
7a14d768
MS
31 * _cupsSNMPWalk() - Enumerate a group of OIDs.
32 * _cupsSNMPWrite() - Send an SNMP query packet.
33 * asn1_debug() - Decode an ASN1-encoded message.
34 * asn1_decode_snmp() - Decode a SNMP packet.
35 * asn1_encode_snmp() - Encode a SNMP packet.
36 * asn1_get_integer() - Get an integer value.
37 * asn1_get_length() - Get a value length.
38 * asn1_get_oid() - Get an OID value.
39 * asn1_get_packed() - Get a packed integer value.
40 * asn1_get_string() - Get a string value.
41 * asn1_get_type() - Get a value type.
42 * asn1_set_integer() - Set an integer value.
43 * asn1_set_length() - Set a value length.
44 * asn1_set_oid() - Set an OID value.
45 * asn1_set_packed() - Set a packed integer value.
46 * asn1_size_integer() - Figure out the number of bytes needed for an
47 * integer value.
48 * asn1_size_length() - Figure out the number of bytes needed for a
49 * length value.
50 * asn1_size_oid() - Figure out the numebr of bytes needed for an
51 * OID value.
52 * asn1_size_packed() - Figure out the number of bytes needed for a
53 * packed integer value.
54 * snmp_set_error() - Set the localized error for a packet.
91c84a35
MS
55 */
56
57/*
58 * Include necessary headers.
59 */
60
61#include "globals.h"
969307f0 62#include "debug.h"
7a14d768 63#include "snmp-private.h"
91c84a35
MS
64#include <errno.h>
65#ifdef HAVE_POLL
66# include <sys/poll.h>
67#endif /* HAVE_POLL */
68
69
70/*
71 * Local functions...
72 */
73
91c84a35
MS
74static void asn1_debug(const char *prefix, unsigned char *buffer,
75 size_t len, int indent);
ac884b6a
MS
76static int asn1_decode_snmp(unsigned char *buffer, size_t len,
77 cups_snmp_t *packet);
91c84a35
MS
78static int asn1_encode_snmp(unsigned char *buffer, size_t len,
79 cups_snmp_t *packet);
80static int asn1_get_integer(unsigned char **buffer,
81 unsigned char *bufend,
82 int length);
83static int asn1_get_oid(unsigned char **buffer,
84 unsigned char *bufend,
85 int length, int *oid, int oidsize);
86static int asn1_get_packed(unsigned char **buffer,
87 unsigned char *bufend);
88static char *asn1_get_string(unsigned char **buffer,
89 unsigned char *bufend,
90 int length, char *string,
91 int strsize);
92static int asn1_get_length(unsigned char **buffer,
93 unsigned char *bufend);
94static int asn1_get_type(unsigned char **buffer,
95 unsigned char *bufend);
96static void asn1_set_integer(unsigned char **buffer,
97 int integer);
98static void asn1_set_length(unsigned char **buffer,
99 int length);
100static void asn1_set_oid(unsigned char **buffer,
101 const int *oid);
102static void asn1_set_packed(unsigned char **buffer,
103 int integer);
104static int asn1_size_integer(int integer);
105static int asn1_size_length(int length);
106static int asn1_size_oid(const int *oid);
107static int asn1_size_packed(int integer);
108static void snmp_set_error(cups_snmp_t *packet,
109 const char *message);
110
111
112/*
7a14d768 113 * '_cupsSNMPClose()' - Close a SNMP socket.
91c84a35
MS
114 *
115 * @since CUPS 1.4@
116 */
117
118void
7a14d768 119_cupsSNMPClose(int fd) /* I - SNMP socket file descriptor */
91c84a35 120{
969307f0
MS
121 DEBUG_printf(("_cupsSNMPClose(fd=%d)\n", fd));
122
91c84a35
MS
123#ifdef WIN32
124 closesocket(fd);
125#else
126 close(fd);
127#endif /* WIN32 */
128}
129
130
131/*
7a14d768 132 * '_cupsSNMPCopyOID()' - Copy an OID.
ac884b6a
MS
133 *
134 * The array pointed to by "src" is terminated by the value -1.
135 *
136 * @since CUPS 1.4@
91c84a35
MS
137 */
138
139int * /* O - New OID */
7a14d768
MS
140_cupsSNMPCopyOID(int *dst, /* I - Destination OID */
141 const int *src, /* I - Source OID */
142 int dstsize) /* I - Number of integers in dst */
91c84a35
MS
143{
144 int i; /* Looping var */
145
146
969307f0
MS
147 DEBUG_printf(("_cupsSNMPCopyOID(dst=%p, src=%p, dstsize=%d)\n", dst, src,
148 dstsize));
149
ac884b6a 150 for (i = 0, dstsize --; src[i] >= 0 && i < dstsize; i ++)
91c84a35
MS
151 dst[i] = src[i];
152
ac884b6a 153 dst[i] = -1;
91c84a35
MS
154
155 return (dst);
156}
157
158
ac884b6a 159/*
7a14d768 160 * '_cupsSNMPDefaultCommunity()' - Get the default SNMP community name.
ac884b6a
MS
161 *
162 * The default community name is the first community name found in the
163 * snmp.conf file. If no community name is defined there, "public" is used.
164 *
165 * @since CUPS 1.4@
166 */
167
168const char * /* O - Default community name */
7a14d768 169_cupsSNMPDefaultCommunity(void)
ac884b6a
MS
170{
171 cups_file_t *fp; /* snmp.conf file */
172 char line[1024], /* Line from file */
173 *value; /* Value from file */
174 int linenum; /* Line number in file */
175 _cups_globals_t *cg = _cupsGlobals(); /* Global data */
176
177
969307f0
MS
178 DEBUG_puts("_cupsSNMPDefaultCommunity()");
179
ac884b6a
MS
180 if (!cg->snmp_community[0])
181 {
182 strlcpy(cg->snmp_community, "public", sizeof(cg->snmp_community));
183
184 snprintf(line, sizeof(line), "%s/snmp.conf", cg->cups_serverroot);
185 if ((fp = cupsFileOpen(line, "r")) != NULL)
186 {
187 linenum = 0;
188 while (cupsFileGetConf(fp, line, sizeof(line), &value, &linenum))
189 if (!strcasecmp(line, "Community") && value)
190 {
191 strlcpy(cg->snmp_community, value, sizeof(cg->snmp_community));
192 break;
193 }
194
195 cupsFileClose(fp);
196 }
197 }
198
969307f0
MS
199 DEBUG_printf(("_cupsSNMPDefaultCommunity: Returning \"%s\"\n",
200 cg->snmp_community));
201
ac884b6a
MS
202 return (cg->snmp_community);
203}
204
205
91c84a35 206/*
7a14d768 207 * '_cupsSNMPIsOID()' - Test whether a SNMP response contains the specified OID.
91c84a35 208 *
ac884b6a 209 * The array pointed to by "oid" is terminated by the value -1.
91c84a35
MS
210 *
211 * @since CUPS 1.4@
212 */
213
214int /* O - 1 if equal, 0 if not equal */
7a14d768
MS
215_cupsSNMPIsOID(cups_snmp_t *packet, /* I - Response packet */
216 const int *oid) /* I - OID */
91c84a35
MS
217{
218 int i; /* Looping var */
219
220
221 /*
222 * Range check input...
223 */
224
969307f0
MS
225 DEBUG_printf(("_cupsSNMPIsOID(packet=%p, oid=%p)\n", packet, oid));
226
91c84a35 227 if (!packet || !oid)
969307f0
MS
228 {
229 DEBUG_puts("_cupsSNMPIsOID: Returning 0");
230
91c84a35 231 return (0);
969307f0 232 }
91c84a35
MS
233
234 /*
235 * Compare OIDs...
236 */
237
ac884b6a
MS
238 for (i = 0;
239 i < CUPS_SNMP_MAX_OID && oid[i] >= 0 && packet->object_name[i] >= 0;
240 i ++)
91c84a35 241 if (oid[i] != packet->object_name[i])
969307f0
MS
242 {
243 DEBUG_puts("_cupsSNMPIsOID: Returning 0");
244
91c84a35 245 return (0);
969307f0
MS
246 }
247
248 DEBUG_printf(("_cupsSNMPIsOID: Returning %d\n",
249 i < CUPS_SNMP_MAX_OID && oid[i] == packet->object_name[i]));
91c84a35
MS
250
251 return (i < CUPS_SNMP_MAX_OID && oid[i] == packet->object_name[i]);
252}
253
254
255/*
7a14d768
MS
256 * '_cupsSNMPIsOIDPrefixed()' - Test whether a SNMP response uses the specified
257 * OID prefix.
91c84a35 258 *
ac884b6a 259 * The array pointed to by "prefix" is terminated by the value -1.
91c84a35
MS
260 *
261 * @since CUPS 1.4@
262 */
263
264int /* O - 1 if prefixed, 0 if not prefixed */
7a14d768 265_cupsSNMPIsOIDPrefixed(
91c84a35
MS
266 cups_snmp_t *packet, /* I - Response packet */
267 const int *prefix) /* I - OID prefix */
268{
269 int i; /* Looping var */
270
271
272 /*
273 * Range check input...
274 */
275
969307f0
MS
276 DEBUG_printf(("_cupsSNMPIsOIDPrefixed(packet=%p, prefix=%p)\n", packet,
277 prefix));
278
91c84a35 279 if (!packet || !prefix)
969307f0
MS
280 {
281 DEBUG_puts("_cupsSNMPIsOIDPrefixed: Returning 0");
282
91c84a35 283 return (0);
969307f0 284 }
91c84a35
MS
285
286 /*
287 * Compare OIDs...
288 */
289
290 for (i = 0;
ac884b6a 291 i < CUPS_SNMP_MAX_OID && prefix[i] >= 0 && packet->object_name[i] >= 0;
91c84a35
MS
292 i ++)
293 if (prefix[i] != packet->object_name[i])
969307f0
MS
294 {
295 DEBUG_puts("_cupsSNMPIsOIDPrefixed: Returning 0");
296
91c84a35 297 return (0);
969307f0
MS
298 }
299
300 DEBUG_printf(("_cupsSNMPIsOIDPrefixed: Returning %d\n",
301 i < CUPS_SNMP_MAX_OID));
91c84a35
MS
302
303 return (i < CUPS_SNMP_MAX_OID);
304}
305
306
20fbc903
MS
307/*
308 * '_cupsSNMPOIDToString()' - Convert an OID to a string.
309 *
310 * @since CUPS 1.4@
311 */
312
313
314char * /* O - New string or @code NULL@ on error */
315_cupsSNMPOIDToString(const int *src, /* I - OID */
316 char *dst, /* I - String buffer */
317 size_t dstsize) /* I - Size of string buffer */
318{
319 char *dstptr, /* Pointer into string buffer */
320 *dstend; /* End of string buffer */
321
322
323 DEBUG_printf(("_cupsSNMPOIDToString(src=%p, dst=%p, dstsize=" CUPS_LLFMT ")\n",
324 src, dst, CUPS_LLCAST dstsize));
325
326 /*
327 * Range check input...
328 */
329
330 if (!src || !dst || dstsize < 4)
331 return (NULL);
332
333 /*
334 * Loop through the OID array and build a string...
335 */
336
337 for (dstptr = dst, dstend = dstptr + dstsize - 1;
338 *src >= 0 && dstptr < dstend;
339 src ++, dstptr += strlen(dstptr))
340 snprintf(dstptr, dstend - dstptr + 1, ".%d", *src);
341
342 if (*src >= 0)
343 return (NULL);
344 else
345 return (dst);
346}
347
348
91c84a35 349/*
7a14d768 350 * '_cupsSNMPOpen()' - Open a SNMP socket.
91c84a35
MS
351 *
352 * @since CUPS 1.4@
353 */
354
355int /* O - SNMP socket file descriptor */
7a14d768 356_cupsSNMPOpen(int family) /* I - Address family - @code AF_INET@ or @code AF_INET6@ */
91c84a35
MS
357{
358 int fd; /* SNMP socket file descriptor */
359 int val; /* Socket option value */
360
361
362 /*
363 * Create the SNMP socket...
364 */
365
969307f0
MS
366 DEBUG_printf(("_cupsSNMPOpen(family=%d)\n", family));
367
ac884b6a 368 if ((fd = socket(family, SOCK_DGRAM, 0)) < 0)
969307f0
MS
369 {
370 DEBUG_printf(("_cupsSNMPOpen: Returning -1 (%s)\n", strerror(errno)));
371
91c84a35 372 return (-1);
969307f0 373 }
91c84a35
MS
374
375 /*
376 * Set the "broadcast" flag...
377 */
378
379 val = 1;
380
381 if (setsockopt(fd, SOL_SOCKET, SO_BROADCAST, &val, sizeof(val)))
382 {
969307f0
MS
383 DEBUG_printf(("_cupsSNMPOpen: Returning -1 (%s)\n", strerror(errno)));
384
91c84a35
MS
385 close(fd);
386
387 return (-1);
388 }
389
969307f0
MS
390 DEBUG_printf(("_cupsSNMPOpen: Returning %d\n", fd));
391
91c84a35
MS
392 return (fd);
393}
394
395
396/*
7a14d768 397 * '_cupsSNMPRead()' - Read and parse a SNMP response.
91c84a35 398 *
7a14d768 399 * If "timeout" is negative, @code _cupsSNMPRead@ will wait for a response
91c84a35
MS
400 * indefinitely.
401 *
402 * @since CUPS 1.4@
403 */
404
ac884b6a 405cups_snmp_t * /* O - SNMP packet or @code NULL@ if none */
7a14d768 406_cupsSNMPRead(int fd, /* I - SNMP socket file descriptor */
969307f0
MS
407 cups_snmp_t *packet, /* I - SNMP packet buffer */
408 double timeout) /* I - Timeout in seconds */
91c84a35
MS
409{
410 unsigned char buffer[CUPS_SNMP_MAX_PACKET];
411 /* Data packet */
412 int bytes; /* Number of bytes received */
413 socklen_t addrlen; /* Source address length */
ac884b6a 414 http_addr_t address; /* Source address */
91c84a35
MS
415
416
417 /*
418 * Range check input...
419 */
420
969307f0
MS
421 DEBUG_printf(("_cupsSNMPRead(fd=%d, packet=%p, timeout=%.1f)\n", fd, packet,
422 timeout));
423
91c84a35 424 if (fd < 0 || !packet)
969307f0
MS
425 {
426 DEBUG_puts("_cupsSNMPRead: Returning NULL");
427
91c84a35 428 return (NULL);
969307f0 429 }
91c84a35
MS
430
431 /*
432 * Optionally wait for a response...
433 */
434
568fa3fa 435 if (timeout >= 0.0)
91c84a35
MS
436 {
437 int ready; /* Data ready on socket? */
438#ifdef HAVE_POLL
439 struct pollfd pfd; /* Polled file descriptor */
440
441 pfd.fd = fd;
442 pfd.events = POLLIN;
443
568fa3fa
MS
444 while ((ready = poll(&pfd, 1, (int)(timeout * 1000.0))) < 0 &&
445 errno == EINTR);
91c84a35
MS
446
447#else
448 fd_set input_set; /* select() input set */
568fa3fa 449 struct timeval stimeout; /* select() timeout */
91c84a35
MS
450
451 do
452 {
453 FD_ZERO(&input_set);
454 FD_SET(fd, &input_set);
455
568fa3fa
MS
456 stimeout.tv_sec = (int)timeout;
457 stimeout.tv_usec = (int)((timeout - stimeout.tv_usec) * 1000000);
91c84a35 458
568fa3fa 459 ready = select(fd + 1, &input_set, NULL, NULL, &stimeout);
91c84a35
MS
460 }
461# ifdef WIN32
462 while (ready < 0 && WSAGetLastError() == WSAEINTR);
463# else
464 while (ready < 0 && errno == EINTR);
465# endif /* WIN32 */
466#endif /* HAVE_POLL */
467
468 /*
469 * If we don't have any data ready, return right away...
470 */
471
472 if (ready <= 0)
969307f0
MS
473 {
474 DEBUG_puts("_cupsSNMPRead: Returning NULL (timeout)");
475
91c84a35 476 return (NULL);
969307f0 477 }
91c84a35
MS
478 }
479
480 /*
481 * Read the response data...
482 */
483
ac884b6a 484 addrlen = sizeof(address);
91c84a35 485
ac884b6a
MS
486 if ((bytes = recvfrom(fd, buffer, sizeof(buffer), 0, (void *)&address,
487 &addrlen)) < 0)
969307f0
MS
488 {
489 DEBUG_printf(("_cupsSNMPRead: Returning NULL (%s)\n", strerror(errno)));
490
91c84a35 491 return (NULL);
969307f0 492 }
91c84a35
MS
493
494 /*
495 * Look for the response status code in the SNMP message header...
496 */
497
498 asn1_debug("DEBUG: IN ", buffer, bytes, 0);
499
500 asn1_decode_snmp(buffer, bytes, packet);
501
ac884b6a
MS
502 memcpy(&(packet->address), &address, sizeof(packet->address));
503
91c84a35
MS
504 /*
505 * Return decoded data packet...
506 */
507
969307f0
MS
508 DEBUG_puts("_cupsSNMPRead: Returning packet");
509
91c84a35
MS
510 return (packet);
511}
512
513
514/*
7a14d768 515 * '_cupsSNMPSetDebug()' - Enable/disable debug logging to stderr.
91c84a35
MS
516 *
517 * @since CUPS 1.4@
518 */
519
520void
7a14d768 521_cupsSNMPSetDebug(int level) /* I - 1 to enable debug output, 0 otherwise */
91c84a35
MS
522{
523 _cups_globals_t *cg = _cupsGlobals(); /* Global data */
524
525
969307f0
MS
526 DEBUG_printf(("_cupsSNMPSetDebug(level=%d)\n", level));
527
91c84a35
MS
528 cg->snmp_debug = level;
529}
530
531
20fbc903
MS
532/*
533 * '_cupsSNMPStringToOID()' - Convert a numeric OID string to an OID array.
534 *
535 * This function converts a string of the form ".N.N.N.N.N" to the
536 * corresponding OID array terminated by -1.
537 *
538 * @code NULL@ is returned if the array is not large enough or the string is
539 * not a valid OID number.
540 *
541 * @since CUPS 1.4@
542 */
543
544int * /* O - Pointer to OID array or @code NULL@ on error */
545_cupsSNMPStringToOID(const char *src, /* I - OID string */
546 int *dst, /* I - OID array */
547 int dstsize)/* I - Number of integers in OID array */
548{
549 int *dstptr, /* Pointer into OID array */
550 *dstend; /* End of OID array */
551
552
553 DEBUG_printf(("_cupsSNMPStringToOID(src=\"%s\", dst=%p, dstsize=%d)\n",
554 src, dst, dstsize));
555
556 /*
557 * Range check input...
558 */
559
560 if (!src || !dst || dstsize < 2)
561 return (NULL);
562
563 /*
564 * Skip leading "."...
565 */
566
567 if (*src == '.')
568 src ++;
569
570 /*
571 * Loop to the end of the string...
572 */
573
574 for (dstend = dst + dstsize - 1, dstptr = dst, *dstptr = 0;
575 *src && dstptr < dstend;
576 src ++)
577 {
578 if (*src == '.')
579 {
580 dstptr ++;
581 *dstptr = 0;
582 }
583 else if (isdigit(*src & 255))
584 *dstptr = *dstptr * 10 + *src - '0';
585 else
586 break;
587 }
588
589 if (*src)
590 return (NULL);
591
592 /*
593 * Terminate the end of the OID array and return...
594 */
595
596 dstptr[1] = -1;
597
598 return (dst);
599}
600
601
ac884b6a 602/*
7a14d768 603 * '_cupsSNMPWalk()' - Enumerate a group of OIDs.
ac884b6a
MS
604 *
605 * This function queries all of the OIDs with the specified OID prefix,
606 * calling the "cb" function for every response that is received.
607 *
608 * The array pointed to by "prefix" is terminated by the value -1.
609 *
7a14d768 610 * If "timeout" is negative, @code _cupsSNMPWalk@ will wait for a response
568fa3fa
MS
611 * indefinitely.
612 *
ac884b6a
MS
613 * @since CUPS 1.4@
614 */
615
616int /* O - Number of OIDs found or -1 on error */
7a14d768
MS
617_cupsSNMPWalk(int fd, /* I - SNMP socket */
618 http_addr_t *address, /* I - Address to query */
619 int version, /* I - SNMP version */
620 const char *community,/* I - Community name */
621 const int *prefix, /* I - OID prefix */
622 double timeout, /* I - Timeout for each response in seconds */
623 cups_snmp_cb_t cb, /* I - Function to call for each response */
624 void *data) /* I - User data pointer that is passed to the callback function */
ac884b6a
MS
625{
626 int count = 0; /* Number of OIDs found */
627 int request_id = 0; /* Current request ID */
628 cups_snmp_t packet; /* Current response packet */
629
630
631 /*
632 * Range check input...
633 */
634
969307f0
MS
635 DEBUG_printf(("_cupsSNMPWalk(fd=%d, address=%p, version=%d, "
636 "community=\"%s\", prefix=%p, timeout=%.1f, cb=%p, data=%p)\n",
637 fd, address, version, community ? community : "(null)",
638 prefix, timeout, cb, data));
639
ac884b6a
MS
640 if (fd < 0 || !address || version != CUPS_SNMP_VERSION_1 || !community ||
641 !prefix || !cb)
969307f0
MS
642 {
643 DEBUG_puts("_cupsSNMPWalk: Returning -1");
644
ac884b6a 645 return (-1);
969307f0 646 }
ac884b6a
MS
647
648 /*
649 * Copy the OID prefix and then loop until we have no more OIDs...
650 */
651
7a14d768 652 _cupsSNMPCopyOID(packet.object_name, prefix, CUPS_SNMP_MAX_OID);
ac884b6a
MS
653
654 for (;;)
655 {
656 request_id ++;
657
7a14d768 658 if (!_cupsSNMPWrite(fd, address, version, community,
ac884b6a
MS
659 CUPS_ASN1_GET_NEXT_REQUEST, request_id,
660 packet.object_name))
969307f0
MS
661 {
662 DEBUG_puts("_cupsSNMPWalk: Returning -1");
663
ac884b6a 664 return (-1);
969307f0 665 }
ac884b6a 666
7a14d768 667 if (!_cupsSNMPRead(fd, &packet, timeout))
969307f0
MS
668 {
669 DEBUG_puts("_cupsSNMPWalk: Returning -1");
670
ac884b6a 671 return (-1);
969307f0 672 }
ac884b6a 673
7a14d768 674 if (!_cupsSNMPIsOIDPrefixed(&packet, prefix))
969307f0
MS
675 {
676 DEBUG_printf(("_cupsSNMPWalk: Returning %d\n", count));
677
ac884b6a 678 return (count);
969307f0 679 }
ac884b6a
MS
680
681 if (packet.error || packet.error_status)
969307f0
MS
682 {
683 DEBUG_printf(("_cupsSNMPWalk: Returning %d\n", count > 0 ? count : -1));
684
ac884b6a 685 return (count > 0 ? count : -1);
969307f0 686 }
ac884b6a
MS
687
688 count ++;
689
690 (*cb)(&packet, data);
691 }
692}
693
694
91c84a35 695/*
7a14d768 696 * '_cupsSNMPWrite()' - Send an SNMP query packet.
91c84a35 697 *
ac884b6a 698 * The array pointed to by "oid" is terminated by the value -1.
91c84a35
MS
699 *
700 * @since CUPS 1.4@
701 */
702
703int /* O - 1 on success, 0 on error */
7a14d768 704_cupsSNMPWrite(
91c84a35
MS
705 int fd, /* I - SNMP socket */
706 http_addr_t *address, /* I - Address to send to */
707 int version, /* I - SNMP version */
708 const char *community, /* I - Community name */
709 cups_asn1_t request_type, /* I - Request type */
710 const unsigned request_id, /* I - Request ID */
711 const int *oid) /* I - OID */
712{
713 int i; /* Looping var */
714 cups_snmp_t packet; /* SNMP message packet */
715 unsigned char buffer[CUPS_SNMP_MAX_PACKET];
716 /* SNMP message buffer */
717 int bytes; /* Size of message */
1ff0402e 718 http_addr_t temp; /* Copy of address */
91c84a35
MS
719
720
ac884b6a
MS
721 /*
722 * Range check input...
723 */
724
969307f0
MS
725 DEBUG_printf(("_cupsSNMPWrite(fd=%d, address=%p, version=%d, "
726 "community=\"%s\", request_type=%d, request_id=%u, oid=%p)\n",
727 fd, address, version, community ? community : "(null)",
728 request_type, request_id, oid));
729
ac884b6a
MS
730 if (fd < 0 || !address || version != CUPS_SNMP_VERSION_1 || !community ||
731 (request_type != CUPS_ASN1_GET_REQUEST &&
732 request_type != CUPS_ASN1_GET_NEXT_REQUEST) || request_id < 1 || !oid)
969307f0
MS
733 {
734 DEBUG_puts("_cupsSNMPWrite: Returning 0 (bad arguments)");
735
ac884b6a 736 return (0);
969307f0 737 }
ac884b6a 738
91c84a35
MS
739 /*
740 * Create the SNMP message...
741 */
742
743 memset(&packet, 0, sizeof(packet));
744
745 packet.version = version;
746 packet.request_type = request_type;
747 packet.request_id = request_id;
748 packet.object_type = CUPS_ASN1_NULL_VALUE;
749
750 strlcpy(packet.community, community, sizeof(packet.community));
751
ac884b6a 752 for (i = 0; oid[i] >= 0 && i < (CUPS_SNMP_MAX_OID - 1); i ++)
91c84a35 753 packet.object_name[i] = oid[i];
ac884b6a
MS
754 packet.object_name[i] = -1;
755
756 if (oid[i] >= 0)
757 {
969307f0
MS
758 DEBUG_puts("_cupsSNMPWrite: Returning 0 (OID too big)");
759
ac884b6a
MS
760 errno = E2BIG;
761 return (0);
762 }
91c84a35
MS
763
764 bytes = asn1_encode_snmp(buffer, sizeof(buffer), &packet);
765
766 if (bytes < 0)
767 {
969307f0
MS
768 DEBUG_puts("_cupsSNMPWrite: Returning 0 (request too big)");
769
91c84a35 770 errno = E2BIG;
91c84a35
MS
771 return (0);
772 }
773
774 asn1_debug("DEBUG: OUT ", buffer, bytes, 0);
775
776 /*
777 * Send the message...
778 */
779
1ff0402e
MS
780 temp = *address;
781
91c84a35 782#ifdef AF_INET6
1ff0402e
MS
783 if (temp.addr.sa_family == AF_INET6)
784 temp.ipv6.sin6_port = htons(CUPS_SNMP_PORT);
91c84a35
MS
785 else
786#endif /* AF_INET6 */
1ff0402e 787 temp.ipv4.sin_port = htons(CUPS_SNMP_PORT);
91c84a35 788
1ff0402e
MS
789 return (sendto(fd, buffer, bytes, 0, (void *)&temp,
790 httpAddrLength(&temp)) == bytes);
91c84a35
MS
791}
792
793
ac884b6a
MS
794/*
795 * 'asn1_debug()' - Decode an ASN1-encoded message.
796 */
797
798static void
799asn1_debug(const char *prefix, /* I - Prefix string */
800 unsigned char *buffer, /* I - Buffer */
801 size_t len, /* I - Length of buffer */
802 int indent) /* I - Indentation */
803{
804 int i; /* Looping var */
805 unsigned char *bufend; /* End of buffer */
806 int integer; /* Number value */
807 int oid[CUPS_SNMP_MAX_OID]; /* OID value */
808 char string[CUPS_SNMP_MAX_STRING];
809 /* String value */
810 unsigned char value_type; /* Type of value */
811 int value_length; /* Length of value */
812 _cups_globals_t *cg = _cupsGlobals(); /* Global data */
813
814
815 if (cg->snmp_debug <= 0)
816 return;
817
818 if (cg->snmp_debug > 1 && indent == 0)
819 {
820 /*
821 * Do a hex dump of the packet...
822 */
823
824 int j;
825
826 fprintf(stderr, "%sHex Dump (%d bytes):\n", prefix, (int)len);
827
828 for (i = 0; i < len; i += 16)
829 {
830 fprintf(stderr, "%s%04x:", prefix, i);
831
832 for (j = 0; j < 16 && (i + j) < len; j ++)
833 {
834 if (j && !(j & 3))
835 fprintf(stderr, " %02x", buffer[i + j]);
836 else
837 fprintf(stderr, " %02x", buffer[i + j]);
838 }
839
840 while (j < 16)
841 {
842 if (j && !(j & 3))
843 fputs(" ", stderr);
844 else
845 fputs(" ", stderr);
846
847 j ++;
848 }
849
850 fputs(" ", stderr);
851
852 for (j = 0; j < 16 && (i + j) < len; j ++)
853 if (buffer[i + j] < ' ' || buffer[i + j] >= 0x7f)
854 putc('.', stderr);
855 else
856 putc(buffer[i + j], stderr);
857
858 putc('\n', stderr);
859 }
860 }
861
862 if (indent == 0)
863 fprintf(stderr, "%sMessage:\n", prefix);
864
865 bufend = buffer + len;
866
867 while (buffer < bufend)
868 {
869 /*
870 * Get value type...
871 */
872
873 value_type = asn1_get_type(&buffer, bufend);
874 value_length = asn1_get_length(&buffer, bufend);
875
876 switch (value_type)
877 {
878 case CUPS_ASN1_BOOLEAN :
879 integer = asn1_get_integer(&buffer, bufend, value_length);
880
881 fprintf(stderr, "%s%*sBOOLEAN %d bytes %d\n", prefix, indent, "",
882 value_length, integer);
883 break;
884
885 case CUPS_ASN1_INTEGER :
886 integer = asn1_get_integer(&buffer, bufend, value_length);
887
888 fprintf(stderr, "%s%*sINTEGER %d bytes %d\n", prefix, indent, "",
889 value_length, integer);
890 break;
891
892 case CUPS_ASN1_COUNTER :
893 integer = asn1_get_integer(&buffer, bufend, value_length);
894
895 fprintf(stderr, "%s%*sCOUNTER %d bytes %u\n", prefix, indent, "",
896 value_length, (unsigned)integer);
897 break;
898
899 case CUPS_ASN1_GAUGE :
900 integer = asn1_get_integer(&buffer, bufend, value_length);
901
902 fprintf(stderr, "%s%*sGAUGE %d bytes %u\n", prefix, indent, "",
903 value_length, (unsigned)integer);
904 break;
905
906 case CUPS_ASN1_TIMETICKS :
907 integer = asn1_get_integer(&buffer, bufend, value_length);
908
909 fprintf(stderr, "%s%*sTIMETICKS %d bytes %u\n", prefix, indent, "",
910 value_length, (unsigned)integer);
911 break;
912
913 case CUPS_ASN1_OCTET_STRING :
914 fprintf(stderr, "%s%*sOCTET STRING %d bytes \"%s\"\n", prefix,
915 indent, "", value_length,
916 asn1_get_string(&buffer, bufend, value_length, string,
917 sizeof(string)));
918 break;
919
920 case CUPS_ASN1_HEX_STRING :
921 asn1_get_string(&buffer, bufend, value_length, string,
922 sizeof(string));
923 fprintf(stderr, "%s%*sHex-STRING %d bytes", prefix,
924 indent, "", value_length);
925 for (i = 0; i < value_length; i ++)
926 fprintf(stderr, " %02X", string[i] & 255);
927 putc('\n', stderr);
928 break;
929
930 case CUPS_ASN1_NULL_VALUE :
931 fprintf(stderr, "%s%*sNULL VALUE %d bytes\n", prefix, indent, "",
932 value_length);
933
934 buffer += value_length;
935 break;
936
937 case CUPS_ASN1_OID :
938 integer = asn1_get_oid(&buffer, bufend, value_length, oid,
939 CUPS_SNMP_MAX_OID);
940
941 fprintf(stderr, "%s%*sOID %d bytes ", prefix, indent, "",
942 value_length);
943 for (i = 0; i < integer; i ++)
944 fprintf(stderr, ".%d", oid[i]);
945 putc('\n', stderr);
946 break;
947
948 case CUPS_ASN1_SEQUENCE :
949 fprintf(stderr, "%s%*sSEQUENCE %d bytes\n", prefix, indent, "",
950 value_length);
951 asn1_debug(prefix, buffer, value_length, indent + 4);
952
953 buffer += value_length;
954 break;
955
956 case CUPS_ASN1_GET_NEXT_REQUEST :
957 fprintf(stderr, "%s%*sGet-Next-Request-PDU %d bytes\n", prefix,
958 indent, "", value_length);
959 asn1_debug(prefix, buffer, value_length, indent + 4);
960
961 buffer += value_length;
962 break;
963
964 case CUPS_ASN1_GET_REQUEST :
965 fprintf(stderr, "%s%*sGet-Request-PDU %d bytes\n", prefix, indent, "",
966 value_length);
967 asn1_debug(prefix, buffer, value_length, indent + 4);
968
969 buffer += value_length;
970 break;
971
972 case CUPS_ASN1_GET_RESPONSE :
973 fprintf(stderr, "%s%*sGet-Response-PDU %d bytes\n", prefix, indent,
974 "", value_length);
975 asn1_debug(prefix, buffer, value_length, indent + 4);
976
977 buffer += value_length;
978 break;
979
980 default :
981 fprintf(stderr, "%s%*sUNKNOWN(%x) %d bytes\n", prefix, indent, "",
982 value_type, value_length);
983
984 buffer += value_length;
985 break;
986 }
987 }
988}
989
990
91c84a35
MS
991/*
992 * 'asn1_decode_snmp()' - Decode a SNMP packet.
993 */
994
995static int /* O - 0 on success, -1 on error */
996asn1_decode_snmp(unsigned char *buffer, /* I - Buffer */
997 size_t len, /* I - Size of buffer */
998 cups_snmp_t *packet) /* I - SNMP packet */
999{
1000 unsigned char *bufptr, /* Pointer into the data */
1001 *bufend; /* End of data */
1002 int length; /* Length of value */
1003
1004
1005 /*
1006 * Initialize the decoding...
1007 */
1008
1009 memset(packet, 0, sizeof(cups_snmp_t));
ac884b6a 1010 packet->object_name[0] = -1;
91c84a35
MS
1011
1012 bufptr = buffer;
1013 bufend = buffer + len;
1014
1015 if (asn1_get_type(&bufptr, bufend) != CUPS_ASN1_SEQUENCE)
1016 snmp_set_error(packet, _("Packet does not start with SEQUENCE"));
1017 else if (asn1_get_length(&bufptr, bufend) == 0)
1018 snmp_set_error(packet, _("SEQUENCE uses indefinite length"));
1019 else if (asn1_get_type(&bufptr, bufend) != CUPS_ASN1_INTEGER)
1020 snmp_set_error(packet, _("No version number"));
1021 else if ((length = asn1_get_length(&bufptr, bufend)) == 0)
1022 snmp_set_error(packet, _("Version uses indefinite length"));
1023 else if ((packet->version = asn1_get_integer(&bufptr, bufend, length))
1024 != CUPS_SNMP_VERSION_1)
1025 snmp_set_error(packet, _("Bad SNMP version number"));
1026 else if (asn1_get_type(&bufptr, bufend) != CUPS_ASN1_OCTET_STRING)
1027 snmp_set_error(packet, _("No community name"));
1028 else if ((length = asn1_get_length(&bufptr, bufend)) == 0)
1029 snmp_set_error(packet, _("Community name uses indefinite length"));
1030 else
1031 {
1032 asn1_get_string(&bufptr, bufend, length, packet->community,
1033 sizeof(packet->community));
1034
1035 if ((packet->request_type = asn1_get_type(&bufptr, bufend))
1036 != CUPS_ASN1_GET_RESPONSE)
1037 snmp_set_error(packet, _("Packet does not contain a Get-Response-PDU"));
1038 else if (asn1_get_length(&bufptr, bufend) == 0)
1039 snmp_set_error(packet, _("Get-Response-PDU uses indefinite length"));
1040 else if (asn1_get_type(&bufptr, bufend) != CUPS_ASN1_INTEGER)
1041 snmp_set_error(packet, _("No request-id"));
1042 else if ((length = asn1_get_length(&bufptr, bufend)) == 0)
1043 snmp_set_error(packet, _("request-id uses indefinite length"));
1044 else
1045 {
1046 packet->request_id = asn1_get_integer(&bufptr, bufend, length);
1047
1048 if (asn1_get_type(&bufptr, bufend) != CUPS_ASN1_INTEGER)
1049 snmp_set_error(packet, _("No error-status"));
1050 else if ((length = asn1_get_length(&bufptr, bufend)) == 0)
1051 snmp_set_error(packet, _("error-status uses indefinite length"));
1052 else
1053 {
1054 packet->error_status = asn1_get_integer(&bufptr, bufend, length);
1055
1056 if (asn1_get_type(&bufptr, bufend) != CUPS_ASN1_INTEGER)
1057 snmp_set_error(packet, _("No error-index"));
1058 else if ((length = asn1_get_length(&bufptr, bufend)) == 0)
1059 snmp_set_error(packet, _("error-index uses indefinite length"));
1060 else
1061 {
1062 packet->error_index = asn1_get_integer(&bufptr, bufend, length);
1063
1064 if (asn1_get_type(&bufptr, bufend) != CUPS_ASN1_SEQUENCE)
1065 snmp_set_error(packet, _("No variable-bindings SEQUENCE"));
1066 else if (asn1_get_length(&bufptr, bufend) == 0)
1067 snmp_set_error(packet,
1068 _("variable-bindings uses indefinite length"));
1069 else if (asn1_get_type(&bufptr, bufend) != CUPS_ASN1_SEQUENCE)
1070 snmp_set_error(packet, _("No VarBind SEQUENCE"));
1071 else if (asn1_get_length(&bufptr, bufend) == 0)
1072 snmp_set_error(packet, _("VarBind uses indefinite length"));
1073 else if (asn1_get_type(&bufptr, bufend) != CUPS_ASN1_OID)
1074 snmp_set_error(packet, _("No name OID"));
1075 else if ((length = asn1_get_length(&bufptr, bufend)) == 0)
1076 snmp_set_error(packet, _("Name OID uses indefinite length"));
1077 else
1078 {
1079 asn1_get_oid(&bufptr, bufend, length, packet->object_name,
1080 CUPS_SNMP_MAX_OID);
1081
1082 packet->object_type = asn1_get_type(&bufptr, bufend);
1083
1084 if ((length = asn1_get_length(&bufptr, bufend)) == 0 &&
1085 packet->object_type != CUPS_ASN1_NULL_VALUE &&
1086 packet->object_type != CUPS_ASN1_OCTET_STRING)
1087 snmp_set_error(packet, _("Value uses indefinite length"));
1088 else
1089 {
1090 switch (packet->object_type)
1091 {
1092 case CUPS_ASN1_BOOLEAN :
1093 packet->object_value.boolean =
1094 asn1_get_integer(&bufptr, bufend, length);
1095 break;
1096
1097 case CUPS_ASN1_INTEGER :
1098 packet->object_value.integer =
1099 asn1_get_integer(&bufptr, bufend, length);
1100 break;
1101
1102 case CUPS_ASN1_NULL_VALUE :
1103 break;
1104
1105 case CUPS_ASN1_OCTET_STRING :
1106 asn1_get_string(&bufptr, bufend, length,
1107 packet->object_value.string,
1108 CUPS_SNMP_MAX_STRING);
1109 break;
1110
1111 case CUPS_ASN1_OID :
1112 asn1_get_oid(&bufptr, bufend, length,
1113 packet->object_value.oid, CUPS_SNMP_MAX_OID);
1114 break;
1115
ac884b6a
MS
1116 case CUPS_ASN1_HEX_STRING :
1117 packet->object_value.hex_string.num_bytes = length;
1118
1119 asn1_get_string(&bufptr, bufend, length,
1120 (char *)packet->object_value.hex_string.bytes,
1121 CUPS_SNMP_MAX_STRING);
1122 break;
1123
91c84a35
MS
1124 case CUPS_ASN1_COUNTER :
1125 packet->object_value.counter =
1126 asn1_get_integer(&bufptr, bufend, length);
1127 break;
1128
1129 case CUPS_ASN1_GAUGE :
1130 packet->object_value.gauge =
1131 asn1_get_integer(&bufptr, bufend, length);
1132 break;
1133
ac884b6a
MS
1134 case CUPS_ASN1_TIMETICKS :
1135 packet->object_value.timeticks =
1136 asn1_get_integer(&bufptr, bufend, length);
1137 break;
1138
91c84a35
MS
1139 default :
1140 snmp_set_error(packet, _("Unsupported value type"));
1141 break;
1142 }
1143 }
1144 }
1145 }
1146 }
1147 }
1148 }
1149
1150 return (packet->error ? -1 : 0);
1151}
1152
1153
91c84a35
MS
1154/*
1155 * 'asn1_encode_snmp()' - Encode a SNMP packet.
1156 */
1157
1158static int /* O - Length on success, -1 on error */
1159asn1_encode_snmp(unsigned char *buffer, /* I - Buffer */
1160 size_t bufsize, /* I - Size of buffer */
1161 cups_snmp_t *packet) /* I - SNMP packet */
1162{
1163 unsigned char *bufptr; /* Pointer into buffer */
1164 int total, /* Total length */
1165 msglen, /* Length of entire message */
1166 commlen, /* Length of community string */
1167 reqlen, /* Length of request */
1168 listlen, /* Length of variable list */
1169 varlen, /* Length of variable */
1170 namelen, /* Length of object name OID */
1171 valuelen; /* Length of object value */
1172
1173
1174 /*
1175 * Get the lengths of the community string, OID, and message...
1176 */
1177
ac884b6a 1178
91c84a35
MS
1179 namelen = asn1_size_oid(packet->object_name);
1180
1181 switch (packet->object_type)
1182 {
1183 case CUPS_ASN1_NULL_VALUE :
1184 valuelen = 0;
1185 break;
1186
1187 case CUPS_ASN1_BOOLEAN :
1188 valuelen = asn1_size_integer(packet->object_value.boolean);
1189 break;
1190
1191 case CUPS_ASN1_INTEGER :
1192 valuelen = asn1_size_integer(packet->object_value.integer);
1193 break;
1194
1195 case CUPS_ASN1_OCTET_STRING :
1196 valuelen = strlen(packet->object_value.string);
1197 break;
1198
1199 case CUPS_ASN1_OID :
1200 valuelen = asn1_size_oid(packet->object_value.oid);
1201 break;
1202
1203 default :
1204 packet->error = "Unknown object type";
1205 return (-1);
1206 }
1207
1208 varlen = 1 + asn1_size_length(namelen) + namelen +
1209 1 + asn1_size_length(valuelen) + valuelen;
1210 listlen = 1 + asn1_size_length(varlen) + varlen;
1211 reqlen = 2 + asn1_size_integer(packet->request_id) +
1212 2 + asn1_size_integer(packet->error_status) +
1213 2 + asn1_size_integer(packet->error_index) +
1214 1 + asn1_size_length(listlen) + listlen;
1215 commlen = strlen(packet->community);
1216 msglen = 2 + asn1_size_integer(packet->version) +
1217 1 + asn1_size_length(commlen) + commlen +
1218 1 + asn1_size_length(reqlen) + reqlen;
1219 total = 1 + asn1_size_length(msglen) + msglen;
1220
1221 if (total > bufsize)
1222 {
1223 packet->error = "Message too large for buffer";
1224 return (-1);
1225 }
1226
1227 /*
1228 * Then format the message...
1229 */
1230
1231 bufptr = buffer;
1232
1233 *bufptr++ = CUPS_ASN1_SEQUENCE; /* SNMPv1 message header */
1234 asn1_set_length(&bufptr, msglen);
1235
1236 asn1_set_integer(&bufptr, packet->version);
1237 /* version */
1238
1239 *bufptr++ = CUPS_ASN1_OCTET_STRING; /* community */
1240 asn1_set_length(&bufptr, commlen);
1241 memcpy(bufptr, packet->community, commlen);
1242 bufptr += commlen;
1243
ac884b6a 1244 *bufptr++ = packet->request_type; /* Get-Request-PDU/Get-Next-Request-PDU */
91c84a35
MS
1245 asn1_set_length(&bufptr, reqlen);
1246
1247 asn1_set_integer(&bufptr, packet->request_id);
1248
1249 asn1_set_integer(&bufptr, packet->error_status);
1250
1251 asn1_set_integer(&bufptr, packet->error_index);
1252
1253 *bufptr++ = CUPS_ASN1_SEQUENCE; /* variable-bindings */
1254 asn1_set_length(&bufptr, listlen);
1255
1256 *bufptr++ = CUPS_ASN1_SEQUENCE; /* variable */
1257 asn1_set_length(&bufptr, varlen);
1258
1259 asn1_set_oid(&bufptr, packet->object_name);
1260 /* ObjectName */
1261
1262 switch (packet->object_type)
1263 {
1264 case CUPS_ASN1_NULL_VALUE :
1265 *bufptr++ = CUPS_ASN1_NULL_VALUE;
1266 /* ObjectValue */
1267 *bufptr++ = 0; /* Length */
1268 break;
1269
1270 case CUPS_ASN1_BOOLEAN :
1271 asn1_set_integer(&bufptr, packet->object_value.boolean);
1272 break;
1273
1274 case CUPS_ASN1_INTEGER :
1275 asn1_set_integer(&bufptr, packet->object_value.integer);
1276 break;
1277
1278 case CUPS_ASN1_OCTET_STRING :
1279 *bufptr++ = CUPS_ASN1_OCTET_STRING;
1280 asn1_set_length(&bufptr, valuelen);
1281 memcpy(bufptr, packet->object_value.string, valuelen);
1282 bufptr += valuelen;
1283 break;
1284
1285 case CUPS_ASN1_OID :
1286 asn1_set_oid(&bufptr, packet->object_value.oid);
1287 break;
1288
1289 default :
1290 break;
1291 }
1292
1293 return (bufptr - buffer);
1294}
1295
1296
1297/*
1298 * 'asn1_get_integer()' - Get an integer value.
1299 */
1300
1301static int /* O - Integer value */
1302asn1_get_integer(
1303 unsigned char **buffer, /* IO - Pointer in buffer */
1304 unsigned char *bufend, /* I - End of buffer */
1305 int length) /* I - Length of value */
1306{
1307 int value; /* Integer value */
1308
1309
1310 for (value = 0;
1311 length > 0 && *buffer < bufend;
1312 length --, (*buffer) ++)
1313 value = (value << 8) | **buffer;
1314
1315 return (value);
1316}
1317
1318
1319/*
1320 * 'asn1_get_length()' - Get a value length.
1321 */
1322
1323static int /* O - Length */
1324asn1_get_length(unsigned char **buffer, /* IO - Pointer in buffer */
1325 unsigned char *bufend) /* I - End of buffer */
1326{
1327 int length; /* Length */
1328
1329
1330 length = **buffer;
1331 (*buffer) ++;
1332
1333 if (length & 128)
1334 length = asn1_get_integer(buffer, bufend, length & 127);
1335
1336 return (length);
1337}
1338
1339
1340/*
1341 * 'asn1_get_oid()' - Get an OID value.
1342 */
1343
ac884b6a 1344static int /* O - Number of OIDs */
91c84a35
MS
1345asn1_get_oid(
1346 unsigned char **buffer, /* IO - Pointer in buffer */
1347 unsigned char *bufend, /* I - End of buffer */
1348 int length, /* I - Length of value */
1349 int *oid, /* I - OID buffer */
1350 int oidsize) /* I - Size of OID buffer */
1351{
1352 unsigned char *valend; /* End of value */
ac884b6a
MS
1353 int *oidptr, /* Current OID */
1354 *oidend; /* End of OID buffer */
91c84a35
MS
1355 int number; /* OID number */
1356
1357
1358 valend = *buffer + length;
ac884b6a 1359 oidptr = oid;
91c84a35
MS
1360 oidend = oid + oidsize - 1;
1361
1362 if (valend > bufend)
1363 valend = bufend;
1364
1365 number = asn1_get_packed(buffer, bufend);
1366
1367 if (number < 80)
1368 {
ac884b6a
MS
1369 *oidptr++ = number / 40;
1370 number = number % 40;
1371 *oidptr++ = number;
91c84a35
MS
1372 }
1373 else
1374 {
ac884b6a
MS
1375 *oidptr++ = 2;
1376 number -= 80;
1377 *oidptr++ = number;
91c84a35
MS
1378 }
1379
1380 while (*buffer < valend)
1381 {
1382 number = asn1_get_packed(buffer, bufend);
1383
ac884b6a
MS
1384 if (oidptr < oidend)
1385 *oidptr++ = number;
91c84a35
MS
1386 }
1387
ac884b6a 1388 *oidptr = -1;
91c84a35 1389
ac884b6a 1390 return (oidptr - oid);
91c84a35
MS
1391}
1392
1393
1394/*
1395 * 'asn1_get_packed()' - Get a packed integer value.
1396 */
1397
1398static int /* O - Value */
1399asn1_get_packed(
1400 unsigned char **buffer, /* IO - Pointer in buffer */
1401 unsigned char *bufend) /* I - End of buffer */
1402{
1403 int value; /* Value */
1404
1405
1406 value = 0;
1407
1408 while ((**buffer & 128) && *buffer < bufend)
1409 {
1410 value = (value << 7) | (**buffer & 127);
1411 (*buffer) ++;
1412 }
1413
1414 if (*buffer < bufend)
1415 {
1416 value = (value << 7) | **buffer;
1417 (*buffer) ++;
1418 }
1419
1420 return (value);
1421}
1422
1423
1424/*
1425 * 'asn1_get_string()' - Get a string value.
1426 */
1427
1428static char * /* O - String */
1429asn1_get_string(
1430 unsigned char **buffer, /* IO - Pointer in buffer */
1431 unsigned char *bufend, /* I - End of buffer */
1432 int length, /* I - Value length */
1433 char *string, /* I - String buffer */
1434 int strsize) /* I - String buffer size */
1435{
1436 if (length < 0)
1437 {
1438 /*
1439 * Disallow negative lengths!
1440 */
1441
1442 *string = '\0';
1443 }
1444 else if (length < strsize)
1445 {
1446 /*
1447 * String is smaller than the buffer...
1448 */
1449
1450 if (length > 0)
1451 memcpy(string, *buffer, length);
1452
1453 string[length] = '\0';
1454 }
1455 else
1456 {
1457 /*
1458 * String is larger than the buffer...
1459 */
1460
1461 memcpy(string, *buffer, strsize - 1);
1462 string[strsize - 1] = '\0';
1463 }
1464
1465 if (length > 0)
1466 (*buffer) += length;
1467
1468 return (length < 0 ? NULL : string);
1469}
1470
1471
1472/*
1473 * 'asn1_get_type()' - Get a value type.
1474 */
1475
1476static int /* O - Type */
1477asn1_get_type(unsigned char **buffer, /* IO - Pointer in buffer */
1478 unsigned char *bufend) /* I - End of buffer */
1479{
1480 int type; /* Type */
1481
1482
1483 type = **buffer;
1484 (*buffer) ++;
1485
1486 if ((type & 31) == 31)
1487 type = asn1_get_packed(buffer, bufend);
1488
1489 return (type);
1490}
1491
1492
1493/*
1494 * 'asn1_set_integer()' - Set an integer value.
1495 */
1496
1497static void
1498asn1_set_integer(unsigned char **buffer,/* IO - Pointer in buffer */
1499 int integer) /* I - Integer value */
1500{
1501 **buffer = CUPS_ASN1_INTEGER;
1502 (*buffer) ++;
1503
1504 if (integer > 0x7fffff || integer < -0x800000)
1505 {
1506 **buffer = 4;
1507 (*buffer) ++;
1508 **buffer = integer >> 24;
1509 (*buffer) ++;
1510 **buffer = integer >> 16;
1511 (*buffer) ++;
1512 **buffer = integer >> 8;
1513 (*buffer) ++;
1514 **buffer = integer;
1515 (*buffer) ++;
1516 }
1517 else if (integer > 0x7fff || integer < -0x8000)
1518 {
1519 **buffer = 3;
1520 (*buffer) ++;
1521 **buffer = integer >> 16;
1522 (*buffer) ++;
1523 **buffer = integer >> 8;
1524 (*buffer) ++;
1525 **buffer = integer;
1526 (*buffer) ++;
1527 }
1528 else if (integer > 0x7f || integer < -0x80)
1529 {
1530 **buffer = 2;
1531 (*buffer) ++;
1532 **buffer = integer >> 8;
1533 (*buffer) ++;
1534 **buffer = integer;
1535 (*buffer) ++;
1536 }
1537 else
1538 {
1539 **buffer = 1;
1540 (*buffer) ++;
1541 **buffer = integer;
1542 (*buffer) ++;
1543 }
1544}
1545
1546
1547/*
1548 * 'asn1_set_length()' - Set a value length.
1549 */
1550
1551static void
1552asn1_set_length(unsigned char **buffer, /* IO - Pointer in buffer */
1553 int length) /* I - Length value */
1554{
1555 if (length > 255)
1556 {
1557 **buffer = 0x82; /* 2-byte length */
1558 (*buffer) ++;
1559 **buffer = length >> 8;
1560 (*buffer) ++;
1561 **buffer = length;
1562 (*buffer) ++;
1563 }
1564 else if (length > 127)
1565 {
1566 **buffer = 0x81; /* 1-byte length */
1567 (*buffer) ++;
1568 **buffer = length;
1569 (*buffer) ++;
1570 }
1571 else
1572 {
1573 **buffer = length; /* Length */
1574 (*buffer) ++;
1575 }
1576}
1577
1578
1579/*
1580 * 'asn1_set_oid()' - Set an OID value.
1581 */
1582
1583static void
1584asn1_set_oid(unsigned char **buffer, /* IO - Pointer in buffer */
1585 const int *oid) /* I - OID value */
1586{
1587 **buffer = CUPS_ASN1_OID;
1588 (*buffer) ++;
1589
1590 asn1_set_length(buffer, asn1_size_oid(oid));
1591
ac884b6a
MS
1592 if (oid[1] < 0)
1593 {
1594 asn1_set_packed(buffer, oid[0] * 40);
1595 return;
1596 }
1597
91c84a35
MS
1598 asn1_set_packed(buffer, oid[0] * 40 + oid[1]);
1599
ac884b6a 1600 for (oid += 2; *oid >= 0; oid ++)
91c84a35
MS
1601 asn1_set_packed(buffer, *oid);
1602}
1603
1604
1605/*
1606 * 'asn1_set_packed()' - Set a packed integer value.
1607 */
1608
1609static void
1610asn1_set_packed(unsigned char **buffer, /* IO - Pointer in buffer */
1611 int integer) /* I - Integer value */
1612{
1613 if (integer > 0xfffffff)
1614 {
ac884b6a 1615 **buffer = ((integer >> 28) & 0x7f) | 0x80;
91c84a35
MS
1616 (*buffer) ++;
1617 }
1618
1619 if (integer > 0x1fffff)
1620 {
ac884b6a 1621 **buffer = ((integer >> 21) & 0x7f) | 0x80;
91c84a35
MS
1622 (*buffer) ++;
1623 }
1624
1625 if (integer > 0x3fff)
1626 {
ac884b6a 1627 **buffer = ((integer >> 14) & 0x7f) | 0x80;
91c84a35
MS
1628 (*buffer) ++;
1629 }
1630
1631 if (integer > 0x7f)
1632 {
ac884b6a 1633 **buffer = ((integer >> 7) & 0x7f) | 0x80;
91c84a35
MS
1634 (*buffer) ++;
1635 }
1636
1637 **buffer = integer & 0x7f;
1638 (*buffer) ++;
1639}
1640
1641
1642/*
1643 * 'asn1_size_integer()' - Figure out the number of bytes needed for an
1644 * integer value.
1645 */
1646
1647static int /* O - Size in bytes */
1648asn1_size_integer(int integer) /* I - Integer value */
1649{
1650 if (integer > 0x7fffff || integer < -0x800000)
1651 return (4);
1652 else if (integer > 0x7fff || integer < -0x8000)
1653 return (3);
1654 else if (integer > 0x7f || integer < -0x80)
1655 return (2);
1656 else
1657 return (1);
1658}
1659
1660
1661/*
1662 * 'asn1_size_length()' - Figure out the number of bytes needed for a
1663 * length value.
1664 */
1665
1666static int /* O - Size in bytes */
1667asn1_size_length(int length) /* I - Length value */
1668{
1669 if (length > 0xff)
1670 return (3);
1671 else if (length > 0x7f)
1672 return (2);
1673 else
1674 return (1);
1675}
1676
1677
1678/*
1679 * 'asn1_size_oid()' - Figure out the numebr of bytes needed for an
1680 * OID value.
1681 */
1682
1683static int /* O - Size in bytes */
1684asn1_size_oid(const int *oid) /* I - OID value */
1685{
1686 int length; /* Length of value */
1687
1688
ac884b6a
MS
1689 if (oid[1] < 0)
1690 return (asn1_size_packed(oid[0] * 40));
1691
1692 for (length = asn1_size_packed(oid[0] * 40 + oid[1]), oid += 2;
1693 *oid >= 0;
1694 oid ++)
91c84a35
MS
1695 length += asn1_size_packed(*oid);
1696
1697 return (length);
1698}
1699
1700
1701/*
1702 * 'asn1_size_packed()' - Figure out the number of bytes needed for a
1703 * packed integer value.
1704 */
1705
1706static int /* O - Size in bytes */
1707asn1_size_packed(int integer) /* I - Integer value */
1708{
1709 if (integer > 0xfffffff)
1710 return (5);
1711 else if (integer > 0x1fffff)
1712 return (4);
1713 else if (integer > 0x3fff)
1714 return (3);
1715 else if (integer > 0x7f)
1716 return (2);
1717 else
1718 return (1);
1719}
1720
1721
1722/*
1723 * 'snmp_set_error()' - Set the localized error for a packet.
1724 */
1725
1726static void
1727snmp_set_error(cups_snmp_t *packet, /* I - Packet */
1728 const char *message) /* I - Error message */
1729{
1730 _cups_globals_t *cg = _cupsGlobals(); /* Global data */
1731
1732
1733 if (!cg->lang_default)
1734 cg->lang_default = cupsLangDefault();
1735
1736 packet->error = _cupsLangString(cg->lang_default, message);
1737}
1738
1739
1740/*
1741 * End of "$Id$".
1742 */