Index: uspace/lib/c/Makefile =================================================================== --- uspace/lib/c/Makefile (revision 041ab6496858f6057c2140f33f0484a346328d1f) +++ uspace/lib/c/Makefile (revision 5c702a8e28dec4a706805f46de14ae9961503ebb) @@ -106,4 +106,5 @@ generic/io/vsnprintf.c \ generic/io/printf_core.c \ + generic/io/con_srv.c \ generic/io/console.c \ generic/io/visualizer.c \ Index: uspace/lib/c/generic/io/con_srv.c =================================================================== --- uspace/lib/c/generic/io/con_srv.c (revision 5c702a8e28dec4a706805f46de14ae9961503ebb) +++ uspace/lib/c/generic/io/con_srv.c (revision 5c702a8e28dec4a706805f46de14ae9961503ebb) @@ -0,0 +1,409 @@ +/* + * Copyright (c) 2012 Jiri Svoboda + * All rights reserved. + * + * Redistribution and use in source and binary forms, with or without + * modification, are permitted provided that the following conditions + * are met: + * + * - Redistributions of source code must retain the above copyright + * notice, this list of conditions and the following disclaimer. + * - Redistributions in binary form must reproduce the above copyright + * notice, this list of conditions and the following disclaimer in the + * documentation and/or other materials provided with the distribution. + * - The name of the author may not be used to endorse or promote products + * derived from this software without specific prior written permission. + * + * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR + * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES + * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. + * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT, + * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT + * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, + * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY + * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT + * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF + * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. + */ + +/** @addtogroup libc + * @{ + */ +/** + * @file + * @brief Console protocol server stub + */ +#include +#include +#include +#include + +#include + +static void con_read_srv(con_srv_t *srv, ipc_callid_t callid, + ipc_call_t *call) +{ + void *buf; + size_t size; + int rc; + ipc_callid_t rcallid; + + if (!async_data_read_receive(&rcallid, &size)) { + async_answer_0(callid, EINVAL); + return; + } + + buf = malloc(size); + if (buf == NULL) { + async_answer_0(rcallid, ENOMEM); + async_answer_0(callid, ENOMEM); + return; + } + + if (srv->srvs->ops->read == NULL) { + async_answer_0(rcallid, ENOTSUP); + async_answer_0(callid, ENOTSUP); + return; + } + + rc = srv->srvs->ops->read(srv, buf, size); + if (rc < 0) { + async_answer_0(rcallid, rc); + async_answer_0(callid, rc); + return; + } + + async_data_read_finalize(rcallid, buf, size); + free(buf); + + if (rc >= 0) + async_answer_1(callid, EOK, rc); + else + async_answer_0(callid, rc); +} + +static void con_write_srv(con_srv_t *srv, ipc_callid_t callid, + ipc_call_t *call) +{ + void *data; + size_t size; + int rc; + + rc = async_data_write_accept(&data, false, 0, 0, 0, &size); + if (rc != EOK) { + async_answer_0(callid, rc); + return; + } + + if (srv->srvs->ops->write == NULL) { + async_answer_0(callid, ENOTSUP); + return; + } + + rc = srv->srvs->ops->write(srv, data, size); + free(data); + + if (rc >= 0) + async_answer_1(callid, EOK, rc); + else + async_answer_0(callid, rc); +} + +static void con_sync_srv(con_srv_t *srv, ipc_callid_t callid, + ipc_call_t *call) +{ + if (srv->srvs->ops->sync == NULL) { + async_answer_0(callid, ENOTSUP); + return; + } + + srv->srvs->ops->sync(srv); + async_answer_0(callid, EOK); +} + +static void con_clear_srv(con_srv_t *srv, ipc_callid_t callid, + ipc_call_t *call) +{ + if (srv->srvs->ops->clear == NULL) { + async_answer_0(callid, ENOTSUP); + return; + } + + srv->srvs->ops->clear(srv); + async_answer_0(callid, EOK); +} + +static void con_set_pos_srv(con_srv_t *srv, ipc_callid_t callid, + ipc_call_t *call) +{ + sysarg_t col; + sysarg_t row; + + col = IPC_GET_ARG1(*call); + row = IPC_GET_ARG2(*call); + + if (srv->srvs->ops->set_pos == NULL) { + async_answer_0(callid, ENOTSUP); + return; + } + + srv->srvs->ops->set_pos(srv, col, row); + async_answer_0(callid, EOK); +} + +static void con_get_pos_srv(con_srv_t *srv, ipc_callid_t callid, + ipc_call_t *call) +{ + int rc; + sysarg_t col; + sysarg_t row; + + if (srv->srvs->ops->get_pos == NULL) { + async_answer_0(callid, ENOTSUP); + return; + } + + rc = srv->srvs->ops->get_pos(srv, &col, &row); + async_answer_2(callid, rc, col, row); +} + +static void con_get_size_srv(con_srv_t *srv, ipc_callid_t callid, + ipc_call_t *call) +{ + int rc; + sysarg_t cols; + sysarg_t rows; + + if (srv->srvs->ops->get_size == NULL) { + async_answer_0(callid, ENOTSUP); + return; + } + + rc = srv->srvs->ops->get_size(srv, &cols, &rows); + async_answer_2(callid, rc, cols, rows); +} + +static void con_get_color_cap_srv(con_srv_t *srv, ipc_callid_t callid, + ipc_call_t *call) +{ + int rc; + console_caps_t ccap; + + if (srv->srvs->ops->get_color_cap == NULL) { + async_answer_0(callid, ENOTSUP); + return; + } + + rc = srv->srvs->ops->get_color_cap(srv, &ccap); + async_answer_1(callid, rc, (sysarg_t)ccap); +} + +static void con_set_style_srv(con_srv_t *srv, ipc_callid_t callid, + ipc_call_t *call) +{ + console_style_t style; + + style = IPC_GET_ARG1(*call); + + if (srv->srvs->ops->set_style == NULL) { + async_answer_0(callid, ENOTSUP); + return; + } + + srv->srvs->ops->set_style(srv, style); + async_answer_0(callid, EOK); +} + +static void con_set_color_srv(con_srv_t *srv, ipc_callid_t callid, + ipc_call_t *call) +{ + console_color_t bgcolor; + console_color_t fgcolor; + console_color_attr_t flags; + + bgcolor = IPC_GET_ARG1(*call); + fgcolor = IPC_GET_ARG2(*call); + flags = IPC_GET_ARG3(*call); + + if (srv->srvs->ops->set_color == NULL) { + async_answer_0(callid, ENOTSUP); + return; + } + + srv->srvs->ops->set_color(srv, bgcolor, fgcolor, flags); + async_answer_0(callid, EOK); +} + +static void con_set_rgb_color_srv(con_srv_t *srv, ipc_callid_t callid, + ipc_call_t *call) +{ + pixel_t bgcolor; + pixel_t fgcolor; + + bgcolor = IPC_GET_ARG1(*call); + fgcolor = IPC_GET_ARG2(*call); + + if (srv->srvs->ops->set_rgb_color == NULL) { + async_answer_0(callid, ENOTSUP); + return; + } + + srv->srvs->ops->set_rgb_color(srv, bgcolor, fgcolor); + async_answer_0(callid, EOK); +} + +static void con_set_cursor_visibility_srv(con_srv_t *srv, ipc_callid_t callid, + ipc_call_t *call) +{ + bool show; + + show = IPC_GET_ARG1(*call); + + if (srv->srvs->ops->set_cursor_visibility == NULL) { + async_answer_0(callid, ENOTSUP); + return; + } + + srv->srvs->ops->set_cursor_visibility(srv, show); + async_answer_0(callid, EOK); +} + +static void con_get_event_srv(con_srv_t *srv, ipc_callid_t callid, + ipc_call_t *call) +{ + int rc; + kbd_event_t event; + + if (srv->srvs->ops->get_event == NULL) { + async_answer_0(callid, ENOTSUP); + return; + } + + rc = srv->srvs->ops->get_event(srv, &event); + async_answer_4(callid, rc, event.type, event.key, event.mods, event.c); +} + +static con_srv_t *con_srv_create(con_srvs_t *srvs) +{ + con_srv_t *srv; + + srv = calloc(1, sizeof(*srv)); + if (srv == NULL) + return NULL; + + srv->srvs = srvs; + return srv; +} + +void con_srvs_init(con_srvs_t *srvs) +{ + srvs->ops = NULL; + srvs->sarg = NULL; + srvs->abort_timeout = 0; + srvs->aborted = false; +} + +int con_conn(ipc_callid_t iid, ipc_call_t *icall, con_srvs_t *srvs) +{ + con_srv_t *srv; + int rc; + + /* Accept the connection */ + async_answer_0(iid, EOK); + + srv = con_srv_create(srvs); + if (srv == NULL) + return ENOMEM; + +/* async_sess_t *sess = async_callback_receive(EXCHANGE_SERIALIZE); + if (sess == NULL) + return ENOMEM; + + srv->client_sess = sess; +*/ + srv->client_sess = NULL; + + rc = srvs->ops->open(srvs, srv); + if (rc != EOK) + return rc; + + while (true) { + ipc_call_t call; + ipc_callid_t callid = 0; + + while (callid == 0) { + /* XXX Need to be able to abort immediately */ + callid = async_get_call_timeout(&call, + srvs->abort_timeout); + + if (srv->srvs->aborted) { + if (callid != 0) + async_answer_0(callid, EINTR); + break; + } + } + + if (callid == 0) + break; + + sysarg_t method = IPC_GET_IMETHOD(call); + + if (!method) { + /* The other side has hung up */ + async_answer_0(callid, EOK); + break; + } + + switch (method) { + case VFS_OUT_READ: + con_read_srv(srv, callid, &call); + break; + case VFS_OUT_WRITE: + con_write_srv(srv, callid, &call); + break; + case VFS_OUT_SYNC: + con_sync_srv(srv, callid, &call); + break; + case CONSOLE_CLEAR: + con_clear_srv(srv, callid, &call); + break; + case CONSOLE_SET_POS: + con_set_pos_srv(srv, callid, &call); + break; + case CONSOLE_GET_POS: + con_get_pos_srv(srv, callid, &call); + break; + case CONSOLE_GET_SIZE: + con_get_size_srv(srv, callid, &call); + break; + case CONSOLE_GET_COLOR_CAP: + con_get_color_cap_srv(srv, callid, &call); + break; + case CONSOLE_SET_STYLE: + con_set_style_srv(srv, callid, &call); + break; + case CONSOLE_SET_COLOR: + con_set_color_srv(srv, callid, &call); + break; + case CONSOLE_SET_RGB_COLOR: + con_set_rgb_color_srv(srv, callid, &call); + break; + case CONSOLE_SET_CURSOR_VISIBILITY: + con_set_cursor_visibility_srv(srv, callid, &call); + break; + case CONSOLE_GET_EVENT: + con_get_event_srv(srv, callid, &call); + break; + default: + async_answer_0(callid, ENOTSUP); + } + } + + rc = srvs->ops->close(srv); + free(srv); + + return rc; +} + +/** @} + */ Index: uspace/lib/c/generic/io/console.c =================================================================== --- uspace/lib/c/generic/io/console.c (revision 041ab6496858f6057c2140f33f0484a346328d1f) +++ uspace/lib/c/generic/io/console.c (revision 5c702a8e28dec4a706805f46de14ae9961503ebb) @@ -38,5 +38,4 @@ #include #include -#include #include #include @@ -126,5 +125,5 @@ { async_exch_t *exch = async_exchange_begin(ctrl->output_sess); - async_req_1_0(exch, CONSOLE_CURSOR_VISIBILITY, (show != false)); + async_req_1_0(exch, CONSOLE_SET_CURSOR_VISIBILITY, (show != false)); async_exchange_end(exch); } @@ -151,5 +150,5 @@ { async_exch_t *exch = async_exchange_begin(ctrl->output_sess); - async_req_2_0(exch, CONSOLE_GOTO, col, row); + async_req_2_0(exch, CONSOLE_SET_POS, col, row); async_exchange_end(exch); } Index: uspace/lib/c/generic/io/output.c =================================================================== --- uspace/lib/c/generic/io/output.c (revision 041ab6496858f6057c2140f33f0484a346328d1f) +++ uspace/lib/c/generic/io/output.c (revision 5c702a8e28dec4a706805f46de14ae9961503ebb) @@ -37,4 +37,5 @@ #include #include +#include #include Index: uspace/lib/c/include/io/con_srv.h =================================================================== --- uspace/lib/c/include/io/con_srv.h (revision 5c702a8e28dec4a706805f46de14ae9961503ebb) +++ uspace/lib/c/include/io/con_srv.h (revision 5c702a8e28dec4a706805f46de14ae9961503ebb) @@ -0,0 +1,94 @@ +/* + * Copyright (c) 2012 Jiri Svoboda + * All rights reserved. + * + * Redistribution and use in source and binary forms, with or without + * modification, are permitted provided that the following conditions + * are met: + * + * - Redistributions of source code must retain the above copyright + * notice, this list of conditions and the following disclaimer. + * - Redistributions in binary form must reproduce the above copyright + * notice, this list of conditions and the following disclaimer in the + * documentation and/or other materials provided with the distribution. + * - The name of the author may not be used to endorse or promote products + * derived from this software without specific prior written permission. + * + * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR + * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES + * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. + * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT, + * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT + * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, + * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY + * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT + * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF + * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. + */ + +/** @addtogroup libc + * @{ + */ +/** @file + */ + +#ifndef LIBC_CON_SRV_H_ +#define LIBC_CON_SRV_H_ + +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include + +typedef struct con_ops con_ops_t; + +/** Service setup (per sevice) */ +typedef struct { + con_ops_t *ops; + void *sarg; + /** Period to check for abort */ + suseconds_t abort_timeout; + bool aborted; +} con_srvs_t; + +/** Server structure (per client session) */ +typedef struct { + con_srvs_t *srvs; + async_sess_t *client_sess; + void *carg; +} con_srv_t; + +typedef struct con_ops { + int (*open)(con_srvs_t *, con_srv_t *); + int (*close)(con_srv_t *); + int (*read)(con_srv_t *, void *, size_t); + int (*write)(con_srv_t *, void *, size_t); + void (*sync)(con_srv_t *); + void (*clear)(con_srv_t *); + void (*set_pos)(con_srv_t *, sysarg_t col, sysarg_t row); + int (*get_pos)(con_srv_t *, sysarg_t *, sysarg_t *); + int (*get_size)(con_srv_t *, sysarg_t *, sysarg_t *); + int (*get_color_cap)(con_srv_t *, console_caps_t *); + void (*set_style)(con_srv_t *, console_style_t); + void (*set_color)(con_srv_t *, console_color_t, console_color_t, + console_color_attr_t); + void (*set_rgb_color)(con_srv_t *, pixel_t, pixel_t); + void (*set_cursor_visibility)(con_srv_t *, bool); + int (*get_event)(con_srv_t *, kbd_event_t *); +} con_ops_t; + +extern void con_srvs_init(con_srvs_t *); + +extern int con_conn(ipc_callid_t, ipc_call_t *, con_srvs_t *); + +#endif + +/** @} + */ Index: uspace/lib/c/include/io/concaps.h =================================================================== --- uspace/lib/c/include/io/concaps.h (revision 5c702a8e28dec4a706805f46de14ae9961503ebb) +++ uspace/lib/c/include/io/concaps.h (revision 5c702a8e28dec4a706805f46de14ae9961503ebb) @@ -0,0 +1,48 @@ +/* + * Copyright (c) 2012 Jiri Svoboda + * All rights reserved. + * + * Redistribution and use in source and binary forms, with or without + * modification, are permitted provided that the following conditions + * are met: + * + * - Redistributions of source code must retain the above copyright + * notice, this list of conditions and the following disclaimer. + * - Redistributions in binary form must reproduce the above copyright + * notice, this list of conditions and the following disclaimer in the + * documentation and/or other materials provided with the distribution. + * - The name of the author may not be used to endorse or promote products + * derived from this software without specific prior written permission. + * + * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR + * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES + * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. + * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT, + * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT + * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, + * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY + * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT + * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF + * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. + */ + +/** @addtogroup libcipc + * @{ + */ +/** @file + */ + +#ifndef LIBC_IO_CONCAPS_H_ +#define LIBC_IO_CONCAPS_H_ + +typedef enum { + CONSOLE_CAP_NONE = 0, + CONSOLE_CAP_STYLE = 1, + CONSOLE_CAP_INDEXED = 2, + CONSOLE_CAP_RGB = 4 +} console_caps_t; + +#endif + +/** @} + */ Index: uspace/lib/c/include/io/console.h =================================================================== --- uspace/lib/c/include/io/console.h (revision 041ab6496858f6057c2140f33f0484a346328d1f) +++ uspace/lib/c/include/io/console.h (revision 5c702a8e28dec4a706805f46de14ae9961503ebb) @@ -37,4 +37,5 @@ #include +#include #include #include @@ -42,11 +43,4 @@ #include #include - -typedef enum { - CONSOLE_CAP_NONE = 0, - CONSOLE_CAP_STYLE = 1, - CONSOLE_CAP_INDEXED = 2, - CONSOLE_CAP_RGB = 4 -} console_caps_t; /** Console control structure. */ Index: uspace/lib/c/include/ipc/console.h =================================================================== --- uspace/lib/c/include/ipc/console.h (revision 041ab6496858f6057c2140f33f0484a346328d1f) +++ uspace/lib/c/include/ipc/console.h (revision 5c702a8e28dec4a706805f46de14ae9961503ebb) @@ -43,10 +43,10 @@ CONSOLE_GET_EVENT, CONSOLE_GET_POS, - CONSOLE_GOTO, + CONSOLE_SET_POS, CONSOLE_CLEAR, CONSOLE_SET_STYLE, CONSOLE_SET_COLOR, CONSOLE_SET_RGB_COLOR, - CONSOLE_CURSOR_VISIBILITY + CONSOLE_SET_CURSOR_VISIBILITY } console_request_t; Index: uspace/lib/gui/terminal.c =================================================================== --- uspace/lib/gui/terminal.c (revision 041ab6496858f6057c2140f33f0484a346328d1f) +++ uspace/lib/gui/terminal.c (revision 5c702a8e28dec4a706805f46de14ae9961503ebb) @@ -39,6 +39,7 @@ #include #include +#include +#include #include -#include #include #include @@ -60,4 +61,44 @@ static LIST_INITIALIZE(terms); + +static int term_open(con_srvs_t *, con_srv_t *); +static int term_close(con_srv_t *); +static int term_read(con_srv_t *, void *, size_t); +static int term_write(con_srv_t *, void *, size_t); +static void term_sync(con_srv_t *); +static void term_clear(con_srv_t *); +static void term_set_pos(con_srv_t *, sysarg_t col, sysarg_t row); +static int term_get_pos(con_srv_t *, sysarg_t *, sysarg_t *); +static int term_get_size(con_srv_t *, sysarg_t *, sysarg_t *); +static int term_get_color_cap(con_srv_t *, console_caps_t *); +static void term_set_style(con_srv_t *, console_style_t); +static void term_set_color(con_srv_t *, console_color_t, console_color_t, + console_color_attr_t); +static void term_set_rgb_color(con_srv_t *, pixel_t, pixel_t); +static void term_set_cursor_visibility(con_srv_t *, bool); +static int term_get_event(con_srv_t *, kbd_event_t *); + +static con_ops_t con_ops = { + .open = term_open, + .close = term_close, + .read = term_read, + .write = term_write, + .sync = term_sync, + .clear = term_clear, + .set_pos = term_set_pos, + .get_pos = term_get_pos, + .get_size = term_get_size, + .get_color_cap = term_get_color_cap, + .set_style = term_set_style, + .set_color = term_set_color, + .set_rgb_color = term_set_rgb_color, + .set_cursor_visibility = term_set_cursor_visibility, + .get_event = term_get_event +}; + +static terminal_t *srv_to_terminal(con_srv_t *srv) +{ + return srv->srvs->sarg; +} static void getterm(const char *svc, const char *app) @@ -341,39 +382,18 @@ } -static void term_set_cursor(terminal_t *term, sysarg_t col, sysarg_t row) -{ - fibril_mutex_lock(&term->mtx); - chargrid_set_cursor(term->frontbuf, col, row); - fibril_mutex_unlock(&term->mtx); - - term_update(term); -} - -static void term_set_cursor_visibility(terminal_t *term, bool visible) -{ - fibril_mutex_lock(&term->mtx); - chargrid_set_cursor_visibility(term->frontbuf, visible); - fibril_mutex_unlock(&term->mtx); - - term_update(term); -} - -static void term_read(terminal_t *term, ipc_callid_t iid, ipc_call_t *icall) -{ - ipc_callid_t callid; - size_t size; - if (!async_data_read_receive(&callid, &size)) { - async_answer_0(callid, EINVAL); - async_answer_0(iid, EINVAL); - return; - } - - char *buf = (char *) malloc(size); - if (buf == NULL) { - async_answer_0(callid, ENOMEM); - async_answer_0(iid, ENOMEM); - return; - } - +static int term_open(con_srvs_t *srvs, con_srv_t *srv) +{ + return EOK; +} + +static int term_close(con_srv_t *srv) +{ + return EOK; +} + +static int term_read(con_srv_t *srv, void *buf, size_t size) +{ + terminal_t *term = srv_to_terminal(srv); + uint8_t *bbuf = buf; size_t pos = 0; @@ -386,5 +406,5 @@ /* Copy to the buffer remaining characters. */ while ((pos < size) && (term->char_remains_len > 0)) { - buf[pos] = term->char_remains[0]; + bbuf[pos] = term->char_remains[0]; pos++; @@ -416,7 +436,5 @@ } - (void) async_data_read_finalize(callid, buf, size); - async_answer_1(iid, EOK, size); - free(buf); + return size; } @@ -449,25 +467,26 @@ } -static void term_write(terminal_t *term, ipc_callid_t iid, ipc_call_t *icall) -{ - void *buf; - size_t size; - int rc = async_data_write_accept(&buf, false, 0, 0, 0, &size); - - if (rc != EOK) { - async_answer_0(iid, rc); - return; - } +static int term_write(con_srv_t *srv, void *data, size_t size) +{ + terminal_t *term = srv_to_terminal(srv); size_t off = 0; while (off < size) - term_write_char(term, str_decode(buf, &off, size)); - - async_answer_1(iid, EOK, size); - free(buf); -} - -static void term_clear(terminal_t *term) -{ + term_write_char(term, str_decode(data, &off, size)); + + return size; +} + +static void term_sync(con_srv_t *srv) +{ + terminal_t *term = srv_to_terminal(srv); + + term_update(term); +} + +static void term_clear(con_srv_t *srv) +{ + terminal_t *term = srv_to_terminal(srv); + fibril_mutex_lock(&term->mtx); chargrid_clear(term->frontbuf); @@ -477,18 +496,50 @@ } -static void term_get_cursor(terminal_t *term, ipc_callid_t iid, ipc_call_t *icall) -{ - sysarg_t col; - sysarg_t row; - - fibril_mutex_lock(&term->mtx); - chargrid_get_cursor(term->frontbuf, &col, &row); - fibril_mutex_unlock(&term->mtx); - - async_answer_2(iid, EOK, col, row); -} - -static void term_set_style(terminal_t *term, console_style_t style) -{ +static void term_set_pos(con_srv_t *srv, sysarg_t col, sysarg_t row) +{ + terminal_t *term = srv_to_terminal(srv); + + fibril_mutex_lock(&term->mtx); + chargrid_set_cursor(term->frontbuf, col, row); + fibril_mutex_unlock(&term->mtx); + + term_update(term); +} + +static int term_get_pos(con_srv_t *srv, sysarg_t *col, sysarg_t *row) +{ + terminal_t *term = srv_to_terminal(srv); + + fibril_mutex_lock(&term->mtx); + chargrid_get_cursor(term->frontbuf, col, row); + fibril_mutex_unlock(&term->mtx); + + return EOK; +} + +static int term_get_size(con_srv_t *srv, sysarg_t *cols, sysarg_t *rows) +{ + terminal_t *term = srv_to_terminal(srv); + + fibril_mutex_lock(&term->mtx); + *cols = term->cols; + *rows = term->rows; + fibril_mutex_unlock(&term->mtx); + + return EOK; +} + +static int term_get_color_cap(con_srv_t *srv, console_caps_t *caps) +{ + (void) srv; + *caps = TERM_CAPS; + + return EOK; +} + +static void term_set_style(con_srv_t *srv, console_style_t style) +{ + terminal_t *term = srv_to_terminal(srv); + fibril_mutex_lock(&term->mtx); chargrid_set_style(term->frontbuf, style); @@ -496,7 +547,9 @@ } -static void term_set_color(terminal_t *term, console_color_t bgcolor, +static void term_set_color(con_srv_t *srv, console_color_t bgcolor, console_color_t fgcolor, console_color_attr_t attr) { + terminal_t *term = srv_to_terminal(srv); + fibril_mutex_lock(&term->mtx); chargrid_set_color(term->frontbuf, bgcolor, fgcolor, attr); @@ -504,7 +557,9 @@ } -static void term_set_rgb_color(terminal_t *term, pixel_t bgcolor, +static void term_set_rgb_color(con_srv_t *srv, pixel_t bgcolor, pixel_t fgcolor) { + terminal_t *term = srv_to_terminal(srv); + fibril_mutex_lock(&term->mtx); chargrid_set_rgb_color(term->frontbuf, bgcolor, fgcolor); @@ -512,11 +567,24 @@ } -static void term_get_event(terminal_t *term, ipc_callid_t iid, ipc_call_t *icall) -{ +static void term_set_cursor_visibility(con_srv_t *srv, bool visible) +{ + terminal_t *term = srv_to_terminal(srv); + + fibril_mutex_lock(&term->mtx); + chargrid_set_cursor_visibility(term->frontbuf, visible); + fibril_mutex_unlock(&term->mtx); + + term_update(term); +} + +static int term_get_event(con_srv_t *srv, kbd_event_t *event) +{ + terminal_t *term = srv_to_terminal(srv); link_t *link = prodcons_consume(&term->input_pc); - kbd_event_t *event = list_get_instance(link, kbd_event_t, link); - - async_answer_4(iid, EOK, event->type, event->key, event->mods, event->c); - free(event); + kbd_event_t *kevent = list_get_instance(link, kbd_event_t, link); + + *event = *kevent; + free(kevent); + return EOK; } @@ -612,68 +680,7 @@ if (atomic_postinc(&term->refcnt) == 0) - term_set_cursor_visibility(term, true); - - /* Accept the connection */ - async_answer_0(iid, EOK); - - while (true) { - ipc_call_t call; - ipc_callid_t callid = async_get_call(&call); - - if (!IPC_GET_IMETHOD(call)) - return; - - switch (IPC_GET_IMETHOD(call)) { - case VFS_OUT_READ: - term_read(term, callid, &call); - break; - case VFS_OUT_WRITE: - term_write(term, callid, &call); - break; - case VFS_OUT_SYNC: - term_update(term); - async_answer_0(callid, EOK); - break; - case CONSOLE_CLEAR: - term_clear(term); - async_answer_0(callid, EOK); - break; - case CONSOLE_GOTO: - term_set_cursor(term, IPC_GET_ARG1(call), IPC_GET_ARG2(call)); - async_answer_0(callid, EOK); - break; - case CONSOLE_GET_POS: - term_get_cursor(term, callid, &call); - break; - case CONSOLE_GET_SIZE: - async_answer_2(callid, EOK, term->cols, term->rows); - break; - case CONSOLE_GET_COLOR_CAP: - async_answer_1(callid, EOK, TERM_CAPS); - break; - case CONSOLE_SET_STYLE: - term_set_style(term, IPC_GET_ARG1(call)); - async_answer_0(callid, EOK); - break; - case CONSOLE_SET_COLOR: - term_set_color(term, IPC_GET_ARG1(call), IPC_GET_ARG2(call), - IPC_GET_ARG3(call)); - async_answer_0(callid, EOK); - break; - case CONSOLE_SET_RGB_COLOR: - term_set_rgb_color(term, IPC_GET_ARG1(call), IPC_GET_ARG2(call)); - async_answer_0(callid, EOK); - break; - case CONSOLE_CURSOR_VISIBILITY: - term_set_cursor_visibility(term, IPC_GET_ARG1(call)); - async_answer_0(callid, EOK); - break; - case CONSOLE_GET_EVENT: - term_get_event(term, callid, &call); - break; - default: - async_answer_0(callid, EINVAL); - } - } + chargrid_set_cursor_visibility(term->frontbuf, true); + + con_conn(iid, icall, &term->srvs); } @@ -727,4 +734,8 @@ async_set_client_connection(term_connection); + con_srvs_init(&term->srvs); + term->srvs.ops = &con_ops; + term->srvs.sarg = term; + int rc = loc_server_register(NAME); if (rc != EOK) { Index: uspace/lib/gui/terminal.h =================================================================== --- uspace/lib/gui/terminal.h (revision 041ab6496858f6057c2140f33f0484a346328d1f) +++ uspace/lib/gui/terminal.h (revision 5c702a8e28dec4a706805f46de14ae9961503ebb) @@ -41,4 +41,5 @@ #include #include +#include #include #include @@ -66,4 +67,5 @@ service_id_t dsid; + con_srvs_t srvs; } terminal_t;