Changeset a94cbfa in mainline for uspace/drv/bus/usb/ehci/ehci_rh.c

Timestamp:

2018-01-26T00:55:38Z (7 years ago)

Author:

Ondřej Hlavatý <aearsis@…>

Branches:

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

Children:

77733a9

Parents:

047fbc8

git-author:

Ondřej Hlavatý <aearsis@…> (2018-01-26 00:15:17)

git-committer:

Ondřej Hlavatý <aearsis@…> (2018-01-26 00:55:38)

Message:

ehci+ohci: proper handling of unfinished transfer

Because transfers can be aborted, the RH may not store a pointer to
them. Also, it's no longer true that the batch automatically locks the
endpoint, the mechanism must be used explicitly.

File:

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

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

@@ -127 +127 @@
 
         ehci_rh_hub_desc_init(instance, EHCI_RD(caps->hcsparams));
-        instance->unfinished_interrupt_transfer = NULL;
+        instance->status_change_endpoint = NULL;
 
         return virthub_base_init(&instance->base, name, &ops, instance,
@@ -150 +150 @@
                 usb_log_debug("RH(%p): BATCH(%p) adding as unfinished",
                     instance, batch);
-                /* This is safe because only status change interrupt transfers
-                 * return NAK. The assertion holds true because the batch
-                 * existence prevents communication with that ep */
-                assert(instance->unfinished_interrupt_transfer == NULL);
-                instance->unfinished_interrupt_transfer = batch;
+
+                /* Lock the HC guard */
+                fibril_mutex_lock(batch->ep->guard);
+                const int err = endpoint_activate_locked(batch->ep, batch);
+                if (err) {
+                        fibril_mutex_unlock(batch->ep->guard);
+                        return err;
+                }
+
+                /*
+                 * Asserting that the HC do not run two instances of the status
+                 * change endpoint - shall be true.
+                 */
+                assert(!instance->status_change_endpoint);
+
+                endpoint_add_ref(batch->ep);
+                instance->status_change_endpoint = batch->ep;
+                fibril_mutex_unlock(batch->ep->guard);
         } else {
                 usb_log_debug("RH(%p): BATCH(%p) virtual request complete: %s",
@@ -172 +185 @@
 int ehci_rh_interrupt(ehci_rh_t *instance)
 {
-        //TODO atomic swap needed
-        usb_transfer_batch_t *batch = instance->unfinished_interrupt_transfer;
-        instance->unfinished_interrupt_transfer = NULL;
-        usb_log_debug2("RH(%p): Interrupt. Processing batch: %p",
-            instance, batch);
+        endpoint_t *ep = instance->status_change_endpoint;
+        if (!ep)
+                return EOK;
+
+        fibril_mutex_lock(ep->guard);
+        usb_transfer_batch_t * const batch = ep->active_batch;
+        endpoint_deactivate_locked(ep);
+        instance->status_change_endpoint = NULL;
+        fibril_mutex_unlock(ep->guard);
+
+        endpoint_del_ref(ep);
+
         if (batch) {
+                usb_log_debug2("RH(%p): Interrupt. Processing batch: %p",
+                    instance, batch);
                 batch->error = virthub_base_request(&instance->base, batch->target,
                     batch->dir, (void*) batch->setup.buffer,