Changes in uspace/srv/hid/console/console.c [2f6ad06:902f0906] in mainline

File:

• uspace/srv/hid/console/console.c (modified) (24 diffs)

uspace/srv/hid/console/console.c

@@ -41 +41 @@
 #include <str_error.h>
 #include <loc.h>
+#include <event.h>
 #include <io/con_srv.h>
 #include <io/kbd_event.h>
@@ -49 +50 @@
 #include <malloc.h>
 #include <as.h>
-#include <task.h>
 #include <fibril_synch.h>
 #include "console.h"
@@ -84 +84 @@
 /** Input server proxy */
 static input_t *input;
-static bool active = false;
 
 /** Session to the output server */
@@ -99 +98 @@
 static FIBRIL_MUTEX_INITIALIZE(switch_mtx);
 
+static console_t *prev_console = &consoles[0];
 static console_t *active_console = &consoles[0];
-
-static int input_ev_active(input_t *);
-static int input_ev_deactive(input_t *);
+static console_t *kernel_console = &consoles[KERNEL_CONSOLE];
+
 static int input_ev_key(input_t *, kbd_event_type_t, keycode_t, keymod_t, wchar_t);
 static int input_ev_move(input_t *, int, int);
@@ -109 +108 @@
 
 static input_ev_ops_t input_ev_ops = {
-        .active = input_ev_active,
-        .deactive = input_ev_deactive,
         .key = input_ev_key,
         .move = input_ev_move,
@@ -162 +159 @@
         fibril_mutex_lock(&cons->mtx);
         
-        if ((active) && (cons == active_console)) {
+        if ((cons == active_console) && (active_console != kernel_console)) {
                 output_update(output_sess, cons->fbid);
                 output_cursor_update(output_sess, cons->fbid);
@@ -176 +173 @@
         fibril_mutex_lock(&cons->mtx);
         
-        if ((active) && (cons == active_console))
+        if ((cons == active_console) && (active_console != kernel_console))
                 output_cursor_update(output_sess, cons->fbid);
         
@@ -188 +185 @@
         fibril_mutex_lock(&cons->mtx);
         
-        if ((active) && (cons == active_console)) {
+        if ((cons == active_console) && (active_console != kernel_console)) {
                 output_damage(output_sess, cons->fbid, 0, 0, cons->cols,
                     cons->rows);
@@ -198 +195 @@
 }
 
-static void cons_switch(unsigned int index)
-{
-        /*
-         * The first undefined index is reserved
-         * for switching to the kernel console.
-         */
-        if (index == CONSOLE_COUNT) {
-                if (console_kcon())
-                        active = false;
-                
-                return;
-        }
-        
-        if (index > CONSOLE_COUNT)
-                return;
-        
-        console_t *cons = &consoles[index];
-        
+static void cons_switch(console_t *cons)
+{
         fibril_mutex_lock(&switch_mtx);
         
@@ -223 +204 @@
         }
         
+        if (cons == kernel_console) {
+                output_yield(output_sess);
+                if (!console_kcon()) {
+                        output_claim(output_sess);
+                        fibril_mutex_unlock(&switch_mtx);
+                        return;
+                }
+        }
+        
+        if (active_console == kernel_console)
+                output_claim(output_sess);
+        
+        prev_console = active_console;
         active_console = cons;
         
@@ -230 +224 @@
 }
 
-static int input_ev_active(input_t *input)
-{
-        active = true;
-        output_claim(output_sess);
-        cons_damage(active_console);
-        
-        return EOK;
-}
-
-static int input_ev_deactive(input_t *input)
-{
-        active = false;
-        output_yield(output_sess);
-        
-        return EOK;
+static console_t *cons_get_active_uspace(void)
+{
+        fibril_mutex_lock(&switch_mtx);
+        
+        console_t *active_uspace = active_console;
+        if (active_uspace == kernel_console)
+                active_uspace = prev_console;
+        
+        assert(active_uspace != kernel_console);
+        
+        fibril_mutex_unlock(&switch_mtx);
+        
+        return active_uspace;
 }
 
@@ -250 +242 @@
     keymod_t mods, wchar_t c)
 {
-        if ((key >= KC_F1) && (key <= KC_F1 + CONSOLE_COUNT) &&
+        if ((key >= KC_F1) && (key < KC_F1 + CONSOLE_COUNT) &&
             ((mods & KM_CTRL) == 0)) {
-                cons_switch(key - KC_F1);
+                cons_switch(&consoles[key - KC_F1]);
         } else {
                 /* Got key press/release event */
@@ -267 +259 @@
                 event->c = c;
                 
-                prodcons_produce(&active_console->input_pc,
+                /*
+                 * Kernel console does not read events
+                 * from us, so we will redirect them
+                 * to the (last) active userspace console
+                 * if necessary.
+                 */
+                console_t *target_console = cons_get_active_uspace();
+                
+                prodcons_produce(&target_console->input_pc,
                     &event->link);
         }
@@ -377 +377 @@
                 }
         }
-        
+
         return size;
 }
@@ -388 +388 @@
         while (off < size)
                 cons_write_char(cons, str_decode(data, &off, size));
-        
         return size;
 }
@@ -499 +498 @@
         event->type = CEV_KEY;
         event->ev.key = *kevent;
-        
         free(kevent);
         return EOK;
@@ -509 +507 @@
         
         for (size_t i = 0; i < CONSOLE_COUNT; i++) {
-                if (consoles[i].dsid == (service_id_t) IPC_GET_ARG2(*icall)) {
+                if (i == KERNEL_CONSOLE)
+                        continue;
+                
+                if (consoles[i].dsid == (service_id_t) IPC_GET_ARG1(*icall)) {
                         cons = &consoles[i];
                         break;
@@ -525 +526 @@
         con_conn(iid, icall, &cons->srvs);
 }
+
 
 static int input_connect(const char *svc)
@@ -537 +539 @@
         }
 
-        sess = loc_service_connect(dsid, INTERFACE_INPUT, 0);
+        sess = loc_service_connect(EXCHANGE_ATOMIC, dsid, 0);
         if (sess == NULL) {
                 printf("%s: Unable to connect to input service %s\n", NAME,
@@ -555 +557 @@
 }
 
+static void interrupt_received(ipc_callid_t callid, ipc_call_t *call)
+{
+        cons_switch(prev_console);
+}
+
 static async_sess_t *output_connect(const char *svc)
 {
@@ -562 +569 @@
         int rc = loc_service_get_id(svc, &dsid, 0);
         if (rc == EOK) {
-                sess = loc_service_connect(dsid, INTERFACE_OUTPUT, 0);
+                sess = loc_service_connect(EXCHANGE_SERIALIZE, dsid, 0);
                 if (sess == NULL) {
                         printf("%s: Unable to connect to output service %s\n",
@@ -576 +583 @@
 static bool console_srv_init(char *input_svc, char *output_svc)
 {
+        int rc;
+        
         /* Connect to input service */
-        int rc = input_connect(input_svc);
+        rc = input_connect(input_svc);
         if (rc != EOK)
                 return false;
@@ -587 +596 @@
         
         /* Register server */
-        async_set_fallback_port_handler(client_connection, NULL);
+        async_set_client_connection(client_connection);
         rc = loc_server_register(NAME);
         if (rc != EOK) {
@@ -601 +610 @@
         output_get_caps(output_sess, &ccaps);
         
-        /*
-         * Inititalize consoles only if there are
-         * actually some output devices.
-         */
-        if (ccaps != 0) {
-                for (size_t i = 0; i < CONSOLE_COUNT; i++) {
-                        consoles[i].index = i;
-                        atomic_set(&consoles[i].refcnt, 0);
-                        fibril_mutex_initialize(&consoles[i].mtx);
-                        prodcons_initialize(&consoles[i].input_pc);
-                        consoles[i].char_remains_len = 0;
-                        
-                        consoles[i].cols = cols;
-                        consoles[i].rows = rows;
-                        consoles[i].ccaps = ccaps;
-                        consoles[i].frontbuf =
-                            chargrid_create(cols, rows, CHARGRID_FLAG_SHARED);
-                        
-                        if (consoles[i].frontbuf == NULL) {
-                                printf("%s: Unable to allocate frontbuffer %zu\n", NAME, i);
-                                return false;
-                        }
-                        
-                        consoles[i].fbid = output_frontbuf_create(output_sess,
-                            consoles[i].frontbuf);
-                        if (consoles[i].fbid == 0) {
-                                printf("%s: Unable to create frontbuffer %zu\n", NAME, i);
-                                return false;
-                        }
-                        
-                        con_srvs_init(&consoles[i].srvs);
-                        consoles[i].srvs.ops = &con_ops;
-                        consoles[i].srvs.sarg = &consoles[i];
-                        
-                        char vc[LOC_NAME_MAXLEN + 1];
-                        snprintf(vc, LOC_NAME_MAXLEN, "%s/vc%zu", NAMESPACE, i);
-                        
-                        if (loc_service_register(vc, &consoles[i].dsid) != EOK) {
-                                printf("%s: Unable to register device %s\n", NAME, vc);
-                                return false;
-                        }
-                }
-                
-                input_activate(input);
-        }
+        /* Inititalize consoles */
+        for (size_t i = 0; i < CONSOLE_COUNT; i++) {
+                consoles[i].index = i;
+                atomic_set(&consoles[i].refcnt, 0);
+                fibril_mutex_initialize(&consoles[i].mtx);
+                prodcons_initialize(&consoles[i].input_pc);
+                consoles[i].char_remains_len = 0;
+                
+                if (i == KERNEL_CONSOLE)
+                        continue;
+                
+                consoles[i].cols = cols;
+                consoles[i].rows = rows;
+                consoles[i].ccaps = ccaps;
+                consoles[i].frontbuf =
+                    chargrid_create(cols, rows, CHARGRID_FLAG_SHARED);
+                
+                if (consoles[i].frontbuf == NULL) {
+                        printf("%s: Unable to allocate frontbuffer %zu\n", NAME, i);
+                        return false;
+                }
+                
+                consoles[i].fbid = output_frontbuf_create(output_sess,
+                    consoles[i].frontbuf);
+                if (consoles[i].fbid == 0) {
+                        printf("%s: Unable to create frontbuffer %zu\n", NAME, i);
+                        return false;
+                }
+                
+                con_srvs_init(&consoles[i].srvs);
+                consoles[i].srvs.ops = &con_ops;
+                consoles[i].srvs.sarg = &consoles[i];
+                
+                char vc[LOC_NAME_MAXLEN + 1];
+                snprintf(vc, LOC_NAME_MAXLEN, "%s/vc%zu", NAMESPACE, i);
+                
+                if (loc_service_register(vc, &consoles[i].dsid) != EOK) {
+                        printf("%s: Unable to register device %s\n", NAME, vc);
+                        return false;
+                }
+        }
+        
+        cons_damage(active_console);
+        
+        /* Receive kernel notifications */
+        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));
         
         return true;