WebSVN – HelenOS – Diff – /branches/dynload/uspace/lib/libc/generic/io/stream.c


/*
 * Copyright (c) 2006 Josef Cejka
 * Copyright (c) 2006 Jakub Vana
 * 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 <io/io.h>
#include <io/stream.h>
#include <string.h>
#include <malloc.h>
#include <libc.h>
#include <ipc/ipc.h>
#include <ipc/ns.h>
#include <ipc/fb.h>
#include <ipc/services.h>
#include <ipc/console.h>
#include <kbd/kbd.h>
#include <unistd.h>
#include <async.h>
#include <sys/types.h>
 
static int console_phone = -1;
 
ssize_t write_stderr(const void *buf, size_t count)
{
    return count;
}
 
ssize_t read_stdin(void *buf, size_t count)
{
    open_console();
    if (console_phone >= 0) {
        kbd_event_t ev;
        int rc;
        size_t i = 0;
   
        while (i < count) {
            do {
                rc = kbd_get_event(&ev);
                if (rc < 0) return -1;
            } while (ev.c == 0 || ev.type == KE_RELEASE);
 
            ((char *) buf)[i++] = ev.c;
        }
        return i;
    } else {
        return -1;
    }
}
 
ssize_t write_stdout(const void *buf, size_t count)
{
    open_console();
    if (console_phone >= 0) {
        int i;
   
        for (i = 0; i < count; i++)
            async_msg_1(console_phone, CONSOLE_PUTCHAR,
                ((const char *) buf)[i]);
       
        return count;
    } else
        return __SYSCALL3(SYS_KLOG, 1, (sysarg_t) buf, count);
}
 
void open_console(void)
{
    if (console_phone < 0) {
        int phone = ipc_connect_me_to(PHONE_NS, SERVICE_CONSOLE, 0, 0);
        if (phone >= 0)
            console_phone = phone;
    }
}
 
void close_console(void)
{
    if (console_phone >= 0) {
        if (ipc_hangup(console_phone) == 0) {
            console_phone = -1;
        }
    }
}
 
void klog_update(void)
{
    (void) __SYSCALL3(SYS_KLOG, 1, NULL, 0);
}
 
int get_console_phone(void)
{
    if (console_phone < 0)
        console_phone = ipc_connect_me_to_blocking(PHONE_NS, SERVICE_CONSOLE, 0, 0);
   
    return console_phone;
}
 
void console_wait(void)
{
    while (console_phone < 0)
        get_console_phone();
}
 
/** @}
 */
 

