5544c1b
From b89a0cc1ec9dbe30cbe002f12d487a52950da166 Mon Sep 17 00:00:00 2001
c8dfc65
From: Hans de Goede <hdegoede@redhat.com>
c8dfc65
Date: Thu, 23 Aug 2012 16:37:19 +0200
5544c1b
Subject: [PATCH] usb-redir: Don't delay handling of open events to a bottom
5544c1b
 half
c8dfc65
c8dfc65
There is no need for this, and doing so means that a backend trying to
c8dfc65
write immediately after an open event will see qemu_chr_be_can_write
c8dfc65
returning 0, which not all backends handle well as there is no wakeup
c8dfc65
mechanism to detect when the frontend does become writable.
c8dfc65
c8dfc65
Signed-off-by: Hans de Goede <hdegoede@redhat.com>
c8dfc65
Signed-off-by: Gerd Hoffmann <kraxel@redhat.com>
5544c1b
(cherry picked from commit ed9873bfbf145c084d039baab08c63b9d67e7bd3)
5544c1b
5544c1b
Signed-off-by: Michael Roth <mdroth@linux.vnet.ibm.com>
c8dfc65
---
c8dfc65
 hw/usb/redirect.c | 100 +++++++++++++++++++++++++++++-------------------------
c8dfc65
 1 file changed, 53 insertions(+), 47 deletions(-)
