Lines Matching refs:node
39 QLIST_ENTRY(AioHandler) node;
44 AioHandler *node;
46 QLIST_FOREACH(node, &aio_handlers, node) {
47 if (node->fd == fd)
48 if (!node->deleted)
49 return node;
61 AioHandler *node;
63 node = find_aio_handler(fd);
67 if (node) {
68 /* If the lock is held, just mark the node as deleted */
70 node->deleted = 1;
76 QLIST_REMOVE(node, node);
77 qemu_free(node);
81 if (node == NULL) {
83 node = qemu_mallocz(sizeof(AioHandler));
84 node->fd = fd;
85 QLIST_INSERT_HEAD(&aio_handlers, node, node);
88 node->io_read = io_read;
89 node->io_write = io_write;
90 node->io_flush = io_flush;
91 node->opaque = opaque;
101 AioHandler *node;
113 QLIST_FOREACH(node, &aio_handlers, node) {
114 ret |= node->io_flush(node->opaque);
130 AioHandler *node;
136 QLIST_FOREACH(node, &aio_handlers, node) {
141 if (node->io_flush && node->io_flush(node->opaque) == 0)
144 if (!node->deleted && node->io_read) {
145 iolooper_add_read(looper, node->fd);
147 if (!node->deleted && node->io_write) {
148 iolooper_add_write(looper, node->fd);
163 node = QLIST_FIRST(&aio_handlers);
164 while (node) {
167 if (!node->deleted &&
168 iolooper_is_read(looper, node->fd) &&
169 node->io_read) {
170 node->io_read(node->opaque);
172 if (!node->deleted &&
173 iolooper_is_write(looper, node->fd) &&
174 node->io_write) {
175 node->io_write(node->opaque);
178 tmp = node;
179 node = QLIST_NEXT(node, node);
182 QLIST_REMOVE(tmp, node);
