Archipelago » qemu

#include "qemu-common.h"

#include "block.h"

#include "qemu_socket.h"

typedef struct AioHandler AioHandler;

/* The list of registered AIO handlers */

/* This is a simple lock used to protect the aio_handlers list.  Specifically,

 * it's used to ensure that no callbacks are removed while we're walking and

    AioFlushHandler *io_flush;

    int deleted;

    void *opaque;

};

static AioHandler *find_aio_handler(int fd)

{

    AioHandler *node;

        if (node->fd == fd)

            if (!node->deleted)

                return node;

                 * deleted because deleted nodes are only cleaned up after

                 * releasing the walking_handlers lock.

                 */

                qemu_free(node);

            }

        }

            /* Alloc and insert if it's not already there */

            node = qemu_mallocz(sizeof(AioHandler));

            node->fd = fd;

        }

        /* Update handler with latest information */

        node->io_read = io_read;

	 */

        qemu_aio_wait();

            ret |= node->io_flush(node->opaque);

        }

    } while (qemu_bh_poll() || ret > 0);

        FD_ZERO(&wrfds);

        /* fill fd sets */

            /* If there aren't pending AIO operations, don't invoke callbacks.

             * Otherwise, if there are no AIO requests, qemu_aio_wait() would

             * wait indefinitely.

            /* we have to walk very carefully in case

             * qemu_aio_set_fd_handler is called while we're walking */

            while (node) {

                AioHandler *tmp;

                }

                tmp = node;

                if (tmp->deleted) {

                    qemu_free(tmp);

                }

            }