Lines Matching refs:fds
216 int fds[MULTICONN_NFDS]; in test_stream_multiconn_client() local
220 fds[i] = vsock_stream_connect(opts->peer_cid, opts->peer_port); in test_stream_multiconn_client()
221 if (fds[i] < 0) { in test_stream_multiconn_client()
229 recv_byte(fds[i], 1, 0); in test_stream_multiconn_client()
231 send_byte(fds[i], 1, 0); in test_stream_multiconn_client()
235 close(fds[i]); in test_stream_multiconn_client()
240 int fds[MULTICONN_NFDS]; in test_stream_multiconn_server() local
244 fds[i] = vsock_stream_accept(VMADDR_CID_ANY, opts->peer_port, NULL); in test_stream_multiconn_server()
245 if (fds[i] < 0) { in test_stream_multiconn_server()
253 send_byte(fds[i], 1, 0); in test_stream_multiconn_server()
255 recv_byte(fds[i], 1, 0); in test_stream_multiconn_server()
259 close(fds[i]); in test_stream_multiconn_server()
840 struct pollfd fds; in test_stream_poll_rcvlowat_client() local
859 fds.fd = fd; in test_stream_poll_rcvlowat_client()
861 fds.events = poll_flags; in test_stream_poll_rcvlowat_client()
864 if (poll(&fds, 1, 1000) < 0) { in test_stream_poll_rcvlowat_client()
870 if (fds.revents) { in test_stream_poll_rcvlowat_client()
872 fds.revents); in test_stream_poll_rcvlowat_client()
880 if (poll(&fds, 1, 10000) < 0) { in test_stream_poll_rcvlowat_client()
886 if (fds.revents != poll_flags) { in test_stream_poll_rcvlowat_client()
888 fds.revents); in test_stream_poll_rcvlowat_client()
1361 struct pollfd fds; in test_stream_credit_update_test() local
1440 fds.fd = fd; in test_stream_credit_update_test()
1441 fds.events = POLLIN | POLLRDNORM | POLLERR | in test_stream_credit_update_test()
1447 if (poll(&fds, 1, -1) < 0) { in test_stream_credit_update_test()
1452 if (fds.revents & POLLERR) { in test_stream_credit_update_test()
1457 if (fds.revents & (POLLIN | POLLRDNORM)) { in test_stream_credit_update_test()