Changeset 99c2e9f3 in mainline for uspace/srv/hid/remcons/user.c

Timestamp:

2012-01-12T09:29:00Z (14 years ago)

Author:

Vojtech Horky <vojtechhorky@…>

Branches:

lfn, master, serial, ticket/834-toolchain-update, topic/msim-upgrade, topic/simplify-dev-export

Children:

2a180307

Parents:

261bbdc

Message:

remcons: more refactoring

File:

• uspace/srv/hid/remcons/user.c (modified) (1 diff)

uspace/srv/hid/remcons/user.c

@@ -172 +172 @@
 }
 
+/** Tell whether the launched task already exited and socket is already closed.
+ *
+ * @param user Telnet user in question.
+ */
+bool telnet_user_is_zombie(telnet_user_t *user)
+{
+        fibril_mutex_lock(&user->guard);
+        bool zombie = user->socket_closed || user->task_finished;
+        fibril_mutex_unlock(&user->guard);
+
+        return zombie;
+}
+
+/** Receive next byte from a socket (use buffering.
+ * We need to return the value via extra argument because the read byte
+ * might be negative.
+ */
+static int telnet_user_recv_next_byte_no_lock(telnet_user_t *user, char *byte)
+{
+        /* No more buffered data? */
+        if (user->socket_buffer_len <= user->socket_buffer_pos) {
+                int recv_length = recv(user->socket, user->socket_buffer, BUFFER_SIZE, 0);
+                if ((recv_length == 0) || (recv_length == ENOTCONN)) {
+                        user->socket_closed = true;
+                        return ENOENT;
+                }
+                if (recv_length < 0) {
+                        return recv_length;
+                }
+                user->socket_buffer_len = recv_length;
+                user->socket_buffer_pos = 0;
+        }
+
+        *byte = user->socket_buffer[user->socket_buffer_pos++];
+
+        return EOK;
+}
+
+/** Creates new keyboard event from given char.
+ *
+ * @param type Event type (press / release).
+ * @param c Pressed character.
+ */
+static kbd_event_t* new_kbd_event(kbd_event_type_t type, wchar_t c) {
+        kbd_event_t *event = malloc(sizeof(kbd_event_t));
+        assert(event);
+
+        link_initialize(&event->link);
+        event->type = type;
+        event->c = c;
+        event->mods = 0;
+        event->key = (c == '\n' ? KC_ENTER : KC_A);
+
+        return event;
+}
+
+int telnet_user_get_next_keyboard_event(telnet_user_t *user, kbd_event_t *event)
+{
+        fibril_mutex_lock(&user->guard);
+        if (list_empty(&user->in_events.list)) {
+                char next_byte = 0;
+                /* Skip zeros, bail-out on error. */
+                while (next_byte == 0) {
+                        int rc = telnet_user_recv_next_byte_no_lock(user, &next_byte);
+                        DEBUG("Got %d.\n", next_byte);
+                        if (rc != EOK) {
+                                fibril_mutex_unlock(&user->guard);
+                                return rc;
+                        }
+                }
+
+                /* CR-LF conversions. */
+                if (next_byte == 13) {
+                        next_byte = 10;
+                }
+
+                kbd_event_t *down = new_kbd_event(KEY_PRESS, next_byte);
+                kbd_event_t *up = new_kbd_event(KEY_RELEASE, next_byte);
+                assert(down);
+                assert(up);
+                prodcons_produce(&user->in_events, &down->link);
+                prodcons_produce(&user->in_events, &up->link);
+        }
+
+        link_t *link = prodcons_consume(&user->in_events);
+        kbd_event_t *tmp = list_get_instance(link, kbd_event_t, link);
+
+        fibril_mutex_unlock(&user->guard);
+
+        *event = *tmp;
+
+        free(tmp);
+
+        return EOK;
+}
 
 /**