Lines Matching refs:fd

56   if (handle->io_watcher.fd != -1) {  in uv__udp_close()
57 uv__close(handle->io_watcher.fd); in uv__udp_close()
58 handle->io_watcher.fd = -1; in uv__udp_close()
68 assert(handle->io_watcher.fd == -1); in uv__udp_finish_close()
179 nread = recvmmsg(handle->io_watcher.fd, msgs, chunks, 0, NULL); in uv__udp_recvmmsg()
252 nread = recvmsg(handle->io_watcher.fd, &h, 0); in uv__udp_recvmsg()
274 && handle->io_watcher.fd != -1 in uv__udp_recvmsg()
305 size = sendmsg(handle->io_watcher.fd, &h, 0); in uv__udp_sendmsg_one()
370 npkts = sendmmsg(handle->io_watcher.fd, h, pkts, 0); in uv__udp_sendmsg_many()
447 static int uv__set_reuse(int fd) { in uv__set_reuse() argument
454 if (getsockname(fd, (struct sockaddr*) &sockfd, &sockfd_len) == -1) in uv__set_reuse()
457 if (setsockopt(fd, SOL_SOCKET, SO_REUSEADDR, &yes, sizeof(yes))) in uv__set_reuse()
460 if (setsockopt(fd, SOL_SOCKET, SO_REUSEPORT, &yes, sizeof(yes))) in uv__set_reuse()
465 if (setsockopt(fd, SOL_SOCKET, SO_REUSEPORT, &yes, sizeof(yes))) in uv__set_reuse()
468 if (setsockopt(fd, SOL_SOCKET, SO_REUSEADDR, &yes, sizeof(yes))) in uv__set_reuse()
481 static int uv__set_recverr(int fd, sa_family_t ss_family) { in uv__set_recverr() argument
487 if (setsockopt(fd, IPPROTO_IP, IP_RECVERR, &yes, sizeof(yes))) in uv__set_recverr()
490 if (setsockopt(fd, IPPROTO_IPV6, IPV6_RECVERR, &yes, sizeof(yes))) in uv__set_recverr()
504 int fd; in uv__udp_bind() local
514 fd = handle->io_watcher.fd; in uv__udp_bind()
515 if (fd == -1) { in uv__udp_bind()
519 fd = err; in uv__udp_bind()
520 handle->io_watcher.fd = fd; in uv__udp_bind()
524 err = uv__set_recverr(fd, addr->sa_family); in uv__udp_bind()
530 err = uv__set_reuse(fd); in uv__udp_bind()
538 if (setsockopt(fd, IPPROTO_IPV6, IPV6_V6ONLY, &yes, sizeof yes) == -1) { in uv__udp_bind()
548 if (bind(fd, addr, addrlen)) { in uv__udp_bind()
571 if (handle->io_watcher.fd != -1) in uv__udp_maybe_deferred_bind()
613 err = connect(handle->io_watcher.fd, addr, addrlen); in uv__udp_connect()
679 r = connect(handle->io_watcher.fd, (struct sockaddr*) NULL, 0); in uv__udp_disconnect()
681 r = connect(handle->io_watcher.fd, (struct sockaddr*) &addr, sizeof(addr)); in uv__udp_disconnect()
794 size = sendmsg(handle->io_watcher.fd, &h, 0); in uv__udp_try_send()
839 if (setsockopt(handle->io_watcher.fd, in uv__udp_set_membership4()
886 if (setsockopt(handle->io_watcher.fd, in uv__udp_set_membership6()
941 if (setsockopt(handle->io_watcher.fd, in uv__udp_set_source_membership4()
990 if (setsockopt(handle->io_watcher.fd, in uv__udp_set_source_membership6()
1007 int fd; in uv__udp_init_ex() local
1009 fd = -1; in uv__udp_init_ex()
1011 fd = uv__socket(domain, SOCK_DGRAM, 0); in uv__udp_init_ex()
1012 if (fd < 0) in uv__udp_init_ex()
1013 return fd; in uv__udp_init_ex()
1021 uv__io_init(&handle->io_watcher, uv__udp_io, fd); in uv__udp_init_ex()
1042 if (handle->io_watcher.fd != -1) in uv_udp_open()
1056 handle->io_watcher.fd = sock; in uv_udp_open()
1140 r = setsockopt(handle->io_watcher.fd, in uv__setsockopt()
1146 r = setsockopt(handle->io_watcher.fd, in uv__setsockopt()
1177 if (setsockopt(handle->io_watcher.fd, in uv_udp_set_broadcast()
1301 if (setsockopt(handle->io_watcher.fd, in uv_udp_set_multicast_interface()
1309 if (setsockopt(handle->io_watcher.fd, in uv_udp_set_multicast_interface()