Changeset e9c5bd9 in mainline for uspace/drv/bus/usb/ehci/hc.c

Timestamp:

2014-01-25T07:10:04Z (10 years ago)

Author:

Jan Vesely <jano.vesely@…>

Branches:

lfn, master, serial, ticket/834-toolchain-update, topic/msim-upgrade, topic/simplify-dev-export

Children:

44b9b44

Parents:

23e5471

Message:

ehci: plug in scheduling.

File:

• uspace/drv/bus/usb/ehci/hc.c (modified) (3 diffs)

uspace/drv/bus/usb/ehci/hc.c

@@ -47 +47 @@
 
 //#include "ehci_endpoint.h"
-//#include "ehci_batch.h"
+#include "ehci_batch.h"
 #include "utils/malloc32.h"
 
@@ -280 +280 @@
         /* Check for root hub communication */
         if (batch->ep->address == ehci_rh_get_address(&instance->rh)) {
-                usb_log_debug("EHCI root hub request.\n");
                 return ehci_rh_schedule(&instance->rh, batch);
         }
-        return ENOTSUP;
+        ehci_transfer_batch_t *ehci_batch = ehci_transfer_batch_get(batch);
+        if (!ehci_batch)
+                return ENOMEM;
+
+        fibril_mutex_lock(&instance->guard);
+        list_append(&ehci_batch->link, &instance->pending_batches);
+        ehci_transfer_batch_commit(ehci_batch);
+
+        fibril_mutex_unlock(&instance->guard);
+        return EOK;
 }
 
@@ -303 +311 @@
                 fibril_condvar_signal(&instance->async_doorbell);
         }
+        if (status & (USB_STS_IRQ_FLAG | USB_STS_ERR_IRQ_FLAG)) {
+                fibril_mutex_lock(&instance->guard);
+
+                link_t *current = list_first(&instance->pending_batches);
+                while (current && current != &instance->pending_batches.head) {
+                        link_t *next = current->next;
+                        ehci_transfer_batch_t *batch =
+                            ehci_transfer_batch_from_link(current);
+
+                        if (ehci_transfer_batch_is_complete(batch)) {
+                                list_remove(current);
+                                ehci_transfer_batch_finish_dispose(batch);
+                        }
+                        current = next;
+                }
+                fibril_mutex_unlock(&instance->guard);
+        }
+
 }