[no reason given] is not good.
[p5sagit/p5-mst-13.2.git] / perlio.c
index 638a1be..2c9e7a8 100644 (file)
--- a/perlio.c
+++ b/perlio.c
 
 #include "XSUB.h"
 
-#undef PerlMemShared_calloc
-#define PerlMemShared_calloc(x,y) calloc(x,y)
-#undef PerlMemShared_free
-#define PerlMemShared_free(x) free(x)
-
 int
 perlsio_binmode(FILE *fp, int iotype, int mode)
 {
@@ -99,6 +94,55 @@ perlsio_binmode(FILE *fp, int iotype, int mode)
 #endif
 }
 
+#ifndef O_ACCMODE
+#define O_ACCMODE 3            /* Assume traditional implementation */
+#endif
+
+int
+PerlIO_intmode2str(int rawmode, char *mode, int *writing)
+{
+    int result = rawmode & O_ACCMODE;
+    int ix = 0;
+    int ptype;
+    switch (result) {
+    case O_RDONLY:
+       ptype = IoTYPE_RDONLY;
+       break;
+    case O_WRONLY:
+       ptype = IoTYPE_WRONLY;
+       break;
+    case O_RDWR:
+    default:
+       ptype = IoTYPE_RDWR;
+       break;
+    }
+    if (writing)
+       *writing = (result != O_RDONLY);
+
+    if (result == O_RDONLY) {
+       mode[ix++] = 'r';
+    }
+#ifdef O_APPEND
+    else if (rawmode & O_APPEND) {
+       mode[ix++] = 'a';
+       if (result != O_WRONLY)
+           mode[ix++] = '+';
+    }
+#endif
+    else {
+       if (result == O_WRONLY)
+           mode[ix++] = 'w';
+       else {
+           mode[ix++] = 'r';
+           mode[ix++] = '+';
+       }
+    }
+    if (rawmode & O_BINARY)
+       mode[ix++] = 'b';
+    mode[ix] = '\0';
+    return ptype;
+}
+
 #ifndef PERLIO_LAYERS
 int
 PerlIO_apply_layers(pTHX_ PerlIO *f, const char *mode, const char *names)
@@ -128,6 +172,27 @@ PerlIO_binmode(pTHX_ PerlIO *fp, int iotype, int mode, const char *names)
 #endif
 }
 
+PerlIO *
+PerlIO_fdupopen(pTHX_ PerlIO *f, CLONE_PARAMS *param)
+{
+    if (f) {
+       int fd = PerlLIO_dup(PerlIO_fileno(f));
+       if (fd >= 0) {
+           char mode[8];
+           int omode = fcntl(fd, F_GETFL);
+           PerlIO_intmode2str(omode,mode,NULL);
+           /* the r+ is a hack */
+           return PerlIO_fdopen(fd, mode);
+       }
+       return NULL;
+    }
+    else {
+       SETERRNO(EBADF, SS$_IVCHAN);
+    }
+    return NULL;
+}
+
+
 /*
  * De-mux PerlIO_openn() into fdopen, freopen and fopen type entries
  */
@@ -186,7 +251,7 @@ Perl_boot_core_PerlIO(pTHX)
 #ifdef PERLIO_IS_STDIO
 
 void
-PerlIO_init(void)
+PerlIO_init(pTHX)
 {
     /*
      * Does nothing (yet) except force this file to be included in perl
@@ -223,7 +288,7 @@ PerlIO_tmpfile(void)
 }
 
 void
-PerlIO_init(void)
+PerlIO_init(pTHX)
 {
     /*
      * Force this file to be included in perl binary. Which allows this
@@ -340,11 +405,8 @@ PerlIO_debug(const char *fmt, ...)
 /*
  * Table of pointers to the PerlIO structs (malloc'ed)
  */
-PerlIO *_perlio = NULL;
 #define PERLIO_TABLE_SIZE 64
 
-
-
 PerlIO *
 PerlIO_allocate(pTHX)
 {
@@ -353,7 +415,7 @@ PerlIO_allocate(pTHX)
      */
     PerlIO **last;
     PerlIO *f;
-    last = &_perlio;
+    last = &PL_perlio;
     while ((f = *last)) {
        int i;
        last = (PerlIO **) (f);
@@ -363,7 +425,7 @@ PerlIO_allocate(pTHX)
            }
        }
     }
