1 /* 2 * Copyright (c) 2010 Kip Macy. All rights reserved. 3 * Copyright (C) 2017 THL A29 Limited, a Tencent company. 4 * All rights reserved. 5 * 6 * Redistribution and use in source and binary forms, with or without 7 * modification, are permitted provided that the following conditions are met: 8 * 9 * 1. Redistributions of source code must retain the above copyright notice, this 10 * list of conditions and the following disclaimer. 11 * 2. Redistributions in binary form must reproduce the above copyright notice, 12 * this list of conditions and the following disclaimer in the documentation 13 * and/or other materials provided with the distribution. 14 * 15 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND 16 * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED 17 * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE 18 * DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE LIABLE FOR 19 * ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES 20 * (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; 21 * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND 22 * ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT 23 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS 24 * SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. 25 * 26 * Derived in part from libplebnet's pn_syscall_wrapper.c. 27 */ 28 29 #include <sys/param.h> 30 #include <sys/limits.h> 31 #include <sys/uio.h> 32 #include <sys/proc.h> 33 #include <sys/syscallsubr.h> 34 #include <sys/module.h> 35 #include <sys/param.h> 36 #include <sys/malloc.h> 37 #include <sys/socketvar.h> 38 #include <sys/event.h> 39 #include <sys/kernel.h> 40 #include <sys/refcount.h> 41 #include <sys/sysctl.h> 42 #include <sys/pcpu.h> 43 #include <sys/select.h> 44 #include <sys/poll.h> 45 #include <sys/event.h> 46 #include <sys/file.h> 47 #include <netinet/in.h> 48 #include <netinet/tcp.h> 49 #include <sys/ttycom.h> 50 #include <sys/filio.h> 51 #include <sys/sysproto.h> 52 #include <sys/fcntl.h> 53 #include <net/route.h> 54 55 #include <machine/stdarg.h> 56 57 #include "ff_api.h" 58 #include "ff_host_interface.h" 59 60 /* setsockopt/getsockopt define start */ 61 62 #define LINUX_SOL_SOCKET 1 63 64 #define LINUX_SO_DEBUG 1 65 #define LINUX_SO_REUSEADDR 2 66 #define LINUX_SO_ERROR 4 67 #define LINUX_SO_DONTROUTE 5 68 #define LINUX_SO_BROADCAST 6 69 #define LINUX_SO_SNDBUF 7 70 #define LINUX_SO_RCVBUF 8 71 #define LINUX_SO_KEEPALIVE 9 72 #define LINUX_SO_OOBINLINE 10 73 #define LINUX_SO_LINGER 13 74 #define LINUX_SO_RCVLOWAT 18 75 #define LINUX_SO_SNDLOWAT 19 76 #define LINUX_SO_RCVTIMEO 20 77 #define LINUX_SO_SNDTIMEO 21 78 #define LINUX_SO_ACCEPTCONN 30 79 #define LINUX_SO_PROTOCOL 38 80 81 82 #define LINUX_IP_TOS 1 83 #define LINUX_IP_TTL 2 84 #define LINUX_IP_HDRINCL 3 85 #define LINUX_IP_OPTIONS 4 86 87 #define LINUX_IP_MULTICAST_IF 32 88 #define LINUX_IP_MULTICAST_TTL 33 89 #define LINUX_IP_MULTICAST_LOOP 34 90 #define LINUX_IP_ADD_MEMBERSHIP 35 91 #define LINUX_IP_DROP_MEMBERSHIP 36 92 93 #define LINUX_TCP_NODELAY 1 94 #define LINUX_TCP_MAXSEG 2 95 #define LINUX_TCP_KEEPIDLE 4 96 #define LINUX_TCP_KEEPINTVL 5 97 #define LINUX_TCP_KEEPCNT 6 98 #define LINUX_TCP_MD5SIG 14 99 100 /* setsockopt/getsockopt define end */ 101 102 103 /* ioctl define start */ 104 105 #define LINUX_TIOCEXCL 0x540C 106 #define LINUX_TIOCNXCL 0x540D 107 #define LINUX_TIOCSCTTY 0x540E 108 #define LINUX_TIOCGPGRP 0x540F 109 #define LINUX_TIOCSPGRP 0x5410 110 #define LINUX_TIOCOUTQ 0x5411 111 #define LINUX_TIOCSTI 0x5412 112 #define LINUX_TIOCGWINSZ 0x5413 113 #define LINUX_TIOCSWINSZ 0x5414 114 #define LINUX_TIOCMGET 0x5415 115 #define LINUX_TIOCMBIS 0x5416 116 #define LINUX_TIOCMBIC 0x5417 117 #define LINUX_TIOCMSET 0x5418 118 119 #define LINUX_FIONREAD 0x541B 120 #define LINUX_TIOCCONS 0x541D 121 #define LINUX_TIOCPKT 0x5420 122 #define LINUX_FIONBIO 0x5421 123 #define LINUX_TIOCNOTTY 0x5422 124 #define LINUX_TIOCSETD 0x5423 125 #define LINUX_TIOCGETD 0x5424 126 #define LINUX_TIOCSBRK 0x5427 127 #define LINUX_TIOCCBRK 0x5428 128 #define LINUX_TIOCGSID 0x5429 129 130 #define LINUX_FIONCLEX 0x5450 131 #define LINUX_FIOCLEX 0x5451 132 #define LINUX_FIOASYNC 0x5452 133 134 #define LINUX_TIOCPKT_DATA 0 135 #define LINUX_TIOCPKT_FLUSHREAD 1 136 #define LINUX_TIOCPKT_FLUSHWRITE 2 137 #define LINUX_TIOCPKT_STOP 4 138 #define LINUX_TIOCPKT_START 8 139 #define LINUX_TIOCPKT_NOSTOP 16 140 #define LINUX_TIOCPKT_DOSTOP 32 141 #define LINUX_TIOCPKT_IOCTL 64 142 143 /* ioctl define end */ 144 145 146 extern int sendit(struct thread *td, int s, struct msghdr *mp, int flags); 147 148 static long 149 linux2freebsd_ioctl(unsigned long request) 150 { 151 switch(request) { 152 case LINUX_TIOCEXCL: 153 return TIOCEXCL; 154 case LINUX_TIOCNXCL: 155 return TIOCNXCL; 156 case LINUX_TIOCSCTTY: 157 return TIOCSCTTY; 158 case LINUX_TIOCGPGRP: 159 return TIOCGPGRP; 160 case LINUX_TIOCSPGRP: 161 return TIOCSPGRP; 162 case LINUX_TIOCOUTQ: 163 return TIOCOUTQ; 164 case LINUX_TIOCSTI: 165 return TIOCSTI; 166 case LINUX_TIOCGWINSZ: 167 return TIOCGWINSZ; 168 case LINUX_TIOCSWINSZ: 169 return TIOCSWINSZ; 170 case LINUX_TIOCMGET: 171 return TIOCMGET; 172 case LINUX_TIOCMBIS: 173 return TIOCMBIS; 174 case LINUX_TIOCMBIC: 175 return TIOCMBIC; 176 case LINUX_TIOCMSET: 177 return TIOCMSET; 178 case LINUX_FIONREAD: 179 return FIONREAD; 180 case LINUX_TIOCCONS: 181 return TIOCCONS; 182 case LINUX_TIOCPKT: 183 return TIOCPKT; 184 case LINUX_FIONBIO: 185 return FIONBIO; 186 case LINUX_TIOCNOTTY: 187 return TIOCNOTTY; 188 case LINUX_TIOCSETD: 189 return TIOCSETD; 190 case LINUX_TIOCGETD: 191 return TIOCGETD; 192 case LINUX_TIOCSBRK: 193 return TIOCSBRK; 194 case LINUX_TIOCCBRK: 195 return TIOCCBRK; 196 case LINUX_TIOCGSID: 197 return TIOCGSID; 198 case LINUX_FIONCLEX: 199 return FIONCLEX; 200 case LINUX_FIOCLEX: 201 return FIOCLEX; 202 case LINUX_FIOASYNC: 203 return FIOASYNC; 204 case LINUX_TIOCPKT_DATA: 205 return TIOCPKT_DATA; 206 case LINUX_TIOCPKT_FLUSHREAD: 207 return TIOCPKT_FLUSHREAD; 208 case LINUX_TIOCPKT_FLUSHWRITE: 209 return TIOCPKT_FLUSHWRITE; 210 case LINUX_TIOCPKT_STOP: 211 return TIOCPKT_STOP; 212 case LINUX_TIOCPKT_START: 213 return TIOCPKT_START; 214 case LINUX_TIOCPKT_NOSTOP: 215 return TIOCPKT_NOSTOP; 216 case LINUX_TIOCPKT_DOSTOP: 217 return TIOCPKT_DOSTOP; 218 case LINUX_TIOCPKT_IOCTL: 219 return TIOCPKT_IOCTL; 220 default: 221 return request; 222 } 223 } 224 225 static int 226 so_opt_convert(int optname) 227 { 228 switch(optname) { 229 case LINUX_SO_DEBUG: 230 return SO_DEBUG; 231 case LINUX_SO_REUSEADDR: 232 return SO_REUSEADDR; 233 case LINUX_SO_ERROR: 234 return SO_ERROR; 235 case LINUX_SO_DONTROUTE: 236 return SO_DONTROUTE; 237 case LINUX_SO_BROADCAST: 238 return SO_BROADCAST; 239 case LINUX_SO_SNDBUF: 240 return SO_SNDBUF; 241 case LINUX_SO_RCVBUF: 242 return SO_RCVBUF; 243 case LINUX_SO_KEEPALIVE: 244 return SO_KEEPALIVE; 245 case LINUX_SO_OOBINLINE: 246 return SO_OOBINLINE; 247 case LINUX_SO_LINGER: 248 return SO_LINGER; 249 case LINUX_SO_RCVLOWAT: 250 return SO_RCVLOWAT; 251 case LINUX_SO_SNDLOWAT: 252 return SO_SNDLOWAT; 253 case LINUX_SO_RCVTIMEO: 254 return SO_RCVTIMEO; 255 case LINUX_SO_SNDTIMEO: 256 return SO_SNDTIMEO; 257 case LINUX_SO_ACCEPTCONN: 258 return SO_ACCEPTCONN; 259 case LINUX_SO_PROTOCOL: 260 return SO_PROTOCOL; 261 default: 262 return optname; 263 } 264 } 265 266 static int 267 ip_opt_convert(int optname) 268 { 269 switch(optname) { 270 case LINUX_IP_TOS: 271 return IP_TOS; 272 case LINUX_IP_TTL: 273 return IP_TTL; 274 case LINUX_IP_HDRINCL: 275 return IP_HDRINCL; 276 case LINUX_IP_OPTIONS: 277 return IP_OPTIONS; 278 case LINUX_IP_MULTICAST_IF: 279 return IP_MULTICAST_IF; 280 case LINUX_IP_MULTICAST_TTL: 281 return IP_MULTICAST_TTL; 282 case LINUX_IP_MULTICAST_LOOP: 283 return IP_MULTICAST_LOOP; 284 case LINUX_IP_ADD_MEMBERSHIP: 285 return IP_ADD_MEMBERSHIP; 286 case LINUX_IP_DROP_MEMBERSHIP: 287 return IP_DROP_MEMBERSHIP; 288 default: 289 return optname; 290 } 291 } 292 293 static int 294 tcp_opt_convert(int optname) 295 { 296 switch(optname) { 297 case LINUX_TCP_NODELAY: 298 return TCP_NODELAY; 299 case LINUX_TCP_MAXSEG: 300 return TCP_MAXSEG; 301 case LINUX_TCP_KEEPIDLE: 302 return TCP_KEEPIDLE; 303 case LINUX_TCP_KEEPINTVL: 304 return TCP_KEEPINTVL; 305 case LINUX_TCP_KEEPCNT: 306 return TCP_KEEPCNT; 307 case LINUX_TCP_MD5SIG: 308 return TCP_MD5SIG; 309 default: 310 return optname; 311 } 312 } 313 314 static int 315 linux2freebsd_opt(int level, int optname) 316 { 317 switch(level) { 318 case SOL_SOCKET: 319 return so_opt_convert(optname); 320 case IPPROTO_IP: 321 return ip_opt_convert(optname); 322 case IPPROTO_TCP: 323 return tcp_opt_convert(optname); 324 default: 325 return optname; 326 } 327 } 328 329 static void 330 linux2freebsd_sockaddr(const struct linux_sockaddr *linux, 331 socklen_t addrlen, struct sockaddr *freebsd) 332 { 333 if (linux == NULL) { 334 return; 335 } 336 337 bzero(freebsd, sizeof(struct sockaddr)); 338 freebsd->sa_len = addrlen; 339 freebsd->sa_family = linux->sa_family; 340 bcopy(linux->sa_data, freebsd->sa_data, sizeof(linux->sa_data)); 341 } 342 343 static void 344 freebsd2linux_sockaddr(struct linux_sockaddr *linux, 345 struct sockaddr *freebsd) 346 { 347 if (linux == NULL) { 348 return; 349 } 350 351 linux->sa_family = freebsd->sa_family; 352 bcopy(freebsd->sa_data, linux->sa_data, sizeof(freebsd->sa_data)); 353 } 354 355 int 356 ff_socket(int domain, int type, int protocol) 357 { 358 int rc; 359 struct socket_args sa; 360 sa.domain = domain; 361 sa.type = type; 362 sa.protocol = protocol; 363 if ((rc = sys_socket(curthread, &sa))) 364 goto kern_fail; 365 366 return curthread->td_retval[0]; 367 kern_fail: 368 ff_os_errno(rc); 369 return (-1); 370 } 371 372 int 373 ff_getsockopt(int s, int level, int optname, void *optval, 374 socklen_t *optlen) 375 { 376 int rc; 377 if (level == LINUX_SOL_SOCKET) 378 level = SOL_SOCKET; 379 380 optname = linux2freebsd_opt(level, optname); 381 if (optname < 0) { 382 rc = EINVAL; 383 goto kern_fail; 384 } 385 386 if ((rc = kern_getsockopt(curthread, s, level, optname, 387 optval, UIO_SYSSPACE, optlen))) 388 goto kern_fail; 389 390 return (rc); 391 392 kern_fail: 393 ff_os_errno(rc); 394 return (-1); 395 } 396 397 int 398 ff_setsockopt(int s, int level, int optname, const void *optval, 399 socklen_t optlen) 400 { 401 int rc; 402 403 if (level == LINUX_SOL_SOCKET) 404 level = SOL_SOCKET; 405 406 optname = linux2freebsd_opt(level, optname); 407 if (optname < 0) { 408 rc = EINVAL; 409 goto kern_fail; 410 } 411 412 if ((rc = kern_setsockopt(curthread, s, level, optname, 413 __DECONST(void *, optval), UIO_SYSSPACE, optlen))) 414 goto kern_fail; 415 416 return (rc); 417 418 kern_fail: 419 ff_os_errno(rc); 420 return (-1); 421 } 422 423 int 424 ff_ioctl(int fd, unsigned long request, ...) 425 { 426 int rc; 427 va_list ap; 428 caddr_t argp; 429 430 long req = linux2freebsd_ioctl(request); 431 if (req < 0) { 432 rc = EINVAL; 433 goto kern_fail; 434 } 435 436 va_start(ap, request); 437 438 argp = va_arg(ap, caddr_t); 439 va_end(ap); 440 if ((rc = kern_ioctl(curthread, fd, req, argp))) 441 goto kern_fail; 442 443 return (rc); 444 445 kern_fail: 446 ff_os_errno(rc); 447 return (-1); 448 } 449 450 int 451 ff_close(int fd) 452 { 453 int rc; 454 455 if ((rc = kern_close(curthread, fd))) 456 goto kern_fail; 457 458 return (rc); 459 kern_fail: 460 ff_os_errno(rc); 461 return (-1); 462 } 463 464 ssize_t 465 ff_read(int fd, void *buf, size_t nbytes) 466 { 467 struct uio auio; 468 struct iovec aiov; 469 int rc; 470 471 if (nbytes > INT_MAX) { 472 rc = EINVAL; 473 goto kern_fail; 474 } 475 476 aiov.iov_base = buf; 477 aiov.iov_len = nbytes; 478 auio.uio_iov = &aiov; 479 auio.uio_iovcnt = 1; 480 auio.uio_resid = nbytes; 481 auio.uio_segflg = UIO_SYSSPACE; 482 if ((rc = kern_readv(curthread, fd, &auio))) 483 goto kern_fail; 484 rc = curthread->td_retval[0]; 485 486 return (rc); 487 kern_fail: 488 ff_os_errno(rc); 489 return (-1); 490 } 491 492 ssize_t 493 ff_readv(int fd, const struct iovec *iov, int iovcnt) 494 { 495 struct uio auio; 496 int rc, len, i; 497 498 len = 0; 499 for (i = 0; i < iovcnt; i++) 500 len += iov[i].iov_len; 501 auio.uio_iov = __DECONST(struct iovec *, iov); 502 auio.uio_iovcnt = iovcnt; 503 auio.uio_resid = len; 504 auio.uio_segflg = UIO_SYSSPACE; 505 506 if ((rc = kern_readv(curthread, fd, &auio))) 507 goto kern_fail; 508 rc = curthread->td_retval[0]; 509 510 return (rc); 511 kern_fail: 512 ff_os_errno(rc); 513 return (-1); 514 } 515 516 ssize_t 517 ff_write(int fd, const void *buf, size_t nbytes) 518 { 519 struct uio auio; 520 struct iovec aiov; 521 int rc; 522 523 if (nbytes > INT_MAX) { 524 rc = EINVAL; 525 goto kern_fail; 526 } 527 528 aiov.iov_base = (void *)(uintptr_t)buf; 529 aiov.iov_len = nbytes; 530 auio.uio_iov = &aiov; 531 auio.uio_iovcnt = 1; 532 auio.uio_resid = nbytes; 533 auio.uio_segflg = UIO_SYSSPACE; 534 if ((rc = kern_writev(curthread, fd, &auio))) 535 goto kern_fail; 536 rc = curthread->td_retval[0]; 537 538 return (rc); 539 kern_fail: 540 ff_os_errno(rc); 541 return (-1); 542 } 543 544 ssize_t 545 ff_writev(int fd, const struct iovec *iov, int iovcnt) 546 { 547 struct uio auio; 548 int i, rc, len; 549 550 len = 0; 551 for (i = 0; i < iovcnt; i++) 552 len += iov[i].iov_len; 553 auio.uio_iov = __DECONST(struct iovec *, iov); 554 auio.uio_iovcnt = iovcnt; 555 auio.uio_resid = len; 556 auio.uio_segflg = UIO_SYSSPACE; 557 if ((rc = kern_writev(curthread, fd, &auio))) 558 goto kern_fail; 559 rc = curthread->td_retval[0]; 560 561 return (rc); 562 kern_fail: 563 ff_os_errno(rc); 564 return (-1); 565 } 566 567 ssize_t 568 ff_send(int s, const void *buf, size_t len, int flags) 569 { 570 return (ff_sendto(s, buf, len, flags, NULL, 0)); 571 } 572 573 ssize_t 574 ff_sendto(int s, const void *buf, size_t len, int flags, 575 const struct linux_sockaddr *to, socklen_t tolen) 576 { 577 struct msghdr msg; 578 struct iovec aiov; 579 int rc; 580 581 struct sockaddr bsdaddr; 582 struct sockaddr *pf = &bsdaddr; 583 584 if (to) { 585 linux2freebsd_sockaddr(to, tolen, pf); 586 } else { 587 pf = NULL; 588 } 589 590 msg.msg_name = pf; 591 msg.msg_namelen = tolen; 592 msg.msg_iov = &aiov; 593 msg.msg_iovlen = 1; 594 msg.msg_control = 0; 595 aiov.iov_base = __DECONST(void *, buf); 596 aiov.iov_len = len; 597 if ((rc = sendit(curthread, s, &msg, flags))) 598 goto kern_fail; 599 600 rc = curthread->td_retval[0]; 601 602 return (rc); 603 kern_fail: 604 ff_os_errno(rc); 605 return (-1); 606 } 607 608 ssize_t 609 ff_sendmsg(int s, const struct msghdr *msg, int flags) 610 { 611 int rc; 612 613 if ((rc = sendit(curthread, s, __DECONST(struct msghdr *, msg), flags))) 614 goto kern_fail; 615 616 return (rc); 617 kern_fail: 618 ff_os_errno(rc); 619 return (-1); 620 } 621 622 623 ssize_t 624 ff_recv(int s, void *buf, size_t len, int flags) 625 { 626 return (ff_recvfrom(s, buf, len, flags, NULL, 0)); 627 } 628 629 ssize_t 630 ff_recvfrom(int s, void *buf, size_t len, int flags, 631 struct linux_sockaddr *from, socklen_t *fromlen) 632 { 633 struct msghdr msg; 634 struct iovec aiov; 635 int rc; 636 struct sockaddr bsdaddr; 637 638 if (fromlen != NULL) 639 msg.msg_namelen = *fromlen; 640 else 641 msg.msg_namelen = 0; 642 643 msg.msg_name = &bsdaddr; 644 msg.msg_iov = &aiov; 645 msg.msg_iovlen = 1; 646 aiov.iov_base = buf; 647 aiov.iov_len = len; 648 msg.msg_control = 0; 649 msg.msg_flags = flags; 650 if ((rc = kern_recvit(curthread, s, &msg, UIO_SYSSPACE, NULL))) 651 goto kern_fail; 652 rc = curthread->td_retval[0]; 653 if (fromlen != NULL) 654 *fromlen = msg.msg_namelen; 655 656 if (from) 657 freebsd2linux_sockaddr(from, &bsdaddr); 658 659 return (rc); 660 kern_fail: 661 ff_os_errno(rc); 662 return (-1); 663 } 664 665 ssize_t 666 ff_recvmsg(int s, struct msghdr *msg, int flags) 667 { 668 int rc, oldflags; 669 670 oldflags = msg->msg_flags; 671 msg->msg_flags = flags; 672 673 if ((rc = kern_recvit(curthread, s, msg, UIO_SYSSPACE, NULL))) { 674 msg->msg_flags = oldflags; 675 goto kern_fail; 676 } 677 rc = curthread->td_retval[0]; 678 679 return (rc); 680 kern_fail: 681 ff_os_errno(rc); 682 return (-1); 683 } 684 685 int 686 ff_fcntl(int fd, int cmd, ...) 687 { 688 int rc; 689 va_list ap; 690 uintptr_t argp; 691 692 va_start(ap, cmd); 693 694 argp = va_arg(ap, uintptr_t); 695 va_end(ap); 696 697 if ((rc = kern_fcntl(curthread, fd, cmd, argp))) 698 goto kern_fail; 699 rc = curthread->td_retval[0]; 700 return (rc); 701 kern_fail: 702 ff_os_errno(rc); 703 return (-1); 704 } 705 706 int 707 ff_socketpair(int domain, int type, int protocol, int *sv) 708 { 709 int rc; 710 if ((rc = kern_socketpair(curthread, domain, type, protocol, sv))) 711 goto kern_fail; 712 713 return (rc); 714 kern_fail: 715 ff_os_errno(rc); 716 return (-1); 717 } 718 719 int 720 ff_accept(int s, struct linux_sockaddr * addr, 721 socklen_t * addrlen) 722 { 723 int rc; 724 struct file *fp; 725 struct sockaddr *pf = NULL; 726 socklen_t socklen = sizeof(struct sockaddr); 727 728 if ((rc = kern_accept(curthread, s, &pf, &socklen, &fp))) 729 goto kern_fail; 730 731 rc = curthread->td_retval[0]; 732 fdrop(fp, curthread); 733 734 if (addr && pf) 735 freebsd2linux_sockaddr(addr, pf); 736 737 if (addrlen) 738 *addrlen = socklen; 739 740 if(pf != NULL) 741 free(pf, M_SONAME); 742 return (rc); 743 744 kern_fail: 745 if(pf != NULL) 746 free(pf, M_SONAME); 747 ff_os_errno(rc); 748 return (-1); 749 } 750 751 int 752 ff_listen(int s, int backlog) 753 { 754 int rc; 755 struct listen_args la = { 756 .s = s, 757 .backlog = backlog, 758 }; 759 if ((rc = sys_listen(curthread, &la))) 760 goto kern_fail; 761 762 return (rc); 763 kern_fail: 764 ff_os_errno(rc); 765 return (-1); 766 } 767 768 int 769 ff_bind(int s, const struct linux_sockaddr *addr, socklen_t addrlen) 770 { 771 int rc; 772 struct sockaddr bsdaddr; 773 linux2freebsd_sockaddr(addr, addrlen, &bsdaddr); 774 775 if ((rc = kern_bindat(curthread, AT_FDCWD, s, &bsdaddr))) 776 goto kern_fail; 777 778 return (rc); 779 kern_fail: 780 ff_os_errno(rc); 781 return (-1); 782 } 783 784 int 785 ff_connect(int s, const struct linux_sockaddr *name, socklen_t namelen) 786 { 787 int rc; 788 struct sockaddr bsdaddr; 789 linux2freebsd_sockaddr(name, namelen, &bsdaddr); 790 791 if ((rc = kern_connectat(curthread, AT_FDCWD, s, &bsdaddr))) 792 goto kern_fail; 793 rc = curthread->td_retval[0]; 794 return (rc); 795 kern_fail: 796 ff_os_errno(rc); 797 return (-1); 798 } 799 800 int 801 ff_getpeername(int s, struct linux_sockaddr * name, 802 socklen_t *namelen) 803 { 804 int rc; 805 struct sockaddr *pf = NULL; 806 807 if ((rc = kern_getpeername(curthread, s, &pf, namelen))) 808 goto kern_fail; 809 810 if (name && pf) 811 freebsd2linux_sockaddr(name, pf); 812 813 if(pf != NULL) 814 free(pf, M_SONAME); 815 return (rc); 816 817 kern_fail: 818 if(pf != NULL) 819 free(pf, M_SONAME); 820 ff_os_errno(rc); 821 return (-1); 822 } 823 824 int 825 ff_getsockname(int s, struct linux_sockaddr *name, 826 socklen_t *namelen) 827 { 828 int rc; 829 struct sockaddr *pf = NULL; 830 831 if ((rc = kern_getsockname(curthread, s, &pf, namelen))) 832 goto kern_fail; 833 834 if (name && pf) 835 freebsd2linux_sockaddr(name, pf); 836 837 if(pf != NULL) 838 free(pf, M_SONAME); 839 return (rc); 840 841 kern_fail: 842 if(pf != NULL) 843 free(pf, M_SONAME); 844 ff_os_errno(rc); 845 return (-1); 846 } 847 848 int 849 ff_shutdown(int s, int how) 850 { 851 int rc; 852 853 struct shutdown_args sa = { 854 .s = s, 855 .how = how, 856 }; 857 if ((rc = sys_shutdown(curthread, &sa))) 858 goto kern_fail; 859 860 return (rc); 861 kern_fail: 862 ff_os_errno(rc); 863 return (-1); 864 } 865 866 int 867 ff_sysctl(const int *name, u_int namelen, void *oldp, size_t *oldlenp, 868 const void *newp, size_t newlen) 869 { 870 int rc; 871 size_t retval; 872 873 rc = userland_sysctl(curthread, __DECONST(int *, name), namelen, oldp, oldlenp, 874 1, __DECONST(void *, newp), newlen, &retval, 0); 875 if (rc) 876 goto kern_fail; 877 if (oldlenp) 878 *oldlenp = retval; 879 return (0); 880 kern_fail: 881 ff_os_errno(rc); 882 return (-1); 883 } 884 885 int 886 ff_select(int nfds, fd_set *readfds, fd_set *writefds, fd_set *exceptfds, 887 struct timeval *timeout) 888 889 { 890 int rc; 891 892 rc = kern_select(curthread, nfds, readfds, writefds, exceptfds, timeout, 64); 893 if (rc) 894 goto kern_fail; 895 rc = curthread->td_retval[0]; 896 897 return (rc); 898 kern_fail: 899 ff_os_errno(rc); 900 return (-1); 901 902 } 903 904 int 905 ff_poll(struct pollfd fds[], nfds_t nfds, int timeout) 906 { 907 int rc; 908 struct timespec ts; 909 ts.tv_sec = 0; 910 ts.tv_nsec = 0; 911 if ((rc = kern_poll(curthread, fds, nfds, &ts, NULL))) 912 goto kern_fail; 913 rc = curthread->td_retval[0]; 914 return (rc); 915 916 kern_fail: 917 ff_os_errno(rc); 918 return (-1); 919 } 920 921 int 922 ff_kqueue(void) 923 { 924 int rc; 925 if ((rc = kern_kqueue(curthread, 0, NULL))) 926 goto kern_fail; 927 928 rc = curthread->td_retval[0]; 929 return (rc); 930 931 kern_fail: 932 ff_os_errno(rc); 933 return (-1); 934 } 935 936 struct sys_kevent_args { 937 int fd; 938 const struct kevent *changelist; 939 int nchanges; 940 struct kevent *eventlist; 941 int nevents; 942 const struct timespec *timeout; 943 }; 944 945 static int 946 kevent_copyout(void *arg, struct kevent *kevp, int count) 947 { 948 struct sys_kevent_args *uap; 949 950 uap = (struct sys_kevent_args *)arg; 951 bcopy(kevp, uap->eventlist, count * sizeof *kevp); 952 953 uap->eventlist += count; 954 955 return (0); 956 } 957 958 /* 959 * Copy 'count' items from the list pointed to by uap->changelist. 960 */ 961 static int 962 kevent_copyin(void *arg, struct kevent *kevp, int count) 963 { 964 struct sys_kevent_args *uap; 965 966 uap = (struct sys_kevent_args *)arg; 967 bcopy(uap->changelist, kevp, count * sizeof *kevp); 968 969 uap->changelist += count; 970 971 return (0); 972 } 973 974 int 975 ff_kevent(int kq, const struct kevent *changelist, int nchanges, 976 struct kevent *eventlist, int nevents, const struct timespec *timeout) 977 { 978 int rc; 979 struct timespec ts; 980 ts.tv_sec = 0; 981 ts.tv_nsec = 0; 982 struct sys_kevent_args ska = { 983 kq, 984 changelist, 985 nchanges, 986 eventlist, 987 nevents, 988 &ts 989 }; 990 struct kevent_copyops k_ops = { 991 &ska, 992 kevent_copyout, 993 kevent_copyin 994 }; 995 996 if ((rc = kern_kevent(curthread, kq, nchanges, nevents, &k_ops, 997 &ts))) 998 goto kern_fail; 999 1000 rc = curthread->td_retval[0]; 1001 return (rc); 1002 kern_fail: 1003 ff_os_errno(rc); 1004 return (-1); 1005 } 1006 1007 int 1008 ff_route_ctl(enum FF_ROUTE_CTL req, enum FF_ROUTE_FLAG flag, 1009 struct linux_sockaddr *dst, struct linux_sockaddr *gw, 1010 struct linux_sockaddr *netmask) 1011 1012 { 1013 struct sockaddr sa_gw, sa_dst, sa_nm; 1014 struct sockaddr *psa_gw, *psa_dst, *psa_nm; 1015 int rtreq, rtflag; 1016 int rc; 1017 1018 switch (req) { 1019 case FF_ROUTE_ADD: 1020 rtreq = RTM_ADD; 1021 break; 1022 case FF_ROUTE_DEL: 1023 rtreq = RTM_DELETE; 1024 break; 1025 case FF_ROUTE_CHANGE: 1026 rtreq = RTM_CHANGE; 1027 break; 1028 default: 1029 rc = EINVAL; 1030 goto kern_fail; 1031 } 1032 1033 switch (flag) { 1034 case FF_RTF_HOST: 1035 rtflag = RTF_HOST; 1036 break; 1037 case FF_RTF_GATEWAY: 1038 rtflag = RTF_GATEWAY; 1039 break; 1040 default: 1041 rc = EINVAL; 1042 goto kern_fail; 1043 }; 1044 1045 if (gw != NULL) { 1046 psa_gw = &sa_gw; 1047 linux2freebsd_sockaddr(gw, sizeof(*gw), psa_gw); 1048 } else { 1049 psa_gw = NULL; 1050 } 1051 1052 if (dst != NULL) { 1053 psa_dst = &sa_dst; 1054 linux2freebsd_sockaddr(dst, sizeof(*dst), psa_dst); 1055 } else { 1056 psa_dst = NULL; 1057 } 1058 1059 if (netmask != NULL) { 1060 psa_nm = &sa_nm; 1061 linux2freebsd_sockaddr(netmask, sizeof(*netmask), psa_nm); 1062 } else { 1063 psa_nm = NULL; 1064 } 1065 1066 rc = rtrequest_fib(rtreq, psa_dst, psa_gw, psa_nm, rtflag, 1067 NULL, RT_DEFAULT_FIB); 1068 1069 if (rc != 0) 1070 goto kern_fail; 1071 1072 return (rc); 1073 1074 kern_fail: 1075 ff_os_errno(rc); 1076 return (-1); 1077 } 1078 1079