---

writen.c

Go to the documentation of this file.

/************************************************************************
* File: writen.c
* Purpose: Provides a C file for the writen function from
* the book Advanced Programming in the UNIX Environment by Richard Stevens.
* The writen function calls the write function repeatedly until n bytes
* have been written to the file descriptor.
*************************************************************************/



/* This is neccessary to avoid muliple definitions of fd_set, etc when both
*  RPC via PCNFS and Windows Sockets are to be available. */
#ifdef USE_PCNFS
#undef USE_PCNFS
#endif

#include "rcs_defs.hh"          /* _Windows */

#include "writen.h"             /* writen() */
#if !defined(DOS_WINDOWS) || defined(gnuwin32)
#include <sys/types.h>          /* typedef fd_set, FD_ZERO, FD_SET */
#ifdef VXWORKS
#include <sys/times.h>          /* struct timeval */
#else
#include <sys/time.h>           /* struct timeval */
#endif
#include <unistd.h>             /* write(),select() */
#else
#if defined(MSDOS) && !defined(WINDOWS)
#include <sys/nfs_time.h>
#else
#include <io.h>                 /* write() */
#ifdef USE_OLD_WINSOCK
#include <winsock.h>            /* select(), typedef fd_set, FD_ZERO, FD_SET, struct */
#else
#include <winsock2.h>
#endif
#endif
#endif
#include <stddef.h>             /* size_t */
#include <errno.h>              /* errno */
#include <string.h>             /* strerror() */
#include <math.h>               /* modf() */
#include "rcs_prnt.hh"          /* rcs_print_error() */
#include "sokintrf.h"           /* dl_select() */

/* Write "n" bytes to a descriptor. */
int
writen (int fd, const void *vptr, int n, double _timeout)
{
  int nleft;
  long nwritten;
  char *ptr;
  double int_part;
  struct timeval timeout_tv;
  fd_set write_fd_set;

  timeout_tv.tv_sec = (long) _timeout;
  timeout_tv.tv_usec = (long) (_timeout * 1000000.0);
  if (timeout_tv.tv_usec >= 1000000)
    {
      timeout_tv.tv_usec = timeout_tv.tv_usec % 1000000;
    }
  FD_ZERO (&write_fd_set);
  RCS_FD_SET (fd, &write_fd_set);

  ptr = (char *) vptr;          /* can't do pointer arithmetic on void* */
  nleft = n;
  while (nleft > 0)
    {
      if (_timeout > 0.0)
        {
          switch (dl_select
                  (fd + 1, (fd_set *) NULL, &write_fd_set, (fd_set *) NULL,
                   &timeout_tv))
            {
            case -1:
              rcs_print_error ("Error in select: %d -> %s\n", errno,
                               strerror (errno));
              return -1;

            case 0:
              rcs_print_error ("Write timed out.\n");
              return -1;

            default:
              break;
            }
        }
      if ((nwritten = write (fd, ptr, nleft)) == -1)
        {
          rcs_print_error ("Write error: %d = %s", errno, strerror (errno));
          return (-1);          /* error */
        }

      nleft -= nwritten;
      ptr += nwritten;
    }
  return (n);
}

---