-    f = PerlMemShared_calloc(PERLIO_TABLE_SIZE, sizeof(PerlIO));
+    Newz('I',f,PERLIO_TABLE_SIZE,PerlIO);
     if (!f) {
        return NULL;
     }
@@ -371,6 +433,23 @@ PerlIO_allocate(pTHX)
     return f + 1;
 }
 
+#undef PerlIO_fdupopen
+PerlIO *
+PerlIO_fdupopen(pTHX_ PerlIO *f, CLONE_PARAMS *param)
+{
+    if (f && *f) {
+       PerlIO_funcs *tab = PerlIOBase(f)->tab;
+       PerlIO *new;
+       PerlIO_debug("fdupopen f=%p param=%p\n",f,param);
+        new = (*tab->Dup)(aTHX_ PerlIO_allocate(aTHX),f,param);
+       return new;
+    }
+    else {
+       SETERRNO(EBADF, SS$_IVCHAN);
+       return NULL;
+    }
+}
+
 void
 PerlIO_cleantable(pTHX_ PerlIO **tablep)
 {
@@ -384,16 +463,14 @@ PerlIO_cleantable(pTHX_ PerlIO **tablep)
                PerlIO_close(f);
            }
        }
-       PerlMemShared_free(table);
+       Safefree(table);
        *tablep = NULL;
     }
 }
 
-PerlIO_list_t *PerlIO_known_layers;
-PerlIO_list_t *PerlIO_def_layerlist;
 
 PerlIO_list_t *
-PerlIO_list_alloc(void)
+PerlIO_list_alloc(pTHX)
 {
     PerlIO_list_t *list;
     Newz('L', list, 1, PerlIO_list_t);
@@ -402,12 +479,11 @@ PerlIO_list_alloc(void)
 }
 
 void
