OpenCores
URL https://opencores.org/ocsvn/or1k/or1k/trunk

Subversion Repositories or1k

[/] [or1k/] [tags/] [nog_patch_34/] [or1ksim/] [peripheral/] [channels/] [channel.c] - Diff between revs 1350 and 1393

Go to most recent revision | Only display areas with differences | Details | Blame | View Log

Rev 1350 Rev 1393
/* channel.h -- Definition of types and structures for
/* channel.h -- Definition of types and structures for
   peripheral to communicate with host.  Addapted from UML.
   peripheral to communicate with host.  Addapted from UML.
 
 
   Copyright (C) 2002 Richard Prescott <rip@step.polymtl.ca>
   Copyright (C) 2002 Richard Prescott <rip@step.polymtl.ca>
 
 
This file is part of OpenRISC 1000 Architectural Simulator.
This file is part of OpenRISC 1000 Architectural Simulator.
 
 
This program is free software; you can redistribute it and/or modify
This program is free software; you can redistribute it and/or modify
it under the terms of the GNU General Public License as published by
it under the terms of the GNU General Public License as published by
the Free Software Foundation; either version 2 of the License, or
the Free Software Foundation; either version 2 of the License, or
(at your option) any later version.
(at your option) any later version.
 
 
This program is distributed in the hope that it will be useful,
This program is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
GNU General Public License for more details.
GNU General Public License for more details.
 
 
You should have received a copy of the GNU General Public License
You should have received a copy of the GNU General Public License
along with this program; if not, write to the Free Software
along with this program; if not, write to the Free Software
Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA. */
Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA. */
 
 
#if HAVE_CONFIG_H
#if HAVE_CONFIG_H
#include "config.h"
#include "config.h"
#endif
#endif
 
 
#define _GNU_SOURCE     /* for strndup */
#define _GNU_SOURCE     /* for strndup */
 
 
#include <stdio.h>      /* perror */
#include <stdio.h>      /* perror */
#include <stdlib.h>     /* exit */
#include <stdlib.h>     /* exit */
 
 
#if HAVE_MALLOC_H
#if HAVE_MALLOC_H
#include <malloc.h>     /* calloc, free */
#include <malloc.h>     /* calloc, free */
#endif
#endif
 
 
#include <string.h>     /* strndup, strcmp, strlen, strchr */
#include <string.h>     /* strndup, strcmp, strlen, strchr */
#include <errno.h>      /* errno */
#include <errno.h>      /* errno */
 
 
#include "port.h"
#include "port.h"
 
 
#include "channel.h"
#include "channel.h"
 
 
struct channel_factory
struct channel_factory
{
{
        const char * name;
        const char * name;
        const struct channel_ops * ops;
        const struct channel_ops * ops;
        struct channel_factory * next;
        struct channel_factory * next;
};
};
 
 
extern struct channel_ops fd_channel_ops, file_channel_ops,
extern struct channel_ops fd_channel_ops, file_channel_ops,
        xterm_channel_ops, tcp_channel_ops, tty_channel_ops;
        xterm_channel_ops, tcp_channel_ops, tty_channel_ops;
 
 
