Lines Matching refs:fd
39 int fd; member
53 qemu_set_fd_handler(s->fd, in net_socket_update_fd_handler()
97 ret = iov_send(s->fd, iov, 2, s->send_index, remaining); in net_socket_receive()
122 sendto(s->fd, buf, size, 0, in net_socket_receive_dgram()
125 send(s->fd, buf, size, 0) in net_socket_receive_dgram()
163 size = recv(s->fd, buf1, sizeof(buf1), 0); in net_socket_send()
175 close(s->fd); in net_socket_send()
177 s->fd = -1; in net_socket_send()
198 size = recv(s->fd, s->rs.buf, sizeof(s->rs.buf), 0); in net_socket_send_dgram()
218 int fd; in net_socket_mcast_create() local
234 fd = qemu_socket(PF_INET, SOCK_DGRAM, 0); in net_socket_mcast_create()
235 if (fd < 0) { in net_socket_mcast_create()
246 ret = setsockopt(fd, SOL_SOCKET, SO_REUSEADDR, &val, sizeof(val)); in net_socket_mcast_create()
253 ret = bind(fd, (struct sockaddr *)mcastaddr, sizeof(*mcastaddr)); in net_socket_mcast_create()
268 ret = setsockopt(fd, IPPROTO_IP, IP_ADD_MEMBERSHIP, in net_socket_mcast_create()
279 ret = setsockopt(fd, IPPROTO_IP, IP_MULTICAST_LOOP, in net_socket_mcast_create()
289 ret = setsockopt(fd, IPPROTO_IP, IP_MULTICAST_IF, in net_socket_mcast_create()
298 qemu_socket_set_nonblock(fd); in net_socket_mcast_create()
299 return fd; in net_socket_mcast_create()
301 if (fd >= 0) in net_socket_mcast_create()
302 close(fd); in net_socket_mcast_create()
309 if (s->fd != -1) { in net_socket_cleanup()
312 close(s->fd); in net_socket_cleanup()
313 s->fd = -1; in net_socket_cleanup()
332 int fd, int is_connected, in net_socket_fd_init_dgram() argument
343 sa = socket_local_address(fd, errp); in net_socket_fd_init_dgram()
370 dup2(newfd, fd); in net_socket_fd_init_dgram()
379 s->fd = fd; in net_socket_fd_init_dgram()
388 qemu_set_info_str(nc, "socket: fd=%d (cloned mcast=%s:%d)", fd, in net_socket_fd_init_dgram()
395 qemu_set_info_str(nc, "socket: fd=%d %s", fd, in net_socket_fd_init_dgram()
402 close(fd); in net_socket_fd_init_dgram()
423 int fd, int is_connected) in net_socket_fd_init_stream() argument
430 qemu_set_info_str(nc, "socket: fd=%d", fd); in net_socket_fd_init_stream()
434 s->fd = fd; in net_socket_fd_init_stream()
439 socket_set_nodelay(fd); in net_socket_fd_init_stream()
444 qemu_set_fd_handler(s->fd, NULL, net_socket_connect, s); in net_socket_fd_init_stream()
449 static int net_socket_fd_check(int fd, Error **errp) in net_socket_fd_check() argument
453 if (getsockopt(fd, SOL_SOCKET, SO_TYPE, (char *)&so_type, in net_socket_fd_check()
460 " SOCK_DGRAM or SOCK_STREAM", so_type, fd); in net_socket_fd_check()
471 int fd; in net_socket_accept() local
475 fd = qemu_accept(s->listen_fd, (struct sockaddr *)&saddr, &len); in net_socket_accept()
476 if (fd < 0 && errno != EINTR) { in net_socket_accept()
478 } else if (fd >= 0) { in net_socket_accept()
484 s->fd = fd; in net_socket_accept()
500 int fd, ret; in net_socket_listen_init() local
506 fd = qemu_socket(PF_INET, SOCK_STREAM, 0); in net_socket_listen_init()
507 if (fd < 0) { in net_socket_listen_init()
511 qemu_socket_set_nonblock(fd); in net_socket_listen_init()
513 socket_set_fast_reuse(fd); in net_socket_listen_init()
515 ret = bind(fd, (struct sockaddr *)&saddr, sizeof(saddr)); in net_socket_listen_init()
519 close(fd); in net_socket_listen_init()
522 ret = listen(fd, 0); in net_socket_listen_init()
525 close(fd); in net_socket_listen_init()
531 s->fd = -1; in net_socket_listen_init()
532 s->listen_fd = fd; in net_socket_listen_init()
547 int fd, connected, ret; in net_socket_connect_init() local
554 fd = qemu_socket(PF_INET, SOCK_STREAM, 0); in net_socket_connect_init()
555 if (fd < 0) { in net_socket_connect_init()
559 qemu_socket_set_nonblock(fd); in net_socket_connect_init()
563 ret = connect(fd, (struct sockaddr *)&saddr, sizeof(saddr)); in net_socket_connect_init()
572 close(fd); in net_socket_connect_init()
580 s = net_socket_fd_init_stream(peer, model, name, fd, connected); in net_socket_connect_init()
598 int fd; in net_socket_mcast_init() local
617 fd = net_socket_mcast_create(&saddr, param_localaddr, errp); in net_socket_mcast_init()
618 if (fd < 0) { in net_socket_mcast_init()
622 s = net_socket_fd_init_dgram(peer, model, name, fd, 0, NULL, errp); in net_socket_mcast_init()
643 int fd, ret; in net_socket_udp_init() local
654 fd = qemu_socket(PF_INET, SOCK_DGRAM, 0); in net_socket_udp_init()
655 if (fd < 0) { in net_socket_udp_init()
660 ret = socket_set_fast_reuse(fd); in net_socket_udp_init()
664 close(fd); in net_socket_udp_init()
667 ret = bind(fd, (struct sockaddr *)&laddr, sizeof(laddr)); in net_socket_udp_init()
671 close(fd); in net_socket_udp_init()
674 qemu_socket_set_nonblock(fd); in net_socket_udp_init()
676 s = net_socket_fd_init_dgram(peer, model, name, fd, 0, NULL, errp); in net_socket_udp_init()
696 if (!!sock->fd + !!sock->listen + !!sock->connect + !!sock->mcast + in net_init_socket()
708 if (sock->fd) { in net_init_socket()
709 int fd, ret, so_type; in net_init_socket() local
711 fd = monitor_fd_param(monitor_cur(), sock->fd, errp); in net_init_socket()
712 if (fd == -1) { in net_init_socket()
715 so_type = net_socket_fd_check(fd, errp); in net_init_socket()
719 ret = qemu_socket_try_set_nonblock(fd); in net_init_socket()
722 name, fd); in net_init_socket()
727 if (!net_socket_fd_init_dgram(peer, "socket", name, fd, 1, in net_init_socket()
733 if (!net_socket_fd_init_stream(peer, "socket", name, fd, 1)) { in net_init_socket()