This is a live mirror of the Perl 5 development currently hosted at https://github.com/perl/perl5
AIX patch (including Configure support for {sched,pthread}_yield,
[perl5.git] / perl.c
diff --git a/perl.c b/perl.c
index be2f7d8..923eea5 100644 (file)
--- a/perl.c
+++ b/perl.c
@@ -1,6 +1,6 @@
 /*    perl.c
  *
- *    Copyright (c) 1987-1996 Larry Wall
+ *    Copyright (c) 1987-1997 Larry Wall
  *
  *    You may distribute under the terms of either the GNU General Public
  *    License or the Artistic License, as specified in the README file.
 #include <unistd.h>
 #endif
 
+#if !defined(STANDARD_C) && !defined(HAS_GETENV_PROTOTYPE)
+char *getenv _((char *)); /* Usually in <stdlib.h> */
+#endif
+
 dEXTCONST char rcsid[] = "perl.c\nPatch level: ###\n";
 
 #ifdef IAMSUID
@@ -55,6 +59,7 @@ dEXTCONST char rcsid[] = "perl.c\nPatch level: ###\n";
     dlmax       = 128;         \
     laststatval = -1;          \
     laststype   = OP_STAT;     \
+    mess_sv     = Nullsv;      \
   } STMT_END
 
 static void find_beginning _((void));
@@ -64,10 +69,12 @@ static void init_ids _((void));
 static void init_debugger _((void));
 static void init_lexer _((void));
 static void init_main_stash _((void));
+#ifdef USE_THREADS
+static struct perl_thread * init_main_thread _((void));
+#endif /* USE_THREADS */
 static void init_perllib _((void));
 static void init_postdump_symbols _((int, char **, char **));
 static void init_predump_symbols _((void));
-static void init_stacks _((void));
 static void my_exit_jump _((void)) __attribute__((noreturn));
 static void nuke_stacks _((void));
 static void open_script _((char *, bool, SV *));
@@ -76,8 +83,21 @@ static void validate_suid _((char *, char*));
 
 static int fdscript = -1;
 
+#if defined(DEBUGGING) && defined(USE_THREADS) && defined(__linux__)
+#include <asm/sigcontext.h>
+static void
+catch_sigsegv(int signo, struct sigcontext_struct sc)
+{
+    signal(SIGSEGV, SIG_DFL);
+    fprintf(stderr, "Segmentation fault dereferencing 0x%lx\n"
+                   "return_address = 0x%lx, eip = 0x%lx\n",
+                   sc.cr2, __builtin_return_address(0), sc.eip);
+    fprintf(stderr, "thread = 0x%lx\n", (unsigned long)THR); 
+}
+#endif
+
 PerlInterpreter *
-perl_alloc()
+perl_alloc(void)
 {
     PerlInterpreter *sv_interp;
 
@@ -87,9 +107,15 @@ perl_alloc()
 }
 
 void
