git.pond.sub.org Git - empserver/blob - src/lib/w32/w32io.c

   1 /*
   2  *  Empire - A multi-player, client/server Internet based war game.
   3  *  Copyright (C) 1986-2010, Dave Pare, Jeff Bailey, Thomas Ruschak,
   4  *                           Ken Stevens, Steve McClure
   5  *
   6  *  This program is free software; you can redistribute it and/or modify
   7  *  it under the terms of the GNU General Public License as published by
   8  *  the Free Software Foundation; either version 2 of the License, or
   9  *  (at your option) any later version.
  10  *
  11  *  This program is distributed in the hope that it will be useful,
  12  *  but WITHOUT ANY WARRANTY; without even the implied warranty of
  13  *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  14  *  GNU General Public License for more details.
  15  *
  16  *  You should have received a copy of the GNU General Public License
  17  *  along with this program; if not, write to the Free Software
  18  *  Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
  19  *
  20  *  ---
  21  *
  22  *  See files README, COPYING and CREDITS in the root of the source
  23  *  tree for related information and legal notices.  It is expected
  24  *  that future projects/authors will amend these files as needed.
  25  *
  26  *  ---
  27  *
  28  *  w32io.c: POSIX I/O emulation layer for Windows
  29  *
  30  *  Known contributors to this file:
  31  *     Ron Koenderink, 2007
  32  *     Markus Armbruster, 2007-2009
  33  */
  34
  35 /*
  36  * POSIX sockets are file descriptors.  Windows sockets are something
  37  * else, with a separate set of functions to operate on them.  To
  38  * present a more POSIX-like interface to our application code, we
  39  * provide a compatibility layer that wraps file descriptors around
  40  * sockets.
  41  */
  42
  43 #include <config.h>
  44
  45 #include <errno.h>
  46 #include <io.h>
  47 #include <stdlib.h>
  48 #include <string.h>
  49 #include "misc.h"
  50 #include "sys/uio.h"
  51
  52 int (*w32_close_function)(int) = _close;
  53 int (*w32_read_function)(int, void *, unsigned) = _read;
  54 int (*w32_write_function)(int, const void *, unsigned) = _write;
  55
  56 /*
  57  * POSIX equivalent for readv
  58  * Modelled after the GNU's libc/sysdeps/posix/readv.c
  59  */
  60 ssize_t
  61 readv(int fd, const struct iovec *iov, int iovcnt)
  62 {
  63     int i;
  64     unsigned char *buffer, *buffer_location;
  65     size_t total_bytes = 0;
  66     int bytes_read;
  67     size_t bytes_left;
  68
  69     for (i = 0; i < iovcnt; i++) {
  70         total_bytes += iov[i].iov_len;
  71     }
  72
  73     buffer = malloc(total_bytes);
  74     if (buffer == NULL && total_bytes != 0) {
  75         errno = ENOMEM;
  76         return -1;
  77     }
  78
  79     bytes_read = read(fd, buffer, total_bytes);
  80     if (bytes_read < 0) {
  81         free(buffer);
  82         return -1;
  83     }
  84
  85     bytes_left = bytes_read;
  86     buffer_location = buffer;
  87     for (i = 0; i < iovcnt; i++) {
  88         size_t copy = MIN(iov[i].iov_len, bytes_left);
  89
  90         memcpy(iov[i].iov_base, buffer_location, copy);
  91
  92         buffer_location += copy;
  93         bytes_left -= copy;
  94         if (bytes_left == 0)
  95             break;
  96     }
  97
  98     free(buffer);
  99     return bytes_read;
 100 }
 101
 102 /*
 103  * POSIX equivalent for writev
 104  * Modelled after the GNU's libc/sysdeps/posix/writev.c
 105  */
 106 ssize_t
 107 writev(int fd, const struct iovec *iov, int iovcnt)
 108 {
 109     int i;
 110     unsigned char *buffer, *buffer_location;
 111     size_t total_bytes = 0;
 112     int bytes_written;
 113
 114     for (i = 0; i < iovcnt; i++)
 115         total_bytes += iov[i].iov_len;
 116
 117     buffer = malloc(total_bytes);
 118     if (buffer == NULL && total_bytes != 0) {
 119         errno = ENOMEM;
 120         return -1;
 121     }
 122
 123     buffer_location = buffer;
 124     for (i = 0; i < iovcnt; i++) {
 125         memcpy(buffer_location, iov[i].iov_base, iov[i].iov_len);
 126         buffer_location += iov[i].iov_len;
 127     }
 128
 129     bytes_written = write(fd, buffer, total_bytes);
 130     free(buffer);
 131     return bytes_written;
 132 }