openkylin
/
qemu
mirror of https://gitee.com/openkylin/qemu.git
9
0
Fork 0
Code Issues Projects Releases Wiki Activity

virtio-serial-port: Convert to QOM realize/unrealize 

Signed-off-by: Andreas Färber <afaerber@suse.de>
This commit is contained in:
Andreas Färber 2013-06-07 19:02:12 +02:00
parent 0399a3819b
commit 2ef66625f3
3 changed files with 43 additions and 44 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
hw/char/virtio-console.c
View File

@ -126,14 +126,16 @@ static void chr_event(void *opaque, int event)
} }
} }
static int virtconsole_initfn(VirtIOSerialPort *port) static void virtconsole_realize(DeviceState *dev, Error **errp)
{ {
VirtConsole *vcon = VIRTIO_CONSOLE(port); VirtIOSerialPort *port = VIRTIO_SERIAL_PORT(dev);
VirtIOSerialPortClass *k = VIRTIO_SERIAL_PORT_GET_CLASS(port); VirtConsole *vcon = VIRTIO_CONSOLE(dev);
VirtIOSerialPortClass *k = VIRTIO_SERIAL_PORT_GET_CLASS(dev);
if (port->id == 0 && !k->is_console) { if (port->id == 0 && !k->is_console) {
error_report("Port number 0 on virtio-serial devices reserved for virtconsole devices for backward compatibility."); error_setg(errp, "Port number 0 on virtio-serial devices reserved "
return -1; "for virtconsole devices for backward compatibility.");
return;
} }
if (vcon->chr) { if (vcon->chr) {
@ -141,19 +143,15 @@ static int virtconsole_initfn(VirtIOSerialPort *port)
qemu_chr_add_handlers(vcon->chr, chr_can_read, chr_read, chr_event, qemu_chr_add_handlers(vcon->chr, chr_can_read, chr_read, chr_event,
vcon); vcon);
} }
return 0;
} }
static int virtconsole_exitfn(VirtIOSerialPort *port) static void virtconsole_unrealize(DeviceState *dev, Error **errp)
{ {
VirtConsole *vcon = VIRTIO_CONSOLE(port); VirtConsole *vcon = VIRTIO_CONSOLE(dev);
if (vcon->watch) { if (vcon->watch) {
g_source_remove(vcon->watch); g_source_remove(vcon->watch);
} }
return 0;
} }
static Property virtconsole_properties[] = { static Property virtconsole_properties[] = {
@ -167,8 +165,8 @@ static void virtconsole_class_init(ObjectClass *klass, void *data)
VirtIOSerialPortClass *k = VIRTIO_SERIAL_PORT_CLASS(klass); VirtIOSerialPortClass *k = VIRTIO_SERIAL_PORT_CLASS(klass);
k->is_console = true; k->is_console = true;
k->init = virtconsole_initfn; k->realize = virtconsole_realize;
k->exit = virtconsole_exitfn; k->unrealize = virtconsole_unrealize;
k->have_data = flush_buf; k->have_data = flush_buf;
k->set_guest_connected = set_guest_connected; k->set_guest_connected = set_guest_connected;
dc->props = virtconsole_properties; dc->props = virtconsole_properties;
@ -191,8 +189,8 @@ static void virtserialport_class_init(ObjectClass *klass, void *data)
DeviceClass *dc = DEVICE_CLASS(klass); DeviceClass *dc = DEVICE_CLASS(klass);
VirtIOSerialPortClass *k = VIRTIO_SERIAL_PORT_CLASS(klass); VirtIOSerialPortClass *k = VIRTIO_SERIAL_PORT_CLASS(klass);
k->init = virtconsole_initfn; k->realize = virtconsole_realize;
k->exit = virtconsole_exitfn; k->unrealize = virtconsole_unrealize;
k->have_data = flush_buf; k->have_data = flush_buf;
k->set_guest_connected = set_guest_connected; k->set_guest_connected = set_guest_connected;
dc->props = virtserialport_properties; dc->props = virtserialport_properties;

51
hw/char/virtio-serial-bus.c
View File

@ -808,13 +808,14 @@ static void remove_port(VirtIOSerial *vser, uint32_t port_id)
send_control_event(vser, port->id, VIRTIO_CONSOLE_PORT_REMOVE, 1); send_control_event(vser, port->id, VIRTIO_CONSOLE_PORT_REMOVE, 1);
} }
static int virtser_port_qdev_init(DeviceState *qdev) static void virtser_port_device_realize(DeviceState *dev, Error **errp)
{ {
VirtIOSerialPort *port = DO_UPCAST(VirtIOSerialPort, dev, qdev); VirtIOSerialPort *port = VIRTIO_SERIAL_PORT(dev);
VirtIOSerialPortClass *vsc = VIRTIO_SERIAL_PORT_GET_CLASS(port); VirtIOSerialPortClass *vsc = VIRTIO_SERIAL_PORT_GET_CLASS(port);
VirtIOSerialBus *bus = DO_UPCAST(VirtIOSerialBus, qbus, qdev->parent_bus); VirtIOSerialBus *bus = VIRTIO_SERIAL_BUS(qdev_get_parent_bus(dev));
int ret, max_nr_ports; int max_nr_ports;
bool plugging_port0; bool plugging_port0;
Error *err = NULL;
port->vser = bus->vser; port->vser = bus->vser;
port->bh = qemu_bh_new(flush_queued_data_bh, port); port->bh = qemu_bh_new(flush_queued_data_bh, port);
@ -829,9 +830,9 @@ static int virtser_port_qdev_init(DeviceState *qdev)
plugging_port0 = vsc->is_console && !find_port_by_id(port->vser, 0); plugging_port0 = vsc->is_console && !find_port_by_id(port->vser, 0);
if (find_port_by_id(port->vser, port->id)) { if (find_port_by_id(port->vser, port->id)) {
error_report("virtio-serial-bus: A port already exists at id %u", error_setg(errp, "virtio-serial-bus: A port already exists at id %u",
port->id); port->id);
return -1; return;
} }
if (port->id == VIRTIO_CONSOLE_BAD_ID) { if (port->id == VIRTIO_CONSOLE_BAD_ID) {
@ -840,22 +841,24 @@ static int virtser_port_qdev_init(DeviceState *qdev)
} else { } else {
port->id = find_free_port_id(port->vser); port->id = find_free_port_id(port->vser);
if (port->id == VIRTIO_CONSOLE_BAD_ID) { if (port->id == VIRTIO_CONSOLE_BAD_ID) {
error_report("virtio-serial-bus: Maximum port limit for this device reached"); error_setg(errp, "virtio-serial-bus: Maximum port limit for "
return -1; "this device reached");
return;
} }
} }
} }
max_nr_ports = tswap32(port->vser->config.max_nr_ports); max_nr_ports = tswap32(port->vser->config.max_nr_ports);
if (port->id >= max_nr_ports) { if (port->id >= max_nr_ports) {
error_report("virtio-serial-bus: Out-of-range port id specified, max. allowed: %u", error_setg(errp, "virtio-serial-bus: Out-of-range port id specified, "
max_nr_ports - 1); "max. allowed: %u", max_nr_ports - 1);
return -1; return;
} }
ret = vsc->init(port); vsc->realize(dev, &err);
if (ret) { if (err != NULL) {
return ret; error_propagate(errp, err);
return;
} }
port->elem.out_num = 0; port->elem.out_num = 0;
@ -868,14 +871,12 @@ static int virtser_port_qdev_init(DeviceState *qdev)
/* Send an update to the guest about this new port added */ /* Send an update to the guest about this new port added */
virtio_notify_config(VIRTIO_DEVICE(port->vser)); virtio_notify_config(VIRTIO_DEVICE(port->vser));
return ret;
} }
static int virtser_port_qdev_exit(DeviceState *qdev) static void virtser_port_device_unrealize(DeviceState *dev, Error **errp)
{ {
VirtIOSerialPort *port = DO_UPCAST(VirtIOSerialPort, dev, qdev); VirtIOSerialPort *port = VIRTIO_SERIAL_PORT(dev);
VirtIOSerialPortClass *vsc = VIRTIO_SERIAL_PORT_GET_CLASS(port); VirtIOSerialPortClass *vsc = VIRTIO_SERIAL_PORT_GET_CLASS(dev);
VirtIOSerial *vser = port->vser; VirtIOSerial *vser = port->vser;
qemu_bh_delete(port->bh); qemu_bh_delete(port->bh);
@ -883,10 +884,9 @@ static int virtser_port_qdev_exit(DeviceState *qdev)
QTAILQ_REMOVE(&vser->ports, port, next); QTAILQ_REMOVE(&vser->ports, port, next);
if (vsc->exit) { if (vsc->unrealize) {
vsc->exit(port); vsc->unrealize(dev, errp);
} }
return 0;
} }
static void virtio_serial_device_realize(DeviceState *dev, Error **errp) static void virtio_serial_device_realize(DeviceState *dev, Error **errp)
@ -971,10 +971,11 @@ static void virtio_serial_device_realize(DeviceState *dev, Error **errp)
static void virtio_serial_port_class_init(ObjectClass *klass, void *data) static void virtio_serial_port_class_init(ObjectClass *klass, void *data)
{ {
DeviceClass *k = DEVICE_CLASS(klass); DeviceClass *k = DEVICE_CLASS(klass);
k->init = virtser_port_qdev_init;
set_bit(DEVICE_CATEGORY_INPUT, k->categories); set_bit(DEVICE_CATEGORY_INPUT, k->categories);
k->bus_type = TYPE_VIRTIO_SERIAL_BUS; k->bus_type = TYPE_VIRTIO_SERIAL_BUS;
k->exit = virtser_port_qdev_exit; k->realize = virtser_port_device_realize;
k->unrealize = virtser_port_device_unrealize;
k->unplug = qdev_simple_unplug_cb; k->unplug = qdev_simple_unplug_cb;
k->props = virtser_props; k->props = virtser_props;
} }

8
include/hw/virtio/virtio-serial.h
View File

@ -81,15 +81,15 @@ typedef struct VirtIOSerialPortClass {
bool is_console; bool is_console;
/* /*
* The per-port (or per-app) init function that's called when a * The per-port (or per-app) realize function that's called when a
* new device is found on the bus. * new device is found on the bus.
*/ */
int (*init)(VirtIOSerialPort *port); DeviceRealize realize;
/* /*
* Per-port exit function that's called when a port gets * Per-port unrealize function that's called when a port gets
* hot-unplugged or removed. * hot-unplugged or removed.
*/ */
int (*exit)(VirtIOSerialPort *port); DeviceUnrealize unrealize;
/* Callbacks for guest events */ /* Callbacks for guest events */
/* Guest opened/closed device. */ /* Guest opened/closed device. */