-perl_construct( sv_interp )
-register PerlInterpreter *sv_interp;
+perl_construct(register PerlInterpreter *sv_interp)
 {
+#ifdef USE_THREADS
+    int i;
+#ifndef FAKE_THREADS
+    struct perl_thread *thr;
+#endif /* FAKE_THREADS */
+#endif /* USE_THREADS */
+    
     if (!(curinterp = sv_interp))
        return;
 
@@ -97,8 +123,31 @@ register PerlInterpreter *sv_interp;
     Zero(sv_interp, 1, PerlInterpreter);
 #endif
 
-    /* Init the real globals? */
+   /* Init the real globals (and main thread)? */
     if (!linestr) {
+#ifdef USE_THREADS
+
+       INIT_THREADS;
+#ifdef ALLOC_THREAD_KEY
+        ALLOC_THREAD_KEY;
+#else
+       if (pthread_key_create(&thr_key, 0))
+           croak("panic: pthread_key_create");
+#endif
+       MUTEX_INIT(&malloc_mutex);
+       MUTEX_INIT(&sv_mutex);
+       /*
+        * Safe to use basic SV functions from now on (though
+        * not things like mortals or tainting yet).
+        */
+       MUTEX_INIT(&eval_mutex);
+       COND_INIT(&eval_cond);
+       MUTEX_INIT(&threads_mutex);
+       COND_INIT(&nthreads_cond);
+       
+       thr = init_main_thread();
+#endif /* USE_THREADS */
+
        linestr = NEWSV(65,80);
        sv_upgrade(linestr,SVt_PVIV);
 
@@ -117,6 +166,7 @@ register PerlInterpreter *sv_interp;
        nrs = newSVpv("\n", 1);
        rs = SvREFCNT_inc(nrs);
 
+       sighandlerp = sighandler;
        pidstatus = newHV();
 
 #ifdef MSDOS
@@ -139,7 +189,12 @@ register PerlInterpreter *sv_interp;
 #endif
 
     init_ids();
+    lex_state = LEX_NOTPARSING;
 
+    start_env.je_prev = NULL;
+    start_env.je_ret = -1;
+    start_env.je_mustcatch = TRUE;
+    top_env     = &start_env;
     STATUS_ALL_SUCCESS;
 
     SET_NUMERIC_STANDARD();
@@ -160,21 +215,99 @@ register PerlInterpreter *sv_interp;
 
     fdpid = newAV();   /* for remembering popen pids by fd */
 
-    init_stacks();
+    init_stacks(ARGS);
+    DEBUG( {
+       New(51,debname,128,char);
+       New(52,debdelim,128,char);
+    } )
+
     ENTER;
 }
 
 void
-perl_destruct(sv_interp)
-register PerlInterpreter *sv_interp;
+perl_destruct(register PerlInterpreter *sv_interp)
 {
+    dTHR;
     int destruct_level;  /* 0=none, 1=full, 2=full with checks */
     I32 last_sv_count;
     HV *hv;
+#ifdef USE_THREADS
+    Thread t;
+#endif /* USE_THREADS */
 
     if (!(curinterp = sv_interp))
        return;
 
+#ifdef USE_THREADS
+#ifndef FAKE_THREADS
+    /* Pass 1 on any remaining threads: detach joinables, join zombies */
+  retry_cleanup:
+    MUTEX_LOCK(&threads_mutex);
+    DEBUG_L(PerlIO_printf(PerlIO_stderr(),
+                         "perl_destruct: waiting for %d threads...\n",
+                         nthreads - 1));
+    for (t = thr->next; t != thr; t = t->next) {
+       MUTEX_LOCK(&t->mutex);
+       switch (ThrSTATE(t)) {
+           AV *av;
+       case THRf_ZOMBIE:
+           DEBUG_L(PerlIO_printf(PerlIO_stderr(),
+                                 "perl_destruct: joining zombie %p\n", t));
+           ThrSETSTATE(t, THRf_DEAD);
+           MUTEX_UNLOCK(&t->mutex);
+           nthreads--;
+           /*
+            * The SvREFCNT_dec below may take a long time (e.g. av
+            * may contain an object scalar whose destructor gets
+            * called) so we have to unlock threads_mutex and start
+            * all over again.
+            */
+           MUTEX_UNLOCK(&threads_mutex);
+           JOIN(t, &av);
+           SvREFCNT_dec((SV*)av);
+           DEBUG_L(PerlIO_printf(PerlIO_stderr(),
+                                 "perl_destruct: joined zombie %p OK\n", t));
+           goto retry_cleanup;
+       case THRf_R_JOINABLE:
+           DEBUG_L(PerlIO_printf(PerlIO_stderr(),
+                                 "perl_destruct: detaching thread %p\n", t));
+           ThrSETSTATE(t, THRf_R_DETACHED);
+           /* 
+            * We unlock threads_mutex and t->mutex in the opposite order
+            * from which we locked them just so that DETACH won't
+            * deadlock if it panics. It's only a breach of good style
+            * not a bug since they are unlocks not locks.
+            */
+           MUTEX_UNLOCK(&threads_mutex);
+           DETACH(t);
+           MUTEX_UNLOCK(&t->mutex);
+           goto retry_cleanup;
+       default:
+           DEBUG_L(PerlIO_printf(PerlIO_stderr(),
+                                 "perl_destruct: ignoring %p (state %u)\n",
+                                 t, ThrSTATE(t)));
+           MUTEX_UNLOCK(&t->mutex);
+           /* fall through and out */
+       }
+    }
+    /* We leave the above "Pass 1" loop with threads_mutex still locked */
+
+    /* Pass 2 on remaining threads: wait for the thread count to drop to one */
+    while (nthreads > 1)
+    {
+       DEBUG_L(PerlIO_printf(PerlIO_stderr(),
+                             "perl_destruct: final wait for %d threads\n",
+                             nthreads - 1));
+       COND_WAIT(&nthreads_cond, &threads_mutex);
+    }
+    /* At this point, we're the last thread */
+    MUTEX_UNLOCK(&threads_mutex);
+    DEBUG_L(PerlIO_printf(PerlIO_stderr(), "perl_destruct: armageddon has arrived\n"));
+    MUTEX_DESTROY(&threads_mutex);
+    COND_DESTROY(&nthreads_cond);
+#endif /* !defined(FAKE_THREADS) */
+#endif /* USE_THREADS */
+
     destruct_level = perl_destruct_level;
 #ifdef DEBUGGING
     {
@@ -187,14 +320,6 @@ register PerlInterpreter *sv_interp;
     }
 #endif
 
-    /* unhook hooks which will soon be, or use, destroyed data */
-    SvREFCNT_dec(warnhook);
-    warnhook = Nullsv;
-    SvREFCNT_dec(diehook);
-    diehook = Nullsv;
-    SvREFCNT_dec(parsehook);
-    parsehook = Nullsv;
-
     LEAVE;
     FREETMPS;
 
@@ -221,6 +346,14 @@ register PerlInterpreter *sv_interp;
        sv_clean_objs();
     }
 
+    /* unhook hooks which will soon be, or use, destroyed data */
+    SvREFCNT_dec(warnhook);
+    warnhook = Nullsv;
+    SvREFCNT_dec(diehook);
+    diehook = Nullsv;
+    SvREFCNT_dec(parsehook);
+    parsehook = Nullsv;
+
     if (destruct_level == 0){
 
        DEBUG_P(debprofdump());
@@ -285,36 +418,6 @@ register PerlInterpreter *sv_interp;
 
     /* defgv, aka *_ should be taken care of elsewhere */
 
-#if 0  /* just about all regexp stuff, seems to be ok */
-
-    /* shortcuts to regexp stuff */
-    leftgv = Nullgv;
-    ampergv = Nullgv;
-
-    SAVEFREEOP(curpm);
-    SAVEFREEOP(oldlastpm); /* for saving regexp context during debugger */
-
-    regprecomp = NULL; /* uncompiled string. */
-    regparse = NULL;   /* Input-scan pointer. */
-    regxend = NULL;    /* End of input for compile */
-    regnpar = 0;       /* () count. */
-    regcode = NULL;    /* Code-emit pointer; &regdummy = don't. */
-    regsize = 0;       /* Code size. */
-    regnaughty = 0;    /* How bad is this pattern? */
-    regsawback = 0;    /* Did we see \1, ...? */
-
-    reginput = NULL;           /* String-input pointer. */
-    regbol = NULL;             /* Beginning of input, for ^ check. */
-    regeol = NULL;             /* End of input, for $ check. */
-    regstartp = (char **)NULL; /* Pointer to startp array. */
-    regendp = (char **)NULL;   /* Ditto for endp. */
-    reglastparen = 0;          /* Similarly for lastparen. */
-    regtill = NULL;            /* How far we are required to go. */
-    regflags = 0;              /* are we folding, multilining? */
-    regprev = (char)NULL;      /* char before regbol, \n if none */
-
-#endif /* if 0 */
-
     /* clean up after study() */
     SvREFCNT_dec(lastscream);
     lastscream = Nullsv;
@@ -326,8 +429,10 @@ register PerlInterpreter *sv_interp;
     /* startup and shutdown function lists */
     SvREFCNT_dec(beginav);
     SvREFCNT_dec(endav);
+    SvREFCNT_dec(initav);
     beginav = Nullav;
     endav = Nullav;
+    initav = Nullav;
 
     /* temp stack during pp_sort() */
     SvREFCNT_dec(sortstack);
@@ -419,37 +524,55 @@ register PerlInterpreter *sv_interp;
     if (origfilename)
        Safefree(origfilename);
     nuke_stacks();
-    hints = 0;                 /* Reset hints. Should hints be per-interpreter ? */
+    hints = 0;         /* Reset hints. Should hints be per-interpreter ? */
     
     DEBUG_P(debprofdump());
+#ifdef USE_THREADS
+    MUTEX_DESTROY(&sv_mutex);
+    MUTEX_DESTROY(&malloc_mutex);
+    MUTEX_DESTROY(&eval_mutex);
+    COND_DESTROY(&eval_cond);
+
+    /* As the penultimate thing, free the non-arena SV for thrsv */
+    Safefree(SvPVX(thrsv));
+    Safefree(SvANY(thrsv));
+    Safefree(thrsv);
+    thrsv = Nullsv;
+#endif /* USE_THREADS */
+    
+    /* As the absolutely last thing, free the non-arena SV for mess() */
+
+    if (mess_sv) {
+       /* we know that type >= SVt_PV */
+       SvOOK_off(mess_sv);
+       Safefree(SvPVX(mess_sv));
+       Safefree(SvANY(mess_sv));
+       Safefree(mess_sv);
+       mess_sv = Nullsv;
+    }
 }
 
 void
-perl_free(sv_interp)
-PerlInterpreter *sv_interp;
+perl_free(PerlInterpreter *sv_interp)
 {
     if (!(curinterp = sv_interp))
        return;
     Safefree(sv_interp);
 }
-#if !defined(STANDARD_C) && !defined(HAS_GETENV_PROTOTYPE)
-char *getenv _((char *)); /* Usually in <stdlib.h> */
-#endif
 
 int
-perl_parse(sv_interp, xsinit, argc, argv, env)
-PerlInterpreter *sv_interp;
-void (*xsinit)_((void));
-int argc;
-char **argv;
-char **env;
+perl_parse(PerlInterpreter *sv_interp, void (*xsinit) (void), int argc, char **argv, char **env)
 {
+    dTHR;
     register SV *sv;
     register char *s;
     char *scriptname = NULL;
     VOL bool dosearch = FALSE;
     char *validarg = "";
+    I32 oldscope;
     AV* comppadlist;
+    dJMPENV;
+    int ret;
 
 #ifdef SETUID_SCRIPTS_ARE_SECURE_NOW
 #ifdef IAMSUID
@@ -496,18 +619,25 @@ setuid perl scripts securely.\n");
     main_cv = Nullcv;
 
     time(&basetime);
+    oldscope = scopestack_ix;
 
-    switch (Sigsetjmp(top_env,1)) {
+    JMPENV_PUSH(ret);
+    switch (ret) {
     case 1:
        STATUS_ALL_FAILURE;
        /* FALL THROUGH */
     case 2:
        /* my_exit() was called */
+       while (scopestack_ix > oldscope)
+           LEAVE;
+       FREETMPS;
        curstash = defstash;
        if (endav)
-           calllist(endav);
+           call_list(oldscope, endav);
+       JMPENV_POP;
        return STATUS_NATIVE_EXPORT;
     case 3:
+       JMPENV_POP;
        PerlIO_printf(PerlIO_stderr(), "panic: top_env\n");
        return 1;
     }
@@ -516,6 +646,7 @@ setuid perl scripts securely.\n");
     sv = newSVpv("",0);                /* first used for -I flags */
     SAVEFREESV(sv);
     init_main_stash();
+
     for (argc--,argv++; argc > 0; argc--,argv++) {
        if (argv[0][0] != '-' || !argv[0][1])
            break;
@@ -577,20 +708,23 @@ setuid perl scripts securely.\n");
                croak("No code specified for -e");
            (void)PerlIO_putc(e_fp,'\n');
            break;
-       case 'I':
+       case 'I':       /* -I handled both here and in moreswitches() */
            forbid_setid("-I");
-           sv_catpv(sv,"-");
-           sv_catpv(sv,s);
-           sv_catpv(sv," ");
-           if (*++s) {
-               incpush(s, TRUE);
-           }
-           else if (argv[1]) {
-               incpush(argv[1], TRUE);
-               sv_catpv(sv,argv[1]);
+           if (!*++s && (s=argv[1]) != Nullch) {
                argc--,argv++;
-               sv_catpv(sv," ");
            }
+           while (s && isSPACE(*s))
+               ++s;
+           if (s && *s) {
+               char *e, *p;
+               for (e = s; *e && !isSPACE(*e); e++) ;
+               p = savepvn(s, e-s);
+               incpush(p, TRUE);
+               sv_catpv(sv,"-I");
+               sv_catpv(sv,p);
+               sv_catpv(sv," ");
+               Safefree(p);
+           }   /* XXX else croak? */
            break;
        case 'P':
            forbid_setid("-P");
@@ -613,43 +747,42 @@ setuid perl scripts securely.\n");
 #else
                sv_catpv(Sv,"print \"\\nCharacteristics of this binary (from libperl): \\n\",");
 #endif
-#if defined(DEBUGGING) || defined(NOEMBED) || defined(MULTIPLICITY)
-               strcpy(buf,"\"  Compile-time options:");
+#if defined(DEBUGGING) || defined(NO_EMBED) || defined(MULTIPLICITY)
+               sv_catpv(Sv,"\"  Compile-time options:");
 #  ifdef DEBUGGING
-               strcat(buf," DEBUGGING");
+               sv_catpv(Sv," DEBUGGING");
 #  endif
-#  ifdef NOEMBED
-               strcat(buf," NOEMBED");
+#  ifdef NO_EMBED
+               sv_catpv(Sv," NO_EMBED");
 #  endif
 #  ifdef MULTIPLICITY
-               strcat(buf," MULTIPLICITY");
+               sv_catpv(Sv," MULTIPLICITY");
 #  endif
-               strcat(buf,"\\n\",");
-               sv_catpv(Sv,buf);
+               sv_catpv(Sv,"\\n\",");
 #endif
 #if defined(LOCAL_PATCH_COUNT)
-               if (LOCAL_PATCH_COUNT > 0)
-               {   int i;
-                   sv_catpv(Sv,"print \"  Locally applied patches:\\n\",");
+               if (LOCAL_PATCH_COUNT > 0) {
+                   int i;
+                   sv_catpv(Sv,"\"  Locally applied patches:\\n\",");
                    for (i = 1; i <= LOCAL_PATCH_COUNT; i++) {
-                       if (localpatches[i]) {
-                           sprintf(buf,"\"  \\t%s\\n\",",localpatches[i]);
-                           sv_catpv(Sv,buf);
-                       }
+                       if (localpatches[i])
+                           sv_catpvf(Sv,"\"  \\t%s\\n\",",localpatches[i]);
                    }
                }
 #endif
-               sprintf(buf,"\"  Built under %s\\n\",",OSNAME);
-               sv_catpv(Sv,buf);
+               sv_catpvf(Sv,"\"  Built under %s\\n\"",OSNAME);
 #ifdef __DATE__
 #  ifdef __TIME__
-               sprintf(buf,"\"  Compiled at %s %s\\n\"",__DATE__,__TIME__);
+               sv_catpvf(Sv,",\"  Compiled at %s %s\\n\"",__DATE__,__TIME__);
 #  else
-               sprintf(buf,"\"  Compiled on %s\\n\"",__DATE__);
+               sv_catpvf(Sv,",\"  Compiled on %s\\n\"",__DATE__);
 #  endif
-               sv_catpv(Sv,buf);
 #endif
-               sv_catpv(Sv,"; $\"=\"\\n    \"; print \"  \\@INC:\\n    @INC\\n\"");
+               sv_catpv(Sv, "; \
+$\"=\"\\n    \"; \
+@env = map { \"$_=\\\"$ENV{$_}\\\"\" } sort grep {/^PERL/} keys %ENV; \
+print \"  \\%ENV:\\n    @env\\n\" if @env; \
+print \"  \\@INC:\\n    @INC\\n\";");
            }
            else {
                Sv = newSVpv("config_vars(qw(",0);
@@ -666,21 +799,56 @@ setuid perl scripts securely.\n");
            if (*s)
                cddir = savepv(s);
            break;
-       case '-':
-           argc--,argv++;
-           goto switch_end;
        case 0:
            break;
+       case '-':
+           if (!*++s || isSPACE(*s)) {
+               argc--,argv++;
+               goto switch_end;
+           }
+           /* catch use of gnu style long options */
+           if (strEQ(s, "version")) {
+               s = "v";
+               goto reswitch;
+           }
+           if (strEQ(s, "help")) {
+               s = "h";
+               goto reswitch;
+           }
+           s--;
+           /* FALL THROUGH */
        default:
-           croak("Unrecognized switch: -%s",s);
+           croak("Unrecognized switch: -%s  (-h will show valid options)",s);
        }
     }
   switch_end:
+
+    if (!tainting && (s = getenv("PERL5OPT"))) {
+       while (s && *s) {
+           while (isSPACE(*s))
+               s++;
+           if (*s == '-') {
+               s++;
+               if (isSPACE(*s))
+                   continue;
+           }
+           if (!*s)
+               break;
+           if (!strchr("DIMUdmw", *s))
+               croak("Illegal switch in PERL5OPT: -%c", *s);
+           s = moreswitches(s);
+       }
+    }
+
     if (!scriptname)
        scriptname = argv[0];
     if (e_fp) {
-       if (PerlIO_flush(e_fp) || PerlIO_error(e_fp) || PerlIO_close(e_fp))
+       if (PerlIO_flush(e_fp) || PerlIO_error(e_fp) || PerlIO_close(e_fp)) {
+#ifndef MULTIPLICITY
+           warn("Did you forget to compile with -DMULTIPLICITY?");
+#endif     
            croak("Can't write to temp file for -e: %s", Strerror(errno));
+       }
        e_fp = Nullfp;
        argc++,argv--;
        scriptname = e_tmpname;
@@ -713,6 +881,14 @@ setuid perl scripts securely.\n");
     comppad_name_fill = 0;
     min_intro_pending = 0;
     padix = 0;
+#ifdef USE_THREADS
+    av_store(comppad_name, 0, newSVpv("@_", 2));
+    curpad[0] = (SV*)newAV();
+    SvPADMY_on(curpad[0]);     /* XXX Needed? */
+    CvOWNER(compcv) = 0;
+    New(666, CvMUTEXP(compcv), 1, perl_mutex);
+    MUTEX_INIT(CvMUTEXP(compcv));
+#endif /* USE_THREADS */
 
     comppadlist = newAV();
     AvREAL_off(comppadlist);
@@ -723,10 +899,14 @@ setuid perl scripts securely.\n");
     boot_core_UNIVERSAL();
     if (xsinit)
        (*xsinit)();    /* in case linked C routines want magical variables */
-#ifdef VMS
+#if defined(VMS) || defined(WIN32)
     init_os_extras();
 #endif
 
+#if defined(DEBUGGING) && defined(USE_THREADS) && defined(__linux__)
+    DEBUG_L(signal(SIGSEGV, (void(*)(int))catch_sigsegv););
+#endif
+
     init_predump_symbols();
     if (!do_undump)
        init_postdump_symbols(argc,argv,env);
@@ -756,8 +936,11 @@ setuid perl scripts securely.\n");
     /* now that script is parsed, we can modify record separator */
     SvREFCNT_dec(rs);
     rs = SvREFCNT_inc(nrs);
+#ifdef USE_THREADS
+    sv_setsv(*av_fetch(thr->threadsv, find_threadsv("/"), FALSE), rs); 
+#else
     sv_setsv(GvSV(gv_fetchpv("/", TRUE, SVt_PV)), rs);
-
+#endif /* USE_THREADS */
     if (do_undump)
        my_unexec();
 
@@ -767,41 +950,54 @@ setuid perl scripts securely.\n");
     LEAVE;
     FREETMPS;
 
-#ifdef DEBUGGING_MSTATS
+#ifdef MYMALLOC
     if ((s=getenv("PERL_DEBUG_MSTATS")) && atoi(s) >= 2)
        dump_mstats("after compilation:");
 #endif
 
     ENTER;
     restartop = 0;
+    JMPENV_POP;
     return 0;
 }
 
 int
-perl_run(sv_interp)
-PerlInterpreter *sv_interp;
+perl_run(PerlInterpreter *sv_interp)
 {
+    dTHR;
+    I32 oldscope;
+    dJMPENV;
+    int ret;
+
     if (!(curinterp = sv_interp))
        return 255;
-    switch (Sigsetjmp(top_env,1)) {
+
+    oldscope = scopestack_ix;
+
+    JMPENV_PUSH(ret);
+    switch (ret) {
     case 1:
        cxstack_ix = -1;                /* start context stack again */
        break;
     case 2:
        /* my_exit() was called */
+       while (scopestack_ix > oldscope)
+           LEAVE;
+       FREETMPS;
        curstash = defstash;
        if (endav)
-           calllist(endav);
-       FREETMPS;
-#ifdef DEBUGGING_MSTATS
+           call_list(oldscope, endav);
+#ifdef MYMALLOC
        if (getenv("PERL_DEBUG_MSTATS"))
            dump_mstats("after execution:  ");
 #endif
+       JMPENV_POP;
        return STATUS_NATIVE_EXPORT;
     case 3:
        if (!restartop) {
            PerlIO_printf(PerlIO_stderr(), "panic: restartop\n");
            FREETMPS;
+           JMPENV_POP;
            return 1;
        }
        if (curstack != mainstack) {
@@ -811,19 +1007,25 @@ PerlInterpreter *sv_interp;
        break;
     }
 
-    DEBUG_r(PerlIO_printf(PerlIO_stderr(), "%s $` $& $' support.\n",
+    DEBUG_r(PerlIO_printf(Perl_debug_log, "%s $` $& $' support.\n",
                     sawampersand ? "Enabling" : "Omitting"));
 
     if (!restartop) {
        DEBUG_x(dump_all());
        DEBUG(PerlIO_printf(Perl_debug_log, "\nEXECUTING...\n\n"));
+#ifdef USE_THREADS
+       DEBUG_L(PerlIO_printf(Perl_debug_log, "main thread is 0x%lx\n",
+                             (unsigned long) thr));
+#endif /* USE_THREADS */       
 
        if (minus_c) {
            PerlIO_printf(PerlIO_stderr(), "%s syntax OK\n", origfilename);
            my_exit(0);
        }
-       if (perldb && DBsingle)
+       if (PERLDB_SINGLE && DBsingle)
           sv_setiv(DBsingle, 1); 
+       if (initav)
+           call_list(oldscope, initav);
     }
 
     /* do it */
@@ -840,24 +1042,31 @@ PerlInterpreter *sv_interp;
     }
 
     my_exit(0);
+    /* NOTREACHED */
     return 0;
 }
 
 SV*
-perl_get_sv(name, create)
-char* name;
-I32 create;
+perl_get_sv(char *name, I32 create)
 {
-    GV* gv = gv_fetchpv(name, create, SVt_PV);
+    GV *gv;
+#ifdef USE_THREADS
+    if (name[1] == '\0' && !isALPHA(name[0])) {
+       PADOFFSET tmp = find_threadsv(name);
+       if (tmp != NOT_IN_PAD) {
+           dTHR;
+           return *av_fetch(thr->threadsv, tmp, FALSE);
+       }
+    }
+#endif /* USE_THREADS */
+    gv = gv_fetchpv(name, create, SVt_PV);
     if (gv)
        return GvSV(gv);
     return Nullsv;
 }
 
 AV*
-perl_get_av(name, create)
-char* name;
-I32 create;
+perl_get_av(char *name, I32 create)
 {
     GV* gv = gv_fetchpv(name, create, SVt_PVAV);
     if (create)
@@ -868,9 +1077,7 @@ I32 create;
 }
 
 HV*
-perl_get_hv(name, create)
-char* name;
-I32 create;
+perl_get_hv(char *name, I32 create)
 {
     GV* gv = gv_fetchpv(name, create, SVt_PVHV);
     if (create)
@@ -881,9 +1088,7 @@ I32 create;
 }
 
 CV*
-perl_get_cv(name, create)
-char* name;
-I32 create;
+perl_get_cv(char *name, I32 create)
 {
     GV* gv = gv_fetchpv(name, create, SVt_PVCV);
     if (create && !GvCVu(gv))
@@ -899,10 +1104,10 @@ I32 create;
 /* Be sure to refetch the stack pointer after calling these routines. */
 
 I32
-perl_call_argv(subname, flags, argv)
-char *subname;
-I32 flags;             /* See G_* flags in cop.h */
-register char **argv;  /* null terminated arg list */
+perl_call_argv(char *subname, I32 flags, register char **argv)
+              
+                       /* See G_* flags in cop.h */
+                       /* null terminated arg list */
 {
     dSP;
 
@@ -918,17 +1123,17 @@ register char **argv;    /* null terminated arg list */
 }
 
 I32
-perl_call_pv(subname, flags)
-char *subname;         /* name of the subroutine */
-I32 flags;             /* See G_* flags in cop.h */
+perl_call_pv(char *subname, I32 flags)
+                       /* name of the subroutine */
+                       /* See G_* flags in cop.h */
 {
     return perl_call_sv((SV*)perl_get_cv(subname, TRUE), flags);
 }
 
 I32
-perl_call_method(methname, flags)
-char *methname;                /* name of the subroutine */
-I32 flags;             /* See G_* flags in cop.h */
+perl_call_method(char *methname, I32 flags)
+                               /* name of the subroutine */
+                       /* See G_* flags in cop.h */
 {
     dSP;
     OP myop;
@@ -936,44 +1141,49 @@ I32 flags;               /* See G_* flags in cop.h */
        op = &myop;
     XPUSHs(sv_2mortal(newSVpv(methname,0)));
     PUTBACK;
-    pp_method();
+    pp_method(ARGS);
     return perl_call_sv(*stack_sp--, flags);
 }
 
 /* May be called with any of a CV, a GV, or an SV containing the name. */
 I32
-perl_call_sv(sv, flags)
-SV* sv;
-I32 flags;             /* See G_* flags in cop.h */
+perl_call_sv(SV *sv, I32 flags)
+       
+                       /* See G_* flags in cop.h */
 {
+    dTHR;
     LOGOP myop;                /* fake syntax tree node */
     SV** sp = stack_sp;
-    I32 oldmark = TOPMARK;
+    I32 oldmark;
     I32 retval;
-    Sigjmp_buf oldtop;
     I32 oldscope;
     static CV *DBcv;
-    
+    bool oldcatch = CATCH_GET;
+    dJMPENV;
+    int ret;
+    OP* oldop = op;
+
     if (flags & G_DISCARD) {
        ENTER;
        SAVETMPS;
     }
 
-    SAVESPTR(op);
+    Zero(&myop, 1, LOGOP);
+    myop.op_next = Nullop;
+    if (!(flags & G_NOARGS))
+       myop.op_flags |= OPf_STACKED;
+    myop.op_flags |= ((flags & G_VOID) ? OPf_WANT_VOID :
+                     (flags & G_ARRAY) ? OPf_WANT_LIST :
+                     OPf_WANT_SCALAR);
+    SAVEOP();
     op = (OP*)&myop;
-    Zero(op, 1, LOGOP);
+
     EXTEND(stack_sp, 1);
     *++stack_sp = sv;
+    oldmark = TOPMARK;
     oldscope = scopestack_ix;
 
-    if (!(flags & G_NOARGS))
-       myop.op_flags = OPf_STACKED;
-    myop.op_next = Nullop;
-    myop.op_flags |= OPf_KNOW;
-    if (flags & G_ARRAY)
-      myop.op_flags |= OPf_LIST;
-
-    if (perldb && curstash != debstash
+    if (PERLDB_SUB && curstash != debstash
           /* Handle first BEGIN of -d. */
          && (DBcv || (DBcv = GvCV(DBsub)))
           /* Try harder, since this may have been a sighandler, thus
@@ -982,14 +1192,12 @@ I32 flags;               /* See G_* flags in cop.h */
        op->op_private |= OPpENTERSUB_DB;
 
     if (flags & G_EVAL) {
-       Copy(top_env, oldtop, 1, Sigjmp_buf);
-
        cLOGOP->op_other = op;
        markstack_ptr--;
        /* we're trying to emulate pp_entertry() here */
        {
-           register CONTEXT *cx;
-           I32 gimme = GIMME;
+           register PERL_CONTEXT *cx;
+           I32 gimme = GIMME_V;
            
            ENTER;
            SAVETMPS;
@@ -1003,12 +1211,12 @@ I32 flags;              /* See G_* flags in cop.h */
            if (flags & G_KEEPERR)
                in_eval |= 4;
            else
-               sv_setpv(GvSV(errgv),"");
+               sv_setpv(ERRSV,"");
        }
        markstack_ptr++;
 
-    restart:
-       switch (Sigsetjmp(top_env,1)) {
+       JMPENV_PUSH(ret);
+       switch (ret) {
        case 0:
            break;
        case 1:
@@ -1018,7 +1226,7 @@ I32 flags;                /* See G_* flags in cop.h */
            /* my_exit() was called */
            curstash = defstash;
            FREETMPS;
-           Copy(oldtop, top_env, 1, Sigjmp_buf);
+           JMPENV_POP;
            if (statusvalue)
                croak("Callback called exit");
            my_exit_jump();
@@ -1027,7 +1235,7 @@ I32 flags;                /* See G_* flags in cop.h */
            if (restartop) {
                op = restartop;
                restartop = 0;
-               goto restart;
+               break;
            }
            stack_sp = stack_base + oldmark;
            if (flags & G_ARRAY)
@@ -1039,14 +1247,16 @@ I32 flags;              /* See G_* flags in cop.h */
            goto cleanup;
        }
     }
+    else
+       CATCH_SET(TRUE);
 
     if (op == (OP*)&myop)
-       op = pp_entersub();
+       op = pp_entersub(ARGS);
     if (op)
        runops();
     retval = stack_sp - (stack_base + oldmark);
     if ((flags & G_EVAL) && !(flags & G_KEEPERR))
-       sv_setpv(GvSV(errgv),"");
+       sv_setpv(ERRSV,"");
 
   cleanup:
     if (flags & G_EVAL) {
@@ -1054,7 +1264,7 @@ I32 flags;                /* See G_* flags in cop.h */
            SV **newsp;
            PMOP *newpm;
            I32 gimme;
-           register CONTEXT *cx;
+           register PERL_CONTEXT *cx;
            I32 optype;
 
            POPBLOCK(cx,newpm);
@@ -1063,37 +1273,44 @@ I32 flags;              /* See G_* flags in cop.h */
            curpm = newpm;
            LEAVE;
        }
-       Copy(oldtop, top_env, 1, Sigjmp_buf);
+       JMPENV_POP;
     }
+    else
+       CATCH_SET(oldcatch);
+
     if (flags & G_DISCARD) {
        stack_sp = stack_base + oldmark;
        retval = 0;
        FREETMPS;
        LEAVE;
     }
+    op = oldop;
     return retval;
 }
 
 /* Eval a string. The G_EVAL flag is always assumed. */
 
 I32
-perl_eval_sv(sv, flags)
-SV* sv;
-I32 flags;             /* See G_* flags in cop.h */
+perl_eval_sv(SV *sv, I32 flags)
+       
+                       /* See G_* flags in cop.h */
 {
+    dTHR;
     UNOP myop;         /* fake syntax tree node */
     SV** sp = stack_sp;
     I32 oldmark = sp - stack_base;
     I32 retval;
-    Sigjmp_buf oldtop;
     I32 oldscope;
-    
+    dJMPENV;
+    int ret;
+    OP* oldop = op;
+
     if (flags & G_DISCARD) {
        ENTER;
        SAVETMPS;
     }
 
-    SAVESPTR(op);
+    SAVEOP();
     op = (OP*)&myop;
     Zero(op, 1, UNOP);
     EXTEND(stack_sp, 1);
@@ -1104,16 +1321,14 @@ I32 flags;              /* See G_* flags in cop.h */
        myop.op_flags = OPf_STACKED;
     myop.op_next = Nullop;
     myop.op_type = OP_ENTEREVAL;
-    myop.op_flags |= OPf_KNOW;
+    myop.op_flags |= ((flags & G_VOID) ? OPf_WANT_VOID :
+                     (flags & G_ARRAY) ? OPf_WANT_LIST :
+                     OPf_WANT_SCALAR);
     if (flags & G_KEEPERR)
        myop.op_flags |= OPf_SPECIAL;
-    if (flags & G_ARRAY)
-       myop.op_flags |= OPf_LIST;
 
-    Copy(top_env, oldtop, 1, Sigjmp_buf);
-
-restart:
-    switch (Sigsetjmp(top_env,1)) {
+    JMPENV_PUSH(ret);
+    switch (ret) {
     case 0:
        break;
     case 1:
@@ -1123,7 +1338,7 @@ restart:
        /* my_exit() was called */
        curstash = defstash;
        FREETMPS;
-       Copy(oldtop, top_env, 1, Sigjmp_buf);
+       JMPENV_POP;
        if (statusvalue)
            croak("Callback called exit");
        my_exit_jump();
@@ -1132,7 +1347,7 @@ restart:
        if (restartop) {
            op = restartop;
            restartop = 0;
-           goto restart;
+           break;
        }
        stack_sp = stack_base + oldmark;
        if (flags & G_ARRAY)
@@ -1145,29 +1360,49 @@ restart:
     }
 
     if (op == (OP*)&myop)
-       op = pp_entereval();
+       op = pp_entereval(ARGS);
     if (op)
        runops();
     retval = stack_sp - (stack_base + oldmark);
     if (!(flags & G_KEEPERR))
-       sv_setpv(GvSV(errgv),"");
+       sv_setpv(ERRSV,"");
 
   cleanup:
-    Copy(oldtop, top_env, 1, Sigjmp_buf);
+    JMPENV_POP;
     if (flags & G_DISCARD) {
        stack_sp = stack_base + oldmark;
        retval = 0;
        FREETMPS;
        LEAVE;
     }
+    op = oldop;
     return retval;
 }
 
+SV*
+perl_eval_pv(char *p, I32 croak_on_error)
+{
+    dSP;
+    SV* sv = newSVpv(p, 0);
+
+    PUSHMARK(sp);
+    perl_eval_sv(sv, G_SCALAR);
+    SvREFCNT_dec(sv);
+
+    SPAGAIN;
+    sv = POPs;
+    PUTBACK;
+
+    if (croak_on_error && SvTRUE(ERRSV))
+       croak(SvPVx(ERRSV, na));
+
+    return sv;
+}
+
 /* Require a module. */
 
 void
-perl_require_pv(pv)
-char* pv;
+perl_require_pv(char *pv)
 {
     SV* sv = sv_newmortal();
     sv_setpv(sv, "require '");
@@ -1177,10 +1412,7 @@ char* pv;
 }
 
 void
-magicname(sym,name,namlen)
-char *sym;
-char *name;
-I32 namlen;
+magicname(char *sym, char *name, I32 namlen)
 {
     register GV *gv;
 
@@ -1189,48 +1421,58 @@ I32 namlen;
 }
 
 static void
-usage(name)            /* XXX move this out into a module ? */
-char *name;
+usage(char *name)              /* XXX move this out into a module ? */
+           
 {
     /* This message really ought to be max 23 lines.
      * Removed -h because the user already knows that opton. Others? */
+
+    static char *usage[] = {
+"-0[octal]       specify record separator (\\0, if no argument)",
+"-a              autosplit mode with -n or -p (splits $_ into @F)",
+"-c              check syntax only (runs BEGIN and END blocks)",
+"-d[:debugger]   run scripts under debugger",
+"-D[number/list] set debugging flags (argument is a bit mask or flags)",
+"-e 'command'    one line of script. Several -e's allowed. Omit [programfile].",
+"-F/pattern/     split() pattern for autosplit (-a). The //'s are optional.",
+"-i[extension]   edit <> files in place (make backup if extension supplied)",
+"-Idirectory     specify @INC/#include directory (may be used more than once)",
+"-l[octal]       enable line ending processing, specifies line terminator",
+"-[mM][-]module.. executes `use/no module...' before executing your script.",
+"-n              assume 'while (<>) { ... }' loop around your script",
+"-p              assume loop like -n but print line also like sed",
+"-P              run script through C preprocessor before compilation",
+"-s              enable some switch parsing for switches after script name",
+"-S              look for the script using PATH environment variable",
+"-T              turn on tainting checks",
+"-u              dump core after parsing script",
+"-U              allow unsafe operations",
+"-v              print version number and patchlevel of perl",
+"-V[:variable]   print perl configuration information",
+"-w              TURN WARNINGS ON FOR COMPILATION OF YOUR SCRIPT. Recommended.",
+"-x[directory]   strip off text before #!perl line and perhaps cd to directory",
+"\n",
+NULL
+};
+    char **p = usage;
+
     printf("\nUsage: %s [switches] [--] [programfile] [arguments]", name);
-    printf("\n  -0[octal]       specify record separator (\\0, if no argument)");
-    printf("\n  -a              autosplit mode with -n or -p (splits $_ into @F)");
-    printf("\n  -c              check syntax only (runs BEGIN and END blocks)");
-    printf("\n  -d[:debugger]   run scripts under debugger");
-    printf("\n  -D[number/list] set debugging flags (argument is a bit mask or flags)");
-    printf("\n  -e 'command'    one line of script. Several -e's allowed. Omit [programfile].");
-    printf("\n  -F/pattern/     split() pattern for autosplit (-a). The //'s are optional.");
-    printf("\n  -i[extension]   edit <> files in place (make backup if extension supplied)");
-    printf("\n  -Idirectory     specify @INC/#include directory (may be used more then once)");
-    printf("\n  -l[octal]       enable line ending processing, specifies line teminator");
-    printf("\n  -[mM][-]module.. executes `use/no module...' before executing your script.");
-    printf("\n  -n              assume 'while (<>) { ... }' loop arround your script");
-    printf("\n  -p              assume loop like -n but print line also like sed");
-    printf("\n  -P              run script through C preprocessor before compilation");
-    printf("\n  -s              enable some switch parsing for switches after script name");
-    printf("\n  -S              look for the script using PATH environment variable");
-    printf("\n  -T              turn on tainting checks");
-    printf("\n  -u              dump core after parsing script");
-    printf("\n  -U              allow unsafe operations");
-    printf("\n  -v              print version number and patchlevel of perl");
-    printf("\n  -V[:variable]   print perl configuration information");
-    printf("\n  -w              TURN WARNINGS ON FOR COMPILATION OF YOUR SCRIPT.");
-    printf("\n  -x[directory]   strip off text before #!perl line and perhaps cd to directory\n");
+    while (*p)
+       printf("\n  %s", *p++);
 }
 
 /* This routine handles any switches that can be given during run */
 
 char *
-moreswitches(s)
-char *s;
+moreswitches(char *s)
 {
     I32 numlen;
     U32 rschar;
 
     switch (*s) {
     case '0':
+    {
+       dTHR;
        rschar = scan_oct(s, 4, &numlen);
        SvREFCNT_dec(nrs);
        if (rschar & ~((U8)~0))
@@ -1242,6 +1484,7 @@ char *s;
            nrs = newSVpv(&ch, 1);
        }
        return s + numlen;
+    }
     case 'F':
        minus_F = TRUE;
        splitstr = savepv(s + 1);
@@ -1259,12 +1502,11 @@ char *s;
        forbid_setid("-d");
        s++;
        if (*s == ':' || *s == '=')  {
-           sprintf(buf, "use Devel::%s;", ++s);
+           my_setenv("PERL5DB", form("use Devel::%s;", ++s));
            s += strlen(s);
-           my_setenv("PERL5DB",buf);
        }
        if (!perldb) {
-           perldb = TRUE;
+           perldb = PERLDB_ALL;
            init_debugger();
        }
        return s;
@@ -1298,22 +1540,25 @@ char *s;
        inplace = savepv(s+1);
        /*SUPPRESS 530*/
        for (s = inplace; *s && !isSPACE(*s); s++) ;
-       *s = '\0';
-       break;
-    case 'I':
+       if (*s)
+           *s++ = '\0';
+       return s;
+    case 'I':  /* -I handled both here and in parse_perl() */
        forbid_setid("-I");
-       if (*++s) {
+       ++s;
+       while (*s && isSPACE(*s))
+           ++s;
+       if (*s) {
            char *e, *p;
            for (e = s; *e && !isSPACE(*e); e++) ;
            p = savepvn(s, e-s);
            incpush(p, TRUE);
            Safefree(p);
-           if (*e)
-               return e;
+           s = e;
        }
        else
            croak("No space allowed after -I");
-       break;
+       return s;
     case 'l':
        minus_l = TRUE;
        s++;
@@ -1326,6 +1571,7 @@ char *s;
            s += numlen;
        }
        else {
+           dTHR;
            if (RsPARA(nrs)) {
                ors = "\n\n";
                orslen = 2;
@@ -1342,30 +1588,31 @@ char *s;
        forbid_setid("-m");     /* XXX ? */
        if (*++s) {
            char *start;
+           SV *sv;
            char *use = "use ";
            /* -M-foo == 'no foo'       */
            if (*s == '-') { use = "no "; ++s; }
-           Sv = newSVpv(use,0);
+           sv = newSVpv(use,0);
            start = s;
            /* We allow -M'Module qw(Foo Bar)'  */
            while(isALNUM(*s) || *s==':') ++s;
            if (*s != '=') {
-               sv_catpv(Sv, start);
+               sv_catpv(sv, start);
                if (*(start-1) == 'm') {
                    if (*s != '\0')
                        croak("Can't use '%c' after -mname", *s);
-                   sv_catpv( Sv, " ()");
+                   sv_catpv( sv, " ()");
                }
            } else {
-               sv_catpvn(Sv, start, s-start);
-               sv_catpv(Sv, " split(/,/,q{");
-               sv_catpv(Sv, ++s);
-               sv_catpv(Sv,    "})");
+               sv_catpvn(sv, start, s-start);
+               sv_catpv(sv, " split(/,/,q{");
+               sv_catpv(sv, ++s);
+               sv_catpv(sv,    "})");
            }
            s += strlen(s);
            if (preambleav == NULL)
                preambleav = newAV();
-           av_push(preambleav, Sv);
+           av_push(preambleav, sv);
        }
        else
            croak("No space allowed after -%c", *(s-1));
@@ -1385,7 +1632,7 @@ char *s;
        return s;
     case 'T':
        if (!tainting)
-           croak("Too late for \"-T\" option (try putting it first)");
+           croak("Too late for \"-T\" option");
        s++;
        return s;
     case 'u':
@@ -1398,21 +1645,28 @@ char *s;
        return s;
     case 'v':
 #if defined(SUBVERSION) && SUBVERSION > 0
-       printf("\nThis is perl, version 5.%03d_%02d", PATCHLEVEL, SUBVERSION);
+       printf("\nThis is perl, version 5.%03d_%02d built for %s",
+           PATCHLEVEL, SUBVERSION, ARCHNAME);
 #else
-       printf("\nThis is perl, version %s",patchlevel);
+       printf("\nThis is perl, version %s built for %s",
+               patchlevel, ARCHNAME);
+#endif
+#if defined(LOCAL_PATCH_COUNT)
+       if (LOCAL_PATCH_COUNT > 0)
+           printf("\n(with %d registered patch%s, see perl -V for more detail)",
+               LOCAL_PATCH_COUNT, (LOCAL_PATCH_COUNT!=1) ? "es" : "");
 #endif
 
        printf("\n\nCopyright 1987-1997, Larry Wall\n");
 #ifdef MSDOS
-       printf("\n\nMS-DOS port Copyright (c) 1989, 1990, Diomidis Spinellis\n");
+       printf("\nMS-DOS port Copyright (c) 1989, 1990, Diomidis Spinellis\n");
 #endif
 #ifdef DJGPP
        printf("djgpp v2 port (jpl5003c) by Hirofumi Watanabe, 1996\n");
 #endif
 #ifdef OS2
        printf("\n\nOS/2 port Copyright (c) 1990, 1991, Raymond Chen, Kai Uwe Rommel\n"
-           "Version 5 port Copyright (c) 1994-1996, Andreas Kaiser, Ilya Zakharevich\n");
+           "Version 5 port Copyright (c) 1994-1997, Andreas Kaiser, Ilya Zakharevich\n");
 #endif
 #ifdef atarist
        printf("atariST series port, ++jrb  bammi@cadence.com\n");
@@ -1435,13 +1689,13 @@ GNU General Public License, which may be found in the Perl 5.0 source kit.\n\n")
     case '\n':
     case '\t':
        break;
-    case 'P':
-       if (preprocess)
-           return s+1;
 #ifdef ALTERNATE_SHEBANG
     case 'S':                  /* OS/2 needs -S on "extproc" line. */
        break;
 #endif
+    case 'P':
+       if (preprocess)
+           return s+1;
        /* FALL THROUGH */
     default:
        croak("Can't emulate -%.1s on #! line",s);
@@ -1454,32 +1708,38 @@ GNU General Public License, which may be found in the Perl 5.0 source kit.\n\n")
 /* unexec() can be found in the Gnu emacs distribution */
 
 void
-my_unexec()
+my_unexec(void)
 {
 #ifdef UNEXEC
+    SV*    prog;
+    SV*    file;
     int    status;
     extern int etext;
 
-    sprintf (buf, "%s.perldump", origfilename);
-    sprintf (tokenbuf, "%s/perl", BIN);
+    prog = newSVpv(BIN_EXP);
+    sv_catpv(prog, "/perl");
+    file = newSVpv(origfilename);
+    sv_catpv(file, ".perldump");
 
-    status = unexec(buf, tokenbuf, &etext, sbrk(0), 0);
+    status = unexec(SvPVX(file), SvPVX(prog), &etext, sbrk(0), 0);
     if (status)
-       PerlIO_printf(PerlIO_stderr(), "unexec of %s into %s failed!\n", tokenbuf, buf);
+       PerlIO_printf(PerlIO_stderr(), "unexec of %s into %s failed!\n",
+                     SvPVX(prog), SvPVX(file));
     exit(status);
 #else
 #  ifdef VMS
 #    include <lib$routines.h>
      lib$signal(SS$_DEBUG);  /* ssdef.h #included from vmsish.h */
-#else
+#  else
     ABORT();           /* for use with undump */
-#endif
+#  endif
 #endif
 }
 
 static void
-init_main_stash()
+init_main_stash(void)
 {
+    dTHR;
     GV *gv;
 
     /* Note that strtab is a rather special HV.  Assumptions are made
@@ -1502,10 +1762,13 @@ init_main_stash()
     defgv = gv_fetchpv("_",TRUE, SVt_PVAV);
     errgv = gv_HVadd(gv_fetchpv("@", TRUE, SVt_PV));
     GvMULTI_on(errgv);
-    sv_setpvn(GvSV(errgv), "", 0);
+    (void)form("%240s","");    /* Preallocate temp - for immediate signals. */
+    sv_grow(ERRSV, 240);       /* Preallocate - for immediate signals. */
+    sv_setpvn(ERRSV, "", 0);
     curstash = defstash;
     compiling.cop_stash = defstash;
     debstash = GvHV(gv_fetchpv("DB::", GV_ADDMULTI, SVt_PVHV));
+    globalstash = GvHV(gv_fetchpv("CORE::GLOBAL::", GV_ADDMULTI, SVt_PVHV));
     /* We must init $/ before switches are processed. */
     sv_setpvn(GvSV(gv_fetchpv("/", TRUE, SVt_PV)), "\n", 1);
 }
@@ -1521,62 +1784,148 @@ bool dosearch;
 SV *sv;
 #endif
 {
+    dTHR;
     char *xfound = Nullch;
     char *xfailed = Nullch;
     register char *s;
     I32 len;
     int retval;
 #if defined(DOSISH) && !defined(OS2) && !defined(atarist)
-#define SEARCH_EXTS ".bat", ".cmd", NULL
+#  define SEARCH_EXTS ".bat", ".cmd", NULL
+#  define MAX_EXT_LEN 4
+#endif
+#ifdef OS2
+#  define SEARCH_EXTS ".cmd", ".btm", ".bat", ".pl", NULL
+#  define MAX_EXT_LEN 4
 #endif
 #ifdef VMS
 #  define SEARCH_EXTS ".pl", ".com", NULL
+#  define MAX_EXT_LEN 4
 #endif
     /* additional extensions to try in each dir if scriptname not found */
 #ifdef SEARCH_EXTS
     char *ext[] = { SEARCH_EXTS };
-    int extidx = (strchr(scriptname,'.')) ? -1 : 0; /* has ext already */
+    int extidx = 0, i = 0;
+    char *curext = Nullch;
+#else
+#  define MAX_EXT_LEN 0
 #endif
 
+    /*
+     * If dosearch is true and if scriptname does not contain path
+     * delimiters, search the PATH for scriptname.
+     *
+     * If SEARCH_EXTS is also defined, will look for each
+     * scriptname{SEARCH_EXTS} whenever scriptname is not found
+     * while searching the PATH.
+     *
+     * Assuming SEARCH_EXTS is C<".foo",".bar",NULL>, PATH search
+     * proceeds as follows:
+     *   If DOSISH:
+     *     + look for ./scriptname{,.foo,.bar}
+     *     + search the PATH for scriptname{,.foo,.bar}
+     *
+     *   If !DOSISH:
+     *     + look *only* in the PATH for scriptname{,.foo,.bar} (note
+     *       this will not look in '.' if it's not in the PATH)
+     */
+
 #ifdef VMS
     if (dosearch) {
        int hasdir, idx = 0, deftypes = 1;
+       bool seen_dot = 1;
 
        hasdir = (strpbrk(scriptname,":[</") != Nullch) ;
        /* The first time through, just add SEARCH_EXTS to whatever we
         * already have, so we can check for default file types. */
-       while (deftypes || (!hasdir && my_trnlnm("DCL$PATH",tokenbuf,idx++)) ) {
-           if (deftypes) { deftypes = 0; *tokenbuf = '\0'; }
-           strcat(tokenbuf,scriptname);
+       while (deftypes ||
+              (!hasdir && my_trnlnm("DCL$PATH",tokenbuf,idx++)) )
+       {
+           if (deftypes) {
+               deftypes = 0;
+               *tokenbuf = '\0';
+           }
+           if ((strlen(tokenbuf) + strlen(scriptname)
+                + MAX_EXT_LEN) >= sizeof tokenbuf)
+               continue;       /* don't search dir with too-long name */
+           strcat(tokenbuf, scriptname);
 #else  /* !VMS */
-    if (dosearch && !strchr(scriptname, '/') && (s = getenv("PATH"))) {
 
-       bufend = s + strlen(s);
-       while (*s) {
-#ifndef DOSISH
-           s = cpytill(tokenbuf,s,bufend,':',&len);
-#else
-#ifdef atarist
-           for (len = 0; *s && *s != ',' && *s != ';'; tokenbuf[len++] = *s++);
-           tokenbuf[len] = '\0';
-#else
-           for (len = 0; *s && *s != ';'; tokenbuf[len++] = *s++);
-           tokenbuf[len] = '\0';
+#ifdef DOSISH
+    if (strEQ(scriptname, "-"))
+       dosearch = 0;
+    if (dosearch) {            /* Look in '.' first. */
+       char *cur = scriptname;
+#ifdef SEARCH_EXTS
+       if ((curext = strrchr(scriptname,'.'))) /* possible current ext */
+           while (ext[i])
+               if (strEQ(ext[i++],curext)) {
+                   extidx = -1;                /* already has an ext */
+                   break;
+               }
+       do {
 #endif
+           DEBUG_p(PerlIO_printf(Perl_debug_log,
+                                 "Looking for %s\n",cur));
+           if (Stat(cur,&statbuf) >= 0) {
+               dosearch = 0;
+               scriptname = cur;
+#ifdef SEARCH_EXTS
+               break;
 #endif
-           if (*s)
-               s++;
-#ifndef DOSISH
-           if (len && tokenbuf[len-1] != '/')
-#else
-#ifdef atarist
-           if (len && ((tokenbuf[len-1] != '\\') && (tokenbuf[len-1] != '/')))
-#else
-           if (len && tokenbuf[len-1] != '\\')
+           }
+#ifdef SEARCH_EXTS
+           if (cur == scriptname) {
+               len = strlen(scriptname);
+               if (len+MAX_EXT_LEN+1 >= sizeof(tokenbuf))
+                   break;
+               cur = strcpy(tokenbuf, scriptname);
+           }
+       } while (extidx >= 0 && ext[extidx]     /* try an extension? */
+                && strcpy(tokenbuf+len, ext[extidx++]));
+#endif
+    }
 #endif
+
+    if (dosearch && !strchr(scriptname, '/')
+#ifdef DOSISH
+                && !strchr(scriptname, '\\')
 #endif
-               (void)strcat(tokenbuf+len,"/");
-           (void)strcat(tokenbuf+len,scriptname);
+                && (s = getenv("PATH"))) {
+       bool seen_dot = 0;
+       
+       bufend = s + strlen(s);
+       while (s < bufend) {
+#if defined(atarist) || defined(DOSISH)
+           for (len = 0; *s
+#  ifdef atarist
+                   && *s != ','
+#  endif
+                   && *s != ';'; len++, s++) {
+               if (len < sizeof tokenbuf)
+                   tokenbuf[len] = *s;
+           }
+           if (len < sizeof tokenbuf)
+               tokenbuf[len] = '\0';
+#else  /* ! (atarist || DOSISH) */
+           s = delimcpy(tokenbuf, tokenbuf + sizeof tokenbuf, s, bufend,
+                       ':',
+                       &len);
+#endif /* ! (atarist || DOSISH) */
+           if (s < bufend)
+               s++;
+           if (len + 1 + strlen(scriptname) + MAX_EXT_LEN >= sizeof tokenbuf)
+               continue;       /* don't search dir with too-long name */
+           if (len
+#if defined(atarist) || defined(DOSISH)
+               && tokenbuf[len - 1] != '/'
+               && tokenbuf[len - 1] != '\\'
+#endif
+              )
+               tokenbuf[len++] = '/';
+           if (len == 2 && tokenbuf[0] == '.')
+               seen_dot = 1;
+           (void)strcpy(tokenbuf + len, scriptname);
 #endif  /* !VMS */
 
 #ifdef SEARCH_EXTS
@@ -1596,15 +1945,28 @@ SV *sv;
            if (retval < 0)
                continue;
            if (S_ISREG(statbuf.st_mode)
-            && cando(S_IRUSR,TRUE,&statbuf) && cando(S_IXUSR,TRUE,&statbuf)) {
+               && cando(S_IRUSR,TRUE,&statbuf)
+#ifndef DOSISH
+               && cando(S_IXUSR,TRUE,&statbuf)
+#endif
+               )
+           {
                xfound = tokenbuf;              /* bingo! */
                break;
            }
            if (!xfailed)
                xfailed = savepv(tokenbuf);
        }
+#ifndef DOSISH
+       if (!xfound && !seen_dot && !xfailed && (Stat(scriptname,&statbuf) < 0))
+#endif
+           seen_dot = 1;                       /* Disable message. */
        if (!xfound)
-           croak("Can't execute %s", xfailed ? xfailed : scriptname );
+           croak("Can't %s %s%s%s",
+                 (xfailed ? "execute" : "find"),
+                 (xfailed ? xfailed : scriptname),
+                 (xfailed ? "" : " on PATH"),
+                 (xfailed || seen_dot) ? "" : ", '.' not in PATH");
        if (xfailed)
            Safefree(xfailed);
        scriptname = xfound;
@@ -1632,16 +1994,19 @@ SV *sv;
 #endif
     }
     else if (preprocess) {
-       char *cpp = CPPSTDIN;
+       char *cpp_cfg = CPPSTDIN;
+       SV *cpp = NEWSV(0,0);
+       SV *cmd = NEWSV(0,0);
+
+       if (strEQ(cpp_cfg, "cppstdin"))
+           sv_catpvf(cpp, "%s/", BIN_EXP);
+       sv_catpv(cpp, cpp_cfg);
 
-       if (strEQ(cpp,"cppstdin"))
-           sprintf(tokenbuf, "%s/%s", SCRIPTDIR, cpp);
-       else
-           sprintf(tokenbuf, "%s", cpp);
        sv_catpv(sv,"-I");
        sv_catpv(sv,PRIVLIB_EXP);
+
 #ifdef MSDOS
-       (void)sprintf(buf, "\
+       sv_setpvf(cmd, "\
 sed %s -e \"/^[^#]/b\" \
  -e \"/^#[     ]*include[      ]/b\" \
  -e \"/^#[     ]*define[       ]/b\" \
@@ -1653,10 +2018,10 @@ sed %s -e \"/^[^#]/b\" \
  -e \"/^#[     ]*undef[        ]/b\" \
  -e \"/^#[     ]*endif/b\" \
  -e \"s/^#.*//\" \
- %s | %s -C %s %s",
+ %s | %_ -C %_ %s",
          (doextract ? "-e \"1,/^#/d\n\"" : ""),
 #else
-       (void)sprintf(buf, "\
+       sv_setpvf(cmd, "\
 %s %s -e '/^[^#]/b' \
  -e '/^#[      ]*include[      ]/b' \
  -e '/^#[      ]*define[       ]/b' \
@@ -1668,7 +2033,7 @@ sed %s -e \"/^[^#]/b\" \
  -e '/^#[      ]*undef[        ]/b' \
  -e '/^#[      ]*endif/b' \
  -e 's/^[      ]*#.*//' \
- %s | %s -C %s %s",
+ %s | %_ -C %_ %s",
 #ifdef LOC_SED
          LOC_SED,
 #else
@@ -1676,7 +2041,7 @@ sed %s -e \"/^[^#]/b\" \
 #endif
          (doextract ? "-e '1,/^#/d\n'" : ""),
 #endif
-         scriptname, tokenbuf, SvPV(sv, na), CPPMINUS);
+         scriptname, cpp, sv, CPPMINUS);
        doextract = FALSE;
 #ifdef IAMSUID                         /* actually, this is caught earlier */
        if (euid != uid && !euid) {     /* if running suidperl */
@@ -1697,7 +2062,9 @@ sed %s -e \"/^[^#]/b\" \
                croak("Can't do seteuid!\n");
        }
 #endif /* IAMSUID */
-       rsfp = my_popen(buf,"r");
+       rsfp = my_popen(SvPVX(cmd), "r");
+       SvREFCNT_dec(cmd);
+       SvREFCNT_dec(cpp);
     }
     else if (!*scriptname) {
        forbid_setid("program input from stdin");
@@ -1718,8 +2085,8 @@ sed %s -e \"/^[^#]/b\" \
 #ifndef IAMSUID                /* in case script is not readable before setuid */
        if (euid && Stat(SvPVX(GvSV(curcop->cop_filegv)),&statbuf) >= 0 &&
          statbuf.st_mode & (S_ISUID|S_ISGID)) {
-           (void)sprintf(buf, "%s/sperl%s", BIN, patchlevel);
-           execv(buf, origargv);       /* try again */
+           /* try again */
+           execv(form("%s/sperl%s", BIN_EXP, patchlevel), origargv);
            croak("Can't do setuid\n");
        }
 #endif
@@ -1730,9 +2097,7 @@ sed %s -e \"/^[^#]/b\" \
 }
 
 static void
-validate_suid(validarg, scriptname)
-char *validarg;
-char *scriptname;
+validate_suid(char *validarg, char *scriptname)
 {
     int which;
 
@@ -1757,6 +2122,7 @@ char *scriptname;
      */
 
 #ifdef DOSUID
+    dTHR;
     char *s, *s2;
 
     if (Fstat(PerlIO_fileno(rsfp),&statbuf) < 0)       /* normal stat is insecure */
@@ -1866,8 +2232,8 @@ FIX YOUR KERNEL, PUT A C WRAPPER AROUND THIS SCRIPT, OR USE -u AND UNDUMP!\n");
        if (euid) {     /* oops, we're not the setuid root perl */
            (void)PerlIO_close(rsfp);
 #ifndef IAMSUID
-           (void)sprintf(buf, "%s/sperl%s", BIN, patchlevel);
-           execv(buf, origargv);       /* try again */
+           /* try again */
+           execv(form("%s/sperl%s", BIN_EXP, patchlevel), origargv);
 #endif
            croak("Can't do setuid\n");
        }
@@ -1944,20 +2310,18 @@ FIX YOUR KERNEL, PUT A C WRAPPER AROUND THIS SCRIPT, OR USE -u AND UNDUMP!\n");
     for (which = 1; origargv[which] && origargv[which] != scriptname; which++) ;
     if (!origargv[which])
        croak("Permission denied");
-    (void)sprintf(buf, "/dev/fd/%d/%.127s", PerlIO_fileno(rsfp), origargv[which]);
-    origargv[which] = buf;
-
+    origargv[which] = savepv(form("/dev/fd/%d/%s",
+                                 PerlIO_fileno(rsfp), origargv[which]));
 #if defined(HAS_FCNTL) && defined(F_SETFD)
     fcntl(PerlIO_fileno(rsfp),F_SETFD,0);      /* ensure no close-on-exec */
 #endif
-
-    (void)sprintf(tokenbuf, "%s/perl%s", BIN, patchlevel);
-    execv(tokenbuf, origargv); /* try again */
+    execv(form("%s/perl%s", BIN_EXP, patchlevel), origargv);   /* try again */
     croak("Can't do setuid\n");
 #endif /* IAMSUID */
 #else /* !DOSUID */
     if (euid != uid || egid != gid) {  /* (suidperl doesn't exist, in fact) */
 #ifndef SETUID_SCRIPTS_ARE_SECURE_NOW
+       dTHR;
        Fstat(PerlIO_fileno(rsfp),&statbuf);    /* may be either wrapped or real suid */
        if ((euid != uid && euid == statbuf.st_uid && statbuf.st_mode & S_ISUID)
            ||
@@ -1973,7 +2337,7 @@ FIX YOUR KERNEL, PUT A C WRAPPER AROUND THIS SCRIPT, OR USE -u AND UNDUMP!\n");
 }
 
 static void
-find_beginning()
+find_beginning(void)
 {
     register char *s, *s2;
 
@@ -2002,7 +2366,7 @@ find_beginning()
 }
 
 static void
-init_ids()
+init_ids(void)
 {
     uid = (int)getuid();
     euid = (int)geteuid();
@@ -2016,8 +2380,7 @@ init_ids()
 }
 
 static void
-forbid_setid(s)
-char *s;
+forbid_setid(char *s)
 {
     if (euid != uid)
         croak("No %s allowed while running setuid", s);
@@ -2026,8 +2389,9 @@ char *s;
 }
 
 static void
-init_debugger()
+init_debugger(void)
 {
+    dTHR;
     curstash = debstash;
     dbargs = GvAV(gv_AVadd((gv_fetchpv("args", GV_ADDMULTI, SVt_PVAV))));
     AvREAL_off(dbargs);
@@ -2043,8 +2407,8 @@ init_debugger()
     curstash = defstash;
 }
 
-static void
-init_stacks()
+void
+init_stacks(ARGSproto)
 {
     curstack = newAV();
     mainstack = curstack;              /* remember in case we switch stacks */
@@ -2055,19 +2419,15 @@ init_stacks()
     stack_sp = stack_base;
     stack_max = stack_base + 127;
 
-    cxstack_max = 8192 / sizeof(CONTEXT) - 2;  /* Use most of 8K. */
-    New(50,cxstack,cxstack_max + 1,CONTEXT);
+    cxstack_max = 8192 / sizeof(PERL_CONTEXT) - 2;     /* Use most of 8K. */
+    New(50,cxstack,cxstack_max + 1,PERL_CONTEXT);
     cxstack_ix = -1;
 
     New(50,tmps_stack,128,SV*);
+    tmps_floor = -1;
     tmps_ix = -1;
     tmps_max = 128;
 
-    DEBUG( {
-       New(51,debname,128,char);
-       New(52,debdelim,128,char);
-    } )
-
     /*
      * The following stacks almost certainly should be per-interpreter,
      * but for now they're not.  XXX
@@ -2107,8 +2467,9 @@ init_stacks()
 }
 
 static void
-nuke_stacks()
+nuke_stacks(void)
 {
+    dTHR;
     Safefree(cxstack);
     Safefree(tmps_stack);
     DEBUG( {
@@ -2120,21 +2481,27 @@ nuke_stacks()
 static PerlIO *tmpfp;  /* moved outside init_lexer() because of UNICOS bug */
 
 static void
-init_lexer()
+init_lexer(void)
 {
     tmpfp = rsfp;
+    rsfp = Nullfp;
     lex_start(linestr);
     rsfp = tmpfp;
     subname = newSVpv("main",4);
 }
 
 static void
-init_predump_symbols()
+init_predump_symbols(void)
 {
+    dTHR;
     GV *tmpgv;
     GV *othergv;
 
+#ifdef USE_THREADS
+    sv_setpvn(*av_fetch(thr->threadsv,find_threadsv("\""),FALSE)," ", 1);
+#else
     sv_setpvn(GvSV(gv_fetchpv("\"", TRUE, SVt_PV)), " ", 1);
+#endif /* USE_THREADS */
 
     stdingv = gv_fetchpv("STDIN",TRUE, SVt_PVIO);
     GvMULTI_on(stdingv);
@@ -2165,11 +2532,9 @@ init_predump_symbols()
 }
 
 static void
-init_postdump_symbols(argc,argv,env)
-register int argc;
-register char **argv;
-register char **env;
+init_postdump_symbols(register int argc, register char **argv, register char **env)
 {
+    dTHR;
     char *s;
     SV *sv;
     GV* tmpgv;
@@ -2218,7 +2583,7 @@ register char **env;
        HV *hv;
        GvMULTI_on(envgv);
        hv = GvHVn(envgv);
-       hv_clear(hv);
+       hv_magic(hv, envgv, 'E');
 #ifndef VMS  /* VMS doesn't have environ array */
        /* Note that if the supplied env parameter is actually a copy
           of the global environ then it may now point to free'd memory
@@ -2227,32 +2592,35 @@ register char **env;
        */
        if (!env)
            env = environ;
-       if (env != environ) {
+       if (env != environ)
            environ[0] = Nullch;
-           hv_magic(hv, envgv, 'E');
-       }
        for (; *env; env++) {
            if (!(s = strchr(*env,'=')))
                continue;
            *s++ = '\0';
+#ifdef WIN32
+           (void)strupr(*env);
+#endif
            sv = newSVpv(s--,0);
-           sv_magic(sv, sv, 'e', *env, s - *env);
            (void)hv_store(hv, *env, s - *env, sv, 0);
            *s = '=';
+#if defined(__BORLANDC__) && defined(USE_WIN32_RTL_ENV)
+           /* Sins of the RTL. See note in my_setenv(). */
+           (void)putenv(savepv(*env));
+#endif
        }
 #endif
 #ifdef DYNAMIC_ENV_FETCH
        HvNAME(hv) = savepv(ENV_HV_NAME);
 #endif
-       hv_magic(hv, envgv, 'E');
     }
     TAINT_NOT;
     if (tmpgv = gv_fetchpv("$",TRUE, SVt_PV))
-       sv_setiv(GvSV(tmpgv),(I32)getpid());
+       sv_setiv(GvSV(tmpgv), (IV)getpid());
 }
 
 static void
-init_perllib()
+init_perllib(void)
 {
     char *s;
     if (!tainting) {
@@ -2276,7 +2644,7 @@ init_perllib()
 #endif /* VMS */
     }
 
-/* Use the ~-expanded versions of APPLIB (undocumented),
+/* Use the ~-expanded versions of APPLLIB (undocumented),
     ARCHLIB PRIVLIB SITEARCH SITELIB and OLDARCHLIB
 */
 #ifdef APPLLIB_EXP
@@ -2319,9 +2687,7 @@ init_perllib()
 #endif 
 
 static void
-incpush(p, addsubdirs)
-char *p;
-int addsubdirs;
+incpush(char *p, int addsubdirs)
 {
     SV *subdir = Nullsv;
     static char *archpat_auto;
@@ -2336,6 +2702,11 @@ int addsubdirs;
                          + sizeof("//auto"));
            New(55, archpat_auto, len, char);
            sprintf(archpat_auto, "/%s/%s/auto", ARCHNAME, patchlevel);
+#ifdef VMS
+       for (len = sizeof(ARCHNAME) + 2;
+            archpat_auto[len] != '\0' && archpat_auto[len] != '/'; len++)
+               if (archpat_auto[len] == '.') archpat_auto[len] = '_';
+#endif
        }
     }
 
@@ -2367,7 +2738,20 @@ int addsubdirs;
         */
        if (addsubdirs) {
            struct stat tmpstatbuf;
+#ifdef VMS
+           char *unix;
+           STRLEN len;
 
+           if ((unix = tounixspec_ts(SvPV(libdir,na),Nullch)) != Nullch) {
+               len = strlen(unix);
+               while (unix[len-1] == '/') len--;  /* Cosmetic */
+               sv_usepvn(libdir,unix,len);
+           }
+           else
+               PerlIO_printf(PerlIO_stderr(),
+                             "Failed to unixify @INC element \"%s\"\n",
+                             SvPV(libdir,na));
+#endif
            /* .../archname/version if -d .../archname/version/auto */
            sv_setsv(subdir, libdir);
            sv_catpv(subdir, archpat_auto);
@@ -2392,35 +2776,100 @@ int addsubdirs;
     SvREFCNT_dec(subdir);
 }
 
+#ifdef USE_THREADS
+static struct perl_thread *
+init_main_thread()
+{
+    struct perl_thread *thr;
+    XPV *xpv;
+
+    Newz(53, thr, 1, struct perl_thread);
+    curcop = &compiling;
+    thr->cvcache = newHV();
+    thr->threadsv = newAV();
+    thr->specific = newAV();
+    thr->errhv = newHV();
+    thr->flags = THRf_R_JOINABLE;
+    MUTEX_INIT(&thr->mutex);
+    /* Handcraft thrsv similarly to mess_sv */
+    New(53, thrsv, 1, SV);
+    Newz(53, xpv, 1, XPV);
+    SvFLAGS(thrsv) = SVt_PV;
+    SvANY(thrsv) = (void*)xpv;
+    SvREFCNT(thrsv) = 1 << 30; /* practically infinite */
+    SvPVX(thrsv) = (char*)thr;
+    SvCUR_set(thrsv, sizeof(thr));
+    SvLEN_set(thrsv, sizeof(thr));
+    *SvEND(thrsv) = '\0';      /* in the trailing_nul field */
+    thr->oursv = thrsv;
+    curcop = &compiling;
+    chopset = " \n-";
+
+    MUTEX_LOCK(&threads_mutex);
+    nthreads++;
+    thr->tid = 0;
+    thr->next = thr;
+    thr->prev = thr;
+    MUTEX_UNLOCK(&threads_mutex);
+
+#ifdef HAVE_THREAD_INTERN
+    init_thread_intern(thr);
+#endif
+
+#ifdef SET_THREAD_SELF
+    SET_THREAD_SELF(thr);
+#else
+    thr->self = pthread_self();
+#endif /* SET_THREAD_SELF */
+    SET_THR(thr);
+
+    /*
+     * These must come after the SET_THR because sv_setpvn does
+     * SvTAINT and the taint fields require dTHR.
+     */
+    toptarget = NEWSV(0,0);
+    sv_upgrade(toptarget, SVt_PVFM);
+    sv_setpvn(toptarget, "", 0);
+    bodytarget = NEWSV(0,0);
+    sv_upgrade(bodytarget, SVt_PVFM);
+    sv_setpvn(bodytarget, "", 0);
+    formtarget = bodytarget;
+    thr->errsv = newSVpv("", 0);
+    return thr;
+}
+#endif /* USE_THREADS */
+
 void
-calllist(list)
-AV* list;
+call_list(I32 oldscope, AV *list)
 {
-    Sigjmp_buf oldtop;
-    STRLEN len;
+    dTHR;
     line_t oldline = curcop->cop_line;
-
-    Copy(top_env, oldtop, 1, Sigjmp_buf);
+    STRLEN len;
+    dJMPENV;
+    int ret;
 
     while (AvFILL(list) >= 0) {
        CV *cv = (CV*)av_shift(list);
 
        SAVEFREESV(cv);
 
-       switch (Sigsetjmp(top_env,1)) {
+       JMPENV_PUSH(ret);
+       switch (ret) {
        case 0: {
-               SV* atsv = GvSV(errgv);
+               SV* atsv = ERRSV;
                PUSHMARK(stack_sp);
                perl_call_sv((SV*)cv, G_EVAL|G_DISCARD);
                (void)SvPV(atsv, len);
                if (len) {
-                   Copy(oldtop, top_env, 1, Sigjmp_buf);
+                   JMPENV_POP;
                    curcop = &compiling;
                    curcop->cop_line = oldline;
                    if (list == beginav)
                        sv_catpv(atsv, "BEGIN failed--compilation aborted");
                    else
                        sv_catpv(atsv, "END failed--cleanup aborted");
+                   while (scopestack_ix > oldscope)
+                       LEAVE;
                    croak("%s", SvPVX(atsv));
                }
            }
@@ -2430,11 +2879,13 @@ AV* list;
            /* FALL THROUGH */
        case 2:
            /* my_exit() was called */
+           while (scopestack_ix > oldscope)
+               LEAVE;
+           FREETMPS;
            curstash = defstash;
            if (endav)
-               calllist(endav);
-           FREETMPS;
-           Copy(oldtop, top_env, 1, Sigjmp_buf);
+               call_list(oldscope, endav);
+           JMPENV_POP;
            curcop = &compiling;
            curcop->cop_line = oldline;
            if (statusvalue) {
@@ -2451,20 +2902,24 @@ AV* list;
                FREETMPS;
                break;
            }
-           Copy(oldtop, top_env, 1, Sigjmp_buf);
+           JMPENV_POP;
            curcop = &compiling;
            curcop->cop_line = oldline;
-           Siglongjmp(top_env, 3);
+           JMPENV_JUMP(3);
        }
+       JMPENV_POP;
     }
-
-    Copy(oldtop, top_env, 1, Sigjmp_buf);
 }
 
 void
-my_exit(status)
-U32 status;
+my_exit(U32 status)
 {
+    dTHR;
+
+#ifdef USE_THREADS
+    DEBUG_L(PerlIO_printf(Perl_debug_log, "my_exit: thread %p, status %lu\n",
+                         thr, (unsigned long) status));
+#endif /* USE_THREADS */
     switch (status) {
     case 0:
        STATUS_ALL_SUCCESS;
@@ -2480,7 +2935,7 @@ U32 status;
 }
 
 void
-my_failure_exit()
+my_failure_exit(void)
 {
 #ifdef VMS
     if (vaxc$errno & 1) {
@@ -2503,9 +2958,10 @@ my_failure_exit()
 }
 
 static void
-my_exit_jump()
+my_exit_jump(void)
 {
-    register CONTEXT *cx;
+    dTHR;
+    register PERL_CONTEXT *cx;
     I32 gimme;
     SV **newsp;
 
@@ -2526,5 +2982,7 @@ my_exit_jump()
        LEAVE;
     }
 
-    Siglongjmp(top_env, 2);
+    JMPENV_JUMP(2);
 }
+
+