generic-library/msgpack
1
0
Fork 0
mirror of https://github.com/msgpack/msgpack-c.git synced 2025-10-23 08:31:45 +02:00
Code Issues Projects Releases Wiki Activity

oops. 0.21 breakes ithreads support!

Browse Source
This commit is contained in:
tokuhirom
2010-09-12 00:09:44 +09:00
parent 1e6262f24f
commit a41f7ce3bd
4 changed files with 31 additions and 21 deletions
Download Patch File Download Diff File Expand all files Collapse all files

43
perl/xs-src/unpack.c
View File

@@ -4,7 +4,7 @@ extern "C" {
#define NEED_newRV_noinc
#define NEED_sv_2pv_flags
#include "perlxs.h"
#include "xshelper.h"
#ifdef __cplusplus
};
@@ -36,6 +36,7 @@ typedef struct {
STATIC_INLINE SV *
get_bool (const char *name) {
dTHX;
SV * sv = sv_mortalcopy(get_sv( name, 1 ));
SvREADONLY_on(sv);
@@ -57,19 +58,20 @@ static int template_execute(msgpack_unpack_t* u,
const char* data, size_t len, size_t* off);
STATIC_INLINE SV* template_callback_root(unpack_user* u)
{ return &PL_sv_undef; }
{ dTHX; return &PL_sv_undef; }
STATIC_INLINE int template_callback_uint8(unpack_user* u, uint8_t d, SV** o)
{ *o = sv_2mortal(newSVuv(d)); return 0; }
{ dTHX; *o = sv_2mortal(newSVuv(d)); return 0; }
STATIC_INLINE int template_callback_uint16(unpack_user* u, uint16_t d, SV** o)
{ *o = sv_2mortal(newSVuv(d)); return 0; }
{ dTHX; *o = sv_2mortal(newSVuv(d)); return 0; }
STATIC_INLINE int template_callback_uint32(unpack_user* u, uint32_t d, SV** o)
{ *o = sv_2mortal(newSVuv(d)); return 0; }
{ dTHX; *o = sv_2mortal(newSVuv(d)); return 0; }
STATIC_INLINE int template_callback_uint64(unpack_user* u, uint64_t d, SV** o)
{
dTHX;
#if IVSIZE==4
*o = sv_2mortal(newSVnv(d));
#else
@@ -79,47 +81,47 @@ STATIC_INLINE int template_callback_uint64(unpack_user* u, uint64_t d, SV** o)
}
STATIC_INLINE int template_callback_int8(unpack_user* u, int8_t d, SV** o)
{ *o = sv_2mortal(newSViv((long)d)); return 0; }
{ dTHX; *o = sv_2mortal(newSViv((long)d)); return 0; }
STATIC_INLINE int template_callback_int16(unpack_user* u, int16_t d, SV** o)
{ *o = sv_2mortal(newSViv((long)d)); return 0; }
{ dTHX; *o = sv_2mortal(newSViv((long)d)); return 0; }
STATIC_INLINE int template_callback_int32(unpack_user* u, int32_t d, SV** o)
{ *o = sv_2mortal(newSViv((long)d)); return 0; }
{ dTHX; *o = sv_2mortal(newSViv((long)d)); return 0; }
STATIC_INLINE int template_callback_int64(unpack_user* u, int64_t d, SV** o)
{ *o = sv_2mortal(newSViv(d)); return 0; }
{ dTHX; *o = sv_2mortal(newSViv(d)); return 0; }
STATIC_INLINE int template_callback_float(unpack_user* u, float d, SV** o)
{ *o = sv_2mortal(newSVnv(d)); return 0; }
{ dTHX; *o = sv_2mortal(newSVnv(d)); return 0; }
STATIC_INLINE int template_callback_double(unpack_user* u, double d, SV** o)
{ *o = sv_2mortal(newSVnv(d)); return 0; }
{ dTHX; *o = sv_2mortal(newSVnv(d)); return 0; }
/* &PL_sv_undef is not so good. see http://gist.github.com/387743 */
STATIC_INLINE int template_callback_nil(unpack_user* u, SV** o)
{ *o = sv_newmortal(); return 0; }
{ dTHX; *o = sv_newmortal(); return 0; }
STATIC_INLINE int template_callback_true(unpack_user* u, SV** o)
{ *o = get_bool("Data::MessagePack::true") ; return 0; }
{ dTHX; *o = get_bool("Data::MessagePack::true") ; return 0; }
STATIC_INLINE int template_callback_false(unpack_user* u, SV** o)
{ *o = get_bool("Data::MessagePack::false") ; return 0; }
{ dTHX; *o = get_bool("Data::MessagePack::false") ; return 0; }
STATIC_INLINE int template_callback_array(unpack_user* u, unsigned int n, SV** o)
{ AV* a = (AV*)sv_2mortal((SV*)newAV()); *o = sv_2mortal((SV*)newRV_inc((SV*)a)); av_extend(a, n); return 0; }
{ dTHX; AV* a = (AV*)sv_2mortal((SV*)newAV()); *o = sv_2mortal((SV*)newRV_inc((SV*)a)); av_extend(a, n); return 0; }
STATIC_INLINE int template_callback_array_item(unpack_user* u, SV** c, SV* o)
{ av_push((AV*)SvRV(*c), o); SvREFCNT_inc(o); return 0; } /* FIXME set value directry RARRAY_PTR(obj)[RARRAY_LEN(obj)++] */
{ dTHX; av_push((AV*)SvRV(*c), o); SvREFCNT_inc(o); return 0; } /* FIXME set value directry RARRAY_PTR(obj)[RARRAY_LEN(obj)++] */
STATIC_INLINE int template_callback_map(unpack_user* u, unsigned int n, SV** o)
{ HV * h = (HV*)sv_2mortal((SV*)newHV()); *o = sv_2mortal(newRV_inc((SV*)h)); return 0; }
{ dTHX; HV * h = (HV*)sv_2mortal((SV*)newHV()); *o = sv_2mortal(newRV_inc((SV*)h)); return 0; }
STATIC_INLINE int template_callback_map_item(unpack_user* u, SV** c, SV* k, SV* v)
{ hv_store_ent((HV*)SvRV(*c), k, v, 0); SvREFCNT_inc(v); return 0; }
{ dTHX; hv_store_ent((HV*)SvRV(*c), k, v, 0); SvREFCNT_inc(v); return 0; }
STATIC_INLINE int template_callback_raw(unpack_user* u, const char* b, const char* p, unsigned int l, SV** o)
{ *o = sv_2mortal((l==0) ? newSVpv("", 0) : newSVpv(p, l)); return 0; }
{ dTHX; *o = sv_2mortal((l==0) ? newSVpv("", 0) : newSVpv(p, l)); return 0; }
/* { *o = newSVpvn_flags(p, l, SVs_TEMP); return 0; } <= this does not works. */
#define UNPACKER(from, name) \
@@ -133,6 +135,7 @@ STATIC_INLINE int template_callback_raw(unpack_user* u, const char* b, const cha
STATIC_INLINE SV* _msgpack_unpack(SV* data, int limit) {
msgpack_unpack_t mp;
dTHX;
unpack_user u = {0, &PL_sv_undef};
int ret;
size_t from = 0;
@@ -195,6 +198,7 @@ XS(xs_unpack) {
/* http://twitter.com/frsyuki/status/13249304748 */
STATIC_INLINE void _reset(SV* self) {
dTHX;
unpack_user u = {0, &PL_sv_undef, 0};
UNPACKER(self, mp);
@@ -221,6 +225,7 @@ XS(xs_unpacker_new) {
}
STATIC_INLINE SV* _execute_impl(SV* self, SV* data, UV off, I32 limit) {
dTHX;
UNPACKER(self, mp);
size_t from = off;