This is a live mirror of the Perl 5 development currently hosted at https://github.com/perl/perl5
more complete pseudo-fork() support for Windows
[perl5.git] / os2 / os2.c
index 94d25e2..8a17ae7 100644 (file)
--- a/os2/os2.c
+++ b/os2/os2.c
@@ -3,8 +3,14 @@
 #define INCL_DOSFILEMGR
 #define INCL_DOSMEMMGR
 #define INCL_DOSERRORS
+/* These 3 are needed for compile if os2.h includes os2tk.h, not os2emx.h */
+#define INCL_DOSPROCESS
+#define SPU_DISABLESUPPRESSION          0
+#define SPU_ENABLESUPPRESSION           1
 #include <os2.h>
 
+#include <sys/uflags.h>
+
 /*
  * Various Unix compatibility functions for OS/2
  */
@@ -160,11 +166,15 @@ int
 os2_cond_wait(perl_cond *c, perl_mutex *m)
 {                                              
     int rc;
-    if ((rc = DosResetEventSem(*c,&na)) && (rc != ERROR_ALREADY_RESET))
+    STRLEN n_a;
+    if ((rc = DosResetEventSem(*c,&n_a)) && (rc != ERROR_ALREADY_RESET))
        croak("panic: COND_WAIT-reset: rc=%i", rc);             
     if (m) MUTEX_UNLOCK(m);                                    
-    if (CheckOSError(DosWaitEventSem(*c,SEM_INDEFINITE_WAIT)))
+    if (CheckOSError(DosWaitEventSem(*c,SEM_INDEFINITE_WAIT))
+       && (rc != ERROR_INTERRUPT))
        croak("panic: COND_WAIT: rc=%i", rc);           
+    if (rc == ERROR_INTERRUPT)
+       errno = EINTR;
     if (m) MUTEX_LOCK(m);                                      
 } 
 #endif 
@@ -175,9 +185,10 @@ static PFN ExtFCN[2];                      /* Labeled by ord below. */
 static USHORT loadOrd[2] = { 874, 873 }; /* Query=874, Set=873. */
 #define ORD_QUERY_ELP  0
 #define ORD_SET_ELP    1
+struct PMWIN_entries_t PMWIN_entries;
 
 APIRET
-loadByOrd(ULONG ord)
+loadByOrd(char *modname, ULONG ord)
 {
     if (ExtFCN[ord] == NULL) {
        static HMODULE hdosc = 0;
@@ -186,15 +197,46 @@ loadByOrd(ULONG ord)
        APIRET rc;
 
        if ((!hdosc && CheckOSError(DosLoadModule(buf, sizeof buf, 
-                                                 "doscalls", &hdosc)))
+                                                 modname, &hdosc)))
            || CheckOSError(DosQueryProcAddr(hdosc, loadOrd[ord], NULL, &fcn)))
-           die("This version of OS/2 does not support doscalls.%i", 
-               loadOrd[ord]);
+           croak("This version of OS/2 does not support %s.%i", 
+                 modname, loadOrd[ord]);
        ExtFCN[ord] = fcn;
     } 
-    if ((long)ExtFCN[ord] == -1) die("panic queryaddr");
+    if ((long)ExtFCN[ord] == -1) 
+       croak("panic queryaddr");
+}
+
+void 
+init_PMWIN_entries(void)
+{
+    static HMODULE hpmwin = 0;
+    static const int ords[] = {
+       763,                            /* Initialize */
+       716,                            /* CreateMsgQueue */
+       726,                            /* DestroyMsgQueue */
+       918,                            /* PeekMsg */
+       915,                            /* GetMsg */
+       912,                            /* DispatchMsg */
+    };
+    BYTE buf[20];
+    int i = 0;
+    unsigned long rc;
+
+    if (hpmwin)
+       return;
+
+    if (CheckOSError(DosLoadModule(buf, sizeof buf, "pmwin", &hpmwin)))
+       croak("This version of OS/2 does not support pmwin: error in %s", buf);
+    while (i <= 5) {
+       if (CheckOSError(DosQueryProcAddr(hpmwin, ords[i], NULL, 
+                                         ((PFN*)&PMWIN_entries)+i)))
+           croak("This version of OS/2 does not support pmwin.%d", ords[i]);
+       i++;
+    }
 }
 
+
 /* priorities */
 static signed char priors[] = {0, 1, 3, 2}; /* Last two interchanged,
                                               self inverse. */
@@ -307,7 +349,28 @@ getpriority(int which /* ignored */, int pid)
 
 /*****************************************************************************/
 /* spawn */
-typedef void (*Sigfunc) _((int));
+
+/* There is no big sense to make it thread-specific, since signals 
+   are delivered to thread 1 only.  XXXX Maybe make it into an array? */
+static int spawn_pid;
+static int spawn_killed;
+
+static Signal_t
+spawn_sighandler(int sig)
+{
+    /* Some programs do not arrange for the keyboard signals to be
+       delivered to them.  We need to deliver the signal manually. */
+    /* We may get a signal only if 
+       a) kid does not receive keyboard signal: deliver it;
+       b) kid already died, and we get a signal.  We may only hope
+          that the pid number was not reused.
+     */
+    
+    if (spawn_killed) 
+       sig = SIGKILL;                  /* Try harder. */
+    kill(spawn_pid, sig);
+    spawn_killed = 1;
+}
 
 static int
 result(int flag, int pid)
@@ -324,15 +387,17 @@ result(int flag, int pid)
                return pid;
 
 #ifdef __EMX__
-       ihand = rsignal(SIGINT, SIG_IGN);
-       qhand = rsignal(SIGQUIT, SIG_IGN);
+       spawn_pid = pid;
+       spawn_killed = 0;
+       ihand = rsignal(SIGINT, &spawn_sighandler);
+       qhand = rsignal(SIGQUIT, &spawn_sighandler);
        do {
            r = wait4pid(pid, &status, 0);
        } while (r == -1 && errno == EINTR);
        rsignal(SIGINT, ihand);
        rsignal(SIGQUIT, qhand);
 
-       statusvalue = (U16)status;
+       PL_statusvalue = (U16)status;
        if (r < 0)
                return -1;
        return status & 0xFFFF;
@@ -340,10 +405,10 @@ result(int flag, int pid)
        ihand = rsignal(SIGINT, SIG_IGN);
        r = DosWaitChild(DCWA_PROCESS, DCWW_WAIT, &res, &rpid, pid);
        rsignal(SIGINT, ihand);
-       statusvalue = res.codeResult << 8 | res.codeTerminate;
+       PL_statusvalue = res.codeResult << 8 | res.codeTerminate;
        if (r)
                return -1;
-       return statusvalue;
+       return PL_statusvalue;
 #endif
 }
 
@@ -351,215 +416,417 @@ result(int flag, int pid)
 #define EXECF_EXEC 1
 #define EXECF_TRUEEXEC 2
 #define EXECF_SPAWN_NOWAIT 3
+#define EXECF_SPAWN_BYFLAG 4
+
+/* const char* const ptypes[] = { "FS", "DOS", "VIO", "PM", "DETACH" }; */
+
+static int
+my_type()
+{
+    int rc;
+    TIB *tib;
+    PIB *pib;
+    
+    if (!(_emx_env & 0x200)) return 1; /* not OS/2. */
+    if (CheckOSError(DosGetInfoBlocks(&tib, &pib))) 
+       return -1; 
+    
+    return (pib->pib_ultype);
+}
+
+static ULONG
+file_type(char *path)
+{
+    int rc;
+    ULONG apptype;
+    
+    if (!(_emx_env & 0x200)) 
+       croak("file_type not implemented on DOS"); /* not OS/2. */
+    if (CheckOSError(DosQueryAppType(path, &apptype))) {
+       switch (rc) {
+       case ERROR_FILE_NOT_FOUND:
+       case ERROR_PATH_NOT_FOUND:
+           return -1;
+       case ERROR_ACCESS_DENIED:       /* Directory with this name found? */
+           return -3;
+       default:                        /* Found, but not an
+                                          executable, or some other
+                                          read error. */
+           return -2;
+       }
+    }    
+    return apptype;
+}
+
+static ULONG os2_mytype;
 
 /* Spawn/exec a program, revert to shell if needed. */
