Lines Matching refs:node
40 QLIST_ENTRY(AioHandler) node;
45 AioHandler *node; in find_aio_handler() local
47 QLIST_FOREACH(node, &aio_handlers, node) { in find_aio_handler()
48 if (node->fd == fd) in find_aio_handler()
49 if (!node->deleted) in find_aio_handler()
50 return node; in find_aio_handler()
63 AioHandler *node; in qemu_aio_set_fd_handler() local
65 node = find_aio_handler(fd); in qemu_aio_set_fd_handler()
69 if (node) { in qemu_aio_set_fd_handler()
72 node->deleted = 1; in qemu_aio_set_fd_handler()
78 QLIST_REMOVE(node, node); in qemu_aio_set_fd_handler()
79 qemu_free(node); in qemu_aio_set_fd_handler()
83 if (node == NULL) { in qemu_aio_set_fd_handler()
85 node = qemu_mallocz(sizeof(AioHandler)); in qemu_aio_set_fd_handler()
86 node->fd = fd; in qemu_aio_set_fd_handler()
87 QLIST_INSERT_HEAD(&aio_handlers, node, node); in qemu_aio_set_fd_handler()
90 node->io_read = io_read; in qemu_aio_set_fd_handler()
91 node->io_write = io_write; in qemu_aio_set_fd_handler()
92 node->io_flush = io_flush; in qemu_aio_set_fd_handler()
93 node->io_process_queue = io_process_queue; in qemu_aio_set_fd_handler()
94 node->opaque = opaque; in qemu_aio_set_fd_handler()
104 AioHandler *node; in qemu_aio_flush() local
116 QLIST_FOREACH(node, &aio_handlers, node) { in qemu_aio_flush()
117 if (node->io_flush) { in qemu_aio_flush()
118 ret |= node->io_flush(node->opaque); in qemu_aio_flush()
126 AioHandler *node; in qemu_aio_process_queue() local
131 QLIST_FOREACH(node, &aio_handlers, node) { in qemu_aio_process_queue()
132 if (node->io_process_queue) { in qemu_aio_process_queue()
133 if (node->io_process_queue(node->opaque)) { in qemu_aio_process_queue()
162 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 iolooper_add_read(looper, node->fd); in qemu_aio_wait()
179 if (!node->deleted && node->io_write) { in qemu_aio_wait()
180 iolooper_add_write(looper, node->fd); in qemu_aio_wait()
200 node = QLIST_FIRST(&aio_handlers); in qemu_aio_wait()
201 while (node) { in qemu_aio_wait()
204 if (!node->deleted && in qemu_aio_wait()
205 iolooper_is_read(looper, node->fd) && in qemu_aio_wait()
206 node->io_read) { in qemu_aio_wait()
207 node->io_read(node->opaque); in qemu_aio_wait()
209 if (!node->deleted && in qemu_aio_wait()
210 iolooper_is_write(looper, node->fd) && in qemu_aio_wait()
211 node->io_write) { in qemu_aio_wait()
212 node->io_write(node->opaque); in qemu_aio_wait()
215 tmp = node; in qemu_aio_wait()
216 node = QLIST_NEXT(node, node); in qemu_aio_wait()
219 QLIST_REMOVE(tmp, node); in qemu_aio_wait()