Changes in uspace/drv/bus/usb/usbhid/mouse/mousedev.c [5f6e25e:5da7199] in mainline

File:

• uspace/drv/bus/usb/usbhid/mouse/mousedev.c (modified) (11 diffs)

uspace/drv/bus/usb/usbhid/mouse/mousedev.c

@@ -42 +42 @@
 #include <errno.h>
 #include <async.h>
-#include <async_obsolete.h>
 #include <str_error.h>
 #include <ipc/mouseev.h>
@@ -56 +55 @@
 #define ARROWS_PER_SINGLE_WHEEL 3
 
-// FIXME: remove this header
-#include <abi/ipc/methods.h>
-
-#define NAME "mouse"
+#define NAME  "mouse"
 
 /*----------------------------------------------------------------------------*/
@@ -128 +124 @@
     ipc_callid_t icallid, ipc_call_t *icall)
 {
-        sysarg_t method = IPC_GET_IMETHOD(*icall);
-        
-        usb_mouse_t *mouse_dev = (usb_mouse_t *)fun->driver_data;
+        usb_mouse_t *mouse_dev = (usb_mouse_t *) fun->driver_data;
         
         if (mouse_dev == NULL) {
@@ -141 +135 @@
         usb_log_debug("default_connection_handler: fun->name: %s\n",
                       fun->name);
-        usb_log_debug("default_connection_handler: mouse_phone: %d, wheel "
-            "phone: %d\n", mouse_dev->mouse_phone, mouse_dev->wheel_phone);
-        
-        int *phone = (str_cmp(fun->name, HID_MOUSE_FUN_NAME) == 0) 
-                     ? &mouse_dev->mouse_phone : &mouse_dev->wheel_phone;
-        
-        if (method == IPC_M_CONNECT_TO_ME) {
-                int callback = IPC_GET_ARG5(*icall);
-
-                if (*phone != -1) {
+        usb_log_debug("default_connection_handler: mouse_sess: %p, "
+            "wheel_sess: %p\n", mouse_dev->mouse_sess, mouse_dev->wheel_sess);
+        
+        async_sess_t **sess_ptr =
+            (str_cmp(fun->name, HID_MOUSE_FUN_NAME) == 0) ?
+            &mouse_dev->mouse_sess : &mouse_dev->wheel_sess;
+        
+        async_sess_t *sess =
+            async_callback_receive_start(EXCHANGE_SERIALIZE, icall);
+        if (sess != NULL) {
+                if (*sess_ptr == NULL) {
+                        *sess_ptr = sess;
+                        usb_log_debug("Console session to mouse set ok (%p).\n",
+                            sess);
+                        async_answer_0(icallid, EOK);
+                } else {
                         usb_log_debug("default_connection_handler: Console "
-                            "phone to mouse already set.\n");
+                            "session to mouse already set.\n");
                         async_answer_0(icallid, ELIMIT);
-                        return;
                 }
-
-                *phone = callback;
-                usb_log_debug("Console phone to mouse set ok (%d).\n", *phone);
-                async_answer_0(icallid, EOK);
-                return;
-        }
-
-        usb_log_debug("default_connection_handler: Invalid function.\n");
-        async_answer_0(icallid, EINVAL);
+        } else {
+                usb_log_debug("default_connection_handler: Invalid function.\n");
+                async_answer_0(icallid, EINVAL);
+        }
 }
 
@@ -175 +169 @@
                 return NULL;
         }
-        mouse->mouse_phone = -1;
-        mouse->wheel_phone = -1;
+        mouse->mouse_sess = NULL;
+        mouse->wheel_sess = NULL;
         
         return mouse;
@@ -187 +181 @@
         assert(mouse_dev != NULL);
         
-        // hangup phone to the console
-        if (mouse_dev->mouse_phone >= 0) {
-                async_obsolete_hangup(mouse_dev->mouse_phone);
-        }
-        
-        if (mouse_dev->wheel_phone >= 0) {
-                async_obsolete_hangup(mouse_dev->wheel_phone);
-        }
+        // hangup session to the console
+        if (mouse_dev->mouse_sess != NULL)
+                async_hangup(mouse_dev->mouse_sess);
+        
+        if (mouse_dev->wheel_sess != NULL)
+                async_hangup(mouse_dev->wheel_sess);
 }
 
@@ -203 +195 @@
         unsigned int key = (wheel > 0) ? KC_UP : KC_DOWN;
 
-        if (mouse_dev->wheel_phone < 0) {
+        if (mouse_dev->wheel_sess == NULL) {
                 usb_log_warning(
                     "Connection to console not ready, wheel roll discarded.\n");
@@ -215 +207 @@
                 /* Send arrow press and release. */
                 usb_log_debug2("Sending key %d to the console\n", key);
-                async_obsolete_msg_4(mouse_dev->wheel_phone, KBDEV_EVENT,
-                    KEY_PRESS, key, 0, 0);
-                async_obsolete_msg_4(mouse_dev->wheel_phone, KBDEV_EVENT,
-                    KEY_RELEASE, key, 0, 0);
+                
+                async_exch_t *exch = async_exchange_begin(mouse_dev->wheel_sess);
+                
+                async_msg_4(exch, KBDEV_EVENT, KEY_PRESS, key, 0, 0);
+                async_msg_4(exch, KBDEV_EVENT, KEY_RELEASE, key, 0, 0);
+                
+                async_exchange_end(exch);
         }
 }
@@ -253 +248 @@
         assert(mouse_dev != NULL);
         
-        if (mouse_dev->mouse_phone < 0) {
-                usb_log_warning(NAME " No console phone.\n");
+        if (mouse_dev->mouse_sess == NULL) {
+                usb_log_warning(NAME " No console session.\n");
                 return true;
         }
@@ -266 +261 @@
 
         if ((shift_x != 0) || (shift_y != 0)) {
-                async_obsolete_req_2_0(mouse_dev->mouse_phone,
-                    MOUSEEV_MOVE_EVENT, shift_x, shift_y);
-        }
-
-        if (wheel != 0) {
+                async_exch_t *exch = async_exchange_begin(mouse_dev->mouse_sess);
+                async_req_2_0(exch, MOUSEEV_MOVE_EVENT, shift_x, shift_y);
+                async_exchange_end(exch);
+        }
+        
+        if (wheel != 0)
                 usb_mouse_send_wheel(mouse_dev, wheel);
-        }
         
         /*
@@ -292 +287 @@
                 if (mouse_dev->buttons[field->usage - field->usage_minimum] == 0
                     && field->value != 0) {
-                        async_obsolete_req_2_0(mouse_dev->mouse_phone,
-                            MOUSEEV_BUTTON_EVENT, field->usage, 1);
+                        async_exch_t *exch =
+                            async_exchange_begin(mouse_dev->mouse_sess);
+                        async_req_2_0(exch, MOUSEEV_BUTTON_EVENT, field->usage, 1);
+                        async_exchange_end(exch);
+                        
                         mouse_dev->buttons[field->usage - field->usage_minimum]
                             = field->value;
                 } else if (mouse_dev->buttons[field->usage - field->usage_minimum] != 0
                     && field->value == 0) {
-                        async_obsolete_req_2_0(mouse_dev->mouse_phone,
-                           MOUSEEV_BUTTON_EVENT, field->usage, 0);
+                        async_exch_t *exch =
+                            async_exchange_begin(mouse_dev->mouse_sess);
+                        async_req_2_0(exch, MOUSEEV_BUTTON_EVENT, field->usage, 0);
+                        async_exchange_end(exch);
+                        
                         mouse_dev->buttons[field->usage - field->usage_minimum] =
                            field->value;