Changeset ca48672 in mainline for uspace/lib/c/generic

Timestamp:

2025-06-20T15:18:27Z (4 weeks ago)

Author:

Jiri Svoboda <jiri@…>

Branches:

master

Children:

cb20b05

Parents:

3951046

Message:

loc_service_register() needs to take a port ID argument.

Location:

uspace/lib/c/generic

Files:

• async/ports.c (modified) (4 diffs)
• loc.c (modified) (2 diffs)
• ns.c (modified) (3 diffs)

uspace/lib/c/generic/async/ports.c

@@ -197 +197 @@
 }
 
+static bool destroy_if(ht_link_t *link, void *arg)
+{
+        port_t *port = (port_t *)arg;
+
+        hash_table_remove_item(&port->interface_hash_table, link);
+        return false;
+}
+
+static void async_delete_port(port_t *port)
+{
+        /* Destroy interfaces */
+        hash_table_apply(&port->interface_hash_table, destroy_if, NULL);
+
+        hash_table_destroy(&port->interface_hash_table);
+        free(port);
+}
+
 errno_t async_create_port_internal(iface_t iface, async_port_handler_t handler,
     void *data, port_id_t *port_id)
@@ -212 +229 @@
         interface = async_new_interface(port, iface, handler, data);
         if (interface == NULL) {
-                // XXX delete port
+                async_delete_port(port);
                 fibril_rmutex_unlock(&port_mutex);
                 return ENOMEM;
@@ -218 +235 @@
 
         *port_id = port->id;
+        fibril_rmutex_unlock(&port_mutex);
+        return EOK;
+}
+
+errno_t async_port_create_interface(port_id_t port_id, iface_t iface,
+    async_port_handler_t handler, void *data)
+{
+        ht_link_t *link;
+        port_t *port;
+        interface_t *interface;
+
+        fibril_rmutex_lock(&port_mutex);
+        link = hash_table_find(&port_hash_table, &port_id);
+        assert(link != NULL);
+        port = hash_table_get_inst(link, port_t, link);
+
+        interface = async_new_interface(port, iface, handler, data);
+        if (interface == NULL) {
+                fibril_rmutex_unlock(&port_mutex);
+                return ENOMEM;
+        }
+
         fibril_rmutex_unlock(&port_mutex);
         return EOK;
@@ -306 +345 @@
 }
 
+void async_port_destroy(port_id_t port_id)
+{
+        ht_link_t *link;
+        port_t *port;
+
+        fibril_rmutex_lock(&port_mutex);
+        link = hash_table_find(&port_hash_table, &port_id);
+        assert(link != NULL);
+        port = hash_table_get_inst(link, port_t, link);
+        async_delete_port(port);
+        fibril_rmutex_unlock(&port_mutex);
+}
+
 /** Initialize the async framework ports.
  *

uspace/lib/c/generic/loc.c

@@ -1 +1 @@
 /*
- * Copyright (c) 2023 Jiri Svoboda
+ * Copyright (c) 2025 Jiri Svoboda
  * Copyright (c) 2007 Josef Cejka
  * All rights reserved.
@@ -258 +258 @@
  * @param srv Server object
  * @param fqsn Fully qualified service name
+ * @param portid ID of port providing the service
  * @param sid  Service ID of new service
  *
  */
 errno_t loc_service_register(loc_srv_t *srv, const char *fqsn,
-    service_id_t *sid)
+    port_id_t portid, service_id_t *sid)
 {
         async_exch_t *exch = async_exchange_begin(srv->sess);
         ipc_call_t answer;
-        aid_t req = async_send_0(exch, LOC_SERVICE_REGISTER, &answer);
+        aid_t req = async_send_1(exch, LOC_SERVICE_REGISTER, portid, &answer);
         errno_t retval = async_data_write_start(exch, fqsn, str_size(fqsn));
 

uspace/lib/c/generic/ns.c

@@ -1 +1 @@
 /*
+ * Copyright (c) 2025 Jiri Svoboda
  * Copyright (c) 2011 Martin Decky
  * All rights reserved.
@@ -68 +69 @@
 
         if (rc != EOK) {
+                async_port_destroy(port);
                 async_forget(req);
                 return rc;
@@ -74 +76 @@
         errno_t retval;
         async_wait_for(req, &retval);
+
+        if (rc != EOK)
+                async_port_destroy(port);
         return rc;
 }