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 /* #linux and #freebsd may point to the same address */ 338 freebsd->sa_family = linux->sa_family; 339 freebsd->sa_len = addrlen; 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_USERSPACE, 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_USERSPACE, 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 struct sockaddr freebsd_sa; 613 void *linux_sa = msg->msg_name; 614 615 if (linux_sa != NULL) { 616 linux2freebsd_sockaddr(linux_sa, 617 sizeof(struct linux_sockaddr), &freebsd_sa); 618 __DECONST(struct msghdr *, msg)->msg_name = &freebsd_sa; 619 } 620 621 rc = sendit(curthread, s, __DECONST(struct msghdr *, msg), flags); 622 623 __DECONST(struct msghdr *, msg)->msg_name = linux_sa; 624 625 if (rc) 626 goto kern_fail; 627 628 return (rc); 629 kern_fail: 630 ff_os_errno(rc); 631 return (-1); 632 } 633 634 635 ssize_t 636 ff_recv(int s, void *buf, size_t len, int flags) 637 { 638 return (ff_recvfrom(s, buf, len, flags, NULL, 0)); 639 } 640 641 ssize_t 642 ff_recvfrom(int s, void *buf, size_t len, int flags, 643 struct linux_sockaddr *from, socklen_t *fromlen) 644 { 645 struct msghdr msg; 646 struct iovec aiov; 647 int rc; 648 struct sockaddr bsdaddr; 649 650 if (fromlen != NULL) 651 msg.msg_namelen = *fromlen; 652 else 653 msg.msg_namelen = 0; 654 655 msg.msg_name = &bsdaddr; 656 msg.msg_iov = &aiov; 657 msg.msg_iovlen = 1; 658 aiov.iov_base = buf; 659 aiov.iov_len = len; 660 msg.msg_control = 0; 661 msg.msg_flags = flags; 662 if ((rc = kern_recvit(curthread, s, &msg, UIO_SYSSPACE, NULL))) 663 goto kern_fail; 664 rc = curthread->td_retval[0]; 665 if (fromlen != NULL) 666 *fromlen = msg.msg_namelen; 667 668 if (from) 669 freebsd2linux_sockaddr(from, &bsdaddr); 670 671 return (rc); 672 kern_fail: 673 ff_os_errno(rc); 674 return (-1); 675 } 676 677 ssize_t 678 ff_recvmsg(int s, struct msghdr *msg, int flags) 679 { 680 int rc, oldflags; 681 682 oldflags = msg->msg_flags; 683 msg->msg_flags = flags; 684 685 if ((rc = kern_recvit(curthread, s, msg, UIO_SYSSPACE, NULL))) { 686 msg->msg_flags = oldflags; 687 goto kern_fail; 688 } 689 rc = curthread->td_retval[0]; 690 691 freebsd2linux_sockaddr(msg->msg_name, msg->msg_name); 692 693 return (rc); 694 kern_fail: 695 ff_os_errno(rc); 696 return (-1); 697 } 698 699 int 700 ff_fcntl(int fd, int cmd, ...) 701 { 702 int rc; 703 va_list ap; 704 uintptr_t argp; 705 706 va_start(ap, cmd); 707 708 argp = va_arg(ap, uintptr_t); 709 va_end(ap); 710 711 if ((rc = kern_fcntl(curthread, fd, cmd, argp))) 712 goto kern_fail; 713 rc = curthread->td_retval[0]; 714 return (rc); 715 kern_fail: 716 ff_os_errno(rc); 717 return (-1); 718 } 719 720 int 721 ff_accept(int s, struct linux_sockaddr * addr, 722 socklen_t * addrlen) 723 { 724 int rc; 725 struct file *fp; 726 struct sockaddr *pf = NULL; 727 socklen_t socklen = sizeof(struct sockaddr); 728 729 if ((rc = kern_accept(curthread, s, &pf, &socklen, &fp))) 730 goto kern_fail; 731 732 rc = curthread->td_retval[0]; 733 fdrop(fp, curthread); 734 735 if (addr && pf) 736 freebsd2linux_sockaddr(addr, pf); 737 738 if (addrlen) 739 *addrlen = socklen; 740 741 if(pf != NULL) 742 free(pf, M_SONAME); 743 return (rc); 744 745 kern_fail: 746 if(pf != NULL) 747 free(pf, M_SONAME); 748 ff_os_errno(rc); 749 return (-1); 750 } 751 752 int 753 ff_listen(int s, int backlog) 754 { 755 int rc; 756 struct listen_args la = { 757 .s = s, 758 .backlog = backlog, 759 }; 760 if ((rc = sys_listen(curthread, &la))) 761 goto kern_fail; 762 763 return (rc); 764 kern_fail: 765 ff_os_errno(rc); 766 return (-1); 767 } 768 769 int 770 ff_bind(int s, const struct linux_sockaddr *addr, socklen_t addrlen) 771 { 772 int rc; 773 struct sockaddr bsdaddr; 774 linux2freebsd_sockaddr(addr, addrlen, &bsdaddr); 775 776 if ((rc = kern_bindat(curthread, AT_FDCWD, s, &bsdaddr))) 777 goto kern_fail; 778 779 return (rc); 780 kern_fail: 781 ff_os_errno(rc); 782 return (-1); 783 } 784 785 int 786 ff_connect(int s, const struct linux_sockaddr *name, socklen_t namelen) 787 { 788 int rc; 789 struct sockaddr bsdaddr; 790 linux2freebsd_sockaddr(name, namelen, &bsdaddr); 791 792 if ((rc = kern_connectat(curthread, AT_FDCWD, s, &bsdaddr))) 793 goto kern_fail; 794 795 return (rc); 796 kern_fail: 797 ff_os_errno(rc); 798 return (-1); 799 } 800 801 int 802 ff_getpeername(int s, struct linux_sockaddr * name, 803 socklen_t *namelen) 804 { 805 int rc; 806 struct sockaddr *pf = NULL; 807 808 if ((rc = kern_getpeername(curthread, s, &pf, namelen))) 809 goto kern_fail; 810 811 if (name && pf) 812 freebsd2linux_sockaddr(name, pf); 813 814 if(pf != NULL) 815 free(pf, M_SONAME); 816 return (rc); 817 818 kern_fail: 819 if(pf != NULL) 820 free(pf, M_SONAME); 821 ff_os_errno(rc); 822 return (-1); 823 } 824 825 int 826 ff_getsockname(int s, struct linux_sockaddr *name, 827 socklen_t *namelen) 828 { 829 int rc; 830 struct sockaddr *pf = NULL; 831 832 if ((rc = kern_getsockname(curthread, s, &pf, namelen))) 833 goto kern_fail; 834 835 if (name && pf) 836 freebsd2linux_sockaddr(name, pf); 837 838 if(pf != NULL) 839 free(pf, M_SONAME); 840 return (rc); 841 842 kern_fail: 843 if(pf != NULL) 844 free(pf, M_SONAME); 845 ff_os_errno(rc); 846 return (-1); 847 } 848 849 int 850 ff_shutdown(int s, int how) 851 { 852 int rc; 853 854 struct shutdown_args sa = { 855 .s = s, 856 .how = how, 857 }; 858 if ((rc = sys_shutdown(curthread, &sa))) 859 goto kern_fail; 860 861 return (rc); 862 kern_fail: 863 ff_os_errno(rc); 864 return (-1); 865 } 866 867 int 868 ff_sysctl(const int *name, u_int namelen, void *oldp, size_t *oldlenp, 869 const void *newp, size_t newlen) 870 { 871 int rc; 872 size_t retval; 873 874 rc = userland_sysctl(curthread, __DECONST(int *, name), namelen, oldp, oldlenp, 875 1, __DECONST(void *, newp), newlen, &retval, 0); 876 if (rc) 877 goto kern_fail; 878 if (oldlenp) 879 *oldlenp = retval; 880 return (0); 881 kern_fail: 882 ff_os_errno(rc); 883 return (-1); 884 } 885 886 int 887 ff_select(int nfds, fd_set *readfds, fd_set *writefds, fd_set *exceptfds, 888 struct timeval *timeout) 889 890 { 891 int rc; 892 893 rc = kern_select(curthread, nfds, readfds, writefds, exceptfds, timeout, 64); 894 if (rc) 895 goto kern_fail; 896 rc = curthread->td_retval[0]; 897 898 return (rc); 899 kern_fail: 900 ff_os_errno(rc); 901 return (-1); 902 903 } 904 905 int 906 ff_poll(struct pollfd fds[], nfds_t nfds, int timeout) 907 { 908 int rc; 909 struct timespec ts; 910 ts.tv_sec = 0; 911 ts.tv_nsec = 0; 912 if ((rc = kern_poll(curthread, fds, nfds, &ts, NULL))) 913 goto kern_fail; 914 rc = curthread->td_retval[0]; 915 return (rc); 916 917 kern_fail: 918 ff_os_errno(rc); 919 return (-1); 920 } 921 922 int 923 ff_kqueue(void) 924 { 925 int rc; 926 if ((rc = kern_kqueue(curthread, 0, NULL))) 927 goto kern_fail; 928 929 rc = curthread->td_retval[0]; 930 return (rc); 931 932 kern_fail: 933 ff_os_errno(rc); 934 return (-1); 935 } 936 937 struct sys_kevent_args { 938 int fd; 939 const struct kevent *changelist; 940 int nchanges; 941 void *eventlist; 942 int nevents; 943 const struct timespec *timeout; 944 void (*do_each)(void **, struct kevent *); 945 }; 946 947 static int 948 kevent_copyout(void *arg, struct kevent *kevp, int count) 949 { 950 int i; 951 struct kevent *ke; 952 struct sys_kevent_args *uap; 953 954 uap = (struct sys_kevent_args *)arg; 955 956 if (!uap->do_each) { 957 bcopy(kevp, uap->eventlist, count * sizeof *kevp); 958 uap->eventlist = (void *)((struct kevent *)(uap->eventlist) + count); 959 960 } else { 961 for (ke = kevp, i = 0; i < count; i++, ke++) { 962 uap->do_each(&(uap->eventlist), ke); 963 } 964 } 965 966 return (0); 967 } 968 969 /* 970 * Copy 'count' items from the list pointed to by uap->changelist. 971 */ 972 static int 973 kevent_copyin(void *arg, struct kevent *kevp, int count) 974 { 975 struct sys_kevent_args *uap; 976 977 uap = (struct sys_kevent_args *)arg; 978 bcopy(uap->changelist, kevp, count * sizeof *kevp); 979 980 uap->changelist += count; 981 982 return (0); 983 } 984 985 int 986 ff_kevent_do_each(int kq, const struct kevent *changelist, int nchanges, 987 void *eventlist, int nevents, const struct timespec *timeout, 988 void (*do_each)(void **, struct kevent *)) 989 { 990 int rc; 991 struct timespec ts; 992 ts.tv_sec = 0; 993 ts.tv_nsec = 0; 994 995 struct sys_kevent_args ska = { 996 kq, 997 changelist, 998 nchanges, 999 eventlist, 1000 nevents, 1001 &ts, 1002 do_each 1003 }; 1004 1005 struct kevent_copyops k_ops = { 1006 &ska, 1007 kevent_copyout, 1008 kevent_copyin 1009 }; 1010 1011 if ((rc = kern_kevent(curthread, kq, nchanges, nevents, &k_ops, 1012 &ts))) 1013 goto kern_fail; 1014 1015 rc = curthread->td_retval[0]; 1016 return (rc); 1017 kern_fail: 1018 ff_os_errno(rc); 1019 return (-1); 1020 } 1021 1022 int 1023 ff_kevent(int kq, const struct kevent *changelist, int nchanges, 1024 struct kevent *eventlist, int nevents, const struct timespec *timeout) 1025 { 1026 return ff_kevent_do_each(kq, changelist, nchanges, eventlist, nevents, timeout, NULL); 1027 } 1028 1029 int 1030 ff_gettimeofday(struct timeval *tv, struct timezone *tz) 1031 { 1032 long nsec; 1033 ff_get_current_time(&(tv->tv_sec), &nsec); 1034 tv->tv_usec = nsec/1000; 1035 return 0; 1036 } 1037 1038 int 1039 ff_route_ctl(enum FF_ROUTE_CTL req, enum FF_ROUTE_FLAG flag, 1040 struct linux_sockaddr *dst, struct linux_sockaddr *gw, 1041 struct linux_sockaddr *netmask) 1042 1043 { 1044 struct sockaddr sa_gw, sa_dst, sa_nm; 1045 struct sockaddr *psa_gw, *psa_dst, *psa_nm; 1046 int rtreq, rtflag; 1047 int rc; 1048 1049 switch (req) { 1050 case FF_ROUTE_ADD: 1051 rtreq = RTM_ADD; 1052 break; 1053 case FF_ROUTE_DEL: 1054 rtreq = RTM_DELETE; 1055 break; 1056 case FF_ROUTE_CHANGE: 1057 rtreq = RTM_CHANGE; 1058 break; 1059 default: 1060 rc = EINVAL; 1061 goto kern_fail; 1062 } 1063 1064 switch (flag) { 1065 case FF_RTF_HOST: 1066 rtflag = RTF_HOST; 1067 break; 1068 case FF_RTF_GATEWAY: 1069 rtflag = RTF_GATEWAY; 1070 break; 1071 default: 1072 rc = EINVAL; 1073 goto kern_fail; 1074 }; 1075 1076 if (gw != NULL) { 1077 psa_gw = &sa_gw; 1078 linux2freebsd_sockaddr(gw, sizeof(*gw), psa_gw); 1079 } else { 1080 psa_gw = NULL; 1081 } 1082 1083 if (dst != NULL) { 1084 psa_dst = &sa_dst; 1085 linux2freebsd_sockaddr(dst, sizeof(*dst), psa_dst); 1086 } else { 1087 psa_dst = NULL; 1088 } 1089 1090 if (netmask != NULL) { 1091 psa_nm = &sa_nm; 1092 linux2freebsd_sockaddr(netmask, sizeof(*netmask), psa_nm); 1093 } else { 1094 psa_nm = NULL; 1095 } 1096 1097 rc = rtrequest_fib(rtreq, psa_dst, psa_gw, psa_nm, rtflag, 1098 NULL, RT_DEFAULT_FIB); 1099 1100 if (rc != 0) 1101 goto kern_fail; 1102 1103 return (rc); 1104 1105 kern_fail: 1106 ff_os_errno(rc); 1107 return (-1); 1108 } 1109