Changeset 327f147 in mainline for uspace/lib/drv/generic/remote_usb.c

Timestamp:

2017-10-23T19:03:37Z (7 years ago)

Author:

Ondřej Hlavatý <aearsis@…>

Branches:

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

Children:

b724494

Parents:

e160bfe8

Message:

usbhost: change parameters of methods

Pass (device_t, usb_target_t) to read and write, which finally allows to drop hash tables and access device right away. Then, all callbacks to complete transfer now uses usb_transfer_batch. This requires libdrv to include libusbhost, but it is not linked against it - it is there only to share definition of usb_transfer_batch_t.

File:

• uspace/lib/drv/generic/remote_usb.c (modified) (4 diffs)

uspace/lib/drv/generic/remote_usb.c

@@ -38 +38 @@
 #include <errno.h>
 #include <devman.h>
+#include <usb/host/usb_transfer_batch.h>
 
 #include "usb_iface.h"
@@ -539 +540 @@
 }
 
-static void callback_out(int outcome, void *arg)
-{
-        async_transaction_t *trans = arg;
-
-        async_answer_0(trans->caller, outcome);
+static int callback_out(usb_transfer_batch_t *batch)
+{
+        async_transaction_t *trans = batch->on_complete_data;
+
+        const int err = async_answer_0(trans->caller, batch->error);
 
         async_transaction_destroy(trans);
-}
-
-static void callback_in(int outcome, size_t actual_size, void *arg)
-{
-        async_transaction_t *trans = (async_transaction_t *)arg;
-
-        if (outcome != EOK) {
-                async_answer_0(trans->caller, outcome);
-                if (trans->data_caller) {
+
+        return err;
+}
+
+static int callback_in(usb_transfer_batch_t *batch)
+{
+        async_transaction_t *trans = batch->on_complete_data;
+
+        if (trans->data_caller) {
+                if (batch->error == EOK) {
+                        batch->error = async_data_read_finalize(trans->data_caller,
+                            trans->buffer, batch->transfered_size);
+                } else {
                         async_answer_0(trans->data_caller, EINTR);
                 }
-                async_transaction_destroy(trans);
-                return;
-        }
-
-        if (trans->data_caller) {
-                async_data_read_finalize(trans->data_caller,
-                    trans->buffer, actual_size);
-        }
-
-        async_answer_0(trans->caller, EOK);
-
+        }
+
+        const int err = async_answer_0(trans->caller, batch->error);
         async_transaction_destroy(trans);
+        return err;
 }
 
@@ -611 +609 @@
         }
 
+        const usb_target_t target = {{
+                /* .address is initialized by read itself */
+                .endpoint = ep,
+        }};
+
         const int rc = usb_iface->read(
-            fun, ep, setup, trans->buffer, size, callback_in, trans);
+            fun, target, setup, trans->buffer, size, callback_in, trans);
 
         if (rc != EOK) {
@@ -659 +662 @@
         }
 
+        const usb_target_t target = {{
+                /* .address is initialized by write itself */
+                .endpoint = ep,
+        }};
+
         const int rc = usb_iface->write(
-            fun, ep, setup, trans->buffer, size, callback_out, trans);
+            fun, target, setup, trans->buffer, size, callback_out, trans);
 
         if (rc != EOK) {