-/* global Argv[] contains arguments. */
+/* global PL_Argv[] contains arguments. */
 
 int
-do_aspawn(really, flag, execf)
+do_spawn_ve(really, flag, execf, inicmd, addflag)
 SV *really;
 U32 flag;
 U32 execf;
+char *inicmd;
+U32 addflag;
 {
     dTHR;
        int trueflag = flag;
-       int rc, secondtry = 0, err;
+       int rc, pass = 1;
        char *tmps;
-       char buf[256], *s = 0;
+       char buf[256], *s = 0, scrbuf[280];
        char *args[4];
        static char * fargs[4] 
            = { "/bin/sh", "-c", "\"$@\"", "spawn-via-shell", };
        char **argsp = fargs;
        char nargs = 4;
+       int force_shell;
+       int new_stderr = -1, nostderr = 0, fl_stderr;
+       STRLEN n_a;
        
        if (flag == P_WAIT)
                flag = P_NOWAIT;
 
       retry:
-       if (strEQ(Argv[0],"/bin/sh")) 
-           Argv[0] = sh_path;
+       if (strEQ(PL_Argv[0],"/bin/sh")) 
+           PL_Argv[0] = PL_sh_path;
 
-       if (Argv[0][0] != '/' && Argv[0][0] != '\\'
-           && !(Argv[0][0] && Argv[0][1] == ':' 
-                && (Argv[0][2] == '/' || Argv[0][2] != '\\'))
-           ) /* will swawnvp use PATH? */
+       if (PL_Argv[0][0] != '/' && PL_Argv[0][0] != '\\'
+           && !(PL_Argv[0][0] && PL_Argv[0][1] == ':' 
+                && (PL_Argv[0][2] == '/' || PL_Argv[0][2] != '\\'))
+           ) /* will spawnvp use PATH? */
            TAINT_ENV();        /* testing IFS here is overkill, probably */
        /* We should check PERL_SH* and PERLLIB_* as well? */
-       if (!really || !*(tmps = SvPV(really, na)))
-           tmps = Argv[0];
+       if (!really || !*(tmps = SvPV(really, n_a)))
+           tmps = PL_Argv[0];
+
+      reread:
+       force_shell = 0;
+       if (_emx_env & 0x200) { /* OS/2. */ 
+           int type = file_type(tmps);
+         type_again:
+           if (type == -1) {           /* Not found */
+               errno = ENOENT;
+               rc = -1;
+               goto do_script;
+           }
+           else if (type == -2) {              /* Not an EXE */
+               errno = ENOEXEC;
+               rc = -1;
+               goto do_script;
+           }
+           else if (type == -3) {              /* Is a directory? */
+               /* Special-case this */
+               char tbuf[512];
+               int l = strlen(tmps);
+
+               if (l + 5 <= sizeof tbuf) {
+                   strcpy(tbuf, tmps);
+                   strcpy(tbuf + l, ".exe");
+                   type = file_type(tbuf);
+                   if (type >= -3)
+                       goto type_again;
+               }
+               
+               errno = ENOEXEC;
+               rc = -1;
+               goto do_script;
+           }
+           switch (type & 7) {
+               /* Ignore WINDOWCOMPAT and FAPI, start them the same type we are. */
+           case FAPPTYP_WINDOWAPI: 
+           {
+               if (os2_mytype != 3) {  /* not PM */
+                   if (flag == P_NOWAIT)
+                       flag = P_PM;
+                   else if ((flag & 7) != P_PM && (flag & 7) != P_SESSION)
+                       warn("Starting PM process with flag=%d, mytype=%d",
+                            flag, os2_mytype);
+               }
+           }
+           break;
+           case FAPPTYP_NOTWINDOWCOMPAT: 
+           {
+               if (os2_mytype != 0) {  /* not full screen */
+                   if (flag == P_NOWAIT)
+                       flag = P_SESSION;
+                   else if ((flag & 7) != P_SESSION)
+                       warn("Starting Full Screen process with flag=%d, mytype=%d",
+                            flag, os2_mytype);
+               }
+           }
+           break;
+           case FAPPTYP_NOTSPEC: 
+               /* Let the shell handle this... */
+               force_shell = 1;
+               goto doshell_args;
+               break;
+           }
+       }
+
+       if (addflag) {
+           addflag = 0;
+           new_stderr = dup(2);                /* Preserve stderr */
+           if (new_stderr == -1) {
+               if (errno == EBADF)
+                   nostderr = 1;
+               else {
+                   rc = -1;
+                   goto finish;
+               }
+           } else
+               fl_stderr = fcntl(2, F_GETFD);
+           rc = dup2(1,2);
+           if (rc == -1)
+               goto finish;
+           fcntl(new_stderr, F_SETFD, FD_CLOEXEC);
+       }
+
 #if 0
-       rc = result(trueflag, spawnvp(flag,tmps,Argv));
+       rc = result(trueflag, spawnvp(flag,tmps,PL_Argv));
 #else
        if (execf == EXECF_TRUEEXEC)
-           rc = execvp(tmps,Argv);
+           rc = execvp(tmps,PL_Argv);
        else if (execf == EXECF_EXEC)
-           rc = spawnvp(trueflag | P_OVERLAY,tmps,Argv);
+           rc = spawnvp(trueflag | P_OVERLAY,tmps,PL_Argv);
        else if (execf == EXECF_SPAWN_NOWAIT)
-           rc = spawnvp(trueflag | P_NOWAIT,tmps,Argv);
-        else                           /* EXECF_SPAWN */
+           rc = spawnvp(flag,tmps,PL_Argv);
+        else                           /* EXECF_SPAWN, EXECF_SPAWN_BYFLAG */
            rc = result(trueflag, 
-                       spawnvp(trueflag | P_NOWAIT,tmps,Argv));
+                       spawnvp(flag,tmps,PL_Argv));
 #endif 
