This is a live mirror of the Perl 5 development currently hosted at https://github.com/perl/perl5
Implement use attrs qw(locked package);
[perl5.git] / pp_hot.c
index 7f9f513..41f2aee 100644 (file)
--- a/pp_hot.c
+++ b/pp_hot.c
 #include "EXTERN.h"
 #include "perl.h"
 
+#ifdef I_UNISTD
+#include <unistd.h>
+#endif
+
 /* Hot code. */
 
+#ifdef USE_THREADS
+static void
+unset_cvowner(void *cvarg)
+{
+    register CV* cv = (CV *) cvarg;
+#ifdef DEBUGGING
+    dTHR;
+#endif /* DEBUGGING */
+
+    DEBUG_L((PerlIO_printf(PerlIO_stderr(), "%p unsetting CvOWNER of %p:%s\n",
+                          thr, cv, SvPEEK((SV*)cv))));
+    MUTEX_LOCK(CvMUTEXP(cv));
+    DEBUG_L(if (CvDEPTH(cv) != 0)
+               PerlIO_printf(PerlIO_stderr(), "depth %ld != 0\n",
+                             CvDEPTH(cv)););
+    assert(thr == CvOWNER(cv));
+    CvOWNER(cv) = 0;
+    MUTEX_UNLOCK(CvMUTEXP(cv));
+    SvREFCNT_dec(cv);
+}
+#endif /* USE_THREADS */
+
 PP(pp_const)
 {
-    dSP;
+    djSP;
     XPUSHs(cSVOP->op_sv);
     RETURN;
 }
