Logo Search packages:      
Sourcecode: tcsh version File versions

stdio.c

/*$Header: /src/pub/tcsh/win32/stdio.c,v 1.3 2002/08/11 07:58:13 amold Exp $*/
/*-
 * Copyright (c) 1980, 1991 The Regents of the University of California.
 * All rights reserved.
 *
 * Redistribution and use in source and binary forms, with or without
 * modification, are permitted provided that the following conditions
 * are met:
 * 1. Redistributions of source code must retain the above copyright
 *    notice, this list of conditions and the following disclaimer.
 * 2. Redistributions in binary form must reproduce the above copyright
 *    notice, this list of conditions and the following disclaimer in the
 *    documentation and/or other materials provided with the distribution.
 * 3. Neither the name of the University nor the names of its contributors
 *    may be used to endorse or promote products derived from this software
 *    without specific prior written permission.
 *
 * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
 * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
 * ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
 * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
 * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
 * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
 * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
 * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
 * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
 * SUCH DAMAGE.
 */
/*
 * stdio.c Implement a whole load of i/o functions.
 *         This makes it much easier to keep track of inherited handles and
 *         also makes us reasonably vendor crt-independent.
 * -amol
 *
 */

#define WIN32_LEAN_AND_MEAN
#include <windows.h>
#include <stdio.h>
#include <errno.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>
#define STDIO_C
#include <ntport.h>
#include <forkdata.h>


#define __MAX_OPEN_FILES 64

#define FIOCLEX 1
#define FCONSOLE 2
#define FRESOURCE 4 //stringtable resource

typedef struct _myfile {
      HANDLE  handle;
      unsigned long flags;
} MY_FILE;

typedef unsigned long u_long;

#define INVHL (INVALID_HANDLE_VALUE)

MY_FILE __gOpenFiles[__MAX_OPEN_FILES]={0};
MY_FILE __gOpenFilesCopy[__MAX_OPEN_FILES]={0};

MY_FILE *my_stdin=0, *my_stdout=0, *my_stderr=0;

extern int didfds;
int __dup_stdin = 0;


