X-Git-Url: http://git.vpit.fr/?p=perl%2Fmodules%2FSub-Op.git;a=blobdiff_plain;f=Op.xs;h=24ab0dc2166a69db3ac65154b0eeb95808256fbe;hp=b5417de40a3b002e426f8a82019f17dcad661909;hb=HEAD;hpb=95275fe70b3a1b3a6ea0d76676dbb55afe8b8b73

diff --git a/Op.xs b/Op.xs
index b5417de..24ab0dc 100644
--- a/Op.xs
+++ b/Op.xs
@@ -13,6 +13,10 @@
 
 #define SO_HAS_PERL(R, V, S) (PERL_REVISION > (R) || (PERL_REVISION == (R) && (PERL_VERSION > (V) || (PERL_VERSION == (V) && (PERL_SUBVERSION >= (S))))))
 
+#ifndef GvCV_set
+# define GvCV_set(G, C) (GvCV(G) = (C))
+#endif
+
 /* ... Thread safety and multiplicity ...................................... */
 
 #ifndef SO_MULTIPLICITY
@@ -49,6 +53,44 @@
 # define MY_CXT_CLONE NOOP
 #endif
 
+#if defined(OP_CHECK_MUTEX_LOCK) && defined(OP_CHECK_MUTEX_UNLOCK)
+# define SO_CHECK_MUTEX_LOCK   OP_CHECK_MUTEX_LOCK
+# define SO_CHECK_MUTEX_UNLOCK OP_CHECK_MUTEX_UNLOCK
+#else
+# define SO_CHECK_MUTEX_LOCK   OP_REFCNT_LOCK
+# define SO_CHECK_MUTEX_UNLOCK OP_REFCNT_UNLOCK
+#endif
+
+typedef OP *(*so_ck_t)(pTHX_ OP *);
+
+#ifdef wrap_op_checker
+
+# define so_ck_replace(T, NC, OCP) wrap_op_checker((T), (NC), (OCP))
+
+#else
+
+STATIC void so_ck_replace(pTHX_ OPCODE type, so_ck_t new_ck, so_ck_t *old_ck_p){
+#define so_ck_replace(T, NC, OCP) so_ck_replace(aTHX_ (T), (NC), (OCP))
+ SO_CHECK_MUTEX_LOCK;
+ if (!*old_ck_p) {
+  *old_ck_p      = PL_check[type];
+  PL_check[type] = new_ck;
+ }
+ SO_CHECK_MUTEX_UNLOCK;
+}
+
+#endif
+
+STATIC void so_ck_restore(pTHX_ OPCODE type, so_ck_t *old_ck_p) {
+#define so_ck_restore(T, OCP) so_ck_restore(aTHX_ (T), (OCP))
+ SO_CHECK_MUTEX_LOCK;
+ if (*old_ck_p) {
+  PL_check[type] = *old_ck_p;
+  *old_ck_p      = 0;
+ }
+ SO_CHECK_MUTEX_UNLOCK;
+}
+
 /* --- Global data --------------------------------------------------------- */
 
 #define MY_CXT_KEY __PACKAGE__ "::_guts" XS_VERSION
@@ -284,7 +326,7 @@ STATIC OP *so_ck_entersub(pTHX_ OP *o) {
 
    if (gv && SvTYPE(gv) >= SVt_PVGV && (cv = GvCV(gv)) == MY_CXT.placeholder) {
     SvREFCNT_dec(cv);
-    GvCV(gv) = NULL;
+    GvCV_set(gv, NULL);
    }
 
    if (c->call)
@@ -389,7 +431,7 @@ STATIC OP *so_ck_gelem(pTHX_ OP *o) {
 
    if (gv && SvTYPE(gv) >= SVt_PVGV && (cv = GvCV(gv)) == MY_CXT.placeholder) {
     SvREFCNT_dec(cv);
-    GvCV(gv) = NULL;
+    GvCV_set(gv, NULL);
    }
   }
  }
@@ -413,12 +455,9 @@ BOOT:
  MY_CXT.owner       = aTHX;
 #endif /* SO_THREADSAFE */
 
- so_old_ck_entersub    = PL_check[OP_ENTERSUB];
- PL_check[OP_ENTERSUB] = so_ck_entersub;
- so_old_ck_refgen      = PL_check[OP_REFGEN];
- PL_check[OP_REFGEN]   = so_ck_refgen;
- so_old_ck_gelem       = PL_check[OP_GELEM];
- PL_check[OP_GELEM]    = so_ck_gelem;
+ so_ck_replace(OP_ENTERSUB, so_ck_entersub, &so_old_ck_entersub);
+ so_ck_replace(OP_REFGEN,   so_ck_refgen,   &so_old_ck_refgen);
+ so_ck_replace(OP_GELEM,    so_ck_gelem,    &so_old_ck_gelem);
 }
 
 #if SO_THREADSAFE