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

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines