Changes in uspace/srv/hid/compositor/compositor.c [00ddb40:8e4a408] in mainline

File:

• uspace/srv/hid/compositor/compositor.c (modified) (34 diffs)

uspace/srv/hid/compositor/compositor.c

@@ -56 +56 @@
 #include <loc.h>
 
+#include <event.h>
 #include <io/keycode.h>
 #include <io/mode.h>
 #include <io/visualizer.h>
 #include <io/window.h>
-#include <io/console.h>
 
 #include <transform.h>
@@ -84 +84 @@
 static sysarg_t coord_origin;
 static pixel_t bg_color;
-static filter_t filter = filter_bilinear;
-static unsigned int filter_index = 1;
 
 typedef struct {
@@ -146 +144 @@
 /** Input server proxy */
 static input_t *input;
-static bool active = false;
-
-static int comp_active(input_t *);
-static int comp_deactive(input_t *);
+
 static int comp_key_press(input_t *, kbd_event_type_t, keycode_t, keymod_t, wchar_t);
 static int comp_mouse_move(input_t *, int, int);
@@ -156 +151 @@
 
 static input_ev_ops_t input_ev_ops = {
-        .active = comp_active,
-        .deactive = comp_deactive,
         .key = comp_key_press,
         .move = comp_mouse_move,
@@ -163 +156 @@
         .button = comp_mouse_button
 };
+
+static void input_disconnect(void);
 
 static pointer_t *input_pointer(input_t *input)
@@ -235 +230 @@
 static void window_destroy(window_t *win)
 {
-        if ((win) && (atomic_get(&win->ref_cnt) == 0)) {
+        if (win && atomic_get(&win->ref_cnt) == 0) {
                 while (!list_empty(&win->queue.list)) {
                         window_event_t *event = (window_event_t *) list_first(&win->queue.list);
@@ -241 +236 @@
                         free(event);
                 }
-                
-                if (win->surface)
+
+                if (win->surface) {
                         surface_destroy(win->surface);
-                
+                }
                 free(win);
         }
@@ -256 +251 @@
         transform_invert(&win_trans);
         transform_apply_affine(&win_trans, &x, &y);
-        
-        /*
-         * Since client coordinate origin is (0, 0), it is necessary to check
+
+        /* Since client coordinate origin is (0, 0), it is necessary to check
          * coordinates to avoid underflow. Moreover, it is convenient to also
          * check against provided upper limits to determine whether the converted
-         * coordinates are within the client window.
-         */
-        if ((x < 0) || (y < 0))
+         * coordinates are within the client window.  */
+        if (x < 0 || y < 0) {
                 return false;
-        
-        (*x_out) = (sysarg_t) (x + 0.5);
-        (*y_out) = (sysarg_t) (y + 0.5);
-        
-        if (((*x_out) >= x_lim) || ((*y_out) >= y_lim))
-                return false;
-        
-        return true;
+        } else {
+                (*x_out) = (sysarg_t) (x + 0.5);
+                (*y_out) = (sysarg_t) (y + 0.5);
+
+                if ((*x_out) >= x_lim || (*y_out) >= y_lim) {
+                        return false;
+                } else {
+                        return true;
+                }
+        }
 }
 
@@ -282 +277 @@
         transform_apply_affine(&win_trans, &x, &y);
         
-        /*
-         * It is assumed that compositor coordinate origin is chosen in such way,
-         * that underflow/overflow here would be unlikely.
-         */
+        /* It is assumed that compositor coordinate origin is chosen in such way,
+         * that underflow/overflow here would be unlikely. */
         (*x_out) = (sysarg_t) (x + 0.5);
         (*y_out) = (sysarg_t) (y + 0.5);
@@ -410 +403 @@
 
                         source_init(&source);
-                        source_set_filter(&source, filter);
+                        source_set_filter(&source, filter_nearest);
                         drawctx_init(&context, vp->surface);
                         drawctx_set_compose(&context, compose_over);
@@ -443 +436 @@
                                         transform_translate(&transform, -pos.x, -pos.y);
 
-                                        source_set_transform(&source, transform);
-                                        source_set_texture(&source, win->surface,
-                                            PIXELMAP_EXTEND_TRANSPARENT_SIDES);
+                                        source_set_transform(&source, transform);                               
+                                        source_set_texture(&source, win->surface, false);
                                         source_set_alpha(&source, PIXEL(win->opacity, 0, 0, 0));
 
@@ -573 +565 @@
 
         /* Notify visualizers about updated regions. */
-        if (active) {
-                list_foreach(viewport_list, link, viewport_t, vp) {
-                        sysarg_t x_dmg_vp, y_dmg_vp, w_dmg_vp, h_dmg_vp;
-                        surface_get_damaged_region(vp->surface, &x_dmg_vp, &y_dmg_vp, &w_dmg_vp, &h_dmg_vp);
-                        surface_reset_damaged_region(vp->surface);
-                        visualizer_update_damaged_region(vp->sess,
-                            x_dmg_vp, y_dmg_vp, w_dmg_vp, h_dmg_vp, 0, 0);
-                }
-        }
-        
+        list_foreach(viewport_list, link, viewport_t, vp) {
+                sysarg_t x_dmg_vp, y_dmg_vp, w_dmg_vp, h_dmg_vp;
+                surface_get_damaged_region(vp->surface, &x_dmg_vp, &y_dmg_vp, &w_dmg_vp, &h_dmg_vp);
+                surface_reset_damaged_region(vp->surface);
+                visualizer_update_damaged_region(
+                    vp->sess, x_dmg_vp, y_dmg_vp, w_dmg_vp, h_dmg_vp, 0, 0);
+        }
+
         fibril_mutex_unlock(&viewport_list_mtx);
 }
@@ -598 +588 @@
                 return;
         }
-        
         int rc = async_data_read_finalize(callid, event, len);
         if (rc != EOK) {
@@ -605 +594 @@
                 return;
         }
-        
         async_answer_0(iid, EOK);
+        
         free(event);
 }
@@ -617 +606 @@
         double height = IPC_GET_ARG4(*icall);
 
-        if ((width == 0) || (height == 0)) {
+        if (width == 0 || height == 0) {
                 comp_damage(0, 0, UINT32_MAX, UINT32_MAX);
         } else {
@@ -866 +855 @@
 
         comp_damage(x, y, width, height);
+
         async_answer_0(iid, EOK);
 }
@@ -871 +861 @@
 static void comp_window_close_request(window_t *win, ipc_callid_t iid, ipc_call_t *icall)
 {
-        window_event_t *event = (window_event_t *) malloc(sizeof(window_event_t));
+    window_event_t *event = (window_event_t *) malloc(sizeof(window_event_t));
         if (event == NULL) {
                 async_answer_0(iid, ENOMEM);
@@ -1011 +1001 @@
                                 break;
                         case WINDOW_CLOSE:
-                                /*
-                                 * Postpone the closing until the phone is hung up to cover
-                                 * the case when the client is killed abruptly.
-                                 */
+                                /* Postpone the closing until the phone is hung up to cover
+                                 * the case when the client is killed abruptly. */
                                 async_answer_0(callid, EOK);
                                 break;
@@ -1029 +1017 @@
 static void comp_mode_change(viewport_t *vp, ipc_callid_t iid, ipc_call_t *icall)
 {
+        int rc;
         sysarg_t mode_idx = IPC_GET_ARG2(*icall);
         fibril_mutex_lock(&viewport_list_mtx);
@@ -1034 +1023 @@
         /* Retrieve the mode that shall be set. */
         vslmode_t new_mode;
-        int rc = visualizer_get_mode(vp->sess, &new_mode, mode_idx);
+        rc = visualizer_get_mode(vp->sess, &new_mode, mode_idx);
         if (rc != EOK) {
                 fibril_mutex_unlock(&viewport_list_mtx);
@@ -1052 +1041 @@
         /* Try to set the mode and share out the surface. */
         rc = visualizer_set_mode(vp->sess,
-            new_mode.index, new_mode.version, surface_direct_access(new_surface));
+                new_mode.index, new_mode.version, surface_direct_access(new_surface));
         if (rc != EOK) {
                 surface_destroy(new_surface);
@@ -1082 +1071 @@
 }
 
-#if 0
-static void comp_shutdown(void)
-{
-        loc_service_unregister(winreg_id);
-        input_disconnect();
-        
-        /* Close all clients and their windows. */
-        fibril_mutex_lock(&window_list_mtx);
-        list_foreach(window_list, link, window_t, win) {
-                window_event_t *event = (window_event_t *) malloc(sizeof(window_event_t));
-                if (event) {
-                        link_initialize(&event->link);
-                        event->type = WINDOW_CLOSE;
-                        prodcons_produce(&win->queue, &event->link);
-                }
-        }
-        fibril_mutex_unlock(&window_list_mtx);
-        
-        async_answer_0(iid, EOK);
-        
-        /* All fibrils of the compositor will terminate soon. */
-}
-#endif
-
 static void comp_visualizer_disconnect(viewport_t *vp, ipc_callid_t iid, ipc_call_t *icall)
 {
         /* Release viewport resources. */
         fibril_mutex_lock(&viewport_list_mtx);
-        
         list_remove(&vp->link);
         viewport_destroy(vp);
-        
-        fibril_mutex_unlock(&viewport_list_mtx);
-        
-        async_answer_0(iid, EOK);
-        
-        comp_restrict_pointers();
-        comp_damage(0, 0, UINT32_MAX, UINT32_MAX);
+
+        /* Terminate compositor if there are no more viewports. */
+        if (list_empty(&viewport_list)) {
+                fibril_mutex_unlock(&viewport_list_mtx);
+                loc_service_unregister(winreg_id);
+                input_disconnect();
+
+                /* Close all clients and their windows. */
+                fibril_mutex_lock(&window_list_mtx);
+                list_foreach(window_list, link, window_t, win) {
+                        window_event_t *event = (window_event_t *) malloc(sizeof(window_event_t));
+                        if (event) {
+                                link_initialize(&event->link);
+                                event->type = WINDOW_CLOSE;
+                                prodcons_produce(&win->queue, &event->link);
+                        }
+                }
+                fibril_mutex_unlock(&window_list_mtx);
+
+                async_answer_0(iid, EOK);
+
+                /* All fibrils of the compositor will terminate soon. */
+        } else {
+                fibril_mutex_unlock(&viewport_list_mtx);
+                async_answer_0(iid, EOK);
+
+                comp_restrict_pointers();
+                comp_damage(0, 0, UINT32_MAX, UINT32_MAX);
+        }
 }
 
@@ -1134 +1120 @@
         fibril_mutex_unlock(&viewport_list_mtx);
 
-        if (!vp)
+        if (!vp) {
                 return;
+        }
 
         /* Ignore parameters, the connection is already opened. */
@@ -1236 +1223 @@
         /* Try to set the mode and share out the surface. */
         rc = visualizer_set_mode(vp->sess,
-            vp->mode.index, vp->mode.version, surface_direct_access(vp->surface));
+                vp->mode.index, vp->mode.version, surface_direct_access(vp->surface));
         if (rc != EOK) {
                 printf("%s: Unable to set mode (%s)\n", NAME, str_error(rc));
@@ -1246 +1233 @@
         if (claimed)
                 visualizer_yield(vp->sess);
-        
         if (vp->sess != NULL)
                 async_hangup(vp->sess);
-        
         free(vp);
         free(vsl_name);
@@ -1790 +1775 @@
 }
 
-static int comp_active(input_t *input)
-{
-        active = true;
-        comp_damage(0, 0, UINT32_MAX, UINT32_MAX);
-        
-        return EOK;
-}
-
-static int comp_deactive(input_t *input)
-{
-        active = false;
-        return EOK;
-}
-
 static int comp_key_press(input_t *input, kbd_event_type_t type, keycode_t key,
     keymod_t mods, wchar_t c)
@@ -1821 +1792 @@
             key == KC_O || key == KC_P);
         bool kconsole_switch = (mods & KM_ALT) && (key == KC_M);
-        bool filter_switch = (mods & KM_ALT) && (key == KC_Y);
-
-        bool key_filter = (type == KEY_RELEASE) && (win_transform || win_resize ||
+
+        bool filter = (type == KEY_RELEASE) && (win_transform || win_resize ||
             win_opacity || win_close || win_switch || viewport_move ||
-            viewport_change || kconsole_switch || filter_switch);
-
-        if (key_filter) {
+            viewport_change || kconsole_switch);
+
+        if (filter) {
                 /* no-op */
         } else if (win_transform) {
@@ -2093 +2063 @@
                 fibril_mutex_unlock(&viewport_list_mtx);
         } else if (kconsole_switch) {
-                if (console_kcon())
-                        active = false;
-        } else if (filter_switch) {
-                filter_index++;
-                if (filter_index > 1)
-                        filter_index = 0;
-                if (filter_index == 0) {
-                        filter = filter_nearest;
-                }
-                else {
-                        filter = filter_bilinear;
-                }
-                comp_damage(0, 0, UINT32_MAX, UINT32_MAX);
+                __SYSCALL0(SYS_DEBUG_ACTIVATE_CONSOLE);
         } else {
                 window_event_t *event = (window_event_t *) malloc(sizeof(window_event_t));
@@ -2174 +2132 @@
 }
 
-static void discover_viewports(void)
-{
-        fibril_mutex_lock(&discovery_mtx);
-        
+static void interrupt_received(ipc_callid_t callid, ipc_call_t *call)
+{
+        comp_damage(0, 0, UINT32_MAX, UINT32_MAX);
+}
+
+static int discover_viewports(void)
+{
         /* Create viewports and connect them to visualizers. */
         category_id_t cat_id;
         int rc = loc_category_get_id("visualizer", &cat_id, IPC_FLAG_BLOCKING);
-        if (rc != EOK)
-                goto ret;
+        if (rc != EOK) {
+                printf("%s: Failed to get visualizer category.\n", NAME);
+                return -1;
+        }
         
         service_id_t *svcs;
         size_t svcs_cnt = 0;
         rc = loc_category_get_svcs(cat_id, &svcs, &svcs_cnt);
-        if (rc != EOK)
-                goto ret;
-        
-        fibril_mutex_lock(&viewport_list_mtx);
+        if (rc != EOK || svcs_cnt == 0) {
+                printf("%s: Failed to get visualizer category services.\n", NAME);
+                return -1;
+        }
+
+        fibril_mutex_lock(&viewport_list_mtx);  
         for (size_t i = 0; i < svcs_cnt; ++i) {
                 bool exists = false;
@@ -2209 +2174 @@
         fibril_mutex_unlock(&viewport_list_mtx);
         
-        if (!list_empty(&viewport_list))
-                input_activate(input);
-        
-ret:
+        /* TODO damage only newly added viewports */
+        comp_damage(0, 0, UINT32_MAX, UINT32_MAX);
+        return EOK;
+}
+
+static void category_change_cb(void)
+{
+        fibril_mutex_lock(&discovery_mtx);
+        discover_viewports();
         fibril_mutex_unlock(&discovery_mtx);
-}
-
-static void category_change_cb(void)
-{
-        discover_viewports();
 }
 
@@ -2231 +2196 @@
         /* Register compositor server. */
         async_set_client_connection(client_connection);
-        
         int rc = loc_server_register(NAME);
         if (rc != EOK) {
                 printf("%s: Unable to register server (%s)\n", NAME, str_error(rc));
                 return -1;
+        }
+        
+        /* Register interrupt handler to switch back from kconsole. */
+        async_set_interrupt_received(interrupt_received);
+        rc = event_subscribe(EVENT_KCONSOLE, 0);
+        if (rc != EOK) {
+                printf("%s: Failed to register kconsole notifications (%s)\n",
+                    NAME, str_error(rc));
         }
         
@@ -2257 +2229 @@
                 return -1;
         }
-        
+
         /* Establish input bidirectional connection. */
         rc = input_connect(input_svc);
@@ -2264 +2236 @@
                 return rc;
         }
-        
+
         rc = loc_register_cat_change_cb(category_change_cb);
         if (rc != EOK) {
@@ -2270 +2242 @@
                 input_disconnect();
                 return rc;
-        }
-        
-        discover_viewports();
-        
+        }       
+
+        rc = discover_viewports();
+        if (rc != EOK) {
+                input_disconnect();
+                return rc;
+        }
+        
+        if (list_empty(&viewport_list)) {
+                printf("%s: Failed to get viewports.\n", NAME);
+                input_disconnect();
+                return -1;
+        }
+
         comp_restrict_pointers();
         comp_damage(0, 0, UINT32_MAX, UINT32_MAX);
+        
         
         return EOK;