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

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines