1 /* Copyright (C) 2001-2023 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
16 not, see <https://www.gnu.org/licenses/>. */
20 #include <sys/socket.h>
25 #include <hurd/ifsock.h>
26 #include <hurd/socket.h>
27 #include <sysdep-cancel.h>
28 #include "hurd/hurdsocket.h"
30 /* Send a message described MESSAGE on socket FD.
31 Returns the number of bytes sent, or -1 for errors. */
33 __libc_sendmsg (int fd
, const struct msghdr
*message
, int flags
)
37 mach_port_t
*ports
= NULL
;
38 mach_msg_type_number_t nports
= 0;
40 struct sockaddr_un
*addr
= message
->msg_name
;
41 socklen_t addr_len
= message
->msg_namelen
;
42 addr_port_t aport
= MACH_PORT_NULL
;
47 } data
= { .ptr
= NULL
};
49 mach_msg_type_number_t len
;
55 /* Find the total number of bytes to be written. */
57 for (i
= 0; i
< message
->msg_iovlen
; i
++)
59 if (message
->msg_iov
[i
].iov_len
> 0)
61 /* As an optimization, if we only have a single non-empty
62 iovec, we set DATA and LEN from it. */
64 data
.ptr
= message
->msg_iov
[i
].iov_base
;
68 len
+= message
->msg_iov
[i
].iov_len
;
77 /* Allocate a temporary buffer to hold the data. For small
78 amounts of data, we allocate a buffer on the stack. Larger
79 amounts of data are stored in a page-aligned buffer. The
80 limit of 2048 bytes is inspired by the MiG stubs. */
83 err
= __vm_allocate (__mach_task_self (), &data
.addr
, len
, 1);
94 /* Copy the data into DATA. */
97 for (i
= 0; i
< len
; i
++)
99 #define min(a, b) ((a) > (b) ? (b) : (a))
100 size_t copy
= min (message
->msg_iov
[i
].iov_len
, to_copy
);
102 buf
= __mempcpy (buf
, message
->msg_iov
[i
].iov_base
, copy
);
110 /* Allocate enough room for ports. */
111 cmsg
= CMSG_FIRSTHDR (message
);
112 for (; cmsg
; cmsg
= CMSG_NXTHDR ((struct msghdr
*) message
, cmsg
))
113 if (cmsg
->cmsg_level
== SOL_SOCKET
&& cmsg
->cmsg_type
== SCM_RIGHTS
)
114 nports
+= (cmsg
->cmsg_len
- CMSG_ALIGN (sizeof (struct cmsghdr
)))
118 ports
= __alloca (nports
* sizeof (mach_port_t
));
121 for (cmsg
= CMSG_FIRSTHDR (message
);
123 cmsg
= CMSG_NXTHDR ((struct msghdr
*) message
, cmsg
))
125 if (cmsg
->cmsg_level
== SOL_SOCKET
&& cmsg
->cmsg_type
== SCM_RIGHTS
)
127 /* SCM_RIGHTS support: send FDs. */
128 fds
= (int *) CMSG_DATA (cmsg
);
129 nfds
= (cmsg
->cmsg_len
- CMSG_ALIGN (sizeof (struct cmsghdr
)))
132 for (i
= 0; i
< nfds
; i
++)
137 err
= __io_restrict_auth (port
, &ports
[nports
],
141 /* We pass the flags in the control data. */
142 fds
[i
] = descriptor
->flags
;
154 if (addr
->sun_family
== AF_LOCAL
)
156 char *name
= _hurd_sun_path_dupa (addr
, addr_len
);
157 /* For the local domain, we must look up the name as a file
158 and talk to it with the ifsock protocol. */
159 file_t file
= __file_name_lookup (name
, 0, 0);
160 if (file
== MACH_PORT_NULL
)
165 err
= __ifsock_getsockaddr (file
, &aport
);
166 __mach_port_deallocate (__mach_task_self (), file
);
167 if (err
== MIG_BAD_ID
|| err
== EOPNOTSUPP
)
168 /* The file did not grok the ifsock protocol. */
177 err
= HURD_DPORT_USE_CANCEL (fd
,
180 err
= __socket_create_address (port
,
188 int cancel_oldtype
= LIBC_CANCEL_ASYNC();
189 err
= __socket_send (port
, aport
,
190 flags
, data
.ptr
, len
,
192 MACH_MSG_TYPE_COPY_SEND
,
194 message
->msg_control
,
195 message
->msg_controllen
,
197 LIBC_CANCEL_RESET (cancel_oldtype
);
198 __mach_port_deallocate (__mach_task_self (),
206 for (i
= 0; i
< nports
; i
++)
207 __mach_port_deallocate (__mach_task_self (), ports
[i
]);
210 __vm_deallocate (__mach_task_self (), data
.addr
, len
);
213 return err
? __hurd_sockfail (fd
, flags
, err
) : amount
;
215 return __hurd_fail (err
);
218 weak_alias (__libc_sendmsg
, sendmsg
)
219 weak_alias (__libc_sendmsg
, __sendmsg
)