static void posix_aio_read(void *opaque)

{

    PosixAioState *s = opaque;

    ssize_t len;



    /* read all bytes from signal pipe */

    for (;;) {

        char bytes[16];



        len = read(s->rfd, bytes, sizeof(bytes));

        if (len == -1 && errno == EINTR)

            continue; /* try again */

        if (len == sizeof(bytes))

            continue; /* more to read */

        break;

    }



    posix_aio_process_queue(s);

}

static void posix_aio_read(void *opaque)

{

    PosixAioState *s = opaque;

    ssize_t len;



    

    for (;;) {

        char bytes[16];



        len = read(s->rfd, bytes, sizeof(bytes));

        if (len == -1 && errno == EINTR)

            continue; 

        if (len == sizeof(bytes))

            continue; 

        break;

    }



    posix_aio_process_queue(s);

}

static void posix_aio_read(void *opaque)     PosixAioState *s = opaque;     ssize_t len;     for (;;) {         char bytes[16];         len = read(s->rfd, bytes, sizeof(bytes));         if (len == -1 && errno == EINTR)         if (len == sizeof(bytes))         break;     posix_aio_process_queue(s);
static void FUNC_0(void *VAR_0)

{

    PosixAioState *s = VAR_0;

    ssize_t len;



    

    for (;;) {

        char VAR_1[16];



        len = read(s->rfd, VAR_1, sizeof(VAR_1));

        if (len == -1 && errno == EINTR)

            continue; 

        if (len == sizeof(VAR_1))

            continue; 

        break;

    }



    posix_aio_process_queue(s);

}

static void FUNC_0(void *VAR_0)
{ PosixAioState *s = VAR_0; ssize_t len; for (;;) { char VAR_1[16]; len = read(s->rfd, VAR_1, sizeof(VAR_1)); if (len == -1 && errno == EINTR)
continue; if (len == sizeof(VAR_1))
continue; break; } posix_aio_process_queue(s); }