-PerlIO_list_free(PerlIO_list_t *list)
+PerlIO_list_free(pTHX_ PerlIO_list_t *list)
 {
     if (list) {
        if (--list->refcnt == 0) {
            if (list->array) {
-               dTHX;
                IV i;
                for (i = 0; i < list->cur; i++) {
                    if (list->array[i].arg)
@@ -421,9 +497,8 @@ PerlIO_list_free(PerlIO_list_t *list)
 }
 
 void
-PerlIO_list_push(PerlIO_list_t *list, PerlIO_funcs *funcs, SV *arg)
+PerlIO_list_push(pTHX_ PerlIO_list_t *list, PerlIO_funcs *funcs, SV *arg)
 {
-    dTHX;
     PerlIO_pair_t *p;
     if (list->cur >= list->len) {
        list->len += 8;
@@ -439,27 +514,53 @@ PerlIO_list_push(PerlIO_list_t *list, PerlIO_funcs *funcs, SV *arg)
     }
 }
 
+PerlIO_list_t *
+PerlIO_clone_list(pTHX_ PerlIO_list_t *proto, CLONE_PARAMS *param)
+{
+    int i;
+    PerlIO_list_t *list = PerlIO_list_alloc(aTHX);
+    for (i=0; i < proto->cur; i++) {
+       SV *arg = Nullsv;
+       if (proto->array[i].arg)
+           arg = PerlIO_sv_dup(aTHX_ proto->array[i].arg,param);
+       PerlIO_list_push(aTHX_ list, proto->array[i].funcs, arg);
+    }
+    return list;
+}
 
 void
-PerlIO_cleanup_layers(pTHX_ void *data)
+PerlIO_clone(pTHX_ PerlInterpreter *proto, CLONE_PARAMS *param)
 {
-#if 0
-    PerlIO_known_layers = Nullhv;
-    PerlIO_def_layerlist = Nullav;
+#ifdef USE_ITHREADS
+    PerlIO **table = &proto->Iperlio;
+    PerlIO *f;
+    PL_perlio = NULL;
+    PL_known_layers = PerlIO_clone_list(aTHX_ proto->Iknown_layers, param);
+    PL_def_layerlist = PerlIO_clone_list(aTHX_ proto->Idef_layerlist, param);
+    PerlIO_allocate(aTHX); /* root slot is never used */
+    while ((f = *table)) {
+           int i;
+           table = (PerlIO **) (f++);
+           for (i = 1; i < PERLIO_TABLE_SIZE; i++) {
+               if (*f) {
+                   PerlIO_fdupopen(aTHX_ f, param);
+               }
+               f++;
+           }
+       }
 #endif
 }
 
 void
-PerlIO_cleanup()
+PerlIO_cleanup(pTHX)
 {
-    dTHX;
-    PerlIO_cleantable(aTHX_ & _perlio);
+    PerlIO_cleantable(aTHX_ &PL_perlio);
 }
 
 void
 PerlIO_destruct(pTHX)
 {
-    PerlIO **table = &_perlio;
+    PerlIO **table = &PL_perlio;
     PerlIO *f;
     while ((f = *table)) {
        int i;
@@ -480,6 +581,10 @@ PerlIO_destruct(pTHX)
            f++;
        }
     }
+    PerlIO_list_free(aTHX_ PL_known_layers);
+    PL_known_layers = NULL;
+    PerlIO_list_free(aTHX_ PL_def_layerlist);
+    PL_def_layerlist = NULL;
 }
 
 void
@@ -498,7 +603,7 @@ PerlIO_pop(pTHX_ PerlIO *f)
                return;
        }
        *f = l->next;;
-       PerlMemShared_free(l);
+       Safefree(l);
     }
 }
 
@@ -513,15 +618,15 @@ PerlIO_find_layer(pTHX_ const char *name, STRLEN len, int load)
     IV i;
     if ((SSize_t) len <= 0)
        len = strlen(name);
