win32/win32io.c

   1
   2 #ifdef __cplusplus
   3 extern "C" {
   4 #endif
   5
   6 #define WIN32_LEAN_AND_MEAN
   7 #define WIN32IO_IS_STDIO
   8 #define EXT
   9 #include <windows.h>
  10 #include <stdio.h>
  11 #include <stdlib.h>
  12 #include <io.h>
  13 #include <sys/stat.h>
  14 #include <sys/socket.h>
  15 #include <fcntl.h>
  16 #include <assert.h>
  17 #include <errno.h>
  18 #include <process.h>
  19 #include <direct.h>
  20 #include "win32iop.h"
  21
  22 /*
  23  * The following is just a basic wrapping of the stdio
  24  *
  25  *  redirected io subsystem for all XS modules
  26  */
  27
  28 static int *
  29 dummy_errno(void)
  30 {
  31     return (&(errno));
  32 }
  33
  34 static char ***
  35 dummy_environ(void)
  36 {
  37     return (&(_environ));
  38 }
  39
  40 /* the rest are the remapped stdio routines */
  41 static FILE *
  42 dummy_stderr(void)
  43 {
  44     return stderr;
  45 }
  46
  47 static FILE *
  48 dummy_stdin(void)
  49 {
  50     return stdin;
  51 }
  52
  53 static FILE *
  54 dummy_stdout(void)
  55 {
  56     return stdout;
  57 }
  58
  59 static int
  60 dummy_globalmode(int mode)
  61 {
  62     int o = _fmode;
  63     _fmode = mode;
  64
  65     return o;
  66 }
  67
  68 #if defined(_DLL) || defined(__BORLANDC__)
  69 /* It may or may not be fixed (ok on NT), but DLL runtime
  70    does not export the functions used in the workround
  71 */
  72 #define WIN95_OSFHANDLE_FIXED
  73 #endif
  74
  75 #if defined(_WIN32) && !defined(WIN95_OSFHANDLE_FIXED) && defined(_M_IX86)
  76
  77 #       ifdef __cplusplus
  78 #define EXT_C_FUNC      extern "C"
  79 #       else
  80 #define EXT_C_FUNC      extern
  81 #       endif
  82
  83 EXT_C_FUNC int __cdecl _alloc_osfhnd(void);
  84 EXT_C_FUNC int __cdecl _set_osfhnd(int fh, long value);
  85 EXT_C_FUNC void __cdecl _lock_fhandle(int);
  86 EXT_C_FUNC void __cdecl _unlock_fhandle(int);
  87 EXT_C_FUNC void __cdecl _unlock(int);
  88
  89 #if     (_MSC_VER >= 1000)
  90 typedef struct  {
  91     long osfhnd;    /* underlying OS file HANDLE */
  92     char osfile;    /* attributes of file (e.g., open in text mode?) */
  93     char pipech;    /* one char buffer for handles opened on pipes */
  94 #if defined (_MT) && !defined (DLL_FOR_WIN32S)
  95     int lockinitflag;
  96     CRITICAL_SECTION lock;
  97 #endif  /* defined (_MT) && !defined (DLL_FOR_WIN32S) */
  98 }       ioinfo;
  99
 100 EXT_C_FUNC ioinfo * __pioinfo[];
 101
 102 #define IOINFO_L2E                      5
 103 #define IOINFO_ARRAY_ELTS       (1 << IOINFO_L2E)
 104 #define _pioinfo(i)     (__pioinfo[i >> IOINFO_L2E] + (i & (IOINFO_ARRAY_ELTS - 1)))
 105 #define _osfile(i)      (_pioinfo(i)->osfile)
 106
 107 #else   /* (_MSC_VER >= 1000) */
 108 extern char _osfile[];
 109 #endif  /* (_MSC_VER >= 1000) */
 110
 111 #define FOPEN                   0x01    /* file handle open */
 112 #define FAPPEND                 0x20    /* file handle opened O_APPEND */
 113 #define FDEV                    0x40    /* file handle refers to device */
 114 #define FTEXT                   0x80    /* file handle is in text mode */
 115
 116 #define _STREAM_LOCKS   26              /* Table of stream locks */
 117 #define _LAST_STREAM_LOCK  (_STREAM_LOCKS+_NSTREAM_-1)  /* Last stream lock */
 118 #define _FH_LOCKS          (_LAST_STREAM_LOCK+1)        /* Table of fh locks */
 119
 120 /***
 121 *int _patch_open_osfhandle(long osfhandle, int flags) - open C Runtime file handle
 122 *
 123 *Purpose:
 124 *       This function allocates a free C Runtime file handle and associates
 125 *       it with the Win32 HANDLE specified by the first parameter. This is a
 126 *               temperary fix for WIN95's brain damage GetFileType() error on socket
 127 *               we just bypass that call for socket
 128 *
 129 *Entry:
 130 *       long osfhandle - Win32 HANDLE to associate with C Runtime file handle.
 131 *       int flags      - flags to associate with C Runtime file handle.
 132 *
 133 *Exit:
 134 *       returns index of entry in fh, if successful
 135 *       return -1, if no free entry is found
 136 *
 137 *Exceptions:
 138 *
 139 *******************************************************************************/
 140
 141 int
 142 my_open_osfhandle(long osfhandle, int flags)
 143 {
 144     int fh;
 145     char fileflags;             /* _osfile flags */
 146
 147     /* copy relevant flags from second parameter */
 148     fileflags = FDEV;
 149
 150     if(flags & O_APPEND)
 151         fileflags |= FAPPEND;
 152
 153     if(flags & O_TEXT)
 154         fileflags |= FTEXT;
 155
 156     /* attempt to allocate a C Runtime file handle */
 157     if((fh = _alloc_osfhnd()) == -1) {
 158         errno = EMFILE;         /* too many open files */
 159         _doserrno = 0L;         /* not an OS error */
 160         return -1;              /* return error to caller */
 161     }
 162
 163     /* the file is open. now, set the info in _osfhnd array */
 164     _set_osfhnd(fh, osfhandle);
 165
 166     fileflags |= FOPEN;         /* mark as open */
 167
 168 #if (_MSC_VER >= 1000)
 169     _osfile(fh) = fileflags;    /* set osfile entry */
 170     _unlock_fhandle(fh);
 171 #else
 172     _osfile[fh] = fileflags;    /* set osfile entry */
 173     _unlock(fh+_FH_LOCKS);              /* unlock handle */
 174 #endif
 175
 176     return fh;                  /* return handle */
 177 }
 178 #else
 179
 180 int __cdecl
 181 my_open_osfhandle(long osfhandle, int flags)
 182 {
 183     return _open_osfhandle(osfhandle, flags);
 184 }
 185 #endif  /* _M_IX86 */
 186
 187 long
 188 my_get_osfhandle( int filehandle )
 189 {
 190     return _get_osfhandle(filehandle);
 191 }
 192
 193 #ifdef __BORLANDC__
 194 #define _chdir chdir
 195 #endif
 196
 197 /* simulate flock by locking a range on the file */
 198
 199
 200 #define LK_ERR(f,i)     ((f) ? (i = 0) : (errno = GetLastError()))
 201 #define LK_LEN          0xffff0000
 202
 203 int
 204 my_flock(int fd, int oper)
 205 {
 206     OVERLAPPED o;
 207     int i = -1;
 208     HANDLE fh;
 209
 210     fh = (HANDLE)my_get_osfhandle(fd);
 211     memset(&o, 0, sizeof(o));
 212
 213     switch(oper) {
 214     case LOCK_SH:               /* shared lock */
 215         LK_ERR(LockFileEx(fh, 0, 0, LK_LEN, 0, &o),i);
 216         break;
 217     case LOCK_EX:               /* exclusive lock */
 218         LK_ERR(LockFileEx(fh, LOCKFILE_EXCLUSIVE_LOCK, 0, LK_LEN, 0, &o),i);
 219         break;
 220     case LOCK_SH|LOCK_NB:       /* non-blocking shared lock */
 221         LK_ERR(LockFileEx(fh, LOCKFILE_FAIL_IMMEDIATELY, 0, LK_LEN, 0, &o),i);
 222         break;
 223     case LOCK_EX|LOCK_NB:       /* non-blocking exclusive lock */
 224         LK_ERR(LockFileEx(fh,
 225                        LOCKFILE_EXCLUSIVE_LOCK|LOCKFILE_FAIL_IMMEDIATELY,
 226                        0, LK_LEN, 0, &o),i);
 227         break;
 228     case LOCK_UN:               /* unlock lock */
 229         LK_ERR(UnlockFileEx(fh, 0, LK_LEN, 0, &o),i);
 230         break;
 231     default:                    /* unknown */
 232         errno = EINVAL;
 233         break;
 234     }
 235     return i;
 236 }
 237
 238 #undef LK_ERR
 239 #undef LK_LEN
 240
 241
 242 #ifdef PERLDLL
 243 __declspec(dllexport)
 244 #endif
 245 WIN32_IOSUBSYSTEM       win32stdio = {
 246     12345678L,          /* begin of structure; */
 247     dummy_errno,        /* (*pfunc_errno)(void); */
 248     dummy_environ,      /* (*pfunc_environ)(void); */
 249     dummy_stdin,        /* (*pfunc_stdin)(void); */
 250     dummy_stdout,       /* (*pfunc_stdout)(void); */
 251     dummy_stderr,       /* (*pfunc_stderr)(void); */
 252     ferror,             /* (*pfunc_ferror)(FILE *fp); */
 253     feof,               /* (*pfunc_feof)(FILE *fp); */
 254     strerror,           /* (*strerror)(int e); */
 255     vfprintf,           /* (*pfunc_vfprintf)(FILE *pf, const char *format, va_list arg); */
 256     vprintf,            /* (*pfunc_vprintf)(const char *format, va_list arg); */
 257     fread,              /* (*pfunc_fread)(void *buf, size_t size, size_t count, FILE *pf); */
 258     fwrite,             /* (*pfunc_fwrite)(void *buf, size_t size, size_t count, FILE *pf); */
 259     fopen,              /* (*pfunc_fopen)(const char *path, const char *mode); */
 260     fdopen,             /* (*pfunc_fdopen)(int fh, const char *mode); */
 261     freopen,            /* (*pfunc_freopen)(const char *path, const char *mode, FILE *pf); */
 262     fclose,             /* (*pfunc_fclose)(FILE *pf); */
 263     fputs,              /* (*pfunc_fputs)(const char *s,FILE *pf); */
 264     fputc,              /* (*pfunc_fputc)(int c,FILE *pf); */
 265     ungetc,             /* (*pfunc_ungetc)(int c,FILE *pf); */
 266     getc,               /* (*pfunc_getc)(FILE *pf); */
 267     fileno,             /* (*pfunc_fileno)(FILE *pf); */
 268     clearerr,           /* (*pfunc_clearerr)(FILE *pf); */
 269     fflush,             /* (*pfunc_fflush)(FILE *pf); */
 270     ftell,              /* (*pfunc_ftell)(FILE *pf); */
 271     fseek,              /* (*pfunc_fseek)(FILE *pf,long offset,int origin); */
 272     fgetpos,            /* (*pfunc_fgetpos)(FILE *pf,fpos_t *p); */
 273     fsetpos,            /* (*pfunc_fsetpos)(FILE *pf,fpos_t *p); */
 274     rewind,             /* (*pfunc_rewind)(FILE *pf); */
 275     tmpfile,            /* (*pfunc_tmpfile)(void); */
 276     abort,              /* (*pfunc_abort)(void); */
 277     fstat,              /* (*pfunc_fstat)(int fd,struct stat *bufptr); */
 278     stat,               /* (*pfunc_stat)(const char *name,struct stat *bufptr); */
 279     _pipe,              /* (*pfunc_pipe)( int *phandles, unsigned int psize, int textmode ); */
 280     _popen,             /* (*pfunc_popen)( const char *command, const char *mode ); */
 281     _pclose,            /* (*pfunc_pclose)( FILE *pf); */
 282     setmode,            /* (*pfunc_setmode)( int fd, int mode); */
 283     lseek,              /* (*pfunc_lseek)( int fd, long offset, int origin); */
 284     tell,               /* (*pfunc_tell)( int fd); */
 285     dup,                /* (*pfunc_dup)( int fd); */
 286     dup2,               /* (*pfunc_dup2)(int h1, int h2); */
 287     open,               /* (*pfunc_open)(const char *path, int oflag,...); */
 288     close,              /* (*pfunc_close)(int fd); */
 289     eof,                /* (*pfunc_eof)(int fd); */
 290     read,               /* (*pfunc_read)(int fd, void *buf, unsigned int cnt); */
 291     write,              /* (*pfunc_write)(int fd, const void *buf, unsigned int cnt); */
 292     dummy_globalmode,   /* (*pfunc_globalmode)(int mode) */
 293     my_open_osfhandle,
 294     my_get_osfhandle,
 295     spawnvp,
 296     _mkdir,
 297     _rmdir,
 298     _chdir,
 299     my_flock,           /* (*pfunc_flock)(int fd, int oper) */
 300     execvp,
 301     87654321L,          /* end of structure */
 302 };
 303
 304
 305 #ifdef __cplusplus
 306 }
 307 #endif
 308