Changeset fda19b8 in mainline for uspace/lib/c/generic/async.c

Timestamp:

2018-05-31T15:41:31Z (6 years ago)

Author:

Jiří Zárevúcky <jiri.zarevucky@…>

Branches:

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

Children:

49a796f1

Parents:

fc0b2a8

git-author:

Jiří Zárevúcky <jiri.zarevucky@…> (2018-05-31 15:35:24)

git-committer:

Jiří Zárevúcky <jiri.zarevucky@…> (2018-05-31 15:41:31)

Message:

Deduplicate async_create_port().

File:

• uspace/lib/c/generic/async.c (modified) (3 diffs)

uspace/lib/c/generic/async.c

@@ -511 +511 @@
 static FIBRIL_CONDVAR_INITIALIZE(avail_phone_cv);
 
-errno_t async_create_port(iface_t iface, async_port_handler_t handler,
-    void *data, port_id_t *port_id)
-{
-        if ((iface & IFACE_MOD_MASK) == IFACE_MOD_CALLBACK)
-                return EINVAL;
-
+static errno_t async_create_port_internal(iface_t iface,
+    async_port_handler_t handler, void *data, port_id_t *port_id)
+{
         interface_t *interface;
 
@@ -543 +540 @@
 
         return EOK;
+}
+
+errno_t async_create_port(iface_t iface, async_port_handler_t handler,
+    void *data, port_id_t *port_id)
+{
+        if ((iface & IFACE_MOD_MASK) == IFACE_MOD_CALLBACK)
+                return EINVAL;
+
+        return async_create_port_internal(iface, handler, data, port_id);
 }
 
@@ -860 +866 @@
             &answer);
 
-        errno_t ret;
-        async_wait_for(req, &ret);
-        if (ret != EOK)
-                return (errno_t) ret;
+        errno_t rc;
+        async_wait_for(req, &rc);
+        if (rc != EOK)
+                return rc;
+
+        rc = async_create_port_internal(iface, handler, data, port_id);
+        if (rc != EOK)
+                return rc;
 
         sysarg_t phone_hash = IPC_GET_ARG5(answer);
-        interface_t *interface;
-
-        futex_down(&async_futex);
-
-        ht_link_t *link = hash_table_find(&interface_hash_table, &iface);
-        if (link)
-                interface = hash_table_get_inst(link, interface_t, link);
-        else
-                interface = async_new_interface(iface);
-
-        if (!interface) {
-                futex_up(&async_futex);
-                return ENOMEM;
-        }
-
-        port_t *port = async_new_port(interface, handler, data);
-        if (!port) {
-                futex_up(&async_futex);
-                return ENOMEM;
-        }
-
-        *port_id = port->id;
-
-        futex_up(&async_futex);
-
         fid_t fid = async_new_connection(answer.in_task_id, phone_hash,
             CAP_NIL, NULL, handler, data);