-    for (i = 0; i < PerlIO_known_layers->cur; i++) {
-       PerlIO_funcs *f = PerlIO_known_layers->array[i].funcs;
+    for (i = 0; i < PL_known_layers->cur; i++) {
+       PerlIO_funcs *f = PL_known_layers->array[i].funcs;
        if (memEQ(f->name, name, len)) {
            PerlIO_debug("%.*s => %p\n", (int) len, name, f);
            return f;
        }
     }
-    if (load && PL_subname && PerlIO_def_layerlist
-       && PerlIO_def_layerlist->cur >= 2) {
+    if (load && PL_subname && PL_def_layerlist
+       && PL_def_layerlist->cur >= 2) {
        SV *pkgsv = newSVpvn("PerlIO", 6);
        SV *layer = newSVpvn(name, len);
        ENTER;
@@ -644,9 +749,9 @@ XS(XS_PerlIO__Layer__find)
 void
 PerlIO_define_layer(pTHX_ PerlIO_funcs *tab)
 {
-    if (!PerlIO_known_layers)
-       PerlIO_known_layers = PerlIO_list_alloc();
-    PerlIO_list_push(PerlIO_known_layers, tab, Nullsv);
+    if (!PL_known_layers)
+       PL_known_layers = PerlIO_list_alloc(aTHX);
+    PerlIO_list_push(aTHX_ PL_known_layers, tab, Nullsv);
     PerlIO_debug("define %s %p\n", tab->name, tab);
 }
 
@@ -721,7 +826,7 @@ PerlIO_parse_layers(pTHX_ PerlIO_list_t *av, const char *names)
                    PerlIO_funcs *layer =
                        PerlIO_find_layer(aTHX_ s, llen, 1);
                    if (layer) {
-                       PerlIO_list_push(av, layer,
+                       PerlIO_list_push(aTHX_ av, layer,
                                         (as) ? newSVpvn(as,
                                                         alen) :
                                         &PL_sv_undef);
@@ -752,7 +857,7 @@ PerlIO_default_buffer(pTHX_ PerlIO_list_t *av)
        }
     }
     PerlIO_debug("Pushing %s\n", tab->name);
-    PerlIO_list_push(av, PerlIO_find_layer(aTHX_ tab->name, 0, 0),
+    PerlIO_list_push(aTHX_ av, PerlIO_find_layer(aTHX_ tab->name, 0, 0),
                     &PL_sv_undef);
 }
 
@@ -778,10 +883,10 @@ PerlIO_layer_fetch(pTHX_ PerlIO_list_t *av, IV n, PerlIO_funcs *def)
 PerlIO_list_t *
 PerlIO_default_layers(pTHX)
 {
-    if (!PerlIO_def_layerlist) {
+    if (!PL_def_layerlist) {
        const char *s = (PL_tainting) ? Nullch : PerlEnv_getenv("PERLIO");
        PerlIO_funcs *osLayer = &PerlIO_unix;
-       PerlIO_def_layerlist = PerlIO_list_alloc();
+       PL_def_layerlist = PerlIO_list_alloc(aTHX);
        PerlIO_define_layer(aTHX_ & PerlIO_unix);
 #if defined(WIN32) && !defined(UNDER_CE)
        PerlIO_define_layer(aTHX_ & PerlIO_win32);
@@ -798,20 +903,20 @@ PerlIO_default_layers(pTHX)
 #endif
        PerlIO_define_layer(aTHX_ & PerlIO_utf8);
        PerlIO_define_layer(aTHX_ & PerlIO_byte);
-       PerlIO_list_push(PerlIO_def_layerlist,
+       PerlIO_list_push(aTHX_ PL_def_layerlist,
                         PerlIO_find_layer(aTHX_ osLayer->name, 0, 0),
                         &PL_sv_undef);
        if (s) {
-           PerlIO_parse_layers(aTHX_ PerlIO_def_layerlist, s);
+           PerlIO_parse_layers(aTHX_ PL_def_layerlist, s);
        }
        else {
-           PerlIO_default_buffer(aTHX_ PerlIO_def_layerlist);
+           PerlIO_default_buffer(aTHX_ PL_def_layerlist);
        }
     }
-    if (PerlIO_def_layerlist->cur < 2) {
-       PerlIO_default_buffer(aTHX_ PerlIO_def_layerlist);
+    if (PL_def_layerlist->cur < 2) {
+       PerlIO_default_buffer(aTHX_ PL_def_layerlist);
     }
-    return PerlIO_def_layerlist;
+    return PL_def_layerlist;
 }
 
 void
@@ -839,7 +944,7 @@ PerlIO_default_layer(pTHX_ I32 n)
 void
 PerlIO_stdstreams(pTHX)
 {
-    if (!_perlio) {
+    if (!PL_perlio) {
        PerlIO_allocate(aTHX);
        PerlIO_fdopen(0, "Ir" PERLIO_STDTEXT);
        PerlIO_fdopen(1, "Iw" PERLIO_STDTEXT);
@@ -851,7 +956,7 @@ PerlIO *
 PerlIO_push(pTHX_ PerlIO *f, PerlIO_funcs *tab, const char *mode, SV *arg)
 {
     PerlIOl *l = NULL;
-    l = PerlMemShared_calloc(tab->size, sizeof(char));
+    Newc('L',l,tab->size,char,PerlIOl);
     if (l) {
        Zero(l, tab->size, char);
        l->next = *f;
@@ -937,12 +1042,12 @@ PerlIO_apply_layers(pTHX_ PerlIO *f, const char *mode, const char *names)
 {
     int code = 0;
     if (names) {
-       PerlIO_list_t *layers = PerlIO_list_alloc();
+       PerlIO_list_t *layers = PerlIO_list_alloc(aTHX);
        code = PerlIO_parse_layers(aTHX_ layers, names);
        if (code == 0) {
            code = PerlIO_apply_layera(aTHX_ f, mode, layers, 0);
        }
-       PerlIO_list_free(layers);
+       PerlIO_list_free(aTHX_ layers);
     }
     return code;
 }
@@ -981,28 +1086,11 @@ PerlIO__close(PerlIO *f)
     if (f && *f)
        return (*PerlIOBase(f)->tab->Close) (f);
     else {
-       SETERRNO(EBADF, VMS_SS_IVCHAN);
+       SETERRNO(EBADF, SS$_IVCHAN);
        return -1;
     }
 }
 
-#undef PerlIO_fdupopen
-PerlIO *
-PerlIO_fdupopen(pTHX_ PerlIO *f, CLONE_PARAMS *param)
-{
-    if (f && *f) {
-       PerlIO_funcs *tab = PerlIOBase(f)->tab;
-       PerlIO *new;
-       PerlIO_debug("fdupopen f=%p param=%p\n",f,param);
-        new = (*tab->Dup)(aTHX_ PerlIO_allocate(aTHX),f,param);
-       return new;
-    }
-    else {
-       SETERRNO(EBADF, VMS_SS_IVCHAN);
-       return NULL;
-    }
-}
-
 #undef PerlIO_close
 int
 PerlIO_close(PerlIO *f)
@@ -1025,7 +1113,7 @@ PerlIO_fileno(PerlIO *f)
     if (f && *f)
        return (*PerlIOBase(f)->tab->Fileno) (f);
     else {
-       SETERRNO(EBADF, VMS_SS_IVCHAN);
+       SETERRNO(EBADF, SS$_IVCHAN);
        return -1;
     }
 }
@@ -1087,7 +1175,7 @@ PerlIO_resolve_layers(pTHX_ const char *layers,
 {
     PerlIO_list_t *def = PerlIO_default_layers(aTHX);
     int incdef = 1;
-    if (!_perlio)
+    if (!PL_perlio)
        PerlIO_stdstreams(aTHX);
     if (narg) {
        SV *arg = *args;
@@ -1098,8 +1186,8 @@ PerlIO_resolve_layers(pTHX_ const char *layers,
        if (SvROK(arg) && !sv_isobject(arg)) {
            PerlIO_funcs *handler = PerlIO_layer_from_ref(aTHX_ SvRV(arg));
            if (handler) {
-               def = PerlIO_list_alloc();
-               PerlIO_list_push(def, handler, &PL_sv_undef);
+               def = PerlIO_list_alloc(aTHX);
+               PerlIO_list_push(aTHX_ def, handler, &PL_sv_undef);
                incdef = 0;
            }
            /*
@@ -1115,9 +1203,9 @@ PerlIO_resolve_layers(pTHX_ const char *layers,
        PerlIO_list_t *av;
        if (incdef) {
            IV i = def->cur;
-           av = PerlIO_list_alloc();
+           av = PerlIO_list_alloc(aTHX);
            for (i = 0; i < def->cur; i++) {
-               PerlIO_list_push(av, def->array[i].funcs,
+               PerlIO_list_push(aTHX_ av, def->array[i].funcs,
                                 def->array[i].arg);
            }
        }
@@ -1156,12 +1244,12 @@ PerlIO_openn(pTHX_ const char *layers, const char *mode, int fd,
             * yet
             */
            PerlIOl *l = *f;
-           layera = PerlIO_list_alloc();
+           layera = PerlIO_list_alloc(aTHX);
            while (l) {
                SV *arg =
                    (l->tab->Getarg) ? (*l->tab->
                                        Getarg) (&l) : &PL_sv_undef;
-               PerlIO_list_push(layera, l->tab, arg);
+               PerlIO_list_push(aTHX_ layera, l->tab, arg);
                l = *PerlIONext(&l);
            }
        }
@@ -1202,7 +1290,7 @@ PerlIO_openn(pTHX_ const char *layers, const char *mode, int fd,
                }
            }
        }
-       PerlIO_list_free(layera);
+       PerlIO_list_free(aTHX_ layera);
     }
     return f;
 }
@@ -1241,7 +1329,7 @@ PerlIO_read(PerlIO *f, void *vbuf, Size_t count)
     if (f && *f)
        return (*PerlIOBase(f)->tab->Read) (f, vbuf, count);
     else {
-       SETERRNO(EBADF, VMS_SS_IVCHAN);
+       SETERRNO(EBADF, SS$_IVCHAN);
        return -1;
     }
 }
@@ -1253,7 +1341,7 @@ PerlIO_unread(PerlIO *f, const void *vbuf, Size_t count)
     if (f && *f)
        return (*PerlIOBase(f)->tab->Unread) (f, vbuf, count);
     else {
-       SETERRNO(EBADF, VMS_SS_IVCHAN);
+       SETERRNO(EBADF, SS$_IVCHAN);
        return -1;
     }
 }
@@ -1265,7 +1353,7 @@ PerlIO_write(PerlIO *f, const void *vbuf, Size_t count)
     if (f && *f)
        return (*PerlIOBase(f)->tab->Write) (f, vbuf, count);
     else {
-       SETERRNO(EBADF, VMS_SS_IVCHAN);
+       SETERRNO(EBADF, SS$_IVCHAN);
        return -1;
     }
 }
@@ -1277,7 +1365,7 @@ PerlIO_seek(PerlIO *f, Off_t offset, int whence)
     if (f && *f)
        return (*PerlIOBase(f)->tab->Seek) (f, offset, whence);
     else {
-       SETERRNO(EBADF, VMS_SS_IVCHAN);
+       SETERRNO(EBADF, SS$_IVCHAN);
        return -1;
     }
 }
@@ -1289,7 +1377,7 @@ PerlIO_tell(PerlIO *f)
     if (f && *f)
        return (*PerlIOBase(f)->tab->Tell) (f);
     else {
-       SETERRNO(EBADF, VMS_SS_IVCHAN);
+       SETERRNO(EBADF, SS$_IVCHAN);
        return -1;
     }
 }
@@ -1306,13 +1394,13 @@ PerlIO_flush(PerlIO *f)
            }
            else {
                PerlIO_debug("Cannot flush f=%p :%s\n", f, tab->name);
-               SETERRNO(EBADF, VMS_SS_IVCHAN);
+               SETERRNO(EBADF, SS$_IVCHAN);
                return -1;
            }
        }
        else {
            PerlIO_debug("Cannot flush f=%p\n", f);
-           SETERRNO(EBADF, VMS_SS_IVCHAN);
+           SETERRNO(EBADF, SS$_IVCHAN);
            return -1;
        }
     }
@@ -1324,7 +1412,8 @@ PerlIO_flush(PerlIO *f)
         * things on fflush(NULL), but should we be bound by their design
         * decisions? --jhi
         */
-       PerlIO **table = &_perlio;
+       dTHX;
+       PerlIO **table = &PL_perlio;
        int code = 0;
        while ((f = *table)) {
            int i;
@@ -1342,7 +1431,8 @@ PerlIO_flush(PerlIO *f)
 void
 PerlIOBase_flush_linebuf()
 {
-    PerlIO **table = &_perlio;
+    dTHX;
+    PerlIO **table = &PL_perlio;
     PerlIO *f;
     while ((f = *table)) {
        int i;
@@ -1365,7 +1455,7 @@ PerlIO_fill(PerlIO *f)
     if (f && *f)
        return (*PerlIOBase(f)->tab->Fill) (f);
     else {
-       SETERRNO(EBADF, VMS_SS_IVCHAN);
+       SETERRNO(EBADF, SS$_IVCHAN);
        return -1;
     }
 }
@@ -1377,7 +1467,7 @@ PerlIO_isutf8(PerlIO *f)
     if (f && *f)
        return (PerlIOBase(f)->flags & PERLIO_F_UTF8) != 0;
     else {
-       SETERRNO(EBADF, VMS_SS_IVCHAN);
+       SETERRNO(EBADF, SS$_IVCHAN);
        return -1;
     }
 }
@@ -1389,7 +1479,7 @@ PerlIO_eof(PerlIO *f)
     if (f && *f)
        return (*PerlIOBase(f)->tab->Eof) (f);
     else {
-       SETERRNO(EBADF, VMS_SS_IVCHAN);
+       SETERRNO(EBADF, SS$_IVCHAN);
        return -1;
     }
 }
@@ -1401,7 +1491,7 @@ PerlIO_error(PerlIO *f)
     if (f && *f)
        return (*PerlIOBase(f)->tab->Error) (f);
     else {
-       SETERRNO(EBADF, VMS_SS_IVCHAN);
+       SETERRNO(EBADF, SS$_IVCHAN);
        return -1;
     }
 }
