Changeset 9b1baac in mainline for uspace/lib/c/generic/ns.c

Timestamp:

2018-07-18T08:35:42Z (7 years ago)

Author:

Martin Decky <martin@…>

Branches:

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

Children:

0b05082

Parents:

edc64c0

Message:

ns: register service interfaces individually

Each service interface is now registered individually with the naming
service. This adds a degree of type safety, potentially allows the
individual interfaces to be implemented by independent tasks and moves
the code slightly closer to the full-fledged ports design.

Broker services (e.g. the location service) can still register a
fallback port for receiving connections to all interface types
explicitly using service_register_broker().

File:

• uspace/lib/c/generic/ns.c (modified) (2 diffs)

uspace/lib/c/generic/ns.c

@@ -46 +46 @@
 static async_sess_t *sess_ns = NULL;
 
-errno_t service_register(service_t service)
-{
-        errno_t retval;
+errno_t service_register(service_t service, iface_t iface,
+    async_port_handler_t handler, void *data)
+{
+        async_sess_t *sess = ns_session_get();
+        if (sess == NULL)
+                return EIO;
+
+        port_id_t port;
+        errno_t rc = async_create_port(iface, handler, data, &port);
+        if (rc != EOK)
+                return rc;
+
+        async_exch_t *exch = async_exchange_begin(sess);
+
         ipc_call_t answer;
-
-        async_sess_t *sess = ns_session_get();
-        if (sess == NULL)
-                return EIO;
-
-        async_exch_t *exch = async_exchange_begin(sess);
-        aid_t req = async_send_1(exch, NS_REGISTER, service, &answer);
-        errno_t rc = async_connect_to_me(exch, 0, service, 0);
+        aid_t req = async_send_2(exch, NS_REGISTER, service, iface, &answer);
+        rc = async_connect_to_me(exch, iface, service, 0);
 
         async_exchange_end(exch);
@@ -66 +71 @@
         }
 
+        errno_t retval;
+        async_wait_for(req, &retval);
+        return rc;
+}
+
+errno_t service_register_broker(service_t service, async_port_handler_t handler,
+    void *data)
+{
+        async_set_fallback_port_handler(handler, data);
+
+        async_sess_t *sess = ns_session_get();
+        if (sess == NULL)
+                return EIO;
+
+        async_exch_t *exch = async_exchange_begin(sess);
+
+        ipc_call_t answer;
+        aid_t req = async_send_1(exch, NS_REGISTER_BROKER, service, &answer);
+        errno_t rc = async_connect_to_me(exch, INTERFACE_ANY, service, 0);
+
+        async_exchange_end(exch);
+
+        if (rc != EOK) {
+                async_forget(req);
+                return rc;
+        }
+
+        errno_t retval;
         async_wait_for(req, &retval);
         return rc;