提交 7fa47e2a 编写于 作者: M Marc-André Lureau 提交者: Paolo Bonzini

char: rename some frontend functions

qemu_chr_accept_input() and qemu_chr_disconnect() are only used by
frontend, so use qemu_chr_fe prefix.
Signed-off-by: NMarc-André Lureau <marcandre.lureau@redhat.com>
Message-Id: <20161022095318.17775-14-marcandre.lureau@redhat.com>
Signed-off-by: NPaolo Bonzini <pbonzini@redhat.com>
上级 32a6ebec
...@@ -80,7 +80,7 @@ static uint64_t bcm2835_aux_read(void *opaque, hwaddr offset, unsigned size) ...@@ -80,7 +80,7 @@ static uint64_t bcm2835_aux_read(void *opaque, hwaddr offset, unsigned size)
} }
} }
if (s->chr.chr) { if (s->chr.chr) {
qemu_chr_accept_input(s->chr.chr); qemu_chr_fe_accept_input(s->chr.chr);
} }
bcm2835_aux_update(s); bcm2835_aux_update(s);
return c; return c;
......
...@@ -143,7 +143,7 @@ static void uart_rx_reset(CadenceUARTState *s) ...@@ -143,7 +143,7 @@ static void uart_rx_reset(CadenceUARTState *s)
s->rx_wpos = 0; s->rx_wpos = 0;
s->rx_count = 0; s->rx_count = 0;
if (s->chr.chr) { if (s->chr.chr) {
qemu_chr_accept_input(s->chr.chr); qemu_chr_fe_accept_input(s->chr.chr);
} }
} }
...@@ -369,7 +369,7 @@ static void uart_read_rx_fifo(CadenceUARTState *s, uint32_t *c) ...@@ -369,7 +369,7 @@ static void uart_read_rx_fifo(CadenceUARTState *s, uint32_t *c)
s->rx_count--; s->rx_count--;
if (s->chr.chr) { if (s->chr.chr) {
qemu_chr_accept_input(s->chr.chr); qemu_chr_fe_accept_input(s->chr.chr);
} }
} else { } else {
*c = 0; *c = 0;
......
...@@ -600,7 +600,7 @@ static uint64_t escc_mem_read(void *opaque, hwaddr addr, ...@@ -600,7 +600,7 @@ static uint64_t escc_mem_read(void *opaque, hwaddr addr,
ret = s->rx; ret = s->rx;
trace_escc_mem_readb_data(CHN_C(s), ret); trace_escc_mem_readb_data(CHN_C(s), ret);
if (s->chr.chr) { if (s->chr.chr) {
qemu_chr_accept_input(s->chr.chr); qemu_chr_fe_accept_input(s->chr.chr);
} }
return ret; return ret;
default: default:
......
...@@ -122,7 +122,7 @@ static uint64_t imx_serial_read(void *opaque, hwaddr offset, ...@@ -122,7 +122,7 @@ static uint64_t imx_serial_read(void *opaque, hwaddr offset,
s->uts1 |= UTS1_RXEMPTY; s->uts1 |= UTS1_RXEMPTY;
imx_update(s); imx_update(s);
if (s->chr.chr) { if (s->chr.chr) {
qemu_chr_accept_input(s->chr.chr); qemu_chr_fe_accept_input(s->chr.chr);
} }
} }
return c; return c;
...@@ -216,7 +216,7 @@ static void imx_serial_write(void *opaque, hwaddr offset, ...@@ -216,7 +216,7 @@ static void imx_serial_write(void *opaque, hwaddr offset,
if (value & UCR2_RXEN) { if (value & UCR2_RXEN) {
if (!(s->ucr2 & UCR2_RXEN)) { if (!(s->ucr2 & UCR2_RXEN)) {
if (s->chr.chr) { if (s->chr.chr) {
qemu_chr_accept_input(s->chr.chr); qemu_chr_fe_accept_input(s->chr.chr);
} }
} }
} }
......
...@@ -289,7 +289,7 @@ static uint16_t io_read(IPackDevice *ip, uint8_t addr) ...@@ -289,7 +289,7 @@ static uint16_t io_read(IPackDevice *ip, uint8_t addr)
ch->sr &= ~SR_RXRDY; ch->sr &= ~SR_RXRDY;
blk->isr &= ~ISR_RXRDY(channel); blk->isr &= ~ISR_RXRDY(channel);
if (ch->dev.chr) { if (ch->dev.chr) {
qemu_chr_accept_input(ch->dev.chr); qemu_chr_fe_accept_input(ch->dev.chr);
} }
} else { } else {
ch->rhr_idx = (ch->rhr_idx + 1) % RX_FIFO_SIZE; ch->rhr_idx = (ch->rhr_idx + 1) % RX_FIFO_SIZE;
......
...@@ -142,7 +142,7 @@ static uint64_t uart_read(void *opaque, hwaddr addr, ...@@ -142,7 +142,7 @@ static uint64_t uart_read(void *opaque, hwaddr addr,
r = s->regs[R_RXTX]; r = s->regs[R_RXTX];
s->regs[R_LSR] &= ~LSR_DR; s->regs[R_LSR] &= ~LSR_DR;
uart_update_irq(s); uart_update_irq(s);
qemu_chr_accept_input(s->chr.chr); qemu_chr_fe_accept_input(s->chr.chr);
break; break;
case R_IIR: case R_IIR:
case R_LSR: case R_LSR:
......
...@@ -93,7 +93,7 @@ uint64_t mcf_uart_read(void *opaque, hwaddr addr, ...@@ -93,7 +93,7 @@ uint64_t mcf_uart_read(void *opaque, hwaddr addr,
if (s->fifo_len == 0) if (s->fifo_len == 0)
s->sr &= ~MCF_UART_RxRDY; s->sr &= ~MCF_UART_RxRDY;
mcf_uart_update(s); mcf_uart_update(s);
qemu_chr_accept_input(s->chr.chr); qemu_chr_fe_accept_input(s->chr.chr);
return val; return val;
} }
case 0x10: case 0x10:
......
...@@ -138,7 +138,7 @@ static void uart_write(void *opaque, hwaddr addr, uint64_t value, ...@@ -138,7 +138,7 @@ static void uart_write(void *opaque, hwaddr addr, uint64_t value,
case R_STAT: case R_STAT:
/* write one to clear bits */ /* write one to clear bits */
s->regs[addr] &= ~(value & (STAT_RX_EVT | STAT_TX_EVT)); s->regs[addr] &= ~(value & (STAT_RX_EVT | STAT_TX_EVT));
qemu_chr_accept_input(s->chr.chr); qemu_chr_fe_accept_input(s->chr.chr);
break; break;
default: default:
......
...@@ -88,7 +88,7 @@ static uint64_t pl011_read(void *opaque, hwaddr offset, ...@@ -88,7 +88,7 @@ static uint64_t pl011_read(void *opaque, hwaddr offset,
s->rsr = c >> 8; s->rsr = c >> 8;
pl011_update(s); pl011_update(s);
if (s->chr.chr) { if (s->chr.chr) {
qemu_chr_accept_input(s->chr.chr); qemu_chr_fe_accept_input(s->chr.chr);
} }
r = c; r = c;
break; break;
......
...@@ -490,7 +490,7 @@ static uint64_t serial_ioport_read(void *opaque, hwaddr addr, unsigned size) ...@@ -490,7 +490,7 @@ static uint64_t serial_ioport_read(void *opaque, hwaddr addr, unsigned size)
serial_update_irq(s); serial_update_irq(s);
if (!(s->mcr & UART_MCR_LOOP)) { if (!(s->mcr & UART_MCR_LOOP)) {
/* in loopback mode, don't receive any data */ /* in loopback mode, don't receive any data */
qemu_chr_accept_input(s->chr.chr); qemu_chr_fe_accept_input(s->chr.chr);
} }
} }
break; break;
......
...@@ -51,7 +51,7 @@ static int vty_getchars(VIOsPAPRDevice *sdev, uint8_t *buf, int max) ...@@ -51,7 +51,7 @@ static int vty_getchars(VIOsPAPRDevice *sdev, uint8_t *buf, int max)
buf[n++] = dev->buf[dev->out++ % VTERM_BUFSIZE]; buf[n++] = dev->buf[dev->out++ % VTERM_BUFSIZE];
} }
qemu_chr_accept_input(dev->chardev.chr); qemu_chr_fe_accept_input(dev->chardev.chr);
return n; return n;
} }
......
...@@ -98,7 +98,7 @@ static uint64_t stm32f2xx_usart_read(void *opaque, hwaddr addr, ...@@ -98,7 +98,7 @@ static uint64_t stm32f2xx_usart_read(void *opaque, hwaddr addr,
retvalue = s->usart_sr; retvalue = s->usart_sr;
s->usart_sr &= ~USART_SR_TC; s->usart_sr &= ~USART_SR_TC;
if (s->chr.chr) { if (s->chr.chr) {
qemu_chr_accept_input(s->chr.chr); qemu_chr_fe_accept_input(s->chr.chr);
} }
return retvalue; return retvalue;
case USART_DR: case USART_DR:
...@@ -106,7 +106,7 @@ static uint64_t stm32f2xx_usart_read(void *opaque, hwaddr addr, ...@@ -106,7 +106,7 @@ static uint64_t stm32f2xx_usart_read(void *opaque, hwaddr addr,
s->usart_sr |= USART_SR_TXE; s->usart_sr |= USART_SR_TXE;
s->usart_sr &= ~USART_SR_RXNE; s->usart_sr &= ~USART_SR_RXNE;
if (s->chr.chr) { if (s->chr.chr) {
qemu_chr_accept_input(s->chr.chr); qemu_chr_fe_accept_input(s->chr.chr);
} }
qemu_set_irq(s->irq, 0); qemu_set_irq(s->irq, 0);
return s->usart_dr & 0x3FF; return s->usart_dr & 0x3FF;
......
...@@ -123,7 +123,7 @@ static void guest_writable(VirtIOSerialPort *port) ...@@ -123,7 +123,7 @@ static void guest_writable(VirtIOSerialPort *port)
VirtConsole *vcon = VIRTIO_CONSOLE(port); VirtConsole *vcon = VIRTIO_CONSOLE(port);
if (vcon->chr.chr) { if (vcon->chr.chr) {
qemu_chr_accept_input(vcon->chr.chr); qemu_chr_fe_accept_input(vcon->chr.chr);
} }
} }
......
...@@ -107,7 +107,7 @@ uart_read(void *opaque, hwaddr addr, unsigned int size) ...@@ -107,7 +107,7 @@ uart_read(void *opaque, hwaddr addr, unsigned int size)
s->rx_fifo_len--; s->rx_fifo_len--;
uart_update_status(s); uart_update_status(s);
uart_update_irq(s); uart_update_irq(s);
qemu_chr_accept_input(s->chr.chr); qemu_chr_fe_accept_input(s->chr.chr);
break; break;
default: default:
......
...@@ -165,11 +165,11 @@ CharDriverState *qemu_chr_new(const char *label, const char *filename); ...@@ -165,11 +165,11 @@ CharDriverState *qemu_chr_new(const char *label, const char *filename);
/** /**
* @qemu_chr_disconnect: * @qemu_chr_fe_disconnect:
* *
* Close a fd accpeted by character backend. * Close a fd accpeted by character backend.
*/ */
void qemu_chr_disconnect(CharDriverState *chr); void qemu_chr_fe_disconnect(CharDriverState *chr);
/** /**
* @qemu_chr_cleanup: * @qemu_chr_cleanup:
...@@ -490,7 +490,7 @@ void qemu_chr_add_handlers_full(CharDriverState *s, ...@@ -490,7 +490,7 @@ void qemu_chr_add_handlers_full(CharDriverState *s,
GMainContext *context); GMainContext *context);
void qemu_chr_be_generic_open(CharDriverState *s); void qemu_chr_be_generic_open(CharDriverState *s);
void qemu_chr_accept_input(CharDriverState *s); void qemu_chr_fe_accept_input(CharDriverState *s);
int qemu_chr_add_client(CharDriverState *s, int fd); int qemu_chr_add_client(CharDriverState *s, int fd);
CharDriverState *qemu_chr_find(const char *name); CharDriverState *qemu_chr_find(const char *name);
bool chr_is_ringbuf(const CharDriverState *chr); bool chr_is_ringbuf(const CharDriverState *chr);
......
...@@ -187,7 +187,7 @@ static gboolean net_vhost_user_watch(GIOChannel *chan, GIOCondition cond, ...@@ -187,7 +187,7 @@ static gboolean net_vhost_user_watch(GIOChannel *chan, GIOCondition cond,
{ {
VhostUserState *s = opaque; VhostUserState *s = opaque;
qemu_chr_disconnect(s->chr.chr); qemu_chr_fe_disconnect(s->chr.chr);
return FALSE; return FALSE;
} }
...@@ -212,7 +212,7 @@ static void net_vhost_user_event(void *opaque, int event) ...@@ -212,7 +212,7 @@ static void net_vhost_user_event(void *opaque, int event)
s->watch = qemu_chr_fe_add_watch(s->chr.chr, G_IO_HUP, s->watch = qemu_chr_fe_add_watch(s->chr.chr, G_IO_HUP,
net_vhost_user_watch, s); net_vhost_user_watch, s);
if (vhost_user_start(queues, ncs) < 0) { if (vhost_user_start(queues, ncs) < 0) {
qemu_chr_disconnect(s->chr.chr); qemu_chr_fe_disconnect(s->chr.chr);
return; return;
} }
qmp_set_link(name, true, &err); qmp_set_link(name, true, &err);
......
...@@ -430,7 +430,7 @@ int qemu_chr_add_client(CharDriverState *s, int fd) ...@@ -430,7 +430,7 @@ int qemu_chr_add_client(CharDriverState *s, int fd)
return s->chr_add_client ? s->chr_add_client(s, fd) : -1; return s->chr_add_client ? s->chr_add_client(s, fd) : -1;
} }
void qemu_chr_accept_input(CharDriverState *s) void qemu_chr_fe_accept_input(CharDriverState *s)
{ {
if (s->chr_accept_input) if (s->chr_accept_input)
s->chr_accept_input(s); s->chr_accept_input(s);
...@@ -4225,7 +4225,7 @@ void qemu_chr_fe_release(CharDriverState *s) ...@@ -4225,7 +4225,7 @@ void qemu_chr_fe_release(CharDriverState *s)
s->avail_connections++; s->avail_connections++;
} }
void qemu_chr_disconnect(CharDriverState *chr) void qemu_chr_fe_disconnect(CharDriverState *chr)
{ {
if (chr->chr_disconnect) { if (chr->chr_disconnect) {
chr->chr_disconnect(chr); chr->chr_disconnect(chr);
......
...@@ -268,7 +268,7 @@ static void chr_read(void *opaque, const uint8_t *buf, int size) ...@@ -268,7 +268,7 @@ static void chr_read(void *opaque, const uint8_t *buf, int size)
int fd; int fd;
if (s->test_fail) { if (s->test_fail) {
qemu_chr_disconnect(chr->chr); qemu_chr_fe_disconnect(chr->chr);
/* now switch to non-failure */ /* now switch to non-failure */
s->test_fail = false; s->test_fail = false;
} }
...@@ -313,7 +313,7 @@ static void chr_read(void *opaque, const uint8_t *buf, int size) ...@@ -313,7 +313,7 @@ static void chr_read(void *opaque, const uint8_t *buf, int size)
g_assert_cmpint(msg.payload.u64 & (0x1ULL << VHOST_USER_F_PROTOCOL_FEATURES), g_assert_cmpint(msg.payload.u64 & (0x1ULL << VHOST_USER_F_PROTOCOL_FEATURES),
!=, 0ULL); !=, 0ULL);
if (s->test_flags == TEST_FLAGS_DISCONNECT) { if (s->test_flags == TEST_FLAGS_DISCONNECT) {
qemu_chr_disconnect(chr->chr); qemu_chr_fe_disconnect(chr->chr);
s->test_flags = TEST_FLAGS_BAD; s->test_flags = TEST_FLAGS_BAD;
} }
break; break;
...@@ -724,7 +724,7 @@ reconnect_cb(gpointer user_data) ...@@ -724,7 +724,7 @@ reconnect_cb(gpointer user_data)
{ {
TestServer *s = user_data; TestServer *s = user_data;
qemu_chr_disconnect(s->chr.chr); qemu_chr_fe_disconnect(s->chr.chr);
return FALSE; return FALSE;
} }
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册