]> CyberLeo.Net >> Repos - FreeBSD/stable/10.git/blob - sys/compat/linux/linux_socket.c
MFC r283490:
[FreeBSD/stable/10.git] / sys / compat / linux / linux_socket.c
1 /*-
2  * Copyright (c) 1995 Søren Schmidt
3  * All rights reserved.
4  *
5  * Redistribution and use in source and binary forms, with or without
6  * modification, are permitted provided that the following conditions
7  * are met:
8  * 1. Redistributions of source code must retain the above copyright
9  *    notice, this list of conditions and the following disclaimer
10  *    in this position and unchanged.
11  * 2. Redistributions in binary form must reproduce the above copyright
12  *    notice, this list of conditions and the following disclaimer in the
13  *    documentation and/or other materials provided with the distribution.
14  * 3. The name of the author may not be used to endorse or promote products
15  *    derived from this software without specific prior written permission
16  *
17  * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
18  * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
19  * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
20  * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,
21  * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
22  * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
23  * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
24  * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
25  * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
26  * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
27  */
28
29 #include <sys/cdefs.h>
30 __FBSDID("$FreeBSD$");
31
32 /* XXX we use functions that might not exist. */
33 #include "opt_compat.h"
34 #include "opt_inet6.h"
35
36 #include <sys/param.h>
37 #include <sys/proc.h>
38 #include <sys/systm.h>
39 #include <sys/sysproto.h>
40 #include <sys/capsicum.h>
41 #include <sys/fcntl.h>
42 #include <sys/file.h>
43 #include <sys/limits.h>
44 #include <sys/lock.h>
45 #include <sys/malloc.h>
46 #include <sys/mutex.h>
47 #include <sys/mbuf.h>
48 #include <sys/socket.h>
49 #include <sys/socketvar.h>
50 #include <sys/syscallsubr.h>
51 #include <sys/uio.h>
52 #include <sys/syslog.h>
53 #include <sys/un.h>
54
55 #include <net/if.h>
56 #include <netinet/in.h>
57 #include <netinet/in_systm.h>
58 #include <netinet/ip.h>
59 #include <netinet/tcp.h>
60 #ifdef INET6
61 #include <netinet/ip6.h>
62 #include <netinet6/ip6_var.h>
63 #include <netinet6/in6_var.h>
64 #endif
65
66 #ifdef COMPAT_LINUX32
67 #include <machine/../linux32/linux.h>
68 #include <machine/../linux32/linux32_proto.h>
69 #else
70 #include <machine/../linux/linux.h>
71 #include <machine/../linux/linux_proto.h>
72 #endif
73 #include <compat/linux/linux_file.h>
74 #include <compat/linux/linux_socket.h>
75 #include <compat/linux/linux_timer.h>
76 #include <compat/linux/linux_util.h>
77
78 static int linux_to_bsd_domain(int);
79 static int linux_sendmsg_common(struct thread *, l_int, struct l_msghdr *,
80                                         l_uint);
81 static int linux_recvmsg_common(struct thread *, l_int, struct l_msghdr *,
82                                         l_uint, struct msghdr *);
83 static int linux_set_socket_flags(int, int *);
84
85 /*
86  * Reads a linux sockaddr and does any necessary translation.
87  * Linux sockaddrs don't have a length field, only a family.
88  * Copy the osockaddr structure pointed to by osa to kernel, adjust
89  * family and convert to sockaddr.
90  */
91 static int
92 linux_getsockaddr(struct sockaddr **sap, const struct osockaddr *osa, int salen)
93 {
94         struct sockaddr *sa;
95         struct osockaddr *kosa;
96 #ifdef INET6
97         struct sockaddr_in6 *sin6;
98         int oldv6size;
99 #endif
100         char *name;
101         int bdom, error, hdrlen, namelen;
102
103         if (salen < 2 || salen > UCHAR_MAX || !osa)
104                 return (EINVAL);
105
106 #ifdef INET6
107         oldv6size = 0;
108         /*
109          * Check for old (pre-RFC2553) sockaddr_in6. We may accept it
110          * if it's a v4-mapped address, so reserve the proper space
111          * for it.
112          */
113         if (salen == sizeof(struct sockaddr_in6) - sizeof(uint32_t)) {
114                 salen += sizeof(uint32_t);
115                 oldv6size = 1;
116         }
117 #endif
118
119         kosa = malloc(salen, M_SONAME, M_WAITOK);
120
121         if ((error = copyin(osa, kosa, salen)))
122                 goto out;
123
124         bdom = linux_to_bsd_domain(kosa->sa_family);
125         if (bdom == -1) {
126                 error = EAFNOSUPPORT;
127                 goto out;
128         }
129
130 #ifdef INET6
131         /*
132          * Older Linux IPv6 code uses obsolete RFC2133 struct sockaddr_in6,
133          * which lacks the scope id compared with RFC2553 one. If we detect
134          * the situation, reject the address and write a message to system log.
135          *
136          * Still accept addresses for which the scope id is not used.
137          */
138         if (oldv6size) {
139                 if (bdom == AF_INET6) {
140                         sin6 = (struct sockaddr_in6 *)kosa;
141                         if (IN6_IS_ADDR_V4MAPPED(&sin6->sin6_addr) ||
142                             (!IN6_IS_ADDR_LINKLOCAL(&sin6->sin6_addr) &&
143                              !IN6_IS_ADDR_SITELOCAL(&sin6->sin6_addr) &&
144                              !IN6_IS_ADDR_V4COMPAT(&sin6->sin6_addr) &&
145                              !IN6_IS_ADDR_UNSPECIFIED(&sin6->sin6_addr) &&
146                              !IN6_IS_ADDR_MULTICAST(&sin6->sin6_addr))) {
147                                 sin6->sin6_scope_id = 0;
148                         } else {
149                                 log(LOG_DEBUG,
150                                     "obsolete pre-RFC2553 sockaddr_in6 rejected\n");
151                                 error = EINVAL;
152                                 goto out;
153                         }
154                 } else
155                         salen -= sizeof(uint32_t);
156         }
157 #endif
158         if (bdom == AF_INET) {
159                 if (salen < sizeof(struct sockaddr_in)) {
160                         error = EINVAL;
161                         goto out;
162                 }
163                 salen = sizeof(struct sockaddr_in);
164         }
165
166         if (bdom == AF_LOCAL && salen > sizeof(struct sockaddr_un)) {
167                 hdrlen = offsetof(struct sockaddr_un, sun_path);
168                 name = ((struct sockaddr_un *)kosa)->sun_path;
169                 if (*name == '\0') {
170                         /*
171                          * Linux abstract namespace starts with a NULL byte.
172                          * XXX We do not support abstract namespace yet.
173                          */
174                         namelen = strnlen(name + 1, salen - hdrlen - 1) + 1;
175                 } else
176                         namelen = strnlen(name, salen - hdrlen);
177                 salen = hdrlen + namelen;
178                 if (salen > sizeof(struct sockaddr_un)) {
179                         error = ENAMETOOLONG;
180                         goto out;
181                 }
182         }
183
184         sa = (struct sockaddr *)kosa;
185         sa->sa_family = bdom;
186         sa->sa_len = salen;
187
188         *sap = sa;
189         return (0);
190
191 out:
192         free(kosa, M_SONAME);
193         return (error);
194 }
195
196 static int
197 linux_to_bsd_domain(int domain)
198 {
199
200         switch (domain) {
201         case LINUX_AF_UNSPEC:
202                 return (AF_UNSPEC);
203         case LINUX_AF_UNIX:
204                 return (AF_LOCAL);
205         case LINUX_AF_INET:
206                 return (AF_INET);
207         case LINUX_AF_INET6:
208                 return (AF_INET6);
209         case LINUX_AF_AX25:
210                 return (AF_CCITT);
211         case LINUX_AF_IPX:
212                 return (AF_IPX);
213         case LINUX_AF_APPLETALK:
214                 return (AF_APPLETALK);
215         }
216         return (-1);
217 }
218
219 static int
220 bsd_to_linux_domain(int domain)
221 {
222
223         switch (domain) {
224         case AF_UNSPEC:
225                 return (LINUX_AF_UNSPEC);
226         case AF_LOCAL:
227                 return (LINUX_AF_UNIX);
228         case AF_INET:
229                 return (LINUX_AF_INET);
230         case AF_INET6:
231                 return (LINUX_AF_INET6);
232         case AF_CCITT:
233                 return (LINUX_AF_AX25);
234         case AF_IPX:
235                 return (LINUX_AF_IPX);
236         case AF_APPLETALK:
237                 return (LINUX_AF_APPLETALK);
238         }
239         return (-1);
240 }
241
242 static int
243 linux_to_bsd_sockopt_level(int level)
244 {
245
246         switch (level) {
247         case LINUX_SOL_SOCKET:
248                 return (SOL_SOCKET);
249         }
250         return (level);
251 }
252
253 static int
254 bsd_to_linux_sockopt_level(int level)
255 {
256
257         switch (level) {
258         case SOL_SOCKET:
259                 return (LINUX_SOL_SOCKET);
260         }
261         return (level);
262 }
263
264 static int
265 linux_to_bsd_ip_sockopt(int opt)
266 {
267
268         switch (opt) {
269         case LINUX_IP_TOS:
270                 return (IP_TOS);
271         case LINUX_IP_TTL:
272                 return (IP_TTL);
273         case LINUX_IP_OPTIONS:
274                 return (IP_OPTIONS);
275         case LINUX_IP_MULTICAST_IF:
276                 return (IP_MULTICAST_IF);
277         case LINUX_IP_MULTICAST_TTL:
278                 return (IP_MULTICAST_TTL);
279         case LINUX_IP_MULTICAST_LOOP:
280                 return (IP_MULTICAST_LOOP);
281         case LINUX_IP_ADD_MEMBERSHIP:
282                 return (IP_ADD_MEMBERSHIP);
283         case LINUX_IP_DROP_MEMBERSHIP:
284                 return (IP_DROP_MEMBERSHIP);
285         case LINUX_IP_HDRINCL:
286                 return (IP_HDRINCL);
287         }
288         return (-1);
289 }
290
291 static int
292 linux_to_bsd_so_sockopt(int opt)
293 {
294
295         switch (opt) {
296         case LINUX_SO_DEBUG:
297                 return (SO_DEBUG);
298         case LINUX_SO_REUSEADDR:
299                 return (SO_REUSEADDR);
300         case LINUX_SO_TYPE:
301                 return (SO_TYPE);
302         case LINUX_SO_ERROR:
303                 return (SO_ERROR);
304         case LINUX_SO_DONTROUTE:
305                 return (SO_DONTROUTE);
306         case LINUX_SO_BROADCAST:
307                 return (SO_BROADCAST);
308         case LINUX_SO_SNDBUF:
309                 return (SO_SNDBUF);
310         case LINUX_SO_RCVBUF:
311                 return (SO_RCVBUF);
312         case LINUX_SO_KEEPALIVE:
313                 return (SO_KEEPALIVE);
314         case LINUX_SO_OOBINLINE:
315                 return (SO_OOBINLINE);
316         case LINUX_SO_LINGER:
317                 return (SO_LINGER);
318         case LINUX_SO_PEERCRED:
319                 return (LOCAL_PEERCRED);
320         case LINUX_SO_RCVLOWAT:
321                 return (SO_RCVLOWAT);
322         case LINUX_SO_SNDLOWAT:
323                 return (SO_SNDLOWAT);
324         case LINUX_SO_RCVTIMEO:
325                 return (SO_RCVTIMEO);
326         case LINUX_SO_SNDTIMEO:
327                 return (SO_SNDTIMEO);
328         case LINUX_SO_TIMESTAMP:
329                 return (SO_TIMESTAMP);
330         case LINUX_SO_ACCEPTCONN:
331                 return (SO_ACCEPTCONN);
332         }
333         return (-1);
334 }
335
336 static int
337 linux_to_bsd_tcp_sockopt(int opt)
338 {
339
340         switch (opt) {
341         case LINUX_TCP_NODELAY:
342                 return (TCP_NODELAY);
343         case LINUX_TCP_MAXSEG:
344                 return (TCP_MAXSEG);
345         case LINUX_TCP_KEEPIDLE:
346                 return (TCP_KEEPIDLE);
347         case LINUX_TCP_KEEPINTVL:
348                 return (TCP_KEEPINTVL);
349         case LINUX_TCP_KEEPCNT:
350                 return (TCP_KEEPCNT);
351         case LINUX_TCP_MD5SIG:
352                 return (TCP_MD5SIG);
353         }
354         return (-1);
355 }
356
357 static int
358 linux_to_bsd_msg_flags(int flags)
359 {
360         int ret_flags = 0;
361
362         if (flags & LINUX_MSG_OOB)
363                 ret_flags |= MSG_OOB;
364         if (flags & LINUX_MSG_PEEK)
365                 ret_flags |= MSG_PEEK;
366         if (flags & LINUX_MSG_DONTROUTE)
367                 ret_flags |= MSG_DONTROUTE;
368         if (flags & LINUX_MSG_CTRUNC)
369                 ret_flags |= MSG_CTRUNC;
370         if (flags & LINUX_MSG_TRUNC)
371                 ret_flags |= MSG_TRUNC;
372         if (flags & LINUX_MSG_DONTWAIT)
373                 ret_flags |= MSG_DONTWAIT;
374         if (flags & LINUX_MSG_EOR)
375                 ret_flags |= MSG_EOR;
376         if (flags & LINUX_MSG_WAITALL)
377                 ret_flags |= MSG_WAITALL;
378         if (flags & LINUX_MSG_NOSIGNAL)
379                 ret_flags |= MSG_NOSIGNAL;
380 #if 0 /* not handled */
381         if (flags & LINUX_MSG_PROXY)
382                 ;
383         if (flags & LINUX_MSG_FIN)
384                 ;
385         if (flags & LINUX_MSG_SYN)
386                 ;
387         if (flags & LINUX_MSG_CONFIRM)
388                 ;
389         if (flags & LINUX_MSG_RST)
390                 ;
391         if (flags & LINUX_MSG_ERRQUEUE)
392                 ;
393 #endif
394         return ret_flags;
395 }
396
397 /*
398 * If bsd_to_linux_sockaddr() or linux_to_bsd_sockaddr() faults, then the
399 * native syscall will fault.  Thus, we don't really need to check the
400 * return values for these functions.
401 */
402
403 static int
404 bsd_to_linux_sockaddr(struct sockaddr *arg)
405 {
406         struct sockaddr sa;
407         size_t sa_len = sizeof(struct sockaddr);
408         int error;
409         
410         if ((error = copyin(arg, &sa, sa_len)))
411                 return (error);
412         
413         *(u_short *)&sa = sa.sa_family;
414         
415         error = copyout(&sa, arg, sa_len);
416         
417         return (error);
418 }
419
420 static int
421 linux_to_bsd_sockaddr(struct sockaddr *arg, int len)
422 {
423         struct sockaddr sa;
424         size_t sa_len = sizeof(struct sockaddr);
425         int error;
426
427         if ((error = copyin(arg, &sa, sa_len)))
428                 return (error);
429
430         sa.sa_family = *(sa_family_t *)&sa;
431         sa.sa_len = len;
432
433         error = copyout(&sa, arg, sa_len);
434
435         return (error);
436 }
437
438 static int
439 linux_sa_put(struct osockaddr *osa)
440 {
441         struct osockaddr sa;
442         int error, bdom;
443
444         /*
445          * Only read/write the osockaddr family part, the rest is
446          * not changed.
447          */
448         error = copyin(osa, &sa, sizeof(sa.sa_family));
449         if (error)
450                 return (error);
451
452         bdom = bsd_to_linux_domain(sa.sa_family);
453         if (bdom == -1)
454                 return (EINVAL);
455
456         sa.sa_family = bdom;
457         error = copyout(&sa, osa, sizeof(sa.sa_family));
458         if (error)
459                 return (error);
460
461         return (0);
462 }
463
464 static int
465 linux_to_bsd_cmsg_type(int cmsg_type)
466 {
467
468         switch (cmsg_type) {
469         case LINUX_SCM_RIGHTS:
470                 return (SCM_RIGHTS);
471         case LINUX_SCM_CREDENTIALS:
472                 return (SCM_CREDS);
473         }
474         return (-1);
475 }
476
477 static int
478 bsd_to_linux_cmsg_type(int cmsg_type)
479 {
480
481         switch (cmsg_type) {
482         case SCM_RIGHTS:
483                 return (LINUX_SCM_RIGHTS);
484         case SCM_CREDS:
485                 return (LINUX_SCM_CREDENTIALS);
486         }
487         return (-1);
488 }
489
490 static int
491 linux_to_bsd_msghdr(struct msghdr *bhdr, const struct l_msghdr *lhdr)
492 {
493         if (lhdr->msg_controllen > INT_MAX)
494                 return (ENOBUFS);
495
496         bhdr->msg_name          = PTRIN(lhdr->msg_name);
497         bhdr->msg_namelen       = lhdr->msg_namelen;
498         bhdr->msg_iov           = PTRIN(lhdr->msg_iov);
499         bhdr->msg_iovlen        = lhdr->msg_iovlen;
500         bhdr->msg_control       = PTRIN(lhdr->msg_control);
501
502         /*
503          * msg_controllen is skipped since BSD and LINUX control messages
504          * are potentially different sizes (e.g. the cred structure used
505          * by SCM_CREDS is different between the two operating system).
506          *
507          * The caller can set it (if necessary) after converting all the
508          * control messages.
509          */
510
511         bhdr->msg_flags         = linux_to_bsd_msg_flags(lhdr->msg_flags);
512         return (0);
513 }
514
515 static int
516 bsd_to_linux_msghdr(const struct msghdr *bhdr, struct l_msghdr *lhdr)
517 {
518         lhdr->msg_name          = PTROUT(bhdr->msg_name);
519         lhdr->msg_namelen       = bhdr->msg_namelen;
520         lhdr->msg_iov           = PTROUT(bhdr->msg_iov);
521         lhdr->msg_iovlen        = bhdr->msg_iovlen;
522         lhdr->msg_control       = PTROUT(bhdr->msg_control);
523
524         /*
525          * msg_controllen is skipped since BSD and LINUX control messages
526          * are potentially different sizes (e.g. the cred structure used
527          * by SCM_CREDS is different between the two operating system).
528          *
529          * The caller can set it (if necessary) after converting all the
530          * control messages.
531          */
532
533         /* msg_flags skipped */
534         return (0);
535 }
536
537 static int
538 linux_set_socket_flags(int lflags, int *flags)
539 {
540
541         if (lflags & ~(LINUX_SOCK_CLOEXEC | LINUX_SOCK_NONBLOCK))
542                 return (EINVAL);
543         if (lflags & LINUX_SOCK_NONBLOCK)
544                 *flags |= SOCK_NONBLOCK;
545         if (lflags & LINUX_SOCK_CLOEXEC)
546                 *flags |= SOCK_CLOEXEC;
547         return (0);
548 }
549
550 static int
551 linux_sendit(struct thread *td, int s, struct msghdr *mp, int flags,
552     struct mbuf *control, enum uio_seg segflg)
553 {
554         struct sockaddr *to;
555         int error;
556
557         if (mp->msg_name != NULL) {
558                 error = linux_getsockaddr(&to, mp->msg_name, mp->msg_namelen);
559                 if (error)
560                         return (error);
561                 mp->msg_name = to;
562         } else
563                 to = NULL;
564
565         error = kern_sendit(td, s, mp, linux_to_bsd_msg_flags(flags), control,
566             segflg);
567
568         if (to)
569                 free(to, M_SONAME);
570         return (error);
571 }
572
573 /* Return 0 if IP_HDRINCL is set for the given socket. */
574 static int
575 linux_check_hdrincl(struct thread *td, int s)
576 {
577         int error, optval;
578         socklen_t size_val;
579
580         size_val = sizeof(optval);
581         error = kern_getsockopt(td, s, IPPROTO_IP, IP_HDRINCL,
582             &optval, UIO_SYSSPACE, &size_val);
583         if (error)
584                 return (error);
585
586         return (optval == 0);
587 }
588
589 /*
590  * Updated sendto() when IP_HDRINCL is set:
591  * tweak endian-dependent fields in the IP packet.
592  */
593 static int
594 linux_sendto_hdrincl(struct thread *td, struct linux_sendto_args *linux_args)
595 {
596 /*
597  * linux_ip_copysize defines how many bytes we should copy
598  * from the beginning of the IP packet before we customize it for BSD.
599  * It should include all the fields we modify (ip_len and ip_off).
600  */
601 #define linux_ip_copysize       8
602
603         struct ip *packet;
604         struct msghdr msg;
605         struct iovec aiov[1];
606         int error;
607
608         /* Check that the packet isn't too big or too small. */
609         if (linux_args->len < linux_ip_copysize ||
610             linux_args->len > IP_MAXPACKET)
611                 return (EINVAL);
612
613         packet = (struct ip *)malloc(linux_args->len, M_LINUX, M_WAITOK);
614
615         /* Make kernel copy of the packet to be sent */
616         if ((error = copyin(PTRIN(linux_args->msg), packet,
617             linux_args->len)))
618                 goto goout;
619
620         /* Convert fields from Linux to BSD raw IP socket format */
621         packet->ip_len = linux_args->len;
622         packet->ip_off = ntohs(packet->ip_off);
623
624         /* Prepare the msghdr and iovec structures describing the new packet */
625         msg.msg_name = PTRIN(linux_args->to);
626         msg.msg_namelen = linux_args->tolen;
627         msg.msg_iov = aiov;
628         msg.msg_iovlen = 1;
629         msg.msg_control = NULL;
630         msg.msg_flags = 0;
631         aiov[0].iov_base = (char *)packet;
632         aiov[0].iov_len = linux_args->len;
633         error = linux_sendit(td, linux_args->s, &msg, linux_args->flags,
634             NULL, UIO_SYSSPACE);
635 goout:
636         free(packet, M_LINUX);
637         return (error);
638 }
639
640 int
641 linux_socket(struct thread *td, struct linux_socket_args *args)
642 {
643         struct socket_args /* {
644                 int domain;
645                 int type;
646                 int protocol;
647         } */ bsd_args;
648         int retval_socket;
649
650         bsd_args.protocol = args->protocol;
651         bsd_args.type = args->type & LINUX_SOCK_TYPE_MASK;
652         if (bsd_args.type < 0 || bsd_args.type > LINUX_SOCK_MAX)
653                 return (EINVAL);
654         retval_socket = linux_set_socket_flags(args->type & ~LINUX_SOCK_TYPE_MASK,
655                 &bsd_args.type);
656         if (retval_socket != 0)
657                 return (retval_socket);
658         bsd_args.domain = linux_to_bsd_domain(args->domain);
659         if (bsd_args.domain == -1)
660                 return (EAFNOSUPPORT);
661
662         retval_socket = sys_socket(td, &bsd_args);
663         if (retval_socket)
664                 return (retval_socket);
665
666         if (bsd_args.type == SOCK_RAW
667             && (bsd_args.protocol == IPPROTO_RAW || bsd_args.protocol == 0)
668             && bsd_args.domain == PF_INET) {
669                 /* It's a raw IP socket: set the IP_HDRINCL option. */
670                 int hdrincl;
671
672                 hdrincl = 1;
673                 /* We ignore any error returned by kern_setsockopt() */
674                 kern_setsockopt(td, td->td_retval[0], IPPROTO_IP, IP_HDRINCL,
675                     &hdrincl, UIO_SYSSPACE, sizeof(hdrincl));
676         }
677 #ifdef INET6
678         /*
679          * Linux AF_INET6 socket has IPV6_V6ONLY setsockopt set to 0 by default
680          * and some apps depend on this. So, set V6ONLY to 0 for Linux apps.
681          * For simplicity we do this unconditionally of the net.inet6.ip6.v6only
682          * sysctl value.
683          */
684         if (bsd_args.domain == PF_INET6) {
685                 int v6only;
686
687                 v6only = 0;
688                 /* We ignore any error returned by setsockopt() */
689                 kern_setsockopt(td, td->td_retval[0], IPPROTO_IPV6, IPV6_V6ONLY,
690                     &v6only, UIO_SYSSPACE, sizeof(v6only));
691         }
692 #endif
693
694         return (retval_socket);
695 }
696
697 int
698 linux_bind(struct thread *td, struct linux_bind_args *args)
699 {
700         struct sockaddr *sa;
701         int error;
702
703         error = linux_getsockaddr(&sa, PTRIN(args->name),
704             args->namelen);
705         if (error)
706                 return (error);
707
708         error = kern_bind(td, args->s, sa);
709         free(sa, M_SONAME);
710         if (error == EADDRNOTAVAIL && args->namelen != sizeof(struct sockaddr_in))
711                 return (EINVAL);
712         return (error);
713 }
714
715 int
716 linux_connect(struct thread *td, struct linux_connect_args *args)
717 {
718         cap_rights_t rights;
719         struct socket *so;
720         struct sockaddr *sa;
721         u_int fflag;
722         int error;
723
724         error = linux_getsockaddr(&sa, (struct osockaddr *)PTRIN(args->name),
725             args->namelen);
726         if (error)
727                 return (error);
728
729         error = kern_connect(td, args->s, sa);
730         free(sa, M_SONAME);
731         if (error != EISCONN)
732                 return (error);
733
734         /*
735          * Linux doesn't return EISCONN the first time it occurs,
736          * when on a non-blocking socket. Instead it returns the
737          * error getsockopt(SOL_SOCKET, SO_ERROR) would return on BSD.
738          *
739          * XXXRW: Instead of using fgetsock(), check that it is a
740          * socket and use the file descriptor reference instead of
741          * creating a new one.
742          */
743         error = fgetsock(td, args->s, cap_rights_init(&rights, CAP_CONNECT),
744             &so, &fflag);
745         if (error == 0) {
746                 error = EISCONN;
747                 if (fflag & FNONBLOCK) {
748                         SOCK_LOCK(so);
749                         if (so->so_emuldata == 0)
750                                 error = so->so_error;
751                         so->so_emuldata = (void *)1;
752                         SOCK_UNLOCK(so);
753                 }
754                 fputsock(so);
755         }
756         return (error);
757 }
758
759 int
760 linux_listen(struct thread *td, struct linux_listen_args *args)
761 {
762         struct listen_args /* {
763                 int s;
764                 int backlog;
765         } */ bsd_args;
766
767         bsd_args.s = args->s;
768         bsd_args.backlog = args->backlog;
769         return (sys_listen(td, &bsd_args));
770 }
771
772 static int
773 linux_accept_common(struct thread *td, int s, l_uintptr_t addr,
774     l_uintptr_t namelen, int flags)
775 {
776         struct accept4_args /* {
777                 int     s;
778                 struct sockaddr * __restrict name;
779                 socklen_t * __restrict anamelen;
780                 int     flags;
781         } */ bsd_args;
782         int error;
783
784         bsd_args.s = s;
785         /* XXX: */
786         bsd_args.name = (struct sockaddr * __restrict)PTRIN(addr);
787         bsd_args.anamelen = PTRIN(namelen);/* XXX */
788         error = linux_set_socket_flags(flags, &bsd_args.flags);
789         if (error != 0)
790                 return (error);
791         error = sys_accept4(td, &bsd_args);
792         bsd_to_linux_sockaddr((struct sockaddr *)bsd_args.name);
793         if (error) {
794                 if (error == EFAULT && namelen != sizeof(struct sockaddr_in))
795                         return (EINVAL);
796                 return (error);
797         }
798         if (addr)
799                 error = linux_sa_put(PTRIN(addr));
800         if (error) {
801                 (void)kern_close(td, td->td_retval[0]);
802                 td->td_retval[0] = 0;
803         }
804         return (error);
805 }
806
807 int
808 linux_accept(struct thread *td, struct linux_accept_args *args)
809 {
810
811         return (linux_accept_common(td, args->s, args->addr,
812             args->namelen, 0));
813 }
814
815 int
816 linux_accept4(struct thread *td, struct linux_accept4_args *args)
817 {
818
819         return (linux_accept_common(td, args->s, args->addr,
820             args->namelen, args->flags));
821 }
822
823 int
824 linux_getsockname(struct thread *td, struct linux_getsockname_args *args)
825 {
826         struct getsockname_args /* {
827                 int     fdes;
828                 struct sockaddr * __restrict asa;
829                 socklen_t * __restrict alen;
830         } */ bsd_args;
831         int error;
832
833         bsd_args.fdes = args->s;
834         /* XXX: */
835         bsd_args.asa = (struct sockaddr * __restrict)PTRIN(args->addr);
836         bsd_args.alen = PTRIN(args->namelen);   /* XXX */
837         error = sys_getsockname(td, &bsd_args);
838         bsd_to_linux_sockaddr((struct sockaddr *)bsd_args.asa);
839         if (error)
840                 return (error);
841         error = linux_sa_put(PTRIN(args->addr));
842         if (error)
843                 return (error);
844         return (0);
845 }
846
847 int
848 linux_getpeername(struct thread *td, struct linux_getpeername_args *args)
849 {
850         struct getpeername_args /* {
851                 int fdes;
852                 caddr_t asa;
853                 int *alen;
854         } */ bsd_args;
855         int error;
856
857         bsd_args.fdes = args->s;
858         bsd_args.asa = (struct sockaddr *)PTRIN(args->addr);
859         bsd_args.alen = (socklen_t *)PTRIN(args->namelen);
860         error = sys_getpeername(td, &bsd_args);
861         bsd_to_linux_sockaddr((struct sockaddr *)bsd_args.asa);
862         if (error)
863                 return (error);
864         error = linux_sa_put(PTRIN(args->addr));
865         if (error)
866                 return (error);
867         return (0);
868 }
869
870 int
871 linux_socketpair(struct thread *td, struct linux_socketpair_args *args)
872 {
873         struct socketpair_args /* {
874                 int domain;
875                 int type;
876                 int protocol;
877                 int *rsv;
878         } */ bsd_args;
879         int error;
880
881         bsd_args.domain = linux_to_bsd_domain(args->domain);
882         if (bsd_args.domain != PF_LOCAL)
883                 return (EAFNOSUPPORT);
884         bsd_args.type = args->type & LINUX_SOCK_TYPE_MASK;
885         if (bsd_args.type < 0 || bsd_args.type > LINUX_SOCK_MAX)
886                 return (EINVAL);
887         error = linux_set_socket_flags(args->type & ~LINUX_SOCK_TYPE_MASK,
888                 &bsd_args.type);
889         if (error != 0)
890                 return (error);
891         if (args->protocol != 0 && args->protocol != PF_UNIX)
892
893                 /*
894                  * Use of PF_UNIX as protocol argument is not right,
895                  * but Linux does it.
896                  * Do not map PF_UNIX as its Linux value is identical
897                  * to FreeBSD one.
898                  */
899                 return (EPROTONOSUPPORT);
900         else
901                 bsd_args.protocol = 0;
902         bsd_args.rsv = (int *)PTRIN(args->rsv);
903         return (sys_socketpair(td, &bsd_args));
904 }
905
906 #if defined(__i386__) || (defined(__amd64__) && defined(COMPAT_LINUX32))
907 struct linux_send_args {
908         int s;
909         l_uintptr_t msg;
910         int len;
911         int flags;
912 };
913
914 static int
915 linux_send(struct thread *td, struct linux_send_args *args)
916 {
917         struct sendto_args /* {
918                 int s;
919                 caddr_t buf;
920                 int len;
921                 int flags;
922                 caddr_t to;
923                 int tolen;
924         } */ bsd_args;
925
926         bsd_args.s = args->s;
927         bsd_args.buf = (caddr_t)PTRIN(args->msg);
928         bsd_args.len = args->len;
929         bsd_args.flags = args->flags;
930         bsd_args.to = NULL;
931         bsd_args.tolen = 0;
932         return sys_sendto(td, &bsd_args);
933 }
934
935 struct linux_recv_args {
936         int s;
937         l_uintptr_t msg;
938         int len;
939         int flags;
940 };
941
942 static int
943 linux_recv(struct thread *td, struct linux_recv_args *args)
944 {
945         struct recvfrom_args /* {
946                 int s;
947                 caddr_t buf;
948                 int len;
949                 int flags;
950                 struct sockaddr *from;
951                 socklen_t fromlenaddr;
952         } */ bsd_args;
953
954         bsd_args.s = args->s;
955         bsd_args.buf = (caddr_t)PTRIN(args->msg);
956         bsd_args.len = args->len;
957         bsd_args.flags = linux_to_bsd_msg_flags(args->flags);
958         bsd_args.from = NULL;
959         bsd_args.fromlenaddr = 0;
960         return (sys_recvfrom(td, &bsd_args));
961 }
962 #endif /* __i386__ || (__amd64__ && COMPAT_LINUX32) */
963
964 int
965 linux_sendto(struct thread *td, struct linux_sendto_args *args)
966 {
967         struct msghdr msg;
968         struct iovec aiov;
969         int error;
970
971         if (linux_check_hdrincl(td, args->s) == 0)
972                 /* IP_HDRINCL set, tweak the packet before sending */
973                 return (linux_sendto_hdrincl(td, args));
974
975         msg.msg_name = PTRIN(args->to);
976         msg.msg_namelen = args->tolen;
977         msg.msg_iov = &aiov;
978         msg.msg_iovlen = 1;
979         msg.msg_control = NULL;
980         msg.msg_flags = 0;
981         aiov.iov_base = PTRIN(args->msg);
982         aiov.iov_len = args->len;
983         error = linux_sendit(td, args->s, &msg, args->flags, NULL,
984             UIO_USERSPACE);
985         return (error);
986 }
987
988 int
989 linux_recvfrom(struct thread *td, struct linux_recvfrom_args *args)
990 {
991         struct msghdr msg;
992         struct iovec aiov;
993         int error;
994
995         if (PTRIN(args->fromlen) != NULL) {
996                 error = copyin(PTRIN(args->fromlen), &msg.msg_namelen,
997                     sizeof(msg.msg_namelen));
998                 if (error != 0)
999                         return (error);
1000
1001                 error = linux_to_bsd_sockaddr((struct sockaddr *)PTRIN(args->from),
1002                     msg.msg_namelen);
1003                 if (error != 0)
1004                         return (error);
1005         } else
1006                 msg.msg_namelen = 0;
1007
1008         msg.msg_name = (struct sockaddr * __restrict)PTRIN(args->from);
1009         msg.msg_iov = &aiov;
1010         msg.msg_iovlen = 1;
1011         aiov.iov_base = PTRIN(args->buf);
1012         aiov.iov_len = args->len;
1013         msg.msg_control = 0;
1014         msg.msg_flags = linux_to_bsd_msg_flags(args->flags);
1015
1016         error = kern_recvit(td, args->s, &msg, UIO_USERSPACE, NULL);
1017         if (error != 0)
1018                 return (error);
1019
1020         if (PTRIN(args->from) != NULL) {
1021                 error = bsd_to_linux_sockaddr((struct sockaddr *)
1022                     PTRIN(args->from));
1023                 if (error != 0)
1024                         return (error);
1025
1026                 error = linux_sa_put((struct osockaddr *)
1027                     PTRIN(args->from));
1028         }
1029
1030         if (PTRIN(args->fromlen) != NULL)
1031                 error = copyout(&msg.msg_namelen, PTRIN(args->fromlen),
1032                     sizeof(msg.msg_namelen));
1033
1034         return (error);
1035 }
1036
1037 static int
1038 linux_sendmsg_common(struct thread *td, l_int s, struct l_msghdr *msghdr,
1039     l_uint flags)
1040 {
1041         struct cmsghdr *cmsg;
1042         struct cmsgcred cmcred;
1043         struct mbuf *control;
1044         struct msghdr msg;
1045         struct l_cmsghdr linux_cmsg;
1046         struct l_cmsghdr *ptr_cmsg;
1047         struct l_msghdr linux_msg;
1048         struct iovec *iov;
1049         socklen_t datalen;
1050         struct sockaddr *sa;
1051         sa_family_t sa_family;
1052         void *data;
1053         int error;
1054
1055         error = copyin(msghdr, &linux_msg, sizeof(linux_msg));
1056         if (error != 0)
1057                 return (error);
1058
1059         /*
1060          * Some Linux applications (ping) define a non-NULL control data
1061          * pointer, but a msg_controllen of 0, which is not allowed in the
1062          * FreeBSD system call interface.  NULL the msg_control pointer in
1063          * order to handle this case.  This should be checked, but allows the
1064          * Linux ping to work.
1065          */
1066         if (PTRIN(linux_msg.msg_control) != NULL && linux_msg.msg_controllen == 0)
1067                 linux_msg.msg_control = PTROUT(NULL);
1068
1069         error = linux_to_bsd_msghdr(&msg, &linux_msg);
1070         if (error != 0)
1071                 return (error);
1072
1073 #ifdef COMPAT_LINUX32
1074         error = linux32_copyiniov(PTRIN(msg.msg_iov), msg.msg_iovlen,
1075             &iov, EMSGSIZE);
1076 #else
1077         error = copyiniov(msg.msg_iov, msg.msg_iovlen, &iov, EMSGSIZE);
1078 #endif
1079         if (error != 0)
1080                 return (error);
1081
1082         control = NULL;
1083         cmsg = NULL;
1084
1085         if ((ptr_cmsg = LINUX_CMSG_FIRSTHDR(&linux_msg)) != NULL) {
1086                 error = kern_getsockname(td, s, &sa, &datalen);
1087                 if (error != 0)
1088                         goto bad;
1089                 sa_family = sa->sa_family;
1090                 free(sa, M_SONAME);
1091
1092                 error = ENOBUFS;
1093                 cmsg = malloc(CMSG_HDRSZ, M_LINUX, M_WAITOK|M_ZERO);
1094                 control = m_get(M_WAITOK, MT_CONTROL);
1095                 if (control == NULL)
1096                         goto bad;
1097
1098                 do {
1099                         error = copyin(ptr_cmsg, &linux_cmsg,
1100                             sizeof(struct l_cmsghdr));
1101                         if (error != 0)
1102                                 goto bad;
1103
1104                         error = EINVAL;
1105                         if (linux_cmsg.cmsg_len < sizeof(struct l_cmsghdr))
1106                                 goto bad;
1107
1108                         /*
1109                          * Now we support only SCM_RIGHTS and SCM_CRED,
1110                          * so return EINVAL in any other cmsg_type
1111                          */
1112                         cmsg->cmsg_type =
1113                             linux_to_bsd_cmsg_type(linux_cmsg.cmsg_type);
1114                         cmsg->cmsg_level =
1115                             linux_to_bsd_sockopt_level(linux_cmsg.cmsg_level);
1116                         if (cmsg->cmsg_type == -1
1117                             || cmsg->cmsg_level != SOL_SOCKET)
1118                                 goto bad;
1119
1120                         /*
1121                          * Some applications (e.g. pulseaudio) attempt to
1122                          * send ancillary data even if the underlying protocol
1123                          * doesn't support it which is not allowed in the
1124                          * FreeBSD system call interface.
1125                          */
1126                         if (sa_family != AF_UNIX)
1127                                 continue;
1128
1129                         data = LINUX_CMSG_DATA(ptr_cmsg);
1130                         datalen = linux_cmsg.cmsg_len - L_CMSG_HDRSZ;
1131
1132                         switch (cmsg->cmsg_type)
1133                         {
1134                         case SCM_RIGHTS:
1135                                 break;
1136
1137                         case SCM_CREDS:
1138                                 data = &cmcred;
1139                                 datalen = sizeof(cmcred);
1140
1141                                 /*
1142                                  * The lower levels will fill in the structure
1143                                  */
1144                                 bzero(data, datalen);
1145                                 break;
1146                         }
1147
1148                         cmsg->cmsg_len = CMSG_LEN(datalen);
1149
1150                         error = ENOBUFS;
1151                         if (!m_append(control, CMSG_HDRSZ, (c_caddr_t)cmsg))
1152                                 goto bad;
1153                         if (!m_append(control, datalen, (c_caddr_t)data))
1154                                 goto bad;
1155                 } while ((ptr_cmsg = LINUX_CMSG_NXTHDR(&linux_msg, ptr_cmsg)));
1156
1157                 if (m_length(control, NULL) == 0) {
1158                         m_freem(control);
1159                         control = NULL;
1160                 }
1161         }
1162
1163         msg.msg_iov = iov;
1164         msg.msg_flags = 0;
1165         error = linux_sendit(td, s, &msg, flags, control, UIO_USERSPACE);
1166
1167 bad:
1168         free(iov, M_IOV);
1169         if (cmsg)
1170                 free(cmsg, M_LINUX);
1171         return (error);
1172 }
1173
1174 int
1175 linux_sendmsg(struct thread *td, struct linux_sendmsg_args *args)
1176 {
1177
1178         return (linux_sendmsg_common(td, args->s, PTRIN(args->msg),
1179             args->flags));
1180 }
1181
1182 int
1183 linux_sendmmsg(struct thread *td, struct linux_sendmmsg_args *args)
1184 {
1185         struct l_mmsghdr *msg;
1186         l_uint retval;
1187         int error, datagrams;
1188
1189         if (args->vlen > UIO_MAXIOV)
1190                 args->vlen = UIO_MAXIOV;
1191
1192         msg = PTRIN(args->msg);
1193         datagrams = 0;
1194         while (datagrams < args->vlen) {
1195                 error = linux_sendmsg_common(td, args->s, &msg->msg_hdr,
1196                     args->flags);
1197                 if (error != 0)
1198                         break;
1199
1200                 retval = td->td_retval[0];
1201                 error = copyout(&retval, &msg->msg_len, sizeof(msg->msg_len));
1202                 if (error != 0)
1203                         break;
1204                 ++msg;
1205                 ++datagrams;
1206         }
1207         if (error == 0)
1208                 td->td_retval[0] = datagrams;
1209         return (error);
1210 }
1211
1212 static int
1213 linux_recvmsg_common(struct thread *td, l_int s, struct l_msghdr *msghdr,
1214     l_uint flags, struct msghdr *msg)
1215 {
1216         struct cmsghdr *cm;
1217         struct cmsgcred *cmcred;
1218         struct l_cmsghdr *linux_cmsg = NULL;
1219         struct l_ucred linux_ucred;
1220         socklen_t datalen, outlen;
1221         struct l_msghdr linux_msg;
1222         struct iovec *iov, *uiov;
1223         struct mbuf *control = NULL;
1224         struct mbuf **controlp;
1225         caddr_t outbuf;
1226         void *data;
1227         int error, i, fd, fds, *fdp;
1228
1229         error = copyin(msghdr, &linux_msg, sizeof(linux_msg));
1230         if (error != 0)
1231                 return (error);
1232
1233         error = linux_to_bsd_msghdr(msg, &linux_msg);
1234         if (error != 0)
1235                 return (error);
1236
1237 #ifdef COMPAT_LINUX32
1238         error = linux32_copyiniov(PTRIN(msg->msg_iov), msg->msg_iovlen,
1239             &iov, EMSGSIZE);
1240 #else
1241         error = copyiniov(msg->msg_iov, msg->msg_iovlen, &iov, EMSGSIZE);
1242 #endif
1243         if (error != 0)
1244                 return (error);
1245
1246         if (msg->msg_name) {
1247                 error = linux_to_bsd_sockaddr((struct sockaddr *)msg->msg_name,
1248                     msg->msg_namelen);
1249                 if (error != 0)
1250                         goto bad;
1251         }
1252
1253         uiov = msg->msg_iov;
1254         msg->msg_iov = iov;
1255         controlp = (msg->msg_control != NULL) ? &control : NULL;
1256         error = kern_recvit(td, s, msg, UIO_USERSPACE, controlp);
1257         msg->msg_iov = uiov;
1258         if (error != 0)
1259                 goto bad;
1260
1261         error = bsd_to_linux_msghdr(msg, &linux_msg);
1262         if (error != 0)
1263                 goto bad;
1264
1265         if (linux_msg.msg_name) {
1266                 error = bsd_to_linux_sockaddr((struct sockaddr *)
1267                     PTRIN(linux_msg.msg_name));
1268                 if (error != 0)
1269                         goto bad;
1270         }
1271         if (linux_msg.msg_name && linux_msg.msg_namelen > 2) {
1272                 error = linux_sa_put(PTRIN(linux_msg.msg_name));
1273                 if (error != 0)
1274                         goto bad;
1275         }
1276
1277         outbuf = PTRIN(linux_msg.msg_control);
1278         outlen = 0;
1279
1280         if (control) {
1281                 linux_cmsg = malloc(L_CMSG_HDRSZ, M_LINUX, M_WAITOK | M_ZERO);
1282
1283                 msg->msg_control = mtod(control, struct cmsghdr *);
1284                 msg->msg_controllen = control->m_len;
1285
1286                 cm = CMSG_FIRSTHDR(msg);
1287
1288                 while (cm != NULL) {
1289                         linux_cmsg->cmsg_type =
1290                             bsd_to_linux_cmsg_type(cm->cmsg_type);
1291                         linux_cmsg->cmsg_level =
1292                             bsd_to_linux_sockopt_level(cm->cmsg_level);
1293                         if (linux_cmsg->cmsg_type == -1
1294                             || cm->cmsg_level != SOL_SOCKET)
1295                         {
1296                                 error = EINVAL;
1297                                 goto bad;
1298                         }
1299
1300                         data = CMSG_DATA(cm);
1301                         datalen = (caddr_t)cm + cm->cmsg_len - (caddr_t)data;
1302
1303                         switch (cm->cmsg_type)
1304                         {
1305                         case SCM_RIGHTS:
1306                                 if (flags & LINUX_MSG_CMSG_CLOEXEC) {
1307                                         fds = datalen / sizeof(int);
1308                                         fdp = data;
1309                                         for (i = 0; i < fds; i++) {
1310                                                 fd = *fdp++;
1311                                                 (void)kern_fcntl(td, fd,
1312                                                     F_SETFD, FD_CLOEXEC);
1313                                         }
1314                                 }
1315                                 break;
1316
1317                         case SCM_CREDS:
1318                                 /*
1319                                  * Currently LOCAL_CREDS is never in
1320                                  * effect for Linux so no need to worry
1321                                  * about sockcred
1322                                  */
1323                                 if (datalen != sizeof(*cmcred)) {
1324                                         error = EMSGSIZE;
1325                                         goto bad;
1326                                 }
1327                                 cmcred = (struct cmsgcred *)data;
1328                                 bzero(&linux_ucred, sizeof(linux_ucred));
1329                                 linux_ucred.pid = cmcred->cmcred_pid;
1330                                 linux_ucred.uid = cmcred->cmcred_uid;
1331                                 linux_ucred.gid = cmcred->cmcred_gid;
1332                                 data = &linux_ucred;
1333                                 datalen = sizeof(linux_ucred);
1334                                 break;
1335                         }
1336
1337                         if (outlen + LINUX_CMSG_LEN(datalen) >
1338                             linux_msg.msg_controllen) {
1339                                 if (outlen == 0) {
1340                                         error = EMSGSIZE;
1341                                         goto bad;
1342                                 } else {
1343                                         linux_msg.msg_flags |=
1344                                             LINUX_MSG_CTRUNC;
1345                                         goto out;
1346                                 }
1347                         }
1348
1349                         linux_cmsg->cmsg_len = LINUX_CMSG_LEN(datalen);
1350
1351                         error = copyout(linux_cmsg, outbuf, L_CMSG_HDRSZ);
1352                         if (error)
1353                                 goto bad;
1354                         outbuf += L_CMSG_HDRSZ;
1355
1356                         error = copyout(data, outbuf, datalen);
1357                         if (error)
1358                                 goto bad;
1359
1360                         outbuf += LINUX_CMSG_ALIGN(datalen);
1361                         outlen += LINUX_CMSG_LEN(datalen);
1362
1363                         cm = CMSG_NXTHDR(msg, cm);
1364                 }
1365         }
1366
1367 out:
1368         linux_msg.msg_controllen = outlen;
1369         error = copyout(&linux_msg, msghdr, sizeof(linux_msg));
1370
1371 bad:
1372         free(iov, M_IOV);
1373         m_freem(control);
1374         free(linux_cmsg, M_LINUX);
1375
1376         return (error);
1377 }
1378
1379 int
1380 linux_recvmsg(struct thread *td, struct linux_recvmsg_args *args)
1381 {
1382         struct msghdr bsd_msg;
1383
1384         return (linux_recvmsg_common(td, args->s, PTRIN(args->msg),
1385             args->flags, &bsd_msg));
1386 }
1387
1388 int
1389 linux_recvmmsg(struct thread *td, struct linux_recvmmsg_args *args)
1390 {
1391         struct l_mmsghdr *msg;
1392         struct msghdr bsd_msg;
1393         struct l_timespec lts;
1394         struct timespec ts, tts;
1395         l_uint retval;
1396         int error, datagrams;
1397
1398         if (args->timeout) {
1399                 error = copyin(args->timeout, &lts, sizeof(struct l_timespec));
1400                 if (error != 0)
1401                         return (error);
1402                 error = linux_to_native_timespec(&ts, &lts);
1403                 if (error != 0)
1404                         return (error);
1405                 getnanotime(&tts);
1406                 timespecadd(&tts, &ts);
1407         }
1408
1409         msg = PTRIN(args->msg);
1410         datagrams = 0;
1411         while (datagrams < args->vlen) {
1412                 error = linux_recvmsg_common(td, args->s, &msg->msg_hdr,
1413                     args->flags & ~LINUX_MSG_WAITFORONE, &bsd_msg);
1414                 if (error != 0)
1415                         break;
1416
1417                 retval = td->td_retval[0];
1418                 error = copyout(&retval, &msg->msg_len, sizeof(msg->msg_len));
1419                 if (error != 0)
1420                         break;
1421                 ++msg;
1422                 ++datagrams;
1423
1424                 /*
1425                  * MSG_WAITFORONE turns on MSG_DONTWAIT after one packet.
1426                  */
1427                 if (args->flags & LINUX_MSG_WAITFORONE)
1428                         args->flags |= LINUX_MSG_DONTWAIT;
1429
1430                 /*
1431                  * See BUGS section of recvmmsg(2).
1432                  */
1433                 if (args->timeout) {
1434                         getnanotime(&ts);
1435                         timespecsub(&ts, &tts);
1436                         if (!timespecisset(&ts) || ts.tv_sec > 0)
1437                                 break;
1438                 }
1439                 /* Out of band data, return right away. */
1440                 if (bsd_msg.msg_flags & MSG_OOB)
1441                         break;
1442         }
1443         if (error == 0)
1444                 td->td_retval[0] = datagrams;
1445         return (error);
1446 }
1447
1448 int
1449 linux_shutdown(struct thread *td, struct linux_shutdown_args *args)
1450 {
1451         struct shutdown_args /* {
1452                 int s;
1453                 int how;
1454         } */ bsd_args;
1455
1456         bsd_args.s = args->s;
1457         bsd_args.how = args->how;
1458         return (sys_shutdown(td, &bsd_args));
1459 }
1460
1461 int
1462 linux_setsockopt(struct thread *td, struct linux_setsockopt_args *args)
1463 {
1464         struct setsockopt_args /* {
1465                 int s;
1466                 int level;
1467                 int name;
1468                 caddr_t val;
1469                 int valsize;
1470         } */ bsd_args;
1471         l_timeval linux_tv;
1472         struct timeval tv;
1473         int error, name;
1474
1475         bsd_args.s = args->s;
1476         bsd_args.level = linux_to_bsd_sockopt_level(args->level);
1477         switch (bsd_args.level) {
1478         case SOL_SOCKET:
1479                 name = linux_to_bsd_so_sockopt(args->optname);
1480                 switch (name) {
1481                 case SO_RCVTIMEO:
1482                         /* FALLTHROUGH */
1483                 case SO_SNDTIMEO:
1484                         error = copyin(PTRIN(args->optval), &linux_tv,
1485                             sizeof(linux_tv));
1486                         if (error)
1487                                 return (error);
1488                         tv.tv_sec = linux_tv.tv_sec;
1489                         tv.tv_usec = linux_tv.tv_usec;
1490                         return (kern_setsockopt(td, args->s, bsd_args.level,
1491                             name, &tv, UIO_SYSSPACE, sizeof(tv)));
1492                         /* NOTREACHED */
1493                         break;
1494                 default:
1495                         break;
1496                 }
1497                 break;
1498         case IPPROTO_IP:
1499                 name = linux_to_bsd_ip_sockopt(args->optname);
1500                 break;
1501         case IPPROTO_TCP:
1502                 name = linux_to_bsd_tcp_sockopt(args->optname);
1503                 break;
1504         default:
1505                 name = -1;
1506                 break;
1507         }
1508         if (name == -1)
1509                 return (ENOPROTOOPT);
1510
1511         bsd_args.name = name;
1512         bsd_args.val = PTRIN(args->optval);
1513         bsd_args.valsize = args->optlen;
1514
1515         if (name == IPV6_NEXTHOP) {
1516                 linux_to_bsd_sockaddr((struct sockaddr *)bsd_args.val,
1517                         bsd_args.valsize);
1518                 error = sys_setsockopt(td, &bsd_args);
1519                 bsd_to_linux_sockaddr((struct sockaddr *)bsd_args.val);
1520         } else
1521                 error = sys_setsockopt(td, &bsd_args);
1522
1523         return (error);
1524 }
1525
1526 int
1527 linux_getsockopt(struct thread *td, struct linux_getsockopt_args *args)
1528 {
1529         struct getsockopt_args /* {
1530                 int s;
1531                 int level;
1532                 int name;
1533                 caddr_t val;
1534                 int *avalsize;
1535         } */ bsd_args;
1536         l_timeval linux_tv;
1537         struct timeval tv;
1538         socklen_t tv_len, xulen;
1539         struct xucred xu;
1540         struct l_ucred lxu;
1541         int error, name;
1542
1543         bsd_args.s = args->s;
1544         bsd_args.level = linux_to_bsd_sockopt_level(args->level);
1545         switch (bsd_args.level) {
1546         case SOL_SOCKET:
1547                 name = linux_to_bsd_so_sockopt(args->optname);
1548                 switch (name) {
1549                 case SO_RCVTIMEO:
1550                         /* FALLTHROUGH */
1551                 case SO_SNDTIMEO:
1552                         tv_len = sizeof(tv);
1553                         error = kern_getsockopt(td, args->s, bsd_args.level,
1554                             name, &tv, UIO_SYSSPACE, &tv_len);
1555                         if (error)
1556                                 return (error);
1557                         linux_tv.tv_sec = tv.tv_sec;
1558                         linux_tv.tv_usec = tv.tv_usec;
1559                         return (copyout(&linux_tv, PTRIN(args->optval),
1560                             sizeof(linux_tv)));
1561                         /* NOTREACHED */
1562                         break;
1563                 case LOCAL_PEERCRED:
1564                         if (args->optlen != sizeof(lxu))
1565                                 return (EINVAL);
1566                         xulen = sizeof(xu);
1567                         error = kern_getsockopt(td, args->s, bsd_args.level,
1568                             name, &xu, UIO_SYSSPACE, &xulen);
1569                         if (error)
1570                                 return (error);
1571                         /*
1572                          * XXX Use 0 for pid as the FreeBSD does not cache peer pid.
1573                          */
1574                         lxu.pid = 0;
1575                         lxu.uid = xu.cr_uid;
1576                         lxu.gid = xu.cr_gid;
1577                         return (copyout(&lxu, PTRIN(args->optval), sizeof(lxu)));
1578                         /* NOTREACHED */
1579                         break;
1580                 default:
1581                         break;
1582                 }
1583                 break;
1584         case IPPROTO_IP:
1585                 name = linux_to_bsd_ip_sockopt(args->optname);
1586                 break;
1587         case IPPROTO_TCP:
1588                 name = linux_to_bsd_tcp_sockopt(args->optname);
1589                 break;
1590         default:
1591                 name = -1;
1592                 break;
1593         }
1594         if (name == -1)
1595                 return (EINVAL);
1596
1597         bsd_args.name = name;
1598         bsd_args.val = PTRIN(args->optval);
1599         bsd_args.avalsize = PTRIN(args->optlen);
1600
1601         if (name == IPV6_NEXTHOP) {
1602                 error = sys_getsockopt(td, &bsd_args);
1603                 bsd_to_linux_sockaddr((struct sockaddr *)bsd_args.val);
1604         } else
1605                 error = sys_getsockopt(td, &bsd_args);
1606
1607         return (error);
1608 }
1609
1610 #if defined(__i386__) || (defined(__amd64__) && defined(COMPAT_LINUX32))
1611
1612 /* Argument list sizes for linux_socketcall */
1613
1614 #define LINUX_AL(x) ((x) * sizeof(l_ulong))
1615
1616 static const unsigned char lxs_args[] = {
1617         LINUX_AL(0) /* unused*/,        LINUX_AL(3) /* socket */,
1618         LINUX_AL(3) /* bind */,         LINUX_AL(3) /* connect */,
1619         LINUX_AL(2) /* listen */,       LINUX_AL(3) /* accept */,
1620         LINUX_AL(3) /* getsockname */,  LINUX_AL(3) /* getpeername */,
1621         LINUX_AL(4) /* socketpair */,   LINUX_AL(4) /* send */,
1622         LINUX_AL(4) /* recv */,         LINUX_AL(6) /* sendto */,
1623         LINUX_AL(6) /* recvfrom */,     LINUX_AL(2) /* shutdown */,
1624         LINUX_AL(5) /* setsockopt */,   LINUX_AL(5) /* getsockopt */,
1625         LINUX_AL(3) /* sendmsg */,      LINUX_AL(3) /* recvmsg */,
1626         LINUX_AL(4) /* accept4 */,      LINUX_AL(5) /* recvmmsg */,
1627         LINUX_AL(4) /* sendmmsg */
1628 };
1629
1630 #define LINUX_AL_SIZE   sizeof(lxs_args) / sizeof(lxs_args[0]) - 1
1631
1632 int
1633 linux_socketcall(struct thread *td, struct linux_socketcall_args *args)
1634 {
1635         l_ulong a[6];
1636         void *arg;
1637         int error;
1638
1639         if (args->what < LINUX_SOCKET || args->what > LINUX_AL_SIZE)
1640                 return (EINVAL);
1641         error = copyin(PTRIN(args->args), a, lxs_args[args->what]);
1642         if (error)
1643                 return (error);
1644
1645         arg = a;
1646         switch (args->what) {
1647         case LINUX_SOCKET:
1648                 return (linux_socket(td, arg));
1649         case LINUX_BIND:
1650                 return (linux_bind(td, arg));
1651         case LINUX_CONNECT:
1652                 return (linux_connect(td, arg));
1653         case LINUX_LISTEN:
1654                 return (linux_listen(td, arg));
1655         case LINUX_ACCEPT:
1656                 return (linux_accept(td, arg));
1657         case LINUX_GETSOCKNAME:
1658                 return (linux_getsockname(td, arg));
1659         case LINUX_GETPEERNAME:
1660                 return (linux_getpeername(td, arg));
1661         case LINUX_SOCKETPAIR:
1662                 return (linux_socketpair(td, arg));
1663         case LINUX_SEND:
1664                 return (linux_send(td, arg));
1665         case LINUX_RECV:
1666                 return (linux_recv(td, arg));
1667         case LINUX_SENDTO:
1668                 return (linux_sendto(td, arg));
1669         case LINUX_RECVFROM:
1670                 return (linux_recvfrom(td, arg));
1671         case LINUX_SHUTDOWN:
1672                 return (linux_shutdown(td, arg));
1673         case LINUX_SETSOCKOPT:
1674                 return (linux_setsockopt(td, arg));
1675         case LINUX_GETSOCKOPT:
1676                 return (linux_getsockopt(td, arg));
1677         case LINUX_SENDMSG:
1678                 return (linux_sendmsg(td, arg));
1679         case LINUX_RECVMSG:
1680                 return (linux_recvmsg(td, arg));
1681         case LINUX_ACCEPT4:
1682                 return (linux_accept4(td, arg));
1683         case LINUX_RECVMMSG:
1684                 return (linux_recvmmsg(td, arg));
1685         case LINUX_SENDMMSG:
1686                 return (linux_sendmmsg(td, arg));
1687         }
1688
1689         uprintf("LINUX: 'socket' typ=%d not implemented\n", args->what);
1690         return (ENOSYS);
1691 }
1692 #endif /* __i386__ || (__amd64__ && COMPAT_LINUX32) */