40 	int fd;  in test_stream_connection_reset()  local
42 	fd = socket(AF_VSOCK, SOCK_STREAM, 0);  in test_stream_connection_reset()
46 		ret = connect(fd, &addr.sa, sizeof(addr.svm));  in test_stream_connection_reset()
60 	close(fd);  in test_stream_connection_reset()
76 	int fd;  in test_stream_bind_only_client()  local
81 	fd = socket(AF_VSOCK, SOCK_STREAM, 0);  in test_stream_bind_only_client()
85 		ret = connect(fd, &addr.sa, sizeof(addr.svm));  in test_stream_bind_only_client()
102 	close(fd);  in test_stream_bind_only_client()
117 	int fd;  in test_stream_bind_only_server()  local
119 	fd = socket(AF_VSOCK, SOCK_STREAM, 0);  in test_stream_bind_only_server()
121 	if (bind(fd, &addr.sa, sizeof(addr.svm)) < 0) {  in test_stream_bind_only_server()
132 	close(fd);  in test_stream_bind_only_server()
137 	int fd;  in test_stream_client_close_client()  local
139 	fd = vsock_stream_connect(opts->peer_cid, 1234);  in test_stream_client_close_client()
140 	if (fd < 0) {  in test_stream_client_close_client()
145 	send_byte(fd, 1, 0);  in test_stream_client_close_client()
146 	close(fd);  in test_stream_client_close_client()
151 	int fd;  in test_stream_client_close_server()  local
153 	fd = vsock_stream_accept(VMADDR_CID_ANY, 1234, NULL);  in test_stream_client_close_server()
154 	if (fd < 0) {  in test_stream_client_close_server()
162 	vsock_wait_remote_close(fd);  in test_stream_client_close_server()
164 	send_byte(fd, -EPIPE, 0);  in test_stream_client_close_server()
165 	recv_byte(fd, 1, 0);  in test_stream_client_close_server()
166 	recv_byte(fd, 0, 0);  in test_stream_client_close_server()
167 	close(fd);  in test_stream_client_close_server()
172 	int fd;  in test_stream_server_close_client()  local
174 	fd = vsock_stream_connect(opts->peer_cid, 1234);  in test_stream_server_close_client()
175 	if (fd < 0) {  in test_stream_server_close_client()
183 	vsock_wait_remote_close(fd);  in test_stream_server_close_client()
185 	send_byte(fd, -EPIPE, 0);  in test_stream_server_close_client()
186 	recv_byte(fd, 1, 0);  in test_stream_server_close_client()
187 	recv_byte(fd, 0, 0);  in test_stream_server_close_client()
188 	close(fd);  in test_stream_server_close_client()
193 	int fd;  in test_stream_server_close_server()  local
195 	fd = vsock_stream_accept(VMADDR_CID_ANY, 1234, NULL);  in test_stream_server_close_server()
196 	if (fd < 0) {  in test_stream_server_close_server()
201 	send_byte(fd, 1, 0);  in test_stream_server_close_server()
202 	close(fd);  in test_stream_server_close_server()
265 	int fd;  in test_msg_peek_client()  local
269 		fd = vsock_seqpacket_connect(opts->peer_cid, 1234);  in test_msg_peek_client()
271 		fd = vsock_stream_connect(opts->peer_cid, 1234);  in test_msg_peek_client()
273 	if (fd < 0) {  in test_msg_peek_client()
283 	send_size = send(fd, buf, sizeof(buf), 0);  in test_msg_peek_client()
295 	close(fd);  in test_msg_peek_client()
305 	int fd;  in test_msg_peek_server()  local
308 		fd = vsock_seqpacket_accept(VMADDR_CID_ANY, 1234, NULL);  in test_msg_peek_server()
310 		fd = vsock_stream_accept(VMADDR_CID_ANY, 1234, NULL);  in test_msg_peek_server()
312 	if (fd < 0) {  in test_msg_peek_server()
318 	res = recv(fd, buf_peek, sizeof(buf_peek), MSG_PEEK | MSG_DONTWAIT);  in test_msg_peek_server()
332 	res = recv(fd, buf_half, sizeof(buf_half), MSG_PEEK);  in test_msg_peek_server()
340 	res = recv(fd, buf_peek, sizeof(buf_peek), MSG_PEEK);  in test_msg_peek_server()
358 		res = recv(fd, buf_half, sizeof(buf_half), MSG_PEEK |  in test_msg_peek_server()
368 	res = recv(fd, buf_normal, sizeof(buf_normal), 0);  in test_msg_peek_server()
381 	close(fd);  in test_msg_peek_server()
402 	int fd;  in test_seqpacket_msg_bounds_client()  local
404 	fd = vsock_seqpacket_connect(opts->peer_cid, 1234);  in test_seqpacket_msg_bounds_client()
405 	if (fd < 0) {  in test_seqpacket_msg_bounds_client()
446 		send_size = send(fd, buf, buf_size, flags);  in test_seqpacket_msg_bounds_client()
473 	close(fd);  in test_seqpacket_msg_bounds_client()
481 	int fd;  in test_seqpacket_msg_bounds_server()  local
486 	fd = vsock_seqpacket_accept(VMADDR_CID_ANY, 1234, NULL);  in test_seqpacket_msg_bounds_server()
487 	if (fd < 0) {  in test_seqpacket_msg_bounds_server()
494 	if (setsockopt(fd, AF_VSOCK, SO_VM_SOCKETS_BUFFER_MAX_SIZE,  in test_seqpacket_msg_bounds_server()
500 	if (setsockopt(fd, AF_VSOCK, SO_VM_SOCKETS_BUFFER_SIZE,  in test_seqpacket_msg_bounds_server()
520 		recv_size = recvmsg(fd, &msg, 0);  in test_seqpacket_msg_bounds_server()
536 	close(fd);  in test_seqpacket_msg_bounds_server()
548 	int fd;  in test_seqpacket_msg_trunc_client()  local
551 	fd = vsock_seqpacket_connect(opts->peer_cid, 1234);  in test_seqpacket_msg_trunc_client()
552 	if (fd < 0) {  in test_seqpacket_msg_trunc_client()
557 	if (send(fd, buf, sizeof(buf), 0) != sizeof(buf)) {  in test_seqpacket_msg_trunc_client()
563 	close(fd);  in test_seqpacket_msg_trunc_client()
568 	int fd;  in test_seqpacket_msg_trunc_server()  local
573 	fd = vsock_seqpacket_accept(VMADDR_CID_ANY, 1234, NULL);  in test_seqpacket_msg_trunc_server()
574 	if (fd < 0) {  in test_seqpacket_msg_trunc_server()
585 	ssize_t ret = recvmsg(fd, &msg, MSG_TRUNC);  in test_seqpacket_msg_trunc_server()
598 	close(fd);  in test_seqpacket_msg_trunc_server()
618 	int fd;  in test_seqpacket_timeout_client()  local
624 	fd = vsock_seqpacket_connect(opts->peer_cid, 1234);  in test_seqpacket_timeout_client()
625 	if (fd < 0) {  in test_seqpacket_timeout_client()
633 	if (setsockopt(fd, SOL_SOCKET, SO_RCVTIMEO, (void *)&tv, sizeof(tv)) == -1) {  in test_seqpacket_timeout_client()
640 	if (read(fd, &dummy, sizeof(dummy)) != -1) {  in test_seqpacket_timeout_client()
662 	close(fd);  in test_seqpacket_timeout_client()
667 	int fd;  in test_seqpacket_timeout_server()  local
669 	fd = vsock_seqpacket_accept(VMADDR_CID_ANY, 1234, NULL);  in test_seqpacket_timeout_server()
670 	if (fd < 0) {  in test_seqpacket_timeout_server()
676 	close(fd);  in test_seqpacket_timeout_server()
685 	int fd;  in test_seqpacket_bigmsg_client()  local
689 	fd = vsock_seqpacket_connect(opts->peer_cid, 1234);  in test_seqpacket_bigmsg_client()
690 	if (fd < 0) {  in test_seqpacket_bigmsg_client()
695 	if (getsockopt(fd, AF_VSOCK, SO_VM_SOCKETS_BUFFER_SIZE,  in test_seqpacket_bigmsg_client()
709 	send_size = send(fd, data, sock_buf_size, 0);  in test_seqpacket_bigmsg_client()
725 	close(fd);  in test_seqpacket_bigmsg_client()
730 	int fd;  in test_seqpacket_bigmsg_server()  local
732 	fd = vsock_seqpacket_accept(VMADDR_CID_ANY, 1234, NULL);  in test_seqpacket_bigmsg_server()
733 	if (fd < 0) {  in test_seqpacket_bigmsg_server()
740 	close(fd);  in test_seqpacket_bigmsg_server()
748 	int fd;  in test_seqpacket_invalid_rec_buffer_client()  local
753 	fd = vsock_seqpacket_connect(opts->peer_cid, 1234);  in test_seqpacket_invalid_rec_buffer_client()
754 	if (fd < 0) {  in test_seqpacket_invalid_rec_buffer_client()
774 	if (send(fd, buf1, buf_size, 0) != buf_size) {  in test_seqpacket_invalid_rec_buffer_client()
779 	if (send(fd, buf2, buf_size, 0) != buf_size) {  in test_seqpacket_invalid_rec_buffer_client()
784 	close(fd);  in test_seqpacket_invalid_rec_buffer_client()
789 	int fd;  in test_seqpacket_invalid_rec_buffer_server()  local
799 	fd = vsock_seqpacket_accept(VMADDR_CID_ANY, 1234, NULL);  in test_seqpacket_invalid_rec_buffer_server()
800 	if (fd < 0) {  in test_seqpacket_invalid_rec_buffer_server()
825 	res = read(fd, broken_buf, buf_size);  in test_seqpacket_invalid_rec_buffer_server()
839 	res = read(fd, valid_buf, buf_size);  in test_seqpacket_invalid_rec_buffer_server()
865 	close(fd);  in test_seqpacket_invalid_rec_buffer_server()
872 	int fd;  in test_stream_poll_rcvlowat_server()  local
875 	fd = vsock_stream_accept(VMADDR_CID_ANY, 1234, NULL);  in test_stream_poll_rcvlowat_server()
876 	if (fd < 0) {  in test_stream_poll_rcvlowat_server()
882 	send_byte(fd, 1, 0);  in test_stream_poll_rcvlowat_server()
890 		send_byte(fd, 1, 0);  in test_stream_poll_rcvlowat_server()
895 	close(fd);  in test_stream_poll_rcvlowat_server()
905 	int fd;  in test_stream_poll_rcvlowat_client()  local
907 	fd = vsock_stream_connect(opts->peer_cid, 1234);  in test_stream_poll_rcvlowat_client()
908 	if (fd < 0) {  in test_stream_poll_rcvlowat_client()
913 	if (setsockopt(fd, SOL_SOCKET, SO_RCVLOWAT,  in test_stream_poll_rcvlowat_client()
922 	fds.fd = fd;  in test_stream_poll_rcvlowat_client()
958 	read_res = recv(fd, buf, sizeof(buf), MSG_DONTWAIT);  in test_stream_poll_rcvlowat_client()
967 	close(fd);  in test_stream_poll_rcvlowat_client()
976 	int fd;  in test_inv_buf_client()  local
979 		fd = vsock_stream_connect(opts->peer_cid, 1234);  in test_inv_buf_client()
981 		fd = vsock_seqpacket_connect(opts->peer_cid, 1234);  in test_inv_buf_client()
983 	if (fd < 0) {  in test_inv_buf_client()
991 	ret = recv(fd, NULL, sizeof(data), 0);  in test_inv_buf_client()
1002 	ret = recv(fd, data, sizeof(data), MSG_DONTWAIT);  in test_inv_buf_client()
1026 	close(fd);  in test_inv_buf_client()
1033 	int fd;  in test_inv_buf_server()  local
1036 		fd = vsock_stream_accept(VMADDR_CID_ANY, 1234, NULL);  in test_inv_buf_server()
1038 		fd = vsock_seqpacket_accept(VMADDR_CID_ANY, 1234, NULL);  in test_inv_buf_server()
1040 	if (fd < 0) {  in test_inv_buf_server()
1045 	res = send(fd, data, sizeof(data), 0);  in test_inv_buf_server()
1055 	close(fd);  in test_inv_buf_server()
1084 	int fd;  in test_stream_virtio_skb_merge_client()  local
1086 	fd = vsock_stream_connect(opts->peer_cid, 1234);  in test_stream_virtio_skb_merge_client()
1087 	if (fd < 0) {  in test_stream_virtio_skb_merge_client()
1093 	res = send(fd, HELLO_STR, strlen(HELLO_STR), 0);  in test_stream_virtio_skb_merge_client()
1104 	res = send(fd, WORLD_STR, strlen(WORLD_STR), 0);  in test_stream_virtio_skb_merge_client()
1114 	close(fd);  in test_stream_virtio_skb_merge_client()
1121 	int fd;  in test_stream_virtio_skb_merge_server()  local
1123 	fd = vsock_stream_accept(VMADDR_CID_ANY, 1234, NULL);  in test_stream_virtio_skb_merge_server()
1124 	if (fd < 0) {  in test_stream_virtio_skb_merge_server()
1132 	res = recv(fd, buf, 2, 0);  in test_stream_virtio_skb_merge_server()
1141 	res = recv(fd, buf + 2, sizeof(buf) - 2, 0);  in test_stream_virtio_skb_merge_server()
1147 	res = recv(fd, buf, sizeof(buf) - 8 - 2, MSG_DONTWAIT);  in test_stream_virtio_skb_merge_server()
1160 	close(fd);  in test_stream_virtio_skb_merge_server()