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.1 by root, Fri Apr 19 16:19:36 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 4
5#include <math.h>
6
5// C99 required 7// C99 required!
8// this is not just for comments, but also for
9// integer constant semantics,
10// sscanf format modifiers and more.
6 11
7enum { 12enum {
8 // ASN_TAG 13 // ASN_TAG
9 ASN_BOOLEAN = 0x01, 14 ASN_BOOLEAN = 0x01,
10 ASN_INTEGER32 = 0x02, 15 ASN_INTEGER = 0x02,
11 ASN_BIT_STRING = 0x03, 16 ASN_BIT_STRING = 0x03,
12 ASN_OCTET_STRING = 0x04, 17 ASN_OCTET_STRING = 0x04,
13 ASN_NULL = 0x05, 18 ASN_NULL = 0x05,
14 ASN_OBJECT_IDENTIFIER = 0x06, 19 ASN_OBJECT_IDENTIFIER = 0x06,
20 ASN_OID = 0x06,
21 ASN_OBJECT_DESCRIPTOR = 0x07,
22 ASN_EXTERNAL = 0x08,
23 ASN_REAL = 0x09,
24 ASN_ENUMERATED = 0x0a,
25 ASN_EMBEDDED_PDV = 0x0b,
26 ASN_UTF8_STRING = 0x0c,
27 ASN_RELATIVE_OID = 0x0d,
15 ASN_SEQUENCE = 0x10, 28 ASN_SEQUENCE = 0x10,
29 ASN_SET = 0x11,
30 ASN_NUMERIC_STRING = 0x12,
31 ASN_PRINTABLE_STRING = 0x13,
32 ASN_TELETEX_STRING = 0x14,
33 ASN_T61_STRING = 0x14,
34 ASN_VIDEOTEX_STRING = 0x15,
35 ASN_IA5_STRING = 0x16,
36 ASN_ASCII_STRING = 0x16,
37 ASN_UTC_TIME = 0x17,
38 ASN_GENERALIZED_TIME = 0x18,
39 ASN_GRAPHIC_STRING = 0x19,
40 ASN_VISIBLE_STRING = 0x1a,
41 ASN_ISO646_STRING = 0x1a,
42 ASN_GENERAL_STRING = 0x1b,
43 ASN_UNIVERSAL_STRING = 0x1c,
44 ASN_CHARACTER_STRING = 0x1d,
45 ASN_BMP_STRING = 0x1e,
16 46
17 ASN_TAG_BER = 0x1f, 47 ASN_TAG_BER = 0x1f,
18 ASN_TAG_MASK = 0x1f, 48 ASN_TAG_MASK = 0x1f,
19 49
20 // primitive/constructed 50 // primitive/constructed
21 ASN_CONSTRUCTED = 0x20, 51 ASN_CONSTRUCTED = 0x20,
22 52
23 // ASN_CLASS 53 // ASN_CLASS
24 ASN_UNIVERSAL = 0x00, 54 ASN_UNIVERSAL = 0x00,
25 ASN_APPLICATION = 0x40, 55 ASN_APPLICATION = 0x01,
26 ASN_CONTEXT = 0x80, 56 ASN_CONTEXT = 0x02,
27 ASN_PRIVATE = 0xc0, 57 ASN_PRIVATE = 0x03,
28 58
29 ASN_CLASS_MASK = 0xc0, 59 ASN_CLASS_MASK = 0xc0,
30 ASN_CLASS_SHIFT = 6, 60 ASN_CLASS_SHIFT = 6,
31 61
32 // ASN_APPLICATION 62 // ASN_APPLICATION SNMP
33 ASN_IPADDRESS = 0x00, 63 SNMP_IPADDRESS = 0x00,
34 ASN_COUNTER32 = 0x01, 64 SNMP_COUNTER32 = 0x01,
65 SNMP_GAUGE32 = 0x02,
35 ASN_UNSIGNED32 = 0x02, 66 SNMP_UNSIGNED32 = 0x02,
36 ASN_TIMETICKS = 0x03, 67 SNMP_TIMETICKS = 0x03,
37 ASN_OPAQUE = 0x04, 68 SNMP_OPAQUE = 0x04,
38 ASN_COUNTER64 = 0x06, 69 SNMP_COUNTER64 = 0x06,
39}; 70};
40 71
72// tlow-level types this module can ecode the above (and more) into
41enum { 73enum {
74 BER_TYPE_BYTES,
75 BER_TYPE_UTF8,
76 BER_TYPE_UCS2,
77 BER_TYPE_UCS4,
78 BER_TYPE_INT,
79 BER_TYPE_OID,
80 BER_TYPE_RELOID,
81 BER_TYPE_NULL,
82 BER_TYPE_BOOL,
83 BER_TYPE_REAL,
84 BER_TYPE_IPADDRESS,
85 BER_TYPE_CROAK,
86};
87
88// tuple array indices
89enum {
42 BER_CLASS = 0, 90 BER_CLASS = 0,
43 BER_TAG = 1, 91 BER_TAG = 1,
44 BER_CONSTRUCTED = 2, 92 BER_FLAGS = 2,
45 BER_DATA = 3, 93 BER_DATA = 3,
46 BER_ARRAYSIZE 94 BER_ARRAYSIZE
47}; 95};
48 96
49#define MAX_OID_STRLEN 4096 97#define MAX_OID_STRLEN 4096
50 98
51static U8 *buf, *cur; 99typedef void profile_type;
52static STRLEN len, rem; 100
101static profile_type *cur_profile, *default_profile;
102static SV *buf_sv; // encoding buffer
103static U8 *buf, *cur, *end; // buffer start, current, end
104
105#if PERL_VERSION < 18
106# define utf8_to_uvchr_buf(s,e,l) utf8_to_uvchr (s, l)
107#endif
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
116#if __GNUC__ >= 3
117# define expect(expr,value) __builtin_expect ((expr), (value))
118# define INLINE static inline
119#else
120# define expect(expr,value) (expr)
121# define INLINE static
122#endif
123
124#define expect_false(expr) expect ((expr) != 0, 0)
125#define expect_true(expr) expect ((expr) != 0, 1)
126
127/////////////////////////////////////////////////////////////////////////////
128
129static SV *sviv_cache[32];
53 130
54// for "small" integers, return a readonly sv, otherwise create a new one 131// for "small" integers, return a readonly sv, otherwise create a new one
55static SV *newSVcacheint (int val) 132static SV *newSVcacheint (int val)
56{ 133{
57 static SV *cache[32];
58
59 if (val < 0 || val >= sizeof (cache)) 134 if (expect_false (val < 0 || val >= sizeof (sviv_cache)))
60 return newSViv (val); 135 return newSViv (val);
61 136
62 if (!cache [val]) 137 if (expect_false (!sviv_cache [val]))
63 { 138 {
64 cache [val] = newSVuv (val); 139 sviv_cache [val] = newSVuv (val);
65 SvREADONLY_on (cache [val]); 140 SvREADONLY_on (sviv_cache [val]);
66 } 141 }
67 142
68 return SvREFCNT_inc_NN (cache [val]); 143 return SvREFCNT_inc_NN (sviv_cache [val]);
69} 144}
70 145
71///////////////////////////////////////////////////////////////////////////// 146/////////////////////////////////////////////////////////////////////////////
72 147
148static HV *profile_stash;
149
150static profile_type *
151SvPROFILE (SV *profile)
152{
153 if (!SvOK (profile))
154 return default_profile;
155
156 if (!SvROK (profile))
157 croak ("Convert::BER::XS::Profile expected");
158
159 profile = SvRV (profile);
160
161 if (SvSTASH (profile) != profile_stash)
162 croak ("Convert::BER::XS::Profile expected");
163
164 return (void *)profile;
165}
166
167static int
168profile_lookup (profile_type *profile, int klass, int tag)
169{
170 SV *sv = (SV *)profile;
171 U32 idx = (tag << 2) + klass;
172
173 if (expect_false (idx >= SvCUR (sv)))
174 return BER_TYPE_BYTES;
175
176 return SvPVX (sv)[idx];
177}
178
179static void
180profile_set (profile_type *profile, int klass, int tag, int type)
181{
182 SV *sv = (SV *)profile;
183 U32 idx = (tag << 2) + klass;
184 STRLEN oldlen = SvCUR (sv);
185 STRLEN newlen = idx + 2;
186
187 if (idx >= oldlen)
188 {
189 sv_grow (sv, newlen);
190 memset (SvPVX (sv) + oldlen, BER_TYPE_BYTES, newlen - oldlen);
191 SvCUR_set (sv, newlen);
192 }
193
194 SvPVX (sv)[idx] = type;
195}
196
197static SV *
198profile_new (void)
199{
200 SV *sv = newSVpvn ("", 0);
201
202 static const struct {
203 int klass;
204 int tag;
205 int type;
206 } *celem, default_map[] = {
207 { ASN_UNIVERSAL, ASN_BOOLEAN , BER_TYPE_BOOL },
208 { ASN_UNIVERSAL, ASN_INTEGER , BER_TYPE_INT },
209 { ASN_UNIVERSAL, ASN_NULL , BER_TYPE_NULL },
210 { ASN_UNIVERSAL, ASN_OBJECT_IDENTIFIER, BER_TYPE_OID },
211 { ASN_UNIVERSAL, ASN_RELATIVE_OID , BER_TYPE_RELOID },
212 { ASN_UNIVERSAL, ASN_REAL , BER_TYPE_REAL },
213 { ASN_UNIVERSAL, ASN_ENUMERATED , BER_TYPE_INT },
214 { ASN_UNIVERSAL, ASN_UTF8_STRING , BER_TYPE_UTF8 },
215 { ASN_UNIVERSAL, ASN_BMP_STRING , BER_TYPE_UCS2 },
216 { ASN_UNIVERSAL, ASN_UNIVERSAL_STRING , BER_TYPE_UCS4 },
217 };
218
219 for (celem = default_map + sizeof (default_map) / sizeof (default_map [0]); celem-- > default_map; )
220 profile_set ((profile_type *)sv, celem->klass, celem->tag, celem->type);
221
222 return sv_bless (newRV_noinc (sv), profile_stash);
223}
224
225/////////////////////////////////////////////////////////////////////////////
226// decoder
227
73static void 228static void
74error (const char *errmsg) 229error (const char *errmsg)
75{ 230{
76 croak ("%s at offset 0x%04x", errmsg, cur - buf); 231 croak ("%s at offset 0x%04x", errmsg, cur - buf);
77} 232}
78 233
79static int 234static void
80need (int count) 235want (UV count)
81{ 236{
82 if (count < 0 || (int)rem < count) 237 if (expect_false ((uintptr_t)(end - cur) < count))
83 {
84 error ("unexpected end of message buffer"); 238 error ("unexpected end of message buffer");
85 return 0;
86 }
87
88 return 1;
89} 239}
90 240
241// get_* functions fetch something from the buffer
242// decode_* functions use get_* fun ctions to decode ber values
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
254// get n octets
91static U8 * 255static U8 *
92getn (int count, const U8 *errres) 256get_n (UV count)
93{ 257{
94 if (!need (count)) 258 want (count);
95 return (U8 *)errres;
96
97 U8 *res = cur; 259 U8 *res = cur;
98
99 cur += count; 260 cur += count;
100 rem -= count;
101
102 return res; 261 return res;
103} 262}
104 263
264// get ber-encoded integer (i.e. pack "w")
105static U8 265static UV
106get8 (void) 266get_w (void)
107{ 267{
108 if (rem <= 0)
109 {
110 error ("unexpected end of message buffer");
111 return 0;
112 }
113
114 rem--;
115 return *cur++;
116}
117
118static U32
119getb (void)
120{
121 U32 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)");
122 273
123 for (;;) 274 for (;;)
124 { 275 {
125 U8 c = get8 (); 276 if (expect_false (res >> UVSIZE * 8 - 7))
277 error ("BER variable length integer overflow");
278
126 res = (res << 7) | (c & 0x7f); 279 res = (res << 7) | (c & 0x7f);
127 280
128 if (!(c & 0x80)) 281 if (expect_true (!(c & 0x80)))
129 return res; 282 return res;
130 }
131}
132 283
284 c = get_u8 ();
285 }
286}
287
133static U32 288static UV
134process_length (void) 289get_length (void)
135{ 290{
136 U32 res = get8 (); 291 UV res = get_u8 ();
137 292
138 if (res & 0x80) 293 if (expect_false (res & 0x80))
139 { 294 {
140 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
141 res = 0; 309 res = 0;
142 310 do
143 switch (cnt) 311 res = (res << 8) | *cur++;
144 { 312 while (--cnt);
145 case 0:
146 error ("indefinite ASN.1 lengths not supported");
147 return 0;
148
149 default:
150 error ("ASN.1 length too long");
151 return 0;
152
153 case 4: res = (res << 8) | get8 ();
154 case 3: res = (res << 8) | get8 ();
155 case 2: res = (res << 8) | get8 ();
156 case 1: res = (res << 8) | get8 ();
157 }
158 } 313 }
159 314
160 return res; 315 return res;
161} 316}
162 317
163static U32
164process_integer32 (void)
165{
166 U32 length = process_length ();
167
168 if (length <= 0)
169 {
170 error ("INTEGER32 length equal to zero");
171 return 0;
172 }
173
174 U8 *data = getn (length, 0);
175
176 if (!data)
177 return 0;
178
179 if (length > 5 || (length > 4 && data [0]))
180 {
181 error ("INTEGER32 length too long");
182 return 0;
183 }
184
185 U32 res = data [0] & 0x80 ? 0xffffffff : 0;
186
187 while (length--)
188 res = (res << 8) | *data++;
189
190 return res;
191}
192
193static SV * 318static SV *
194process_integer32_sv (void) 319decode_int (UV len)
195{ 320{
196 return newSViv ((I32)process_integer32 ()); 321 if (!len)
322 error ("invalid BER_TYPE_INT length zero (X.690 8.3.1)");
323
324 U8 *data = get_n (len);
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
334 int negative = data [0] & 0x80;
335
336 UV val = negative ? -1 : 0; // copy signbit to all bits
337
338 if (len > UVSIZE + (!negative && !*data))
339 error ("BER_TYPE_INT overflow");
340
341 do
342 val = (val << 8) | *data++;
343 while (--len);
344
345 // the cast to IV relies on implementation-defined behaviour (two's complement cast)
346 // but that's ok, as perl relies on it as well.
347 return negative ? newSViv ((IV)val) : newSVuv (val);
197} 348}
198 349
199static SV * 350static SV *
200process_unsigned32_sv (void) 351decode_data (UV len)
201{ 352{
202 return newSVuv ((U32)process_integer32 ()); 353 return newSVpvn ((char *)get_n (len), len);
203} 354}
204 355
205#if IVSIZE >= 8 356// helper for decode_object_identifier
206
207static U64TYPE
208process_integer64 (void)
209{
210 U32 length = process_length ();
211
212 if (length <= 0)
213 {
214 error ("INTEGER64 length equal to zero");
215 return 0;
216 }
217
218 U8 *data = getn (length, 0);
219
220 if (!data)
221 return 0;
222
223 if (length > 9 || (length > 8 && data [0]))
224 {
225 error ("INTEGER64 length too long");
226 return 0;
227 }
228
229 U64TYPE res = data [0] & 0x80 ? 0xffffffffffffffff : 0;
230
231 while (length--)
232 res = (res << 8) | *data++;
233
234 return res;
235}
236
237static SV *
238process_integer64_sv (void)
239{
240 return newSViv ((I64TYPE)process_integer64 ());
241}
242
243static SV *
244process_unsigned64_sv (void)
245{
246 return newSVuv ((U64TYPE)process_integer64 ());
247}
248
249#endif
250
251static SV *
252process_octet_string_sv (void)
253{
254 U32 length = process_length ();
255
256 U8 *data = getn (length, 0);
257 if (!data)
258 {
259 error ("OCTET STRING too long");
260 return &PL_sv_undef;
261 }
262
263 return newSVpvn (data, length);
264}
265
266static char * 357static char *
267write_uv (char *buf, U32 u) 358write_uv (char *buf, UV u)
268{ 359{
269 // the one-digit case is absolutely predominant, so this pays off (hopefully) 360 // the one-digit case is absolutely predominant, so this pays off (hopefully)
270 if (u < 10) 361 if (expect_true (u < 10))
271 *buf++ = u + '0'; 362 *buf++ = u + '0';
272 else 363 else
273 { 364 {
365 // this *could* be done much faster using branchless fixed-point arithmetics
274 char *beg = buf; 366 char *beg = buf;
275 367
276 do 368 do
277 { 369 {
278 *buf++ = u % 10 + '0'; 370 *buf++ = u % 10 + '0';
279 u /= 10; 371 u /= 10;
280 } 372 }
281 while (u); 373 while (u);
282 374
283 // reverse digits 375 // reverse digits
284 for (char *ptr = buf; --ptr != beg; ++beg) 376 char *ptr = buf;
377 while (--ptr > beg)
285 { 378 {
286 char c = *ptr; 379 char c = *ptr;
287 *ptr = *beg; 380 *ptr = *beg;
288 *beg = c; 381 *beg = c;
382 ++beg;
289 } 383 }
290 } 384 }
291 385
292 return buf; 386 return buf;
293} 387}
294 388
295static SV * 389static SV *
296process_object_identifier_sv (void) 390decode_oid (UV len, int relative)
297{ 391{
298 U32 length = process_length ();
299
300 if (length <= 0) 392 if (len <= 0)
301 { 393 {
302 error ("OBJECT IDENTIFIER length equal to zero"); 394 error ("BER_TYPE_OID length must not be zero");
303 return &PL_sv_undef; 395 return &PL_sv_undef;
304 } 396 }
305 397
306 U8 *end = cur + length; 398 U8 *end = cur + len;
307 U32 w = getb (); 399 UV w = get_w ();
308 400
309 static char oid[MAX_OID_STRLEN]; // must be static 401 static char oid[MAX_OID_STRLEN]; // static, because too large for stack
310 char *app = oid; 402 char *app = oid;
311 403
404 if (relative)
312 app = write_uv (app, (U8)w / 40); 405 app = write_uv (app, w);
406 else
407 {
408 UV w1, w2;
409
410 if (w < 2 * 40)
411 (w1 = w / 40), (w2 = w % 40);
412 else
413 (w1 = 2), (w2 = w - 2 * 40);
414
415 app = write_uv (app, w1);
313 *app++ = '.'; 416 *app++ = '.';
314 app = write_uv (app, (U8)w % 40); 417 app = write_uv (app, w2);
418 }
315 419
420 while (cur < end)
421 {
316 // we assume an oid component is never > 64 bytes 422 // we assume an oid component is never > 64 digits
317 while (cur < end && oid + sizeof (oid) - app > 64) 423 if (oid + sizeof (oid) - app < 64)
318 { 424 croak ("BER_TYPE_OID to long to decode");
425
319 w = getb (); 426 w = get_w ();
320 *app++ = '.'; 427 *app++ = '.';
321 app = write_uv (app, w); 428 app = write_uv (app, w);
322 } 429 }
323 430
324 return newSVpvn (oid, app - oid); 431 return newSVpvn (oid, app - oid);
325} 432}
326 433
434// oh my, this is a total mess
327static SV * 435static SV *
328ber_decode () 436decode_real (UV len)
329{ 437{
330 int identifier = get8 ();
331
332 SV *res; 438 SV *res;
439 U8 *beg = cur;
333 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
514// TODO: this is unacceptably slow
515static SV *
516decode_ucs (UV len, int chrsize)
517{
518 if (len & (chrsize - 1))
519 croak ("BER_TYPE_UCS has an invalid number of octets (%d)", len);
520
521 SV *res = NEWSV (0, 0);
522
523 while (len)
524 {
525 U8 b1 = get_u8 ();
526 U8 b2 = get_u8 ();
527 U32 chr = (b1 << 8) | b2;
528
529 if (chrsize == 4)
530 {
531 U8 b3 = get_u8 ();
532 U8 b4 = get_u8 ();
533 chr = (chr << 16) | (b3 << 8) | b4;
534 }
535
536 U8 uchr [UTF8_MAXBYTES];
537 int uclen = uvuni_to_utf8 (uchr, chr) - uchr;
538
539 sv_catpvn (res, (const char *)uchr, uclen);
540 len -= chrsize;
541 }
542
543 SvUTF8_on (res);
544
545 return res;
546}
547
548static SV *
549decode_ber (void)
550{
551 int identifier = get_u8 ();
552
553 SV *res;
554
334 int constructed = identifier & ASN_CONSTRUCTED; 555 int constructed = identifier & ASN_CONSTRUCTED;
335 int klass = identifier & ASN_CLASS_MASK; 556 int klass = (identifier & ASN_CLASS_MASK) >> ASN_CLASS_SHIFT;
336 int tag = identifier & ASN_TAG_MASK; 557 int tag = identifier & ASN_TAG_MASK;
337 558
338 if (tag == ASN_TAG_BER) 559 if (tag == ASN_TAG_BER)
339 tag = getb (); 560 tag = get_w ();
340
341 if (tag == ASN_TAG_BER)
342 tag = getb ();
343 561
344 if (constructed) 562 if (constructed)
345 { 563 {
346 U32 len = process_length (); 564 want (1);
347 U32 seqend = (cur - buf) + len;
348 AV *av = (AV *)sv_2mortal ((SV *)newAV ()); 565 AV *av = (AV *)sv_2mortal ((SV *)newAV ());
349 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
350 while (cur < buf + seqend) 589 while (cur < buf + seqend)
351 av_push (av, ber_decode ()); 590 av_push (av, decode_ber ());
352 591
353 if (cur > buf + seqend) 592 if (expect_false (cur > buf + seqend))
354 croak ("constructed type %02x overflow (%x %x)\n", identifier, cur - buf, seqend); 593 croak ("CONSTRUCTED type %02x length overflow (0x%x 0x%x)\n", identifier, (int)(cur - buf), (int)seqend);
594 }
355 595
356 res = newRV_inc ((SV *)av); 596 res = newRV_inc ((SV *)av);
357 } 597 }
358 else 598 else
359 switch (identifier) 599 {
600 UV len = get_length ();
601
602 switch (profile_lookup (cur_profile, klass, tag))
360 { 603 {
361 case ASN_NULL: 604 case BER_TYPE_NULL:
605 if (expect_false (len))
606 croak ("BER_TYPE_NULL value with non-zero length %d encountered (X.690 8.8.2)", len);
607
362 res = &PL_sv_undef; 608 res = &PL_sv_undef;
363 break; 609 break;
364 610
365 case ASN_OBJECT_IDENTIFIER: 611 case BER_TYPE_BOOL:
366 res = process_object_identifier_sv (); 612 if (expect_false (len != 1))
613 croak ("BER_TYPE_BOOLEAN value with invalid length %d encountered (X.690 8.2.1)", len);
614
615 res = newSVcacheint (!!get_u8 ());
367 break; 616 break;
368 617
369 case ASN_INTEGER32: 618 case BER_TYPE_OID:
370 res = process_integer32_sv (); 619 res = decode_oid (len, 0);
371 break; 620 break;
372 621
373 case ASN_APPLICATION | ASN_UNSIGNED32: 622 case BER_TYPE_RELOID:
374 case ASN_APPLICATION | ASN_COUNTER32: 623 res = decode_oid (len, 1);
375 case ASN_APPLICATION | ASN_TIMETICKS:
376 res = process_unsigned32_sv ();
377 break; 624 break;
378 625
379#if 0 // handled by default case 626 case BER_TYPE_INT:
380 case ASN_OCTET_STRING: 627 res = decode_int (len);
381 case ASN_APPLICATION | ASN_IPADDRESS:
382 case ASN_APPLICATION | ASN_OPAQUE:
383 res = process_octet_string_sv ();
384 break; 628 break;
385#endif
386 629
387 case ASN_APPLICATION | ASN_COUNTER64: 630 case BER_TYPE_UTF8:
388 res = process_integer64_sv (); 631 res = decode_data (len);
632 SvUTF8_on (res);
389 break; 633 break;
390 634
391 default: 635 case BER_TYPE_BYTES:
392 res = process_octet_string_sv (); 636 res = decode_data (len);
393 break; 637 break;
638
639 case BER_TYPE_IPADDRESS:
640 {
641 if (len != 4)
642 croak ("BER_TYPE_IPADDRESS type with invalid length %d encountered (RFC 2578 7.1.5)", len);
643
644 U8 *data = get_n (4);
645 res = newSVpvf ("%d.%d.%d.%d", data [0], data [1], data [2], data [3]);
646 }
647 break;
648
649 case BER_TYPE_UCS2:
650 res = decode_ucs (len, 2);
651 break;
652
653 case BER_TYPE_UCS4:
654 res = decode_ucs (len, 4);
655 break;
656
657 case BER_TYPE_REAL:
658 res = decode_real (len);
659 break;
660
661 case BER_TYPE_CROAK:
662 croak ("class/tag %d/%d mapped to BER_TYPE_CROAK", klass, tag);
663
664 default:
665 croak ("unconfigured/unsupported class/tag %d/%d", klass, tag);
394 } 666 }
667 }
395 668
396 AV *av = newAV (); 669 AV *av = newAV ();
397 av_fill (av, BER_ARRAYSIZE - 1); 670 av_fill (av, BER_ARRAYSIZE - 1);
398 AvARRAY (av)[BER_CLASS ] = newSVcacheint (klass >> ASN_CLASS_SHIFT); 671 AvARRAY (av)[BER_CLASS] = newSVcacheint (klass);
399 AvARRAY (av)[BER_TAG ] = newSVcacheint (tag); 672 AvARRAY (av)[BER_TAG ] = newSVcacheint (tag);
400 AvARRAY (av)[BER_CONSTRUCTED] = newSVcacheint (constructed ? 1 : 0); 673 AvARRAY (av)[BER_FLAGS] = newSVcacheint (constructed ? 1 : 0);
401 AvARRAY (av)[BER_DATA ] = res; 674 AvARRAY (av)[BER_DATA ] = res;
402 675
403 return newRV_noinc ((SV *)av); 676 return newRV_noinc ((SV *)av);
404} 677}
405 678
679/////////////////////////////////////////////////////////////////////////////
680// encoder
681
682/* adds two STRLENs together, slow, and with paranoia */
683static STRLEN
684strlen_sum (STRLEN l1, STRLEN l2)
685{
686 size_t sum = l1 + l2;
687
688 if (sum < (size_t)l2 || sum != (size_t)(STRLEN)sum)
689 croak ("Convert::BER::XS: string size overflow");
690
691 return sum;
692}
693
694static void
695set_buf (SV *sv)
696{
697 STRLEN len;
698 buf_sv = sv;
699 buf = (U8 *)SvPVbyte (buf_sv, len);
700 cur = buf;
701 end = buf + len;
702}
703
704/* similar to SvGROW, but somewhat safer and guarantees exponential realloc strategy */
705static char *
706my_sv_grow (SV *sv, size_t len1, size_t len2)
707{
708 len1 = strlen_sum (len1, len2);
709 len1 = strlen_sum (len1, len1 >> 1);
710
711 if (len1 > 4096 - 24)
712 len1 = (len1 | 4095) - 24;
713
714 return SvGROW (sv, len1);
715}
716
717static void
718need (STRLEN len)
719{
720 if (expect_false ((uintptr_t)(end - cur) < len))
721 {
722 STRLEN pos = cur - buf;
723 buf = (U8 *)my_sv_grow (buf_sv, pos, len);
724 cur = buf + pos;
725 end = buf + SvLEN (buf_sv) - 1;
726 }
727}
728
729static void
730put_u8 (int val)
731{
732 need (1);
733 *cur++ = val;
734}
735
736static void
737put_w_nocheck (UV val)
738{
739#if UVSIZE > 4
740 *cur = (val >> 7 * 9) | 0x80; cur += val >= ((UV)1 << (7 * 9));
741 *cur = (val >> 7 * 8) | 0x80; cur += val >= ((UV)1 << (7 * 8));
742 *cur = (val >> 7 * 7) | 0x80; cur += val >= ((UV)1 << (7 * 7));
743 *cur = (val >> 7 * 6) | 0x80; cur += val >= ((UV)1 << (7 * 6));
744 *cur = (val >> 7 * 5) | 0x80; cur += val >= ((UV)1 << (7 * 5));
745#endif
746 *cur = (val >> 7 * 4) | 0x80; cur += val >= ((UV)1 << (7 * 4));
747 *cur = (val >> 7 * 3) | 0x80; cur += val >= ((UV)1 << (7 * 3));
748 *cur = (val >> 7 * 2) | 0x80; cur += val >= ((UV)1 << (7 * 2));
749 *cur = (val >> 7 * 1) | 0x80; cur += val >= ((UV)1 << (7 * 1));
750 *cur = val & 0x7f; cur += 1;
751}
752
753static void
754put_w (UV val)
755{
756 need (5); // we only handle up to 5 bytes
757
758 put_w_nocheck (val);
759}
760
761static U8 *
762put_length_at (UV val, U8 *cur)
763{
764 if (val <= 0x7fU)
765 *cur++ = val;
766 else
767 {
768 U8 *lenb = cur++;
769
770#if UVSIZE > 4
771 *cur = val >> 56; cur += val >= ((UV)1 << (8 * 7));
772 *cur = val >> 48; cur += val >= ((UV)1 << (8 * 6));
773 *cur = val >> 40; cur += val >= ((UV)1 << (8 * 5));
774 *cur = val >> 32; cur += val >= ((UV)1 << (8 * 4));
775#endif
776 *cur = val >> 24; cur += val >= ((UV)1 << (8 * 3));
777 *cur = val >> 16; cur += val >= ((UV)1 << (8 * 2));
778 *cur = val >> 8; cur += val >= ((UV)1 << (8 * 1));
779 *cur = val ; cur += 1;
780
781 *lenb = 0x80 + cur - lenb - 1;
782 }
783
784 return cur;
785}
786
787static void
788put_length (UV val)
789{
790 need (9 + val);
791 cur = put_length_at (val, cur);
792}
793
794// return how many bytes the encoded length requires
795static int length_length (UV val)
796{
797 // use hashing with a DeBruin sequence, anyone?
798 return expect_true (val <= 0x7fU)
799 ? 1
800 : 2
801 + (val > 0x000000000000ffU)
802 + (val > 0x0000000000ffffU)
803 + (val > 0x00000000ffffffU)
804#if UVSIZE > 4
805 + (val > 0x000000ffffffffU)
806 + (val > 0x0000ffffffffffU)
807 + (val > 0x00ffffffffffffU)
808 + (val > 0xffffffffffffffU)
809#endif
810 ;
811}
812
813static void
814encode_data (const char *ptr, STRLEN len)
815{
816 put_length (len);
817 memcpy (cur, ptr, len);
818 cur += len;
819}
820
821static void
822encode_uv (UV uv)
823{
824}
825
826static void
827encode_int (SV *sv)
828{
829 need (8 + 1 + 1); // 64 bit + length + extra 0
830
831 if (expect_false (!SvIOK (sv)))
832 sv_2iv_flags (sv, 0);
833
834 U8 *lenb = cur++;
835
836 if (SvIOK_notUV (sv))
837 {
838 IV iv = SvIVX (sv);
839
840 if (expect_false (iv < 0))
841 {
842 // get two's complement bit pattern - works even on hypothetical non-2c machines
843 UV uv = iv;
844
845#if UVSIZE > 4
846 *cur = uv >> 56; cur += !!(~uv & 0xff80000000000000U);
847 *cur = uv >> 48; cur += !!(~uv & 0xffff800000000000U);
848 *cur = uv >> 40; cur += !!(~uv & 0xffffff8000000000U);
849 *cur = uv >> 32; cur += !!(~uv & 0xffffffff80000000U);
850#endif
851 *cur = uv >> 24; cur += !!(~uv & 0xffffffffff800000U);
852 *cur = uv >> 16; cur += !!(~uv & 0xffffffffffff8000U);
853 *cur = uv >> 8; cur += !!(~uv & 0xffffffffffffff80U);
854 *cur = uv ; cur += 1;
855
856 *lenb = cur - lenb - 1;
857
858 return;
859 }
860 }
861
862 UV uv = SvUV (sv);
863
864 // prepend an extra 0 if the high bit is 1
865 *cur = 0; cur += !!(uv & ((UV)1 << (UVSIZE * 8 - 1)));
866
867#if UVSIZE > 4
868 *cur = uv >> 56; cur += !!(uv & 0xff80000000000000U);
869 *cur = uv >> 48; cur += !!(uv & 0xffff800000000000U);
870 *cur = uv >> 40; cur += !!(uv & 0xffffff8000000000U);
871 *cur = uv >> 32; cur += !!(uv & 0xffffffff80000000U);
872#endif
873 *cur = uv >> 24; cur += !!(uv & 0xffffffffff800000U);
874 *cur = uv >> 16; cur += !!(uv & 0xffffffffffff8000U);
875 *cur = uv >> 8; cur += !!(uv & 0xffffffffffffff80U);
876 *cur = uv ; cur += 1;
877
878 *lenb = cur - lenb - 1;
879}
880
881// we don't know the length yet, so we optimistically
882// assume the length will need one octet later. If that
883// turns out to be wrong, we memmove as needed.
884// mark the beginning
885static STRLEN
886len_fixup_mark (void)
887{
888 return cur++ - buf;
889}
890
891// patch up the length
892static void
893len_fixup (STRLEN mark)
894{
895 STRLEN reallen = (cur - buf) - mark - 1;
896 int lenlen = length_length (reallen);
897
898 if (expect_false (lenlen > 1))
899 {
900 // bad luck, we have to shift the bytes to make room for the length
901 need (5);
902 memmove (buf + mark + lenlen, buf + mark + 1, reallen);
903 cur += lenlen - 1;
904 }
905
906 put_length_at (reallen, buf + mark);
907}
908
909static char *
910read_uv (char *str, UV *uv)
911{
912 UV r = 0;
913
914 while (*str >= '0')
915 r = r * 10 + *str++ - '0';
916
917 *uv = r;
918
919 str += !!*str; // advance over any non-zero byte
920
921 return str;
922}
923
924static void
925encode_oid (SV *oid, int relative)
926{
927 STRLEN len;
928 char *ptr = SvPV (oid, len); // utf8 vs. bytes does not matter
929
930 // we need at most as many octets as the string form
931 need (len + 1);
932 STRLEN mark = len_fixup_mark ();
933
934 UV w1, w2;
935
936 if (!relative)
937 {
938 ptr = read_uv (ptr, &w1);
939 ptr = read_uv (ptr, &w2);
940
941 put_w_nocheck (w1 * 40 + w2);
942 }
943
944 while (*ptr)
945 {
946 ptr = read_uv (ptr, &w1);
947 put_w_nocheck (w1);
948 }
949
950 len_fixup (mark);
951}
952
953static void
954encode_real (SV *data)
955{
956 NV nv = SvNV (data);
957
958 if (expect_false (nv == (NV)0.))
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;
1001
1002 SV *sv = POPs;
1003 STRLEN l;
1004 char *f = SvPV (sv, l);
1005
1006 put_length (l);
1007 memcpy (cur, f, l);
1008 cur += l;
1009
1010 PUTBACK;
1011 FREETMPS;
1012 }
1013}
1014
1015static void
1016encode_ucs (SV *data, int chrsize)
1017{
1018 STRLEN uchars = sv_len_utf8 (data);
1019 STRLEN len;;
1020 char *ptr = SvPVutf8 (data, len);
1021
1022 put_length (uchars * chrsize);
1023
1024 while (uchars--)
1025 {
1026 STRLEN uclen;
1027 UV uchr = utf8_to_uvchr_buf ((U8 *)ptr, (U8 *)ptr + len, &uclen);
1028
1029 ptr += uclen;
1030 len -= uclen;
1031
1032 if (chrsize == 4)
1033 {
1034 *cur++ = uchr >> 24;
1035 *cur++ = uchr >> 16;
1036 }
1037
1038 *cur++ = uchr >> 8;
1039 *cur++ = uchr;
1040 }
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
1061static void
1062encode_ber (SV *tuple)
1063{
1064 AV *av = ber_tuple (tuple);
1065
1066 int klass = SvIV (AvARRAY (av)[BER_CLASS]);
1067 int tag = SvIV (AvARRAY (av)[BER_TAG]);
1068 int constructed = SvIV (AvARRAY (av)[BER_FLAGS]) & 1 ? ASN_CONSTRUCTED : 0;
1069 SV *data = AvARRAY (av)[BER_DATA];
1070
1071 int identifier = (klass << ASN_CLASS_SHIFT) | constructed;
1072
1073 if (expect_false (tag >= ASN_TAG_BER))
1074 {
1075 put_u8 (identifier | ASN_TAG_BER);
1076 put_w (tag);
1077 }
1078 else
1079 put_u8 (identifier | tag);
1080
1081 if (constructed)
1082 {
1083 // we optimistically assume that only one length byte is needed
1084 // and adjust later
1085 need (1);
1086 STRLEN mark = len_fixup_mark ();
1087
1088 if (expect_false (!SvROK (data) || SvTYPE (SvRV (data)) != SVt_PVAV))
1089 croak ("BER CONSTRUCTED data must be array-reference");
1090
1091 AV *av = (AV *)SvRV (data);
1092 int fill = AvFILL (av);
1093
1094 if (expect_false (SvRMAGICAL (av)))
1095 croak ("BER CONSTRUCTED data must not be tied");
1096
1097 int i;
1098 for (i = 0; i <= fill; ++i)
1099 encode_ber (AvARRAY (av)[i]);
1100
1101 len_fixup (mark);
1102 }
1103 else
1104 switch (profile_lookup (cur_profile, klass, tag))
1105 {
1106 case BER_TYPE_NULL:
1107 put_length (0);
1108 break;
1109
1110 case BER_TYPE_BOOL:
1111 put_length (1);
1112 *cur++ = SvTRUE (data) ? 0xff : 0x00; // 0xff = DER/CER
1113 break;
1114
1115 case BER_TYPE_OID:
1116 encode_oid (data, 0);
1117 break;
1118
1119 case BER_TYPE_RELOID:
1120 encode_oid (data, 1);
1121 break;
1122
1123 case BER_TYPE_INT:
1124 encode_int (data);
1125 break;
1126
1127 case BER_TYPE_BYTES:
1128 {
1129 STRLEN len;
1130 const char *ptr = SvPVbyte (data, len);
1131 encode_data (ptr, len);
1132 }
1133 break;
1134
1135 case BER_TYPE_UTF8:
1136 {
1137 STRLEN len;
1138 const char *ptr = SvPVutf8 (data, len);
1139 encode_data (ptr, len);
1140 }
1141 break;
1142
1143 case BER_TYPE_IPADDRESS:
1144 {
1145 U8 ip[4];
1146 sscanf (SvPV_nolen (data), "%hhu.%hhu.%hhu.%hhu", ip + 0, ip + 1, ip + 2, ip + 3);
1147 encode_data ((const char *)ip, sizeof (ip));
1148 }
1149 break;
1150
1151 case BER_TYPE_UCS2:
1152 encode_ucs (data, 2);
1153 break;
1154
1155 case BER_TYPE_UCS4:
1156 encode_ucs (data, 4);
1157 break;
1158
1159 case BER_TYPE_REAL:
1160 encode_real (data);
1161 break;
1162
1163 case BER_TYPE_CROAK:
1164 croak ("class/tag %d/%d mapped to BER_TYPE_CROAK", klass, tag);
1165
1166 default:
1167 croak ("unconfigured/unsupported class/tag %d/%d", klass, tag);
1168 }
1169
1170}
1171
1172/////////////////////////////////////////////////////////////////////////////
1173
406MODULE = Convert::BER::XS PACKAGE = Convert::BER::XS 1174MODULE = Convert::BER::XS PACKAGE = Convert::BER::XS
407 1175
408PROTOTYPES: ENABLE 1176PROTOTYPES: ENABLE
409 1177
410BOOT: 1178BOOT:
411{ 1179{
412 HV *stash = gv_stashpv ("Convert::BER::XS", 1); 1180 HV *stash = gv_stashpv ("Convert::BER::XS", 1);
1181
1182 profile_stash = gv_stashpv ("Convert::BER::XS::Profile", 1);
413 1183
414 static const struct { 1184 static const struct {
415 const char *name; 1185 const char *name;
416 IV iv; 1186 IV iv;
417 } *civ, const_iv[] = { 1187 } *civ, const_iv[] = {
418 { "ASN_BOOLEAN", ASN_BOOLEAN }, 1188#define const_iv(name) { # name, name },
419 { "ASN_INTEGER32", ASN_INTEGER32 }, 1189 const_iv (ASN_BOOLEAN)
420 { "ASN_BIT_STRING", ASN_BIT_STRING }, 1190 const_iv (ASN_INTEGER)
421 { "ASN_OCTET_STRING", ASN_OCTET_STRING }, 1191 const_iv (ASN_BIT_STRING)
422 { "ASN_NULL", ASN_NULL }, 1192 const_iv (ASN_OCTET_STRING)
423 { "ASN_OBJECT_IDENTIFIER", ASN_OBJECT_IDENTIFIER }, 1193 const_iv (ASN_NULL)
424 { "ASN_TAG_BER", ASN_TAG_BER }, 1194 const_iv (ASN_OBJECT_IDENTIFIER)
425 { "ASN_TAG_MASK", ASN_TAG_MASK }, 1195 const_iv (ASN_OBJECT_DESCRIPTOR)
426 { "ASN_CONSTRUCTED", ASN_CONSTRUCTED }, 1196 const_iv (ASN_OID)
427 { "ASN_UNIVERSAL", ASN_UNIVERSAL >> ASN_CLASS_SHIFT }, 1197 const_iv (ASN_EXTERNAL)
428 { "ASN_APPLICATION", ASN_APPLICATION >> ASN_CLASS_SHIFT }, 1198 const_iv (ASN_REAL)
429 { "ASN_CONTEXT", ASN_CONTEXT >> ASN_CLASS_SHIFT }, 1199 const_iv (ASN_SEQUENCE)
430 { "ASN_PRIVATE", ASN_PRIVATE >> ASN_CLASS_SHIFT }, 1200 const_iv (ASN_ENUMERATED)
431 { "ASN_CLASS_MASK", ASN_CLASS_MASK }, 1201 const_iv (ASN_EMBEDDED_PDV)
432 { "ASN_CLASS_SHIFT", ASN_CLASS_SHIFT }, 1202 const_iv (ASN_UTF8_STRING)
433 { "ASN_SEQUENCE", ASN_SEQUENCE }, 1203 const_iv (ASN_RELATIVE_OID)
434 { "ASN_IPADDRESS", ASN_IPADDRESS }, 1204 const_iv (ASN_SET)
435 { "ASN_COUNTER32", ASN_COUNTER32 }, 1205 const_iv (ASN_NUMERIC_STRING)
436 { "ASN_UNSIGNED32", ASN_UNSIGNED32 }, 1206 const_iv (ASN_PRINTABLE_STRING)
437 { "ASN_TIMETICKS", ASN_TIMETICKS }, 1207 const_iv (ASN_TELETEX_STRING)
438 { "ASN_OPAQUE", ASN_OPAQUE }, 1208 const_iv (ASN_T61_STRING)
439 { "ASN_COUNTER64", ASN_COUNTER64 }, 1209 const_iv (ASN_VIDEOTEX_STRING)
1210 const_iv (ASN_IA5_STRING)
1211 const_iv (ASN_ASCII_STRING)
1212 const_iv (ASN_UTC_TIME)
1213 const_iv (ASN_GENERALIZED_TIME)
1214 const_iv (ASN_GRAPHIC_STRING)
1215 const_iv (ASN_VISIBLE_STRING)
1216 const_iv (ASN_ISO646_STRING)
1217 const_iv (ASN_GENERAL_STRING)
1218 const_iv (ASN_UNIVERSAL_STRING)
1219 const_iv (ASN_CHARACTER_STRING)
1220 const_iv (ASN_BMP_STRING)
440 1221
441 { "BER_CLASS" , BER_CLASS }, 1222 const_iv (ASN_UNIVERSAL)
442 { "BER_TAG" , BER_TAG }, 1223 const_iv (ASN_APPLICATION)
443 { "BER_CONSTRUCTED", BER_CONSTRUCTED }, 1224 const_iv (ASN_CONTEXT)
444 { "BER_DATA" , BER_DATA }, 1225 const_iv (ASN_PRIVATE)
1226
1227 const_iv (BER_CLASS)
1228 const_iv (BER_TAG)
1229 const_iv (BER_FLAGS)
1230 const_iv (BER_DATA)
1231
1232 const_iv (BER_TYPE_BYTES)
1233 const_iv (BER_TYPE_UTF8)
1234 const_iv (BER_TYPE_UCS2)
1235 const_iv (BER_TYPE_UCS4)
1236 const_iv (BER_TYPE_INT)
1237 const_iv (BER_TYPE_OID)
1238 const_iv (BER_TYPE_RELOID)
1239 const_iv (BER_TYPE_NULL)
1240 const_iv (BER_TYPE_BOOL)
1241 const_iv (BER_TYPE_REAL)
1242 const_iv (BER_TYPE_IPADDRESS)
1243 const_iv (BER_TYPE_CROAK)
1244
1245 const_iv (SNMP_IPADDRESS)
1246 const_iv (SNMP_COUNTER32)
1247 const_iv (SNMP_GAUGE32)
1248 const_iv (SNMP_UNSIGNED32)
1249 const_iv (SNMP_TIMETICKS)
1250 const_iv (SNMP_OPAQUE)
1251 const_iv (SNMP_COUNTER64)
445 }; 1252 };
446 1253
447 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--)
448 newCONSTSUB (stash, (char *)civ[-1].name, newSViv (civ[-1].iv)); 1255 newCONSTSUB (stash, (char *)civ[-1].name, newSViv (civ[-1].iv));
449} 1256}
450 1257
451SV * 1258void
452ber_decode (SV *ber) 1259ber_decode (SV *ber, SV *profile = &PL_sv_undef)
1260 ALIAS:
1261 ber_decode_prefix = 1
453 CODE: 1262 PPCODE:
454{ 1263{
1264 cur_profile = SvPROFILE (profile);
1265 STRLEN len;
455 buf = SvPVbyte (ber, len); 1266 buf = (U8 *)SvPVbyte (ber, len);
456 cur = buf; 1267 cur = buf;
457 rem = len; 1268 end = buf + len;
458 1269
459 RETVAL = ber_decode (); 1270 PUTBACK;
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");
460} 1281}
461 OUTPUT: RETVAL
462 1282
463void 1283void
464ber_is (SV *tuple, SV *klass = &PL_sv_undef, SV *tag = &PL_sv_undef, SV *constructed = &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)
465 PROTOTYPE: $;$$$
466 PPCODE: 1285 PPCODE:
467{ 1286{
468 if (!SvOK (tuple)) 1287 if (!SvOK (tuple))
469 XSRETURN_NO; 1288 XSRETURN_NO;
470 1289
471 if (!SvROK (tuple) || SvTYPE (SvRV (tuple)) != SVt_PVAV) 1290 if (!SvROK (tuple) || SvTYPE (SvRV (tuple)) != SVt_PVAV)
472 croak ("ber_seq: tuple must be ber tuple (array-ref)"); 1291 croak ("ber_is: tuple must be BER tuple (array-ref)");
473 1292
474 AV *av = (AV *)SvRV (tuple); 1293 AV *av = (AV *)SvRV (tuple);
475 1294
476 XPUSHs ( 1295 XPUSHs (
477 (!SvOK (klass) || SvIV (AvARRAY (av)[BER_CLASS ]) == SvIV (klass)) 1296 (!SvOK (klass) || SvIV (AvARRAY (av)[BER_CLASS]) == SvIV (klass))
478 && (!SvOK (tag) || SvIV (AvARRAY (av)[BER_TAG ]) == SvIV (tag)) 1297 && (!SvOK (tag) || SvIV (AvARRAY (av)[BER_TAG ]) == SvIV (tag))
479 && (!SvOK (constructed) || !SvIV (AvARRAY (av)[BER_CONSTRUCTED]) == !SvIV (constructed)) 1298 && (!SvOK (flags) || !SvIV (AvARRAY (av)[BER_FLAGS]) == !SvIV (flags))
480 && (!SvOK (data) || sv_eq (AvARRAY (av)[BER_DATA ], data)) 1299 && (!SvOK (data) || sv_eq (AvARRAY (av)[BER_DATA ], data))
481 ? &PL_sv_yes : &PL_sv_no); 1300 ? &PL_sv_yes : &PL_sv_undef);
482} 1301}
483 1302
484void 1303void
485ber_is_seq (SV *tuple) 1304ber_is_seq (SV *tuple)
486 PROTOTYPE: $
487 PPCODE: 1305 PPCODE:
488{ 1306{
489 if (!SvOK (tuple)) 1307 if (!SvOK (tuple))
490 XSRETURN_UNDEF; 1308 XSRETURN_UNDEF;
491 1309
492 if (!SvROK (tuple) || SvTYPE (SvRV (tuple)) != SVt_PVAV) 1310 AV *av = ber_tuple (tuple);
493 croak ("ber_seq: tuple must be ber tuple (array-ref)");
494
495 AV *av = (AV *)SvRV (tuple);
496 1311
497 XPUSHs ( 1312 XPUSHs (
498 SvIV (AvARRAY (av)[BER_CLASS ]) == ASN_UNIVERSAL 1313 SvIV (AvARRAY (av)[BER_CLASS]) == ASN_UNIVERSAL
499 && SvIV (AvARRAY (av)[BER_TAG ]) == ASN_SEQUENCE 1314 && SvIV (AvARRAY (av)[BER_TAG ]) == ASN_SEQUENCE
500 && SvIV (AvARRAY (av)[BER_CONSTRUCTED]) 1315 && SvIV (AvARRAY (av)[BER_FLAGS])
501 ? AvARRAY (av)[BER_DATA] : &PL_sv_undef); 1316 ? AvARRAY (av)[BER_DATA] : &PL_sv_undef);
502} 1317}
503 1318
504void 1319void
505ber_is_i32 (SV *tuple, IV value) 1320ber_is_int (SV *tuple, SV *value = &PL_sv_undef)
506 PROTOTYPE: $$
507 PPCODE: 1321 PPCODE:
508{ 1322{
509 if (!SvOK (tuple)) 1323 if (!SvOK (tuple))
510 XSRETURN_NO; 1324 XSRETURN_NO;
511 1325
512 if (!SvROK (tuple) || SvTYPE (SvRV (tuple)) != SVt_PVAV) 1326 AV *av = ber_tuple (tuple);
513 croak ("ber_seq: tuple must be ber tuple (array-ref)");
514 1327
515 AV *av = (AV *)SvRV (tuple); 1328 UV data = SvUV (AvARRAY (av)[BER_DATA]);
516 1329
517 XPUSHs ( 1330 XPUSHs (
518 SvIV (AvARRAY (av)[BER_CLASS ]) == ASN_UNIVERSAL 1331 SvIV (AvARRAY (av)[BER_CLASS]) == ASN_UNIVERSAL
519 && SvIV (AvARRAY (av)[BER_TAG ]) == ASN_INTEGER32 1332 && SvIV (AvARRAY (av)[BER_TAG ]) == ASN_INTEGER
520 && !SvIV (AvARRAY (av)[BER_CONSTRUCTED]) 1333 && !SvIV (AvARRAY (av)[BER_FLAGS])
521 && SvIV (AvARRAY (av)[BER_DATA ]) == value 1334 && (!SvOK (value) || data == SvUV (value))
522 ? &PL_sv_yes : &PL_sv_no); 1335 ? sv_2mortal (data ? newSVsv (AvARRAY (av)[BER_DATA]) : newSVpv ("0 but true", 0))
1336 : &PL_sv_undef);
523} 1337}
524 1338
525void 1339void
526ber_is_oid (SV *tuple, SV *oid) 1340ber_is_oid (SV *tuple, SV *oid = &PL_sv_undef)
527 PROTOTYPE: $$
528 PPCODE: 1341 PPCODE:
529{ 1342{
530 if (!SvOK (tuple)) 1343 if (!SvOK (tuple))
531 XSRETURN_NO; 1344 XSRETURN_NO;
532 1345
533 if (!SvROK (tuple) || SvTYPE (SvRV (tuple)) != SVt_PVAV) 1346 AV *av = ber_tuple (tuple);
534 croak ("ber_seq: tuple must be ber tuple (array-ref)");
535
536 AV *av = (AV *)SvRV (tuple);
537 1347
538 XPUSHs ( 1348 XPUSHs (
539 SvIV (AvARRAY (av)[BER_CLASS ]) == ASN_UNIVERSAL 1349 SvIV (AvARRAY (av)[BER_CLASS]) == ASN_UNIVERSAL
540 && SvIV (AvARRAY (av)[BER_TAG ]) == ASN_OBJECT_IDENTIFIER 1350 && SvIV (AvARRAY (av)[BER_TAG ]) == ASN_OBJECT_IDENTIFIER
541 && !SvIV (AvARRAY (av)[BER_CONSTRUCTED]) 1351 && !SvIV (AvARRAY (av)[BER_FLAGS])
542 && sv_eq (AvARRAY (av)[BER_DATA], oid) 1352 && (!SvOK (oid) || sv_eq (AvARRAY (av)[BER_DATA], oid))
543 ? &PL_sv_yes : &PL_sv_no); 1353 ? newSVsv (AvARRAY (av)[BER_DATA]) : &PL_sv_undef);
544} 1354}
545 1355
1356#############################################################################
1357
1358void
1359ber_encode (SV *tuple, SV *profile = &PL_sv_undef)
1360 PPCODE:
1361{
1362 cur_profile = SvPROFILE (profile);
1363 buf_sv = sv_2mortal (NEWSV (0, 256));
1364 SvPOK_only (buf_sv);
1365 set_buf (buf_sv);
1366
1367 PUTBACK;
1368 encode_ber (tuple);
1369 SPAGAIN;
1370
1371 SvCUR_set (buf_sv, cur - buf);
1372 XPUSHs (buf_sv);
1373}
1374
1375SV *
1376ber_int (SV *sv)
1377 CODE:
1378{
1379 AV *av = newAV ();
1380 av_fill (av, BER_ARRAYSIZE - 1);
1381 AvARRAY (av)[BER_CLASS] = newSVcacheint (ASN_UNIVERSAL);
1382 AvARRAY (av)[BER_TAG ] = newSVcacheint (ASN_INTEGER);
1383 AvARRAY (av)[BER_FLAGS] = newSVcacheint (0);
1384 AvARRAY (av)[BER_DATA ] = newSVsv (sv);
1385 RETVAL = newRV_noinc ((SV *)av);
1386}
1387 OUTPUT: RETVAL
1388
1389# TODO: not arrayref, but elements?
1390SV *
1391ber_seq (SV *arrayref)
1392 CODE:
1393{
1394 AV *av = newAV ();
1395 av_fill (av, BER_ARRAYSIZE - 1);
1396 AvARRAY (av)[BER_CLASS] = newSVcacheint (ASN_UNIVERSAL);
1397 AvARRAY (av)[BER_TAG ] = newSVcacheint (ASN_SEQUENCE);
1398 AvARRAY (av)[BER_FLAGS] = newSVcacheint (1);
1399 AvARRAY (av)[BER_DATA ] = newSVsv (arrayref);
1400 RETVAL = newRV_noinc ((SV *)av);
1401}
1402 OUTPUT: RETVAL
1403
1404MODULE = Convert::BER::XS PACKAGE = Convert::BER::XS::Profile
1405
1406SV *
1407new (SV *klass)
1408 CODE:
1409 RETVAL = profile_new ();
1410 OUTPUT: RETVAL
1411
1412void
1413set (SV *profile, int klass, int tag, int type)
1414 CODE:
1415 profile_set (SvPROFILE (profile), klass, tag, type);
1416
1417IV
1418get (SV *profile, int klass, int tag)
1419 CODE:
1420 RETVAL = profile_lookup (SvPROFILE (profile), klass, tag);
1421 OUTPUT: RETVAL
1422
1423void
1424_set_default (SV *profile)
1425 CODE:
1426 default_profile = SvPROFILE (profile);
1427
1428

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines