diff options
| author | Bruce Cran <bcran@fusionio.com> | 2013-11-01 12:31:03 -0600 |
|---|---|---|
| committer | Jens Axboe <axboe@kernel.dk> | 2013-11-01 12:31:03 -0600 |
| commit | 70a61165b46f210407bcac839b4f0ffe7b4e009f (patch) | |
| tree | fbde357c34c5f428191262aabfcd340d1eaa5818 /os/windows/posix.c | |
| parent | f16b7405fff7c3fc1da421b6bdf8552cc99c3156 (diff) | |
| download | fio-70a61165b46f210407bcac839b4f0ffe7b4e009f.tar.gz fio-70a61165b46f210407bcac839b4f0ffe7b4e009f.tar.bz2 | |
Implement writev on Windows
The network code depends on writev(), so implement it for Windows.
Signed-off-by: Jens Axboe <axboe@kernel.dk>
Diffstat (limited to 'os/windows/posix.c')
| -rwxr-xr-x | os/windows/posix.c | 23 |
1 files changed, 18 insertions, 5 deletions
diff --git a/os/windows/posix.c b/os/windows/posix.c index 8153b455..d238c64a 100755 --- a/os/windows/posix.c +++ b/os/windows/posix.c @@ -19,6 +19,8 @@ #include <sys/uio.h> #include <sys/resource.h> #include <sys/poll.h> +#include <sys/wait.h> +#include <setjmp.h> #include "../os-windows.h" #include "../../lib/hweight.h" @@ -707,9 +709,22 @@ ssize_t readv(int fildes, const struct iovec *iov, int iovcnt) ssize_t writev(int fildes, const struct iovec *iov, int iovcnt) { - log_err("%s is not implemented\n", __func__); - errno = ENOSYS; - return -1; + int i; + DWORD bytes_written = 0; + for (i = 0; i < iovcnt; i++) + { + int len = send((SOCKET)fildes, iov[i].iov_base, iov[i].iov_len, 0); + if (len == SOCKET_ERROR) + { + DWORD err = GetLastError(); + errno = win_to_posix_error(err); + bytes_written = -1; + break; + } + bytes_written += len; + } + + return bytes_written; } long long strtoll(const char *restrict str, char **restrict endptr, @@ -751,7 +766,6 @@ int poll(struct pollfd fds[], nfds_t nfds, int timeout) FD_SET(fds[i].fd, &exceptfds); } - rc = select(nfds, &readfds, &writefds, &exceptfds, to); if (rc != SOCKET_ERROR) { @@ -771,7 +785,6 @@ int poll(struct pollfd fds[], nfds_t nfds, int timeout) fds[i].revents |= POLLHUP; } } - return rc; } |