@@ -38,8 +64,8 @@ PP(pp_nextstate)
 
 PP(pp_gvsv)
 {
-    dSP;
-    EXTEND(sp,1);
+    djSP;
+    EXTEND(SP,1);
     if (op->op_private & OPpLVAL_INTRO)
        PUSHs(save_scalar(cGVOP->op_gv));
     else
@@ -60,7 +86,7 @@ PP(pp_pushmark)
 
 PP(pp_stringify)
 {
-    dSP; dTARGET;
+    djSP; dTARGET;
     STRLEN len;
     char *s;
     s = SvPV(TOPs,len);
@@ -71,76 +97,14 @@ PP(pp_stringify)
 
 PP(pp_gv)
 {
-    dSP;
+    djSP;
     XPUSHs((SV*)cGVOP->op_gv);
     RETURN;
 }
 
-PP(pp_gelem)
-{
-    GV *gv;
-    SV *sv;
-    SV *ref;
-    char *elem;
-    dSP;
-
-    sv = POPs;
-    elem = SvPV(sv, na);
-    gv = (GV*)POPs;
-    ref = Nullsv;
-    sv = Nullsv;
-    switch (elem ? *elem : '\0')
-    {
-    case 'A':
-       if (strEQ(elem, "ARRAY"))
-           ref = (SV*)GvAV(gv);
-       break;
-    case 'C':
-       if (strEQ(elem, "CODE"))
-           ref = (SV*)GvCVu(gv);
-       break;
-    case 'F':
-       if (strEQ(elem, "FILEHANDLE")) /* XXX deprecate in 5.005 */
-           ref = (SV*)GvIOp(gv);
-       break;
-    case 'G':
-       if (strEQ(elem, "GLOB"))
-           ref = (SV*)gv;
-       break;
-    case 'H':
-       if (strEQ(elem, "HASH"))
-           ref = (SV*)GvHV(gv);
-       break;
-    case 'I':
-       if (strEQ(elem, "IO"))
-           ref = (SV*)GvIOp(gv);
-       break;
-    case 'N':
-       if (strEQ(elem, "NAME"))
-           sv = newSVpv(GvNAME(gv), GvNAMELEN(gv));
-       break;
-    case 'P':
-       if (strEQ(elem, "PACKAGE"))
-           sv = newSVpv(HvNAME(GvSTASH(gv)), 0);
-       break;
-    case 'S':
-       if (strEQ(elem, "SCALAR"))
-           ref = GvSV(gv);
-       break;
-    }
-    if (ref)
-       sv = newRV(ref);
-    if (sv)
-       sv_2mortal(sv);
-    else
-       sv = &sv_undef;
-    XPUSHs(sv);
-    RETURN;
-}
-
 PP(pp_and)
 {
-    dSP;
+    djSP;
     if (!SvTRUE(TOPs))
        RETURN;
     else {
@@ -151,7 +115,7 @@ PP(pp_and)
 
 PP(pp_sassign)
 {
-    dSP; dPOPTOPssrl;
+    djSP; dPOPTOPssrl;
     MAGIC *mg;
 
     if (op->op_private & OPpASSIGN_BACKWARDS) {
@@ -160,15 +124,14 @@ PP(pp_sassign)
     }
     if (tainting && tainted && !SvTAINTED(left))
        TAINT_NOT;
-    SvSetSV(right, left);
-    SvSETMAGIC(right);
+    SvSetMagicSV(right, left);
     SETs(right);
     RETURN;
 }
 
 PP(pp_cond_expr)
 {
-    dSP;
+    djSP;
     if (SvTRUEx(POPs))
        RETURNOP(cCONDOP->op_true);
     else
@@ -188,7 +151,7 @@ PP(pp_unstack)
 
 PP(pp_concat)
 {
-  dSP; dATARGET; tryAMAGICbin(concat,opASSIGN);
+  djSP; dATARGET; tryAMAGICbin(concat,opASSIGN);
   {
     dPOPTOPssrl;
     STRLEN len;
@@ -215,13 +178,16 @@ PP(pp_concat)
 
 PP(pp_padsv)
 {
-    dSP; dTARGET;
+    djSP; dTARGET;
     XPUSHs(TARG);
     if (op->op_flags & OPf_MOD) {
        if (op->op_private & OPpLVAL_INTRO)
            SAVECLEARSV(curpad[op->op_targ]);
-        else if (op->op_private & OPpDEREF)
-           vivify_ref(curpad[op->op_targ], op->op_flags & OPpDEREF);
+        else if (op->op_private & OPpDEREF) {
+           PUTBACK;
+           vivify_ref(curpad[op->op_targ], op->op_private & OPpDEREF);
+           SPAGAIN;
+       }
     }
     RETURN;
 }
@@ -234,17 +200,17 @@ PP(pp_readline)
 
 PP(pp_eq)
 {
-    dSP; tryAMAGICbinSET(eq,0); 
+    djSP; tryAMAGICbinSET(eq,0); 
     {
       dPOPnv;
-      SETs((TOPn == value) ? &sv_yes : &sv_no);
+      SETs(boolSV(TOPn == value));
       RETURN;
     }
 }
 
 PP(pp_preinc)
 {
-    dSP;
+    djSP;
     if (SvREADONLY(TOPs) || SvTYPE(TOPs) > SVt_PVLV)
        croak(no_modify);
     if (SvIOK(TOPs) && !SvNOK(TOPs) && !SvPOK(TOPs) &&
@@ -261,7 +227,7 @@ PP(pp_preinc)
 
 PP(pp_or)
 {
-    dSP;
+    djSP;
     if (SvTRUE(TOPs))
        RETURN;
     else {
@@ -272,7 +238,7 @@ PP(pp_or)
 
 PP(pp_add)
 {
-    dSP; dATARGET; tryAMAGICbin(add,opASSIGN); 
+    djSP; dATARGET; tryAMAGICbin(add,opASSIGN); 
     {
       dPOPTOPnnrl_ul;
       SETn( left + right );
@@ -282,7 +248,7 @@ PP(pp_add)
 
 PP(pp_aelemfast)
 {
-    dSP;
+    djSP;
     AV *av = GvAV((GV*)cSVOP->op_sv);
     SV** svp = av_fetch(av, op->op_private, op->op_flags & OPf_MOD);
     PUSHs(svp ? *svp : &sv_undef);
@@ -291,7 +257,7 @@ PP(pp_aelemfast)
 
 PP(pp_join)
 {
-    dSP; dMARK; dTARGET;
+    djSP; dMARK; dTARGET;
     MARK++;
     do_join(TARG, *MARK, MARK, SP);
     SP = MARK;
@@ -301,7 +267,7 @@ PP(pp_join)
 
 PP(pp_pushre)
 {
-    dSP;
+    djSP;
 #ifdef DEBUGGING
     /*
      * We ass_u_me that LvTARGOFF() comes first, and that two STRLENs
@@ -322,7 +288,7 @@ PP(pp_pushre)
 
 PP(pp_print)
 {
-    dSP; dMARK; dORIGMARK;
+    djSP; dMARK; dORIGMARK;
     GV *gv;
     IO *io;
     register PerlIO *fp;
@@ -332,9 +298,12 @@ PP(pp_print)
        gv = (GV*)*++MARK;
     else
        gv = defoutgv;
-    if (SvMAGICAL(gv) && (mg = mg_find((SV*)gv, 'q'))) {
+    if (SvRMAGICAL(gv) && (mg = mg_find((SV*)gv, 'q'))) {
        if (MARK == ORIGMARK) {
-           EXTEND(SP, 1);
+           /* If using default handle then we need to make space to 
+            * pass object as 1st arg, so move other args up ...
+            */
+           MEXTEND(SP, 1);
            ++MARK;
            Move(MARK, MARK + 1, (SP - MARK) + 1, SV*);
            ++SP;
@@ -419,7 +388,7 @@ PP(pp_print)
 
 PP(pp_rv2av)
 {
-    dSP; dPOPss;
+    djSP; dPOPss;
     AV *av;
 
     if (SvROK(sv)) {
@@ -427,8 +396,6 @@ PP(pp_rv2av)
        av = (AV*)SvRV(sv);
        if (SvTYPE(av) != SVt_PVAV)
            DIE("Not an ARRAY reference");
-       if (op->op_private & OPpLVAL_INTRO)
-           av = (AV*)save_svref((SV**)sv);
        if (op->op_flags & OPf_REF) {
            PUSHs((SV*)av);
            RETURN;
@@ -482,8 +449,17 @@ PP(pp_rv2av)
 
     if (GIMME == G_ARRAY) {
        I32 maxarg = AvFILL(av) + 1;
-       EXTEND(SP, maxarg);
-       Copy(AvARRAY(av), SP+1, maxarg, SV*);
+       EXTEND(SP, maxarg);          
+       if (SvRMAGICAL(av)) {
+           U32 i; 
+           for (i=0; i < maxarg; i++) {
+               SV **svp = av_fetch(av, i, FALSE);
+               SP[i+1] = (svp) ? *svp : &sv_undef;
+           }
+       } 
+       else {
+           Copy(AvARRAY(av), SP+1, maxarg, SV*);
+       }
        SP += maxarg;
     }
     else {
@@ -496,23 +472,21 @@ PP(pp_rv2av)
 
 PP(pp_rv2hv)
 {
-    dSP; dTOPss;
+    djSP; dTOPss;
     HV *hv;
 
     if (SvROK(sv)) {
       wasref:
        hv = (HV*)SvRV(sv);
-       if (SvTYPE(hv) != SVt_PVHV)
+       if (SvTYPE(hv) != SVt_PVHV && SvTYPE(hv) != SVt_PVAV)
            DIE("Not a HASH reference");
-       if (op->op_private & OPpLVAL_INTRO)
-           hv = (HV*)save_svref((SV**)sv);
        if (op->op_flags & OPf_REF) {
            SETs((SV*)hv);
            RETURN;
        }
     }
     else {
-       if (SvTYPE(sv) == SVt_PVHV) {
+       if (SvTYPE(sv) == SVt_PVHV || SvTYPE(sv) == SVt_PVAV) {
            hv = (HV*)sv;
            if (op->op_flags & OPf_REF) {
                SETs((SV*)hv);
@@ -565,12 +539,13 @@ PP(pp_rv2hv)
     }
     else {
        dTARGET;
-       if (HvFILL(hv)) {
-           sprintf(buf, "%ld/%ld", (long)HvFILL(hv), (long)HvMAX(hv)+1);
-           sv_setpv(TARG, buf);
-       }
+       /* This bit is OK even when hv is really an AV */
+       if (HvFILL(hv))
+           sv_setpvf(TARG, "%ld/%ld",
+                     (long)HvFILL(hv), (long)HvMAX(hv) + 1);
        else
            sv_setiv(TARG, 0);
+       
        SETTARG;
        RETURN;
     }
@@ -578,7 +553,7 @@ PP(pp_rv2hv)
 
 PP(pp_aassign)
 {
-    dSP;
+    djSP;
     SV **lastlelem = stack_sp;
     SV **lastrelem = stack_base + POPMARK;
     SV **firstrelem = stack_base + POPMARK + 1;
@@ -590,6 +565,7 @@ PP(pp_aassign)
     register SV *sv;
     register AV *ary;
 
+    I32 gimme;
     HV *hash;
     I32 i;
     int magic;
@@ -603,8 +579,10 @@ PP(pp_aassign)
     if (op->op_private & OPpASSIGN_COMMON) {
         for (relem = firstrelem; relem <= lastrelem; relem++) {
             /*SUPPRESS 560*/
-            if (sv = *relem)
+            if (sv = *relem) {
+               TAINT_NOT;      /* Each item is independent */
                 *relem = sv_mortalcopy(sv);
+           }
         }
     }
 
@@ -624,13 +602,18 @@ PP(pp_aassign)
            av_extend(ary, lastrelem - relem);
            i = 0;
            while (relem <= lastrelem) {        /* gobble up all the rest */
+               SV **didstore;
                sv = NEWSV(28,0);
                assert(*relem);
                sv_setsv(sv,*relem);
                *(relem++) = sv;
-               (void)av_store(ary,i++,sv);
-               if (magic)
-                   mg_set(sv);
+               didstore = av_store(ary,i++,sv);
+               if (magic) {
+                   if (SvSMAGICAL(sv))
+                       mg_set(sv);
+                   if (!didstore)
+                       SvREFCNT_dec(sv);
+               }
                TAINT_NOT;
            }
            break;
@@ -643,6 +626,7 @@ PP(pp_aassign)
 
                while (relem < lastrelem) {     /* gobble up all the rest */
                    STRLEN len;
+                   HE *didstore;
                    if (*relem)
                        sv = *(relem++);
                    else
@@ -651,13 +635,24 @@ PP(pp_aassign)
                    if (*relem)
                        sv_setsv(tmpstr,*relem);        /* value */
                    *(relem++) = tmpstr;
-                   (void)hv_store_ent(hash,sv,tmpstr,0);
-                   if (magic)
-                       mg_set(tmpstr);
+                   didstore = hv_store_ent(hash,sv,tmpstr,0);
+                   if (magic) {
+                       if (SvSMAGICAL(tmpstr))
+                           mg_set(tmpstr);
+                       if (!didstore)
+                           SvREFCNT_dec(tmpstr);
+                   }
                    TAINT_NOT;
                }
-               if (relem == lastrelem)
-                   warn("Odd number of elements in hash list");
+               if (relem == lastrelem && dowarn) {
+                   if (relem == firstrelem &&
+                       SvROK(*relem) &&
+                       ( SvTYPE(SvRV(*relem)) == SVt_PVAV ||
+                         SvTYPE(SvRV(*relem)) == SVt_PVHV ) )
+                       warn("Reference found where even-sized list expected");
+                   else
+                       warn("Odd number of elements in hash assignment");
+               }
            }
            break;
        default:
@@ -744,7 +739,16 @@ PP(pp_aassign)
        tainting |= (uid && (euid != uid || egid != gid));
     }
     delaymagic = 0;
-    if (GIMME == G_ARRAY) {
+
+    gimme = GIMME_V;
+    if (gimme == G_VOID)
+       SP = firstrelem - 1;
+    else if (gimme == G_SCALAR) {
+       dTARGET;
+       SP = firstrelem;
+       SETi(lastrelem - firstrelem + 1);
+    }
+    else {
        if (ary || hash)
            SP = lastrelem;
        else
@@ -752,20 +756,13 @@ PP(pp_aassign)
        lelem = firstlelem + (relem - firstrelem);
        while (relem <= SP)
            *relem++ = (lelem <= lastlelem) ? *lelem++ : &sv_undef;
-       RETURN;
-    }
-    else {
-       dTARGET;
-       SP = firstrelem;
-               
-       SETi(lastrelem - firstrelem + 1);
-       RETURN;
     }
+    RETURN;
 }
 
 PP(pp_match)
 {
-    dSP; dTARG;
+    djSP; dTARG;
     register PMOP *pm = cPMOP;
     register char *t;
     register char *s;
@@ -779,13 +776,15 @@ PP(pp_match)
     I32 minmatch = 0;
     I32 oldsave = savestack_ix;
     I32 update_minmatch = 1;
+    SV *screamer;
 
     if (op->op_flags & OPf_STACKED)
        TARG = POPs;
     else {
-       TARG = GvSV(defgv);
+       TARG = DEFSV;
        EXTEND(SP,1);
     }
+    PUTBACK;                           /* EVAL blocks need stack_sp. */
     s = SvPV(TARG, len);
     strend = s + len;
     if (!s)
@@ -793,6 +792,7 @@ PP(pp_match)
     TAINT_NOT;
 
     if (pm->op_pmflags & PMf_USED) {
+      failure:
        if (gimme == G_ARRAY)
            RETURN;
        RETPUSHNO;
@@ -802,6 +802,12 @@ PP(pp_match)
        pm = curpm;
        rx = pm->op_pmregexp;
     }
+    if (rx->minlen > len) goto failure;
+
+    screamer = ( (SvSCREAM(TARG) && rx->check_substr
+                 && SvTYPE(rx->check_substr) == SVt_PVBM
+                 && SvVALID(rx->check_substr)) 
+               ? TARG : Nullsv);
     truebase = t = s;
     if (global = pm->op_pmflags & PMf_GLOBAL) {
        rx->startp[0] = 0;
@@ -816,7 +822,9 @@ PP(pp_match)
     }
     if (!rx->nparens && !global)
        gimme = G_SCALAR;                       /* accidental array context? */
-    safebase = (((gimme == G_ARRAY) || global) && !sawampersand);
+    safebase = (((gimme == G_ARRAY) || global || !rx->nparens)
+               && !sawampersand);
+    safebase = safebase ? 0  : REXEC_COPY_STR ;
     if (pm->op_pmflags & (PMf_MULTILINE|PMf_SINGLELINE)) {
        SAVEINT(multiline);
        multiline = pm->op_pmflags & PMf_MULTILINE;
@@ -825,48 +833,57 @@ PP(pp_match)
 play_it_again:
     if (global && rx->startp[0]) {
        t = s = rx->endp[0];
-       if (s >= strend)
+       if ((s + rx->minlen) > strend)
            goto nope;
        if (update_minmatch++)
            minmatch = (s == rx->startp[0]);
     }
-    if (pm->op_pmshort) {
-       if (pm->op_pmflags & PMf_SCANFIRST) {
-           if (SvSCREAM(TARG)) {
-               if (screamfirst[BmRARE(pm->op_pmshort)] < 0)
+    if (rx->check_substr) {
+       if (!(rx->reganch & ROPT_NOSCAN)) { /* Floating checkstring. */
+           if ( screamer ) {
+               I32 p = -1;
+               
+               if (screamfirst[BmRARE(rx->check_substr)] < 0)
                    goto nope;
-               else if (!(s = screaminstr(TARG, pm->op_pmshort)))
+               else if (!(s = screaminstr(TARG, rx->check_substr, 
+                                          rx->check_offset_min, 0, &p, 0)))
                    goto nope;
-               else if (pm->op_pmflags & PMf_ALL)
+               else if ((rx->reganch & ROPT_CHECK_ALL)
+                        && !sawampersand && !SvTAIL(rx->check_substr))
                    goto yup;
            }
-           else if (!(s = fbm_instr((unsigned char*)s,
-             (unsigned char*)strend, pm->op_pmshort)))
+           else if (!(s = fbm_instr((unsigned char*)s + rx->check_offset_min,
+                                    (unsigned char*)strend, 
+                                    rx->check_substr)))
                goto nope;
-           else if (pm->op_pmflags & PMf_ALL)
+           else if ((rx->reganch & ROPT_CHECK_ALL) && !sawampersand)
                goto yup;
-           if (s && rx->regback >= 0) {
-               ++BmUSEFUL(pm->op_pmshort);
-               s -= rx->regback;
-               if (s < t)
-                   s = t;
+           if (s && rx->check_offset_max < t - s) {
+               ++BmUSEFUL(rx->check_substr);
+               s -= rx->check_offset_max;
            }
            else
                s = t;
        }
-       else if (!multiline) {
-           if (*SvPVX(pm->op_pmshort) != *s
-               || (pm->op_pmslen > 1
-                   && memNE(SvPVX(pm->op_pmshort), s, pm->op_pmslen)))
+       /* Now checkstring is fixed, i.e. at fixed offset from the
+          beginning of match, and the match is anchored at s. */
+       else if (!multiline) {  /* Anchored near beginning of string. */
+           I32 slen;
+           if (*SvPVX(rx->check_substr) != s[rx->check_offset_min]
+               || ((slen = SvCUR(rx->check_substr)) > 1
+                   && memNE(SvPVX(rx->check_substr), 
+                            s + rx->check_offset_min, slen)))
                goto nope;
        }
-       if (!rx->naughty && --BmUSEFUL(pm->op_pmshort) < 0) {
-           SvREFCNT_dec(pm->op_pmshort);
-           pm->op_pmshort = Nullsv;    /* opt is being useless */
+       if (!rx->naughty && --BmUSEFUL(rx->check_substr) < 0
+           && rx->check_substr == rx->float_substr) {
+           SvREFCNT_dec(rx->check_substr);
+           rx->check_substr = Nullsv;  /* opt is being useless */
+           rx->float_substr = Nullsv;
        }
     }
-    if (pregexec(rx, s, strend, truebase, minmatch,
-                SvSCREAM(TARG) ? TARG : Nullsv, safebase))
+    if (regexec_flags(rx, s, strend, truebase, minmatch,
+                     screamer, NULL, safebase))
     {
        curpm = pm;
        if (pm->op_pmflags & PMf_ONCE)
@@ -878,7 +895,7 @@ play_it_again:
     /*NOTREACHED*/
 
   gotcha:
-    TAINT_IF(rx->exec_tainted);
+    TAINT_IF(RX_MATCH_TAINTED(rx));
     if (gimme == G_ARRAY) {
        I32 iters, i, len;
 
@@ -887,6 +904,7 @@ play_it_again:
            i = 1;
        else
            i = 0;
+       SPAGAIN;                        /* EVAL blocks could move the stack. */
        EXTEND(SP, iters + i);
        EXTEND_MORTAL(iters + i);
        for (i = !i; i <= iters; i++) {
@@ -902,6 +920,7 @@ play_it_again:
            strend = rx->subend;
            if (rx->startp[0] && rx->startp[0] == rx->endp[0])
                ++rx->endp[0];
+           PUTBACK;                    /* EVAL blocks may use stack */
            goto play_it_again;
        }
        LEAVE_SCOPE(oldsave);
@@ -928,9 +947,9 @@ play_it_again:
        RETPUSHYES;
     }
 
-yup:
-    TAINT_IF(rx->exec_tainted);
-    ++BmUSEFUL(pm->op_pmshort);
+yup:                                   /* Confirmed by check_substr */
+    TAINT_IF(RX_MATCH_TAINTED(rx));
+    ++BmUSEFUL(rx->check_substr);
     curpm = pm;
     if (pm->op_pmflags & PMf_ONCE)
        pm->op_pmflags |= PMf_USED;
@@ -940,7 +959,7 @@ yup:
        rx->subbeg = truebase;
        rx->subend = strend;
        rx->startp[0] = s;
-       rx->endp[0] = s + SvCUR(pm->op_pmshort);
+       rx->endp[0] = s + SvCUR(rx->check_substr);
        goto gotcha;
     }
     if (sawampersand) {
@@ -950,16 +969,23 @@ yup:
        rx->subbeg = tmps;
        rx->subend = tmps + (strend-t);
        tmps = rx->startp[0] = tmps + (s - t);
-       rx->endp[0] = tmps + SvCUR(pm->op_pmshort);
+       rx->endp[0] = tmps + SvCUR(rx->check_substr);
     }
     LEAVE_SCOPE(oldsave);
     RETPUSHYES;
 
 nope:
-    if (pm->op_pmshort)
-       ++BmUSEFUL(pm->op_pmshort);
+    if (rx->check_substr)
+       ++BmUSEFUL(rx->check_substr);
 
 ret_no:
+    if (global && !(pm->op_pmflags & PMf_CONTINUE)) {
+       if (SvTYPE(TARG) >= SVt_PVMG && SvMAGIC(TARG)) {
+           MAGIC* mg = mg_find(TARG, 'g');
+           if (mg)
+               mg->mg_len = -1;
+       }
+    }
     LEAVE_SCOPE(oldsave);
     if (gimme == G_ARRAY)
        RETURN;
@@ -967,7 +993,7 @@ ret_no:
 }
 
 OP *
-do_readline()
+do_readline(void)
 {
     dSP; dTARGETSTACKED;
     register SV *sv;
@@ -976,18 +1002,19 @@ do_readline()
     PerlIO *fp;
     register IO *io = GvIO(last_in_gv);
     register I32 type = op->op_type;
+    I32 gimme = GIMME_V;
     MAGIC *mg;
 
-    if (SvMAGICAL(last_in_gv) && (mg = mg_find((SV*)last_in_gv, 'q'))) {
+    if (SvRMAGICAL(last_in_gv) && (mg = mg_find((SV*)last_in_gv, 'q'))) {
        PUSHMARK(SP);
        XPUSHs(mg->mg_obj);
        PUTBACK;
        ENTER;
-       perl_call_method("READLINE", GIMME);
+       perl_call_method("READLINE", gimme);
        LEAVE;
        SPAGAIN;
-       if (GIMME == G_SCALAR)
-           SvSetSV_nosteal(TARG, TOPs);
+       if (gimme == G_SCALAR)
+           SvSetMagicSV_nosteal(TARG, TOPs);
        RETURN;
     }
     fp = Nullfp;
@@ -1039,7 +1066,7 @@ do_readline()
                       ((struct NAM *)((struct FAB *)cxt)->fab$l_nam)->nam$l_fnb
                       but that's unsupported, so I don't want to do it now and
                       have it bite someone in the future. */
-                   strcat(tmpfnam,tmpnam(NULL));
+                   strcat(tmpfnam,PerlLIO_tmpnam(NULL));
                    cp = SvPV(tmpglob,i);
                    for (; i; i--) {
                       if (cp[i] == ';') hasver = 1;
@@ -1057,7 +1084,10 @@ do_readline()
                       }
                    }
                    if ((tmpfp = PerlIO_open(tmpfnam,"w+","fop=dlt")) != NULL) {
-                       ok = ((wilddsc.dsc$a_pointer = tovmsspec(SvPVX(tmpglob),vmsspec)) != NULL);
+                       Stat_t st;
+                       if (!PerlLIO_stat(SvPVX(tmpglob),&st) && S_ISDIR(st.st_mode))
+                         ok = ((wilddsc.dsc$a_pointer = tovmspath(SvPVX(tmpglob),vmsspec)) != NULL);
+                       else ok = ((wilddsc.dsc$a_pointer = tovmsspec(SvPVX(tmpglob),vmsspec)) != NULL);
                        if (ok) wilddsc.dsc$w_length = (unsigned short int) strlen(wilddsc.dsc$a_pointer);
                        while (ok && ((sts = lib$find_file(&wilddsc,&rsdsc,&cxt,
                                                    &dfltdsc,NULL,NULL,NULL))&1)) {
@@ -1101,9 +1131,14 @@ do_readline()
                sv_catsv(tmpcmd, tmpglob);
                sv_catpv(tmpcmd, "; do echo \"$a\\0\\c\"; done |");
 #else
+#ifdef DJGPP
+               sv_setpv(tmpcmd, "/dev/dosglob/"); /* File System Extension */
+               sv_catsv(tmpcmd, tmpglob);
+#else
                sv_setpv(tmpcmd, "perlglob ");
                sv_catsv(tmpcmd, tmpglob);
                sv_catpv(tmpcmd, " |");
+#endif /* !DJGPP */
 #endif /* !OS2 */
 #else /* !DOSISH */
 #if defined(CSH)
@@ -1134,17 +1169,13 @@ do_readline()
     if (!fp) {
        if (dowarn && io && !(IoFLAGS(io) & IOf_START))
            warn("Read on closed filehandle <%s>", GvENAME(last_in_gv));
-       if (GIMME == G_SCALAR) {
+       if (gimme == G_SCALAR) {
            (void)SvOK_off(TARG);
            PUSHTARG;
        }
        RETURN;
     }
-    if (GIMME == G_ARRAY) {
-       sv = sv_2mortal(NEWSV(57, 80));
-       offset = 0;
-    }
-    else {
+    if (gimme == G_SCALAR) {
        sv = TARG;
        if (SvROK(sv))
            sv_unref(sv);
@@ -1157,6 +1188,10 @@ do_readline()
        else
            offset = 0;
     }
+    else {
+       sv = sv_2mortal(NEWSV(57, 80));
+       offset = 0;
+    }
     for (;;) {
        if (!sv_gets(sv, fp, offset)) {
            PerlIO_clearerr(fp);
@@ -1168,9 +1203,10 @@ do_readline()
                IoFLAGS(io) |= IOf_START;
            }
            else if (type == OP_GLOB) {
-               (void)do_close(last_in_gv, FALSE);
+               if (do_close(last_in_gv, FALSE) & ~0xFF)
+                   warn("internal error: glob failed");
            }
-           if (GIMME == G_SCALAR) {
+           if (gimme == G_SCALAR) {
                (void)SvOK_off(TARG);
                PUSHTARG;
            }
@@ -1198,12 +1234,12 @@ do_readline()
                if (!isALPHA(*tmps) && !isDIGIT(*tmps) &&
                    strchr("$&*(){}[]'\";\\|?<>~`", *tmps))
                        break;
-           if (*tmps && Stat(SvPVX(sv), &statbuf) < 0) {
+           if (*tmps && PerlLIO_stat(SvPVX(sv), &statbuf) < 0) {
                (void)POPs;             /* Unmatched wildcard?  Chuck it... */
                continue;
            }
        }
-       if (GIMME == G_ARRAY) {
+       if (gimme == G_ARRAY) {
            if (SvLEN(sv) - SvCUR(sv) > 20) {
                SvLEN_set(sv, SvCUR(sv)+1);
                Renew(SvPVX(sv), SvLEN(sv), char);
@@ -1211,7 +1247,7 @@ do_readline()
            sv = sv_2mortal(NEWSV(58, 80));
            continue;
        }
-       else if (!tmplen && SvLEN(sv) - SvCUR(sv) > 80) {
+       else if (gimme == G_SCALAR && !tmplen && SvLEN(sv) - SvCUR(sv) > 80) {
            /* try to reclaim a bit of scalar space (only on 1st alloc) */
            if (SvCUR(sv) < 60)
                SvLEN_set(sv, 80);
@@ -1225,44 +1261,47 @@ do_readline()
 
 PP(pp_enter)
 {
-    dSP;
-    register CONTEXT *cx;
-    I32 gimme;
+    djSP;
+    register PERL_CONTEXT *cx;
+    I32 gimme = OP_GIMME(op, -1);
 
-    /*
-     * We don't just use the GIMME macro here because it assumes there's
-     * already a context, which ain't necessarily so at initial startup.
-     */
-
-    if (op->op_flags & OPf_KNOW)
-       gimme = op->op_flags & OPf_LIST;
-    else if (cxstack_ix >= 0)
-       gimme = cxstack[cxstack_ix].blk_gimme;
-    else
-       gimme = G_SCALAR;
+    if (gimme == -1) {
+       if (cxstack_ix >= 0)
+           gimme = cxstack[cxstack_ix].blk_gimme;
+       else
+           gimme = G_SCALAR;
+    }
 
     ENTER;
 
     SAVETMPS;
-    PUSHBLOCK(cx, CXt_BLOCK, sp);
+    PUSHBLOCK(cx, CXt_BLOCK, SP);
 
     RETURN;
 }
 
 PP(pp_helem)
 {
-    dSP;
+    djSP;
     HE* he;
+    SV **svp;
     SV *keysv = POPs;
     HV *hv = (HV*)POPs;
     U32 lval = op->op_flags & OPf_MOD;
     U32 defer = op->op_private & OPpLVAL_DEFER;
 
-    if (SvTYPE(hv) != SVt_PVHV)
+    if (SvTYPE(hv) == SVt_PVHV) {
+       he = hv_fetch_ent(hv, keysv, lval && !defer, 0);
+       svp = he ? &HeVAL(he) : 0;
+    }
+    else if (SvTYPE(hv) == SVt_PVAV) {
+       svp = avhv_fetch_ent((AV*)hv, keysv, lval && !defer, 0);
+    }
+    else {
        RETPUSHUNDEF;
-    he = hv_fetch_ent(hv, keysv, lval && !defer, 0);
+    }
     if (lval) {
-       if (!he || HeVAL(he) == &sv_undef) {
+       if (!svp || *svp == &sv_undef) {
            SV* lv;
            SV* key2;
            if (!defer)
@@ -1278,22 +1317,22 @@ PP(pp_helem)
            RETURN;
        }
        if (op->op_private & OPpLVAL_INTRO) {
-           if (HvNAME(hv) && isGV(HeVAL(he)))
-               save_gp((GV*)HeVAL(he), !(op->op_flags & OPf_SPECIAL));
+           if (HvNAME(hv) && isGV(*svp))
+               save_gp((GV*)*svp, !(op->op_flags & OPf_SPECIAL));
            else
-               save_svref(&HeVAL(he));
+               save_helem(hv, keysv, svp);
        }
        else if (op->op_private & OPpDEREF)
-           vivify_ref(HeVAL(he), op->op_private & OPpDEREF);
+           vivify_ref(*svp, op->op_private & OPpDEREF);
     }
-    PUSHs(he ? HeVAL(he) : &sv_undef);
+    PUSHs(svp ? *svp : &sv_undef);
     RETURN;
 }
 
 PP(pp_leave)
 {
-    dSP;
-    register CONTEXT *cx;
+    djSP;
+    register PERL_CONTEXT *cx;
     register SV **mark;
     SV **newsp;
     PMOP *newpm;
@@ -1306,35 +1345,38 @@ PP(pp_leave)
 
     POPBLOCK(cx,newpm);
 
-    if (op->op_flags & OPf_KNOW)
-       gimme = op->op_flags & OPf_LIST;
-    else if (cxstack_ix >= 0)
-       gimme = cxstack[cxstack_ix].blk_gimme;
-    else
-       gimme = G_SCALAR;
+    gimme = OP_GIMME(op, -1);
+    if (gimme == -1) {
+       if (cxstack_ix >= 0)
+           gimme = cxstack[cxstack_ix].blk_gimme;
+       else
+           gimme = G_SCALAR;
+    }
 
-    if (gimme == G_SCALAR) {
-       if (op->op_private & OPpLEAVE_VOID)
-           SP = newsp;
+    TAINT_NOT;
+    if (gimme == G_VOID)
+       SP = newsp;
+    else if (gimme == G_SCALAR) {
+       MARK = newsp + 1;
+       if (MARK <= SP)
+           if (SvFLAGS(TOPs) & (SVs_PADTMP|SVs_TEMP))
+               *MARK = TOPs;
+           else
+               *MARK = sv_mortalcopy(TOPs);
        else {
-           MARK = newsp + 1;
-           if (MARK <= SP)
-               if (SvFLAGS(TOPs) & (SVs_PADTMP|SVs_TEMP))
-                   *MARK = TOPs;
-               else
-                   *MARK = sv_mortalcopy(TOPs);
-           else {
-               MEXTEND(mark,0);
-               *MARK = &sv_undef;
-           }
-           SP = MARK;
+           MEXTEND(mark,0);
+           *MARK = &sv_undef;
        }
+       SP = MARK;
     }
-    else {
-       for (mark = newsp + 1; mark <= SP; mark++)
-           if (!(SvFLAGS(*mark) & (SVs_PADTMP|SVs_TEMP)))
+    else if (gimme == G_ARRAY) {
+       /* in case LEAVE wipes old return values */
+       for (mark = newsp + 1; mark <= SP; mark++) {
+           if (!(SvFLAGS(*mark) & (SVs_PADTMP|SVs_TEMP))) {
                *mark = sv_mortalcopy(*mark);
-               /* in case LEAVE wipes old return values */
+               TAINT_NOT;      /* Each item is independent */
+           }
+       }
     }
     curpm = newpm;     /* Don't pop $1 et al till now */
 
@@ -1345,12 +1387,12 @@ PP(pp_leave)
 
 PP(pp_iter)
 {
-    dSP;
-    register CONTEXT *cx;
+    djSP;
+    register PERL_CONTEXT *cx;
     SV* sv;
     AV* av;
 
-    EXTEND(sp, 1);
+    EXTEND(SP, 1);
     cx = &cxstack[cxstack_ix];
     if (cx->cx_type != CXt_LOOP)
        DIE("panic: pp_iter");
@@ -1361,7 +1403,9 @@ PP(pp_iter)
 
     SvREFCNT_dec(*cx->blk_loop.itervar);
 
-    if (sv = AvARRAY(av)[++cx->blk_loop.iterix])
+    if (sv = (SvMAGICAL(av)) 
+           ? *av_fetch(av, ++cx->blk_loop.iterix, FALSE) 
+           : AvARRAY(av)[++cx->blk_loop.iterix])
        SvTEMP_off(sv);
     else
        sv = &sv_undef;
@@ -1381,7 +1425,7 @@ PP(pp_iter)
        }
        LvTARG(lv) = SvREFCNT_inc(av);
        LvTARGOFF(lv) = cx->blk_loop.iterix;
-       LvTARGLEN(lv) = -1;
+       LvTARGLEN(lv) = (UV) -1;
        sv = (SV*)lv;
     }
 
@@ -1391,7 +1435,7 @@ PP(pp_iter)
 
 PP(pp_subst)
 {
-    dSP; dTARG;
+    djSP; dTARG;
     register PMOP *pm = cPMOP;
     PMOP *rpm = pm;
     register SV *dstr;
@@ -1412,19 +1456,23 @@ PP(pp_subst)
     STRLEN len;
     int force_on_match = 0;
     I32 oldsave = savestack_ix;
+    I32 update_minmatch = 1;
+    SV *screamer;
 
-    if (pm->op_pmflags & PMf_CONST)    /* known replacement string? */
-       dstr = POPs;
+    /* known replacement string? */
+    dstr = (pm->op_pmflags & PMf_CONST) ? POPs : Nullsv;
     if (op->op_flags & OPf_STACKED)
        TARG = POPs;
     else {
-       TARG = GvSV(defgv);
+       TARG = DEFSV;
        EXTEND(SP,1);
-    }
+    }                  
     if (SvREADONLY(TARG)
        || (SvTYPE(TARG) > SVt_PVLV
            && !(SvTYPE(TARG) == SVt_PVGV && SvFAKE(TARG))))
        croak(no_modify);
+    PUTBACK;
+
     s = SvPV(TARG, len);
     if (!SvPOKp(TARG) || SvTYPE(TARG) == SVt_PVGV)
        force_on_match = 1;
@@ -1441,41 +1489,52 @@ PP(pp_subst)
        pm = curpm;
        rx = pm->op_pmregexp;
     }
-    safebase = (!rx->nparens && !sawampersand);
+    screamer = ( (SvSCREAM(TARG) && rx->check_substr
+                 && SvTYPE(rx->check_substr) == SVt_PVBM
+                 && SvVALID(rx->check_substr)) 
+               ? TARG : Nullsv);
+    safebase = (!rx->nparens && !sawampersand) ? 0 : REXEC_COPY_STR;
     if (pm->op_pmflags & (PMf_MULTILINE|PMf_SINGLELINE)) {
        SAVEINT(multiline);
        multiline = pm->op_pmflags & PMf_MULTILINE;
     }
     orig = m = s;
-    if (pm->op_pmshort) {
-       if (pm->op_pmflags & PMf_SCANFIRST) {
-           if (SvSCREAM(TARG)) {
-               if (screamfirst[BmRARE(pm->op_pmshort)] < 0)
+    if (rx->check_substr) {
+       if (!(rx->reganch & ROPT_NOSCAN)) { /* It floats. */
+           if (screamer) {
+               I32 p = -1;
+               
+               if (screamfirst[BmRARE(rx->check_substr)] < 0)
                    goto nope;
-               else if (!(s = screaminstr(TARG, pm->op_pmshort)))
+               else if (!(s = screaminstr(TARG, rx->check_substr, rx->check_offset_min, 0, &p, 0)))
                    goto nope;
            }
-           else if (!(s = fbm_instr((unsigned char*)s, (unsigned char*)strend,
-             pm->op_pmshort)))
+           else if (!(s = fbm_instr((unsigned char*)s + rx->check_offset_min, 
+                                    (unsigned char*)strend,
+                                    rx->check_substr)))
                goto nope;
-           if (s && rx->regback >= 0) {
-               ++BmUSEFUL(pm->op_pmshort);
-               s -= rx->regback;
-               if (s < m)
-                   s = m;
+           if (s && rx->check_offset_max < s - m) {
+               ++BmUSEFUL(rx->check_substr);
+               s -= rx->check_offset_max;
            }
            else
                s = m;
        }
-       else if (!multiline) {
-           if (*SvPVX(pm->op_pmshort) != *s
-               || (pm->op_pmslen > 1
-                   && memNE(SvPVX(pm->op_pmshort), s, pm->op_pmslen)))
+       /* Now checkstring is fixed, i.e. at fixed offset from the
+          beginning of match, and the match is anchored at s. */
+       else if (!multiline) { /* Anchored at beginning of string. */
+           I32 slen;
+           if (*SvPVX(rx->check_substr) != s[rx->check_offset_min]
+               || ((slen = SvCUR(rx->check_substr)) > 1
+                   && memNE(SvPVX(rx->check_substr), 
+                            s + rx->check_offset_min, slen)))
                goto nope;
        }
-       if (!rx->naughty && --BmUSEFUL(pm->op_pmshort) < 0) {
-           SvREFCNT_dec(pm->op_pmshort);
-           pm->op_pmshort = Nullsv;    /* opt is being useless */
+       if (!rx->naughty && --BmUSEFUL(rx->check_substr) < 0
+           && rx->check_substr == rx->float_substr) {
+           SvREFCNT_dec(rx->check_substr);
+           rx->check_substr = Nullsv;  /* opt is being useless */
+           rx->float_substr = Nullsv;
        }
     }
 
@@ -1483,12 +1542,13 @@ PP(pp_subst)
     once = !(rpm->op_pmflags & PMf_GLOBAL);
 
     /* known replacement string? */
-    c = (rpm->op_pmflags & PMf_CONST) ? SvPV(dstr, clen) : Nullch;
+    c = dstr ? SvPV(dstr, clen) : Nullch;
 
     /* can do inplace substitution? */
-    if (c && clen <= rx->minlen) {
-       if (! pregexec(rx, s, strend, orig, 0,
-                      SvSCREAM(TARG) ? TARG : Nullsv, safebase)) {
+    if (c && clen <= rx->minlen && (once || !(safebase & REXEC_COPY_STR))
+       && !(rx->reganch & ROPT_LOOKBEHIND_SEEN)) {
+       if (!regexec_flags(rx, s, strend, orig, 0, screamer, NULL, safebase)) {
+           SPAGAIN;
            PUSHs(&sv_no);
            LEAVE_SCOPE(oldsave);
            RETURN;
@@ -1498,15 +1558,18 @@ PP(pp_subst)
            s = SvPV_force(TARG, len);
            goto force_it;
        }
-       if (rx->subbase)        /* oops, no we can't */
-           goto long_way;
        d = s;
        curpm = pm;
        SvSCREAM_off(TARG);     /* disable possible screamer */
        if (once) {
-           rxtainted = rx->exec_tainted;
-           m = rx->startp[0];
-           d = rx->endp[0];
+           rxtainted = RX_MATCH_TAINTED(rx);
+           if (rx->subbase) {
+               m = orig + (rx->startp[0] - rx->subbase);
+               d = orig + (rx->endp[0] - rx->subbase);
+           } else {
+               m = rx->startp[0];
+               d = rx->endp[0];
+           }
            s = orig;
            if (m - s > strend - d) {  /* faster to shorten from end */
                if (clen) {
@@ -1541,6 +1604,7 @@ PP(pp_subst)
                sv_chop(TARG, d);
            }
            TAINT_IF(rxtainted);
+           SPAGAIN;
            PUSHs(&sv_yes);
        }
        else {
@@ -1548,7 +1612,7 @@ PP(pp_subst)
            do {
                if (iters++ > maxiters)
                    DIE("Substitution loop");
-               rxtainted |= rx->exec_tainted;
+               rxtainted |= RX_MATCH_TAINTED(rx);
                m = rx->startp[0];
                /*SUPPRESS 560*/
                if (i = m - s) {
@@ -1561,44 +1625,48 @@ PP(pp_subst)
                    d += clen;
                }
                s = rx->endp[0];
-           } while (pregexec(rx, s, strend, orig, s == m,
-                             Nullsv, TRUE)); /* don't match same null twice */
+           } while (regexec_flags(rx, s, strend, orig, s == m,
+                             Nullsv, NULL, 0)); /* don't match same null twice */
            if (s != d) {
                i = strend - s;
                SvCUR_set(TARG, d - SvPVX(TARG) + i);
                Move(s, d, i+1, char);          /* include the NUL */
            }
            TAINT_IF(rxtainted);
+           SPAGAIN;
            PUSHs(sv_2mortal(newSViv((I32)iters)));
        }
        (void)SvPOK_only(TARG);
-       SvSETMAGIC(TARG);
+       if (SvSMAGICAL(TARG)) {
+           PUTBACK;
+           mg_set(TARG);
+           SPAGAIN;
+       }
        SvTAINT(TARG);
        LEAVE_SCOPE(oldsave);
        RETURN;
     }
 
-    if (pregexec(rx, s, strend, orig, 0,
-                SvSCREAM(TARG) ? TARG : Nullsv, safebase)) {
-    long_way:
+    if (regexec_flags(rx, s, strend, orig, 0, screamer, NULL, safebase)) {
        if (force_on_match) {
            force_on_match = 0;
            s = SvPV_force(TARG, len);
            goto force_it;
        }
-       rxtainted = rx->exec_tainted;
-       dstr = NEWSV(25, sv_len(TARG));
+       rxtainted = RX_MATCH_TAINTED(rx);
+       dstr = NEWSV(25, len);
        sv_setpvn(dstr, m, s-m);
        curpm = pm;
        if (!c) {
-           register CONTEXT *cx;
+           register PERL_CONTEXT *cx;
+           SPAGAIN;
            PUSHSUBST(cx);
            RETURNOP(cPMOP->op_pmreplroot);
        }
        do {
            if (iters++ > maxiters)
                DIE("Substitution loop");
-           rxtainted |= rx->exec_tainted;
+           rxtainted |= RX_MATCH_TAINTED(rx);
            if (rx->subbase && rx->subbase != orig) {
                m = s;
                s = orig;
@@ -1613,7 +1681,7 @@ PP(pp_subst)
                sv_catpvn(dstr, c, clen);
            if (once)
                break;
-       } while (pregexec(rx, s, strend, orig, s == m, Nullsv, safebase));
+       } while (regexec_flags(rx, s, strend, orig, s == m, Nullsv, NULL, safebase));
        sv_catpvn(dstr, s, strend - s);
 
        TAINT_IF(rxtainted);
@@ -1629,17 +1697,18 @@ PP(pp_subst)
        (void)SvPOK_only(TARG);
        SvSETMAGIC(TARG);
        SvTAINT(TARG);
+       SPAGAIN;
        PUSHs(sv_2mortal(newSViv((I32)iters)));
        LEAVE_SCOPE(oldsave);
        RETURN;
     }
-
-    PUSHs(&sv_no);
-    LEAVE_SCOPE(oldsave);
-    RETURN;
+    goto ret_no;
 
 nope:
-    ++BmUSEFUL(pm->op_pmshort);
+    ++BmUSEFUL(rx->check_substr);
+
+ret_no:         
+    SPAGAIN;
     PUSHs(&sv_no);
     LEAVE_SCOPE(oldsave);
     RETURN;
@@ -1647,7 +1716,7 @@ nope:
 
 PP(pp_grepwhile)
 {
-    dSP;
+    djSP;
 
     if (SvTRUEx(POPs))
        stack_base[markstack_ptr[-1]++] = stack_base[*markstack_ptr];
@@ -1655,20 +1724,21 @@ PP(pp_grepwhile)
     LEAVE;                                     /* exit inner scope */
 
     /* All done yet? */
-    if (stack_base + *markstack_ptr > sp) {
+    if (stack_base + *markstack_ptr > SP) {
        I32 items;
+       I32 gimme = GIMME_V;
 
        LEAVE;                                  /* exit outer scope */
        (void)POPMARK;                          /* pop src */
        items = --*markstack_ptr - markstack_ptr[-1];
        (void)POPMARK;                          /* pop dst */
        SP = stack_base + POPMARK;              /* pop original mark */
-       if (GIMME != G_ARRAY) {
+       if (gimme == G_SCALAR) {
            dTARGET;
            XPUSHi(items);
-           RETURN;
        }
-       SP += items;
+       else if (gimme == G_ARRAY)
+           SP += items;
        RETURN;
     }
     else {
@@ -1679,7 +1749,7 @@ PP(pp_grepwhile)
 
        src = stack_base[*markstack_ptr];
        SvTEMP_off(src);
-       GvSV(defgv) = src;
+       DEFSV = src;
 
        RETURNOP(cLOGOP->op_other);
     }
@@ -1687,17 +1757,18 @@ PP(pp_grepwhile)
 
 PP(pp_leavesub)
 {
-    dSP;
+    djSP;
     SV **mark;
     SV **newsp;
     PMOP *newpm;
     I32 gimme;
-    register CONTEXT *cx;
+    register PERL_CONTEXT *cx;
     struct block_sub cxsub;
 
     POPBLOCK(cx,newpm);
     POPSUB1(cx);       /* Delay POPSUB2 until stack values are safe */
  
+    TAINT_NOT;
     if (gimme == G_SCALAR) {
        MARK = newsp + 1;
        if (MARK <= SP)
@@ -1708,10 +1779,12 @@ PP(pp_leavesub)
        }
        SP = MARK;
     }
-    else {
+    else if (gimme == G_ARRAY) {
        for (MARK = newsp + 1; MARK <= SP; MARK++) {
-           if (!SvTEMP(*MARK))
+           if (!SvTEMP(*MARK)) {
                *MARK = sv_mortalcopy(*MARK);
+               TAINT_NOT;      /* Each item is independent */
+           }
        }
     }
     PUTBACK;
@@ -1723,13 +1796,41 @@ PP(pp_leavesub)
     return pop_return();
 }
 
+static CV *
+get_db_sub(SV **svp, CV *cv)
+{
+    dTHR;
+    SV *oldsv = *svp;
+    GV *gv;
+
+    *svp = GvSV(DBsub);
+    save_item(*svp);
+    gv = CvGV(cv);
+    if ( (CvFLAGS(cv) & (CVf_ANON | CVf_CLONED))
+        || strEQ(GvNAME(gv), "END") 
+        || ((GvCV(gv) != cv) && /* Could be imported, and old sub redefined. */
+            !( (SvTYPE(oldsv) == SVt_PVGV) && (GvCV((GV*)oldsv) == cv)
+               && (gv = (GV*)oldsv) ))) {
+       /* Use GV from the stack as a fallback. */
+       /* GV is potentially non-unique, or contain different CV. */
+       sv_setsv(*svp, newRV((SV*)cv));
+    }
+    else {
+       gv_efullname3(*svp, gv, Nullch);
+    }
+    cv = GvCV(DBsub);
+    if (CvXSUB(cv))
+       curcopdb = curcop;
+    return cv;
+}
+
 PP(pp_entersub)
 {
-    dSP; dPOPss;
+    djSP; dPOPss;
     GV *gv;
     HV *stash;
     register CV *cv;
-    register CONTEXT *cx;
+    register PERL_CONTEXT *cx;
     I32 gimme;
     bool hasargs = (op->op_flags & OPf_STACKED) != 0;
 
@@ -1740,8 +1841,11 @@ PP(pp_entersub)
        if (!SvROK(sv)) {
            char *sym;
 
-           if (sv == &sv_yes)          /* unfound import, ignore */
+           if (sv == &sv_yes) {                /* unfound import, ignore */
+               if (hasargs)
+                   SP = stack_base + POPMARK;
                RETURN;
+           }
            if (SvGMAGICAL(sv)) {
                mg_get(sv);
                sym = SvPOKp(sv) ? SvPVX(sv) : Nullch;
@@ -1780,7 +1884,7 @@ PP(pp_entersub)
 
     if (!CvROOT(cv) && !CvXSUB(cv)) {
        GV* autogv;
-       SV* subname;
+       SV* sub_name;
 
        /* anonymous or undef'd function leaves us no recourse */
        if (CvANON(cv) || !(gv = CvGV(cv)))
@@ -1791,38 +1895,155 @@ PP(pp_entersub)
            goto retry;
        }
        /* should call AUTOLOAD now? */
-       if ((autogv = gv_autoload(GvESTASH(gv), GvNAME(gv), GvNAMELEN(gv)))) {
+       if ((autogv = gv_autoload4(GvSTASH(gv), GvNAME(gv), GvNAMELEN(gv),
+                                  FALSE)))
+       {
            cv = GvCV(autogv);
            goto retry;
        }
        /* sorry */
-       subname = sv_newmortal();
-       gv_efullname3(subname, gv, Nullch);
-       DIE("Undefined subroutine &%s called", SvPVX(subname));
-    }
-
-    gimme = GIMME;
-    if ((op->op_private & OPpENTERSUB_DB) && GvCV(DBsub) && !CvNODEBUG(cv)) {
-       SV *oldsv = sv;
-       sv = GvSV(DBsub);
-       save_item(sv);
-       gv = CvGV(cv);
-       if ( (CvFLAGS(cv) & (CVf_ANON | CVf_CLONED))
-            || strEQ(GvNAME(gv), "END") 
-            || ((GvCV(gv) != cv) && /* Could be imported, and old sub redefined. */
-                !( (SvTYPE(oldsv) == SVt_PVGV) && (GvCV((GV*)oldsv) == cv)
-                   && (gv = (GV*)oldsv) ))) { /* Use GV from the stack as a fallback. */
-           /* GV is potentially non-unique, or contain different CV. */
-           sv_setsv(sv, newRV((SV*)cv));
+       sub_name = sv_newmortal();
+       gv_efullname3(sub_name, gv, Nullch);
+       DIE("Undefined subroutine &%s called", SvPVX(sub_name));
+    }
+
+    gimme = GIMME_V;
+    if ((op->op_private & OPpENTERSUB_DB) && GvCV(DBsub) && !CvNODEBUG(cv))
+       cv = get_db_sub(&sv, cv);
+    if (!cv)
+       DIE("No DBsub routine");
+
+#ifdef USE_THREADS
+    /*
+     * First we need to check if the sub or method requires locking.
+     * If so, we gain a lock on the CV, the first argument or the
+     * stash (for static methods), as appropriate. This has to be
+     * inline because for FAKE_THREADS, COND_WAIT inlines code to
+     * reschedule by returning a new op.
+     */
+    MUTEX_LOCK(CvMUTEXP(cv));
+    if (CvFLAGS(cv) & CVf_LOCKED) {
+       MAGIC *mg;        
+       if (CvFLAGS(cv) & CVf_PACKAGE) {
+           sv = (SV *) CvGV(cv);
+       }
+       else if (CvFLAGS(cv) & CVf_METHOD) {
+           if (SP > stack_base + TOPMARK)
+               sv = *(stack_base + TOPMARK + 1);
+           else {
+               MUTEX_UNLOCK(CvMUTEXP(cv));
+               croak("no argument for locked method call");
+           }
+           if (SvROK(sv))
+               sv = SvRV(sv);
+           else {              
+               STRLEN len;
+               char *stashname = SvPV(sv, len);
+               sv = (SV*)gv_stashpvn(stashname, len, TRUE);
+           }
        }
        else {
-           gv_efullname3(sv, gv, Nullch);
+           sv = (SV*)cv;
        }
-       cv = GvCV(DBsub);
-       if (CvXSUB(cv)) curcopdb = curcop;
-       if (!cv)
-           DIE("No DBsub routine");
+       MUTEX_UNLOCK(CvMUTEXP(cv));
+       mg = condpair_magic(sv);
+       MUTEX_LOCK(MgMUTEXP(mg));
+       if (MgOWNER(mg) == thr)
+           MUTEX_UNLOCK(MgMUTEXP(mg));
+       else {
+           while (MgOWNER(mg))
+               COND_WAIT(MgOWNERCONDP(mg), MgMUTEXP(mg));
+           MgOWNER(mg) = thr;
+           DEBUG_L(PerlIO_printf(PerlIO_stderr(), "%p: pp_entersub lock %p\n",
+                                 thr, sv);)
+           MUTEX_UNLOCK(MgMUTEXP(mg));
+           SvREFCNT_inc(sv);   /* Keep alive until magic_mutexfree */
+           save_destructor(unlock_condpair, sv);
+       }
+       MUTEX_LOCK(CvMUTEXP(cv));
     }
+    /*
+     * Now we have permission to enter the sub, we must distinguish
+     * four cases. (0) It's an XSUB (in which case we don't care
+     * about ownership); (1) it's ours already (and we're recursing);
+     * (2) it's free (but we may already be using a cached clone);
+     * (3) another thread owns it. Case (1) is easy: we just use it.
+     * Case (2) means we look for a clone--if we have one, use it
+     * otherwise grab ownership of cv. Case (3) means we look for a
+     * clone (for non-XSUBs) and have to create one if we don't
+     * already have one.
+     * Why look for a clone in case (2) when we could just grab
+     * ownership of cv straight away? Well, we could be recursing,
+     * i.e. we originally tried to enter cv while another thread
+     * owned it (hence we used a clone) but it has been freed up
+     * and we're now recursing into it. It may or may not be "better"
+     * to use the clone but at least CvDEPTH can be trusted.
+     */
+    if (CvOWNER(cv) == thr || CvXSUB(cv))
+       MUTEX_UNLOCK(CvMUTEXP(cv));
+    else {
+       /* Case (2) or (3) */
+       SV **svp;
+       
+       /*
+        * XXX Might it be better to release CvMUTEXP(cv) while we
+        * do the hv_fetch? We might find someone has pinched it
+        * when we look again, in which case we would be in case
+        * (3) instead of (2) so we'd have to clone. Would the fact
+        * that we released the mutex more quickly make up for this?
+        */
+       svp = hv_fetch(thr->cvcache, (char *)cv, sizeof(cv), FALSE);
+       if (svp) {
+           /* We already have a clone to use */
+           MUTEX_UNLOCK(CvMUTEXP(cv));
+           cv = *(CV**)svp;
+           DEBUG_L(PerlIO_printf(PerlIO_stderr(),
+                                 "entersub: %p already has clone %p:%s\n",
+                                 thr, cv, SvPEEK((SV*)cv)));
+           CvOWNER(cv) = thr;
+           SvREFCNT_inc(cv);
+           if (CvDEPTH(cv) == 0)
+               SAVEDESTRUCTOR(unset_cvowner, (void*) cv);
+       }
+       else {
+           /* (2) => grab ownership of cv. (3) => make clone */
+           if (!CvOWNER(cv)) {
+               CvOWNER(cv) = thr;
+               SvREFCNT_inc(cv);
+               MUTEX_UNLOCK(CvMUTEXP(cv));
+               DEBUG_L(PerlIO_printf(PerlIO_stderr(),
+                           "entersub: %p grabbing %p:%s in stash %s\n",
+                           thr, cv, SvPEEK((SV*)cv), CvSTASH(cv) ?
+                               HvNAME(CvSTASH(cv)) : "(none)"));
+           } else {
+               /* Make a new clone. */
+               CV *clonecv;
+               SvREFCNT_inc(cv); /* don't let it vanish from under us */
+               MUTEX_UNLOCK(CvMUTEXP(cv));
+               DEBUG_L((PerlIO_printf(PerlIO_stderr(),
+                                      "entersub: %p cloning %p:%s\n",
+                                      thr, cv, SvPEEK((SV*)cv))));
+               /*
+                * We're creating a new clone so there's no race
+                * between the original MUTEX_UNLOCK and the
+                * SvREFCNT_inc since no one will be trying to undef
+                * it out from underneath us. At least, I don't think
+                * there's a race...
+                */
+               clonecv = cv_clone(cv);
+               SvREFCNT_dec(cv); /* finished with this */
+               hv_store(thr->cvcache, (char*)cv, sizeof(cv), (SV*)clonecv,0);
+               CvOWNER(clonecv) = thr;
+               cv = clonecv;
+               SvREFCNT_inc(cv);
+           }
+           DEBUG_L(if (CvDEPTH(cv) != 0)
+                       PerlIO_printf(PerlIO_stderr(), "depth %ld != 0\n",
+                                     CvDEPTH(cv)););
+           SAVEDESTRUCTOR(unset_cvowner, (void*) cv);
+       }
+    }
+#endif /* USE_THREADS */
 
     if (CvXSUB(cv)) {
        if (CvOLDSTYLE(cv)) {
@@ -1830,9 +2051,9 @@ PP(pp_entersub)
            dMARK;
            register I32 items = SP - MARK;
                                        /* We dont worry to copy from @_. */
-           while (sp > mark) {
-               sp[1] = sp[0];
-               sp--;
+           while (SP > mark) {
+               SP[1] = SP[0];
+               SP--;
            }
            stack_sp = mark + 1;
            fp3 = (I32(*)_((int,int,int)))CvXSUB(cv);
@@ -1850,14 +2071,20 @@ PP(pp_entersub)
                /* Need to copy @_ to stack. Alternative may be to
                 * switch stack to @_, and copy return values
                 * back. This would allow popping @_ in XSUB, e.g.. XXXX */
-               AV* av = GvAV(defgv);
-               I32 items = AvFILL(av) + 1;
+               AV* av;
+               I32 items;
+#ifdef USE_THREADS
+               av = (AV*)curpad[0];
+#else
+               av = GvAV(defgv);
+#endif /* USE_THREADS */               
+               items = AvFILLp(av) + 1;   /* @_ is not tieable */
 
                if (items) {
                    /* Mark is at the end of the stack. */
-                   EXTEND(sp, items);
-                   Copy(AvARRAY(av), sp + 1, items, SV*);
-                   sp += items;
+                   EXTEND(SP, items);
+                   Copy(AvARRAY(av), SP + 1, items, SV*);
+                   SP += items;
                    PUTBACK ;               
                }
            }
@@ -1896,13 +2123,13 @@ PP(pp_entersub)
            (void)SvREFCNT_inc(cv);
        else {  /* save temporaries on recursion? */
            if (CvDEPTH(cv) == 100 && dowarn 
-                 && !(perldb && cv == GvCV(DBsub)))
+                 && !(PERLDB_SUB && cv == GvCV(DBsub)))
                sub_crush_depth(cv);
-           if (CvDEPTH(cv) > AvFILL(padlist)) {
+           if (CvDEPTH(cv) > AvFILLp(padlist)) {
                AV *av;
                AV *newpad = newAV();
                SV **oldpad = AvARRAY(svp[CvDEPTH(cv)-1]);
-               I32 ix = AvFILL((AV*)svp[1]);
+               I32 ix = AvFILLp((AV*)svp[1]);
                svp = AvARRAY(svp[0]);
                for ( ;ix > 0; ix--) {
                    if (svp[ix] != &sv_undef) {
@@ -1932,23 +2159,47 @@ PP(pp_entersub)
                av_store(newpad, 0, (SV*)av);
                AvFLAGS(av) = AVf_REIFY;
                av_store(padlist, CvDEPTH(cv), (SV*)newpad);
-               AvFILL(padlist) = CvDEPTH(cv);
+               AvFILLp(padlist) = CvDEPTH(cv);
                svp = AvARRAY(padlist);
            }
        }
-       SAVESPTR(curpad);
-       curpad = AvARRAY((AV*)svp[CvDEPTH(cv)]);
-       if (hasargs) {
+#ifdef USE_THREADS
+       if (!hasargs) {
            AV* av = (AV*)curpad[0];
+
+           items = AvFILLp(av) + 1;
+           if (items) {
+               /* Mark is at the end of the stack. */
+               EXTEND(SP, items);
+               Copy(AvARRAY(av), SP + 1, items, SV*);
+               SP += items;
+               PUTBACK ;                   
+           }
+       }
+#endif /* USE_THREADS */               
+       SAVESPTR(curpad);
+       curpad = AvARRAY((AV*)svp[CvDEPTH(cv)]);
+#ifndef USE_THREADS
+       if (hasargs)
+#endif /* USE_THREADS */
+       {
+           AV* av;
            SV** ary;
 
+#if 0
+           DEBUG_L(PerlIO_printf(PerlIO_stderr(),
+                                 "%p entersub preparing @_\n", thr));
+#endif
+           av = (AV*)curpad[0];
            if (AvREAL(av)) {
                av_clear(av);
                AvREAL_off(av);
            }
+#ifndef USE_THREADS
            cx->blk_sub.savearray = GvAV(defgv);
-           cx->blk_sub.argarray = av;
            GvAV(defgv) = (AV*)SvREFCNT_inc(av);
+#endif /* USE_THREADS */
+           cx->blk_sub.argarray = av;
            ++MARK;
 
            if (items > AvMAX(av) + 1) {
@@ -1965,7 +2216,7 @@ PP(pp_entersub)
                }
            }
            Copy(MARK,AvARRAY(av),items,SV*);
-           AvFILL(av) = items - 1;
+           AvFILLp(av) = items - 1;
            
            while (items--) {
                if (*MARK)
@@ -1973,13 +2224,16 @@ PP(pp_entersub)
                MARK++;
            }
        }
+#if 0
+       DEBUG_L(PerlIO_printf(PerlIO_stderr(),
+                             "%p entersub returning %p\n", thr, CvSTART(cv)));
+#endif
        RETURNOP(CvSTART(cv));
     }
 }
 
 void
-sub_crush_depth(cv)
-CV* cv;
+sub_crush_depth(CV *cv)
 {
     if (CvANON(cv))
        warn("Deep recursion on anonymous subroutine");
@@ -1992,7 +2246,7 @@ CV* cv;
 
 PP(pp_aelem)
 {
-    dSP;
+    djSP;
     SV** svp;
     I32 elem = POPi;
     AV* av = (AV*)POPs;
@@ -2020,7 +2274,7 @@ PP(pp_aelem)
            RETURN;
        }
        if (op->op_private & OPpLVAL_INTRO)
-           save_svref(svp);
+           save_aelem(av, elem, svp);
        else if (op->op_private & OPpDEREF)
            vivify_ref(*svp, op->op_private & OPpDEREF);
     }
@@ -2029,9 +2283,7 @@ PP(pp_aelem)
 }
 
 void
-vivify_ref(sv, to_what)
-SV* sv;
-U32 to_what;
+vivify_ref(SV *sv, U32 to_what)
 {
     if (SvGMAGICAL(sv))
        mg_get(sv);
@@ -2047,7 +2299,7 @@ U32 to_what;
        }
        switch (to_what) {
        case OPpDEREF_SV:
-           SvRV(sv) = newSV(0);
+           SvRV(sv) = NEWSV(355,0);
            break;
        case OPpDEREF_AV:
            SvRV(sv) = (SV*)newAV();
@@ -2063,64 +2315,76 @@ U32 to_what;
 
 PP(pp_method)
 {
-    dSP;
+    djSP;
     SV* sv;
     SV* ob;
     GV* gv;
-    SV* nm;
+    HV* stash;
+    char* name;
+    char* packname;
+    STRLEN packlen;
+
+    if (SvROK(TOPs)) {
+       sv = SvRV(TOPs);
+       if (SvTYPE(sv) == SVt_PVCV) {
+           SETs(sv);
+           RETURN;
+       }
+    }
 
-    nm = TOPs;
+    name = SvPV(TOPs, na);
     sv = *(stack_base + TOPMARK + 1);
     
-    gv = 0;
     if (SvGMAGICAL(sv))
         mg_get(sv);
     if (SvROK(sv))
        ob = (SV*)SvRV(sv);
     else {
        GV* iogv;
-       char* packname = 0;
-       STRLEN packlen;
 
+       packname = Nullch;
        if (!SvOK(sv) ||
            !(packname = SvPV(sv, packlen)) ||
            !(iogv = gv_fetchpv(packname, FALSE, SVt_PVIO)) ||
            !(ob=(SV*)GvIO(iogv)))
        {
-           char *name = SvPV(nm, na);
-           HV *stash;
-           if (!packname || !isALPHA(*packname))
-DIE("Can't call method \"%s\" without a package or object reference", name);
-           if (!(stash = gv_stashpvn(packname, packlen, FALSE))) {
-               if (gv_stashpvn("UNIVERSAL", 9, FALSE))
-                   stash = gv_stashpvn(packname, packlen, TRUE);
-               else
-                   DIE("Can't call method \"%s\" in empty package \"%s\"",
-                       name, packname);
-           }
-           gv = gv_fetchmethod(stash,name);
-           if (!gv)
-               DIE("Can't locate object method \"%s\" via package \"%s\"",
-                   name, packname);
-           SETs(isGV(gv) ? (SV*)GvCV(gv) : (SV*)gv);
-           RETURN;
+           if (!packname || !isIDFIRST(*packname))
+  DIE("Can't call method \"%s\" without a package or object reference", name);
+           stash = gv_stashpvn(packname, packlen, TRUE);
+           goto fetch;
        }
        *(stack_base + TOPMARK + 1) = sv_2mortal(newRV((SV*)iogv));
     }
 
-    if (!ob || !SvOBJECT(ob)) {
-       char *name = SvPV(nm, na);
+    if (!ob || !SvOBJECT(ob))
        DIE("Can't call method \"%s\" on unblessed reference", name);
-    }
 
-    if (!gv) {         /* nothing cached */
-       char *name = SvPV(nm, na);
-       gv = gv_fetchmethod(SvSTASH(ob),name);
-       if (!gv)
-           DIE("Can't locate object method \"%s\" via package \"%s\"",
-               name, HvNAME(SvSTASH(ob)));
-    }
+    stash = SvSTASH(ob);
+
+  fetch:
+    gv = gv_fetchmethod(stash, name);
+    if (!gv) {
+       char* leaf = name;
+       char* sep = Nullch;
+       char* p;
 
+       for (p = name; *p; p++) {
+           if (*p == '\'')
+               sep = p, leaf = p + 1;
+           else if (*p == ':' && *(p + 1) == ':')
+               sep = p, leaf = p + 2;
+       }
+       if (!sep || ((sep - name) == 5 && strnEQ(name, "SUPER", 5))) {
+           packname = HvNAME(sep ? curcop->cop_stash : stash);
+           packlen = strlen(packname);
+       }
+       else {
+           packname = name;
+           packlen = sep - name;
+       }
+       DIE("Can't locate object method \"%s\" via package \"%.*s\"",
+           leaf, (int)packlen, packname);
+    }
     SETs(isGV(gv) ? (SV*)GvCV(gv) : (SV*)gv);
     RETURN;
 }