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()
260 	int fd;  in test_stream_msg_peek_client()  local
262 	fd = vsock_stream_connect(opts->peer_cid, 1234);  in test_stream_msg_peek_client()
263 	if (fd < 0) {  in test_stream_msg_peek_client()
268 	send_byte(fd, 1, 0);  in test_stream_msg_peek_client()
269 	close(fd);  in test_stream_msg_peek_client()
274 	int fd;  in test_stream_msg_peek_server()  local
276 	fd = vsock_stream_accept(VMADDR_CID_ANY, 1234, NULL);  in test_stream_msg_peek_server()
277 	if (fd < 0) {  in test_stream_msg_peek_server()
282 	recv_byte(fd, 1, MSG_PEEK);  in test_stream_msg_peek_server()
283 	recv_byte(fd, 1, 0);  in test_stream_msg_peek_server()
284 	close(fd);  in test_stream_msg_peek_server()
291 	int fd;  in test_seqpacket_msg_bounds_client()  local
293 	fd = vsock_seqpacket_connect(opts->peer_cid, 1234);  in test_seqpacket_msg_bounds_client()
294 	if (fd < 0) {  in test_seqpacket_msg_bounds_client()
301 		send_byte(fd, 1, (i == MSG_EOR_IDX) ? MSG_EOR : 0);  in test_seqpacket_msg_bounds_client()
304 	close(fd);  in test_seqpacket_msg_bounds_client()
309 	int fd;  in test_seqpacket_msg_bounds_server()  local
314 	fd = vsock_seqpacket_accept(VMADDR_CID_ANY, 1234, NULL);  in test_seqpacket_msg_bounds_server()
315 	if (fd < 0) {  in test_seqpacket_msg_bounds_server()
327 		if (recvmsg(fd, &msg, 0) != 1) {  in test_seqpacket_msg_bounds_server()
338 	close(fd);  in test_seqpacket_msg_bounds_server()
344 	int fd;  in test_seqpacket_msg_trunc_client()  local
347 	fd = vsock_seqpacket_connect(opts->peer_cid, 1234);  in test_seqpacket_msg_trunc_client()
348 	if (fd < 0) {  in test_seqpacket_msg_trunc_client()
353 	if (send(fd, buf, sizeof(buf), 0) != sizeof(buf)) {  in test_seqpacket_msg_trunc_client()
359 	close(fd);  in test_seqpacket_msg_trunc_client()
364 	int fd;  in test_seqpacket_msg_trunc_server()  local
369 	fd = vsock_seqpacket_accept(VMADDR_CID_ANY, 1234, NULL);  in test_seqpacket_msg_trunc_server()
370 	if (fd < 0) {  in test_seqpacket_msg_trunc_server()
381 	ssize_t ret = recvmsg(fd, &msg, MSG_TRUNC);  in test_seqpacket_msg_trunc_server()
394 	close(fd);  in test_seqpacket_msg_trunc_server()
414 	int fd;  in test_seqpacket_timeout_client()  local
420 	fd = vsock_seqpacket_connect(opts->peer_cid, 1234);  in test_seqpacket_timeout_client()
421 	if (fd < 0) {  in test_seqpacket_timeout_client()
429 	if (setsockopt(fd, SOL_SOCKET, SO_RCVTIMEO, (void *)&tv, sizeof(tv)) == -1) {  in test_seqpacket_timeout_client()
436 	if (read(fd, &dummy, sizeof(dummy)) != -1) {  in test_seqpacket_timeout_client()
458 	close(fd);  in test_seqpacket_timeout_client()
463 	int fd;  in test_seqpacket_timeout_server()  local
465 	fd = vsock_seqpacket_accept(VMADDR_CID_ANY, 1234, NULL);  in test_seqpacket_timeout_server()
466 	if (fd < 0) {  in test_seqpacket_timeout_server()
472 	close(fd);  in test_seqpacket_timeout_server()
480 	int fd;  in test_seqpacket_invalid_rec_buffer_client()  local
485 	fd = vsock_seqpacket_connect(opts->peer_cid, 1234);  in test_seqpacket_invalid_rec_buffer_client()
486 	if (fd < 0) {  in test_seqpacket_invalid_rec_buffer_client()
506 	if (send(fd, buf1, buf_size, 0) != buf_size) {  in test_seqpacket_invalid_rec_buffer_client()
511 	if (send(fd, buf2, buf_size, 0) != buf_size) {  in test_seqpacket_invalid_rec_buffer_client()
516 	close(fd);  in test_seqpacket_invalid_rec_buffer_client()
521 	int fd;  in test_seqpacket_invalid_rec_buffer_server()  local
531 	fd = vsock_seqpacket_accept(VMADDR_CID_ANY, 1234, NULL);  in test_seqpacket_invalid_rec_buffer_server()
532 	if (fd < 0) {  in test_seqpacket_invalid_rec_buffer_server()
557 	res = read(fd, broken_buf, buf_size);  in test_seqpacket_invalid_rec_buffer_server()
571 	res = read(fd, valid_buf, buf_size);  in test_seqpacket_invalid_rec_buffer_server()
597 	close(fd);  in test_seqpacket_invalid_rec_buffer_server()
604 	int fd;  in test_stream_poll_rcvlowat_server()  local
607 	fd = vsock_stream_accept(VMADDR_CID_ANY, 1234, NULL);  in test_stream_poll_rcvlowat_server()
608 	if (fd < 0) {  in test_stream_poll_rcvlowat_server()
614 	send_byte(fd, 1, 0);  in test_stream_poll_rcvlowat_server()
622 		send_byte(fd, 1, 0);  in test_stream_poll_rcvlowat_server()
627 	close(fd);  in test_stream_poll_rcvlowat_server()
637 	int fd;  in test_stream_poll_rcvlowat_client()  local
639 	fd = vsock_stream_connect(opts->peer_cid, 1234);  in test_stream_poll_rcvlowat_client()
640 	if (fd < 0) {  in test_stream_poll_rcvlowat_client()
645 	if (setsockopt(fd, SOL_SOCKET, SO_RCVLOWAT,  in test_stream_poll_rcvlowat_client()
654 	fds.fd = fd;  in test_stream_poll_rcvlowat_client()
690 	read_res = recv(fd, buf, sizeof(buf), MSG_DONTWAIT);  in test_stream_poll_rcvlowat_client()
699 	close(fd);  in test_stream_poll_rcvlowat_client()