Archipelago » qemu

        if (len > sizeof(buf))

            len = sizeof(buf);

        qemu_fifo_read(&s->out_fifo, buf, len);

    }

    /* characters are pending: we send them a bit later (XXX:

       horrible, should change char device API) */

            hextomem(mem_buf, p + 5, len);

            len = len / 2;

            mem_buf[len++] = 0;

            put_packet(s, "OK");

            break;

        }

    first = BUF_SIZE - baum->out_buf_ptr;

    if (room > first) {

        baum->out_buf_ptr = 0;

        baum->out_buf_used -= first;

        room -= first;

    }

    baum->out_buf_ptr += room;

    baum->out_buf_used -= room;

}

    len = cur - io_buf;

    if (len <= room) {

        /* Fits */

    } else {

        int first;

        uint8_t out;

        /* Can't fit all, send what can be, and store the rest. */

        len -= room;

        cur = io_buf + room;

        if (len > BUF_SIZE - baum->out_buf_used) {

    /* We always send the packet of, so that we do not have to keep track

       of previous state of the middle button. This can potentially confuse

       some very old drivers for two button mice though. */

}

static int msmouse_chr_write (struct CharDriverState *s, const uint8_t *buf, int len)

    return s->chr_can_read(s->handler_opaque);

}

{

    s->chr_read(s->handler_opaque, buf, len);

}

        return;

    }

    if (size > 0) {

    }

}

    /* try to flush the queue if needed */

    if (term_fifo_size != 0 && qemu_chr_can_read(chr) > 0) {

        term_fifo_size = 0;

    }

    /* see if we can absorb more chars */

    }

    if (size > 0) {

        if (qemu_chr_can_read(chr) > 0) {

        } else if (term_fifo_size == 0) {

            term_fifo[term_fifo_size++] = buf[0];

        }

    }

    if (size > 0) {

        pty_chr_state(chr, 1);

    }

}

    }

    if (size > 0) {

    }

}

     * first

     */

    while (s->max_size > 0 && s->bufptr < s->bufcnt) {

        s->bufptr++;

        s->max_size = qemu_chr_can_read(chr);

    }

    s->bufptr = 0;

    while (s->max_size > 0 && s->bufptr < s->bufcnt) {

        s->bufptr++;

        s->max_size = qemu_chr_can_read(chr);

    }

        if (s->do_telnetopt)

            tcp_chr_process_IAC_bytes(chr, s, buf, &size);

        if (size > 0)

    }

}

int qemu_chr_ioctl(CharDriverState *s, int cmd, void *arg);

void qemu_chr_generic_open(CharDriverState *s);

int qemu_chr_can_read(CharDriverState *s);

int qemu_chr_get_msgfd(CharDriverState *s);

void qemu_chr_accept_input(CharDriverState *s);

int qemu_chr_add_client(CharDriverState *s, int fd);

        if (qemu_chr_can_read(scd->chr) < last_out) {

            break;

        }

        out += last_out;

        len -= last_out;

        p += last_out;