Changes in uspace/srv/fs/devfs/devfs_ops.c [79ae36dd:cfd630af] in mainline

File:

• uspace/srv/fs/devfs/devfs_ops.c (modified) (12 diffs)

uspace/srv/fs/devfs/devfs_ops.c

@@ -59 +59 @@
 typedef struct {
         devmap_handle_t handle;
-        async_sess_t *sess;       /**< If NULL, the structure is incomplete. */
+        int phone;              /**< When < 0, the structure is incomplete. */
         size_t refcount;
         link_t link;
-        fibril_condvar_t cv;      /**< Broadcast when completed. */
+        fibril_condvar_t cv;    /**< Broadcast when completed. */
 } device_t;
 
@@ -232 +232 @@
                 };
                 link_t *lnk;
-                
+
                 fibril_mutex_lock(&devices_mutex);
 restart:
@@ -244 +244 @@
                         
                         dev->handle = node->handle;
-                        
-                        /* Mark as incomplete */
-                        dev->sess = NULL;
+                        dev->phone = -1;        /* mark as incomplete */
                         dev->refcount = 1;
                         fibril_condvar_initialize(&dev->cv);
-                        
+
                         /*
                          * Insert the incomplete device structure so that other
@@ -256 +254 @@
                          */
                         hash_table_insert(&devices, key, &dev->link);
-                        
+
                         /*
                          * Drop the mutex to allow recursive devfs requests.
                          */
                         fibril_mutex_unlock(&devices_mutex);
-                        
-                        async_sess_t *sess = devmap_device_connect(EXCHANGE_SERIALIZE,
-                            node->handle, 0);
-                        
+
+                        int phone = devmap_device_connect(node->handle, 0);
+
                         fibril_mutex_lock(&devices_mutex);
-                        
+
                         /*
                          * Notify possible waiters about this device structure
@@ -272 +269 @@
                          */
                         fibril_condvar_broadcast(&dev->cv);
-                        
-                        if (!sess) {
+
+                        if (phone < 0) {
                                 /*
                                  * Connecting failed, need to remove the
@@ -280 +277 @@
                                 hash_table_remove(&devices, key, DEVICES_KEYS);
                                 fibril_mutex_unlock(&devices_mutex);
-                                
+
                                 return ENOENT;
                         }
                         
-                        /* Set the correct session. */
-                        dev->sess = sess;
+                        /* Set the correct phone. */
+                        dev->phone = phone;
                 } else {
                         device_t *dev = hash_table_get_instance(lnk, device_t, link);
-                        
-                        if (!dev->sess) {
+
+                        if (dev->phone < 0) {
                                 /*
                                  * Wait until the device structure is completed
@@ -611 +608 @@
                 
                 device_t *dev = hash_table_get_instance(lnk, device_t, link);
-                assert(dev->sess);
+                assert(dev->phone >= 0);
                 
                 ipc_callid_t callid;
@@ -622 +619 @@
                 
                 /* Make a request at the driver */
-                async_exch_t *exch = async_exchange_begin(dev->sess);
-                
                 ipc_call_t answer;
-                aid_t msg = async_send_3(exch, IPC_GET_IMETHOD(*request),
+                aid_t msg = async_send_3(dev->phone, IPC_GET_IMETHOD(*request),
                     IPC_GET_ARG1(*request), IPC_GET_ARG2(*request),
                     IPC_GET_ARG3(*request), &answer);
                 
                 /* Forward the IPC_M_DATA_READ request to the driver */
-                async_forward_fast(callid, exch, 0, 0, 0, IPC_FF_ROUTE_FROM_ME);
-                
-                async_exchange_end(exch);
-                
+                async_forward_fast(callid, dev->phone, 0, 0, 0, IPC_FF_ROUTE_FROM_ME);
                 fibril_mutex_unlock(&devices_mutex);
                 
@@ -680 +672 @@
                 
                 device_t *dev = hash_table_get_instance(lnk, device_t, link);
-                assert(dev->sess);
+                assert(dev->phone >= 0);
                 
                 ipc_callid_t callid;
@@ -691 +683 @@
                 
                 /* Make a request at the driver */
-                async_exch_t *exch = async_exchange_begin(dev->sess);
-                
                 ipc_call_t answer;
-                aid_t msg = async_send_3(exch, IPC_GET_IMETHOD(*request),
+                aid_t msg = async_send_3(dev->phone, IPC_GET_IMETHOD(*request),
                     IPC_GET_ARG1(*request), IPC_GET_ARG2(*request),
                     IPC_GET_ARG3(*request), &answer);
                 
                 /* Forward the IPC_M_DATA_WRITE request to the driver */
-                async_forward_fast(callid, exch, 0, 0, 0, IPC_FF_ROUTE_FROM_ME);
-                
-                async_exchange_end(exch);
+                async_forward_fast(callid, dev->phone, 0, 0, 0, IPC_FF_ROUTE_FROM_ME);
                 
                 fibril_mutex_unlock(&devices_mutex);
@@ -754 +742 @@
                 
                 device_t *dev = hash_table_get_instance(lnk, device_t, link);
-                assert(dev->sess);
+                assert(dev->phone >= 0);
                 dev->refcount--;
                 
                 if (dev->refcount == 0) {
-                        async_hangup(dev->sess);
+                        async_hangup(dev->phone);
                         hash_table_remove(&devices, key, DEVICES_KEYS);
                 }
@@ -802 +790 @@
                 
                 device_t *dev = hash_table_get_instance(lnk, device_t, link);
-                assert(dev->sess);
+                assert(dev->phone >= 0);
                 
                 /* Make a request at the driver */
-                async_exch_t *exch = async_exchange_begin(dev->sess);
-                
                 ipc_call_t answer;
-                aid_t msg = async_send_2(exch, IPC_GET_IMETHOD(*request),
+                aid_t msg = async_send_2(dev->phone, IPC_GET_IMETHOD(*request),
                     IPC_GET_ARG1(*request), IPC_GET_ARG2(*request), &answer);
-                
-                async_exchange_end(exch);
                 
                 fibril_mutex_unlock(&devices_mutex);