static struct channel_factory preloaded[] =
static struct channel_factory preloaded[] =
{
{
        { "fd",     &fd_channel_ops,     &preloaded[1] },
        { "fd",     &fd_channel_ops,     &preloaded[1] },
        { "file",   &file_channel_ops,   &preloaded[2] },
        { "file",   &file_channel_ops,   &preloaded[2] },
        { "xterm",  &xterm_channel_ops,  &preloaded[3] },
        { "xterm",  &xterm_channel_ops,  &preloaded[3] },
        { "tcp",    &tcp_channel_ops,    &preloaded[4] },
        { "tcp",    &tcp_channel_ops,    &preloaded[4] },
        { "tty",    &tty_channel_ops,    NULL          }
        { "tty",    &tty_channel_ops,    NULL          }
};
};
 
 
static struct channel_factory * head = &preloaded[0];
static struct channel_factory * head = &preloaded[0];
 
 
static struct channel_factory * find_channel_factory(const char * name);
static struct channel_factory * find_channel_factory(const char * name);
 
 
struct channel * channel_init(const char * descriptor)
struct channel * channel_init(const char * descriptor)
{
{
        struct channel * retval;
        struct channel * retval;
        struct channel_factory * current;
        struct channel_factory * current;
        char * args, * name;
        char * args, * name;
        int count;
        int count;
 
 
        if(!descriptor)
        if(!descriptor)
        {
        {
                return NULL;
                return NULL;
        }
        }
 
 
        retval = (struct channel*)calloc(1, sizeof(struct channel));
        retval = (struct channel*)calloc(1, sizeof(struct channel));
 
 
        if(!retval)
        if(!retval)
        {
        {
                perror(descriptor);
                perror(descriptor);
                exit(1);
                exit(1);
        }
        }
 
 
        args = strchr(descriptor, ':');
        args = strchr(descriptor, ':');
 
 
        if(args)
        if(args)
        {
        {
                count = args - descriptor;
                count = args - descriptor;
                args++;
                args++;
        }
        }
        else
        else
        {
        {
                count = strlen(descriptor);
                count = strlen(descriptor);
        }
        }
 
 
        name = (char*)strndup(descriptor, count);
        name = (char*)strndup(descriptor, count);
 
 
        if(!name)
        if(!name)
        {
        {
                perror(name);
                perror(name);
                exit(1);
                exit(1);
        }
        }
 
 
        current = find_channel_factory(name);
        current = find_channel_factory(name);
 
 
        if(!current)
        if(!current)
        {
        {
                errno = ENODEV;
                errno = ENODEV;
                perror(descriptor);
                perror(descriptor);
                exit(1);
                exit(1);
        }
        }
 
 
        retval->ops = current->ops;
        retval->ops = current->ops;
 
 
        free(name);
        free(name);
 
 
        if(!retval->ops)
        if(!retval->ops)
        {
        {
                errno = ENODEV;
                errno = ENODEV;
                perror(descriptor);
                perror(descriptor);
                exit(1);
                exit(1);
        }
        }
 
 
        if(retval->ops->init)
        if(retval->ops->init)
        {
        {
                retval->data = (retval->ops->init)(args);
                retval->data = (retval->ops->init)(args);
 
 
                if(!retval->data)
                if(!retval->data)
                {
                {
                        perror(descriptor);
                        perror(descriptor);
                        exit(1);
                        exit(1);
                }
                }
        }
        }
 
 
        return retval;
        return retval;
}
}
 
 
int channel_open(struct channel * channel)
int channel_open(struct channel * channel)
{
{
        if(channel && channel->ops && channel->ops->open)
        if(channel && channel->ops && channel->ops->open)
        {
        {
                return (channel->ops->open)(channel->data);
                return (channel->ops->open)(channel->data);
        }
        }
        errno = ENOSYS;
        errno = ENOSYS;
        return -1;
        return -1;
}
}
 
 
int channel_read(struct channel * channel, char * buffer, int size)
int channel_read(struct channel * channel, char * buffer, int size)
{
{
        if(channel && channel->ops && channel->ops->read)
        if(channel && channel->ops && channel->ops->read)
        {
        {
                return (channel->ops->read)(channel->data, buffer, size);
                return (channel->ops->read)(channel->data, buffer, size);
        }
        }
        errno = ENOSYS;
        errno = ENOSYS;
        return -1;
        return -1;
}
}
 
 
int channel_write(struct channel * channel, const char * buffer, int size)
int channel_write(struct channel * channel, const char * buffer, int size)
{
{
        if(channel && channel->ops && channel->ops->write)
        if(channel && channel->ops && channel->ops->write)
        {
        {
                return (channel->ops->write)(channel->data, buffer, size);
                return (channel->ops->write)(channel->data, buffer, size);
        }
        }
        errno = ENOSYS;
        errno = ENOSYS;
        return -1;
        return -1;
}
}
 
 
void channel_close(struct channel * channel)
void channel_close(struct channel * channel)
{
{
        if(channel && channel->ops && channel->ops->close)
        if(channel && channel->ops && channel->ops->close)
        {
        {
                (channel->ops->close)(channel->data);
                (channel->ops->close)(channel->data);
        }
        }
}
}
 
 
void channel_free(struct channel * channel)
void channel_free(struct channel * channel)
{
{
        if(channel && channel->ops && channel->ops->free)
        if(channel && channel->ops && channel->ops->free)
        {
        {
                (channel->ops->free)(channel->data);
                (channel->ops->free)(channel->data);
                free(channel);
                free(channel);
        }
        }
}
}
 
 
 
 
int channel_ok(struct channel * channel)
int channel_ok(struct channel * channel)
{
{
        if(channel && channel->ops)
        if(channel && channel->ops)
        {
        {
                if(channel->ops->isok)
                if(channel->ops->isok)
                        return (channel->ops->isok)(channel->data);
                        return (channel->ops->isok)(channel->data);
                else
                else
                        return 1;
                        return 1;
        }
        }
        return 0;
        return 0;
}
}
 
 
char * channel_status(struct channel * channel)
char * channel_status(struct channel * channel)
{
{
        if(channel && channel->ops && channel->ops->status)
        if(channel && channel->ops && channel->ops->status)
        {
        {
                return (channel->ops->status)(channel->data);
                return (channel->ops->status)(channel->data);
        }
        }
        return "";
        return "";
}
}
 
 
 
 
 
 
static struct channel_factory * find_channel_factory(const char * name)
static struct channel_factory * find_channel_factory(const char * name)
{
{
        struct channel_factory * current = head;
        struct channel_factory * current = head;
 
 
        current = head;
        current = head;
        while(current && strcmp(current->name, name))
        while(current && strcmp(current->name, name))
        {
        {
                current = current->next;
                current = current->next;
        }
        }
 
 
        return current;
        return current;
}
}
 
 
int register_channel(const char * name, const struct channel_ops * ops)
int register_channel(const char * name, const struct channel_ops * ops)
{
{
        struct channel_factory * new;
        struct channel_factory * new;
 
 
 
 
        if(find_channel_factory(name))
        if(find_channel_factory(name))
        {
        {
                errno = EEXIST;
                errno = EEXIST;
                perror(name);
                perror(name);
                exit(1);
                exit(1);
        }
        }
 
 
        new = (struct channel_factory *)calloc(1, sizeof(struct channel_factory));
        new = (struct channel_factory *)calloc(1, sizeof(struct channel_factory));
 
 
        if(!new)
        if(!new)
        {
        {
                perror(name);
                perror(name);
                exit(1);
                exit(1);
        }
        }
 
 
        new->name = name;
        new->name = name;
        new->ops  = ops;
        new->ops  = ops;
        new->next = head;
        new->next = head;
        head = new;
        head = new;
 
 
        return (int)new;        /* dummy */
        return (int)new;        /* dummy */
}
}
 
 
/*
/*
 * Local variables:
 * Local variables:
 * c-file-style: "linux"
 * c-file-style: "linux"
 * End:
 * End:
 */
 */
 
 
 
 

powered by: WebSVN 2.1.0

© copyright 1999-2024 OpenCores.org, equivalent to Oliscience, all rights reserved. OpenCores®, registered trademark.