Skip to content

Commit

Permalink
serial: separate serial_xmit and serial_watch_cb
Browse files Browse the repository at this point in the history
serial_xmit starts transmission of whatever is in the transmitter
register, THR or FIFO; serial_watch_cb is a wrapper around it and is
only used as a qemu_chr_fe_add_watch callback.

Tested-by: Bret Ketchum <bcketchum@gmail.com>
Reviewed-by: Dr. David Alan Gilbert <dgilbert@redhat.com>
Signed-off-by: Paolo Bonzini <pbonzini@redhat.com>
  • Loading branch information
bonzini committed Jun 29, 2016
1 parent bce933b commit b0585e7
Showing 1 changed file with 11 additions and 7 deletions.
18 changes: 11 additions & 7 deletions hw/char/serial.c
Expand Up @@ -106,6 +106,7 @@ do {} while (0)
#endif

static void serial_receive1(void *opaque, const uint8_t *buf, int size);
static void serial_xmit(SerialState *s);

static inline void recv_fifo_put(SerialState *s, uint8_t chr)
{
Expand Down Expand Up @@ -223,10 +224,16 @@ static void serial_update_msl(SerialState *s)
}
}

static gboolean serial_xmit(GIOChannel *chan, GIOCondition cond, void *opaque)
static gboolean serial_watch_cb(GIOChannel *chan, GIOCondition cond,
void *opaque)
{
SerialState *s = opaque;
serial_xmit(s);
return FALSE;
}

static void serial_xmit(SerialState *s)
{
do {
assert(!(s->lsr & UART_LSR_TEMT));
if (s->tsr_retry == 0) {
Expand Down Expand Up @@ -254,9 +261,9 @@ static gboolean serial_xmit(GIOChannel *chan, GIOCondition cond, void *opaque)
} else if (qemu_chr_fe_write(s->chr, &s->tsr, 1) != 1) {
if (s->tsr_retry < MAX_XMIT_RETRY &&
qemu_chr_fe_add_watch(s->chr, G_IO_OUT|G_IO_HUP,
serial_xmit, s) > 0) {
serial_watch_cb, s) > 0) {
s->tsr_retry++;
return FALSE;
return;
}
}
s->tsr_retry = 0;
Expand All @@ -267,11 +274,8 @@ static gboolean serial_xmit(GIOChannel *chan, GIOCondition cond, void *opaque)

s->last_xmit_ts = qemu_clock_get_ns(QEMU_CLOCK_VIRTUAL);
s->lsr |= UART_LSR_TEMT;

return FALSE;
}


/* Setter for FCR.
is_load flag means, that value is set while loading VM state
and interrupt should not be invoked */
Expand Down Expand Up @@ -329,7 +333,7 @@ static void serial_ioport_write(void *opaque, hwaddr addr, uint64_t val,
s->lsr &= ~UART_LSR_TEMT;
serial_update_irq(s);
if (s->tsr_retry == 0) {
serial_xmit(NULL, G_IO_OUT, s);
serial_xmit(s);
}
}
break;
Expand Down

0 comments on commit b0585e7

Please sign in to comment.