/qemu/hw/remote/ |
H A D | mpqemu-link.c | 39 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 D | iohub.c | 109 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 D | event_notifier-posix.c | 37 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 D | compatfd.c | 59 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 D | vhost-user-server.c | 61 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 D | main.c | 135 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 D | ivshmem-client.c | 272 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 D | ivshmem-client.h | 133 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 D | linux-test.c | 333 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 D | libqmp.c | 99 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 D | libqtest.h | 131 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 D | ivshmem-test.c | 256 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 D | channel.c | 54 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 D | channel-socket.c | 461 *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 D | fds.c | 55 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 D | os-posix.c | 216 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 D | fdc.h | 12 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 D | main.c | 149 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 D | ivshmem-server.c | 387 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 D | ivshmem-server.h | 128 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 D | channel.h | 114 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 D | tap.c | 716 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 D | fdc-sysbus.c | 99 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 D | libvhost-user.c | 494 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 D | char-fe.c | 125 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()
|