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