pc-tty: add PS/2 mouse support and kbd/mouse vdevs

Adds PS/2 mouse support. Because PS/2 keyboard and mouse share the same
I/O port, this required some heavy refactoring of ttypc_kbd driver. It
also adds /dev/kbd and /dev/mouse virtual devices, which can be used for
input event capturing by applications, for instance by an X server, as
part of RTOS-864.

Mouse support is optional and can be enabled by exporting HAS_MOUSE=y in
a compatible target.

JIRA: RTOS-896

tty/pc-tty/Makefile

@@ -8,4 +8,9 @@
 NAME := pc-tty
 SRCS := $(wildcard tty/pc-tty/*.c)
 DEP_LIBS := libtty libklog
+
+ifneq ($(HAS_MOUSE), y)
+	SRCS := $(filter-out tty/pc-tty/ttypc_mouse.c, $(SRCS))
+endif
+
 include $(binary.mk)

tty/pc-tty/event_queue.c

@@ -0,0 +1,147 @@
+#include <errno.h>
+#include <stdlib.h>
+#include <string.h>
+#include <fcntl.h>
+#include <sys/threads.h>
+
+#include "event_queue.h"
+
+
+#define min(a, b) ({ \
+	__typeof__(a) _a = (a); \
+	__typeof__(b) _b = (b); \
+	_a > _b ? _b : _a; \
+})
+
+
+struct _event_queue_t {
+	unsigned char *buf;
+	unsigned int count;
+	unsigned int r;
+	unsigned int w;
+	unsigned int sz;
+	handle_t mutex;
+	handle_t waitq;
+};
+
+
+int event_queue_init(event_queue_t **res, unsigned int sz)
+{
+	int err;
+	event_queue_t *eq;
+
+	if (sz == 0)
+		return EINVAL;
+
+	eq = malloc(sizeof(event_queue_t));
+	if (eq == NULL) {
+		return -1;
+	}
+
+	memset(eq, 0, sizeof(event_queue_t));
+
+	eq->buf = malloc(sizeof(unsigned char) * sz);
+	if (eq->buf == NULL) {
+		return -1;
+	}
+
+	eq->sz = sz;
+
+	if ((err = mutexCreate(&eq->mutex)) < 0 || (err = condCreate(&eq->waitq)) < 0) {
+		free(eq->buf);
+		free(eq);
+		return err;
+	}
+
+	*res = eq;
+
+	return EOK;
+}
+
+
+void event_queue_put(event_queue_t *eq, unsigned char event, unsigned int min_size, unsigned int flags)
+{
+	if (!eq)
+		return;
+
+	mutexLock(eq->mutex);
+	if (eq->count < eq->sz) {
+		eq->buf[eq->w] = event;
+		eq->w = (eq->w + 1) % eq->sz;
+		eq->count++;
+		if (eq->count >= min_size)
+			condSignal(eq->waitq);
+	}  // else: discard
+	mutexUnlock(eq->mutex);
+}
+
+
+int event_queue_get(event_queue_t *eq, void *dest, unsigned int size, unsigned int flags)
+{
+	int err;
+	unsigned int bytes;
+
+	if (!eq || !dest)
+		return -1;
+
+	if (size == 0)
+		return 0;
+
+	mutexLock(eq->mutex);
+	do {
+		if (flags & O_NONBLOCK && eq->count < size) {
+			err = -EWOULDBLOCK;
+			break;
+		}
+
+		while (eq->count < size)
+			condWait(eq->waitq, eq->mutex, 0);
+
+		if (eq->w < eq->r)
+			memcpy(dest, eq->buf + eq->r, bytes = min(eq->count, eq->w - eq->r));
+		else {
+			memcpy(dest, eq->buf + eq->r, bytes = min(size, eq->sz - eq->r));
+
+			if (bytes < size) {
+				size -= bytes;
+				memcpy(dest + bytes, eq->buf, min(size, eq->w));
+				bytes += min(size, eq->w);
+			}
+		}
+
+		eq->r = (eq->r + bytes) % eq->sz;
+		eq->count -= bytes;
+
+		err = bytes;
+	} while (0);
+	mutexUnlock(eq->mutex);
+
+	return err;
+}
+
+
+int event_queue_count(event_queue_t *eq)
+{
+	int res;
+
+	if (!eq)
+		return -1;
+
+	mutexLock(eq->mutex);
+	res = eq->count;
+	mutexUnlock(eq->mutex);
+
+	return res;
+}
+
+
+void event_queue_destroy(event_queue_t *eq)
+{
+	if (!eq)
+		return;
+
+	resourceDestroy(eq->mutex);
+	resourceDestroy(eq->waitq);
+	free(eq->buf);
+	free(eq);
+}

tty/pc-tty/event_queue.h

@@ -0,0 +1,42 @@
+/*
+ * Phoenix-RTOS
+ *
+ * Simple circular buffer for enqueueing PS/2 events
+ *
+ * Copyright 2024 Phoenix Systems
+ * Author: Adam Greloch
+ *
+ * This file is part of Phoenix-RTOS.
+ *
+ * %LICENSE%
+ */
+
+
+#ifndef _EVENT_QUEUE_H_
+#define _EVENT_QUEUE_H_
+
+
+typedef struct _event_queue_t event_queue_t;
+
+
+/* Initializes event queue */
+extern int event_queue_init(event_queue_t **res, unsigned int sz);
+
+
+/* Puts a byte to event queue. If queue has more than min_size bytes, wake readers. If queue is full, does nothing */
+extern void event_queue_put(event_queue_t *eq, unsigned char event, unsigned int min_size, unsigned int flags);
+
+
+/* Reads data from event queue */
+extern int event_queue_get(event_queue_t *eq, void *dest, unsigned int size, unsigned int flags);
+
+
+/* Retrieves number of bytes stored in event queue */
+extern int event_queue_count(event_queue_t *eq);
+
+
+/* Destroys event queue */
+extern void event_queue_destroy(event_queue_t *eq);
+
+
+#endif

tty/pc-tty/ttypc.h

@@ -18,61 +18,74 @@
 #include <sys/types.h>
 
 #include "ttypc_vt.h"
+#include "event_queue.h"
 
 
 /* Number of virtual terminals */
 #define NVTS 4
 
 
 /* Keyboard types */
-enum { KBD_BIOS, KBD_PS2 };
+enum { KBD_BIOS,
+	KBD_PS2 };
 
 
 /* Keyboard key types */
 enum {
-	KB_NONE    = 0x0000,
-	KB_CTL     = 0x0001,
-	KB_SHIFT   = 0x0002,
-	KB_ALT     = 0x0004,
-	KB_ALTGR   = 0x0008,
-	KB_SCROLL  = 0x0010,
-	KB_NUM     = 0x0020,
-	KB_CAPS    = 0x0040,
-	KB_FUNC    = 0x0080,
-	KB_ASCII   = 0x0100,
-	KB_KP      = 0x0200,
-	KB_EXT     = 0x0400
+	KB_NONE = 0x0000,
+	KB_CTL = 0x0001,
+	KB_SHIFT = 0x0002,
+	KB_ALT = 0x0004,
+	KB_ALTGR = 0x0008,
+	KB_SCROLL = 0x0010,
+	KB_NUM = 0x0020,
+	KB_CAPS = 0x0040,
+	KB_FUNC = 0x0080,
+	KB_ASCII = 0x0100,
+	KB_KP = 0x0200,
+	KB_EXT = 0x0400
 };
 
 
 struct _ttypc_t {
-	unsigned int port;     /* Driver port */
+	unsigned int port; /* Driver port */
 
 	/* VGA */
-	volatile void *vga;    /* VGA screen memory */
-	void *crtc;            /* Video Display Controller (CRTC) */
-	unsigned color;        /* Color support */
+	volatile void *vga; /* VGA screen memory */
+	void *crtc;         /* Video Display Controller (CRTC) */
+	unsigned color;     /* Color support */
 
 	/* KBD */
 	volatile void *kbd;    /* Keyboard controller */
 	unsigned char ktype;   /* Keyboard type */
 	unsigned char lockst;  /* Lock keys state */
 	unsigned char shiftst; /* Shift keys state */
-	unsigned int kirq;     /* Interrupt number */
-	handle_t klock;        /* Interrupt mutex */
-	handle_t kcond;        /* Interrupt condition variable */
-	handle_t kinth;        /* Interrupt handle */
+	handle_t kmcond;       /* Kbd/mouse interrupt condition variable */
+
+	unsigned int kirq;  /* Kbd interrupt number */
+	handle_t klock;     /* Kbd interrupt mutex */
+	handle_t kinth;     /* Kbd interrupt handle */
+	event_queue_t *keq; /* Kbd event buffer */
+	unsigned int kport; /* Kbd device port */
+
+	unsigned int mirq;  /* Mouse interrupt number */
+	handle_t minth;     /* Mouse interrupt handle */
+	event_queue_t *meq; /* Mouse event buffer */
+	unsigned int mport; /* Mouse device port */
 
 	/* Virtual terminals */
-	ttypc_vt_t *vt;        /* Active virtual terminal */
-	ttypc_vt_t vts[NVTS];  /* Virtual Terminals */
+	ttypc_vt_t *vt;       /* Active virtual terminal */
+	ttypc_vt_t vts[NVTS]; /* Virtual Terminals */
 
 	/* Synchronization */
-	handle_t lock;         /* Access mutex */
+	handle_t lock; /* Access mutex */
 
 	/* Thread stacks */
-	char kstack[2048] __attribute__ ((aligned(8)));
-	char pstack[2048] __attribute__ ((aligned(8)));
+	char kstack[2048] __attribute__((aligned(8)));
+	char pstack[2048] __attribute__((aligned(8)));
+
+	char kpstack[1024] __attribute__((aligned(8)));
+	char mpstack[1024] __attribute__((aligned(8)));
 };