source: mainline/libc/generic/io/stream.c@ 44c6d88d

#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 <console.h>

#define FDS 32

typedef struct stream_t {
        pwritefn_t w;
        preadfn_t r;
        void * param;
} stream_t;

int console_phone = -1;

stream_t streams[FDS] = {{0, 0, 0}};

/*
ssize_t write_stdout(void *param, const void * buf, size_t count);
ssize_t write_stdout(void *param, const void * buf, size_t count)
{
        return (ssize_t) __SYSCALL3(SYS_IO, 1, (sysarg_t) buf, (sysarg_t) count);
}*/

static ssize_t write_stderr(void *param, const void *buf, size_t count)
{
        return count;
        //return (ssize_t) __SYSCALL3(SYS_IO, 1, (sysarg_t) buf, (sysarg_t) count);
}

static char read_stdin(void)
{
        ipcarg_t r0,r1;
        ipc_call_sync_2(console_phone, CONSOLE_GETCHAR, 0, 0, &r0, &r1);
        
        return r0;
        //return (ssize_t) __SYSCALL3(SYS_IO, 1, (sysarg_t) buf, (sysarg_t) count);
}
static ssize_t write_stdout(void *param, const void *buf, size_t count)
{
        int i;
        ipcarg_t r0,r1;

        for (i = 0; i < count; i++)
                ipc_call_sync_2(console_phone, CONSOLE_PUTCHAR, 0, ((const char *)buf)[i], &r0, &r1);
        
        return count;
        //return (ssize_t) __SYSCALL3(SYS_IO, 1, (sysarg_t) buf, (sysarg_t) count);
}



static stream_t open_stdin(void)
{
        stream_t stream;
        int phoneid;
        int res;
        
        if (console_phone < 0) {
                while ((console_phone = ipc_connect_me_to(PHONE_NS, SERVICE_CONSOLE, 0)) < 0) {
                        usleep(10000);
                }
        }
        
        stream.r = read_stdin;
        stream.param = 0;
        return stream;
}

static stream_t open_stdout(void)
{
        stream_t stream;
        int res;
        
        if (console_phone < 0) {
                while ((console_phone = ipc_connect_me_to(PHONE_NS, SERVICE_CONSOLE, 0)) < 0) {
                        volatile int a;
                        for (a = 0; a < 1048576; a++);
                }
        }
        
        stream.w = write_stdout;
        stream.param = 0;
        return stream;
}

fd_t open(const char *fname, int flags)
{
        int c = 0;
        
        while (((streams[c].w) || (streams[c].r)) && (c < FDS))
                c++;
        if (c == FDS)
                return EMFILE;
        
        if (!strcmp(fname, "stdin")) {
                streams[c] = open_stdin();
                return c;
        }
        
        if (!strcmp(fname, "stdout")) {
                //streams[c].w = write_stdout;
                //return c;
                streams[c] = open_stdout();
                return c;
        }
        
        if (!strcmp(fname, "stderr")) {
                streams[c].w = write_stderr;
                return c;
        }
}


ssize_t write(int fd, const void *buf, size_t count)
{
        if (fd < FDS)
                return streams[fd].w(streams[fd].param, buf, count);
        
        return 0;
}