home *** CD-ROM | disk | FTP | other *** search
/ ftp.ncftp.com / ftp.ncftp.com.zip / ftp.ncftp.com / libncftp / older_versions / libncftp-3.2.2-src.tar.bz2 / libncftp-3.2.2-src.tar / libncftp-3.2.2 / sio / SRecvfrom.c < prev    next >
C/C++ Source or Header  |  2003-08-31  |  2KB  |  79 lines
  1. #include "syshdrs.h"
  2. #ifdef PRAGMA_HDRSTOP
  3. #    pragma hdrstop
  4. #endif
  5.  
  6. int
  7. SRecvfrom(int sfd, char *const buf, size_t size, int fl, struct sockaddr_in *const fromAddr, int tlen)
  8. {
  9.     recv_return_t nread;
  10.     int tleft;
  11.     fd_set ss;
  12.     struct timeval tv;
  13.     int result;
  14.     time_t done, now;
  15.     sockaddr_size_t alen;
  16.     DECL_SIGPIPE_VARS
  17.     
  18.     if ((buf == NULL) || (size == 0) || (fromAddr == NULL) || (tlen <= 0)) {
  19.         errno = EINVAL;
  20.         return (-1);
  21.     }
  22.     
  23.     time(&now);
  24.     done = now + tlen;
  25.     tleft = (done > now) ? ((int) (done - now)) : 0;
  26.     nread = 0;
  27.     forever {
  28.         alen = (sockaddr_size_t) sizeof(struct sockaddr_in);
  29.                 
  30.         forever {
  31.             errno = 0;
  32.             MY_FD_ZERO(&ss);
  33. #if defined(__DECC) || defined(__DECCXX)
  34. #pragma message save
  35. #pragma message disable trunclongint
  36. #endif
  37.             MY_FD_SET(sfd, &ss);
  38. #if defined(__DECC) || defined(__DECCXX)
  39. #pragma message restore
  40. #endif
  41.             tv.tv_sec = (tv_sec_t) tleft;
  42.             tv.tv_usec = 0;
  43.             result = select(sfd + 1, SELECT_TYPE_ARG234 &ss, NULL, NULL, SELECT_TYPE_ARG5 &tv);
  44.             if (result == 1) {
  45.                 /* ready */
  46.                 break;
  47.             } else if (result == 0) {
  48.                 /* timeout */
  49.                 errno = ETIMEDOUT;
  50.                 SETWSATIMEOUTERR
  51.                 return (kTimeoutErr);
  52.             } else if (errno != EINTR) {
  53.                 return (-1);
  54.             }
  55.         }
  56.  
  57.         IGNORE_SIGPIPE
  58.         nread = recvfrom(sfd, buf, (recv_size_t) size, fl,
  59.             (struct sockaddr *) fromAddr, &alen);
  60.         RESTORE_SIGPIPE
  61.  
  62.         if (nread >= 0)
  63.             break;
  64.         if (errno != EINTR)
  65.             break;        /* Fatal error. */
  66.         errno = 0;
  67.         time(&now);
  68.         tleft = (done > now) ? ((int) (done - now)) : 0;
  69.         if (tleft < 1) {
  70.             nread = kTimeoutErr;
  71.             errno = ETIMEDOUT;
  72.             SETWSATIMEOUTERR
  73.             break;
  74.         }
  75.     }
  76.  
  77.     return ((int) nread);
  78. }    /* SRecvfrom */
  79.