From efbf5d06a89ec7b329d2aa15d3a6ea023b63c646 Mon Sep 17 00:00:00 2001

From: Hans de Goede <hdegoede@redhat.com>

Date: Tue, 4 Sep 2012 14:18:34 +0200

Subject: [PATCH 361/365] usb-redir: Change cancelled packet code into a

 generic packet-id queue

Signed-off-by: Hans de Goede <hdegoede@redhat.com>

---

 hw/usb/redirect.c | 102 +++++++++++++++++++++++++++++++++++++-----------------

 1 file changed, 71 insertions(+), 31 deletions(-)

diff --git a/hw/usb/redirect.c b/hw/usb/redirect.c

index 9cbcddb..08776d9 100644

--- a/hw/usb/redirect.c

+++ b/hw/usb/redirect.c

@@ -43,7 +43,6 @@

 #define EP2I(ep_address) (((ep_address & 0x80) >> 3) | (ep_address & 0x0f))

 #define I2EP(i) (((i & 0x10) << 3) | (i & 0x0f))

-typedef struct Cancelled Cancelled;

 typedef struct USBRedirDevice USBRedirDevice;

 /* Struct to hold buffered packets (iso or int input packets) */

@@ -69,6 +68,18 @@ struct endp_data {

     int bufpq_target_size;

 };

+struct PacketIdQueueEntry {

+    uint64_t id;

+    QTAILQ_ENTRY(PacketIdQueueEntry)next;

+};

+

+struct PacketIdQueue {

+    USBRedirDevice *dev;

+    const char *name;

+    QTAILQ_HEAD(, PacketIdQueueEntry) head;

+    int size;

+};

+

 struct USBRedirDevice {

     USBDevice dev;

     /* Properties */

@@ -86,7 +97,7 @@ struct USBRedirDevice {

     int64_t next_attach_time;

     struct usbredirparser *parser;

     struct endp_data endpoint[MAX_ENDPOINTS];

-    QTAILQ_HEAD(, Cancelled) cancelled;

+    struct PacketIdQueue cancelled;

     /* Data for device filtering */

     struct usb_redir_device_connect_header device_info;

     struct usb_redir_interface_info_header interface_info;

@@ -94,11 +105,6 @@ struct USBRedirDevice {

     int filter_rules_count;

 };

-struct Cancelled {

-    uint64_t id;

-    QTAILQ_ENTRY(Cancelled)next;

-};

-

 static void usbredir_hello(void *priv, struct usb_redir_hello_header *h);

 static void usbredir_device_connect(void *priv,

     struct usb_redir_device_connect_header *device_connect);

@@ -249,37 +255,75 @@ static int usbredir_write(void *priv, uint8_t *data, int count)

  * Cancelled and buffered packets helpers

  */

-static void usbredir_cancel_packet(USBDevice *udev, USBPacket *p)

+static void packet_id_queue_init(struct PacketIdQueue *q,

+    USBRedirDevice *dev, const char *name)

 {

-    USBRedirDevice *dev = DO_UPCAST(USBRedirDevice, dev, udev);

-    Cancelled *c;

+    q->dev = dev;

+    q->name = name;

+    QTAILQ_INIT(&q->head);

+    q->size = 0;

+}

+

+static void packet_id_queue_add(struct PacketIdQueue *q, uint64_t id)

+{

+    USBRedirDevice *dev = q->dev;

+    struct PacketIdQueueEntry *e;

+

+    DPRINTF("adding packet id %"PRIu64" to %s queue\n", id, q->name);

+

+    e = g_malloc0(sizeof(struct PacketIdQueueEntry));

+    e->id = id;

+    QTAILQ_INSERT_TAIL(&q->head, e, next);

+    q->size++;

+}

+

+static int packet_id_queue_remove(struct PacketIdQueue *q, uint64_t id)

+{

+    USBRedirDevice *dev = q->dev;

+    struct PacketIdQueueEntry *e;

+

+    QTAILQ_FOREACH(e, &q->head, next) {

+        if (e->id == id) {

+            DPRINTF("removing packet id %"PRIu64" from %s queue\n",

+                    id, q->name);

+            QTAILQ_REMOVE(&q->head, e, next);

+            q->size--;

+            g_free(e);

+            return 1;

+        }

+    }

+    return 0;

+}

+

+static void packet_id_queue_empty(struct PacketIdQueue *q)

+{

+    USBRedirDevice *dev = q->dev;

+    struct PacketIdQueueEntry *e, *next_e;

-    DPRINTF("cancel packet id %"PRIu64"\n", p->id);

+    DPRINTF("removing %d packet-ids from %s queue\n", q->size, q->name);

-    c = g_malloc0(sizeof(Cancelled));

-    c->id = p->id;

-    QTAILQ_INSERT_TAIL(&dev->cancelled, c, next);

+    QTAILQ_FOREACH_SAFE(e, &q->head, next, next_e) {

+        QTAILQ_REMOVE(&q->head, e, next);

+        g_free(e);

+    }

+    q->size = 0;

+}

+static void usbredir_cancel_packet(USBDevice *udev, USBPacket *p)

+{

+    USBRedirDevice *dev = DO_UPCAST(USBRedirDevice, dev, udev);

+

+    packet_id_queue_add(&dev->cancelled, p->id);

     usbredirparser_send_cancel_data_packet(dev->parser, p->id);

     usbredirparser_do_write(dev->parser);

 }

 static int usbredir_is_cancelled(USBRedirDevice *dev, uint64_t id)

 {

-    Cancelled *c;

-

     if (!dev->dev.attached) {

         return 1; /* Treat everything as cancelled after a disconnect */

     }

-

-    QTAILQ_FOREACH(c, &dev->cancelled, next) {

-        if (c->id == id) {

-            QTAILQ_REMOVE(&dev->cancelled, c, next);

-            g_free(c);

-            return 1;

-        }

-    }

-    return 0;

+    return packet_id_queue_remove(&dev->cancelled, id);

 }

 static USBPacket *usbredir_find_packet_by_id(USBRedirDevice *dev,

@@ -942,7 +986,7 @@ static int usbredir_initfn(USBDevice *udev)

     dev->chardev_close_bh = qemu_bh_new(usbredir_chardev_close_bh, dev);

     dev->attach_timer = qemu_new_timer_ms(vm_clock, usbredir_do_attach, dev);

-    QTAILQ_INIT(&dev->cancelled);

+    packet_id_queue_init(&dev->cancelled, dev, "cancelled");

     for (i = 0; i < MAX_ENDPOINTS; i++) {

         QTAILQ_INIT(&dev->endpoint[i].bufpq);

     }

@@ -960,13 +1004,9 @@ static int usbredir_initfn(USBDevice *udev)

 static void usbredir_cleanup_device_queues(USBRedirDevice *dev)

 {

-    Cancelled *c, *next_c;

     int i;

-    QTAILQ_FOREACH_SAFE(c, &dev->cancelled, next, next_c) {

-        QTAILQ_REMOVE(&dev->cancelled, c, next);

-        g_free(c);

-    }

+    packet_id_queue_empty(&dev->cancelled);

     for (i = 0; i < MAX_ENDPOINTS; i++) {

         usbredir_free_bufpq(dev, I2EP(i));

     }

-- 

1.7.12