This interface presents a char device from which bits can be
sent and read.
Sample uses for such a device can be obtaining info from the
guest like the file systems used, apps installed, etc. for
offline usage and logged-in users, clipboard copy-paste, etc.
for online usage.
Signed-off-by: Amit Shah <amit.shah@xxxxxxxxxx>
---
Makefile.target | 2 +-
hw/pc.c | 17 +++
hw/pci.h | 1 +
hw/qdev.c | 6 +-
hw/virtio-pci.c | 15 ++
hw/virtio-serial.c | 399 ++++++++++++++++++++++++++++++++++++++++++++++++++++
hw/virtio-serial.h | 41 ++++++
hw/virtio.h | 1 +
monitor.c | 7 +
qemu-monitor.hx | 10 ++
qemu-options.hx | 8 +
sysemu.h | 15 ++
vl.c | 109 ++++++++++++++
13 files changed, 629 insertions(+), 2 deletions(-)
create mode 100644 hw/virtio-serial.c
create mode 100644 hw/virtio-serial.h
diff --git a/Makefile.target b/Makefile.target
index fc715ae..dd543e1 100644
--- a/Makefile.target
+++ b/Makefile.target
@@ -546,7 +546,7 @@ obj-y = vl.o osdep.o monitor.o pci.o loader.o isa_mmio.o machine.o \
gdbstub.o gdbstub-xml.o msix.o
# virtio has to be here due to weird dependency between PCI and virtio-net.
# need to fix this properly
-obj-y += virtio-blk.o virtio-balloon.o virtio-net.o virtio-console.o
+obj-y += virtio-blk.o virtio-balloon.o virtio-net.o virtio-console.o virtio-serial.o
obj-$(CONFIG_KVM) += kvm.o kvm-all.o
LIBS+=-lz
diff --git a/hw/pc.c b/hw/pc.c
index 43e2f29..f40cfde 100644
--- a/hw/pc.c
+++ b/hw/pc.c
@@ -40,6 +40,8 @@
#include "qemu-kvm.h"
+void *virtio_serial_new_port(PCIDevice *dev, int idx, char *name);
+
/* output Bochs bios info messages */
//#define DEBUG_BIOS
@@ -1451,6 +1453,21 @@ static void pc_init1(ram_addr_t ram_size,
}
}
+ /* Add virtio serial devices */
+ if (pci_enabled && virtio_serial_index) {
+ void *dev;
+
+ dev = pci_create_simple(pci_bus, -1, "virtio-serial-pci");
+ if (!dev) {
+ fprintf(stderr, "qemu: could not create virtio serial pci device\n");
+ exit(1);
+ }
+
+ for (i = 0; i < virtio_serial_index; i++) {
+ virtio_serial_new_port(dev, virtio_serial_idx[i], virtio_serial_names[i]);
+ }
+ }
+
#ifdef USE_KVM_DEVICE_ASSIGNMENT
if (kvm_enabled()) {
add_assigned_devices(pci_bus, assigned_devices, assigned_devices_index);
diff --git a/hw/pci.h b/hw/pci.h
index 328b846..4359353 100644
--- a/hw/pci.h
+++ b/hw/pci.h
@@ -72,6 +72,7 @@ extern target_phys_addr_t pci_mem_base;
#define PCI_DEVICE_ID_VIRTIO_BLOCK 0x1001
#define PCI_DEVICE_ID_VIRTIO_BALLOON 0x1002
#define PCI_DEVICE_ID_VIRTIO_CONSOLE 0x1003
+#define PCI_DEVICE_ID_VIRTIO_SERIAL 0x1004
typedef void PCIConfigWriteFunc(PCIDevice *pci_dev,
uint32_t address, uint32_t data, int len);
diff --git a/hw/qdev.c b/hw/qdev.c
index 385e709..fe5bcd0 100644
--- a/hw/qdev.c
+++ b/hw/qdev.c
@@ -168,9 +168,13 @@ CharDriverState *qdev_init_chardev(DeviceState *dev)
{
static int next_serial;
static int next_virtconsole;
+ static int next_virtserial;
+
/* FIXME: This is a nasty hack that needs to go away. */
- if (strncmp(dev->type->info->name, "virtio", 6) == 0) {
+ if (strncmp(dev->type->info->name, "virtio-console", 14) == 0) {
return virtcon_hds[next_virtconsole++];
+ } else if (strncmp(dev->type->info->name, "virtio-serial", 13) == 0) {
+ return virtio_serial_hds[next_virtserial++];
} else {
return serial_hds[next_serial++];
}
diff --git a/hw/virtio-pci.c b/hw/virtio-pci.c
index f7da503..2258717 100644
--- a/hw/virtio-pci.c
+++ b/hw/virtio-pci.c
@@ -466,6 +466,19 @@ static void virtio_balloon_init_pci(PCIDevice *pci_dev)
0x00);
}
+static void virtio_serial_init_pci(PCIDevice *pci_dev)
+{
+ VirtIOPCIProxy *proxy = DO_UPCAST(VirtIOPCIProxy, pci_dev, pci_dev);
+ VirtIODevice *vdev;
+
+ vdev = virtio_serial_init(&pci_dev->qdev);
+ virtio_init_pci(proxy, vdev,
+ PCI_VENDOR_ID_REDHAT_QUMRANET,
+ PCI_DEVICE_ID_VIRTIO_SERIAL,
+ PCI_CLASS_COMMUNICATION_OTHER,
+ 0x00);
+}
+
static void virtio_pci_register_devices(void)
{
pci_qdev_register("virtio-blk-pci", sizeof(VirtIOPCIProxy),
@@ -476,6 +489,8 @@ static void virtio_pci_register_devices(void)
virtio_console_init_pci);
pci_qdev_register("virtio-balloon-pci", sizeof(VirtIOPCIProxy),
virtio_balloon_init_pci);
+ pci_qdev_register("virtio-serial-pci", sizeof(VirtIOPCIProxy),
+ virtio_serial_init_pci);
}
device_init(virtio_pci_register_devices)
diff --git a/hw/virtio-serial.c b/hw/virtio-serial.c
new file mode 100644
index 0000000..3883bc0
--- /dev/null
+++ b/hw/virtio-serial.c
@@ -0,0 +1,399 @@
+/*
+ * Virtio serial interface
+ *
+ * This serial interface is a paravirtualised guest<->host
+ * communication channel for relaying short messages and events in
+ * either direction.
+ *
+ * There's support for multiple serial channels within one virtio PCI
+ * device to keep the guest PCI device count low.
+ *
+ * Copyright (C) 2009, Red Hat, Inc.
+ *
+ * Author(s): Amit Shah <amit.shah@xxxxxxxxxx>
+ *
+ * This work is licensed under the terms of the GNU GPL, version 2. See
+ * the COPYING file in the top-level directory.
+ */
+
+#include "hw.h"
+#include "pci.h"
+#include "monitor.h"
+#include "qemu-char.h"
+#include "virtio.h"
+#include "virtio-serial.h"
+
+typedef struct VirtIOSerial {
+ PCIDevice *dev;
+ VirtIODevice *vdev;
+ VirtQueue *cvq;
+ VirtQueue *ivq, *ovq;
+ struct VirtIOSerialPort *ports;
+ struct virtio_serial_config config;
+} VirtIOSerial;
+
+typedef struct VirtIOSerialPort {
+ VirtIOSerial *virtserial;
+ CharDriverState *hd;
+ char name[VIRTIO_SERIAL_NAME_MAX_LEN];
+ uint32_t port_nr;
+} VirtIOSerialPort;
+
+typedef struct VirtIOSerialId {
+ uint32_t id; /* Port id */
+} VirtIOSerialId;
+
+VirtIOSerial virtio_serial;
+
+static VirtIOSerialPort *get_port_from_id(uint32_t id)
+{
+ if (id > virtio_serial_index)
+ return NULL;
+
+ return &virtio_serial.ports[id];
+}
+
+static char *get_port_name_from_id(uint32_t id)
+{
+ VirtIOSerialPort *port;
+
+ port = get_port_from_id(id);
+ if (port)
+ return port->name;
+ else
+ return NULL;
+}
+
+static int get_id_from_port(VirtIOSerialPort *port)
+{
+ uint32_t i;
+
+ for (i = 0; i < virtio_serial_index; i++) {
+ if (port == &virtio_serial.ports[i]) {
+ return i;
+ }
+ }
+ return VIRTIO_SERIAL_BAD_ID;
+}
+
+static void virtio_serial_handle_control(VirtIODevice *vdev, VirtQueue *vq)
+{
+ VirtQueueElement elem;
+
+ while (virtqueue_pop(vq, &elem)) {
+ int i;
+ char *name;
+ ssize_t len, strlen;
+ struct virtio_serial_control ser_control;
+
+ len = 0;
+ for (i = 0; i < elem.out_num; i++) {
+ memcpy(&ser_control, elem.out_sg[i].iov_base, sizeof(ser_control));
+
+ switch(ser_control.key) {
+ case VIRTIO_SERIAL_GET_PORT_NAME:
+ name = get_port_name_from_id(ser_control.port_nr);
+
+ strlen = strnlen(name, VIRTIO_SERIAL_NAME_MAX_LEN);
+
+ memcpy(elem.in_sg[0].iov_base, &ser_control,
+ sizeof(ser_control));
+ memcpy(elem.in_sg[0].iov_base + sizeof(ser_control), name,
+ strlen);
+
+ len = strlen + sizeof(ser_control);
+ break;
+ }
+ }
+ virtqueue_push(vq, &elem, len);
+ }
+ virtio_notify(vdev, vq);
+
+ return;
+}
+
+static void virtio_serial_handle_output(VirtIODevice *vdev, VirtQueue *vq)
+{
+ VirtIOSerialPort *port;
+ VirtQueueElement elem;
+ VirtIOSerialId id;
+
+ while (virtqueue_pop(vq, &elem)) {
+ ssize_t len = 0;
+ int id_len = sizeof(id);
+ int i;
+
+ memcpy(&id, elem.out_sg[0].iov_base, id_len);
+ port = get_port_from_id(id.id);
+
+ if (port->hd) {
+ for (i = 0; i < elem.out_num; i++) {
+ len += qemu_chr_write(port->hd,
+ elem.out_sg[i].iov_base + id_len,
+ elem.out_sg[i].iov_len - id_len);
+ id_len = 0;
+ }
+ }
+ virtqueue_push(vq, &elem, len);
+ }
+ virtio_notify(vdev, vq);
+}
+
+static void virtio_serial_handle_input(VirtIODevice *vdev, VirtQueue *vq)
+{
+}
+
+void virtio_monitor_command(Monitor *mon,
+ const char *command, const char *param)
+{
+ VirtIOSerialPort *port = &virtio_serial.ports[0];
+ VirtIODevice *vdev = port->virtserial->vdev;
+ VirtQueue *vq = port->virtserial->ivq;
+ VirtQueueElement elem;
+ char buf[300];
+ ssize_t len;
+ unsigned int i;
+ int ret;
+
+ if(!strncmp(command, "add_port", 8)) {
+ if (!param) {
+ param = "none";
+ }
+ ret = init_virtio_serial_port(virtio_serial_index, param);
+ if (ret < 0) {
+ monitor_printf(mon, "can't init port\n");
+ return;
+ }
+ virtio_serial_new_port(NULL, virtio_serial_index,
+ virtio_serial_names[virtio_serial_index]);
+ virtio_serial_index++;
+ virtio_serial.config.nr_ports = cpu_to_le32(virtio_serial_index);
+ return;
+ }
+
+ if (!virtio_queue_ready(vq)) {
+ goto queue_not_ready;
+ }
+
+ len = snprintf(buf, 299, "%s %s\n", command, param);
+
+ ret = virtqueue_pop(vq, &elem);
+ if (!ret) {
+ goto queue_not_ready;
+ }
+
+ i = 0;
+ /* Note: We only have PAGE_SIZE sized buffers */
+ memcpy(elem.in_sg[i].iov_base, buf, len);
+ elem.in_sg[i].iov_len = len;
+
+ virtqueue_push(vq, &elem, len);
+ virtio_notify(vdev, vq);
+ return;
+
+queue_not_ready:
+ monitor_printf(cur_mon,
+ "vmserial: No free virtio buffer found. Message not sent.\n");
+ return;
+}
+
+static int cons_can_read(void *opaque)
+{
+ VirtIOSerialPort *port = (VirtIOSerialPort *) opaque;
+ VirtQueue *vq = port->virtserial->ivq;
+ int size;
+
+ if (!virtio_queue_ready(vq)) {
+ return 0;
+ }
+
+ size = TARGET_PAGE_SIZE;
+ if (virtqueue_avail_bytes(vq, size, 0)) {
+ return size - sizeof(VirtIOSerialId);
+ }
+
+ size = sizeof(VirtIOSerialId) + 1;
+ if (virtqueue_avail_bytes(vq, size, 0)) {
+ return size - sizeof(VirtIOSerialId);
+ }
+ return 0;
+}
+
+static void cons_read(void *opaque, const uint8_t *buf, int size)
+{
+ VirtIOSerialPort *port = (VirtIOSerialPort *) opaque;
+ VirtQueue *vq = port->virtserial->ivq;
+ VirtQueueElement elem;
+ int offset = 0;
+
+ while (offset < size) {
+ VirtIOSerialId id;
+ int i, id_len;
+
+ id_len = sizeof(VirtIOSerialId);
+
+ if (!virtqueue_pop(vq, &elem)) {
+ break;
+ }
+ if (elem.in_sg[0].iov_len < id_len) {
+ /* We can't even store our port number in this buffer. Bug? */
+ fprintf(stderr, "virtio-serial: size %zd less than expected\n",
+ elem.in_sg[0].iov_len);
+ exit(1);
+ }
+ id.id = cpu_to_le32(get_id_from_port(port));
+ memcpy(elem.in_sg[0].iov_base, &id, id_len);
+
+ for (i = 0; offset < size && i < elem.in_num; i++) {
+ int len = MIN(elem.in_sg[i].iov_len - id_len, size - offset);
+
+ memcpy(elem.in_sg[i].iov_base + id_len, buf + offset, len);
+ offset += len;
+ id_len = 0;
+ }
+ virtqueue_push(vq, &elem, size + sizeof(VirtIOSerialId));
+ }
+ virtio_notify(port->virtserial->vdev, vq);
+}
+
+static void cons_event(void *opaque, int event)
+{
+ /* we will ignore any event for the time being */
+}
+
+static uint32_t virtio_serial_get_features(VirtIODevice *vdev)
+{
+ return 0;
+}
+
+static void virtio_serial_get_config(VirtIODevice *vdev, uint8_t *config_data)
+{
+ memcpy(config_data, &virtio_serial.config, sizeof(virtio_serial.config));
+}
+
+static void virtio_serial_set_config(VirtIODevice *vdev,
+ const uint8_t *config_data)
+{
+ struct virtio_serial_config config;
+
+ memcpy(&config, config_data, sizeof(config));
+
+ /* Nothing to do as of now */
+}
+
+static void virtio_serial_save(QEMUFile *f, void *opaque)
+{
+ VirtIODevice *vdev = opaque;
+
+ virtio_save(vdev, f);
+}
+
+static int virtio_serial_load(QEMUFile *f, void *opaque, int version_id)
+{
+ VirtIODevice *vdev = opaque;
+
+ if (version_id != 1)
+ return -EINVAL;
+
+ virtio_load(vdev, f);
+ return 0;
+}
+
+void virtio_serial_set_port_active(uint32_t idx)
+{
+ int i = 0;
+
+ while (idx / 32) {
+ i++;
+ idx -= 32;
+ }
+ virtio_serial.config.ports_map[i] |= 1U << idx;
+}
+
+bool virtio_serial_is_port_active(uint32_t idx)
+{
+ int i = 0;
+
+ while (idx / 32) {
+ i++;
+ idx -= 32;
+ }
+ return virtio_serial.config.ports_map[i] & (1U << idx);
+}
+
+void *virtio_serial_new_port(PCIDevice *dev, int idx, char *name)
+{
+ VirtIOSerialPort *port;
+
+ port = &virtio_serial.ports[idx];
+
+ port->virtserial = &virtio_serial;
+
+ if (!port->virtserial->dev && !dev) {
+ return NULL;
+ }
+
+ if (!port->virtserial->dev) {
+ port->virtserial->dev = dev;
+ }
+
+ /* Hot-adding ports to existing device*/
+ if (!dev) {
+ dev = port->virtserial->dev;
+ }
+
+ memcpy(port->name, name, VIRTIO_SERIAL_NAME_MAX_LEN);
+
+ port->hd = qdev_init_chardev(&dev->qdev);
+ if (port->hd) {
+ qemu_chr_add_handlers(port->hd, cons_can_read, cons_read, cons_event,
+ port);
+ }
+
+ /* Send an update to the guest about this new port added */
+ virtio_notify_config(port->virtserial->vdev);
+ return port;
+}
+
+VirtIODevice *virtio_serial_init(DeviceState *dev)
+{
+ VirtIODevice *vdev;
+ int nr_ports = 4;
+
+ vdev = virtio_common_init("virtio-serial",
+ VIRTIO_ID_SERIAL,
+ sizeof(struct virtio_serial_config),
+ sizeof(VirtIODevice));
+ if (vdev == NULL)
+ return NULL;
+
+ virtio_serial.vdev = vdev;
+ vdev->get_config = virtio_serial_get_config;
+ vdev->set_config = virtio_serial_set_config;
+ vdev->get_features = virtio_serial_get_features;
+
+ /* Add a queue for control information transfer common to all
+ * serial ports
+ */
+ virtio_serial.cvq = virtio_add_queue(vdev, 2, virtio_serial_handle_control);
+
+ /* Add queue for host to guest transfers */
+ virtio_serial.ivq = virtio_add_queue(vdev, VIRTQUEUE_MAX_SIZE,
+ virtio_serial_handle_input);
+ /* Add queue for guest to host transfers */
+ virtio_serial.ovq = virtio_add_queue(vdev, VIRTQUEUE_MAX_SIZE,
+ virtio_serial_handle_output);
+
+
+ /* Allocate space for the number of serial ports specified on the
+ * command line
+ */
+ virtio_serial.ports = qemu_mallocz(sizeof(VirtIOSerialPort) * nr_ports);
+
+ register_savevm("virtio-serial", -1, 1, virtio_serial_save,
+ virtio_serial_load, vdev);
+
+ virtio_serial.config.nr_ports = cpu_to_le32(virtio_serial_index);
+
+ return vdev;
+}
diff --git a/hw/virtio-serial.h b/hw/virtio-serial.h
new file mode 100644
index 0000000..d7cc2b8
--- /dev/null
+++ b/hw/virtio-serial.h
@@ -0,0 +1,41 @@
+/*
+ * Virtio Serial Support
+ *
+ * Copyright (C) 2009, Red Hat, Inc.
+ *
+ * Author(s): Amit Shah <amit.shah@xxxxxxxxxx>
+ *
+ * This work is licensed under the terms of the GNU GPL, version 2. See
+ * the COPYING file in the top-level directory.
+ *
+ */
+#ifndef _QEMU_VIRTIO_SERIAL_H
+#define _QEMU_VIRTIO_SERIAL_H
+
+#include "sysemu.h"
+
+/* The ID for virtio serial */
+#define VIRTIO_ID_SERIAL 7
+#define VIRTIO_SERIAL_BAD_ID (~(uint32_t)0)
+
+struct virtio_serial_config
+{
+ uint32_t nr_ports;
+ uint32_t ports_map[(MAX_VIRTIO_SERIAL_PORTS + 31) / 32];
+};
+
+struct virtio_serial_control
+{
+ uint32_t port_nr;
+ uint32_t key;
+};
+
+/* Some defines for the control channel key */
+#define VIRTIO_SERIAL_GET_PORT_NAME 1
+
+
+void *virtio_serial_new_port(PCIDevice *dev, int idx, char *name);
+void virtio_monitor_command(Monitor *mon,
+ const char *command, const char *param);
+
+#endif
diff --git a/hw/virtio.h b/hw/virtio.h
index aa55677..ec111f6 100644
--- a/hw/virtio.h
+++ b/hw/virtio.h
@@ -165,5 +165,6 @@ VirtIODevice *virtio_blk_init(DeviceState *dev);
VirtIODevice *virtio_net_init(DeviceState *dev);
VirtIODevice *virtio_console_init(DeviceState *dev);
VirtIODevice *virtio_balloon_init(DeviceState *dev);
+VirtIODevice *virtio_serial_init(DeviceState *dev);
#endif
diff --git a/monitor.c b/monitor.c
index cfca466..194e238 100644
--- a/monitor.c
+++ b/monitor.c
@@ -45,6 +45,7 @@
#include "kvm.h"
#include "acl.h"
#include "exec-all.h"
+#include "hw/virtio-serial.h"
#include "qemu-kvm.h"
@@ -1701,6 +1702,12 @@ static void do_acl_remove(Monitor *mon, const char *aclname, const char *match)
}
}
+static void do_virtio_serial_action(Monitor *mon,
+ const char *command, const char *param)
+{
+ virtio_monitor_command(mon, command, param);
+}
+
static const mon_cmd_t mon_cmds[] = {
#include "qemu-monitor.h"
{ NULL, NULL, },
diff --git a/qemu-monitor.hx b/qemu-monitor.hx
index 3fdf2d2..4864488 100644
--- a/qemu-monitor.hx
+++ b/qemu-monitor.hx
@@ -569,6 +569,16 @@ STEXI
Change watchdog action.
ETEXI
+ { "virtio-serial", "ss?", do_virtio_serial_action,
+ "<command> [<parameters>]\n",
+ "virtio-serial write port=3,key=get,value=clipboard\n"
+ "virtio-serial add_port\n"
+ "virtio-serial add_port port=6,name=foo,protocol=keyvalue\n" },
+STEXI
+@item virtio-serial
+Hot-add ports or send data to virtio-serial port
+ETEXI
+
{ "acl_show", "s", do_acl_show, "aclname",
"list rules in the access control list" },
STEXI
diff --git a/qemu-options.hx b/qemu-options.hx
index 7e98053..0ac2b96 100644
--- a/qemu-options.hx
+++ b/qemu-options.hx
@@ -1590,6 +1590,14 @@ STEXI
Set virtio console.
ETEXI
+DEF("virtioserial", HAS_ARG, QEMU_OPTION_virtioserial, \
+ "-virtioserial c\n" \
+ " define virtio serial device\n")
+STEXI
+@item -virtserial @var{c}
+Set virtio serial device.
+ETEXI
+
DEF("show-cursor", 0, QEMU_OPTION_show_cursor, \
"-show-cursor show cursor\n")
STEXI
diff --git a/sysemu.h b/sysemu.h
index 5582633..5b7d0c5 100644
--- a/sysemu.h
+++ b/sysemu.h
@@ -2,6 +2,7 @@
#define SYSEMU_H
/* Misc. things related to the system emulator. */
+#include <stdbool.h>
#include "qemu-common.h"
#ifdef _WIN32
@@ -239,6 +240,20 @@ extern CharDriverState *parallel_hds[MAX_PARALLEL_PORTS];
extern CharDriverState *virtcon_hds[MAX_VIRTIO_CONSOLES];
+/* virtio serial ports */
+
+#define MAX_VIRTIO_SERIAL_PORTS 64
+#define VIRTIO_SERIAL_NAME_MAX_LEN 30
+#define VIRTIO_SERIAL_PROTO_MAX_LEN 30
+
+extern CharDriverState *virtio_serial_hds[MAX_VIRTIO_SERIAL_PORTS];
+extern char virtio_serial_names[MAX_VIRTIO_SERIAL_PORTS][VIRTIO_SERIAL_NAME_MAX_LEN];
+extern uint32_t virtio_serial_idx[MAX_VIRTIO_SERIAL_PORTS];
+extern int virtio_serial_index;
+extern int init_virtio_serial_port(int port, const char *opts);
+extern void virtio_serial_set_port_active(uint32_t idx);
+extern bool virtio_serial_is_port_active(uint32_t idx);
+
#define TFR(expr) do { if ((expr) != -1) break; } while (errno == EINTR)
#ifdef NEED_CPU_H
diff --git a/vl.c b/vl.c
index 5d86e69..0a414e8 100644
--- a/vl.c
+++ b/vl.c
@@ -235,6 +235,11 @@ int no_quit = 0;
CharDriverState *serial_hds[MAX_SERIAL_PORTS];
CharDriverState *parallel_hds[MAX_PARALLEL_PORTS];
CharDriverState *virtcon_hds[MAX_VIRTIO_CONSOLES];
+CharDriverState *virtio_serial_hds[MAX_VIRTIO_SERIAL_PORTS];
+char virtio_serial_names[MAX_VIRTIO_SERIAL_PORTS][VIRTIO_SERIAL_NAME_MAX_LEN];
+char virtio_serial_proto[MAX_VIRTIO_SERIAL_PORTS][VIRTIO_SERIAL_PROTO_MAX_LEN];
+uint32_t virtio_serial_idx[MAX_VIRTIO_SERIAL_PORTS];
+int virtio_serial_index;
#ifdef TARGET_I386
int win2k_install_hack = 0;
int rtc_td_hack = 0;
@@ -5048,6 +5053,78 @@ char *qemu_find_file(int type, const char *name)
return buf;
}
+
+int init_virtio_serial_port(int port, const char *opts)
+{
+ char serdev[256];
+ const char *virtsername;
+ const char *virtserprot;
+ const char *virtseridx;
+ uint32_t port_nr;
+ int j, k;
+
+ memset(serdev, 0, 80);
+ virtsername = strstr(opts, ",name=");
+ virtserprot = strstr(opts, ",protocol=");
+ virtseridx = strstr(opts, ",id=");
+
+ j = k = 0;
+
+ /* Just to maintain compatibility with other qemu options,
+ * we have the format of
+ *
+ * -virtioserial unix:/tmp/foo,name=bar,protocol=baz,id=3
+ *
+ * so to parse the 'unix:', we have to do the following
+ */
+ if (virtsername || virtserprot || virtseridx) {
+ while (&opts[j] != virtsername && &opts[j] != virtserprot
+ && &opts[j] != virtseridx) {
+ serdev[k++] = opts[j++];
+ }
+ } else { /* No options on the command line, just the char device */
+ while((serdev[k++] = opts[j++])) {
+ ;
+ }
+ }
+ if (virtseridx) {
+ /* skip ',id=' */
+ port_nr = atol(virtseridx + 4);
+ } else {
+ port_nr = port;
+ }
+ k = virtio_serial_is_port_active(port_nr);
+ if (k || port_nr >= MAX_VIRTIO_SERIAL_PORTS) {
+ return -EEXIST;
+ }
+ if (serdev[0] && strncmp(serdev, "none", 4)) {
+ char label[32];
+ snprintf(label, sizeof(label), "virtio-serial%d", port);
+ virtio_serial_hds[port] = qemu_chr_open(label, serdev, NULL);
+ if (!virtio_serial_hds[port]) {
+ /* We could be called from a monitor command to hot-add
+ * the port. Don't exit.
+ */
+ return -1;
+ }
+ }
+ virtio_serial_idx[port] = port_nr;
+ virtio_serial_set_port_active(port_nr);
+
+ if (virtsername) {
+ k = 6; /* skip ',name=' */
+
+ for (j = 0; j < VIRTIO_SERIAL_NAME_MAX_LEN && isalnum(virtsername[k]);
+ j++, k++) {
+ virtio_serial_names[port][j] = virtsername[k];
+ }
+ if (j < VIRTIO_SERIAL_NAME_MAX_LEN - 1) {
+ virtio_serial_names[port][j + 1] = 0;
+ }
+ }
+ return 0;
+}
+
int main(int argc, char **argv, char **envp)
{
const char *gdbstub_dev = NULL;
@@ -5075,6 +5152,7 @@ int main(int argc, char **argv, char **envp)
int parallel_device_index;
const char *virtio_consoles[MAX_VIRTIO_CONSOLES];
int virtio_console_index;
+ const char *virtio_serials[MAX_VIRTIO_SERIAL_PORTS];
const char *loadvm = NULL;
QEMUMachine *machine;
const char *cpu_model;
@@ -5154,6 +5232,10 @@ int main(int argc, char **argv, char **envp)
virtio_consoles[i] = NULL;
virtio_console_index = 0;
+ for (i = 0; i < MAX_VIRTIO_SERIAL_PORTS; i++)
+ virtio_serials[i] = NULL;
+ virtio_serial_index = 0;
+
for (i = 0; i < MAX_NODES; i++) {
node_mem[i] = 0;
node_cpumask[i] = 0;
@@ -5584,6 +5666,14 @@ int main(int argc, char **argv, char **envp)
virtio_consoles[virtio_console_index] = optarg;
virtio_console_index++;
break;
+ case QEMU_OPTION_virtioserial:
+ if (virtio_serial_index >= MAX_VIRTIO_SERIAL_PORTS) {
+ fprintf(stderr, "qemu: too many virtio serial ports\n");
+ exit(1);
+ }
+ virtio_serials[virtio_serial_index] = optarg;
+ virtio_serial_index++;
+ break;
case QEMU_OPTION_parallel:
if (parallel_device_index >= MAX_PARALLEL_PORTS) {
fprintf(stderr, "qemu: too many parallel ports\n");
@@ -6217,6 +6307,16 @@ int main(int argc, char **argv, char **envp)
}
}
+ for (i = 0; i < virtio_serial_index; i++) {
+ int ret;
+
+ ret = init_virtio_serial_port(i, virtio_serials[i]);
+ if (ret < 0) {
+ fprintf(stderr, "qemu: could not init virtio serial ports\n");
+ exit(1);
+ }
+ }
+
module_call_init(MODULE_INIT_DEVICE);
if (kvm_enabled())
@@ -6337,6 +6437,15 @@ int main(int argc, char **argv, char **envp)
}
}
+ for(i = 0; i < MAX_VIRTIO_SERIAL_PORTS; i++) {
+ const char *devname = virtio_serials[i];
+ if (virtio_serial_hds[i] && devname) {
+ if (strstart(devname, "vc", 0)) {
+ qemu_chr_printf(virtio_serial_hds[i], "virtio serial%d\r\n", i);
+ }
+ }
+ }
+
if (gdbstub_dev && gdbserver_start(gdbstub_dev) < 0) {
fprintf(stderr, "qemu: could not open gdbserver on device '%s'\n",
gdbstub_dev);
--
1.6.2.5
_______________________________________________
Virtualization mailing list
Virtualization@xxxxxxxxxxxxxxxxxxxxxxxxxx
https://lists.linux-foundation.org/mailman/listinfo/virtualization
