Changeset 7b616e2 in mainline for uspace/srv/ns/service.c

Timestamp:

2017-09-27T22:40:09Z (7 years ago)

Author:

Jiri Svoboda <jiri@…>

Branches:

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

Children:

d076f16

Parents:

8d6bcc8c

Message:

Name service should communicate using async.h.

File:

• uspace/srv/ns/service.c (modified) (5 diffs)

uspace/srv/ns/service.c

@@ -31 +31 @@
  */
 
-#include <ipc/ipc.h>
 #include <adt/hash_table.h>
 #include <assert.h>
+#include <async.h>
 #include <errno.h>
 #include <stdio.h>
@@ -47 +47 @@
         service_t service;
         
-        /** Phone registered with the interface */
-        sysarg_t phone;
-        
-        /** Incoming phone hash */
-        sysarg_t in_phone_hash;
+        /** Session to the service */
+        async_sess_t *sess;
 } hashed_service_t;
 
@@ -121 +118 @@
                 
                 hashed_service_t *hashed_service = hash_table_get_inst(link, hashed_service_t, link);
-                (void) ipc_forward_fast(pending->callid, hashed_service->phone,
-                    pending->iface, pending->arg3, 0, IPC_FF_NONE);
+                async_exch_t *exch = async_exchange_begin(hashed_service->sess);
+                async_forward_fast(pending->callid, exch, pending->iface,
+                    pending->arg3, 0, IPC_FF_NONE);
+                async_exchange_end(exch);
                 
                 list_remove(&pending->link);
@@ -151 +150 @@
         
         hashed_service->service = service;
-        hashed_service->phone = phone;
-        hashed_service->in_phone_hash = call->in_phone_hash;
+        hashed_service->sess = async_callback_receive(EXCHANGE_SERIALIZE);
+        if (hashed_service->sess == NULL)
+                return EIO;
         
         hash_table_insert(&service_hash_table, &hashed_service->link);
-        
         return EOK;
 }
@@ -202 +201 @@
         
         hashed_service_t *hashed_service = hash_table_get_inst(link, hashed_service_t, link);
-        (void) ipc_forward_fast(callid, hashed_service->phone, iface, arg3,
-            0, IPC_FF_NONE);
+        async_exch_t *exch = async_exchange_begin(hashed_service->sess);
+        async_forward_fast(callid, exch, iface, arg3, 0, IPC_FF_NONE);
+        async_exchange_end(exch);
         return;
         
 out:
-        if (!(callid & IPC_CALLID_NOTIFICATION))
-                ipc_answer_0(callid, retval);
+        async_answer_0(callid, retval);
 }