ViewVC Help
View File | Revision Log | Show Annotations | Download File
/cvs/Convert-BER-XS/XS.xs
(Generate patch)

Comparing Convert-BER-XS/XS.xs (file contents):
Revision 1.19 by root, Sat Apr 20 16:34:34 2019 UTC vs.
Revision 1.33 by root, Thu Apr 25 22:30:21 2019 UTC

1#include "EXTERN.h" 1#include "EXTERN.h"
2#include "perl.h" 2#include "perl.h"
3#include "XSUB.h" 3#include "XSUB.h"
4
5#include <math.h>
4 6
5// C99 required! 7// C99 required!
6// this is not just for comments, but also for 8// this is not just for comments, but also for
7// integer constant semantics, 9// integer constant semantics,
8// sscanf format modifiers and more. 10// sscanf format modifiers and more.
58 ASN_CLASS_SHIFT = 6, 60 ASN_CLASS_SHIFT = 6,
59 61
60 // ASN_APPLICATION SNMP 62 // ASN_APPLICATION SNMP
61 SNMP_IPADDRESS = 0x00, 63 SNMP_IPADDRESS = 0x00,
62 SNMP_COUNTER32 = 0x01, 64 SNMP_COUNTER32 = 0x01,
65 SNMP_GAUGE32 = 0x02,
63 SNMP_UNSIGNED32 = 0x02, 66 SNMP_UNSIGNED32 = 0x02,
64 SNMP_TIMETICKS = 0x03, 67 SNMP_TIMETICKS = 0x03,
65 SNMP_OPAQUE = 0x04, 68 SNMP_OPAQUE = 0x04,
66 SNMP_COUNTER64 = 0x06, 69 SNMP_COUNTER64 = 0x06,
67}; 70};
68 71
72// tlow-level types this module can ecode the above (and more) into
69enum { 73enum {
70 BER_TYPE_BYTES, 74 BER_TYPE_BYTES,
71 BER_TYPE_UTF8, 75 BER_TYPE_UTF8,
72 BER_TYPE_UCS2, 76 BER_TYPE_UCS2,
73 BER_TYPE_UCS4, 77 BER_TYPE_UCS4,
79 BER_TYPE_REAL, 83 BER_TYPE_REAL,
80 BER_TYPE_IPADDRESS, 84 BER_TYPE_IPADDRESS,
81 BER_TYPE_CROAK, 85 BER_TYPE_CROAK,
82}; 86};
83 87
88// tuple array indices
84enum { 89enum {
85 BER_CLASS = 0, 90 BER_CLASS = 0,
86 BER_TAG = 1, 91 BER_TAG = 1,
87 BER_FLAGS = 2, 92 BER_FLAGS = 2,
88 BER_DATA = 3, 93 BER_DATA = 3,
99 104
100#if PERL_VERSION < 18 105#if PERL_VERSION < 18
101# define utf8_to_uvchr_buf(s,e,l) utf8_to_uvchr (s, l) 106# define utf8_to_uvchr_buf(s,e,l) utf8_to_uvchr (s, l)
102#endif 107#endif
103 108
109#ifndef SvREFCNT_inc_NN
110#define SvREFCNT_inc_NN(x) SvREFCNT_inc (x)
111#endif
112#ifndef SvREFCNT_dec_NN
113#define SvREFCNT_dec_NN(x) SvREFCNT_dec (x)
114#endif
115
104#if __GNUC__ >= 3 116#if __GNUC__ >= 3
105# define expect(expr,value) __builtin_expect ((expr), (value)) 117# define expect(expr,value) __builtin_expect ((expr), (value))
106# define INLINE static inline 118# define INLINE static inline
107#else 119#else
108# define expect(expr,value) (expr) 120# define expect(expr,value) (expr)
140{ 152{
141 if (!SvOK (profile)) 153 if (!SvOK (profile))
142 return default_profile; 154 return default_profile;
143 155
144 if (!SvROK (profile)) 156 if (!SvROK (profile))
145 croak ("invalid profile"); 157 croak ("Convert::BER::XS::Profile expected");
146 158
147 profile = SvRV (profile); 159 profile = SvRV (profile);
148 160
149 if (SvSTASH (profile) != profile_stash) 161 if (SvSTASH (profile) != profile_stash)
150 croak ("invalid profile object"); 162 croak ("Convert::BER::XS::Profile expected");
151 163
152 return (void *)profile; 164 return (void *)profile;
153} 165}
154 166
155static int 167static int
227} 239}
228 240
229// get_* functions fetch something from the buffer 241// get_* functions fetch something from the buffer
230// decode_* functions use get_* fun ctions to decode ber values 242// decode_* functions use get_* fun ctions to decode ber values
231 243
244// get single octet
245static U8
246get_u8 (void)
247{
248 if (cur == end)
249 error ("unexpected end of message buffer");
250
251 return *cur++;
252}
253
232// get n octets 254// get n octets
233static U8 * 255static U8 *
234get_n (UV count) 256get_n (UV count)
235{ 257{
236 want (count); 258 want (count);
237 U8 *res = cur; 259 U8 *res = cur;
238 cur += count; 260 cur += count;
239 return res; 261 return res;
240} 262}
241 263
242// get single octet
243static U8
244get_u8 (void)
245{
246 if (cur == end)
247 error ("unexpected end of message buffer");
248
249 return *cur++;
250}
251
252// get ber-encoded integer (i.e. pack "w") 264// get ber-encoded integer (i.e. pack "w")
253static UV 265static UV
254get_w (void) 266get_w (void)
255{ 267{
256 UV res = 0; 268 UV res = 0;
269 U8 c = get_u8 ();
270
271 if (expect_false (c == 0x80))
272 error ("invalid BER padding (X.690 8.1.2.4.2, 8.19.2)");
257 273
258 for (;;) 274 for (;;)
259 { 275 {
260 U8 c = get_u8 (); 276 if (expect_false (res >> UVSIZE * 8 - 7))
277 error ("BER variable length integer overflow");
278
261 res = (res << 7) | (c & 0x7f); 279 res = (res << 7) | (c & 0x7f);
262 280
263 if (!(c & 0x80)) 281 if (expect_true (!(c & 0x80)))
264 return res; 282 return res;
265 }
266}
267 283
268// get_w, but disallow padding 284 c = get_u8 ();
269static UV 285 }
270get_w_nopad (void)
271{
272 U8 first = get_u8 ();
273
274 if (first == 0x80)
275 error ("illegal BER padding");
276
277 --cur;
278
279 return get_w ();
280} 286}
281 287
282static UV 288static UV
283get_length (void) 289get_length (void)
284{ 290{
285 UV res = get_u8 (); 291 UV res = get_u8 ();
286 292
287 if (res & 0x80) 293 if (expect_false (res & 0x80))
288 { 294 {
289 int cnt = res & 0x7f; 295 U8 cnt = res & 0x7f;
296
297 // this genewrates quite ugly code, but the overhead
298 // of copying the bytes for these lengths is probably so high
299 // that a slightly inefficient get_length won't matter.
300
301 if (expect_false (cnt == 0))
302 error ("invalid use of indefinite BER length form in primitive encoding (X.690 8.1.3.2)");
303
304 if (expect_false (cnt > UVSIZE))
305 error ("BER value length too long (must fit into UV) or BER reserved value in length (X.690 8.1.3.5)");
306
307 want (cnt);
308
290 res = 0; 309 res = 0;
291 310 do
292 switch (cnt) 311 res = (res << 8) | *cur++;
293 { 312 while (--cnt);
294 case 0:
295 error ("indefinite ASN.1 lengths not supported");
296 return 0;
297
298 //case 0x80: // indefinite length
299
300 //case 0xff: reserved
301 default:
302 error ("ASN.1 length too long");
303 return 0;
304
305 case 8: res = (res << 8) | get_u8 ();
306 case 7: res = (res << 8) | get_u8 ();
307 case 6: res = (res << 8) | get_u8 ();
308 case 5: res = (res << 8) | get_u8 ();
309 case 4: res = (res << 8) | get_u8 ();
310 case 3: res = (res << 8) | get_u8 ();
311 case 2: res = (res << 8) | get_u8 ();
312 case 1: res = (res << 8) | get_u8 ();
313 }
314 } 313 }
315 314
316 return res; 315 return res;
317} 316}
318 317
319static SV * 318static SV *
320decode_int (void) 319decode_int (UV len)
321{ 320{
322 UV len = get_length ();
323
324 if (!len) 321 if (!len)
325 { 322 error ("invalid BER_TYPE_INT length zero (X.690 8.3.1)");
326 error ("invalid integer length equal to zero");
327 return 0;
328 }
329 323
330 U8 *data = get_n (len); 324 U8 *data = get_n (len);
331 325
326 if (expect_false (len > 1))
327 {
328 U16 mask = (data [0] << 8) | data [1] & 0xff80;
329
330 if (expect_false (mask == 0xff80 || mask == 0x0000))
331 error ("invalid padding in BER_TYPE_INT (X.690 8.3.2)");
332 }
333
332 int negative = data [0] & 0x80; 334 int negative = data [0] & 0x80;
333 335
334 UV val = negative ? -1 : 0; // copy signbit to all bits 336 UV val = negative ? -1 : 0; // copy signbit to all bits
337
338 if (len > UVSIZE + (!negative && !*data))
339 error ("BER_TYPE_INT overflow");
335 340
336 do 341 do
337 val = (val << 8) | *data++; 342 val = (val << 8) | *data++;
338 while (--len); 343 while (--len);
339 344
341 // but that's ok, as perl relies on it as well. 346 // but that's ok, as perl relies on it as well.
342 return negative ? newSViv ((IV)val) : newSVuv (val); 347 return negative ? newSViv ((IV)val) : newSVuv (val);
343} 348}
344 349
345static SV * 350static SV *
346decode_data (void) 351decode_data (UV len)
347{ 352{
348 UV len = get_length ();
349 return newSVpvn ((char *)get_n (len), len); 353 return newSVpvn ((char *)get_n (len), len);
350} 354}
351 355
352// helper for decode_object_identifier 356// helper for decode_object_identifier
353static char * 357static char *
381 385
382 return buf; 386 return buf;
383} 387}
384 388
385static SV * 389static SV *
386decode_oid (int relative) 390decode_oid (UV len, int relative)
387{ 391{
388 UV len = get_length ();
389
390 if (len <= 0) 392 if (len <= 0)
391 { 393 {
392 error ("OBJECT IDENTIFIER length equal to zero"); 394 error ("BER_TYPE_OID length must not be zero");
393 return &PL_sv_undef; 395 return &PL_sv_undef;
394 } 396 }
395 397
396 U8 *end = cur + len; 398 U8 *end = cur + len;
397 UV w = get_w_nopad (); 399 UV w = get_w ();
398 400
399 static char oid[MAX_OID_STRLEN]; // static, becaueds too large for stack 401 static char oid[MAX_OID_STRLEN]; // static, because too large for stack
400 char *app = oid; 402 char *app = oid;
401 403
402 if (relative) 404 if (relative)
403 app = write_uv (app, w); 405 app = write_uv (app, w);
406 else
407 {
408 UV w1, w2;
409
404 else if (w < 2 * 40) 410 if (w < 2 * 40)
405 { 411 (w1 = w / 40), (w2 = w % 40);
412 else
413 (w1 = 2), (w2 = w - 2 * 40);
414
406 app = write_uv (app, (U8)w / 40); 415 app = write_uv (app, w1);
407 *app++ = '.'; 416 *app++ = '.';
408 app = write_uv (app, (U8)w % 40);
409 }
410 else
411 {
412 app = write_uv (app, 2); 417 app = write_uv (app, w2);
413 *app++ = '.';
414 app = write_uv (app, w - 2 * 40);
415 } 418 }
416 419
417 while (cur < end) 420 while (cur < end)
418 { 421 {
419 // we assume an oid component is never > 64 digits 422 // we assume an oid component is never > 64 digits
420 if (oid + sizeof (oid) - app < 64) 423 if (oid + sizeof (oid) - app < 64)
421 croak ("BER_TYPE_OID to long to decode"); 424 croak ("BER_TYPE_OID to long to decode");
422 425
423 w = get_w_nopad (); 426 w = get_w ();
424 *app++ = '.'; 427 *app++ = '.';
425 app = write_uv (app, w); 428 app = write_uv (app, w);
426 } 429 }
427 430
428 return newSVpvn (oid, app - oid); 431 return newSVpvn (oid, app - oid);
429} 432}
430 433
434// oh my, this is a total mess
435static SV *
436decode_real (UV len)
437{
438 SV *res;
439 U8 *beg = cur;
440
441 if (len == 0)
442 res = newSVnv (0.);
443 else
444 {
445 U8 info = get_u8 ();
446
447 if (info & 0x80)
448 {
449 // binary
450 static const U8 base[] = { 2, 8, 16, 0 };
451 NV S = info & 0x40 ? -1 : 1; // sign
452 NV B = base [(info >> 4) & 3]; // base
453 NV F = 1 << ((info >> 2) & 3); // scale factor ("shift")
454 int L = info & 3; // exponent length
455
456 if (!B)
457 croak ("BER_TYPE_REAL binary encoding uses invalid base (0x%02x)", info);
458
459 SAVETMPS;
460
461 SV *E = sv_2mortal (decode_int (L == 3 ? get_u8 () : L + 1));
462 SV *M = sv_2mortal (decode_int (len - (cur - beg)));
463
464 res = newSVnv (S * SvNV (M) * F * Perl_pow (B, SvNV (E)));
465
466 FREETMPS;
467 }
468 else if (info & 0x40)
469 {
470 // SpecialRealValue
471 U8 special = get_u8 ();
472 NV val;
473
474 switch (special)
475 {
476 case 0x40: val = NV_INF; break;
477 case 0x41: val = -NV_INF; break;
478 case 0x42: val = NV_NAN; break;
479 case 0x43: val = -(NV)0.; break;
480
481 default:
482 croak ("BER_TYPE_REAL SpecialRealValues invalid encoding 0x%02x (X.690 8.5.9)", special);
483 }
484
485 res = newSVnv (val);
486 }
487 else
488 {
489 // decimal
490 dSP;
491 SAVETMPS;
492 PUSHMARK (SP);
493 EXTEND (SP, 2);
494 PUSHs (sv_2mortal (newSVcacheint (info & 0x3f)));
495 PUSHs (sv_2mortal (newSVpvn (get_n (len - 1), len - 1)));
496 PUTBACK;
497 call_pv ("Convert::BER::XS::_decode_real_decimal", G_SCALAR);
498 SPAGAIN;
499 res = SvREFCNT_inc_NN (POPs);
500 PUTBACK;
501 FREETMPS;
502 }
503 }
504
505 if (cur - beg != len)
506 {
507 SvREFCNT_dec_NN (res);
508 croak ("BER_TYPE_REAL invalid content length (X.690 8,5)");
509 }
510
511 return res;
512}
513
431// TODO: this is unacceptably slow 514// TODO: this is unacceptably slow
432static SV * 515static SV *
433decode_ucs (int chrsize) 516decode_ucs (UV len, int chrsize)
434{ 517{
435 SV *res = NEWSV (0, 0);
436
437 UV len = get_length ();
438
439 if (len & (chrsize - 1)) 518 if (len & (chrsize - 1))
440 croak ("BER_TYPE_UCS has an invalid number of octets (%d)", len); 519 croak ("BER_TYPE_UCS has an invalid number of octets (%d)", len);
520
521 SV *res = NEWSV (0, 0);
441 522
442 while (len) 523 while (len)
443 { 524 {
444 U8 b1 = get_u8 (); 525 U8 b1 = get_u8 ();
445 U8 b2 = get_u8 (); 526 U8 b2 = get_u8 ();
476 int tag = identifier & ASN_TAG_MASK; 557 int tag = identifier & ASN_TAG_MASK;
477 558
478 if (tag == ASN_TAG_BER) 559 if (tag == ASN_TAG_BER)
479 tag = get_w (); 560 tag = get_w ();
480 561
481 if (tag == ASN_TAG_BER)
482 tag = get_w ();
483
484 if (constructed) 562 if (constructed)
485 { 563 {
564 want (1);
565 AV *av = (AV *)sv_2mortal ((SV *)newAV ());
566
567 if (expect_false (*cur == 0x80))
568 {
569 // indefinite length
570 ++cur;
571
572 for (;;)
573 {
574 want (2);
575 if (!cur [0] && !cur [1])
576 {
577 cur += 2;
578 break;
579 }
580
581 av_push (av, decode_ber ());
582 }
583 }
584 else
585 {
586 UV len = get_length ();
587 UV seqend = (cur - buf) + len;
588
589 while (cur < buf + seqend)
590 av_push (av, decode_ber ());
591
592 if (expect_false (cur > buf + seqend))
593 croak ("CONSTRUCTED type %02x length overflow (0x%x 0x%x)\n", identifier, (int)(cur - buf), (int)seqend);
594 }
595
596 res = newRV_inc ((SV *)av);
597 }
598 else
599 {
486 UV len = get_length (); 600 UV len = get_length ();
487 UV seqend = (cur - buf) + len;
488 AV *av = (AV *)sv_2mortal ((SV *)newAV ());
489 601
490 while (cur < buf + seqend)
491 av_push (av, decode_ber ());
492
493 if (cur > buf + seqend)
494 croak ("constructed type %02x overflow (%x %x)\n", identifier, cur - buf, seqend);
495
496 res = newRV_inc ((SV *)av);
497 }
498 else
499 switch (profile_lookup (cur_profile, klass, tag)) 602 switch (profile_lookup (cur_profile, klass, tag))
500 { 603 {
501 case BER_TYPE_NULL: 604 case BER_TYPE_NULL:
502 { 605 if (expect_false (len))
503 UV len = get_length ();
504
505 if (len)
506 croak ("BER_TYPE_NULL value with non-zero length %d encountered", len); 606 croak ("BER_TYPE_NULL value with non-zero length %d encountered (X.690 8.8.2)", len);
507 607
508 res = &PL_sv_undef; 608 res = &PL_sv_undef;
509 }
510 break; 609 break;
511 610
512 case BER_TYPE_BOOL: 611 case BER_TYPE_BOOL:
513 {
514 UV len = get_length ();
515
516 if (len != 1) 612 if (expect_false (len != 1))
517 croak ("BER_TYPE_BOOLEAN value with invalid length %d encountered", len); 613 croak ("BER_TYPE_BOOLEAN value with invalid length %d encountered (X.690 8.2.1)", len);
518 614
519 res = newSVcacheint (!!get_u8 ()); 615 res = newSVcacheint (!!get_u8 ());
520 }
521 break; 616 break;
522 617
523 case BER_TYPE_OID: 618 case BER_TYPE_OID:
524 res = decode_oid (0); 619 res = decode_oid (len, 0);
525 break; 620 break;
526 621
527 case BER_TYPE_RELOID: 622 case BER_TYPE_RELOID:
528 res = decode_oid (1); 623 res = decode_oid (len, 1);
529 break; 624 break;
530 625
531 case BER_TYPE_INT: 626 case BER_TYPE_INT:
532 res = decode_int (); 627 res = decode_int (len);
533 break; 628 break;
534 629
535 case BER_TYPE_UTF8: 630 case BER_TYPE_UTF8:
536 res = decode_data (); 631 res = decode_data (len);
537 SvUTF8_on (res); 632 SvUTF8_on (res);
538 break; 633 break;
539 634
540 case BER_TYPE_BYTES: 635 case BER_TYPE_BYTES:
541 res = decode_data (); 636 res = decode_data (len);
542 break; 637 break;
543 638
544 case BER_TYPE_IPADDRESS: 639 case BER_TYPE_IPADDRESS:
545 { 640 {
546 UV len = get_length ();
547
548 if (len != 4) 641 if (len != 4)
549 croak ("BER_TYPE_IPADDRESS type with invalid length %d encountered", len); 642 croak ("BER_TYPE_IPADDRESS type with invalid length %d encountered (RFC 2578 7.1.5)", len);
550 643
551 U8 c1 = get_u8 (); 644 U8 *data = get_n (4);
552 U8 c2 = get_u8 (); 645 res = newSVpvf ("%d.%d.%d.%d", data [0], data [1], data [2], data [3]);
553 U8 c3 = get_u8 ();
554 U8 c4 = get_u8 ();
555
556 res = newSVpvf ("%d.%d.%d.%d", c1, c2, c3, c4);
557 } 646 }
558 break; 647 break;
559 648
560 case BER_TYPE_UCS2: 649 case BER_TYPE_UCS2:
561 res = decode_ucs (2); 650 res = decode_ucs (len, 2);
562 break; 651 break;
563 652
564 case BER_TYPE_UCS4: 653 case BER_TYPE_UCS4:
565 res = decode_ucs (4); 654 res = decode_ucs (len, 4);
566 break; 655 break;
567 656
568 case BER_TYPE_REAL: 657 case BER_TYPE_REAL:
658 res = decode_real (len);
659 break;
660
569 case BER_TYPE_CROAK: 661 case BER_TYPE_CROAK:
662 croak ("class/tag %d/%d mapped to BER_TYPE_CROAK", klass, tag);
663
570 default: 664 default:
571 croak ("unconfigured/unsupported class/tag %d/%d", klass, tag); 665 croak ("unconfigured/unsupported class/tag %d/%d", klass, tag);
572 } 666 }
667 }
573 668
574 AV *av = newAV (); 669 AV *av = newAV ();
575 av_fill (av, BER_ARRAYSIZE - 1); 670 av_fill (av, BER_ARRAYSIZE - 1);
576 AvARRAY (av)[BER_CLASS] = newSVcacheint (klass); 671 AvARRAY (av)[BER_CLASS] = newSVcacheint (klass);
577 AvARRAY (av)[BER_TAG ] = newSVcacheint (tag); 672 AvARRAY (av)[BER_TAG ] = newSVcacheint (tag);
589strlen_sum (STRLEN l1, STRLEN l2) 684strlen_sum (STRLEN l1, STRLEN l2)
590{ 685{
591 size_t sum = l1 + l2; 686 size_t sum = l1 + l2;
592 687
593 if (sum < (size_t)l2 || sum != (size_t)(STRLEN)sum) 688 if (sum < (size_t)l2 || sum != (size_t)(STRLEN)sum)
594 croak ("JSON::XS: string size overflow"); 689 croak ("Convert::BER::XS: string size overflow");
595 690
596 return sum; 691 return sum;
597} 692}
598 693
599static void 694static void
664} 759}
665 760
666static U8 * 761static U8 *
667put_length_at (UV val, U8 *cur) 762put_length_at (UV val, U8 *cur)
668{ 763{
669 if (val < 0x7fU) 764 if (val <= 0x7fU)
670 *cur++ = val; 765 *cur++ = val;
671 else 766 else
672 { 767 {
673 U8 *lenb = cur++; 768 U8 *lenb = cur++;
674 769
675#if UVSIZE > 4 770#if UVSIZE > 4
676 *cur = val >> 56; cur += *cur > 0; 771 *cur = val >> 56; cur += val >= ((UV)1 << (8 * 7));
677 *cur = val >> 48; cur += *cur > 0; 772 *cur = val >> 48; cur += val >= ((UV)1 << (8 * 6));
678 *cur = val >> 40; cur += *cur > 0; 773 *cur = val >> 40; cur += val >= ((UV)1 << (8 * 5));
679 *cur = val >> 32; cur += *cur > 0; 774 *cur = val >> 32; cur += val >= ((UV)1 << (8 * 4));
680#endif 775#endif
681 *cur = val >> 24; cur += *cur > 0; 776 *cur = val >> 24; cur += val >= ((UV)1 << (8 * 3));
682 *cur = val >> 16; cur += *cur > 0; 777 *cur = val >> 16; cur += val >= ((UV)1 << (8 * 2));
683 *cur = val >> 8; cur += *cur > 0; 778 *cur = val >> 8; cur += val >= ((UV)1 << (8 * 1));
684 *cur = val ; cur += 1; 779 *cur = val ; cur += 1;
685 780
686 *lenb = 0x80 + cur - lenb - 1; 781 *lenb = 0x80 + cur - lenb - 1;
687 } 782 }
688 783
690} 785}
691 786
692static void 787static void
693put_length (UV val) 788put_length (UV val)
694{ 789{
695 need (5 + val); 790 need (9 + val);
696 cur = put_length_at (val, cur); 791 cur = put_length_at (val, cur);
697} 792}
698 793
699// return how many bytes the encoded length requires 794// return how many bytes the encoded length requires
700static int length_length (UV val) 795static int length_length (UV val)
701{ 796{
702 return val < 0x7fU 797 // use hashing with a DeBruin sequence, anyone?
798 return expect_true (val <= 0x7fU)
703 ? 1 799 ? 1
704 : 2 800 : 2
705 + (val > 0xffU) 801 + (val > 0x000000000000ffU)
706 + (val > 0xffffU) 802 + (val > 0x0000000000ffffU)
707 + (val > 0xffffffU) 803 + (val > 0x00000000ffffffU)
708#if UVSIZE > 4 804#if UVSIZE > 4
709 + (val > 0xffffffffU) 805 + (val > 0x000000ffffffffU)
710 + (val > 0xffffffffffU) 806 + (val > 0x0000ffffffffffU)
711 + (val > 0xffffffffffffU) 807 + (val > 0x00ffffffffffffU)
712 + (val > 0xffffffffffffffU) 808 + (val > 0xffffffffffffffU)
713#endif 809#endif
714 ; 810 ;
715} 811}
716 812
852 } 948 }
853 949
854 len_fixup (mark); 950 len_fixup (mark);
855} 951}
856 952
857// check whether an SV is a BER tuple and returns its AV * 953static void
858static AV * 954encode_real (SV *data)
859ber_tuple (SV *tuple)
860{ 955{
861 SV *rv; 956 NV nv = SvNV (data);
862 957
863 if (expect_false (!SvROK (tuple) || SvTYPE ((rv = SvRV (tuple))) != SVt_PVAV)) 958 if (expect_false (nv == (NV)0.))
864 croak ("BER tuple must be array-reference"); 959 {
960 if (signbit (nv))
961 {
962 // negative zero
963 need (3);
964 *cur++ = 2;
965 *cur++ = 0x40;
966 *cur++ = 0x43;
967 }
968 else
969 {
970 // positive zero
971 need (1);
972 *cur++ = 0;
973 }
974 }
975 else if (expect_false (Perl_isinf (nv)))
976 {
977 need (3);
978 *cur++ = 2;
979 *cur++ = 0x40;
980 *cur++ = nv < (NV)0. ? 0x41 : 0x40;
981 }
982 else if (expect_false (Perl_isnan (nv)))
983 {
984 need (3);
985 *cur++ = 2;
986 *cur++ = 0x40;
987 *cur++ = 0x42;
988 }
989 else
990 {
991 // use decimal encoding
992 dSP;
993 SAVETMPS;
994 PUSHMARK (SP);
995 EXTEND (SP, 2);
996 PUSHs (data);
997 PUSHs (sv_2mortal (newSVcacheint (NV_DIG)));
998 PUTBACK;
999 call_pv ("Convert::BER::XS::_encode_real_decimal", G_SCALAR);
1000 SPAGAIN;
865 1001
866 if (expect_false (SvRMAGICAL (rv))) 1002 SV *sv = POPs;
867 croak ("BER tuple must not be tied"); 1003 STRLEN l;
1004 char *f = SvPV (sv, l);
868 1005
869 if (expect_false (AvFILL ((AV *)rv) != BER_ARRAYSIZE - 1)) 1006 put_length (l);
870 croak ("BER tuple must contain exactly %d elements, not %d", BER_ARRAYSIZE, AvFILL ((AV *)rv) + 1); 1007 memcpy (cur, f, l);
1008 cur += l;
871 1009
872 return (AV *)rv; 1010 PUTBACK;
1011 FREETMPS;
1012 }
873} 1013}
874 1014
875static void 1015static void
876encode_ucs (SV *data, int chrsize) 1016encode_ucs (SV *data, int chrsize)
877{ 1017{
897 1037
898 *cur++ = uchr >> 8; 1038 *cur++ = uchr >> 8;
899 *cur++ = uchr; 1039 *cur++ = uchr;
900 } 1040 }
901} 1041}
1042
1043// check whether an SV is a BER tuple and returns its AV *
1044static AV *
1045ber_tuple (SV *tuple)
1046{
1047 SV *rv;
1048
1049 if (expect_false (!SvROK (tuple) || SvTYPE ((rv = SvRV (tuple))) != SVt_PVAV))
1050 croak ("BER tuple must be array-reference");
1051
1052 if (expect_false (SvRMAGICAL (rv)))
1053 croak ("BER tuple must not be tied");
1054
1055 if (expect_false (AvFILL ((AV *)rv) != BER_ARRAYSIZE - 1))
1056 croak ("BER tuple must contain exactly %d elements, not %d", BER_ARRAYSIZE, AvFILL ((AV *)rv) + 1);
1057
1058 return (AV *)rv;
1059}
1060
902static void 1061static void
903encode_ber (SV *tuple) 1062encode_ber (SV *tuple)
904{ 1063{
905 AV *av = ber_tuple (tuple); 1064 AV *av = ber_tuple (tuple);
906 1065
925 // and adjust later 1084 // and adjust later
926 need (1); 1085 need (1);
927 STRLEN mark = len_fixup_mark (); 1086 STRLEN mark = len_fixup_mark ();
928 1087
929 if (expect_false (!SvROK (data) || SvTYPE (SvRV (data)) != SVt_PVAV)) 1088 if (expect_false (!SvROK (data) || SvTYPE (SvRV (data)) != SVt_PVAV))
930 croak ("BER constructed data must be array-reference"); 1089 croak ("BER CONSTRUCTED data must be array-reference");
931 1090
932 AV *av = (AV *)SvRV (data); 1091 AV *av = (AV *)SvRV (data);
933 int fill = AvFILL (av); 1092 int fill = AvFILL (av);
934 1093
935 if (expect_false (SvRMAGICAL (av))) 1094 if (expect_false (SvRMAGICAL (av)))
936 croak ("BER constructed data must not be tied"); 1095 croak ("BER CONSTRUCTED data must not be tied");
937 1096
938 int i; 1097 int i;
939 for (i = 0; i <= fill; ++i) 1098 for (i = 0; i <= fill; ++i)
940 encode_ber (AvARRAY (av)[i]); 1099 encode_ber (AvARRAY (av)[i]);
941 1100
996 case BER_TYPE_UCS4: 1155 case BER_TYPE_UCS4:
997 encode_ucs (data, 4); 1156 encode_ucs (data, 4);
998 break; 1157 break;
999 1158
1000 case BER_TYPE_REAL: 1159 case BER_TYPE_REAL:
1160 encode_real (data);
1161 break;
1162
1001 case BER_TYPE_CROAK: 1163 case BER_TYPE_CROAK:
1164 croak ("class/tag %d/%d mapped to BER_TYPE_CROAK", klass, tag);
1165
1002 default: 1166 default:
1003 croak ("unconfigured/unsupported class/tag %d/%d", klass, tag); 1167 croak ("unconfigured/unsupported class/tag %d/%d", klass, tag);
1004 } 1168 }
1005 1169
1006} 1170}
1078 const_iv (BER_TYPE_IPADDRESS) 1242 const_iv (BER_TYPE_IPADDRESS)
1079 const_iv (BER_TYPE_CROAK) 1243 const_iv (BER_TYPE_CROAK)
1080 1244
1081 const_iv (SNMP_IPADDRESS) 1245 const_iv (SNMP_IPADDRESS)
1082 const_iv (SNMP_COUNTER32) 1246 const_iv (SNMP_COUNTER32)
1247 const_iv (SNMP_GAUGE32)
1083 const_iv (SNMP_UNSIGNED32) 1248 const_iv (SNMP_UNSIGNED32)
1084 const_iv (SNMP_TIMETICKS) 1249 const_iv (SNMP_TIMETICKS)
1085 const_iv (SNMP_OPAQUE) 1250 const_iv (SNMP_OPAQUE)
1086 const_iv (SNMP_COUNTER64) 1251 const_iv (SNMP_COUNTER64)
1087 }; 1252 };
1088 1253
1089 for (civ = const_iv + sizeof (const_iv) / sizeof (const_iv [0]); civ > const_iv; civ--) 1254 for (civ = const_iv + sizeof (const_iv) / sizeof (const_iv [0]); civ > const_iv; civ--)
1090 newCONSTSUB (stash, (char *)civ[-1].name, newSViv (civ[-1].iv)); 1255 newCONSTSUB (stash, (char *)civ[-1].name, newSViv (civ[-1].iv));
1091} 1256}
1092 1257
1093SV * 1258void
1094ber_decode (SV *ber, SV *profile = &PL_sv_undef) 1259ber_decode (SV *ber, SV *profile = &PL_sv_undef)
1260 ALIAS:
1261 ber_decode_prefix = 1
1095 CODE: 1262 PPCODE:
1096{ 1263{
1097 cur_profile = SvPROFILE (profile); 1264 cur_profile = SvPROFILE (profile);
1098 STRLEN len; 1265 STRLEN len;
1099 buf = (U8 *)SvPVbyte (ber, len); 1266 buf = (U8 *)SvPVbyte (ber, len);
1100 cur = buf; 1267 cur = buf;
1101 end = buf + len; 1268 end = buf + len;
1102 1269
1270 PUTBACK;
1103 RETVAL = decode_ber (); 1271 SV *tuple = decode_ber ();
1272 SPAGAIN;
1273
1274 EXTEND (SP, 2);
1275 PUSHs (sv_2mortal (tuple));
1276
1277 if (ix)
1278 PUSHs (sv_2mortal (newSViv (cur - buf)));
1279 else if (cur != end)
1280 error ("trailing garbage after BER value");
1104} 1281}
1105 OUTPUT: RETVAL
1106 1282
1107void 1283void
1108ber_is (SV *tuple, SV *klass = &PL_sv_undef, SV *tag = &PL_sv_undef, SV *flags = &PL_sv_undef, SV *data = &PL_sv_undef) 1284ber_is (SV *tuple, SV *klass = &PL_sv_undef, SV *tag = &PL_sv_undef, SV *flags = &PL_sv_undef, SV *data = &PL_sv_undef)
1109 PPCODE: 1285 PPCODE:
1110{ 1286{
1186 cur_profile = SvPROFILE (profile); 1362 cur_profile = SvPROFILE (profile);
1187 buf_sv = sv_2mortal (NEWSV (0, 256)); 1363 buf_sv = sv_2mortal (NEWSV (0, 256));
1188 SvPOK_only (buf_sv); 1364 SvPOK_only (buf_sv);
1189 set_buf (buf_sv); 1365 set_buf (buf_sv);
1190 1366
1367 PUTBACK;
1191 encode_ber (tuple); 1368 encode_ber (tuple);
1369 SPAGAIN;
1192 1370
1193 SvCUR_set (buf_sv, cur - buf); 1371 SvCUR_set (buf_sv, cur - buf);
1194 XPUSHs (buf_sv); 1372 XPUSHs (buf_sv);
1195} 1373}
1196 1374

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines