* $Id$
*
*/
+#define _XOPEN_SOURCE /* make limits.h #define IOV_MAX */
+
#include "ircd_osdep.h"
+#include "msgq.h"
#include <assert.h>
#include <errno.h>
+#include <limits.h>
#include <netinet/in.h>
#include <stdio.h>
#include <string.h>
#include <sys/resource.h>
#include <sys/socket.h>
#include <sys/types.h>
+#include <sys/uio.h>
#include <unistd.h>
/*
return IO_FAILURE;
}
+IOResult os_sendv_nonb(int fd, struct MsgQ* buf, unsigned int* count_in,
+ unsigned int* count_out)
+{
+ int res;
+ int count;
+ struct iovec iov[IOV_MAX];
+
+ assert(0 != buf);
+ assert(0 != count_in);
+ assert(0 != count_out);
+
+ *count_in = 0;
+ *count_out = 0;
+ errno = 0;
+
+ count = msgq_mapiov(buf, iov, IOV_MAX, count_in);
+
+ if (-1 < (res = writev(fd, iov, count))) {
+ *count_out = (unsigned) res;
+ return IO_SUCCESS;
+ }
+ else if (EAGAIN == errno || ENOBUFS == errno ||
+ ENOMEM == errno || ENOSR == errno)
+ return IO_BLOCKED;
+
+ return IO_FAILURE;
+}
+
int os_connect_nonb(int fd, const struct sockaddr_in* sin)
{
if (connect(fd, (struct sockaddr*) sin, sizeof(struct sockaddr_in))) {