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