123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247 |
- /* -*- mode:c; c-file-style:"k&r"; c-basic-offset: 4; tab-width:4; indent-tabs-mode:nil; mode:auto-fill; fill-column:78; -*- */
- /* vim: set ts=4 sw=4 et tw=78 fo=cqt wm=0: */
- /* Copyright (C) 2014 Stony Brook University
- This file is part of Graphene Library OS.
- Graphene Library OS is free software: you can redistribute it and/or
- modify it under the terms of the GNU Lesser General Public License
- as published by the Free Software Foundation, either version 3 of the
- License, or (at your option) any later version.
- Graphene Library OS is distributed in the hope that it will be useful,
- but WITHOUT ANY WARRANTY; without even the implied warranty of
- MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
- GNU Lesser General Public License for more details.
- You should have received a copy of the GNU Lesser General Public License
- along with this program. If not, see <http://www.gnu.org/licenses/>. */
- /*
- * db_device.c
- *
- * This file contains operands to handle streams with URIs that start with
- * "dev:".
- */
- #include "pal_defs.h"
- #include "pal.h"
- #include "pal_internal.h"
- #include "pal_debug.h"
- #include "pal_error.h"
- #include "api.h"
- #define DEVICE_OPS(handle) \
- ({ int _type = (handle)->dev.dev_type; \
- (_type <= 0 || _type >= PAL_DEVICE_TYPE_BOUND) ? \
- NULL : pal_device_ops[_type]; \
- })
- enum {
- device_type_none = 0,
- device_type_term,
- PAL_DEVICE_TYPE_BOUND,
- };
- static struct handle_ops term_ops;
- static const struct handle_ops * pal_device_ops [PAL_DEVICE_TYPE_BOUND] = {
- NULL,
- &term_ops,
- };
- /* parse-device_uri scan the uri, parse the prefix of the uri and search
- for stream handler wich will open or access the device */
- static int parse_device_uri (const char ** uri, const char ** type,
- struct handle_ops ** ops)
- {
- struct handle_ops * dops = NULL;
- const char * p, * u = (*uri);
- for (p = u ; (*p) && (*p) != ',' && (*p) != '/' ; p++);
- if (strpartcmp_static(u, "tty"))
- dops = &term_ops;
- if (!dops)
- return -PAL_ERROR_NOTSUPPORT;
- *uri = (*p) ? p + 1 : p;
- if (type)
- *type = u;
- if (ops)
- *ops = dops;
- return 0;
- }
- static int char_read (PAL_HANDLE handle, int offset, int count, void * buffer);
- static int char_write (PAL_HANDLE handle, int offset, int count,
- const void * buffer);
- static int term_attrquery (const char * type, const char * uri,
- PAL_STREAM_ATTR * attr);
- static int term_attrquerybyhdl (PAL_HANDLE hdl,
- PAL_STREAM_ATTR * attr);
- /* 'open' operation for terminal stream */
- static int term_open (PAL_HANDLE *handle, const char * type, const char * uri,
- int access, int share, int create, int options)
- {
- return -PAL_ERROR_NOTIMPLEMENTED;
- }
- static int term_close (PAL_HANDLE handle)
- {
- return -PAL_ERROR_NOTIMPLEMENTED;
- }
- /* 'attrquery' operation for terminal stream */
- static int term_attrquery (const char * type, const char * uri,
- PAL_STREAM_ATTR * attr)
- {
- return -PAL_ERROR_NOTIMPLEMENTED;
- }
- /* 'attrquery' operation for terminal stream */
- static int term_attrquerybyhdl (PAL_HANDLE hdl,
- PAL_STREAM_ATTR * attr)
- {
- return -PAL_ERROR_NOTIMPLEMENTED;
- }
- static struct handle_ops term_ops = {
- .open = &term_open,
- .close = &term_close,
- .read = &char_read,
- .write = &char_write,
- .attrquery = &term_attrquery,
- .attrquerybyhdl = &term_attrquerybyhdl,
- };
- /* 'read' operation for character streams. */
- static int char_read (PAL_HANDLE handle, int offset, int size, void * buffer)
- {
- return -PAL_ERROR_NOTIMPLEMENTED;
- }
- /* 'write' operation for character streams. */
- static int char_write (PAL_HANDLE handle, int offset, int size,
- const void * buffer)
- {
- return -PAL_ERROR_NOTIMPLEMENTED;
- }
- /* 'open' operation for device streams */
- static int dev_open (PAL_HANDLE * handle, const char * type, const char * uri,
- int access, int share, int create, int options)
- {
- return -PAL_ERROR_NOTIMPLEMENTED;
- }
- /* 'read' operation for device stream */
- static int dev_read (PAL_HANDLE handle, int offset, int size, void * buffer)
- {
- const struct handle_ops * ops = DEVICE_OPS(handle);
- if (!ops || !ops->read)
- return -PAL_ERROR_NOTSUPPORT;
- return ops->read(handle, offset, size, buffer);
- }
- /* 'write' operation for device stream */
- static int dev_write (PAL_HANDLE handle, int offset, int size,
- const void * buffer)
- {
- const struct handle_ops * ops = DEVICE_OPS(handle);
- if (!ops || !ops->write)
- return -PAL_ERROR_NOTSUPPORT;
- return ops->write(handle, offset, size, buffer);
- }
- /* 'close' operation for device streams */
- static int dev_close (PAL_HANDLE handle)
- {
- const struct handle_ops * ops = DEVICE_OPS(handle);
- if (ops && ops->close)
- return ops->close(handle);
- return -PAL_ERROR_NOTIMPLEMENTED;
- }
- /* 'delete' operation for device streams */
- static int dev_delete (PAL_HANDLE handle, int access)
- {
- const struct handle_ops * ops = DEVICE_OPS(handle);
- if (!ops || !ops->delete)
- return -PAL_ERROR_DENIED;
- int ret = dev_close(handle);
- if (ret < 0)
- return ret;
- return ops->delete(handle, access);
- }
- /* 'flush' operation for device streams */
- static int dev_flush (PAL_HANDLE handle)
- {
- const struct handle_ops * ops = DEVICE_OPS(handle);
- if (ops && ops->flush)
- return ops->flush(handle);
- return -PAL_ERROR_NOTIMPLEMENTED;
- }
- /* 'attrquery' operation for device streams */
- static int dev_attrquery (const char * type, const char * uri,
- PAL_STREAM_ATTR * attr)
- {
- struct handle_ops * ops = NULL;
- const char * dev_type = NULL;
- int ret = 0;
- ret = parse_device_uri(&uri, &dev_type, &ops);
- if (ret < 0)
- return ret;
- if (!ops || !ops->attrquery)
- return -PAL_ERROR_NOTSUPPORT;
- return ops->attrquery(dev_type, uri, attr);
- }
- /* 'attrquerybyhdl' operation for device stream */
- static int dev_attrquerybyhdl (PAL_HANDLE handle,
- PAL_STREAM_ATTR * attr)
- {
- const struct handle_ops * ops = DEVICE_OPS(handle);
- if (ops && ops->attrquerybyhdl)
- return ops->attrquerybyhdl(handle, attr);
- return -PAL_ERROR_NOTIMPLEMENTED;
- }
- static const char * dev_getrealpath (PAL_HANDLE handle)
- {
- return NULL;
- }
- struct handle_ops dev_ops = {
- .getrealpath = &dev_getrealpath,
- .open = &dev_open,
- .read = &dev_read,
- .write = &dev_write,
- .close = &dev_close,
- .delete = &dev_delete,
- .flush = &dev_flush,
- .attrquery = &dev_attrquery,
- .attrquerybyhdl = &dev_attrquerybyhdl,
- };
|