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()
1274 		ret = ioctl(fd, SIOCOUTQ, &sock_bytes_unsent);  in test_unsent_bytes_client()
1286 	close(fd);  in test_unsent_bytes_client()
1321 	int fd;  in test_stream_rcvlowat_def_cred_upd_client()  local
1323 	fd = vsock_stream_connect(opts->peer_cid, opts->peer_port);  in test_stream_rcvlowat_def_cred_upd_client()
1324 	if (fd < 0) {  in test_stream_rcvlowat_def_cred_upd_client()
1339 	recv_byte(fd, 1, 0);  in test_stream_rcvlowat_def_cred_upd_client()
1341 	if (send(fd, buf, buf_size, 0) != buf_size) {  in test_stream_rcvlowat_def_cred_upd_client()
1347 	close(fd);  in test_stream_rcvlowat_def_cred_upd_client()
1358 	int fd;  in test_stream_credit_update_test()  local
1360 	fd = vsock_stream_accept(VMADDR_CID_ANY, opts->peer_port, NULL);  in test_stream_credit_update_test()
1361 	if (fd < 0) {  in test_stream_credit_update_test()
1371 	setsockopt_ull_check(fd, AF_VSOCK, SO_VM_SOCKETS_BUFFER_SIZE,  in test_stream_credit_update_test()
1382 		setsockopt_int_check(fd, SOL_SOCKET, SO_RCVLOWAT,  in test_stream_credit_update_test()
1392 	send_byte(fd, 1, 0);  in test_stream_credit_update_test()
1404 		res = recv(fd, buf, buf_size, MSG_PEEK);  in test_stream_credit_update_test()
1419 	recv_buf(fd, buf, recv_buf_size, 0, recv_buf_size);  in test_stream_credit_update_test()
1425 		setsockopt_int_check(fd, SOL_SOCKET, SO_RCVLOWAT,  in test_stream_credit_update_test()
1429 	fds.fd = fd;  in test_stream_credit_update_test()
1447 		recv_buf(fd, buf, recv_buf_size, MSG_DONTWAIT, recv_buf_size);  in test_stream_credit_update_test()
1457 	close(fd);  in test_stream_credit_update_test()
1487 	int fd;  in test_stream_leak_acceptq_client()  local
1493 		fd = vsock_stream_connect(opts->peer_cid, opts->peer_port);  in test_stream_leak_acceptq_client()
1494 		if (fd >= 0)  in test_stream_leak_acceptq_client()
1495 			close(fd);  in test_stream_leak_acceptq_client()
1504 	int fd;  in test_stream_leak_acceptq_server()  local
1507 		fd = vsock_stream_listen(VMADDR_CID_ANY, opts->peer_port);  in test_stream_leak_acceptq_server()
1509 		close(fd);  in test_stream_leak_acceptq_server()
1517 	int fd;  in test_stream_msgzcopy_leak_errq_client()  local
1519 	fd = vsock_stream_connect(opts->peer_cid, opts->peer_port);  in test_stream_msgzcopy_leak_errq_client()
1520 	if (fd < 0) {  in test_stream_msgzcopy_leak_errq_client()
1525 	enable_so_zerocopy_check(fd);  in test_stream_msgzcopy_leak_errq_client()
1526 	send_byte(fd, 1, MSG_ZEROCOPY);  in test_stream_msgzcopy_leak_errq_client()
1528 	fds.fd = fd;  in test_stream_msgzcopy_leak_errq_client()
1535 	close(fd);  in test_stream_msgzcopy_leak_errq_client()
1540 	int fd;  in test_stream_msgzcopy_leak_errq_server()  local
1542 	fd = vsock_stream_accept(VMADDR_CID_ANY, opts->peer_port, NULL);  in test_stream_msgzcopy_leak_errq_server()
1543 	if (fd < 0) {  in test_stream_msgzcopy_leak_errq_server()
1548 	recv_byte(fd, 1, 0);  in test_stream_msgzcopy_leak_errq_server()
1549 	vsock_wait_remote_close(fd);  in test_stream_msgzcopy_leak_errq_server()
1550 	close(fd);  in test_stream_msgzcopy_leak_errq_server()
1608  *       int fd;
1611  *           fd = vsock_stream_accept(VMADDR_CID_ANY, opts->peer_port, NULL);
1612  *           vsock_wait_remote_close(fd);
1613  *           close(fd);
1629 	int fd, res;  in test_stream_msgzcopy_leak_zcskb_client()  local
1645 	fd = vsock_stream_connect(opts->peer_cid, opts->peer_port);  in test_stream_msgzcopy_leak_zcskb_client()
1646 	if (fd < 0) {  in test_stream_msgzcopy_leak_zcskb_client()
1651 	enable_so_zerocopy_check(fd);  in test_stream_msgzcopy_leak_zcskb_client()
1676 	res = sendmsg(fd, &msg, MSG_ZEROCOPY);  in test_stream_msgzcopy_leak_zcskb_client()
1683 	close(fd);  in test_stream_msgzcopy_leak_zcskb_client()
1688 	int fd;  in test_stream_msgzcopy_leak_zcskb_server()  local
1690 	fd = vsock_stream_accept(VMADDR_CID_ANY, opts->peer_port, NULL);  in test_stream_msgzcopy_leak_zcskb_server()
1691 	if (fd < 0) {  in test_stream_msgzcopy_leak_zcskb_server()
1696 	vsock_wait_remote_close(fd);  in test_stream_msgzcopy_leak_zcskb_server()
1697 	close(fd);  in test_stream_msgzcopy_leak_zcskb_server()
1709 	int fd, i, alen;  in test_stream_transport_uaf_client()  local
1711 	fd = vsock_bind(VMADDR_CID_ANY, VMADDR_PORT_ANY, SOCK_STREAM);  in test_stream_transport_uaf_client()
1714 	if (getsockname(fd, (struct sockaddr *)&addr, &alen)) {  in test_stream_transport_uaf_client()
1723 	close(fd);  in test_stream_transport_uaf_client()
1724 	fd = socket(AF_VSOCK, SOCK_STREAM, 0);  in test_stream_transport_uaf_client()
1725 	if (fd < 0) {  in test_stream_transport_uaf_client()
1730 	if (!vsock_connect_fd(fd, addr.svm_cid, addr.svm_port)) {  in test_stream_transport_uaf_client()
1736 	if (!vsock_connect_fd(fd, VMADDR_CID_HOST, VMADDR_PORT_ANY)) {  in test_stream_transport_uaf_client()
1741 	close(fd);  in test_stream_transport_uaf_client()
1755 	int fd;  in test_stream_connect_retry_client()  local
1757 	fd = socket(AF_VSOCK, SOCK_STREAM, 0);  in test_stream_connect_retry_client()
1758 	if (fd < 0) {  in test_stream_connect_retry_client()
1763 	if (!vsock_connect_fd(fd, opts->peer_cid, opts->peer_port)) {  in test_stream_connect_retry_client()
1771 	if (vsock_connect_fd(fd, opts->peer_cid, opts->peer_port)) {  in test_stream_connect_retry_client()
1776 	close(fd);  in test_stream_connect_retry_client()
1781 	int fd;  in test_stream_connect_retry_server()  local
1785 	fd = vsock_stream_accept(VMADDR_CID_ANY, opts->peer_port, NULL);  in test_stream_connect_retry_server()
1786 	if (fd < 0) {  in test_stream_connect_retry_server()
1791 	vsock_wait_remote_close(fd);  in test_stream_connect_retry_server()
1792 	close(fd);  in test_stream_connect_retry_server()
1801 	int fd;  in test_stream_linger_client()  local
1803 	fd = vsock_stream_connect(opts->peer_cid, opts->peer_port);  in test_stream_linger_client()
1804 	if (fd < 0) {  in test_stream_linger_client()
1809 	if (setsockopt(fd, SOL_SOCKET, SO_LINGER, &optval, sizeof(optval))) {  in test_stream_linger_client()
1814 	close(fd);  in test_stream_linger_client()
1819 	int fd;  in test_stream_linger_server()  local
1821 	fd = vsock_stream_accept(VMADDR_CID_ANY, opts->peer_port, NULL);  in test_stream_linger_server()
1822 	if (fd < 0) {  in test_stream_linger_server()
1827 	vsock_wait_remote_close(fd);  in test_stream_linger_server()
1828 	close(fd);  in test_stream_linger_server()