X-Git-Url: https://scm.lunaixsky.com/lunaix-os.git/blobdiff_plain/45e1f8b055043e54be35462852ab6649d634da7c..0765e7c133eb393d8cd0292af444543c2edf8ccc:/lunaix-os/kernel/tty/lxconsole.c diff --git a/lunaix-os/kernel/tty/lxconsole.c b/lunaix-os/kernel/tty/lxconsole.c index 67961b5..2540077 100644 --- a/lunaix-os/kernel/tty/lxconsole.c +++ b/lunaix-os/kernel/tty/lxconsole.c @@ -23,6 +23,8 @@ #include #include +#include + static struct console lx_console; int @@ -38,24 +40,16 @@ void console_flush(); static waitq_t lx_reader; -static volatile char ttychr; static volatile pid_t fg_pgid = 0; -static inline void -print_control_code(const char cntrl) -{ - console_write_char('^'); - console_write_char(cntrl + 64); -} - int __lxconsole_listener(struct input_device* dev) { u32_t key = dev->current_pkt.sys_code; u32_t type = dev->current_pkt.pkt_type; kbd_kstate_t state = key >> 16; - ttychr = key & 0xff; + u8_t ttychr = key & 0xff; key = key & 0xffff; if (type == PKT_RELEASE) { @@ -68,18 +62,6 @@ __lxconsole_listener(struct input_device* dev) goto done; } ttychr = cntrl - 'a' + 1; - switch (ttychr) { - case TCINTR: - signal_send(-fg_pgid, _SIGINT); - print_control_code(ttychr); - break; - case TCSTOP: - signal_send(-fg_pgid, _SIGSTOP); - print_control_code(ttychr); - break; - default: - break; - } } else if (key == KEY_PG_UP) { console_view_up(); goto done; @@ -92,6 +74,7 @@ __lxconsole_listener(struct input_device* dev) goto done; } + fifo_putone(&lx_console.input, ttychr); pwake_all(&lx_reader); done: @@ -146,20 +129,6 @@ __tty_read_pg(struct device* dev, void* buf, size_t offset) return __tty_read(dev, buf, offset, PG_SIZE); } -void -lxconsole_spawn_ttydev() -{ - struct device* tty_dev = device_addseq(NULL, &lx_console, "tty"); - tty_dev->write = __tty_write; - tty_dev->write_page = __tty_write_pg; - tty_dev->read = __tty_read; - tty_dev->read_page = __tty_read_pg; - tty_dev->exec_cmd = __tty_exec_cmd; - - waitq_init(&lx_reader); - input_add_listener(__lxconsole_listener); -} - int __tty_write(struct device* dev, void* buf, size_t offset, size_t len) { @@ -175,40 +144,11 @@ __tty_read(struct device* dev, void* buf, size_t offset, size_t len) struct console* console = (struct console*)dev->underlay; size_t count = fifo_read(&console->input, buf, len); - if (count > 0 && ((char*)buf)[count - 1] == '\n') { + if (count > 0) { return count; } - while (count < len) { - pwait(&lx_reader); - - if (ttychr < 0x1B) { - // ASCII control codes - switch (ttychr) { - case TCINTR: - fifo_clear(&console->input); - return 0; - case TCBS: - if (fifo_backone(&console->input)) { - console_write_char(ttychr); - } - continue; - case TCLF: - case TCCR: - goto proceed; - default: - break; - } - print_control_code(ttychr); - continue; - } - - proceed: - console_write_char(ttychr); - if (!fifo_putone(&console->input, ttychr) || ttychr == '\n') { - break; - } - } + pwait(&lx_reader); return count + fifo_read(&console->input, buf + count, len - count); } @@ -352,4 +292,32 @@ console_start_flushing() struct lx_timer* timer = timer_run_ms(20, console_flush, NULL, TIMER_MODE_PERIODIC); lx_console.flush_timer = timer; -} \ No newline at end of file +} + +static int +lxconsole_spawn_ttydev(struct device_def* devdef) +{ + struct device* tty_dev = device_allocseq(NULL, &lx_console); + tty_dev->ops.write = __tty_write; + tty_dev->ops.write_page = __tty_write_pg; + tty_dev->ops.read = __tty_read; + tty_dev->ops.read_page = __tty_read_pg; + tty_dev->ops.exec_cmd = __tty_exec_cmd; + + waitq_init(&lx_reader); + input_add_listener(__lxconsole_listener); + + register_device(tty_dev, &devdef->class, "vcon"); + + term_create(tty_dev, "FB"); + + return 0; +} + +static struct device_def lxconsole_def = { + .name = "Lunaix Virtual Console", + .class = DEVCLASS(DEVIF_NON, DEVFN_TTY, DEV_BUILTIN), + .init = lxconsole_spawn_ttydev +}; +// FIXME +EXPORT_DEVICE(lxconsole, &lxconsole_def, load_onboot); \ No newline at end of file