* fhandler_socket (fhandler_socket::readv): Call recv_internal directly,
rather than recvmsg. (fhandler_socket::writev): Call send_internal directly, rather than sendmsg. * net.cc (cygwin_recv): Call fhandler_socket::recvfrom directly, rather than cygwin_recvfrom. (cygwin_send): Call fhandler_socket::sendto directly, rather than cygwin_sendto.
This commit is contained in:
		| @@ -1368,18 +1368,16 @@ int | |||||||
| fhandler_socket::readv (const struct iovec *const iov, const int iovcnt, | fhandler_socket::readv (const struct iovec *const iov, const int iovcnt, | ||||||
| 			ssize_t tot) | 			ssize_t tot) | ||||||
| { | { | ||||||
|   struct msghdr msg = |   WSABUF wsabuf[iovcnt]; | ||||||
|  |   WSABUF *wsaptr = wsabuf + iovcnt; | ||||||
|  |   const struct iovec *iovptr = iov + iovcnt; | ||||||
|  |   while (--wsaptr >= wsabuf) | ||||||
|     { |     { | ||||||
|       msg_name:		NULL, |       wsaptr->len = (--iovptr)->iov_len; | ||||||
|       msg_namelen:	0, |       wsaptr->buf = (char *) iovptr->iov_base; | ||||||
|       msg_iov:		(struct iovec *) iov, // const_cast |     } | ||||||
|       msg_iovlen:	iovcnt, |   WSAMSG wsamsg = { NULL, 0, wsabuf, iovcnt, { 0,  NULL}, 0 }; | ||||||
|       msg_control:	NULL, |   return recv_internal (&wsamsg); | ||||||
|       msg_controllen:	0, |  | ||||||
|       msg_flags:	0 |  | ||||||
|     }; |  | ||||||
|  |  | ||||||
|   return recvmsg (&msg, 0); |  | ||||||
| } | } | ||||||
|  |  | ||||||
| extern "C" { | extern "C" { | ||||||
| @@ -1580,18 +1578,16 @@ int | |||||||
| fhandler_socket::writev (const struct iovec *const iov, const int iovcnt, | fhandler_socket::writev (const struct iovec *const iov, const int iovcnt, | ||||||
| 			 ssize_t tot) | 			 ssize_t tot) | ||||||
| { | { | ||||||
|   struct msghdr msg = |   WSABUF wsabuf[iovcnt]; | ||||||
|  |   WSABUF *wsaptr = wsabuf; | ||||||
|  |   const struct iovec *iovptr = iov; | ||||||
|  |   for (int i = 0; i < iovcnt; ++i) | ||||||
|     { |     { | ||||||
|       msg_name:		NULL, |       wsaptr->len = iovptr->iov_len; | ||||||
|       msg_namelen:	0, |       (wsaptr++)->buf = (char *) (iovptr++)->iov_base; | ||||||
|       msg_iov:		(struct iovec *) iov, // const_cast |     } | ||||||
|       msg_iovlen:	iovcnt, |   WSAMSG wsamsg = { NULL, 0, wsabuf, iovcnt, { 0, NULL}, 0 }; | ||||||
|       msg_control:	NULL, |   return send_internal (&wsamsg, 0); | ||||||
|       msg_controllen:	0, |  | ||||||
|       msg_flags:	0 |  | ||||||
|     }; |  | ||||||
|  |  | ||||||
|   return sendmsg (&msg, 0); |  | ||||||
| } | } | ||||||
|  |  | ||||||
| inline ssize_t | inline ssize_t | ||||||
|   | |||||||
| @@ -643,7 +643,6 @@ cygwin_sendto (int fd, const void *buf, size_t len, int flags, | |||||||
|  |  | ||||||
|   syscall_printf ("%d = sendto (%d, %p, %d, %x, %p, %d)", |   syscall_printf ("%d = sendto (%d, %p, %d, %x, %p, %d)", | ||||||
| 		  res, fd, buf, len, flags, to, tolen); | 		  res, fd, buf, len, flags, to, tolen); | ||||||
|  |  | ||||||
|   return res; |   return res; | ||||||
| } | } | ||||||
|  |  | ||||||
| @@ -664,7 +663,6 @@ cygwin_recvfrom (int fd, void *buf, size_t len, int flags, | |||||||
|  |  | ||||||
|   syscall_printf ("%d = recvfrom (%d, %p, %d, %x, %p, %p)", |   syscall_printf ("%d = recvfrom (%d, %p, %d, %x, %p, %p)", | ||||||
| 		  res, fd, buf, len, flags, from, fromlen); | 		  res, fd, buf, len, flags, from, fromlen); | ||||||
|  |  | ||||||
|   return res; |   return res; | ||||||
| } | } | ||||||
|  |  | ||||||
| @@ -1448,14 +1446,36 @@ cygwin_getpeername (int fd, struct sockaddr *name, socklen_t *len) | |||||||
| extern "C" int | extern "C" int | ||||||
| cygwin_recv (int fd, void *buf, size_t len, int flags) | cygwin_recv (int fd, void *buf, size_t len, int flags) | ||||||
| { | { | ||||||
|   return cygwin_recvfrom (fd, buf, len, flags, NULL, NULL); |   int res; | ||||||
|  |  | ||||||
|  |   fhandler_socket *fh = get (fd); | ||||||
|  |  | ||||||
|  |   myfault efault; | ||||||
|  |   if (efault.faulted (EFAULT) || !fh) | ||||||
|  |     res = -1; | ||||||
|  |   else if ((res = len) != 0) | ||||||
|  |     res = fh->recvfrom (buf, len, flags, NULL, NULL); | ||||||
|  |  | ||||||
|  |   syscall_printf ("%d = recv (%d, %p, %d, %x)", res, fd, buf, len, flags); | ||||||
|  |   return res; | ||||||
| } | } | ||||||
|  |  | ||||||
| /* exported as send: standards? */ | /* exported as send: standards? */ | ||||||
| extern "C" int | extern "C" int | ||||||
| cygwin_send (int fd, const void *buf, size_t len, int flags) | cygwin_send (int fd, const void *buf, size_t len, int flags) | ||||||
| { | { | ||||||
|   return cygwin_sendto (fd, buf, len, flags, NULL, 0); |   int res; | ||||||
|  |  | ||||||
|  |   fhandler_socket *fh = get (fd); | ||||||
|  |  | ||||||
|  |   myfault efault; | ||||||
|  |   if (efault.faulted (EFAULT) || !fh) | ||||||
|  |     res = -1; | ||||||
|  |   else | ||||||
|  |     res = fh->sendto (buf, len, flags, NULL, 0); | ||||||
|  |  | ||||||
|  |   syscall_printf ("%d = send (%d, %p, %d, %x)", res, fd, buf, len, flags); | ||||||
|  |   return res; | ||||||
| } | } | ||||||
|  |  | ||||||
| /* getdomainname: standards? */ | /* getdomainname: standards? */ | ||||||
|   | |||||||
		Reference in New Issue
	
	Block a user