Subversion Repositories HelenOS

/*

 * Copyright (c) 2006 Josef Cejka

 * Copyright (c) 2006 Jakub Vana

 * Copyright (c) 2008 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

 */

#include <async.h>

#include <io/stream.h>

#include <ipc/console.h>

#include <ipc/services.h>

#include <errno.h>

#include <string.h>

#include <console.h>

static int console_phone = -1;

/** Size of cbuffer. */

#define CBUFFER_SIZE 256

/** Buffer for writing characters to the console. */

static char cbuffer[CBUFFER_SIZE];

/** Pointer to end of cbuffer. */

static char *cbuffer_end = cbuffer + CBUFFER_SIZE;

/** Pointer to first available field in cbuffer. */

static char *cbp = cbuffer;

static ssize_t cons_write(const char *buf, size_t nbyte);

static void cons_putchar(int c);

static void cbuffer_flush(void);

static void cbuffer_drain(void);

static void cbuffer_putc(int c);

void console_open(bool blocking)

{

    if (console_phone < 0) {

        int phone;

        if (blocking) {

            phone = ipc_connect_me_to_blocking(PHONE_NS,

                SERVICE_CONSOLE, 0, 0);

        } else {

            phone = ipc_connect_me_to(PHONE_NS, SERVICE_CONSOLE, 0,

                0);

        }

        if (phone >= 0)

            console_phone = phone;

    }

}

void console_close(void)

{

    if (console_phone >= 0) {

        if (ipc_hangup(console_phone) == 0) {

            console_phone = -1;

        }

    }

}

int console_phone_get(bool blocking)

{

    if (console_phone < 0)

        console_open(blocking);

    return console_phone;

}

void console_wait(void)

{

    while (console_phone < 0)

        console_open(true);

}

void console_clear(void)

{

    int cons_phone = console_phone_get(true);

    cbuffer_drain();

    async_msg_0(cons_phone, CONSOLE_CLEAR);

}

void console_goto(int row, int col)

{

    int cons_phone = console_phone_get(true);

    cbuffer_flush();

    async_msg_2(cons_phone, CONSOLE_GOTO, row, col);

}

void console_putchar(int c)

{

    cbuffer_putc(c);

}

/** Write all data from output buffer to the console. */

static void cbuffer_flush(void)

{

    int rc;

    int len;

    len = cbp - cbuffer;

    while (len > 0) {

        rc = cons_write(cbuffer, cbp - cbuffer);

        if (rc < 0)

            return;

        len -= rc;

    }

    cbp = cbuffer;

}

/** Drop all data in console output buffer. */

static void cbuffer_drain(void)

{

    cbp = cbuffer;

}

/** Write one character to the output buffer. */

static inline void cbuffer_putc(int c)

{

    if (cbp == cbuffer_end)

        cbuffer_flush();

    *cbp++ = c;

    if (c == '\n')

        cbuffer_flush();

}

/** Write one character to the console via IPC. */

static void cons_putchar(int c)

{

    int cons_phone = console_phone_get(true);

    async_msg_1(cons_phone, CONSOLE_PUTCHAR, c);

}

/** Write characters to the console via IPC. */

static ssize_t cons_write(const char *buf, size_t nbyte)

{

    int cons_phone = console_phone_get(true);

    ipcarg_t rc;

    ipc_call_t answer;

    aid_t req;

    async_serialize_start();

    req = async_send_0(cons_phone, CONSOLE_WRITE, &answer);

    rc = ipc_data_write_start(cons_phone, (void *) buf, nbyte);

    if (rc != EOK) {

        async_wait_for(req, NULL);

        async_serialize_end();

        return (ssize_t) rc;

    }

    async_wait_for(req, &rc);

    async_serialize_end();

    if (rc == EOK)

        return (ssize_t) IPC_GET_ARG1(answer);

    else

        return -1;

}

/** Write characters to the console. */

ssize_t console_write(const char *buf, size_t nbyte)

{

    size_t left;

    left = nbyte;

    while (left > 0) {

        cbuffer_putc(*buf++);

        --left;

    }

    return nbyte;

}

/** Write a NULL-terminated string to the console. */

void console_putstr(const char *s)

{

    size_t len;

    ssize_t rc;

    len = strlen(s);

    while (len > 0) {

        rc = console_write(s, len);

        if (rc < 0)

            return; /* Error */

        s += rc;

        len -= rc;

    }

}

/** Flush all output to the console. */

void console_flush(void)

{

    int cons_phone = console_phone_get(false);

    cbuffer_flush();

    async_msg_0(cons_phone, CONSOLE_FLUSH);

}

int console_get_size(int *rows, int *cols)

{

    int cons_phone = console_phone_get(true);

    ipcarg_t r, c;

    int rc;

    rc = async_req_0_2(cons_phone, CONSOLE_GETSIZE, &r, &c);

    *rows = (int) r;

    *cols = (int) c;

    return rc;

}

void console_set_style(int style)

{

    int cons_phone = console_phone_get(true);

    cbuffer_flush();

    async_msg_1(cons_phone, CONSOLE_SET_STYLE, style);

}

void console_set_color(int fg_color, int bg_color, int flags)

{

    int cons_phone = console_phone_get(true);

    cbuffer_flush();

    async_msg_3(cons_phone, CONSOLE_SET_COLOR, fg_color, bg_color, flags);

}

void console_set_rgb_color(int fg_color, int bg_color)

{

    int cons_phone = console_phone_get(true);

    cbuffer_flush();

    async_msg_2(cons_phone, CONSOLE_SET_RGB_COLOR, fg_color, bg_color);

}

void console_cursor_visibility(int show)

{

    int cons_phone = console_phone_get(true);

    cbuffer_flush();

    async_msg_1(cons_phone, CONSOLE_CURSOR_VISIBILITY, show != 0);

}

void console_kcon_enable(void)

{

    int cons_phone = console_phone_get(true);

    cbuffer_flush();

    async_msg_0(cons_phone, CONSOLE_KCON_ENABLE);

}

/** @}

 */