1 /* Copyright (C) 2001, 2002 Free Software Foundation, Inc.
2 This file is part of the GNU C Library.
4 The GNU C Library is free software; you can redistribute it and/or
5 modify it under the terms of the GNU Lesser General Public License as
6 published by the Free Software Foundation; either version 2.1 of the
7 License, or (at your option) any later version.
9 The GNU C Library is distributed in the hope that it will be useful,
10 but WITHOUT ANY WARRANTY; without even the implied warranty of
11 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
12 Lesser General Public License for more details.
14 You should have received a copy of the GNU Lesser General Public
15 License along with the GNU C Library; see the file COPYING.LIB. If not,
16 write to the Free Software Foundation, Inc., 59 Temple Place - Suite 330,
17 Boston, MA 02111-1307, USA. */
21 #include <sys/socket.h>
25 #include <hurd/socket.h>
27 /* Receive a message as described by MESSAGE from socket FD.
28 Returns the number of bytes read or -1 for errors. */
30 __libc_recvmsg (int fd
, struct msghdr
*message
, int flags
)
35 mach_msg_type_number_t len
= 0;
37 mach_msg_type_number_t nports
= 0;
39 mach_msg_type_number_t clen
= 0;
44 /* Find the total number of bytes to be read. */
46 for (i
= 0; i
< message
->msg_iovlen
; i
++)
48 amount
+= message
->msg_iov
[i
].iov_len
;
50 /* As an optimization, we set the initial values of DATA and LEN
51 from the first non-empty iovec. This kicks-in in the case
52 where the whole packet fits into that iovec buffer. */
53 if (data
== NULL
&& message
->msg_iov
[i
].iov_len
> 0)
55 data
= message
->msg_iov
[i
].iov_base
;
56 len
= message
->msg_iov
[i
].iov_len
;
61 if (err
= HURD_DPORT_USE (fd
, __socket_recv (port
, &aport
,
65 &message
->msg_flags
, amount
)))
66 return __hurd_sockfail (fd
, flags
, err
);
68 if (message
->msg_name
!= NULL
)
70 char *buf
= message
->msg_name
;
71 mach_msg_type_number_t buflen
= message
->msg_namelen
;
74 err
= __socket_whatis_address (aport
, &type
, &buf
, &buflen
);
75 if (err
== EOPNOTSUPP
)
76 /* If the protocol server can't tell us the address, just return a
79 buf
= message
->msg_name
;
86 __mach_port_deallocate (__mach_task_self (), aport
);
87 return __hurd_sockfail (fd
, flags
, err
);
90 if (message
->msg_namelen
> buflen
)
91 message
->msg_namelen
= buflen
;
93 if (buf
!= message
->msg_name
)
95 memcpy (message
->msg_name
, buf
, message
->msg_namelen
);
96 __vm_deallocate (__mach_task_self (), (vm_address_t
) buf
, buflen
);
100 ((struct sockaddr
*) message
->msg_name
)->sa_family
= type
;
103 __mach_port_deallocate (__mach_task_self (), aport
);
109 /* Copy the data into MSG. */
111 message
->msg_flags
|= MSG_TRUNC
;
116 for (i
= 0; i
< message
->msg_iovlen
; i
++)
118 #define min(a, b) ((a) > (b) ? (b) : (a))
119 size_t copy
= min (message
->msg_iov
[i
].iov_len
, amount
);
121 memcpy (message
->msg_iov
[i
].iov_base
, buf
, copy
);
129 __vm_deallocate (__mach_task_self (), (vm_address_t
) data
, len
);
132 /* Copy the control message into MSG. */
133 if (clen
> message
->msg_controllen
)
134 message
->msg_flags
|= MSG_CTRUNC
;
136 message
->msg_controllen
= clen
;
137 memcpy (message
->msg_control
, cdata
, message
->msg_controllen
);
139 __vm_deallocate (__mach_task_self (), (vm_address_t
) cdata
, clen
);
144 weak_alias (__libc_recvmsg
, recvmsg
)
145 weak_alias (__libc_recvmsg
, __recvmsg
)