| /qemu/util/ |
| A D | aio-win32.c | 33 GPollFD pfd; member
54 node->pfd.revents = 0; in aio_remove_fd_handler()
97 node->pfd.fd = s; in aio_set_fd_handler()
99 node->pfd.events = 0; in aio_set_fd_handler()
101 node->pfd.events |= G_IO_IN; in aio_set_fd_handler()
104 node->pfd.events |= G_IO_OUT; in aio_set_fd_handler()
160 node->pfd.events = G_IO_IN; in aio_set_event_notifier()
208 node->pfd.revents = 0; in aio_prepare()
266 int revents = node->pfd.revents; in aio_dispatch_handlers()
271 node->pfd.revents = 0; in aio_dispatch_handlers()
[all …]
|
| A D | fdmon-epoll.c | 40 .events = new_node ? epoll_events_from_pfd(new_node->pfd.events) : 0, in fdmon_epoll_update()
45 r = epoll_ctl(ctx->epollfd, EPOLL_CTL_DEL, old_node->pfd.fd, &event); in fdmon_epoll_update()
47 r = epoll_ctl(ctx->epollfd, EPOLL_CTL_ADD, new_node->pfd.fd, &event); in fdmon_epoll_update()
49 r = epoll_ctl(ctx->epollfd, EPOLL_CTL_MOD, new_node->pfd.fd, &event); in fdmon_epoll_update()
60 GPollFD pfd = { in fdmon_epoll_wait() local
69 ret = qemu_poll_ns(&pfd, 1, timeout); in fdmon_epoll_wait()
109 if (QLIST_IS_INSERTED(node, node_deleted) || !node->pfd.events) { in fdmon_epoll_try_enable()
112 event.events = epoll_events_from_pfd(node->pfd.events); in fdmon_epoll_try_enable()
114 r = epoll_ctl(ctx->epollfd, EPOLL_CTL_ADD, node->pfd.fd, &event); in fdmon_epoll_try_enable()
|
| A D | aio-posix.c | 41 node->pfd.revents = revents; in aio_add_ready_handler()
58 if (node->pfd.fd == fd) { in find_aio_handler()
76 g_source_remove_poll(&ctx->source, &node->pfd); in aio_remove_fd_handler()
79 node->pfd.revents = 0; in aio_remove_fd_handler()
130 node->pfd.events = 0; in aio_set_fd_handler()
149 new_node->pfd.fd = fd; in aio_set_fd_handler()
151 new_node->pfd = node->pfd; in aio_set_fd_handler()
153 g_source_add_poll(&ctx->source, &new_node->pfd); in aio_set_fd_handler()
285 revents = node->pfd.revents & node->pfd.events; in aio_pending()
327 revents = node->pfd.revents & node->pfd.events; in aio_dispatch_handler()
[all …]
|
| A D | fdmon-poll.c | 53 .fd = node->pfd.fd, in add_pollfd()
54 .events = node->pfd.events, in add_pollfd()
68 if (!QLIST_IS_INSERTED(node, node_deleted) && node->pfd.events) { in fdmon_poll_wait()
|
| A D | main-loop.c | 417 GPollFD *pfd = &g_array_index(pollfds, GPollFD, i);
418 int fd = pfd->fd;
419 int events = pfd->events;
442 GPollFD *pfd = &g_array_index(pollfds, GPollFD, i);
443 int fd = pfd->fd;
455 pfd->revents = revents & pfd->events;
|
| A D | fdmon-io_uring.c | 172 int events = poll_events_from_pfd(node->pfd.events); in add_poll_add_sqe()
174 io_uring_prep_poll_add(sqe, node->pfd.fd, events); in add_poll_add_sqe()
|
| A D | aio-posix.h | 23 GPollFD pfd; member
|
| /qemu/chardev/ |
| A D | char-pty.c | 91 GPollFD pfd; in pty_chr_update_read_handler() local
95 pfd.fd = fioc->fd; in pty_chr_update_read_handler()
96 pfd.events = G_IO_OUT; in pty_chr_update_read_handler()
97 pfd.revents = 0; in pty_chr_update_read_handler()
98 rc = RETRY_ON_EINTR(g_poll(&pfd, 1, 0)); in pty_chr_update_read_handler()
101 if (pfd.revents & G_IO_HUP) { in pty_chr_update_read_handler()
111 GPollFD pfd; in char_pty_chr_write() local
122 pfd.fd = QIO_CHANNEL_FILE(s->ioc)->fd; in char_pty_chr_write()
123 pfd.events = G_IO_OUT; in char_pty_chr_write()
124 pfd.revents = 0; in char_pty_chr_write()
[all …]
|
| /qemu/audio/ |
| A D | sndioaudio.c | 65 struct pollfd *pfd; in sndio_poll_clear() local
69 pfd = &self->pfds[i]; in sndio_poll_clear()
70 qemu_set_fd_handler(pfd->fd, NULL, NULL, NULL); in sndio_poll_clear()
136 struct pollfd *pfd; in sndio_poll_wait() local
158 pfd = &self->pfds[i]; in sndio_poll_wait()
159 if (pfd->fd < 0) { in sndio_poll_wait()
162 qemu_set_fd_handler(pfd->fd, in sndio_poll_wait()
163 (pfd->events & POLLIN) ? sndio_poll_in : NULL, in sndio_poll_wait()
164 (pfd->events & POLLOUT) ? sndio_poll_out : NULL, in sndio_poll_wait()
166 pfd->revents = 0; in sndio_poll_wait()
|
| A D | ossaudio.c | 247 struct oss_params *obt, int *pfd, Audiodev *dev) in oss_open() argument
346 *pfd = fd; in oss_open()
|
| /qemu/migration/ |
| A D | postcopy-ram.c | 969 struct pollfd *pfd; in postcopy_ram_fault_thread() local
974 pfd[0].fd = mis->userfault_fd; in postcopy_ram_fault_thread()
975 pfd[0].events = POLLIN; in postcopy_ram_fault_thread()
976 pfd[1].fd = mis->userfault_event_fd; in postcopy_ram_fault_thread()
978 trace_postcopy_ram_fault_thread_fds_core(pfd[0].fd, pfd[1].fd); in postcopy_ram_fault_thread()
982 pfd[2 + index].fd = pcfd->fd; in postcopy_ram_fault_thread()
983 pfd[2 + index].events = POLLIN; in postcopy_ram_fault_thread()
1013 if (pfd[1].revents) { in postcopy_ram_fault_thread()
1028 if (pfd[0].revents) { in postcopy_ram_fault_thread()
1092 if (pfd[index].revents) { in postcopy_ram_fault_thread()
[all …]
|
| /qemu/tests/qtest/ |
| A D | tpm-emu.c | 115 int *pfd = NULL; in tpm_emu_ctrl_thread() local
118 qio_channel_readv_full(ioc, &iov, 1, &pfd, &nfd, 0, &error_abort); in tpm_emu_ctrl_thread()
122 s->tpm_ioc = QIO_CHANNEL(qio_channel_socket_new_fd(*pfd, &error_abort)); in tpm_emu_ctrl_thread()
123 g_free(pfd); in tpm_emu_ctrl_thread()
|
| /qemu/target/ppc/ |
| A D | kvm_ppc.h | 53 int *pfd, bool need_vfio);
54 int kvmppc_remove_spapr_tce(void *table, int pfd, uint32_t window_size);
280 int *pfd, bool need_vfio) in kvmppc_create_spapr_tce() argument
285 static inline int kvmppc_remove_spapr_tce(void *table, int pfd, in kvmppc_remove_spapr_tce() argument
|
| A D | kvm.c | 2210 int *pfd, bool need_vfio) in kvmppc_create_spapr_tce() argument
2220 *pfd = -1; in kvmppc_create_spapr_tce()
2270 *pfd = fd; in kvmppc_create_spapr_tce()
|
| /qemu/hw/vfio/ |
| A D | helpers.c | 118 int32_t *pfd; in vfio_set_irq_signaling() local
120 argsz = sizeof(*irq_set) + sizeof(*pfd); in vfio_set_irq_signaling()
128 pfd = (int32_t *)&irq_set->data; in vfio_set_irq_signaling()
129 *pfd = fd; in vfio_set_irq_signaling()
|
| /qemu/io/ |
| A D | channel-command.c | 188 GPollFD pfd = { .fd = _get_osfhandle(fd), .events = events }; in win32_fd_poll() local
192 res = g_poll(&pfd, 1, 0); in win32_fd_poll()
|
| /qemu/hw/misc/ |
| A D | ivshmem.c | 608 static int64_t ivshmem_recv_msg(IVShmemState *s, int *pfd, Error **errp) in ivshmem_recv_msg() argument
627 *pfd = qemu_chr_fe_get_msgfd(&s->server_chr); in ivshmem_recv_msg()
|
| /qemu/net/ |
| A D | slirp.c | 320 GPollFD pfd = { in net_slirp_add_poll() local
325 g_array_append_val(pollfds, pfd); in net_slirp_add_poll()
|
| /qemu/linux-user/ |
| A D | syscall.c | 1521 struct pollfd *pfd; in do_ppoll() local
1525 pfd = NULL; in do_ppoll()
1537 pfd = alloca(sizeof(struct pollfd) * nfds); in do_ppoll()
1539 pfd[i].fd = tswap32(target_pfd[i].fd); in do_ppoll()
1540 pfd[i].events = tswap16(target_pfd[i].events); in do_ppoll()
1571 ret = get_errno(safe_ppoll(pfd, nfds, timeout_ts, in do_ppoll()
1600 ret = get_errno(safe_ppoll(pfd, nfds, pts, NULL, 0)); in do_ppoll()
1605 target_pfd[i].revents = tswap16(pfd[i].revents); in do_ppoll()
|