Subversion Repositories HelenOS

Rev

Rev 1719 | Rev 1866 | Go to most recent revision | Details | Compare with Previous | Last modification | View Log | RSS feed

Rev Author Line No. Line
1465 cejka 1
/*
2
 * Copyright (C) 2006 Josef Cejka
3
 * Copyright (C) 2006 Jakub Vana
4
 * All rights reserved.
5
 *
6
 * Redistribution and use in source and binary forms, with or without
7
 * modification, are permitted provided that the following conditions
8
 * are met:
9
 *
10
 * - Redistributions of source code must retain the above copyright
11
 *   notice, this list of conditions and the following disclaimer.
12
 * - Redistributions in binary form must reproduce the above copyright
13
 *   notice, this list of conditions and the following disclaimer in the
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
16
 *   derived from this software without specific prior written permission.
17
 *
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
20
 * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
21
 * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,
22
 * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
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
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
27
 * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
28
 */
29
 
1719 decky 30
/** @addtogroup libc
1653 cejka 31
 * @{
32
 */
33
/** @file
34
 */
1465 cejka 35
 
1653 cejka 36
 
1363 vana 37
#include <io/io.h>
38
#include <io/stream.h>
39
#include <string.h>
40
#include <malloc.h>
41
#include <libc.h>
42
#include <ipc/ipc.h>
43
#include <ipc/ns.h>
44
#include <ipc/fb.h>
45
#include <ipc/services.h>
1451 cejka 46
#include <console.h>
1465 cejka 47
#include <unistd.h>
1519 palkovsky 48
#include <async.h>
1363 vana 49
 
50
#define FDS 32
51
 
1366 decky 52
typedef struct stream_t {
1363 vana 53
    pwritefn_t w;
54
    preadfn_t r;
55
    void * param;
1519 palkovsky 56
    int phone;
1366 decky 57
} stream_t;
1363 vana 58
 
1519 palkovsky 59
static int console_phone = -1;
1536 palkovsky 60
static stream_t streams[FDS];
1363 vana 61
 
1451 cejka 62
static ssize_t write_stderr(void *param, const void *buf, size_t count)
1363 vana 63
{
1451 cejka 64
    return count;
65
}
66
 
1465 cejka 67
static ssize_t read_stdin(void *param, void *buf, size_t count)
1451 cejka 68
{
1363 vana 69
    ipcarg_t r0,r1;
1465 cejka 70
    size_t i = 0;
71
 
72
    while (i < count) {
1610 palkovsky 73
        if (async_req_2(streams[0].phone, CONSOLE_GETCHAR, 0, 0, &r0, &r1) < 0) {
1465 cejka 74
            return -1;
75
        }
1719 decky 76
        ((char *) buf)[i++] = r0;
1465 cejka 77
    }
78
    return i;
1363 vana 79
}
1465 cejka 80
 
1451 cejka 81
static ssize_t write_stdout(void *param, const void *buf, size_t count)
1363 vana 82
{
83
    int i;
1451 cejka 84
 
1366 decky 85
    for (i = 0; i < count; i++)
1719 decky 86
        async_msg(streams[1].phone, CONSOLE_PUTCHAR, ((const char *) buf)[i]);
1363 vana 87
 
88
    return count;
89
}
90
 
91
 
1451 cejka 92
static stream_t open_stdin(void)
1363 vana 93
{
94
    stream_t stream;
95
 
1451 cejka 96
    if (console_phone < 0) {
97
        while ((console_phone = ipc_connect_me_to(PHONE_NS, SERVICE_CONSOLE, 0)) < 0) {
1452 palkovsky 98
            usleep(10000);
1451 cejka 99
        }
1363 vana 100
    }
101
 
1451 cejka 102
    stream.r = read_stdin;
1719 decky 103
    stream.w = NULL;
1451 cejka 104
    stream.param = 0;
1519 palkovsky 105
    stream.phone = console_phone;
106
 
1451 cejka 107
    return stream;
108
}
109
 
110
static stream_t open_stdout(void)
111
{
112
    stream_t stream;
1519 palkovsky 113
 
1451 cejka 114
    if (console_phone < 0) {
115
        while ((console_phone = ipc_connect_me_to(PHONE_NS, SERVICE_CONSOLE, 0)) < 0) {
1476 cejka 116
            usleep(10000);
1451 cejka 117
        }
118
    }
1363 vana 119
 
1719 decky 120
    stream.r = NULL;
1451 cejka 121
    stream.w = write_stdout;
1536 palkovsky 122
    stream.phone = console_phone;
1451 cejka 123
    stream.param = 0;
1719 decky 124
 
1363 vana 125
    return stream;
126
}
127
 
1508 vana 128
static ssize_t write_null(void *param, const void *buf, size_t count)
129
{
130
    return count;
131
}
132
 
133
 
1366 decky 134
fd_t open(const char *fname, int flags)
1363 vana 135
{
1366 decky 136
    int c = 0;
1610 palkovsky 137
 
1366 decky 138
    while (((streams[c].w) || (streams[c].r)) && (c < FDS))
139
        c++;
1719 decky 140
 
1366 decky 141
    if (c == FDS)
142
        return EMFILE;
143
 
144
    if (!strcmp(fname, "stdin")) {
1451 cejka 145
        streams[c] = open_stdin();
1363 vana 146
        return c;
147
    }
148
 
1366 decky 149
    if (!strcmp(fname, "stdout")) {
1451 cejka 150
        streams[c] = open_stdout();
1363 vana 151
        return c;
152
    }
153
 
1366 decky 154
    if (!strcmp(fname, "stderr")) {
155
        streams[c].w = write_stderr;
1363 vana 156
        return c;
157
    }
1719 decky 158
 
1508 vana 159
    if (!strcmp(fname, "null")) {
160
        streams[c].w = write_null;
161
        return c;
162
    }
1719 decky 163
 
164
    return -1;
1363 vana 165
}
166
 
167
 
1366 decky 168
ssize_t write(int fd, const void *buf, size_t count)
1363 vana 169
{
1610 palkovsky 170
//  __SYSCALL3(SYS_IO, 1, (sysarg_t)buf, (sysarg_t) count);
171
//  return count;
1366 decky 172
    if (fd < FDS)
173
        return streams[fd].w(streams[fd].param, buf, count);
174
 
1363 vana 175
    return 0;
176
}
1465 cejka 177
 
178
ssize_t read(int fd, void *buf, size_t count)
179
{
180
    if (fd < FDS)
181
        return streams[fd].r(streams[fd].param, buf, count);
182
 
183
    return 0;
184
}
185
 
1519 palkovsky 186
int get_fd_phone(int fd)
187
{
188
    if (fd >= FDS || fd < 0)
189
        return -1;
190
    return streams[fd].phone;
191
}
1653 cejka 192
 
193
 
1719 decky 194
/** @}
1653 cejka 195
 */