Lines Matching refs:fd
37 int fd; in test_stream_connection_reset() local
39 fd = socket(AF_VSOCK, SOCK_STREAM, 0); in test_stream_connection_reset()
43 ret = connect(fd, &addr.sa, sizeof(addr.svm)); in test_stream_connection_reset()
57 close(fd); in test_stream_connection_reset()
73 int fd; in test_stream_bind_only_client() local
78 fd = socket(AF_VSOCK, SOCK_STREAM, 0); in test_stream_bind_only_client()
82 ret = connect(fd, &addr.sa, sizeof(addr.svm)); in test_stream_bind_only_client()
99 close(fd); in test_stream_bind_only_client()
114 int fd; in test_stream_bind_only_server() local
116 fd = socket(AF_VSOCK, SOCK_STREAM, 0); in test_stream_bind_only_server()
118 if (bind(fd, &addr.sa, sizeof(addr.svm)) < 0) { in test_stream_bind_only_server()
129 close(fd); in test_stream_bind_only_server()
134 int fd; in test_stream_client_close_client() local
136 fd = vsock_stream_connect(opts->peer_cid, 1234); in test_stream_client_close_client()
137 if (fd < 0) { in test_stream_client_close_client()
142 send_byte(fd, 1, 0); in test_stream_client_close_client()
143 close(fd); in test_stream_client_close_client()
148 int fd; in test_stream_client_close_server() local
150 fd = vsock_stream_accept(VMADDR_CID_ANY, 1234, NULL); in test_stream_client_close_server()
151 if (fd < 0) { in test_stream_client_close_server()
159 vsock_wait_remote_close(fd); in test_stream_client_close_server()
161 send_byte(fd, -EPIPE, 0); in test_stream_client_close_server()
162 recv_byte(fd, 1, 0); in test_stream_client_close_server()
163 recv_byte(fd, 0, 0); in test_stream_client_close_server()
164 close(fd); in test_stream_client_close_server()
169 int fd; in test_stream_server_close_client() local
171 fd = vsock_stream_connect(opts->peer_cid, 1234); in test_stream_server_close_client()
172 if (fd < 0) { in test_stream_server_close_client()
180 vsock_wait_remote_close(fd); in test_stream_server_close_client()
182 send_byte(fd, -EPIPE, 0); in test_stream_server_close_client()
183 recv_byte(fd, 1, 0); in test_stream_server_close_client()
184 recv_byte(fd, 0, 0); in test_stream_server_close_client()
185 close(fd); in test_stream_server_close_client()
190 int fd; in test_stream_server_close_server() local
192 fd = vsock_stream_accept(VMADDR_CID_ANY, 1234, NULL); in test_stream_server_close_server()
193 if (fd < 0) { in test_stream_server_close_server()
198 send_byte(fd, 1, 0); in test_stream_server_close_server()
199 close(fd); in test_stream_server_close_server()
257 int fd; in test_stream_msg_peek_client() local
259 fd = vsock_stream_connect(opts->peer_cid, 1234); in test_stream_msg_peek_client()
260 if (fd < 0) { in test_stream_msg_peek_client()
265 send_byte(fd, 1, 0); in test_stream_msg_peek_client()
266 close(fd); in test_stream_msg_peek_client()
271 int fd; in test_stream_msg_peek_server() local
273 fd = vsock_stream_accept(VMADDR_CID_ANY, 1234, NULL); in test_stream_msg_peek_server()
274 if (fd < 0) { in test_stream_msg_peek_server()
279 recv_byte(fd, 1, MSG_PEEK); in test_stream_msg_peek_server()
280 recv_byte(fd, 1, 0); in test_stream_msg_peek_server()
281 close(fd); in test_stream_msg_peek_server()
288 int fd; in test_seqpacket_msg_bounds_client() local
290 fd = vsock_seqpacket_connect(opts->peer_cid, 1234); in test_seqpacket_msg_bounds_client()
291 if (fd < 0) { in test_seqpacket_msg_bounds_client()
298 send_byte(fd, 1, (i == MSG_EOR_IDX) ? MSG_EOR : 0); in test_seqpacket_msg_bounds_client()
301 close(fd); in test_seqpacket_msg_bounds_client()
306 int fd; in test_seqpacket_msg_bounds_server() local
311 fd = vsock_seqpacket_accept(VMADDR_CID_ANY, 1234, NULL); in test_seqpacket_msg_bounds_server()
312 if (fd < 0) { in test_seqpacket_msg_bounds_server()
324 if (recvmsg(fd, &msg, 0) != 1) { in test_seqpacket_msg_bounds_server()
335 close(fd); in test_seqpacket_msg_bounds_server()
341 int fd; in test_seqpacket_msg_trunc_client() local
344 fd = vsock_seqpacket_connect(opts->peer_cid, 1234); in test_seqpacket_msg_trunc_client()
345 if (fd < 0) { in test_seqpacket_msg_trunc_client()
350 if (send(fd, buf, sizeof(buf), 0) != sizeof(buf)) { in test_seqpacket_msg_trunc_client()
356 close(fd); in test_seqpacket_msg_trunc_client()
361 int fd; in test_seqpacket_msg_trunc_server() local
366 fd = vsock_seqpacket_accept(VMADDR_CID_ANY, 1234, NULL); in test_seqpacket_msg_trunc_server()
367 if (fd < 0) { in test_seqpacket_msg_trunc_server()
378 ssize_t ret = recvmsg(fd, &msg, MSG_TRUNC); in test_seqpacket_msg_trunc_server()
391 close(fd); in test_seqpacket_msg_trunc_server()