• Home
  • Raw
  • Download

Lines Matching refs:node

39     QLIST_ENTRY(AioHandler) node;
44 AioHandler *node; in find_aio_handler() local
46 QLIST_FOREACH(node, &aio_handlers, node) { in find_aio_handler()
47 if (node->fd == fd) in find_aio_handler()
48 if (!node->deleted) in find_aio_handler()
49 return node; in find_aio_handler()
62 AioHandler *node; in qemu_aio_set_fd_handler() local
64 node = find_aio_handler(fd); in qemu_aio_set_fd_handler()
68 if (node) { in qemu_aio_set_fd_handler()
71 node->deleted = 1; in qemu_aio_set_fd_handler()
77 QLIST_REMOVE(node, node); in qemu_aio_set_fd_handler()
78 qemu_free(node); in qemu_aio_set_fd_handler()
82 if (node == NULL) { in qemu_aio_set_fd_handler()
84 node = qemu_mallocz(sizeof(AioHandler)); in qemu_aio_set_fd_handler()
85 node->fd = fd; in qemu_aio_set_fd_handler()
86 QLIST_INSERT_HEAD(&aio_handlers, node, node); in qemu_aio_set_fd_handler()
89 node->io_read = io_read; in qemu_aio_set_fd_handler()
90 node->io_write = io_write; in qemu_aio_set_fd_handler()
91 node->io_flush = io_flush; in qemu_aio_set_fd_handler()
92 node->io_process_queue = io_process_queue; in qemu_aio_set_fd_handler()
93 node->opaque = opaque; in qemu_aio_set_fd_handler()
103 AioHandler *node; in qemu_aio_flush() local
115 QLIST_FOREACH(node, &aio_handlers, node) { in qemu_aio_flush()
116 if (node->io_flush) { in qemu_aio_flush()
117 ret |= node->io_flush(node->opaque); in qemu_aio_flush()
125 AioHandler *node; in qemu_aio_process_queue() local
130 QLIST_FOREACH(node, &aio_handlers, node) { in qemu_aio_process_queue()
131 if (node->io_process_queue) { in qemu_aio_process_queue()
132 if (node->io_process_queue(node->opaque)) { in qemu_aio_process_queue()
158 AioHandler *node; in qemu_aio_wait() local
168 QLIST_FOREACH(node, &aio_handlers, node) { in qemu_aio_wait()
173 if (node->io_flush && node->io_flush(node->opaque) == 0) in qemu_aio_wait()
176 if (!node->deleted && node->io_read) { in qemu_aio_wait()
177 FD_SET(node->fd, &rdfds); in qemu_aio_wait()
178 max_fd = MAX(max_fd, node->fd + 1); in qemu_aio_wait()
180 if (!node->deleted && node->io_write) { in qemu_aio_wait()
181 FD_SET(node->fd, &wrfds); in qemu_aio_wait()
182 max_fd = MAX(max_fd, node->fd + 1); in qemu_aio_wait()
203 node = QLIST_FIRST(&aio_handlers); in qemu_aio_wait()
204 while (node) { in qemu_aio_wait()
207 if (!node->deleted && in qemu_aio_wait()
208 FD_ISSET(node->fd, &rdfds) && in qemu_aio_wait()
209 node->io_read) { in qemu_aio_wait()
210 node->io_read(node->opaque); in qemu_aio_wait()
212 if (!node->deleted && in qemu_aio_wait()
213 FD_ISSET(node->fd, &wrfds) && in qemu_aio_wait()
214 node->io_write) { in qemu_aio_wait()
215 node->io_write(node->opaque); in qemu_aio_wait()
218 tmp = node; in qemu_aio_wait()
219 node = QLIST_NEXT(node, node); in qemu_aio_wait()
222 QLIST_REMOVE(tmp, node); in qemu_aio_wait()