@@ -1413,7 +1503,7 @@ PerlIO_clearerr(PerlIO *f)
     if (f && *f)
        (*PerlIOBase(f)->tab->Clearerr) (f);
     else
-       SETERRNO(EBADF, VMS_SS_IVCHAN);
+       SETERRNO(EBADF, SS$_IVCHAN);
 }
 
 #undef PerlIO_setlinebuf
@@ -1423,7 +1513,7 @@ PerlIO_setlinebuf(PerlIO *f)
     if (f && *f)
        (*PerlIOBase(f)->tab->Setlinebuf) (f);
     else
-       SETERRNO(EBADF, VMS_SS_IVCHAN);
+       SETERRNO(EBADF, SS$_IVCHAN);
 }
 
 #undef PerlIO_has_base
@@ -1709,7 +1799,7 @@ PerlIOBase_pushed(PerlIO *f, const char *mode, SV *arg)
            l->flags |= PERLIO_F_TRUNCATE | PERLIO_F_CANWRITE;
            break;
        default:
-           SETERRNO(EINVAL, VMS_LIB_INVARG);
+           SETERRNO(EINVAL, LIB$_INVARG);
            return -1;
        }
        while (*mode) {
@@ -1724,7 +1814,7 @@ PerlIOBase_pushed(PerlIO *f, const char *mode, SV *arg)
                l->flags |= PERLIO_F_CRLF;
                break;
            default:
-               SETERRNO(EINVAL, VMS_LIB_INVARG);
+               SETERRNO(EINVAL, LIB$_INVARG);
                return -1;
            }
        }