-       if (rc < 0 && secondtry == 0 
-           && (tmps == Argv[0])) { /* Cannot transfer `really' via shell. */
-           err = errno;
-           if (err == ENOENT) {        /* No such file. */
-               /* One reason may be that EMX added .exe. We suppose
-                  that .exe-less files are automatically shellable.
-                  It might have also been .cmd file without
-                  extension. */
-               char *no_dir;
-               (no_dir = strrchr(Argv[0], '/')) 
-                   || (no_dir = strrchr(Argv[0], '\\'))
-                   || (no_dir = Argv[0]);
-               if (!strchr(no_dir, '.')) {
-                   struct stat buffer;
-                   if (stat(Argv[0], &buffer) != -1) { /* File exists. */
-                       /* Maybe we need to specify the full name here? */
-                       goto doshell;
-                   } else {
-                       /* Try adding script extensions to the file name */
-                       char *scr;
-                       if ((scr = find_script(Argv[0], TRUE, NULL, 0))) {
-                           FILE *file = fopen(scr, "r");
-                           char *s = 0, *s1;
-
-                           Argv[0] = scr;
-                           if (!file)
-                               goto panic_file;
-                           if (!fgets(buf, sizeof buf, file)) {
-                               fclose(file);
-                               goto panic_file;
-                           }
-                           if (fclose(file) != 0) { /* Failure */
-                             panic_file:
-                               warn("Error reading \"%s\": %s", 
-                                    scr, Strerror(errno));
-                               goto doshell;
-                           }
-                           if (buf[0] == '#') {
-                               if (buf[1] == '!')
-                                   s = buf + 2;
-                           } else if (buf[0] == 'e') {
-                               if (strnEQ(buf, "extproc", 7) 
-                                   && isSPACE(buf[7]))
-                                   s = buf + 8;
-                           } else if (buf[0] == 'E') {
-                               if (strnEQ(buf, "EXTPROC", 7)
-                                   && isSPACE(buf[7]))
-                                   s = buf + 8;
-                           }
-                           if (!s)
-                               goto doshell;
-                           s1 = s;
-                           nargs = 0;
-                           argsp = args;
-                           while (1) {
-                               while (isSPACE(*s))
-                                   s++;
-                               if (*s == 0) 
-                                   break;
-                               if (nargs == 4) {
-                                   nargs = -1;
-                                   break;
+       if (rc < 0 && pass == 1
+           && (tmps == PL_Argv[0])) { /* Cannot transfer `really' via shell. */
+             do_script:
+           {
+           int err = errno;
+
+           if (err == ENOENT || err == ENOEXEC) {
+               /* No such file, or is a script. */
+               /* Try adding script extensions to the file name, and
+                  search on PATH. */
+               char *scr = find_script(PL_Argv[0], TRUE, NULL, 0);
+
+               if (scr) {
+                   FILE *file;
+                   char *s = 0, *s1;
+                   int l;
+
+                    l = strlen(scr);
+               
+                    if (l >= sizeof scrbuf) {
+                       Safefree(scr);
+                     longbuf:
+                       warn("Size of scriptname too big: %d", l);
+                      rc = -1;
+                      goto finish;
+                    }
+                    strcpy(scrbuf, scr);
+                    Safefree(scr);
+                    scr = scrbuf;
+
+                   file = fopen(scr, "r");
+                   PL_Argv[0] = scr;
+                   if (!file)
+                       goto panic_file;
+                   if (!fgets(buf, sizeof buf, file)) { /* Empty... */
+
+                       buf[0] = 0;
+                       fclose(file);
+                       /* Special case: maybe from -Zexe build, so
+                          there is an executable around (contrary to
+                          documentation, DosQueryAppType sometimes (?)
+                          does not append ".exe", so we could have
+                          reached this place). */
+                       if (l + 5 < sizeof scrbuf) {
+                           strcpy(scrbuf + l, ".exe");
+                           if (PerlLIO_stat(scrbuf,&PL_statbuf) >= 0
+                               && !S_ISDIR(PL_statbuf.st_mode)) {
+                               /* Found */
+                               tmps = scr;
+                               pass++;
+                               goto reread;
+                           } else
+                               scrbuf[l] = 0;
+                       } else
+                           goto longbuf;
+                   }
+                   if (fclose(file) != 0) { /* Failure */
+                     panic_file:
+                       warn("Error reading \"%s\": %s", 
+                            scr, Strerror(errno));
+                       buf[0] = 0;     /* Not #! */
+                       goto doshell_args;
+                   }
+                   if (buf[0] == '#') {
+                       if (buf[1] == '!')
+                           s = buf + 2;
+                   } else if (buf[0] == 'e') {
+                       if (strnEQ(buf, "extproc", 7) 
+                           && isSPACE(buf[7]))
+                           s = buf + 8;
+                   } else if (buf[0] == 'E') {
+                       if (strnEQ(buf, "EXTPROC", 7)
+                           && isSPACE(buf[7]))
+                           s = buf + 8;
+                   }
+                   if (!s) {
+                       buf[0] = 0;     /* Not #! */
+                       goto doshell_args;
+                   }
+                   
+                   s1 = s;
+                   nargs = 0;
+                   argsp = args;
+                   while (1) {
+                       /* Do better than pdksh: allow a few args,
+                          strip trailing whitespace.  */
+                       while (isSPACE(*s))
+                           s++;
+                       if (*s == 0) 
+                           break;
+                       if (nargs == 4) {
+                           nargs = -1;
+                           break;
+                       }
+                       args[nargs++] = s;
+                       while (*s && !isSPACE(*s))
+                           s++;
+                       if (*s == 0) 
+                           break;
+                       *s++ = 0;
+                   }
+                   if (nargs == -1) {
+                       warn("Too many args on %.*s line of \"%s\"",
+                            s1 - buf, buf, scr);
+                       nargs = 4;
+                       argsp = fargs;
+                   }
+                 doshell_args:
+                   {
+                       char **a = PL_Argv;
+                       char *exec_args[2];
+
+                       if (force_shell 
+                           || (!buf[0] && file)) { /* File without magic */
+                           /* In fact we tried all what pdksh would
+                              try.  There is no point in calling
+                              pdksh, we may just emulate its logic. */
+                           char *shell = getenv("EXECSHELL");
+                           char *shell_opt = NULL;
+
+                           if (!shell) {
+                               char *s;
+
+                               shell_opt = "/c";
+                               shell = getenv("OS2_SHELL");
+                               if (inicmd) { /* No spaces at start! */
+                                   s = inicmd;
+                                   while (*s && !isSPACE(*s)) {
+                                       if (*s++ = '/') {
+                                           inicmd = NULL; /* Cannot use */
+                                           break;
+                                       }
+                                   }
+                               }
+                               if (!inicmd) {
+                                   s = PL_Argv[0];
+                                   while (*s) { 
+                                       /* Dosish shells will choke on slashes
+                                          in paths, fortunately, this is
+                                          important for zeroth arg only. */
+                                       if (*s == '/') 
+                                           *s = '\\';
+                                       s++;
+                                   }
                                }
-                               args[nargs++] = s;
-                               while (*s && !isSPACE(*s))
-                                   s++;
-                               if (*s == 0) 
-                                   break;
-                               *s++ = 0;
                            }
-                           if (nargs == -1) {
-                               warn("Too many args on %.*s line of \"%s\"",
-                                    s1 - buf, buf, scr);
-                               nargs = 4;
-                               argsp = fargs;
+                           /* If EXECSHELL is set, we do not set */
+                           
+                           if (!shell)
+                               shell = ((_emx_env & 0x200)
+                                        ? "c:/os2/cmd.exe"
+                                        : "c:/command.com");
+                           nargs = shell_opt ? 2 : 1;  /* shell file args */
+                           exec_args[0] = shell;
+                           exec_args[1] = shell_opt;
+                           argsp = exec_args;
+                           if (nargs == 2 && inicmd) {
+                               /* Use the original cmd line */
+                               /* XXXX This is good only until we refuse
+                                       quoted arguments... */
+                               PL_Argv[0] = inicmd;
+                               PL_Argv[1] = Nullch;
                            }
-                           goto doshell;
+                       } else if (!buf[0] && inicmd) { /* No file */
+                           /* Start with the original cmdline. */
+                           /* XXXX This is good only until we refuse
+                                   quoted arguments... */
+
+                           PL_Argv[0] = inicmd;
+                           PL_Argv[1] = Nullch;
+                           nargs = 2;  /* shell -c */
+                       } 
+
+                       while (a[1])            /* Get to the end */
+                           a++;
+                       a++;                    /* Copy finil NULL too */
+                       while (a >= PL_Argv) {
+                           *(a + nargs) = *a;  /* PL_Argv was preallocated to be
+                                                  long enough. */
+                           a--;
                        }
+                       while (nargs-- >= 0)
+                           PL_Argv[nargs] = argsp[nargs];
+                       /* Enable pathless exec if #! (as pdksh). */
+                       pass = (buf[0] == '#' ? 2 : 3);
+                       goto retry;
                    }
                }
-               /* Restore errno */
+               /* Not found: restore errno */
                errno = err;
-           } else if (err == ENOEXEC) { /* Need to send to shell. */
-             doshell:
-               {
-               char **a = Argv;
-
-               while (a[1])            /* Get to the end */
-                   a++;
-               while (a >= Argv) {
-                   *(a + nargs) = *a;  /* Argv was preallocated to be
-                                          long enough. */
-                   a--;
-               }
-               while (nargs-- >= 0)
-                   Argv[nargs] = argsp[nargs];
-               secondtry = 1;
+           }
+         }
+       } else if (rc < 0 && pass == 2 && errno == ENOENT) { /* File not found */
+           char *no_dir = strrchr(PL_Argv[0], '/');
+
+           /* Do as pdksh port does: if not found with /, try without
+              path. */
+           if (no_dir) {
+               PL_Argv[0] = no_dir + 1;
+               pass++;
                goto retry;
-               }
            }
        }
-       if (rc < 0 && dowarn)
-           warn("Can't %s \"%s\": %s\n", 
+       if (rc < 0 && ckWARN(WARN_EXEC))
+           Perl_warner(aTHX_ WARN_EXEC, "Can't %s \"%s\": %s\n", 
                 ((execf != EXECF_EXEC && execf != EXECF_TRUEEXEC) 
                  ? "spawn" : "exec"),
-                Argv[0], Strerror(err));
+                PL_Argv[0], Strerror(errno));
        if (rc < 0 && (execf != EXECF_SPAWN_NOWAIT) 
            && ((trueflag & 0xFF) == P_WAIT)) 
-           rc = 255 << 8; /* Emulate the fork(). */
-
-    return rc;
-}
-
-int
-do_aspawn(really,mark,sp)
-SV *really;
-register SV **mark;
-register SV **sp;
-{
-    dTHR;
-    register char **a;
-    char *tmps = NULL;
-    int rc;
-    int flag = P_WAIT, trueflag, err, secondtry = 0;
-
-    if (sp > mark) {
-       New(1301,Argv, sp - mark + 3, char*);
-       a = Argv;
-
-       if (mark < sp && SvNIOKp(*(mark+1)) && !SvPOKp(*(mark+1))) {
-               ++mark;
-               flag = SvIVx(*mark);
-       }
-
-       while (++mark <= sp) {
-           if (*mark)
-               *a++ = SvPVx(*mark, na);
-           else
-               *a++ = "";
-       }
-       *a = Nullch;
-
-       rc = do_spawn_ve(really, flag, EXECF_SPAWN);
-    } else
-       rc = -1;
-    do_execfree();
+           rc = -1;
+
+  finish:
+    if (new_stderr != -1) {    /* How can we use error codes? */
+       dup2(new_stderr, 2);
+       close(new_stderr);
+       fcntl(2, F_SETFD, fl_stderr);
+    } else if (nostderr)
+       close(2);
     return rc;
 }
 
 /* Try converting 1-arg form to (usually shell-less) multi-arg form. */
 int
-do_spawn2(cmd, execf)
-char *cmd;
-int execf;
+do_spawn3(char *cmd, int execf, int flag)
 {
     register char **a;
     register char *s;
     char flags[10];
     char *shell, *copt, *news = NULL;
-    int rc, added_shell = 0, err, seenspace = 0;
+    int rc, err, seenspace = 0, mergestderr = 0;
     char fullcmd[MAXNAMLEN + 1];
 
 #ifdef TRYSHELL
@@ -576,7 +843,7 @@ int execf;
        have a shell which will not change between computers with the
        same architecture, to avoid "action on a distance". 
        And to have simple build, this shell should be sh. */
-    shell = sh_path;
+    shell = PL_sh_path;
     copt = "-c";
 #endif 
 
@@ -584,13 +851,12 @@ int execf;
        cmd++;
 
     if (strnEQ(cmd,"/bin/sh",7) && isSPACE(cmd[7])) {
-       STRLEN l = strlen(sh_path);
+       STRLEN l = strlen(PL_sh_path);
        
        New(1302, news, strlen(cmd) - 7 + l + 1, char);
-       strcpy(news, sh_path);
+       strcpy(news, PL_sh_path);
        strcpy(news + l, cmd + 7);
        cmd = news;
-       added_shell = 1;
     }
 
     /* save an extra exec if possible */
@@ -613,25 +879,43 @@ int execf;
                break;
            } else if (*s == '\\' && !seenspace) {
                continue;               /* Allow backslashes in names */
+           } else if (*s == '>' && s >= cmd + 3
+                       && s[-1] == '2' && s[1] == '&' && s[2] == '1'
+                       && isSPACE(s[-2]) ) {
+               char *t = s + 3;
+
+               while (*t && isSPACE(*t))
+                   t++;
+               if (!*t) {
+                   s[-2] = '\0';
+                   mergestderr = 1;
+                   break;              /* Allow 2>&1 as the last thing */
+               }
            }
            /* We do not convert this to do_spawn_ve since shell
               should be smart enough to start itself gloriously. */
          doshell:
            if (execf == EXECF_TRUEEXEC)
-                return execl(shell,shell,copt,cmd,(char*)0);
+                rc = execl(shell,shell,copt,cmd,(char*)0);             
            else if (execf == EXECF_EXEC)
-                return spawnl(P_OVERLAY,shell,shell,copt,cmd,(char*)0);
+                rc = spawnl(P_OVERLAY,shell,shell,copt,cmd,(char*)0);
            else if (execf == EXECF_SPAWN_NOWAIT)
-                return spawnl(P_NOWAIT,shell,shell,copt,cmd,(char*)0);
-           /* In the ak code internal P_NOWAIT is P_WAIT ??? */
-           rc = result(P_WAIT,
-                       spawnl(P_NOWAIT,shell,shell,copt,cmd,(char*)0));
-           if (rc < 0 && dowarn)
-               warn("Can't %s \"%s\": %s", 
-                    (execf == EXECF_SPAWN ? "spawn" : "exec"),
-                    shell, Strerror(errno));
-           if (rc < 0) rc = 255 << 8; /* Emulate the fork(). */
-           if (news) Safefree(news);
+                rc = spawnl(P_NOWAIT,shell,shell,copt,cmd,(char*)0);
+           else if (execf == EXECF_SPAWN_BYFLAG)
+                rc = spawnl(flag,shell,shell,copt,cmd,(char*)0);
+           else {
+               /* In the ak code internal P_NOWAIT is P_WAIT ??? */
+               rc = result(P_WAIT,
+                           spawnl(P_NOWAIT,shell,shell,copt,cmd,(char*)0));
+               if (rc < 0 && ckWARN(WARN_EXEC))
+                   Perl_warner(aTHX_ WARN_EXEC, "Can't %s \"%s\": %s", 
+                        (execf == EXECF_SPAWN ? "spawn" : "exec"),
+                        shell, Strerror(errno));
+               if (rc < 0)
+                   rc = -1;
+           }
+           if (news)
+               Safefree(news);
            return rc;
        } else if (*s == ' ' || *s == '\t') {
            seenspace = 1;
@@ -639,10 +923,10 @@ int execf;
     }
 
     /* cmd="a" may lead to "sh", "-c", "\"$@\"", "a", "a.cmd", NULL */
-    New(1303,Argv, (s - cmd + 11) / 2, char*);
-    Cmd = savepvn(cmd, s-cmd);
-    a = Argv;
-    for (s = Cmd; *s;) {
+    New(1303,PL_Argv, (s - cmd + 11) / 2, char*);
+    PL_Cmd = savepvn(cmd, s-cmd);
+    a = PL_Argv;
+    for (s = PL_Cmd; *s;) {
        while (*s && isSPACE(*s)) s++;
        if (*s)
            *(a++) = s;
@@ -651,11 +935,54 @@ int execf;
            *s++ = '\0';
     }
     *a = Nullch;
-    if (Argv[0])
-       rc = do_spawn_ve(NULL, 0, execf);
+    if (PL_Argv[0])
+       rc = do_spawn_ve(NULL, flag, execf, cmd, mergestderr);
     else
        rc = -1;
-    if (news) Safefree(news);
+    if (news)
+       Safefree(news);
+    do_execfree();
+    return rc;
+}
+
+/* Array spawn.  */
+int
+do_aspawn(really,mark,sp)
+SV *really;
+register SV **mark;
+register SV **sp;
+{
+    dTHR;
+    register char **a;
+    int rc;
+    int flag = P_WAIT, flag_set = 0;
+    STRLEN n_a;
+
+    if (sp > mark) {
+       New(1301,PL_Argv, sp - mark + 3, char*);
+       a = PL_Argv;
+
+       if (mark < sp && SvNIOKp(*(mark+1)) && !SvPOKp(*(mark+1))) {
+               ++mark;
+               flag = SvIVx(*mark);
+               flag_set = 1;
+
+       }
+
+       while (++mark <= sp) {
+           if (*mark)
+               *a++ = SvPVx(*mark, n_a);
+           else
+               *a++ = "";
+       }
+       *a = Nullch;
+
+       if (flag_set && (a == PL_Argv + 1)) { /* One arg? */
+           rc = do_spawn3(a[-1], EXECF_SPAWN_BYFLAG, flag);
+       } else
+           rc = do_spawn_ve(really, flag, EXECF_SPAWN, NULL, 0);
+    } else
+       rc = -1;
     do_execfree();
     return rc;
 }
@@ -664,28 +991,29 @@ int
 do_spawn(cmd)
 char *cmd;
 {
-    return do_spawn2(cmd, EXECF_SPAWN);
+    return do_spawn3(cmd, EXECF_SPAWN, 0);
 }
 
 int
 do_spawn_nowait(cmd)
 char *cmd;
 {
-    return do_spawn2(cmd, EXECF_SPAWN_NOWAIT);
+    return do_spawn3(cmd, EXECF_SPAWN_NOWAIT,0);
 }
 
 bool
 do_exec(cmd)
 char *cmd;
 {
-    return do_spawn2(cmd, EXECF_EXEC);
+    do_spawn3(cmd, EXECF_EXEC, 0);
+    return FALSE;
 }
 
 bool
 os2exec(cmd)
 char *cmd;
 {
-    return do_spawn2(cmd, EXECF_TRUEEXEC);
+    return do_spawn3(cmd, EXECF_TRUEEXEC, 0);
 }
 
 PerlIO *
@@ -700,45 +1028,71 @@ char     *mode;
     register I32 pid, rc;
     PerlIO *res;
     SV *sv;
+    int fh_fl;
     
     /* `this' is what we use in the parent, `that' in the child. */
     this = (*mode == 'w');
     that = !this;
-    if (tainting) {
+    if (PL_tainting) {
        taint_env();
        taint_proper("Insecure %s%s", "EXEC");
     }
     if (pipe(p) < 0)
        return Nullfp;
     /* Now we need to spawn the child. */
+    if (p[this] == (*mode == 'r')) {   /* if fh 0/1 was initially closed. */
+       int new = dup(p[this]);
+
+       if (new == -1)
+           goto closepipes;
+       close(p[this]);
+       p[this] = new;
+    }
     newfd = dup(*mode == 'r');         /* Preserve std* */
-    if (p[that] != (*mode == 'r')) {
+    if (newfd == -1) {         
+       /* This cannot happen due to fh being bad after pipe(), since
+          pipe() should have created fh 0 and 1 even if they were
+          initially closed.  But we closed p[this] before.  */
+       if (errno != EBADF) {
+         closepipes:
+           close(p[0]);
+           close(p[1]);
+           return Nullfp;
+       }
+    } else
+       fh_fl = fcntl(*mode == 'r', F_GETFD);
+    if (p[that] != (*mode == 'r')) {   /* if fh 0/1 was initially closed. */
        dup2(p[that], *mode == 'r');
        close(p[that]);
     }
     /* Where is `this' and newfd now? */
     fcntl(p[this], F_SETFD, FD_CLOEXEC);
-    fcntl(newfd, F_SETFD, FD_CLOEXEC);
+    if (newfd != -1)
+       fcntl(newfd, F_SETFD, FD_CLOEXEC);
     pid = do_spawn_nowait(cmd);
-    if (newfd != (*mode == 'r')) {
+    if (newfd == -1)
+       close(*mode == 'r');            /* It was closed initially */
+    else if (newfd != (*mode == 'r')) {        /* Probably this check is not needed */
        dup2(newfd, *mode == 'r');      /* Return std* back. */
        close(newfd);
-    }
+       fcntl(*mode == 'r', F_SETFD, fh_fl);
+    } else
+       fcntl(*mode == 'r', F_SETFD, fh_fl);
     if (p[that] == (*mode == 'r'))
        close(p[that]);
     if (pid == -1) {
        close(p[this]);
-       return NULL;
+       return Nullfp;
     }
-    if (p[that] < p[this]) {
+    if (p[that] < p[this]) {           /* Make fh as small as possible */
        dup2(p[this], p[that]);
        close(p[this]);
        p[this] = p[that];
     }
-    sv = *av_fetch(fdpid,p[this],TRUE);
+    sv = *av_fetch(PL_fdpid,p[this],TRUE);
     (void)SvUPGRADE(sv,SVt_IV);
     SvIVX(sv) = pid;
-    forkprocess = pid;
+    PL_forkprocess = pid;
     return PerlIO_fdopen(p[this], mode);
 
 #else  /* USE_POPEN */
@@ -751,11 +1105,11 @@ char     *mode;
 #  else
     char *shell = getenv("EMXSHELL");
 
-    my_setenv("EMXSHELL", sh_path);
+    my_setenv("EMXSHELL", PL_sh_path);
     res = popen(cmd, mode);
     my_setenv("EMXSHELL", shell);
 #  endif 
-    sv = *av_fetch(fdpid, PerlIO_fileno(res), TRUE);
+    sv = *av_fetch(PL_fdpid, PerlIO_fileno(res), TRUE);
     (void)SvUPGRADE(sv,SVt_IV);
     SvIVX(sv) = -1;                    /* A cooky. */
     return res;
@@ -770,7 +1124,7 @@ char       *mode;
 int
 fork(void)
 {
-    die(no_func, "Unsupported function fork");
+    croak(PL_no_func, "Unsupported function fork");
     errno = EINVAL;
     return -1;
 }
@@ -875,7 +1229,8 @@ sys_alloc(int size) {
 
     if (rc == ERROR_NOT_ENOUGH_MEMORY) {
        return (void *) -1;
-    } else if ( rc ) die("Got an error from DosAllocMem: %li", (long)rc);
+    } else if ( rc ) 
+       croak("Got an error from DosAllocMem: %li", (long)rc);
     return got;
 }
 
@@ -895,10 +1250,12 @@ settmppath()
     if (!p) return;
     len = strlen(p);
     tpath = (char *)malloc(len + strlen(TMPPATH1) + 2);
-    strcpy(tpath, p);
-    tpath[len] = '/';
-    strcpy(tpath + len + 1, TMPPATH1);
-    tmppath = tpath;
+    if (tpath) {
+       strcpy(tpath, p);
+       tpath[len] = '/';
+       strcpy(tpath + len + 1, TMPPATH1);
+       tmppath = tpath;
+    }
 }
 
 #include "XSUB.h"
@@ -909,8 +1266,9 @@ XS(XS_File__Copy_syscopy)
     if (items < 2 || items > 3)
        croak("Usage: File::Copy::syscopy(src,dst,flag=0)");
     {
-       char *  src = (char *)SvPV(ST(0),na);
-       char *  dst = (char *)SvPV(ST(1),na);
+       STRLEN n_a;
+       char *  src = (char *)SvPV(ST(0),n_a);
+       char *  dst = (char *)SvPV(ST(1),n_a);
        U32     flag;
        int     RETVAL, rc;
 
@@ -927,6 +1285,8 @@ XS(XS_File__Copy_syscopy)
     XSRETURN(1);
 }
 
+#include "patchlevel.h"
+
 char *
 mod2fname(sv)
      SV   *sv;
@@ -937,6 +1297,7 @@ mod2fname(sv)
     AV  *av;
     SV  *svp;
     char *s;
+    STRLEN n_a;
 
     if (!SvROK(sv)) croak("Not a reference given to mod2fname");
     sv = SvRV(sv);
@@ -947,7 +1308,7 @@ mod2fname(sv)
     if (avlen < 0) 
       croak("Empty array reference given to mod2fname");
 
-    s = SvPV(*av_fetch((AV*)sv, avlen, FALSE), na);
+    s = SvPV(*av_fetch((AV*)sv, avlen, FALSE), n_a);
     strncpy(fname, s, 8);
     len = strlen(s);
     if (len < 6) pos = len;
@@ -957,7 +1318,7 @@ mod2fname(sv)
     }
     avlen --;
     while (avlen >= 0) {
-       s = SvPV(*av_fetch((AV*)sv, avlen, FALSE), na);
+       s = SvPV(*av_fetch((AV*)sv, avlen, FALSE), n_a);
        while (*s) {
            sum = 33 * sum + *(s++);    /* 7 is primitive mod 13. */
        }
@@ -966,6 +1327,7 @@ mod2fname(sv)
 #ifdef USE_THREADS
     sum++;                             /* Avoid conflict of DLLs in memory. */
 #endif 
+    sum += PERL_VERSION * 200 + PERL_SUBVERSION * 2;  /*  */
     fname[pos] = 'A' + (sum % 26);
     fname[pos + 1] = 'A' + (sum / 26 % 26);
     fname[pos + 2] = '\0';
@@ -999,12 +1361,37 @@ os2error(int rc)
                return NULL;
        if (DosGetMessage(NULL, 0, buf, sizeof buf - 1, rc, "OSO001.MSG", &len))
                sprintf(buf, "OS/2 system error code %d=0x%x", rc, rc);
-       else
+       else {
                buf[len] = '\0';
+               if (len && buf[len - 1] == '\n')
+                       buf[--len] = 0;
+               if (len && buf[len - 1] == '\r')
+                       buf[--len] = 0;
+               if (len && buf[len - 1] == '.')
+                       buf[--len] = 0;
+       }
        return buf;
 }
 
 char *
+os2_execname(void)
+{
+  char buf[300], *p;
+
+  if (_execname(buf, sizeof buf) != 0)
+       return PL_origargv[0];
+  p = buf;
+  while (*p) {
+    if (*p == '\\')
+       *p = '/';
+    p++;
+  }
+  p = savepv(buf);
+  SAVEFREEPV(p);
+  return p;
+}
+
+char *
 perllib_mangle(char *s, unsigned int l)
 {
     static char *newp, *oldp;
@@ -1025,7 +1412,7 @@ perllib_mangle(char *s, unsigned int l)
            }
            newl = strlen(newp);
            if (newl == 0 || oldl == 0) {
-               die("Malformed PERLLIB_PREFIX");
+               croak("Malformed PERLLIB_PREFIX");
            }
            strcpy(ret, newp);
            s = ret;
@@ -1047,12 +1434,102 @@ perllib_mangle(char *s, unsigned int l)
        return s;
     }
     if (l + newl - oldl > STATIC_FILE_LENGTH || newl > STATIC_FILE_LENGTH) {
-       die("Malformed PERLLIB_PREFIX");
+       croak("Malformed PERLLIB_PREFIX");
     }
     strcpy(ret + newl, s + oldl);
     return ret;
 }
 
+unsigned long 
+Perl_hab_GET()                 /* Needed if perl.h cannot be included */
+{
+    return perl_hab_GET();
+}
+
+HMQ
+Perl_Register_MQ(int serve)
+{
+    PPIB pib;
+    PTIB tib;
+
+    if (Perl_os2_initial_mode++)
+       return Perl_hmq;
+    DosGetInfoBlocks(&tib, &pib);
+    Perl_os2_initial_mode = pib->pib_ultype;
+    Perl_hmq_refcnt = 1;
+    /* Try morphing into a PM application. */
+    if (pib->pib_ultype != 3)          /* 2 is VIO */
+       pib->pib_ultype = 3;            /* 3 is PM */
+    init_PMWIN_entries();
+    /* 64 messages if before OS/2 3.0, ignored otherwise */
+    Perl_hmq = (*PMWIN_entries.CreateMsgQueue)(perl_hab_GET(), 64); 
+    if (!Perl_hmq) {
+       static int cnt;
+       if (cnt++)
+           _exit(188);                 /* Panic can try to create a window. */
+       croak("Cannot create a message queue, or morph to a PM application");
+    }
+    return Perl_hmq;
+}
+
+int
+Perl_Serve_Messages(int force)
+{
+    int cnt = 0;
+    QMSG msg;
+
+    if (Perl_hmq_servers && !force)
+       return 0;
+    if (!Perl_hmq_refcnt)
+       croak("No message queue");
+    while ((*PMWIN_entries.PeekMsg)(Perl_hab, &msg, NULLHANDLE, 0, 0, PM_REMOVE)) {
+       cnt++;
+       if (msg.msg == WM_QUIT)
+           croak("QUITing...");
+       (*PMWIN_entries.DispatchMsg)(Perl_hab, &msg);
+    }
+    return cnt;
+}
+
+int
+Perl_Process_Messages(int force, I32 *cntp)
+{
+    QMSG msg;
+
+    if (Perl_hmq_servers && !force)
+       return 0;
+    if (!Perl_hmq_refcnt)
+       croak("No message queue");
+    while ((*PMWIN_entries.GetMsg)(Perl_hab, &msg, NULLHANDLE, 0, 0)) {
+       if (cntp)
+           (*cntp)++;
+       (*PMWIN_entries.DispatchMsg)(Perl_hab, &msg);
+       if (msg.msg == WM_DESTROY)
+           return -1;
+       if (msg.msg == WM_CREATE)
+           return +1;
+    }
+    croak("QUITing...");
+}
+
+void
+Perl_Deregister_MQ(int serve)
+{
+    PPIB pib;
+    PTIB tib;
+
+    if (--Perl_hmq_refcnt == 0) {
+       (*PMWIN_entries.DestroyMsgQueue)(Perl_hmq);
+       Perl_hmq = 0;
+       /* Try morphing back from a PM application. */
+       if (pib->pib_ultype == 3)               /* 3 is PM */
+           pib->pib_ultype = Perl_os2_initial_mode;
+       else
+           warn("Unexpected program mode %d when morphing back from PM",
+                pib->pib_ultype);
+    }
+}
+
 extern void dlopen();
 void *fakedl = &dlopen;                /* Pull in dynaloading part. */
 
@@ -1066,6 +1543,206 @@ void *fakedl = &dlopen;         /* Pull in dynaloading part. */
 #define sys_chdir(p) (chdir(p) == 0)
 #define change_drive(d) (_chdrive(d), (current_drive() == toupper(d)))
 
+static int DOS_harderr_state = -1;    
+
+XS(XS_OS2_Error)
+{
+    dXSARGS;
+    if (items != 2)
+       croak("Usage: OS2::Error(harderr, exception)");
+    {
+       int     arg1 = SvIV(ST(0));
+       int     arg2 = SvIV(ST(1));
+       int     a = ((arg1 ? FERR_ENABLEHARDERR : FERR_DISABLEHARDERR)
+                    | (arg2 ? FERR_ENABLEEXCEPTION : FERR_DISABLEEXCEPTION));
+       int     RETVAL = ((arg1 ? 1 : 0) | (arg2 ? 2 : 0));
+       unsigned long rc;
+
+       if (CheckOSError(DosError(a)))
+           croak("DosError(%d) failed", a);
+       ST(0) = sv_newmortal();
+       if (DOS_harderr_state >= 0)
+           sv_setiv(ST(0), DOS_harderr_state);
+       DOS_harderr_state = RETVAL;
+    }
+    XSRETURN(1);
+}
+
+static signed char DOS_suppression_state = -1;    
+
+XS(XS_OS2_Errors2Drive)
+{
+    dXSARGS;
+    if (items != 1)
+       croak("Usage: OS2::Errors2Drive(drive)");
+    {
+       STRLEN n_a;
+       SV  *sv = ST(0);
+       int     suppress = SvOK(sv);
+       char    *s = suppress ? SvPV(sv, n_a) : NULL;
+       char    drive = (s ? *s : 0);
+       unsigned long rc;
+
+       if (suppress && !isALPHA(drive))
+           croak("Non-char argument '%c' to OS2::Errors2Drive()", drive);
+       if (CheckOSError(DosSuppressPopUps((suppress
+                                           ? SPU_ENABLESUPPRESSION 
+                                           : SPU_DISABLESUPPRESSION),
+                                          drive)))
+           croak("DosSuppressPopUps(%c) failed", drive);
+       ST(0) = sv_newmortal();
+       if (DOS_suppression_state > 0)
+           sv_setpvn(ST(0), &DOS_suppression_state, 1);
+       else if (DOS_suppression_state == 0)
+           sv_setpvn(ST(0), "", 0);
+       DOS_suppression_state = drive;
+    }
+    XSRETURN(1);
+}
+
+static const char * const si_fields[QSV_MAX] = {
+  "MAX_PATH_LENGTH",
+  "MAX_TEXT_SESSIONS",
+  "MAX_PM_SESSIONS",
+  "MAX_VDM_SESSIONS",
+  "BOOT_DRIVE",
+  "DYN_PRI_VARIATION",
+  "MAX_WAIT",
+  "MIN_SLICE",
+  "MAX_SLICE",
+  "PAGE_SIZE",
+  "VERSION_MAJOR",
+  "VERSION_MINOR",
+  "VERSION_REVISION",
+  "MS_COUNT",
+  "TIME_LOW",
+  "TIME_HIGH",
+  "TOTPHYSMEM",
+  "TOTRESMEM",
+  "TOTAVAILMEM",
+  "MAXPRMEM",
+  "MAXSHMEM",
+  "TIMER_INTERVAL",
+  "MAX_COMP_LENGTH",
+  "FOREGROUND_FS_SESSION",
+  "FOREGROUND_PROCESS"
+};
+
+XS(XS_OS2_SysInfo)
+{
+    dXSARGS;
+    if (items != 0)
+       croak("Usage: OS2::SysInfo()");
+    {
+       ULONG   si[QSV_MAX] = {0};      /* System Information Data Buffer */
+       APIRET  rc      = NO_ERROR;     /* Return code            */
+       int i = 0, j = 0;
+
+       if (CheckOSError(DosQuerySysInfo(1L, /* Request all available system */
+                                        QSV_MAX, /* information */
+                                        (PVOID)si,
+                                        sizeof(si))))
+           croak("DosQuerySysInfo() failed");
+       EXTEND(SP,2*QSV_MAX);
+       while (i < QSV_MAX) {
+           ST(j) = sv_newmortal();
+           sv_setpv(ST(j++), si_fields[i]);
+           ST(j) = sv_newmortal();
+           sv_setiv(ST(j++), si[i]);
+           i++;
+       }
+    }
+    XSRETURN(2 * QSV_MAX);
+}
+
+XS(XS_OS2_BootDrive)
+{
+    dXSARGS;
+    if (items != 0)
+       croak("Usage: OS2::BootDrive()");
+    {
+       ULONG   si[1] = {0};    /* System Information Data Buffer */
+       APIRET  rc    = NO_ERROR;       /* Return code            */
+       char c;
+       
+       if (CheckOSError(DosQuerySysInfo(QSV_BOOT_DRIVE, QSV_BOOT_DRIVE,
+                                        (PVOID)si, sizeof(si))))
+           croak("DosQuerySysInfo() failed");
+       ST(0) = sv_newmortal();
+       c = 'a' - 1 + si[0];
+       sv_setpvn(ST(0), &c, 1);
+    }
+    XSRETURN(1);
+}
+
+XS(XS_OS2_MorphPM)
+{
+    dXSARGS;
+    if (items != 1)
+       croak("Usage: OS2::MorphPM(serve)");
+    {
+       bool  serve = SvOK(ST(0));
+       unsigned long   pmq = perl_hmq_GET(serve);
+
+       ST(0) = sv_newmortal();
+       sv_setiv(ST(0), pmq);
+    }
+    XSRETURN(1);
+}
+
+XS(XS_OS2_UnMorphPM)
+{
+    dXSARGS;
+    if (items != 1)
+       croak("Usage: OS2::UnMorphPM(serve)");
+    {
+       bool  serve = SvOK(ST(0));
+
+       perl_hmq_UNSET(serve);
+    }
+    XSRETURN(0);
+}
+
+XS(XS_OS2_Serve_Messages)
+{
+    dXSARGS;
+    if (items != 1)
+       croak("Usage: OS2::Serve_Messages(force)");
+    {
+       bool  force = SvOK(ST(0));
+       unsigned long   cnt = Perl_Serve_Messages(force);
+
+       ST(0) = sv_newmortal();
+       sv_setiv(ST(0), cnt);
+    }
+    XSRETURN(1);
+}
+
+XS(XS_OS2_Process_Messages)
+{
+    dXSARGS;
+    if (items < 1 || items > 2)
+       croak("Usage: OS2::Process_Messages(force [, cnt])");
+    {
+       bool  force = SvOK(ST(0));
+       unsigned long   cnt;
+       I32 *cntp = NULL;
+
+       if (items == 2) {
+           SV *sv = ST(1);
+           int fake = SvIV(sv);        /* Force SvIVX */
+           
+           if (!SvIOK(sv))
+               croak("Can't upgrade count to IV");
+           cntp = &SvIVX(sv);
+       }
+       cnt =  Perl_Process_Messages(force, cntp);
+       ST(0) = sv_newmortal();
+       sv_setiv(ST(0), cnt);
+    }
+    XSRETURN(1);
+}
+
 XS(XS_Cwd_current_drive)
 {
     dXSARGS;
@@ -1087,7 +1764,8 @@ XS(XS_Cwd_sys_chdir)
     if (items != 1)
        croak("Usage: Cwd::sys_chdir(path)");
     {
-       char *  path = (char *)SvPV(ST(0),na);
+       STRLEN n_a;
+       char *  path = (char *)SvPV(ST(0),n_a);
        bool    RETVAL;
 
        RETVAL = sys_chdir(path);
@@ -1103,7 +1781,8 @@ XS(XS_Cwd_change_drive)
     if (items != 1)
        croak("Usage: Cwd::change_drive(d)");
     {
-       char    d = (char)*SvPV(ST(0),na);
+       STRLEN n_a;
+       char    d = (char)*SvPV(ST(0),n_a);
        bool    RETVAL;
 
        RETVAL = change_drive(d);
@@ -1119,7 +1798,8 @@ XS(XS_Cwd_sys_is_absolute)
     if (items != 1)
        croak("Usage: Cwd::sys_is_absolute(path)");
     {
-       char *  path = (char *)SvPV(ST(0),na);
+       STRLEN n_a;
+       char *  path = (char *)SvPV(ST(0),n_a);
        bool    RETVAL;
 
        RETVAL = sys_is_absolute(path);
@@ -1135,7 +1815,8 @@ XS(XS_Cwd_sys_is_rooted)
     if (items != 1)
        croak("Usage: Cwd::sys_is_rooted(path)");
     {
-       char *  path = (char *)SvPV(ST(0),na);
+       STRLEN n_a;
+       char *  path = (char *)SvPV(ST(0),n_a);
        bool    RETVAL;
 
        RETVAL = sys_is_rooted(path);
@@ -1151,7 +1832,8 @@ XS(XS_Cwd_sys_is_relative)
     if (items != 1)
        croak("Usage: Cwd::sys_is_relative(path)");
     {
-       char *  path = (char *)SvPV(ST(0),na);
+       STRLEN n_a;
+       char *  path = (char *)SvPV(ST(0),n_a);
        bool    RETVAL;
 
        RETVAL = sys_is_relative(path);
@@ -1182,7 +1864,8 @@ XS(XS_Cwd_sys_abspath)
     if (items < 1 || items > 2)
        croak("Usage: Cwd::sys_abspath(path, dir = NULL)");
     {
-       char *  path = (char *)SvPV(ST(0),na);
+       STRLEN n_a;
+       char *  path = (char *)SvPV(ST(0),n_a);
        char *  dir;
        char p[MAXPATHLEN];
        char *  RETVAL;
@@ -1190,7 +1873,7 @@ XS(XS_Cwd_sys_abspath)
        if (items < 2)
            dir = NULL;
        else {
-           dir = (char *)SvPV(ST(1),na);
+           dir = (char *)SvPV(ST(1),n_a);
        }
        if (path[0] == '.' && (path[1] == '/' || path[1] == '\\')) {
            path += 2;
@@ -1287,7 +1970,7 @@ typedef APIRET (*PELP)(PSZ path, ULONG type);
 APIRET
 ExtLIBPATH(ULONG ord, PSZ path, ULONG type)
 {
-    loadByOrd(ord);                    /* Guarantied to load or die! */
+    loadByOrd("doscalls",ord);         /* Guarantied to load or die! */
     return (*(PELP)ExtFCN[ord])(path, type);
 }
 
@@ -1330,7 +2013,8 @@ XS(XS_Cwd_extLibpath_set)
     if (items < 1 || items > 2)
        croak("Usage: Cwd::extLibpath_set(s, type = 0)");
     {
-       char *  s = (char *)SvPV(ST(0),na);
+       STRLEN n_a;
+       char *  s = (char *)SvPV(ST(0),n_a);
        bool    type;
        U32     rc;
        bool    RETVAL;
@@ -1360,6 +2044,14 @@ Xs_OS2_init()
             newXS("Cwd::extLibpath", XS_Cwd_extLibpath, file);
             newXS("Cwd::extLibpath_set", XS_Cwd_extLibpath_set, file);
        }
+        newXS("OS2::Error", XS_OS2_Error, file);
+        newXS("OS2::Errors2Drive", XS_OS2_Errors2Drive, file);
+        newXS("OS2::SysInfo", XS_OS2_SysInfo, file);
+        newXS("OS2::BootDrive", XS_OS2_BootDrive, file);
+        newXS("OS2::MorphPM", XS_OS2_MorphPM, file);
+        newXS("OS2::UnMorphPM", XS_OS2_UnMorphPM, file);
+        newXS("OS2::Serve_Messages", XS_OS2_Serve_Messages, file);
+        newXS("OS2::Process_Messages", XS_OS2_Process_Messages, file);
         newXS("DynaLoader::mod2fname", XS_DynaLoader_mod2fname, file);
         newXS("Cwd::current_drive", XS_Cwd_current_drive, file);
         newXS("Cwd::sys_chdir", XS_Cwd_sys_chdir, file);
@@ -1374,6 +2066,17 @@ Xs_OS2_init()
 #ifdef PERL_IS_AOUT
        sv_setiv(GvSV(gv), 1);
 #endif 
+       gv = gv_fetchpv("OS2::emx_rev", TRUE, SVt_PV);
+       GvMULTI_on(gv);
+       sv_setiv(GvSV(gv), _emx_rev);
+       sv_setpv(GvSV(gv), _emx_vprt);
+       SvIOK_on(GvSV(gv));
+       gv = gv_fetchpv("OS2::emx_env", TRUE, SVt_PV);
+       GvMULTI_on(gv);
+       sv_setiv(GvSV(gv), _emx_env);
+       gv = gv_fetchpv("OS2::os_ver", TRUE, SVt_PV);
+       GvMULTI_on(gv);
+       sv_setnv(GvSV(gv), _osmajor + 0.001 * _osminor);
     }
 }
 
@@ -1387,26 +2090,28 @@ Perl_OS2_init(char **env)
     MALLOC_INIT;
     settmppath();
     OS2_Perl_data.xs_init = &Xs_OS2_init;
-    if (environ == NULL) {
+    _uflags (_UF_SBRK_MODEL, _UF_SBRK_ARBITRARY);
+    if (environ == NULL && env) {
        environ = env;
     }
     if ( (shell = getenv("PERL_SH_DRIVE")) ) {
-       New(1304, sh_path, strlen(SH_PATH) + 1, char);
-       strcpy(sh_path, SH_PATH);
-       sh_path[0] = shell[0];
+       New(1304, PL_sh_path, strlen(SH_PATH) + 1, char);
+       strcpy(PL_sh_path, SH_PATH);
+       PL_sh_path[0] = shell[0];
     } else if ( (shell = getenv("PERL_SH_DIR")) ) {
        int l = strlen(shell), i;
        if (shell[l-1] == '/' || shell[l-1] == '\\') {
            l--;
        }
-       New(1304, sh_path, l + 8, char);
-       strncpy(sh_path, shell, l);
-       strcpy(sh_path + l, "/sh.exe");
+       New(1304, PL_sh_path, l + 8, char);
+       strncpy(PL_sh_path, shell, l);
+       strcpy(PL_sh_path + l, "/sh.exe");
        for (i = 0; i < l; i++) {
-           if (sh_path[i] == '\\') sh_path[i] = '/';
+           if (PL_sh_path[i] == '\\') PL_sh_path[i] = '/';
        }
     }
     MUTEX_INIT(&start_thread_mutex);
+    os2_mytype = my_type();            /* Do it before morphing.  Needed? */
 }
 
 #undef tmpnam