Lines Matching full:fd
49 int fd; in test_stream_connection_reset() local
51 fd = socket(AF_VSOCK, SOCK_STREAM, 0); in test_stream_connection_reset()
55 ret = connect(fd, &addr.sa, sizeof(addr.svm)); in test_stream_connection_reset()
69 close(fd); in test_stream_connection_reset()
85 int fd; in test_stream_bind_only_client() local
90 fd = socket(AF_VSOCK, SOCK_STREAM, 0); in test_stream_bind_only_client()
94 ret = connect(fd, &addr.sa, sizeof(addr.svm)); in test_stream_bind_only_client()
111 close(fd); in test_stream_bind_only_client()
116 int fd; in test_stream_bind_only_server() local
118 fd = vsock_bind(VMADDR_CID_ANY, opts->peer_port, SOCK_STREAM); in test_stream_bind_only_server()
126 close(fd); in test_stream_bind_only_server()
131 int fd; in test_stream_client_close_client() local
133 fd = vsock_stream_connect(opts->peer_cid, opts->peer_port); in test_stream_client_close_client()
134 if (fd < 0) { in test_stream_client_close_client()
139 send_byte(fd, 1, 0); in test_stream_client_close_client()
140 close(fd); in test_stream_client_close_client()
145 int fd; in test_stream_client_close_server() local
147 fd = vsock_stream_accept(VMADDR_CID_ANY, opts->peer_port, NULL); in test_stream_client_close_server()
148 if (fd < 0) { in test_stream_client_close_server()
156 vsock_wait_remote_close(fd); in test_stream_client_close_server()
158 send_byte(fd, -EPIPE, 0); in test_stream_client_close_server()
159 recv_byte(fd, 1, 0); in test_stream_client_close_server()
160 recv_byte(fd, 0, 0); in test_stream_client_close_server()
161 close(fd); in test_stream_client_close_server()
166 int fd; in test_stream_server_close_client() local
168 fd = vsock_stream_connect(opts->peer_cid, opts->peer_port); in test_stream_server_close_client()
169 if (fd < 0) { in test_stream_server_close_client()
177 vsock_wait_remote_close(fd); in test_stream_server_close_client()
179 send_byte(fd, -EPIPE, 0); in test_stream_server_close_client()
180 recv_byte(fd, 1, 0); in test_stream_server_close_client()
181 recv_byte(fd, 0, 0); in test_stream_server_close_client()
182 close(fd); in test_stream_server_close_client()
187 int fd; in test_stream_server_close_server() local
189 fd = vsock_stream_accept(VMADDR_CID_ANY, opts->peer_port, NULL); in test_stream_server_close_server()
190 if (fd < 0) { in test_stream_server_close_server()
195 send_byte(fd, 1, 0); in test_stream_server_close_server()
196 close(fd); in test_stream_server_close_server()
258 int fd; in test_msg_peek_client() local
262 fd = vsock_seqpacket_connect(opts->peer_cid, opts->peer_port); in test_msg_peek_client()
264 fd = vsock_stream_connect(opts->peer_cid, opts->peer_port); in test_msg_peek_client()
266 if (fd < 0) { in test_msg_peek_client()
276 send_buf(fd, buf, sizeof(buf), 0, sizeof(buf)); in test_msg_peek_client()
278 close(fd); in test_msg_peek_client()
287 int fd; in test_msg_peek_server() local
290 fd = vsock_seqpacket_accept(VMADDR_CID_ANY, opts->peer_port, NULL); in test_msg_peek_server()
292 fd = vsock_stream_accept(VMADDR_CID_ANY, opts->peer_port, NULL); in test_msg_peek_server()
294 if (fd < 0) { in test_msg_peek_server()
300 recv_buf(fd, buf_peek, sizeof(buf_peek), MSG_PEEK | MSG_DONTWAIT, in test_msg_peek_server()
306 recv_buf(fd, buf_half, sizeof(buf_half), MSG_PEEK, sizeof(buf_half)); in test_msg_peek_server()
309 recv_buf(fd, buf_peek, sizeof(buf_peek), MSG_PEEK, sizeof(buf_peek)); in test_msg_peek_server()
322 recv_buf(fd, buf_half, sizeof(buf_half), MSG_PEEK | MSG_TRUNC, in test_msg_peek_server()
326 recv_buf(fd, buf_normal, sizeof(buf_normal), 0, sizeof(buf_normal)); in test_msg_peek_server()
334 close(fd); in test_msg_peek_server()
356 int fd; in test_seqpacket_msg_bounds_client() local
358 fd = vsock_seqpacket_connect(opts->peer_cid, opts->peer_port); in test_seqpacket_msg_bounds_client()
359 if (fd < 0) { in test_seqpacket_msg_bounds_client()
400 send_buf(fd, buf, buf_size, flags, buf_size); in test_seqpacket_msg_bounds_client()
417 close(fd); in test_seqpacket_msg_bounds_client()
425 int fd; in test_seqpacket_msg_bounds_server() local
429 fd = vsock_seqpacket_accept(VMADDR_CID_ANY, opts->peer_port, NULL); in test_seqpacket_msg_bounds_server()
430 if (fd < 0) { in test_seqpacket_msg_bounds_server()
437 setsockopt_ull_check(fd, AF_VSOCK, SO_VM_SOCKETS_BUFFER_MAX_SIZE, in test_seqpacket_msg_bounds_server()
441 setsockopt_ull_check(fd, AF_VSOCK, SO_VM_SOCKETS_BUFFER_SIZE, in test_seqpacket_msg_bounds_server()
464 recv_size = recvmsg(fd, &msg, 0); in test_seqpacket_msg_bounds_server()
481 close(fd); in test_seqpacket_msg_bounds_server()
493 int fd; in test_seqpacket_msg_trunc_client() local
496 fd = vsock_seqpacket_connect(opts->peer_cid, opts->peer_port); in test_seqpacket_msg_trunc_client()
497 if (fd < 0) { in test_seqpacket_msg_trunc_client()
502 send_buf(fd, buf, sizeof(buf), 0, sizeof(buf)); in test_seqpacket_msg_trunc_client()
505 close(fd); in test_seqpacket_msg_trunc_client()
510 int fd; in test_seqpacket_msg_trunc_server() local
515 fd = vsock_seqpacket_accept(VMADDR_CID_ANY, opts->peer_port, NULL); in test_seqpacket_msg_trunc_server()
516 if (fd < 0) { in test_seqpacket_msg_trunc_server()
527 ssize_t ret = recvmsg(fd, &msg, MSG_TRUNC); in test_seqpacket_msg_trunc_server()
540 close(fd); in test_seqpacket_msg_trunc_server()
560 int fd; in test_seqpacket_timeout_client() local
566 fd = vsock_seqpacket_connect(opts->peer_cid, opts->peer_port); in test_seqpacket_timeout_client()
567 if (fd < 0) { in test_seqpacket_timeout_client()
575 setsockopt_timeval_check(fd, SOL_SOCKET, SO_RCVTIMEO, tv, in test_seqpacket_timeout_client()
580 if (read(fd, &dummy, sizeof(dummy)) != -1) { in test_seqpacket_timeout_client()
602 close(fd); in test_seqpacket_timeout_client()
607 int fd; in test_seqpacket_timeout_server() local
609 fd = vsock_seqpacket_accept(VMADDR_CID_ANY, opts->peer_port, NULL); in test_seqpacket_timeout_server()
610 if (fd < 0) { in test_seqpacket_timeout_server()
616 close(fd); in test_seqpacket_timeout_server()
625 int fd; in test_seqpacket_bigmsg_client() local
629 fd = vsock_seqpacket_connect(opts->peer_cid, opts->peer_port); in test_seqpacket_bigmsg_client()
630 if (fd < 0) { in test_seqpacket_bigmsg_client()
635 if (getsockopt(fd, AF_VSOCK, SO_VM_SOCKETS_BUFFER_SIZE, in test_seqpacket_bigmsg_client()
656 send_buf(fd, data, buf_size, 0, -EMSGSIZE); in test_seqpacket_bigmsg_client()
661 close(fd); in test_seqpacket_bigmsg_client()
666 int fd; in test_seqpacket_bigmsg_server() local
668 fd = vsock_seqpacket_accept(VMADDR_CID_ANY, opts->peer_port, NULL); in test_seqpacket_bigmsg_server()
669 if (fd < 0) { in test_seqpacket_bigmsg_server()
676 close(fd); in test_seqpacket_bigmsg_server()
684 int fd; in test_seqpacket_invalid_rec_buffer_client() local
689 fd = vsock_seqpacket_connect(opts->peer_cid, opts->peer_port); in test_seqpacket_invalid_rec_buffer_client()
690 if (fd < 0) { in test_seqpacket_invalid_rec_buffer_client()
710 send_buf(fd, buf1, buf_size, 0, buf_size); in test_seqpacket_invalid_rec_buffer_client()
712 send_buf(fd, buf2, buf_size, 0, buf_size); in test_seqpacket_invalid_rec_buffer_client()
714 close(fd); in test_seqpacket_invalid_rec_buffer_client()
719 int fd; in test_seqpacket_invalid_rec_buffer_server() local
729 fd = vsock_seqpacket_accept(VMADDR_CID_ANY, opts->peer_port, NULL); in test_seqpacket_invalid_rec_buffer_server()
730 if (fd < 0) { in test_seqpacket_invalid_rec_buffer_server()
755 res = read(fd, broken_buf, buf_size); in test_seqpacket_invalid_rec_buffer_server()
769 res = read(fd, valid_buf, buf_size); in test_seqpacket_invalid_rec_buffer_server()
795 close(fd); in test_seqpacket_invalid_rec_buffer_server()
802 int fd; in test_stream_poll_rcvlowat_server() local
805 fd = vsock_stream_accept(VMADDR_CID_ANY, opts->peer_port, NULL); in test_stream_poll_rcvlowat_server()
806 if (fd < 0) { in test_stream_poll_rcvlowat_server()
812 send_byte(fd, 1, 0); in test_stream_poll_rcvlowat_server()
820 send_byte(fd, 1, 0); in test_stream_poll_rcvlowat_server()
825 close(fd); in test_stream_poll_rcvlowat_server()
834 int fd; in test_stream_poll_rcvlowat_client() local
836 fd = vsock_stream_connect(opts->peer_cid, opts->peer_port); in test_stream_poll_rcvlowat_client()
837 if (fd < 0) { in test_stream_poll_rcvlowat_client()
842 setsockopt_int_check(fd, SOL_SOCKET, SO_RCVLOWAT, in test_stream_poll_rcvlowat_client()
848 fds.fd = fd; in test_stream_poll_rcvlowat_client()
884 recv_buf(fd, buf, sizeof(buf), MSG_DONTWAIT, RCVLOWAT_BUF_SIZE); in test_stream_poll_rcvlowat_client()
888 close(fd); in test_stream_poll_rcvlowat_client()
897 int fd; in test_inv_buf_client() local
900 fd = vsock_stream_connect(opts->peer_cid, opts->peer_port); in test_inv_buf_client()
902 fd = vsock_seqpacket_connect(opts->peer_cid, opts->peer_port); in test_inv_buf_client()
904 if (fd < 0) { in test_inv_buf_client()
912 recv_buf(fd, NULL, sizeof(data), 0, -EFAULT); in test_inv_buf_client()
922 recv_buf(fd, data, sizeof(data), MSG_DONTWAIT, expected_ret); in test_inv_buf_client()
926 close(fd); in test_inv_buf_client()
932 int fd; in test_inv_buf_server() local
935 fd = vsock_stream_accept(VMADDR_CID_ANY, opts->peer_port, NULL); in test_inv_buf_server()
937 fd = vsock_seqpacket_accept(VMADDR_CID_ANY, opts->peer_port, NULL); in test_inv_buf_server()
939 if (fd < 0) { in test_inv_buf_server()
944 send_buf(fd, data, sizeof(data), 0, sizeof(data)); in test_inv_buf_server()
950 close(fd); in test_inv_buf_server()
978 int fd; in test_stream_virtio_skb_merge_client() local
980 fd = vsock_stream_connect(opts->peer_cid, opts->peer_port); in test_stream_virtio_skb_merge_client()
981 if (fd < 0) { in test_stream_virtio_skb_merge_client()
987 send_buf(fd, HELLO_STR, strlen(HELLO_STR), 0, strlen(HELLO_STR)); in test_stream_virtio_skb_merge_client()
994 send_buf(fd, WORLD_STR, strlen(WORLD_STR), 0, strlen(WORLD_STR)); in test_stream_virtio_skb_merge_client()
1000 close(fd); in test_stream_virtio_skb_merge_client()
1007 int fd; in test_stream_virtio_skb_merge_server() local
1009 fd = vsock_stream_accept(VMADDR_CID_ANY, opts->peer_port, NULL); in test_stream_virtio_skb_merge_server()
1010 if (fd < 0) { in test_stream_virtio_skb_merge_server()
1019 recv_buf(fd, buf + read, to_read, 0, to_read); in test_stream_virtio_skb_merge_server()
1027 recv_buf(fd, buf + read, to_read, 0, to_read); in test_stream_virtio_skb_merge_server()
1032 recv_buf(fd, buf + read, to_read, MSG_DONTWAIT, -EAGAIN); in test_stream_virtio_skb_merge_server()
1041 close(fd); in test_stream_virtio_skb_merge_server()
1061 static void test_stream_check_sigpipe(int fd) in test_stream_check_sigpipe() argument
1067 res = send(fd, "A", 1, 0); in test_stream_check_sigpipe()
1080 res = send(fd, "A", 1, MSG_NOSIGNAL); in test_stream_check_sigpipe()
1094 int fd; in test_stream_shutwr_client() local
1102 fd = vsock_stream_connect(opts->peer_cid, opts->peer_port); in test_stream_shutwr_client()
1103 if (fd < 0) { in test_stream_shutwr_client()
1108 if (shutdown(fd, SHUT_WR)) { in test_stream_shutwr_client()
1113 test_stream_check_sigpipe(fd); in test_stream_shutwr_client()
1117 close(fd); in test_stream_shutwr_client()
1122 int fd; in test_stream_shutwr_server() local
1124 fd = vsock_stream_accept(VMADDR_CID_ANY, opts->peer_port, NULL); in test_stream_shutwr_server()
1125 if (fd < 0) { in test_stream_shutwr_server()
1132 close(fd); in test_stream_shutwr_server()
1137 int fd; in test_stream_shutrd_client() local
1145 fd = vsock_stream_connect(opts->peer_cid, opts->peer_port); in test_stream_shutrd_client()
1146 if (fd < 0) { in test_stream_shutrd_client()
1153 test_stream_check_sigpipe(fd); in test_stream_shutrd_client()
1157 close(fd); in test_stream_shutrd_client()
1162 int fd; in test_stream_shutrd_server() local
1164 fd = vsock_stream_accept(VMADDR_CID_ANY, opts->peer_port, NULL); in test_stream_shutrd_server()
1165 if (fd < 0) { in test_stream_shutrd_server()
1170 if (shutdown(fd, SHUT_RD)) { in test_stream_shutrd_server()
1178 close(fd); in test_stream_shutrd_server()
1253 int ret, fd, sock_bytes_unsent; in test_unsent_bytes_client() local
1255 fd = vsock_connect(opts->peer_cid, opts->peer_port, type); in test_unsent_bytes_client()
1256 if (fd < 0) { in test_unsent_bytes_client()
1264 send_buf(fd, buf, sizeof(buf), 0, sizeof(buf)); in test_unsent_bytes_client()
1267 ret = ioctl(fd, SIOCOUTQ, &sock_bytes_unsent); in test_unsent_bytes_client()
1282 close(fd); in test_unsent_bytes_client()
1317 int fd; in test_stream_rcvlowat_def_cred_upd_client() local
1319 fd = vsock_stream_connect(opts->peer_cid, opts->peer_port); in test_stream_rcvlowat_def_cred_upd_client()
1320 if (fd < 0) { in test_stream_rcvlowat_def_cred_upd_client()
1335 recv_byte(fd, 1, 0); in test_stream_rcvlowat_def_cred_upd_client()
1337 if (send(fd, buf, buf_size, 0) != buf_size) { in test_stream_rcvlowat_def_cred_upd_client()
1343 close(fd); in test_stream_rcvlowat_def_cred_upd_client()
1354 int fd; in test_stream_credit_update_test() local
1356 fd = vsock_stream_accept(VMADDR_CID_ANY, opts->peer_port, NULL); in test_stream_credit_update_test()
1357 if (fd < 0) { in test_stream_credit_update_test()
1367 setsockopt_ull_check(fd, AF_VSOCK, SO_VM_SOCKETS_BUFFER_SIZE, in test_stream_credit_update_test()
1378 setsockopt_int_check(fd, SOL_SOCKET, SO_RCVLOWAT, in test_stream_credit_update_test()
1388 send_byte(fd, 1, 0); in test_stream_credit_update_test()
1400 res = recv(fd, buf, buf_size, MSG_PEEK); in test_stream_credit_update_test()
1415 recv_buf(fd, buf, recv_buf_size, 0, recv_buf_size); in test_stream_credit_update_test()
1421 setsockopt_int_check(fd, SOL_SOCKET, SO_RCVLOWAT, in test_stream_credit_update_test()
1425 fds.fd = fd; in test_stream_credit_update_test()
1443 recv_buf(fd, buf, recv_buf_size, MSG_DONTWAIT, recv_buf_size); in test_stream_credit_update_test()
1453 close(fd); in test_stream_credit_update_test()
1483 int fd; in test_stream_leak_acceptq_client() local
1489 fd = vsock_stream_connect(opts->peer_cid, opts->peer_port); in test_stream_leak_acceptq_client()
1490 if (fd >= 0) in test_stream_leak_acceptq_client()
1491 close(fd); in test_stream_leak_acceptq_client()
1500 int fd; in test_stream_leak_acceptq_server() local
1503 fd = vsock_stream_listen(VMADDR_CID_ANY, opts->peer_port); in test_stream_leak_acceptq_server()
1505 close(fd); in test_stream_leak_acceptq_server()
1513 int fd; in test_stream_msgzcopy_leak_errq_client() local
1515 fd = vsock_stream_connect(opts->peer_cid, opts->peer_port); in test_stream_msgzcopy_leak_errq_client()
1516 if (fd < 0) { in test_stream_msgzcopy_leak_errq_client()
1521 enable_so_zerocopy_check(fd); in test_stream_msgzcopy_leak_errq_client()
1522 send_byte(fd, 1, MSG_ZEROCOPY); in test_stream_msgzcopy_leak_errq_client()
1524 fds.fd = fd; in test_stream_msgzcopy_leak_errq_client()
1531 close(fd); in test_stream_msgzcopy_leak_errq_client()
1536 int fd; in test_stream_msgzcopy_leak_errq_server() local
1538 fd = vsock_stream_accept(VMADDR_CID_ANY, opts->peer_port, NULL); in test_stream_msgzcopy_leak_errq_server()
1539 if (fd < 0) { in test_stream_msgzcopy_leak_errq_server()
1544 recv_byte(fd, 1, 0); in test_stream_msgzcopy_leak_errq_server()
1545 vsock_wait_remote_close(fd); in test_stream_msgzcopy_leak_errq_server()
1546 close(fd); in test_stream_msgzcopy_leak_errq_server()
1604 * int fd;
1607 * fd = vsock_stream_accept(VMADDR_CID_ANY, opts->peer_port, NULL);
1608 * vsock_wait_remote_close(fd);
1609 * close(fd);
1625 int fd, res; in test_stream_msgzcopy_leak_zcskb_client() local
1641 fd = vsock_stream_connect(opts->peer_cid, opts->peer_port); in test_stream_msgzcopy_leak_zcskb_client()
1642 if (fd < 0) { in test_stream_msgzcopy_leak_zcskb_client()
1647 enable_so_zerocopy_check(fd); in test_stream_msgzcopy_leak_zcskb_client()
1672 res = sendmsg(fd, &msg, MSG_ZEROCOPY); in test_stream_msgzcopy_leak_zcskb_client()
1679 close(fd); in test_stream_msgzcopy_leak_zcskb_client()
1684 int fd; in test_stream_msgzcopy_leak_zcskb_server() local
1686 fd = vsock_stream_accept(VMADDR_CID_ANY, opts->peer_port, NULL); in test_stream_msgzcopy_leak_zcskb_server()
1687 if (fd < 0) { in test_stream_msgzcopy_leak_zcskb_server()
1692 vsock_wait_remote_close(fd); in test_stream_msgzcopy_leak_zcskb_server()
1693 close(fd); in test_stream_msgzcopy_leak_zcskb_server()
1705 int fd, i, alen; in test_stream_transport_uaf_client() local
1707 fd = vsock_bind(VMADDR_CID_ANY, VMADDR_PORT_ANY, SOCK_STREAM); in test_stream_transport_uaf_client()
1710 if (getsockname(fd, (struct sockaddr *)&addr, &alen)) { in test_stream_transport_uaf_client()
1719 close(fd); in test_stream_transport_uaf_client()
1720 fd = socket(AF_VSOCK, SOCK_STREAM, 0); in test_stream_transport_uaf_client()
1721 if (fd < 0) { in test_stream_transport_uaf_client()
1726 if (!vsock_connect_fd(fd, addr.svm_cid, addr.svm_port)) { in test_stream_transport_uaf_client()
1732 if (!vsock_connect_fd(fd, VMADDR_CID_HOST, VMADDR_PORT_ANY)) { in test_stream_transport_uaf_client()
1737 close(fd); in test_stream_transport_uaf_client()
1751 int fd; in test_stream_connect_retry_client() local
1753 fd = socket(AF_VSOCK, SOCK_STREAM, 0); in test_stream_connect_retry_client()
1754 if (fd < 0) { in test_stream_connect_retry_client()
1759 if (!vsock_connect_fd(fd, opts->peer_cid, opts->peer_port)) { in test_stream_connect_retry_client()
1767 if (vsock_connect_fd(fd, opts->peer_cid, opts->peer_port)) { in test_stream_connect_retry_client()
1772 close(fd); in test_stream_connect_retry_client()
1777 int fd; in test_stream_connect_retry_server() local
1781 fd = vsock_stream_accept(VMADDR_CID_ANY, opts->peer_port, NULL); in test_stream_connect_retry_server()
1782 if (fd < 0) { in test_stream_connect_retry_server()
1787 vsock_wait_remote_close(fd); in test_stream_connect_retry_server()
1788 close(fd); in test_stream_connect_retry_server()
1797 int fd; in test_stream_linger_client() local
1799 fd = vsock_stream_connect(opts->peer_cid, opts->peer_port); in test_stream_linger_client()
1800 if (fd < 0) { in test_stream_linger_client()
1805 if (setsockopt(fd, SOL_SOCKET, SO_LINGER, &optval, sizeof(optval))) { in test_stream_linger_client()
1810 close(fd); in test_stream_linger_client()
1815 int fd; in test_stream_linger_server() local
1817 fd = vsock_stream_accept(VMADDR_CID_ANY, opts->peer_port, NULL); in test_stream_linger_server()
1818 if (fd < 0) { in test_stream_linger_server()
1823 vsock_wait_remote_close(fd); in test_stream_linger_server()
1824 close(fd); in test_stream_linger_server()