@@ -1918,7 +2008,7 @@ PerlIOUnix_oflags(const char *mode)
      */
     oflags |= O_BINARY;
     if (*mode || oflags == -1) {
-       SETERRNO(EINVAL, VMS_LIB_INVARG);
+       SETERRNO(EINVAL, LIB$_INVARG);
        oflags = -1;
     }
     return oflags;
@@ -2993,7 +3083,7 @@ PerlIOBuf_close(PerlIO *f)
     IV code = PerlIOBase_close(f);
     PerlIOBuf *b = PerlIOSelf(f, PerlIOBuf);
     if (b->buf && b->buf != (STDCHAR *) & b->oneword) {
-       PerlMemShared_free(b->buf);
+       Safefree(b->buf);
     }
     b->buf = NULL;
     b->ptr = b->end = b->buf;
@@ -3028,7 +3118,8 @@ PerlIOBuf_get_base(PerlIO *f)
     if (!b->buf) {
        if (!b->bufsiz)
            b->bufsiz = 4096;
-       b->buf = PerlMemShared_calloc(b->bufsiz, sizeof(STDCHAR));
+       b->buf =
+       Newz('B',b->buf,b->bufsiz, STDCHAR);
        if (!b->buf) {
            b->buf = (STDCHAR *) & b->oneword;
            b->bufsiz = sizeof(b->oneword);
@@ -3142,7 +3233,7 @@ PerlIOPending_flush(PerlIO *f)
     dTHX;
     PerlIOBuf *b = PerlIOSelf(f, PerlIOBuf);
     if (b->buf && b->buf != (STDCHAR *) & b->oneword) {
-       PerlMemShared_free(b->buf);
+       Safefree(b->buf);
        b->buf = NULL;
     }
     PerlIO_pop(aTHX_ f);
@@ -3548,7 +3639,7 @@ PerlIOMmap_map(PerlIO *f)
                if (!page_size) {
 #if defined(HAS_SYSCONF) && (defined(_SC_PAGESIZE) || defined(_SC_PAGE_SIZE))
                    {
-                       SETERRNO(0, VMS_SS_NORMAL);
+                       SETERRNO(0, SS$_NORMAL);
 #   ifdef _SC_PAGESIZE
                        page_size = sysconf(_SC_PAGESIZE);
 #   else
@@ -3830,50 +3921,42 @@ PerlIO_funcs PerlIO_mmap = {
 #endif                         /* HAS_MMAP */
 
 void
-PerlIO_init(void)
+PerlIO_init(pTHX)
 {
-    dTHX;
-#ifndef WIN32
-    call_atexit(PerlIO_cleanup_layers, NULL);
-#endif
-    if (!_perlio) {
-#ifndef WIN32
-       atexit(&PerlIO_cleanup);
-#endif
-    }
+ /* Place holder for stdstreams call ??? */
 }
 
 #undef PerlIO_stdin
 PerlIO *
 PerlIO_stdin(void)
 {
-    if (!_perlio) {
-       dTHX;
+    dTHX;
+    if (!PL_perlio) {
        PerlIO_stdstreams(aTHX);
     }
-    return &_perlio[1];
+    return &PL_perlio[1];
 }
 
 #undef PerlIO_stdout
 PerlIO *
 PerlIO_stdout(void)
 {
-    if (!_perlio) {
-       dTHX;
+    dTHX;
+    if (!PL_perlio) {
        PerlIO_stdstreams(aTHX);
     }
-    return &_perlio[2];
+    return &PL_perlio[2];
 }
 
 #undef PerlIO_stderr
 PerlIO *
 PerlIO_stderr(void)
 {
-    if (!_perlio) {
-       dTHX;
+    dTHX;
+    if (!PL_perlio) {
        PerlIO_stdstreams(aTHX);
     }
-    return &_perlio[3];
+    return &PL_perlio[3];
 }
 
 /*--------------------------------------------------------------------------------------*/
@@ -4055,7 +4138,7 @@ PerlIO_setpos(PerlIO *f, SV *pos)
        if (f && len == sizeof(Off_t))
            return PerlIO_seek(f, *posn, SEEK_SET);
     }
-    SETERRNO(EINVAL, VMS_SS_IVCHAN);
+    SETERRNO(EINVAL, SS$_IVCHAN);
     return -1;
 }
 #else
@@ -4075,7 +4158,7 @@ PerlIO_setpos(PerlIO *f, SV *pos)
 #endif
        }
     }
-    SETERRNO(EINVAL, VMS_SS_IVCHAN);
+    SETERRNO(EINVAL, SS$_IVCHAN);
     return -1;
 }
 #endif
@@ -4157,3 +4240,4 @@ PerlIO_sprintf(char *s, int n, const char *fmt, ...)
     return result;
 }
 #endif
+