void init_stdio(void) {

      int i;
      __gOpenFiles[0].handle = GetStdHandle(STD_INPUT_HANDLE);
      __gOpenFiles[1].handle = GetStdHandle(STD_OUTPUT_HANDLE);
      __gOpenFiles[2].handle = GetStdHandle(STD_ERROR_HANDLE);

      __gOpenFiles[0].flags = (GetFileType((HANDLE)STD_INPUT_HANDLE)== 
                                                      FILE_TYPE_CHAR)?  FCONSOLE:0;
      __gOpenFiles[1].flags = (GetFileType((HANDLE)STD_OUTPUT_HANDLE)== 
                                                      FILE_TYPE_CHAR)?  FCONSOLE:0;
      __gOpenFiles[2].flags = (GetFileType((HANDLE)STD_ERROR_HANDLE)==
                                                      FILE_TYPE_CHAR)?  FCONSOLE:0;

      for(i=3;i<__MAX_OPEN_FILES;i++) {
            __gOpenFiles[i].handle = INVHL;
            __gOpenFilesCopy[i].handle = INVHL;
            __gOpenFiles[i].flags = 0;
      }

      my_stdin = &__gOpenFiles[0];
      my_stdout = &__gOpenFiles[1];
      my_stderr = &__gOpenFiles[2];


}
void nt_close_on_exec(int fd, int on) {
      if(on)
            __gOpenFiles[fd].flags |= FIOCLEX;
      else
            __gOpenFiles[fd].flags &= ~FIOCLEX;
}
void restore_fds(void ) {
      int i;
      int min=3;

      if (__forked && (didfds|| __dup_stdin))
            min =0;
      //
      // ok for tcsh. see fork.c for why
      //
      __gOpenFiles[0].handle = INVHL;
      __gOpenFiles[1].handle = INVHL;
      __gOpenFiles[2].handle = INVHL;
      my_stdin = &__gOpenFiles[0];
      my_stdout = &__gOpenFiles[1];
      my_stderr = &__gOpenFiles[2];
      for(i=min;i<__MAX_OPEN_FILES;i++) {
            if (__gOpenFilesCopy[i].handle == INVHL)
                  continue;
            __gOpenFiles[i].handle = __gOpenFilesCopy[i].handle ;
            __gOpenFiles[i].flags = __gOpenFilesCopy[i].flags ;
      }
}
void close_copied_fds(void ) {
      int i;
      int min=3;
      if (didfds|| __dup_stdin)
            min =0;
      for(i=min;i<__MAX_OPEN_FILES;i++) {
            if (__gOpenFilesCopy[i].handle == INVHL)
                  continue;
            CloseHandle((HANDLE)__gOpenFilesCopy[i].handle);
            __gOpenFilesCopy[i].handle = INVHL;
      }
      __dup_stdin=0;
}
void copy_fds(void ) {
      int i;
      int min=3;
      if (didfds || __dup_stdin)
            min =0;
      for(i=min;i<__MAX_OPEN_FILES;i++) {
            if (__gOpenFiles[i].handle == INVHL) {
                  __gOpenFilesCopy[i].handle = INVHL;
                  continue;
            }
            
            if(!DuplicateHandle(GetCurrentProcess(), 
                                    (HANDLE)__gOpenFiles[i].handle ,
                                    GetCurrentProcess(), 
                                    (HANDLE*)&__gOpenFilesCopy[i].handle,
                                     0, TRUE, DUPLICATE_SAME_ACCESS) )
                  __gOpenFilesCopy[i].handle = INVHL;
            __gOpenFilesCopy[i].flags = __gOpenFiles[i].flags;
      }
}
int is_resource_file(int fd) {
      return (__gOpenFiles[fd].flags & FRESOURCE);
}
intptr_t __nt_get_osfhandle(int fd) {
      return (intptr_t)(__gOpenFiles[fd].handle);
}
int __nt_open_osfhandle(intptr_t h1, int mode) {
      int i;

      for(i=0;i<__MAX_OPEN_FILES;i++) {
            if (__gOpenFiles[i].handle == INVHL) {
                  __gOpenFiles[i].handle = (HANDLE)h1;
                  __gOpenFiles[i].flags = 0;
                  return i;
            }
      }
      errno = EMFILE;
      return -1;
}
int nt_close(int fd) {
      
      if (__gOpenFiles[fd].flags & FRESOURCE) {
            __gOpenFiles[fd].handle = INVHL;
            __gOpenFiles[fd].flags = 0;
            return 0;
      }
      if( (fd == -1) ||(__gOpenFiles[fd].handle == INVHL))
            return 0;
      CloseHandle((HANDLE)(__gOpenFiles[fd].handle));
      __gOpenFiles[fd].handle = INVHL;
      __gOpenFiles[fd].flags = 0;

//    dprintf("closing 0x%08x\n",(__gOpenFiles[fd].handle));
      return 0;
}
int nt_access(char *filename, int mode) {
      
      DWORD attribs=(DWORD)-1, bintype;
      int tries=0;
      char buf[512];

      if (!filename) {
            errno = ENOENT;
            return -1;
      }
      sprintf(buf,"%s",filename);
retry:
      attribs = GetFileAttributes(buf);
      tries++;

      if (attribs == (DWORD) -1) {
            if( (GetLastError() == ERROR_FILE_NOT_FOUND) && (mode & X_OK) ) {
                  switch(tries){
                        case 1:
                              sprintf(buf,"%s.exe",filename);
                              break;
                        case 2:
                              sprintf(buf,"%s.cmd",filename);
                              break;
                        case 3:
                              sprintf(buf,"%s.bat",filename);
                              break;
                        case 4:
                              sprintf(buf,"%s.com",filename);
                              break;
                        default:
                              goto giveup;
                              break;
                  }
                  goto retry;
            }
      }
giveup:
      if (attribs == (DWORD)-1 ) {
            errno = EACCES;
            return -1;
      }
      if ( (mode & W_OK) &&  (attribs & FILE_ATTRIBUTE_READONLY) ) {
            errno = EACCES;
            return -1;
      }
      if (mode & X_OK) {
            if ((mode & XD_OK) && (attribs & FILE_ATTRIBUTE_DIRECTORY) ){
                  errno = EACCES;
                  return -1;
            }
            if ((!(attribs & FILE_ATTRIBUTE_DIRECTORY)) && 
//                      !is_executable(buf,NULL) &&(tries >4) ) {
                        !GetBinaryType(buf,&bintype) &&(tries >4) ) {
                  errno = EACCES;
                  return -1;
            }
      }
      return 0;
}
int nt_seek(HANDLE h1, long offset, int how) {
      DWORD dwmove;

      switch(how) {
            case SEEK_CUR:
                  dwmove = FILE_CURRENT;
                  break;
            case SEEK_END:
                  dwmove = FILE_END;
                  break;
            case SEEK_SET:
                  dwmove = FILE_BEGIN;
                  break;
            default:
                  errno = EINVAL;
                  return -1;
      }

      if (SetFilePointer(h1,offset,NULL,dwmove) == -1){
            errno = EBADF;
            return -1;
      }
      return 0;
}
int nt_lseek(int fd,long offset, int how) {
      HANDLE h1 ; 
      h1 =__gOpenFiles[fd].handle;
      return nt_seek((HANDLE)h1,offset,how);
}
int nt_isatty(int fd) {
      HANDLE h1 = __gOpenFiles[fd].handle;
      return (__gOpenFiles[fd].flags & FCONSOLE);
}
int nt_dup(int fdin) {

      HANDLE hdup;
      HANDLE horig =  __gOpenFiles[fdin].handle;
      int ret;

      if (__gOpenFiles[fdin].flags & FRESOURCE) {
            hdup = __gOpenFiles[fdin].handle;
      }
      else {

            if (!DuplicateHandle(GetCurrentProcess(),
                              horig,
                              GetCurrentProcess(),
                              &hdup,
                              0,
                              FALSE,
                              DUPLICATE_SAME_ACCESS)) {
                  errno = GetLastError();
                  errno = EBADF;
                  return -1;
            }
      }
      ret = __nt_open_osfhandle((intptr_t)hdup,_O_BINARY | _O_NOINHERIT);

      __gOpenFiles[ret].flags = __gOpenFiles[fdin].flags;

      return  ret;
}
int nt_dup2(int fdorig,int fdcopy) {

      HANDLE hdup;
      HANDLE horig =  __gOpenFiles[fdorig].handle;
      
      if (__gOpenFiles[fdorig].flags & FRESOURCE) {
            __gOpenFiles[fdcopy].handle = __gOpenFiles[fdorig].handle;
            __gOpenFiles[fdcopy].flags = __gOpenFiles[fdorig].flags;
            return 0;
      }

      if (__gOpenFiles[fdcopy].handle != INVHL) {
            CloseHandle((HANDLE)__gOpenFiles[fdcopy].handle );
            __gOpenFiles[fdcopy].handle = INVHL;
            __gOpenFiles[fdcopy].flags = 0;
      }
      if (!DuplicateHandle(GetCurrentProcess(),
                                     horig,
                                     GetCurrentProcess(),
                                     &hdup,
                                     0,
                                     fdcopy<3?TRUE:FALSE,
                                     DUPLICATE_SAME_ACCESS)) {
            errno = GetLastError();
            errno = EBADF;
            return -1;
      }
      __gOpenFiles[fdcopy].handle = hdup;
      __gOpenFiles[fdcopy].flags = __gOpenFiles[fdorig].flags;
      switch(fdcopy) {
            case 0:
                  SetStdHandle(STD_INPUT_HANDLE,hdup);
                  break;
            case 1:
                  SetStdHandle(STD_OUTPUT_HANDLE,hdup);
                  break;
            case 2:
                  SetStdHandle(STD_ERROR_HANDLE,hdup);
                  break;
            default:
                  break;
      }

      return  0;
}
int nt_pipe2(HANDLE hpipe[2]) {

      SECURITY_ATTRIBUTES secd;

      secd.nLength=sizeof(secd);
      secd.lpSecurityDescriptor=NULL;
      secd.bInheritHandle=FALSE;

      return (!CreatePipe(&hpipe[0],&hpipe[1],&secd,0));
}
int nt_pipe(int hpipe[2]) {
      HANDLE hpipe2[2];

      nt_pipe2(hpipe2);
      hpipe[0] = __nt_open_osfhandle((intptr_t)hpipe2[0],O_NOINHERIT);
      hpipe[1] = __nt_open_osfhandle((intptr_t)hpipe2[1],O_NOINHERIT);
      return 0;
}
/* check if name is //server. if checkifShare is set,
 * also check if //server/share
 */
