Lines Matching refs:fds
208 int fds[MULTICONN_NFDS]; in test_stream_multiconn_client() local
212 fds[i] = vsock_stream_connect(opts->peer_cid, opts->peer_port); in test_stream_multiconn_client()
213 if (fds[i] < 0) { in test_stream_multiconn_client()
221 recv_byte(fds[i], 1, 0); in test_stream_multiconn_client()
223 send_byte(fds[i], 1, 0); in test_stream_multiconn_client()
227 close(fds[i]); in test_stream_multiconn_client()
232 int fds[MULTICONN_NFDS]; in test_stream_multiconn_server() local
236 fds[i] = vsock_stream_accept(VMADDR_CID_ANY, opts->peer_port, NULL); in test_stream_multiconn_server()
237 if (fds[i] < 0) { in test_stream_multiconn_server()
245 send_byte(fds[i], 1, 0); in test_stream_multiconn_server()
247 recv_byte(fds[i], 1, 0); in test_stream_multiconn_server()
251 close(fds[i]); in test_stream_multiconn_server()
834 struct pollfd fds; in test_stream_poll_rcvlowat_client() local
850 fds.fd = fd; in test_stream_poll_rcvlowat_client()
852 fds.events = poll_flags; in test_stream_poll_rcvlowat_client()
855 if (poll(&fds, 1, 1000) < 0) { in test_stream_poll_rcvlowat_client()
861 if (fds.revents) { in test_stream_poll_rcvlowat_client()
863 fds.revents); in test_stream_poll_rcvlowat_client()
871 if (poll(&fds, 1, 10000) < 0) { in test_stream_poll_rcvlowat_client()
877 if (fds.revents != poll_flags) { in test_stream_poll_rcvlowat_client()
879 fds.revents); in test_stream_poll_rcvlowat_client()
1444 struct pollfd fds; in test_stream_credit_update_test() local
1519 fds.fd = fd; in test_stream_credit_update_test()
1520 fds.events = POLLIN | POLLRDNORM | POLLERR | in test_stream_credit_update_test()
1526 if (poll(&fds, 1, -1) < 0) { in test_stream_credit_update_test()
1531 if (fds.revents & POLLERR) { in test_stream_credit_update_test()
1536 if (fds.revents & (POLLIN | POLLRDNORM)) { in test_stream_credit_update_test()
1606 struct pollfd fds = { 0 }; in test_stream_msgzcopy_leak_errq_client() local
1618 fds.fd = fd; in test_stream_msgzcopy_leak_errq_client()
1619 fds.events = 0; in test_stream_msgzcopy_leak_errq_client()
1620 if (poll(&fds, 1, -1) < 0) { in test_stream_msgzcopy_leak_errq_client()