#include "perl.h"
#include "XSUB.h"
-#define SLOT_WEAKEN 0x01
+#define NEED_newRV_noinc
+#define NEED_newSVpvn_share
+#define NEED_sv_2pv_flags
+#include "ppport.h"
-/* FIXME
- * needs to be made into Moose::XS::Meta::Instance and Meta::Slot for the
- * metadata, with a proper destructor. XSANY still points to this struct, but
- * it is shared by all functions of the same type.
- *
- * Instance contains SvSTASH, and SLOT slots[]
- *
- * On recreation of the meta instance we refresh the SLOT value of all the CVs
- * we installed
- *
- * need a good way to handle time between invalidate and regeneration (just
- * check XSANY and call get_meta_instance if null?)
- */
-
-
-/* FIXME
- * slot access is one of 4 values in flags:
- * 0 == hash
- * 1 == array
- * 3 == fptr (allows access into C structs, etc)
- * 4 == callsv (really a special case of fptr)
- *
- * for fptr case we have a pointer to a vtable for get/set/has/delete, all of which take the same args as set_slot_value
- */
-
-/* FIXME
- * type constraints are already implemented by konobi
- * should be trivial to do coercions for the core types, too
- *
- * TypeConstraint::Class can compare SvSTASH by ptr, and if it's neq *then*
- * call ->isa (should handle vast majority of cases)
- *
- * base parametrized types are also trivial
- *
- * ClassName is get_stathpvn
- */
+#ifndef XSPROTO
+#define XSPROTO(name) void name(pTHX_ CV* cv)
+#endif
-/* FIXME
- * for a constructor we have SLOT *slots, and iterate that, removing init_arg
- * we can preallocate the structure to the right size (maybe even with the
- * right HEs?), and do various other prehashing hacks to gain speed
- * */
+#ifndef gv_stashpvs
+#define gv_stashpvs(x, y) gv_stashpvn(STR_WITH_LEN(x), y)
+#endif
/* FIXME
* delegations and attribute helpers:
*
* typedef struct {
- * SLOT *slot;
+ * ATTR *attr;
* pv *method;
* } delegation;
*
* typedef struct {
- * SLOT *slot;
+ * ATTR *attr;
* I32 *type; // hash, array, whatever + vtable for operation
* } attributehelper;
*/
-typedef struct {
- U32 hash;
+
+STATIC MGVTBL null_mg_vtbl = {
+ NULL, /* get */
+ NULL, /* set */
+ NULL, /* len */
+ NULL, /* clear */
+ NULL, /* free */
+#if MGf_COPY
+ NULL, /* copy */
+#endif /* MGf_COPY */
+#if MGf_DUP
+ NULL, /* dup */
+#endif /* MGf_DUP */
+#if MGf_LOCAL
+ NULL, /* local */
+#endif /* MGf_LOCAL */
+};
+
+STATIC MAGIC *stash_in_mg (pTHX_ SV *sv, SV *obj) {
+ MAGIC *mg = sv_magicext(sv, obj, PERL_MAGIC_ext, &null_mg_vtbl, NULL, 0 );
+ mg->mg_flags |= MGf_REFCOUNTED;
+
+ return mg;
+}
+
+STATIC SV *get_stashed_in_mg(pTHX_ SV *sv) {
+ MAGIC *mg, *moremagic;
+
+ if (SvTYPE(sv) >= SVt_PVMG) {
+ for (mg = SvMAGIC(sv); mg; mg = mg->mg_moremagic) {
+ if ((mg->mg_type == PERL_MAGIC_ext) && (mg->mg_virtual == &null_mg_vtbl))
+ break;
+ }
+ if (mg)
+ return mg->mg_obj;
+ }
+
+ return NULL;
+}
+
+/* this is a enum of checks */
+typedef enum {
+ Any, /* or item, or bool */
+ Undef,
+ Defined,
+ Str, /* or value */
+ Num,
+ Int,
+ GlobRef, /* SVt_PVGV */
+ ArrayRef, /* SVt_PVAV */
+ HashRef, /* SVt_PVHV */
+ CodeRef, /* SVt_PVCV */
+ Ref,
+ ScalarRef,
+ FileHandle,
+ RegexpRef,
+ Object,
+ ClassName,
+ /* complex checks */
+ Role,
+ Enum,
+} TC;
+
+typedef enum {
+ tc_none = 0,
+ tc_type,
+ tc_stash,
+ tc_cv,
+ tc_op,
+ tc_fptr,
+} tc_kind;
+
+typedef union {
+ TC type;
+ SV *sv;
+ OP *op;
+ bool (*fptr)(pTHX_ SV *type_constraint, SV *sv);
+} TC_CHECK;
+
+typedef union {
+ char *builder;
SV *sv;
- U32 flags /* slot type, TC behavior, coerce, weaken, (no default | default, builder + lazy), auto_deref */
- /* FIXME
- * type constraint (pointer or enum union)
- * default / builder ptr (or SV *)
- * initializer
- */
-} SLOT;
+ OP *op;
+ U32 type;
+} DEFAULT;
+
+typedef enum {
+ default_none = 0,
+ default_normal,
+ default_builder,
+ default_type,
+ default_op,
+} default_kind;
+
+typedef struct {
+ /* the meta instance struct */
+ struct mi *mi;
+
+ U32 flags; /* slot type, TC behavior, coerce, weaken, (no default | default, builder + lazy), auto_deref */
+
+ /* slot access fields */
+ SV *slot_sv; /* value of the slot (slot name presumably) */
+ U32 slot_u32; /* for optimized access (precomputed hash or otherr) */
+
+ DEFAULT def; /* cv, value or other, depending on flags */
+
+ TC_CHECK tc_check; /* cv, value or other, dependidng on flags */
+ SV *type_constraint; /* meta attr */
+
+ CV *initializer;
+ CV *trigger;
+
+ SV *meta_attr; /* the meta attr object */
+ AV *cvs; /* CVs which use this attr */
+} ATTR;
+
+/* slot flags:
+ * instance reading writing
+ * 00000000 00000000 00000000 00000000
+ * ^ trigger
+ * ^ weak
+ * ^ tc.sv is refcounted
+ * ^^^ tc_kind
+ * ^ coerce
+ * ^^^ default_kind
+ * ^ lazy
+ * ^ def.sv is refcounted
+ * ^ required
+ * ^^^^^^^ if 0 then nothing special (just hash)? FIXME TBD
+ */
+
+#define ATTR_INSTANCE_MASK 0xff000000
+#define ATTR_READING_MASK 0x0000ff00
+#define ATTR_WRITING_MASK 0x000000ff
+
+#define ATTR_MASK_TYPE 0x7
+
+#define ATTR_MASK_DEFAULT 0x700
+#define ATTR_SHIFT_DEFAULT 8
+
+#define ATTR_LAZY 0x800
+#define ATTR_DEFREFCNT 0x1000
+
+#define ATTR_COERCE 0x8
+#define ATTR_TCREFCNT 0x10
+#define ATTR_WEAK 0x20
+#define ATTR_TRIGGER 0x40
-#define dSLOT SLOT *slot = INT2PTR(SLOT *, XSANY.any_i32)
+#define ATTR_ISWEAK(attr) ( attr->flags & ATTR_WEAK )
+#define ATTR_ISLAZY(attr) ( attr->flags & ATTR_LAZY )
+#define ATTR_ISCOERCE(attr) ( attr->flags & ATTR_COERCE )
+
+#define ATTR_TYPE(f) ( attr->flags & 0x7 )
+#define ATTR_DEFAULT(f) ( ( attr->flags & ATTR_MASK_DEFAULT ) >> ATTR_SHIFT_DEFAULT )
+
+#define ATTR_DUMB_READER(attr) !ATTR_IS_LAZY(attr)
+#define ATTR_DUMB_WRITER(attr) ( ( attr->flags & ATTR_WRITING_MASK ) == 0 )
+#define ATTR_DUMB_INSTANCE(attr) ( ( attr->flags & ATTR_INSTANCE_MASK ) == 0 )
+
+#define dATTR ATTR *attr = (XSANY.any_i32 ? INT2PTR(ATTR *, (XSANY.any_i32)) : define_attr(aTHX_ cv))
+
+
+/* FIXME define a vtable that does call_sv */
+typedef struct {
+ SV * (*get)(pTHX_ SV *self, ATTR *attr);
+ void (*set)(pTHX_ SV *self, ATTR *attr, SV *value);
+ bool * (*has)(pTHX_ SV *self, ATTR *attr);
+ SV * (*delete)(pTHX_ SV *self, ATTR *attr);
+} instance_vtbl;
-/* utility functions */
-STATIC SLOT *new_slot_from_key (SV *key, U32 flags) {
- SLOT *slot = (SLOT *)malloc(sizeof(SLOT));
+typedef enum {
+ hash = 0,
+
+ /* these are not yet implemented */
+ array,
+ fptr,
+ cv,
+ judy,
+} instance_types;
+
+typedef struct mi {
+ HV *stash;
+
+ /* slot access method */
+ instance_types type;
+ instance_vtbl *vtbl;
+
+ /* attr descriptors */
+ I32 num_attrs;
+ ATTR *attrs;
+} MI;
+
+
+
+
+STATIC bool check_is_scalar_ref(SV *sv) {
+ if( SvROK(sv) ) {
+ switch (SvTYPE(SvRV(sv))) {
+ case SVt_IV:
+ case SVt_NV:
+ case SVt_PV:
+ case SVt_NULL:
+ return 1;
+ break;
+ default:
+ return 0;
+ }
+ }
+ return 0;
+}
+
+STATIC bool check_reftype(TC type, SV *sv) {
+ int svt;
+
+ if ( !SvROK(sv) )
+ return 0;
+
+ switch (type) {
+ case GlobRef:
+ svt = SVt_PVGV;
+ break;
+ case ArrayRef:
+ svt = SVt_PVAV;
+ break;
+ case HashRef:
+ svt = SVt_PVHV;
+ break;
+ case CodeRef:
+ svt = SVt_PVCV;
+ break;
+ }
+
+ return SvTYPE(SvRV(sv)) == svt;
+}
+
+STATIC bool check_sv_class(pTHX_ HV *stash, SV *sv) {
+ dSP;
+ bool ret;
+ SV *rv;
+
+ if (!sv)
+ return 0;
+ SvGETMAGIC(sv);
+ if (!SvROK(sv))
+ return 0;
+ rv = (SV*)SvRV(sv);
+ if (!SvOBJECT(rv))
+ return 0;
+ if (SvSTASH(rv) == stash)
+ return 1;
+
+ ENTER;
+ SAVETMPS;
+ PUSHMARK(SP);
+ XPUSHs(sv);
+ XPUSHs(sv_2mortal(newSVpv(HvNAME_get(stash), 0)));
+ PUTBACK;
+
+ call_method("isa", G_SCALAR);
+
+ SPAGAIN;
+ ret = SvTRUE(TOPs);
+
+ FREETMPS;
+ LEAVE;
+
+ return ret;
+}
+
+STATIC bool check_sv_type (TC type, SV *sv) {
+ if (!sv)
+ return 0;
+
+ switch (type) {
+ case Any:
+ return 1;
+ break;
+ case Undef:
+ return !SvOK(sv);
+ break;
+ case Defined:
+ return SvOK(sv);
+ break;
+ case Str:
+ return (SvOK(sv) && !SvROK(sv));
+ case Num:
+#if (PERL_VERSION < 8) || (PERL_VERSION == 8 && PERL_SUBVERSION <5)
+ if (!SvPOK(sv) && !SvPOKp(sv))
+ return SvFLAGS(sv) & (SVf_NOK|SVp_NOK|SVf_IOK|SVp_IOK);
+ else
+#endif
+ return looks_like_number(sv);
+ break;
+ case Int:
+ if ( SvIOK(sv) ) {
+ return 1;
+ } else if ( SvPOK(sv) ) {
+ /* FIXME i really don't like this */
+ int i;
+ STRLEN len;
+ char *pv = SvPV(sv, len);
+ char *end = pv + len;
+ char *tail = end;
+
+ errno = 0;
+ i = strtol(pv, &tail, 0);
+
+ if ( errno ) return 0;
+
+ while ( tail != end ) {
+ if ( !isspace(*tail++) ) return 0;
+ }
+
+ return 1;
+ }
+ return 0;
+ break;
+ case Ref:
+ return SvROK(sv);
+ break;
+ case ScalarRef:
+ return check_is_scalar_ref(sv);
+ break;
+ case ArrayRef:
+ case HashRef:
+ case CodeRef:
+ case GlobRef:
+ return check_reftype(type, sv);
+ break;
+ case Object:
+ return sv_isobject(sv);
+ break;
+ case ClassName:
+ if ( SvOK(sv) && !SvROK(sv) ) {
+ STRLEN len;
+ char *pv;
+ pv = SvPV(sv, len);
+ return ( gv_stashpvn(pv, len, 0) != NULL );
+ }
+ return 0;
+ break;
+ case RegexpRef:
+ return sv_isa(sv, "Regexp");
+ break;
+ case FileHandle:
+ croak("todo");
+ break;
+ default:
+ croak("todo");
+ }
+
+ return 0;
+}
+
+STATIC bool check_sv_cv (pTHX_ SV *cv, SV *sv) {
+ bool ret;
+ dSP;
+
+ ENTER;
+ SAVETMPS;
+ PUSHMARK(SP);
+ XPUSHs(sv);
+ PUTBACK;
+
+ call_sv(cv, G_SCALAR);
+
+ SPAGAIN;
+ ret = SvTRUE(POPs);
+
+ PUTBACK;
+ FREETMPS;
+ LEAVE;
+
+ return ret;
+}
+
+STATIC bool check_type_constraint(pTHX_ tc_kind kind, TC_CHECK tc_check, SV *type_constraint, SV *sv) {
+ switch (kind) {
+ case tc_none:
+ return 1;
+ break;
+ case tc_type:
+ return check_sv_type(tc_check.type, sv);
+ break;
+ case tc_stash:
+ return check_sv_class(aTHX_ (HV *)tc_check.sv, sv);
+ break;
+ case tc_fptr:
+ return tc_check.fptr(aTHX_ type_constraint, sv);
+ break;
+ case tc_cv:
+ return check_sv_cv(aTHX_ tc_check.sv, sv);
+ break;
+ case tc_op:
+ croak("todo");
+ break;
+ }
+
+ croak("todo");
+ return 0;
+}
+
+
+STATIC void init_attr (MI *mi, ATTR *attr, AV *desc) {
+ U32 flags = 0;
U32 hash;
STRLEN len;
- char *pv = SvPV(key, len);
+ char *pv;
+ I32 ix = av_len(desc);
+ SV **params = AvARRAY(desc);
+ SV *tc;
+ SV *key;
+
+ attr->mi = mi;
+
+ if ( ix != 12 )
+ croak("wrong number of args (%d != 13)", ix + 1);
+
+ for ( ; ix >= 0; ix-- ) {
+ if ( !params[ix] || params[ix] == &PL_sv_undef )
+ croak("bad params");
+ }
+
+ if ( !SvROK(params[1]) || SvTYPE(SvRV(params[1])) != SVt_PVAV )
+ croak("slots is not an array");
+
+ if ( av_len((AV *)SvRV(params[1])) != 0 )
+ croak("Only unary slots are supported at the moment");
+
+ /* calculate a hash from the slot */
+ /* FIXME arrays etc should also be supported */
+ key = *av_fetch((AV *)SvRV(params[1]), 0, 0);
+ pv = SvPV(key, len);
PERL_HASH(hash, pv, len);
- slot->sv = newSVpvn_share(pv, len, hash);
- slot->hash = hash;
- slot->flags = flags;
- return slot;
+
+ /* FIXME better organize these */
+ if ( SvTRUE(params[2]) )
+ flags |= ATTR_WEAK;
+
+ if ( SvTRUE(params[3]) )
+ flags |= ATTR_COERCE;
+
+ if ( SvTRUE(params[4]) )
+ flags |= ATTR_LAZY;
+
+ tc = params[5];
+
+ if ( SvOK(tc) ) {
+ int tc_kind = SvIV(params[6]);
+ SV *data = params[7];
+
+ switch (tc_kind) {
+ case tc_type:
+ attr->tc_check.type = SvIV(data);
+ break;
+ case tc_stash:
+ flags |= ATTR_TCREFCNT;
+ attr->tc_check.sv = (SV *)gv_stashsv(data, 0);
+ break;
+ case tc_cv:
+ flags |= ATTR_TCREFCNT;
+ attr->tc_check.sv = SvRV(data);
+ if ( SvTYPE(attr->tc_check.sv) != SVt_PVCV )
+ croak("compiled type constraint is not a coderef");
+ break;
+ default:
+ croak("todo");
+ }
+
+ flags |= tc_kind;
+ }
+
+
+ if ( SvTRUE(params[10]) ) { /* has default */
+ SV *sv = params[11];
+
+ if ( SvROK(sv) ) {
+ attr->def.sv = SvRV(sv);
+ if ( SvTYPE(attr->def.sv) != SVt_PVCV )
+ croak("compiled type constraint is not a coderef");
+ } else {
+ attr->def.sv = newSVsv(sv);
+ sv_2mortal(attr->def.sv); /* in case of error soon, we refcnt inc it later after we're done checking params */
+ }
+
+ flags |= ( ATTR_DEFREFCNT | ( default_normal << ATTR_SHIFT_DEFAULT ) );
+ } else if ( SvOK(params[12]) ) { /* builder */
+ attr->def.sv = newSVsv(params[12]);
+ flags |= ( ATTR_DEFREFCNT | ( default_builder << ATTR_SHIFT_DEFAULT ) );
+ }
+
+ attr->flags = flags; /* FIXME default_kind */
+
+ attr->trigger = SvROK(params[6]) ? (CV *)SvRV(params[6]) : NULL;
+ if ( attr->trigger && SvTYPE(attr->trigger) != SVt_PVCV )
+ croak("trigger is not a coderef");
+
+ attr->initializer = SvROK(params[7]) ? (CV *)SvRV(params[7]) : NULL;
+ if ( attr->initializer && SvTYPE(attr->initializer) != SVt_PVCV )
+ croak("initializer is not a coderef");
+
+ /* copy refs */
+ attr->meta_attr = newSVsv(params[0]);
+ attr->type_constraint = newSVsv(tc);
+ SvREFCNT_inc(attr->trigger);
+ SvREFCNT_inc(attr->initializer);
+ if ( flags & ATTR_TCREFCNT ) SvREFCNT_inc(attr->tc_check.sv);
+ if ( flags & ATTR_DEFREFCNT ) SvREFCNT_inc(attr->def.sv);
+
+ attr->slot_sv = newSVpvn_share(pv, len, hash);
+ attr->slot_u32 = hash;
+
+ /* cross refs to CVs which use this struct */
+ attr->cvs = newAV();
+}
+
+STATIC MI *new_mi (pTHX_ HV *stash, AV *attrs) {
+ MI *mi;
+ I32 ix;
+ const I32 num = av_len(attrs) + 1;
+
+ Newx(mi, 1, MI);
+
+ SvREFCNT_inc_simple(stash);
+ mi->stash = stash;
+
+ mi->type = 0; /* nothing else implemented yet */
+
+ /* initialize attributes */
+ mi->num_attrs = num;
+ Newx(mi->attrs, num, ATTR);
+ for ( ix = 0; ix < num; ix++ ) {
+ SV **desc = av_fetch(attrs, ix, 0);
+
+ if ( !desc || !*desc || !SvROK(*desc) || !(SvTYPE(SvRV(*desc)) == SVt_PVAV) ) {
+ croak("Attribute descriptor has to be a hash reference");
+ }
+
+ init_attr(mi, &mi->attrs[ix], (AV *)SvRV(*desc));
+ }
+
+ return mi;
+}
+
+STATIC void delete_mi (pTHX_ MI *mi) {
+ I32 i, j;
+
+ for ( i = 0; i < mi->num_attrs; i++ ) {
+ ATTR *attr = &mi->attrs[i];
+ /* clear the pointers to this meta attr from all the CVs */
+ SV **cvs = AvARRAY(attr->cvs);
+ for ( j = av_len(attr->cvs); j >= 0; j-- ) {
+ CV *cv = (CV *)cvs[j];
+ XSANY.any_i32 = 0;
+ }
+
+ SvREFCNT_dec(attr->cvs);
+ SvREFCNT_dec(attr->slot_sv);
+ SvREFCNT_dec(attr->type_constraint);
+ if ( attr->flags & ATTR_TCREFCNT ) SvREFCNT_dec(attr->tc_check.sv);
+ if ( attr->flags & ATTR_DEFREFCNT ) SvREFCNT_dec(attr->def.sv);
+ SvREFCNT_dec(attr->initializer);
+ SvREFCNT_dec(attr->trigger);
+ SvREFCNT_dec(attr->meta_attr);
+ }
+
+ Safefree(mi->attrs);
+ Safefree(mi);
+}
+
+STATIC SV *new_mi_obj (pTHX_ MI *mi) {
+ HV *stash = gv_stashpvs("Moose::XS::Meta::Instance",0);
+ SV *obj = newRV_noinc(newSViv(PTR2IV(mi)));
+ sv_bless( obj, stash );
+ return obj;
+}
+
+STATIC SV *attr_to_meta_instance(pTHX_ SV *meta_attr) {
+ dSP;
+ I32 count;
+ SV *mi;
+
+ if ( !meta_attr )
+ croak("No attr found in magic!");
+
+ ENTER;
+ SAVETMPS;
+ PUSHMARK(SP);
+ XPUSHs(meta_attr);
+ PUTBACK;
+ count = call_pv("Moose::XS::attr_to_meta_instance", G_SCALAR);
+
+ if ( count != 1 )
+ croak("attr_to_meta_instance borked (%d args returned, expecting 1)", count);
+
+ SPAGAIN;
+ mi = POPs;
+
+ SvREFCNT_inc(mi);
+
+ PUTBACK;
+ FREETMPS;
+ LEAVE;
+
+ return sv_2mortal(mi);
+}
+
+STATIC SV *perl_mi_to_c_mi(pTHX_ SV *perl_mi) {
+ dSP;
+ I32 count;
+ MI *mi = NULL;
+ SV *class;
+ SV *attrs;
+ HV *stash;
+
+ ENTER;
+ SAVETMPS;
+ PUSHMARK(SP);
+ XPUSHs(perl_mi);
+ PUTBACK;
+ count = call_pv("Moose::XS::meta_instance_to_attr_descs", G_ARRAY);
+
+ if ( count != 2 )
+ croak("meta_instance_to_attr_descs borked (%d args returned, expecting 2)", count);
+
+ SPAGAIN;
+ attrs = POPs;
+ class = POPs;
+
+ PUTBACK;
+
+ stash = gv_stashsv(class, 0);
+
+ mi = new_mi(aTHX_ stash, (AV *)SvRV(attrs));
+
+ FREETMPS;
+ LEAVE;
+
+ return new_mi_obj(aTHX_ mi);
+}
+
+STATIC ATTR *mi_find_attr(MI *mi, SV *meta_attr) {
+ I32 ix;
+
+ for ( ix = 0; ix < mi->num_attrs; ix++ ) {
+ if ( SvRV(mi->attrs[ix].meta_attr) == SvRV(meta_attr) ) {
+ return &mi->attrs[ix];
+ }
+ }
+
+ sv_dump(meta_attr);
+ croak("Attr not found");
+ return NULL;
+}
+
+STATIC ATTR *get_attr(pTHX_ CV *cv) {
+ SV *meta_attr = get_stashed_in_mg(aTHX_ (SV *)cv);
+ SV *perl_mi = attr_to_meta_instance(aTHX_ meta_attr);
+ SV *c_mi = get_stashed_in_mg(aTHX_ SvRV(perl_mi));
+ MI *mi;
+
+ if (!c_mi) {
+ c_mi = perl_mi_to_c_mi(aTHX_ perl_mi);
+ stash_in_mg(aTHX_ SvRV(perl_mi), c_mi);
+ SvREFCNT_dec(c_mi);
+ }
+
+ mi = INT2PTR(MI *, SvIV(SvRV(c_mi)));
+
+ return mi_find_attr(mi, meta_attr);
+}
+
+STATIC ATTR *define_attr (pTHX_ CV *cv) {
+ ATTR *attr = get_attr(aTHX_ cv);
+ assert(attr);
+
+ XSANY.any_i32 = PTR2IV(attr);
+
+ SvREFCNT_inc(cv);
+ av_push( attr->cvs, (SV *)cv );
+
+ return attr;
}
-STATIC void weaken(SV *sv) {
+STATIC void weaken(pTHX_ SV *sv) {
#ifdef SvWEAKREF
- sv_rvweaken(sv);
+ sv_rvweaken(sv); /* FIXME i think this might warn when weakening an already weak ref */
#else
croak("weak references are not implemented in this release of perl");
#endif
/* meta instance protocol */
-STATIC SV *get_slot_value(SV *self, SLOT *slot) {
+STATIC SV *get_slot_value(pTHX_ SV *self, ATTR *attr) {
HE *he;
assert(self);
assert(SvROK(self));
assert(SvTYPE(SvRV(self)) == SVt_PVHV);
- if (he = hv_fetch_ent((HV *)SvRV(self), slot->sv, 0, slot->hash))
+ assert( ATTR_DUMB_INSTANCE(attr) );
+
+ if ((he = hv_fetch_ent((HV *)SvRV(self), attr->slot_sv, 0, attr->slot_u32)))
return HeVAL(he);
else
return NULL;
}
-STATIC void set_slot_value(SV *self, SLOT *slot, SV *value) {
+STATIC void set_slot_value(pTHX_ SV *self, ATTR *attr, SV *value) {
HE *he;
+ SV *copy;
assert(self);
assert(SvROK(self));
assert(SvTYPE(SvRV(self)) == SVt_PVHV);
- SvREFCNT_inc(value);
+ assert( ATTR_DUMB_INSTANCE(attr) );
+
+ copy = newSVsv(value);
+
+ he = hv_store_ent((HV*)SvRV(self), attr->slot_sv, copy, attr->slot_u32);
- he = hv_store_ent((HV*)SvRV(self), slot->sv, value, slot->hash);
if (he != NULL) {
- if ( slot->flags & SLOT_WEAKEN )
- weaken(HeVAL(he));
+ if ( ATTR_ISWEAK(attr) )
+ weaken(aTHX_ HeVAL(he));
} else {
+ SvREFCNT_dec(copy);
croak("Hash store failed.");
}
}
-STATIC bool has_slot_value(SV *self, SLOT *slot) {
+STATIC bool has_slot_value(pTHX_ SV *self, ATTR *attr) {
+ assert(self);
+ assert(SvROK(self));
+ assert(SvTYPE(SvRV(self)) == SVt_PVHV);
+
+ assert( ATTR_DUMB_INSTANCE(attr) );
+
+ return hv_exists_ent((HV *)SvRV(self), attr->slot_sv, attr->slot_u32);
+}
+
+STATIC SV *deinitialize_slot(pTHX_ SV *self, ATTR *attr) {
assert(self);
assert(SvROK(self));
assert(SvTYPE(SvRV(self)) == SVt_PVHV);
- return hv_exists_ent((HV *)SvRV(self), slot->sv, slot->hash);
+ assert( ATTR_DUMB_INSTANCE(attr) );
+
+ return hv_delete_ent((HV *)SvRV(self), attr->slot_sv, 0, attr->slot_u32);
+}
+
+STATIC void setter_common(pTHX_ SV *self, ATTR *attr, SV *value);
+
+
+STATIC SV *get_default(pTHX_ SV *self, ATTR *attr) {
+ switch ( ATTR_DEFAULT(attr) ) {
+ case default_none:
+ return NULL;
+ break;
+ case default_builder:
+ {
+ SV *sv;
+ dSP;
+
+ ENTER;
+ SAVETMPS;
+ PUSHMARK(SP);
+ XPUSHs(self);
+ PUTBACK;
+
+ call_method(SvPV_nolen(attr->def.sv), G_SCALAR);
+
+ SPAGAIN;
+ sv = POPs;
+
+ SvREFCNT_inc(sv);
+
+ PUTBACK;
+ FREETMPS;
+ LEAVE;
+
+ return sv_2mortal(sv);
+ }
+ break;
+ case default_normal:
+ if ( SvROK(attr->def.sv) ) {
+ printf("CV default\n");
+ } else {
+ printf("simple value\n");
+ return attr->def.sv; /* will be copied by set for lazy, and by reader for both cases */
+ }
+ break;
+ case default_op:
+ case default_type:
+ croak("todo");
+ break;
+ }
+
+ return NULL;
+}
+
+STATIC SV *getter_common(pTHX_ SV *self, ATTR *attr) {
+ SV *value = get_slot_value(aTHX_ self, attr);
+
+ if ( value ) {
+ return value;
+ } else if ( ATTR_ISLAZY(attr) ) {
+ value = get_default(aTHX_ self, attr);
+ setter_common(aTHX_ self, attr, value);
+ return value;
+ }
+
+ return NULL;
}
+STATIC void setter_common(pTHX_ SV *self, ATTR *attr, SV *value) {
+ if ( ATTR_TYPE(attr) ) {
+ if ( !check_type_constraint(aTHX_ ATTR_TYPE(attr), attr->tc_check, attr->type_constraint, value) )
+ croak("Bad param");
+ }
+
+ set_slot_value(aTHX_ self, attr, value);
+}
/* simple high level api */
-STATIC XS(simple_getter);
-STATIC XS(simple_getter)
+STATIC XS(getter);
+STATIC XS(getter)
{
#ifdef dVAR
dVAR;
#endif
dXSARGS;
- dSLOT;
+ dATTR;
SV *value;
if (items != 1)
SP -= items;
- value = get_slot_value(ST(0), slot);
+ value = getter_common(aTHX_ ST(0), attr);
if (value) {
ST(0) = sv_mortalcopy(value); /* mortalcopy because $_ .= "blah" for $foo->bar */
}
}
-STATIC XS(simple_setter);
-STATIC XS(simple_setter)
+STATIC XS(setter);
+STATIC XS(setter)
{
#ifdef dVAR
dVAR;
#endif
dXSARGS;
- dSLOT;
+ dATTR;
if (items != 2)
Perl_croak(aTHX_ "Usage: %s(%s, %s)", GvNAME(CvGV(cv)), "self", "value");
SP -= items;
- set_slot_value(ST(0), slot, ST(1));
+ setter_common(aTHX_ ST(0), attr, ST(1));
ST(0) = ST(1); /* return value */
XSRETURN(1);
}
-STATIC XS(simple_accessor);
-STATIC XS(simple_accessor)
+STATIC XS(accessor);
+STATIC XS(accessor)
{
#ifdef dVAR
dVAR;
#endif
dXSARGS;
- dSLOT;
+ dATTR;
if (items < 1)
Perl_croak(aTHX_ "Usage: %s(%s, [ %s ])", GvNAME(CvGV(cv)), "self", "value");
SP -= items;
if (items > 1) {
- set_slot_value(ST(0), slot, ST(1));
+ setter_common(aTHX_ ST(0), attr, ST(1));
ST(0) = ST(1); /* return value */
} else {
- SV *value = get_slot_value(ST(0), slot);
+ SV *value = getter_common(aTHX_ ST(0), attr);
if ( value ) {
ST(0) = value;
} else {
dVAR;
#endif
dXSARGS;
- dSLOT;
+ dATTR;
if (items != 1)
Perl_croak(aTHX_ "Usage: %s(%s)", GvNAME(CvGV(cv)), "self");
SP -= items;
- if ( has_slot_value(ST(0), slot) )
+ if ( has_slot_value(aTHX_ ST(0), attr) )
XSRETURN_YES;
else
XSRETURN_NO;
}
enum xs_body {
- xs_body_simple_getter = 0,
- xs_body_simple_setter,
- xs_body_simple_accessor,
+ xs_body_getter = 0,
+ xs_body_setter,
+ xs_body_accessor,
xs_body_predicate,
max_xs_body
};
STATIC XSPROTO ((*xs_bodies[])) = {
- simple_getter,
- simple_setter,
- simple_accessor,
+ getter,
+ setter,
+ accessor,
predicate,
};
MODULE = Moose PACKAGE = Moose::XS
CV *
-install_sub(name, key)
+new_sub(attr, name)
INPUT:
- char *name;
- SV *key;
+ SV *attr;
+ SV *name;
ALIAS:
- install_simple_getter = xs_body_simple_getter
- install_simple_setter = xs_body_simple_setter
- install_simple_accessor = xs_body_simple_accessor
- install_predicate = xs_body_predicate
+ new_getter = xs_body_getter
+ new_setter = xs_body_setter
+ new_accessor = xs_body_accessor
+ new_predicate = xs_body_predicate
PREINIT:
CV * cv;
CODE:
if ( ix >= max_xs_body )
croak("Unknown Moose::XS body type");
- cv = newXS(name, xs_bodies[ix], __FILE__);
+ if ( !sv_isobject(attr) )
+ croak("'attr' must be a Moose::Meta::Attribute");
+
+ cv = newXS(SvOK(name) ? SvPV_nolen(name) : NULL, xs_bodies[ix], __FILE__);
if (cv == NULL)
croak("Oi vey!");
- /* FIXME leaks, fail for anon classes */
- XSANY.any_i32 = PTR2IV(new_slot_from_key(key, 0));
+ /* associate CV with meta attr */
+ stash_in_mg(aTHX_ (SV *)cv, attr);
+
+ /* this will be set on first call */
+ XSANY.any_i32 = 0;
RETVAL = cv;
OUTPUT:
RETVAL
+MODULE = Moose PACKAGE = Moose::XS::Meta::Instance
+
+void
+DESTROY(self)
+ INPUT:
+ SV *self;
+ PREINIT:
+ MI *mi = INT2PTR(MI *, SvIV(SvRV(self)));
+ CODE:
+ delete_mi(aTHX_ mi);