src/read.c

Go to the documentation of this file.

/*
     This file is part of PlibC.
     (C) 2005 Nils Durner (and other contributing authors)

           This library is free software; you can redistribute it and/or
           modify it under the terms of the GNU Lesser General Public
           License as published by the Free Software Foundation; either
           version 2.1 of the License, or (at your option) any later version.
        
           This library is distributed in the hope that it will be useful,
           but WITHOUT ANY WARRANTY; without even the implied warranty of
           MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
           Lesser General Public License for more details.
        
           You should have received a copy of the GNU Lesser General Public
           License along with this library; if not, write to the Free Software
           Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
*/

#include "plibc_private.h"

DWORD WINAPI __win_Read(TReadWriteInfo *pInfo)
{
        if (_setmode(pInfo->fildes, _O_BINARY) != -1)
        {
                errno = 0;
                return _read(pInfo->fildes, pInfo->buf, pInfo->nbyte);
        }
        else
        {
    DWORD dwRead;
    
    errno = 0;
    if (!ReadFile((HANDLE) pInfo->fildes, pInfo->buf, pInfo->nbyte, &dwRead,
      NULL))
    {
      SetErrnoFromWinError(GetLastError());
      return -1;
    }
    else
      return dwRead;
        }
}

int _win_read(int fildes, void *buf, size_t nbyte)
{
  if (_win_isSocketValid(fildes))
    return _win_recv(fildes, (char *) buf, nbyte, 0);
  else
  {
    TReadWriteInfo theInfo;
    theInfo.fildes = fildes;
    theInfo.buf = buf;
    theInfo.nbyte = nbyte;

    if (__win_IsHandleMarkedAsBlocking(fildes))
      return __win_Read(&theInfo);
    else
    {
      DWORD dwTID; /* Last ptr of CreateThread my not be NULL under Win9x */
      CreateThread(NULL, 0, (LPTHREAD_START_ROUTINE) __win_Read, &theInfo, 0, &dwTID);
      return 1;
    }
  }
}

/* end of read.c */

---