c8dfc65
c8dfc65
diff --git a/hw/usb/redirect.c b/hw/usb/redirect.c
5544c1b
index 7f3719b..5cc3334 100644
c8dfc65
--- a/hw/usb/redirect.c
c8dfc65
+++ b/hw/usb/redirect.c
c8dfc65
@@ -79,8 +79,8 @@ struct USBRedirDevice {
c8dfc65
     /* Data passed from chardev the fd_read cb to the usbredirparser read cb */
c8dfc65
     const uint8_t *read_buf;
c8dfc65
     int read_buf_size;
c8dfc65
-    /* For async handling of open/close */
c8dfc65
-    QEMUBH *open_close_bh;
c8dfc65
+    /* For async handling of close */
c8dfc65
+    QEMUBH *chardev_close_bh;
c8dfc65
     /* To delay the usb attach in case of quick chardev close + open */
c8dfc65
     QEMUTimer *attach_timer;
c8dfc65
     int64_t next_attach_time;
5544c1b
@@ -784,18 +784,11 @@ static int usbredir_handle_control(USBDevice *udev, USBPacket *p,
c8dfc65
  * from within the USBDevice data / control packet callbacks and doing a
c8dfc65
  * usb_detach from within these callbacks is not a good idea.
c8dfc65
  *
c8dfc65
- * So we use a bh handler to take care of close events. We also handle
c8dfc65
- * open events from this callback to make sure that a close directly followed
c8dfc65
- * by an open gets handled in the right order.
c8dfc65
+ * So we use a bh handler to take care of close events.
c8dfc65
  */
c8dfc65
-static void usbredir_open_close_bh(void *opaque)
c8dfc65
+static void usbredir_chardev_close_bh(void *opaque)
c8dfc65
 {
c8dfc65
     USBRedirDevice *dev = opaque;
c8dfc65
-    uint32_t caps[USB_REDIR_CAPS_SIZE] = { 0, };
c8dfc65
-    char version[32];
c8dfc65
-
c8dfc65
-    strcpy(version, "qemu usb-redir guest ");
c8dfc65
-    pstrcat(version, sizeof(version), qemu_get_version());
c8dfc65
 
c8dfc65
     usbredir_device_disconnect(dev);
c8dfc65
 
5544c1b
@@ -803,36 +796,47 @@ static void usbredir_open_close_bh(void *opaque)
c8dfc65
         usbredirparser_destroy(dev->parser);
c8dfc65
         dev->parser = NULL;
c8dfc65
     }
c8dfc65
+}
c8dfc65
 
c8dfc65
-    if (dev->cs->opened) {
c8dfc65
-        dev->parser = qemu_oom_check(usbredirparser_create());
c8dfc65
-        dev->parser->priv = dev;
c8dfc65
-        dev->parser->log_func = usbredir_log;
c8dfc65
-        dev->parser->read_func = usbredir_read;
c8dfc65
-        dev->parser->write_func = usbredir_write;
c8dfc65
-        dev->parser->hello_func = usbredir_hello;
c8dfc65
-        dev->parser->device_connect_func = usbredir_device_connect;
c8dfc65
-        dev->parser->device_disconnect_func = usbredir_device_disconnect;
c8dfc65
-        dev->parser->interface_info_func = usbredir_interface_info;
c8dfc65
-        dev->parser->ep_info_func = usbredir_ep_info;
c8dfc65
-        dev->parser->configuration_status_func = usbredir_configuration_status;
c8dfc65
-        dev->parser->alt_setting_status_func = usbredir_alt_setting_status;
c8dfc65
-        dev->parser->iso_stream_status_func = usbredir_iso_stream_status;
c8dfc65
-        dev->parser->interrupt_receiving_status_func =
c8dfc65
-            usbredir_interrupt_receiving_status;
c8dfc65
-        dev->parser->bulk_streams_status_func = usbredir_bulk_streams_status;
c8dfc65
-        dev->parser->control_packet_func = usbredir_control_packet;
c8dfc65
-        dev->parser->bulk_packet_func = usbredir_bulk_packet;
c8dfc65
-        dev->parser->iso_packet_func = usbredir_iso_packet;
c8dfc65
-        dev->parser->interrupt_packet_func = usbredir_interrupt_packet;
c8dfc65
-        dev->read_buf = NULL;
c8dfc65
-        dev->read_buf_size = 0;
c8dfc65
+static void usbredir_chardev_open(USBRedirDevice *dev)
c8dfc65
+{
c8dfc65
+    uint32_t caps[USB_REDIR_CAPS_SIZE] = { 0, };
c8dfc65
+    char version[32];
c8dfc65
 
c8dfc65
-        usbredirparser_caps_set_cap(caps, usb_redir_cap_connect_device_version);
c8dfc65
-        usbredirparser_caps_set_cap(caps, usb_redir_cap_filter);
c8dfc65
-        usbredirparser_init(dev->parser, version, caps, USB_REDIR_CAPS_SIZE, 0);
c8dfc65
-        usbredirparser_do_write(dev->parser);
c8dfc65
-    }
c8dfc65
+    /* Make sure any pending closes are handled (no-op if none pending) */
c8dfc65
+    usbredir_chardev_close_bh(dev);
c8dfc65
+    qemu_bh_cancel(dev->chardev_close_bh);
c8dfc65
+
c8dfc65
+    strcpy(version, "qemu usb-redir guest ");
c8dfc65
+    pstrcat(version, sizeof(version), qemu_get_version());
c8dfc65
+
c8dfc65
+    dev->parser = qemu_oom_check(usbredirparser_create());
c8dfc65
+    dev->parser->priv = dev;
c8dfc65
+    dev->parser->log_func = usbredir_log;
c8dfc65
+    dev->parser->read_func = usbredir_read;
c8dfc65
+    dev->parser->write_func = usbredir_write;
c8dfc65
+    dev->parser->hello_func = usbredir_hello;
c8dfc65
+    dev->parser->device_connect_func = usbredir_device_connect;
c8dfc65
+    dev->parser->device_disconnect_func = usbredir_device_disconnect;
c8dfc65
+    dev->parser->interface_info_func = usbredir_interface_info;
c8dfc65
+    dev->parser->ep_info_func = usbredir_ep_info;
c8dfc65
+    dev->parser->configuration_status_func = usbredir_configuration_status;
c8dfc65
+    dev->parser->alt_setting_status_func = usbredir_alt_setting_status;
c8dfc65
+    dev->parser->iso_stream_status_func = usbredir_iso_stream_status;
c8dfc65
+    dev->parser->interrupt_receiving_status_func =
c8dfc65
+        usbredir_interrupt_receiving_status;
c8dfc65
+    dev->parser->bulk_streams_status_func = usbredir_bulk_streams_status;
c8dfc65
+    dev->parser->control_packet_func = usbredir_control_packet;
c8dfc65
+    dev->parser->bulk_packet_func = usbredir_bulk_packet;
c8dfc65
+    dev->parser->iso_packet_func = usbredir_iso_packet;
c8dfc65
+    dev->parser->interrupt_packet_func = usbredir_interrupt_packet;
c8dfc65
+    dev->read_buf = NULL;
c8dfc65
+    dev->read_buf_size = 0;
c8dfc65
+
c8dfc65
+    usbredirparser_caps_set_cap(caps, usb_redir_cap_connect_device_version);
c8dfc65
+    usbredirparser_caps_set_cap(caps, usb_redir_cap_filter);
c8dfc65
+    usbredirparser_init(dev->parser, version, caps, USB_REDIR_CAPS_SIZE, 0);
c8dfc65
+    usbredirparser_do_write(dev->parser);
c8dfc65
 }
c8dfc65
 
c8dfc65
 static void usbredir_do_attach(void *opaque)
5544c1b
@@ -856,13 +860,13 @@ static int usbredir_chardev_can_read(void *opaque)
c8dfc65
 {
c8dfc65
     USBRedirDevice *dev = opaque;
c8dfc65
 
c8dfc65
-    if (dev->parser) {
c8dfc65
-        /* usbredir_parser_do_read will consume *all* data we give it */
c8dfc65
-        return 1024 * 1024;
c8dfc65
-    } else {
c8dfc65
-        /* usbredir_open_close_bh hasn't handled the open event yet */
c8dfc65
+    if (!dev->parser) {
c8dfc65
+        WARNING("chardev_can_read called on non open chardev!\n");
c8dfc65
         return 0;
c8dfc65
     }
c8dfc65
+
c8dfc65
+    /* usbredir_parser_do_read will consume *all* data we give it */
c8dfc65
+    return 1024 * 1024;
c8dfc65
 }
c8dfc65
 
c8dfc65
 static void usbredir_chardev_read(void *opaque, const uint8_t *buf, int size)
5544c1b
@@ -886,8 +890,10 @@ static void usbredir_chardev_event(void *opaque, int event)
c8dfc65
 
c8dfc65
     switch (event) {
c8dfc65
     case CHR_EVENT_OPENED:
c8dfc65
+        usbredir_chardev_open(dev);
c8dfc65
+        break;
c8dfc65
     case CHR_EVENT_CLOSED:
c8dfc65
-        qemu_bh_schedule(dev->open_close_bh);
c8dfc65
+        qemu_bh_schedule(dev->chardev_close_bh);
c8dfc65
         break;
c8dfc65
     }
c8dfc65
 }
5544c1b
@@ -917,7 +923,7 @@ static int usbredir_initfn(USBDevice *udev)
c8dfc65
         }
c8dfc65
     }
c8dfc65
 
c8dfc65
-    dev->open_close_bh = qemu_bh_new(usbredir_open_close_bh, dev);
c8dfc65
+    dev->chardev_close_bh = qemu_bh_new(usbredir_chardev_close_bh, dev);
c8dfc65
     dev->attach_timer = qemu_new_timer_ms(vm_clock, usbredir_do_attach, dev);
c8dfc65
 
c8dfc65
     QTAILQ_INIT(&dev->asyncq);
5544c1b
@@ -957,7 +963,7 @@ static void usbredir_handle_destroy(USBDevice *udev)
c8dfc65
     qemu_chr_fe_close(dev->cs);
c8dfc65
     qemu_chr_delete(dev->cs);
c8dfc65
     /* Note must be done after qemu_chr_close, as that causes a close event */
c8dfc65
-    qemu_bh_delete(dev->open_close_bh);
c8dfc65
+    qemu_bh_delete(dev->chardev_close_bh);
c8dfc65
 
c8dfc65
     qemu_del_timer(dev->attach_timer);
c8dfc65
     qemu_free_timer(dev->attach_timer);