Rev 4343	Rev 4345
1	/*	1	/*
2	* Copyright (c) 2006 Josef Cejka	2	* Copyright (c) 2006 Josef Cejka
3	* Copyright (c) 2006 Jakub Vana	3	* Copyright (c) 2006 Jakub Vana
4	* All rights reserved.	4	* All rights reserved.
5	*	5	*
6	* Redistribution and use in source and binary forms, with or without	6	* Redistribution and use in source and binary forms, with or without
7	* modification, are permitted provided that the following conditions	7	* modification, are permitted provided that the following conditions
8	* are met:	8	* are met:
9	*	9	*
10	* - Redistributions of source code must retain the above copyright	10	* - Redistributions of source code must retain the above copyright
11	* notice, this list of conditions and the following disclaimer.	11	* notice, this list of conditions and the following disclaimer.
12	* - Redistributions in binary form must reproduce the above copyright	12	* - Redistributions in binary form must reproduce the above copyright
13	* notice, this list of conditions and the following disclaimer in the	13	* notice, this list of conditions and the following disclaimer in the
14	* documentation and/or other materials provided with the distribution.	14	* documentation and/or other materials provided with the distribution.
15	* - The name of the author may not be used to endorse or promote products	15	* - The name of the author may not be used to endorse or promote products
16	* derived from this software without specific prior written permission.	16	* derived from this software without specific prior written permission.
17	*	17	*
18	* THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR	18	* THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
19	* IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES	19	* IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
20	* OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.	20	* OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
21	* IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,	21	* IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,
22	* INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT	22	* INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
23	* NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,	23	* NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
24	* DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY	24	* DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
25	* THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT	25	* THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
26	* (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF	26	* (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
27	* THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.	27	* THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
28	*/	28	*/
29		29
30	/** @addtogroup libc	30	/** @addtogroup libc
31	* @{	31	* @{
32	*/	32	*/
33	/** @file	33	/** @file
34	*/	34	*/
35		35
36	#include <io/io.h>	36	#include <io/io.h>
37	#include <io/stream.h>	37	#include <io/stream.h>
38	#include <string.h>	38	#include <string.h>
39	#include <malloc.h>	39	#include <malloc.h>
40	#include <libc.h>	40	#include <libc.h>
41	#include <ipc/ipc.h>	41	#include <ipc/ipc.h>
42	#include <ipc/ns.h>	42	#include <ipc/ns.h>
43	#include <ipc/fb.h>	43	#include <ipc/fb.h>
44	#include <ipc/services.h>	44	#include <ipc/services.h>
45	#include <ipc/console.h>	45	#include <ipc/console.h>
46	#include <kbd/kbd.h>	46	#include <kbd/kbd.h>
47	#include <unistd.h>	47	#include <unistd.h>
48	#include <async.h>	48	#include <async.h>
49	#include <sys/types.h>	49	#include <sys/types.h>
50		50
51	static int console_phone = -1;	51	static int console_phone = -1;
52		52
53	ssize_t write_stderr(const void *buf, size_t count)	53	ssize_t write_stderr(const void *buf, size_t count)
54	{	54	{
55	return count;	55	return count;
56	}	56	}
57		57
58	ssize_t read_stdin(void *buf, size_t count)	58	ssize_t read_stdin(void *buf, size_t count)
59	{	59	{
60	open_console();	60	open_console();
61	if (console_phone >= 0) {	61	if (console_phone >= 0) {
62	kbd_event_t ev;	62	kbd_event_t ev;
63	int rc;	63	int rc;
64	size_t i = 0;	64	size_t i = 0;
65		65
66	while (i < count) {	66	while (i < count) {
67	do {	67	do {
68	rc = kbd_get_event(&ev);	68	rc = kbd_get_event(&ev);
69	if (rc < 0) return -1;	69	if (rc < 0) return -1;
70	} while (ev.c == 0 \|\| ev.type == KE_RELEASE);	70	} while (ev.c == 0 \|\| ev.type == KE_RELEASE);
71		71
72	((char *) buf)[i++] = ev.c;	72	((char *) buf)[i++] = ev.c;
73	}	73	}
74	return i;	74	return i;
75	} else {	75	} else {
76	return -1;	76	return -1;
77	}	77	}
78	}	78	}
79		79
80	ssize_t write_stdout(const void *buf, size_t count)	80	ssize_t write_stdout(const void *buf, size_t count)
81	{	81	{
82	open_console();	82	open_console();
83	if (console_phone >= 0) {	83	if (console_phone >= 0) {
84	int i;	84	int i;
85		85
86	for (i = 0; i < count; i++)	86	for (i = 0; i < count; i++)
87	async_msg_1(console_phone, CONSOLE_PUTCHAR,	87	async_msg_1(console_phone, CONSOLE_PUTCHAR,
88	((const char *) buf)[i]);	88	((const char *) buf)[i]);
89		89
90	return count;	90	return count;
91	} else	91	} else
92	return __SYSCALL3(SYS_KLOG, 1, (sysarg_t) buf, count);	92	return __SYSCALL3(SYS_KLOG, 1, (sysarg_t) buf, count);
93	}	93	}
94		94
95	void open_console(void)	95	void open_console(void)
96	{	96	{
97	if (console_phone < 0) {	97	if (console_phone < 0) {
98	int phone = ipc_connect_me_to(PHONE_NS, SERVICE_CONSOLE, 0, 0);	98	int phone = ipc_connect_me_to(PHONE_NS, SERVICE_CONSOLE, 0, 0);
99	if (phone >= 0)	99	if (phone >= 0)
100	console_phone = phone;	100	console_phone = phone;
101	}	101	}
102	}	102	}
103		103
104	void close_console(void)	104	void close_console(void)
105	{	105	{
106	if (console_phone >= 0) {	106	if (console_phone >= 0) {
107	if (ipc_hangup(console_phone) == 0) {	107	if (ipc_hangup(console_phone) == 0) {
108	console_phone = -1;	108	console_phone = -1;
109	}	109	}
110	}	110	}
111	}	111	}
112		112
113	void klog_update(void)	113	void klog_update(void)
114	{	114	{
115	(void) __SYSCALL3(SYS_KLOG, 1, NULL, 0);	115	(void) __SYSCALL3(SYS_KLOG, 1, NULL, 0);
116	}	116	}
117		117
118	int get_cons_phone(void)	118	int get_console_phone(void)
119	{	119	{
120	open_console();	120	if (console_phone < 0)
-		121	console_phone = ipc_connect_me_to_blocking(PHONE_NS, SERVICE_CONSOLE, 0, 0);
-		122
121	return console_phone;	123	return console_phone;
122	}	124	}
-		125
-		126	void console_wait(void)
-		127	{
-		128	while (console_phone < 0)
-		129	get_console_phone();
-		130	}
123		131
124	/** @}	132	/** @}
125	*/	133	*/
126		134

Subversion Repositories HelenOS

(root)/branches/dynload/uspace/lib/libc/generic/io/stream.c – Rev 4343 → 4345