Home
last modified time | relevance | path

Searched refs:fds (Results 1 – 25 of 74) sorted by relevance

123

/qemu/hw/remote/
H A Dmpqemu-link.c39 int *fds = NULL; in mpqemu_msg_send() local
51 fds = msg->fds; in mpqemu_msg_send()
71 fds, nfds, 0, errp)) { in mpqemu_msg_send()
95 static ssize_t mpqemu_read(QIOChannel *ioc, void *buf, size_t len, int **fds, in mpqemu_read() argument
113 ret = qio_channel_readv_full_all_eof(ioc, &iov, 1, fds, nfds, errp); in mpqemu_read()
125 g_autofree int *fds = NULL; in mpqemu_msg_recv() local
130 len = mpqemu_read(ioc, msg, MPQEMU_MSG_HDR_SIZE, &fds, &nfds, errp); in mpqemu_msg_recv()
158 if (nfds > G_N_ELEMENTS(msg->fds)) { in mpqemu_msg_recv()
165 memcpy(msg->fds, fds, nfds * sizeof(int)); in mpqemu_msg_recv()
175 close(fds[nfds - 1]); in mpqemu_msg_recv()
[all …]
H A Diohub.c109 event_notifier_init_fd(&iohub->irqfds[pirq], msg->fds[0]); in process_set_irqfd_msg()
110 event_notifier_init_fd(&iohub->resamplefds[pirq], msg->fds[1]); in process_set_irqfd_msg()
115 qemu_set_fd_handler(msg->fds[1], intr_resample_handler, NULL, in process_set_irqfd_msg()
/qemu/util/
H A Devent_notifier-posix.c37 int fds[2]; in event_notifier_init() local
52 if (!g_unix_open_pipe(fds, FD_CLOEXEC, NULL)) { in event_notifier_init()
55 if (!g_unix_set_fd_nonblocking(fds[0], true, NULL)) { in event_notifier_init()
59 if (!g_unix_set_fd_nonblocking(fds[1], true, NULL)) { in event_notifier_init()
63 e->rfd = fds[0]; in event_notifier_init()
64 e->wfd = fds[1]; in event_notifier_init()
73 close(fds[0]); in event_notifier_init()
74 close(fds[1]); in event_notifier_init()
H A Dcompatfd.c59 int fds[2]; in qemu_signalfd_compat() local
63 if (!g_unix_open_pipe(fds, FD_CLOEXEC, NULL)) { in qemu_signalfd_compat()
69 info->fd = fds[1]; in qemu_signalfd_compat()
74 return fds[0]; in qemu_signalfd_compat()
H A Dvhost-user-server.c61 close(vmsg->fds[i]); in vmsg_close_fds()
69 qemu_socket_set_nonblock(vmsg->fds[i]); in vmsg_unblock_fds()
107 const size_t max_fds = G_N_ELEMENTS(vmsg->fds); in vu_message_read()
120 int *fds = NULL; in vu_message_read() local
126 rc = qio_channel_readv_full(ioc, &iov, 1, &fds, &nfds, 0, &local_err); in vu_message_read()
149 g_free(fds); in vu_message_read()
152 memcpy(vmsg->fds + vmsg->fd_num, fds, nfds * sizeof(vmsg->fds[0])); in vu_message_read()
154 g_free(fds); in vu_message_read()
/qemu/contrib/ivshmem-client/
H A Dmain.c135 fd_set fds; in ivshmem_client_poll_events() local
140 FD_ZERO(&fds); in ivshmem_client_poll_events()
141 FD_SET(0, &fds); /* add stdin in fd_set */ in ivshmem_client_poll_events()
144 ivshmem_client_get_fds(client, &fds, &maxfd); in ivshmem_client_poll_events()
146 ret = select(maxfd, &fds, NULL, NULL, NULL); in ivshmem_client_poll_events()
159 if (FD_ISSET(0, &fds) && in ivshmem_client_poll_events()
165 if (ivshmem_client_handle_fds(client, &fds, maxfd) < 0) { in ivshmem_client_poll_events()
H A Divshmem-client.c272 ivshmem_client_get_fds(const IvshmemClient *client, fd_set *fds, int *maxfd) in ivshmem_client_get_fds() argument
277 FD_SET(client->sock_fd, fds); in ivshmem_client_get_fds()
284 FD_SET(fd, fds); in ivshmem_client_get_fds()
328 ivshmem_client_handle_fds(IvshmemClient *client, fd_set *fds, int maxfd) in ivshmem_client_handle_fds() argument
330 if (client->sock_fd < maxfd && FD_ISSET(client->sock_fd, fds) && in ivshmem_client_handle_fds()
335 } else if (ivshmem_client_handle_event(client, fds, maxfd) < 0 && in ivshmem_client_handle_fds()
H A Divshmem-client.h133 void ivshmem_client_get_fds(const IvshmemClient *client, fd_set *fds,
150 int ivshmem_client_handle_fds(IvshmemClient *client, fd_set *fds, int maxfd);
/qemu/tests/tcg/multiarch/linux/
H A Dlinux-test.c333 int fds[2], fd_max, ret; in test_pipe() local
337 chk_error(pipe(fds)); in test_pipe()
344 fd_max = fds[0]; in test_pipe()
345 FD_SET(fds[0], &rfds); in test_pipe()
348 FD_SET(fds[1], &wfds); in test_pipe()
349 if (fds[1] > fd_max) in test_pipe()
350 fd_max = fds[1]; in test_pipe()
354 if (FD_ISSET(fds[0], &rfds)) { in test_pipe()
361 if (FD_ISSET(fds[1], &wfds)) { in test_pipe()
371 chk_error(close(fds[0])); in test_pipe()
[all …]
/qemu/tests/qtest/
H A Dlibqmp.c99 static void socket_send_fds(int socket_fd, int *fds, size_t fds_num, in socket_send_fds() argument
112 if (fds && fds_num > 0) { in socket_send_fds()
122 memcpy(CMSG_DATA(cmsg), fds, fdsize); in socket_send_fds()
138 _qmp_fd_vsend_fds(int fd, int *fds, size_t fds_num, in _qmp_fd_vsend_fds() argument
167 if (fds && fds_num > 0) { in _qmp_fd_vsend_fds()
168 socket_send_fds(fd, fds, fds_num, str->str, str->len); in _qmp_fd_vsend_fds()
181 void qmp_fd_vsend_fds(int fd, int *fds, size_t fds_num, in qmp_fd_vsend_fds() argument
184 _qmp_fd_vsend_fds(fd, fds, fds_num, fmt, ap); in qmp_fd_vsend_fds()
H A Dlibqtest.h131 QDict *qtest_qmp_fds(QTestState *s, int *fds, size_t fds_num,
192 QDict *qtest_vqmp_fds(QTestState *s, int *fds, size_t fds_num,
223 void qtest_qmp_vsend_fds(QTestState *s, int *fds, size_t fds_num,
804 QDict *qtest_vqmp_fds_assert_success_ref(QTestState *qts, int *fds, size_t nfds,
821 void qtest_vqmp_fds_assert_success(QTestState *qts, int *fds, size_t nfds,
894 QDict *qtest_qmp_fds_assert_success_ref(QTestState *qts, int *fds, size_t nfds,
910 void qtest_qmp_fds_assert_success(QTestState *qts, int *fds, size_t nfds,
H A Divshmem-test.c256 fd_set fds; in server_thread() local
259 FD_ZERO(&fds); in server_thread()
260 FD_SET(t->pipe[0], &fds); in server_thread()
263 ivshmem_server_get_fds(server, &fds, &maxfd); in server_thread()
265 ret = select(maxfd, &fds, NULL, NULL, NULL); in server_thread()
279 if (FD_ISSET(t->pipe[0], &fds)) { in server_thread()
283 if (ivshmem_server_handle_fds(server, &fds, maxfd) < 0) { in server_thread()
/qemu/io/
H A Dchannel.c54 int **fds, in qio_channel_readv_full() argument
61 if ((fds || nfds) && in qio_channel_readv_full()
89 if (fds || nfds) { in qio_channel_writev_full()
139 int **local_fds = fds; in qio_channel_readv_full_all_eof()
147 if (fds) { in qio_channel_readv_full_all_eof()
148 *fds = NULL; in qio_channel_readv_full_all_eof()
190 if (nfds && fds) { in qio_channel_readv_full_all_eof()
193 close((*fds)[i]); in qio_channel_readv_full_all_eof()
195 g_free(*fds); in qio_channel_readv_full_all_eof()
196 *fds = NULL; in qio_channel_readv_full_all_eof()
[all …]
H A Dchannel-socket.c461 *fds = NULL; in qio_channel_socket_copy_fds()
480 *fds = g_renew(int, *fds, *nfds + gotfds); in qio_channel_socket_copy_fds()
484 int fd = (*fds)[*nfds + i]; in qio_channel_socket_copy_fds()
504 int **fds, in qio_channel_socket_readv() argument
519 if (fds && nfds) { in qio_channel_socket_readv()
547 if (fds && nfds) { in qio_channel_socket_readv()
548 qio_channel_socket_copy_fds(&msg, fds, nfds); in qio_channel_socket_readv()
557 int *fds, in qio_channel_socket_writev() argument
590 memcpy(CMSG_DATA(cmsg), fds, fdsize); in qio_channel_socket_writev()
637 int **fds, in qio_channel_socket_readv() argument
[all …]
/qemu/monitor/
H A Dfds.c55 QLIST_HEAD(, MonFdsetFd) fds;
77 QLIST_FOREACH(monfd, &mon->fds, next) { in monitor_add_fd()
96 QLIST_INSERT_HEAD(&mon->fds, monfd, next); in monitor_add_fd()
124 QLIST_FOREACH(monfd, &cur_mon->fds, next) { in qmp_closefd()
148 QLIST_FOREACH(monfd, &mon->fds, next) { in monitor_get_fd()
186 if (QLIST_EMPTY(&mon_fdset->fds) && QLIST_EMPTY(&mon_fdset->dup_fds)) { in monitor_fdset_cleanup()
274 QLIST_FOREACH(mon_fdset_fd, &mon_fdset->fds, next) { in qmp_remove_fd()
314 QLIST_FOREACH(mon_fdset_fd, &mon_fdset->fds, next) { in qmp_query_fdsets()
321 QAPI_LIST_PREPEND(fdset_info->fds, fdsetfd_info); in qmp_query_fdsets()
400 QLIST_INSERT_HEAD(&mon_fdset->fds, mon_fdset_fd, next); in monitor_fdset_add_fd()
[all …]
/qemu/
H A Dos-posix.c216 int fds[2]; in os_daemonize() local
218 if (!g_unix_open_pipe(fds, FD_CLOEXEC, NULL)) { in os_daemonize()
227 close(fds[1]); in os_daemonize()
230 len = read(fds[0], &status, 1); in os_daemonize()
241 close(fds[0]); in os_daemonize()
242 daemon_pipe = fds[1]; in os_daemonize()
/qemu/include/hw/block/
H A Dfdc.h12 void isa_fdc_init_drives(ISADevice *fdc, DriveInfo **fds);
13 void fdctrl_init_sysbus(qemu_irq irq, hwaddr mmio_base, DriveInfo **fds);
15 DriveInfo **fds, qemu_irq *fdc_tc);
/qemu/contrib/ivshmem-server/
H A Dmain.c149 fd_set fds; in ivshmem_server_poll_events() local
154 FD_ZERO(&fds); in ivshmem_server_poll_events()
156 ivshmem_server_get_fds(server, &fds, &maxfd); in ivshmem_server_poll_events()
158 ret = select(maxfd, &fds, NULL, NULL, NULL); in ivshmem_server_poll_events()
172 if (ivshmem_server_handle_fds(server, &fds, maxfd) < 0) { in ivshmem_server_poll_events()
H A Divshmem-server.c387 ivshmem_server_get_fds(const IvshmemServer *server, fd_set *fds, int *maxfd) in ivshmem_server_get_fds() argument
395 FD_SET(server->sock_fd, fds); in ivshmem_server_get_fds()
401 FD_SET(peer->sock_fd, fds); in ivshmem_server_get_fds()
410 ivshmem_server_handle_fds(IvshmemServer *server, fd_set *fds, int maxfd) in ivshmem_server_handle_fds() argument
414 if (server->sock_fd < maxfd && FD_ISSET(server->sock_fd, fds) && in ivshmem_server_handle_fds()
424 if (peer->sock_fd < maxfd && FD_ISSET(peer->sock_fd, fds)) { in ivshmem_server_handle_fds()
H A Divshmem-server.h128 ivshmem_server_get_fds(const IvshmemServer *server, fd_set *fds, int *maxfd);
143 int ivshmem_server_handle_fds(IvshmemServer *server, fd_set *fds, int maxfd);
/qemu/include/io/
H A Dchannel.h114 int *fds,
121 int **fds,
244 int **fds,
288 int *fds,
902 int **fds, size_t *nfds,
928 int **fds, size_t *nfds,
962 int *fds, size_t nfds,
/qemu/net/
H A Dtap.c716 if (tap->fd || tap->fds) { in net_init_tap_one()
786 static int get_fds(char *str, char *fds[], int max) in get_fds() argument
796 fds[i] = g_strdup(ptr); in get_fds()
798 fds[i] = g_strndup(ptr, this - ptr); in get_fds()
842 tap->fds || tap->vhostfds) { in net_init_tap()
875 } else if (tap->fds) { in net_init_tap()
876 char **fds; in net_init_tap() local
889 fds = g_new0(char *, MAX_TAP_QUEUES); in net_init_tap()
892 nfds = get_fds(tap->fds, fds, MAX_TAP_QUEUES); in net_init_tap()
946 g_free(fds[i]); in net_init_tap()
[all …]
/qemu/hw/block/
H A Dfdc-sysbus.c99 void fdctrl_init_sysbus(qemu_irq irq, hwaddr mmio_base, DriveInfo **fds) in fdctrl_init_sysbus() argument
112 fdctrl_init_drives(&sys->state.bus, fds); in fdctrl_init_sysbus()
116 DriveInfo **fds, qemu_irq *fdc_tc) in sun4m_fdctrl_init() argument
128 fdctrl_init_drives(&sys->state.bus, fds); in sun4m_fdctrl_init()
/qemu/subprojects/libvhost-user/
H A Dlibvhost-user.c494 close(vmsg->fds[i]); in vmsg_close_fds()
953 close(vmsg->fds[0]); in vu_add_mem_reg()
961 close(vmsg->fds[0]); in vu_add_mem_reg()
981 close(vmsg->fds[0]); in vu_add_mem_reg()
1096 close(vmsg->fds[i]); in vu_set_mem_table_exec()
1147 fd = vmsg->fds[0]; in vu_set_log_base_exec()
1183 dev->log_call_fd = vmsg->fds[0]; in vu_set_log_fd_exec()
1471 vmsg.fds[fd_num++] = fd; in vu_set_queue_host_notifier()
1529 *dmabuf_fd = msg_reply.fds[0]; in vu_lookup_shared_object()
1746 dev->backend_fd = vmsg->fds[0]; in vu_set_backend_req_fd()
[all …]
/qemu/chardev/
H A Dchar-fe.c125 int qemu_chr_fe_get_msgfds(CharBackend *be, int *fds, int len) in qemu_chr_fe_get_msgfds() argument
134 CHARDEV_GET_CLASS(s)->get_msgfds(s, fds, len) : -1; in qemu_chr_fe_get_msgfds()
137 int qemu_chr_fe_set_msgfds(CharBackend *be, int *fds, int num) in qemu_chr_fe_set_msgfds() argument
146 CHARDEV_GET_CLASS(s)->set_msgfds(s, fds, num) : -1; in qemu_chr_fe_set_msgfds()

123