Changes in uspace/srv/devmap/devmap.c [79ae36dd:4ae90f9] in mainline

File:

• uspace/srv/devmap/devmap.c (modified) (9 diffs)

uspace/srv/devmap/devmap.c

@@ -37 +37 @@
 
 #include <ipc/services.h>
-#include <ns.h>
+#include <ipc/ns.h>
 #include <async.h>
 #include <stdio.h>
@@ -59 +59 @@
         /** Pointers to previous and next drivers in linked list */
         link_t drivers;
-        
         /** Pointer to the linked list of devices controlled by this driver */
         link_t devices;
-        
-        /** Session asociated with this driver */
-        async_sess_t *sess;
-        
+        /** Phone asociated with this driver */
+        sysarg_t phone;
         /** Device driver name */
         char *name;
-        
         /** Fibril mutex for list of devices owned by this driver */
         fibril_mutex_t devices_mutex;
@@ -79 +75 @@
         /** Pointer to the previous and next device in the list of all namespaces */
         link_t namespaces;
-        
         /** Unique namespace identifier */
         devmap_handle_t handle;
-        
         /** Namespace name */
         char *name;
-        
         /** Reference count */
         size_t refcnt;
@@ -412 +405 @@
          * Create connection to the driver
          */
-        driver->sess = async_callback_receive(EXCHANGE_SERIALIZE);
-        if (!driver->sess) {
+        ipc_call_t call;
+        ipc_callid_t callid = async_get_call(&call);
+        
+        if (IPC_GET_IMETHOD(call) != IPC_M_CONNECT_TO_ME) {
                 free(driver->name);
                 free(driver);
+                async_answer_0(callid, ENOTSUP);
                 async_answer_0(iid, ENOTSUP);
                 return NULL;
         }
+        
+        driver->phone = IPC_GET_ARG5(call);
+        async_answer_0(callid, EOK);
         
         /*
@@ -463 +462 @@
         fibril_mutex_lock(&drivers_list_mutex);
         
-        if (driver->sess)
-                async_hangup(driver->sess);
+        if (driver->phone != 0)
+                async_hangup(driver->phone);
         
         /* Remove it from list of drivers */
@@ -608 +607 @@
         devmap_device_t *dev = devmap_device_find_handle(handle);
         
-        if ((dev == NULL) || (dev->driver == NULL) || (!dev->driver->sess)) {
+        if ((dev == NULL) || (dev->driver == NULL) || (dev->driver->phone == 0)) {
                 fibril_mutex_unlock(&devices_list_mutex);
                 async_answer_0(callid, ENOENT);
@@ -614 +613 @@
         }
         
-        async_exch_t *exch = async_exchange_begin(dev->driver->sess);
-        
-        if (dev->forward_interface == 0)
-                async_forward_fast(callid, exch, dev->handle, 0, 0, IPC_FF_NONE);
-        else
-                async_forward_fast(callid, exch, dev->forward_interface,
-                    dev->handle, 0, IPC_FF_NONE);
-        
-        async_exchange_end(exch);
+        if (dev->forward_interface == 0) {
+                async_forward_fast(callid, dev->driver->phone,
+                    dev->handle, 0, 0,
+                    IPC_FF_NONE);
+        } else {
+                async_forward_fast(callid, dev->driver->phone,
+                    dev->forward_interface, dev->handle, 0,
+                    IPC_FF_NONE);
+        }
         
         fibril_mutex_unlock(&devices_list_mutex);
@@ -1030 +1029 @@
                 return;
         
-        while (true) {
+        bool cont = true;
+        while (cont) {
                 ipc_call_t call;
                 ipc_callid_t callid = async_get_call(&call);
                 
-                if (!IPC_GET_IMETHOD(call))
-                        break;
-                
                 switch (IPC_GET_IMETHOD(call)) {
+                case IPC_M_PHONE_HUNGUP:
+                        cont = false;
+                        continue;
                 case DEVMAP_DRIVER_UNREGISTER:
                         if (NULL == driver)
@@ -1080 +1080 @@
         async_answer_0(iid, EOK);
         
-        while (true) {
+        bool cont = true;
+        while (cont) {
                 ipc_call_t call;
                 ipc_callid_t callid = async_get_call(&call);
                 
-                if (!IPC_GET_IMETHOD(call))
-                        break;
-                
                 switch (IPC_GET_IMETHOD(call)) {
+                case IPC_M_PHONE_HUNGUP:
+                        cont = false;
+                        continue;
                 case DEVMAP_DEVICE_GET_HANDLE:
                         devmap_device_get_handle(callid, &call);