int is_server(char *name,int checkifShare) {
      char *p1, *p2;

      if (!*name || !*(name+1))
            return 0;

      p1 = name;
      if ( 
            ((p1[0] != '/') && (p1[0] != '\\') ) ||
            ((p1[1] != '/') && (p1[1] != '\\') )
         )
            return 0;
      
      p2 = p1 + 2;
      while (*p2 && *p2 != '/' && *p2 != '\\')
#ifdef DSPMBYTE
            if (Ismbyte1(*p2) && *(p2 + 1))
                  p2 += 2;
            else
#endif /* DSPMBYTE */
                  p2++;
            
      /* just check for server */
      if (!checkifShare) {

            /* null terminated unc server name */
            /* terminating '/' (//server/) is also ok */
            if (!*p2 || !*(p2+1)) 
                  return 1;

      }
      else {
            if (!*p2 || !*(p2+1))
                  return 0;
            p2++;
            while(*p2 && *p2 != '/' && *p2 != '\\')
                  p2++;

            if (!*p2 || !*(p2+1))
                  return 1;

      }
      return 0;

      //p1++;

      /*
      p2 = strrchr(name,'/');
      if (!p2)
            p2 = strchr(name,'\\');
      {
            p2--;
            while ( (*p2 != '/') && (*p2 != '\\') )
                  p2--;
      }
      if (p2 != p1)
            return 0;

      */
      return 1;
}
__inline int is_unc(char *filename) {
      if (*filename && (*filename == '/' || *filename == '\\')
            && *(filename+1) && (*(filename+1) == '/' || *(filename+1) == '\\'))
            return 1;
      return 0;
      
}
int nt_stat(char *filename, struct stat *stbuf) {
      
      // stat hangs on server name 
      // Use any  directory, since the info in stat means %$!* on
      // windows anyway.
      // -amol 5/28/97
      /* is server or share */
      if (is_server(filename,0)  || is_server(filename,1) ||
            (*(filename+1) && *(filename+1) == ':' && !*(filename+2)) ) {
            return _stat("C:/",(struct _stat *)stbuf);
      }
#if 0
      else if (is_unc(filename)) { /* could be //server/share/filename */
            return _stat("NUL",(struct _stat*)stbuf);
      }
#endif 0
      else 
            return _stat(filename,(struct _stat *)stbuf);
}
//
// replacement for creat that makes handle non-inheritable. 
// -amol 
//
int nt_creat(char *filename, int mode) {

      // ignore the bloody mode

      int fd,is_cons =0, is_resource = 0;
      HANDLE retval;
      SECURITY_ATTRIBUTES security;

      security.nLength = sizeof(security);
      security.lpSecurityDescriptor = NULL;
      security.bInheritHandle = FALSE;

      if (!lstrcmp(filename,"/dev/tty") ){
            filename = "CONOUT$";
            is_cons = 1;
      }
      else if (!lstrcmp(filename,"/dev/null") ){
            filename = "NUL";
      }
      else if (!lstrcmpi(filename,"/dev/clipboard")) {
            retval = create_clip_writer_thread();
            if (retval == INVHL)
                  return -1;
            goto get_fd;
      }
      else if (!lstrcmp(filename,"/dev/builtinresource")) {
            retval = GetModuleHandle(NULL);
            is_resource = 1;
            goto get_fd;
      }
      retval = CreateFile(filename,
                                    GENERIC_READ | GENERIC_WRITE,
                                    FILE_SHARE_READ | FILE_SHARE_WRITE,
                                    is_cons?NULL:&security,
                                    CREATE_ALWAYS,
                                    0,
                                    NULL);

      if (retval == INVALID_HANDLE_VALUE) {
            errno = EACCES;
            return -1;
      }
get_fd:
      fd = __nt_open_osfhandle((intptr_t)retval,_O_BINARY);
      if (fd <0) {
            //should never happen
            abort();
      }
      if (is_cons) {
            __gOpenFiles[fd].flags = FCONSOLE;
      }
      if (is_resource) {
            __gOpenFiles[fd].flags = FRESOURCE;
      }
      return fd;
      
}
int nt_open(char *filename, int perms,...) { 

      // ignore the bloody mode

      int fd,mode, is_cons=0;
      int is_resource = 0;
      HANDLE retval;
      SECURITY_ATTRIBUTES security;
      DWORD dwAccess, dwFlags, dwCreateDist;
      va_list ap;

      va_start(ap,perms);
      mode = va_arg(ap,int);
      va_end(ap);

      if (!lstrcmp(filename,"/dev/tty") ){
            if (perms == O_RDONLY) //o_rdonly is 0
                  filename = "CONIN$";
            else if (perms & O_WRONLY)
                  filename = "CONOUT$";
            is_cons = 1;
      }
      else if (!lstrcmp(filename,"/dev/null") ){
            filename = "NUL";
      }
      else if (!lstrcmpi(filename,"/dev/clipboard")) {
            retval = create_clip_reader_thread();
            goto get_fd;
      }
      else if (!lstrcmp(filename,"/dev/builtinresource")) {
            retval = GetModuleHandle(NULL);
            is_resource = 1;
            goto get_fd;
      }
      security.nLength = sizeof(security);
      security.lpSecurityDescriptor = NULL;
      security.bInheritHandle = FALSE;

      switch (perms & (_O_RDONLY | _O_WRONLY | _O_RDWR) ) {
            case _O_RDONLY:
                  dwAccess = GENERIC_READ;
                  break;
            case _O_WRONLY:
                  dwAccess = GENERIC_WRITE;
                  break;
            case _O_RDWR:
                  dwAccess = GENERIC_READ | GENERIC_WRITE ;
                  break;
            default:
                  errno = EINVAL;
                  return -1;
      }
      switch (perms & (_O_CREAT | _O_TRUNC) ){
            case 0:
                  dwCreateDist = OPEN_EXISTING;
                  break;
            case _O_CREAT:
                  dwCreateDist = CREATE_ALWAYS;
                  break;
            case _O_CREAT | _O_TRUNC:
                  dwCreateDist = CREATE_ALWAYS;
                  break;
            case _O_TRUNC:
                  dwCreateDist = TRUNCATE_EXISTING;
                  break;
            default:
                  errno = EINVAL;
                  return -1;
      }
      dwFlags = 0;
      if (perms & O_TEMPORARY)
            dwFlags = FILE_FLAG_DELETE_ON_CLOSE;
      retval = CreateFile(filename,
                                    dwAccess,//GENERIC_READ | GENERIC_WRITE,
                                    FILE_SHARE_READ | FILE_SHARE_WRITE,
                                    &security,
                                    dwCreateDist,//CREATE_ALWAYS,
                                    dwFlags,
                                    NULL);

      if (retval == INVALID_HANDLE_VALUE) {
            int err = GetLastError();
            if (err == ERROR_FILE_NOT_FOUND)
                  errno = ENOENT;
            else
                  errno = EACCES;
            return -1;
      }
      if (perms & O_APPEND) {
            SetFilePointer(retval,0,NULL,FILE_END);
      }
get_fd:
      fd = __nt_open_osfhandle((intptr_t)retval,_O_BINARY);
      if (fd <0) {
            //should never happen
            abort();
      }
      if (is_cons) {
            __gOpenFiles[fd].flags = FCONSOLE;
      }
      if (is_resource) {
            __gOpenFiles[fd].flags = FRESOURCE;
      }
      return fd;
      
}
/*
 * This should be the LAST FUNCTION IN THIS FILE 
 *
 */
#undef fstat
#undef _open_osfhandle
#undef close
int nt_fstat(int fd, struct stat *stbuf) {
      int realfd;
      HANDLE h1;

      errno = EBADF;

      if(!DuplicateHandle(GetCurrentProcess(),
                                    (HANDLE)__gOpenFiles[fd].handle,
                                    GetCurrentProcess(),
                                    &h1,
                                    0,
                                    FALSE,
                                    DUPLICATE_SAME_ACCESS) )
            return -1;
      realfd = _open_osfhandle((intptr_t)h1,0);
      if (realfd <0 ) 
            return -1;
      
      if( fstat(realfd,stbuf) <0 ) {
            close(realfd);
            return -1;
      }
      close(realfd);
      errno =0;
      return 0;
      
}


Generated by  Doxygen 1.6.0   Back to index