123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397 |
- /* 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 <linux/types.h>
- #include "api.h"
- #include "pal.h"
- #include "pal_debug.h"
- #include "pal_defs.h"
- #include "pal_error.h"
- #include "pal_internal.h"
- #include "pal_linux.h"
- #include "pal_linux_defs.h"
- #include "pal_linux_error.h"
- typedef __kernel_pid_t pid_t;
- #include <asm/fcntl.h>
- #include <asm/stat.h>
- #include <linux/stat.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 scans the uri, parses the prefix of the uri and searches
- for stream handler wich will open or access the device. */
- static int parse_device_uri(const char** uri, char** type, struct handle_ops** ops) {
- struct handle_ops* dops = NULL;
- const char* p;
- const char* u = (*uri);
- for (p = u; (*p) && (*p) != ',' && (*p) != '/'; p++)
- ;
- if (strstartswith_static(u, "tty"))
- dops = &term_ops;
- if (!dops)
- return -PAL_ERROR_NOTSUPPORT;
- *uri = (*p) ? p + 1 : p;
- if (type) {
- *type = malloc_copy(u, p - u + 1);
- if (!*type)
- return -PAL_ERROR_NOMEM;
- (*type)[p - u] = '\0';
- }
- if (ops)
- *ops = dops;
- return 0;
- }
- static int64_t char_read(PAL_HANDLE handle, uint64_t offset, uint64_t count, void* buffer);
- static int64_t char_write(PAL_HANDLE handle, uint64_t offset, uint64_t 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);
- /* Method to open standard terminal */
- static int open_standard_term(PAL_HANDLE* handle, const char* param, int access) {
- if (param)
- return -PAL_ERROR_NOTIMPLEMENTED;
- PAL_HANDLE hdl = malloc(HANDLE_SIZE(dev));
- SET_HANDLE_TYPE(hdl, dev);
- hdl->dev.dev_type = device_type_term;
- if (!(access & PAL_ACCESS_WRONLY)) {
- HANDLE_HDR(hdl)->flags |= RFD(0);
- hdl->dev.fd_in = 0;
- }
- if (access & (PAL_ACCESS_WRONLY | PAL_ACCESS_RDWR)) {
- HANDLE_HDR(hdl)->flags |= WFD(1);
- hdl->dev.fd_out = 1;
- }
- *handle = hdl;
- return 0;
- }
- /* '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) {
- if (strcmp_static(type, "tty"))
- return -PAL_ERROR_INVAL;
- if (!WITHIN_MASK(share, PAL_SHARE_MASK) || !WITHIN_MASK(create, PAL_CREATE_MASK) ||
- !WITHIN_MASK(options, PAL_OPTION_MASK))
- return -PAL_ERROR_INVAL;
- const char* term = NULL;
- const char* param = NULL;
- const char* tmp = uri;
- while (*tmp) {
- if (!term && *tmp == '/')
- term = tmp + 1;
- if (*tmp == ',') {
- param = param + 1;
- break;
- }
- tmp++;
- }
- if (term)
- return -PAL_ERROR_NOTIMPLEMENTED;
- return open_standard_term(handle, param, access);
- }
- static int term_close(PAL_HANDLE handle) {
- __UNUSED(handle);
- return 0;
- }
- /* 'attrquery' operation for terminal stream */
- static int term_attrquery(const char* type, const char* uri, PAL_STREAM_ATTR* attr) {
- __UNUSED(uri);
- if (strcmp_static(type, "tty"))
- return -PAL_ERROR_INVAL;
- attr->handle_type = pal_type_dev;
- attr->readable = PAL_TRUE;
- attr->writable = PAL_TRUE;
- attr->runnable = PAL_FALSE;
- attr->pending_size = 0;
- return 0;
- }
- /* 'attrquery' operation for terminal stream */
- static int term_attrquerybyhdl(PAL_HANDLE hdl, PAL_STREAM_ATTR* attr) {
- attr->handle_type = pal_type_dev;
- attr->readable = (hdl->dev.fd_in != PAL_IDX_POISON);
- attr->writable = (hdl->dev.fd_out != PAL_IDX_POISON);
- attr->runnable = PAL_FALSE;
- attr->pending_size = 0;
- return 0;
- }
- 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 int64_t char_read(PAL_HANDLE handle, uint64_t offset, uint64_t size, void* buffer) {
- if (offset)
- return -PAL_ERROR_INVAL;
- PAL_IDX fd = handle->dev.fd_in;
- if (fd == PAL_IDX_POISON)
- return -PAL_ERROR_DENIED;
- if (size != (uint32_t)size)
- return -PAL_ERROR_INVAL;
- ssize_t bytes = ocall_read(fd, buffer, size);
- return IS_ERR(bytes) ? unix_to_pal_error(ERRNO(bytes)) : bytes;
- }
- /* 'write' operation for character streams. */
- static int64_t char_write(PAL_HANDLE handle, uint64_t offset, uint64_t size, const void* buffer) {
- if (offset)
- return -PAL_ERROR_INVAL;
- PAL_IDX fd = handle->dev.fd_out;
- if (fd == PAL_IDX_POISON)
- return -PAL_ERROR_DENIED;
- if (size != (uint32_t)size)
- return -PAL_ERROR_INVAL;
- ssize_t bytes = ocall_write(fd, buffer, size);
- return IS_ERR(bytes) ? unix_to_pal_error(ERRNO(bytes)) : bytes;
- }
- /* '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) {
- if (strcmp_static(type, URI_TYPE_DEV))
- return -PAL_ERROR_INVAL;
- struct handle_ops* ops = NULL;
- char* dev_type = NULL;
- int ret = 0;
- ret = parse_device_uri(&uri, &dev_type, &ops);
- if (ret < 0)
- return ret;
- if (!ops->open)
- return -PAL_ERROR_NOTSUPPORT;
- PAL_HANDLE hdl = malloc(HANDLE_SIZE(dev));
- SET_HANDLE_TYPE(hdl, dev);
- hdl->dev.fd_in = PAL_IDX_POISON;
- hdl->dev.fd_out = PAL_IDX_POISON;
- *handle = hdl;
- ret = ops->open(handle, dev_type, uri, access, share, create, options);
- free(dev_type);
- return ret;
- }
- /* 'read' operation for device stream */
- static int64_t dev_read(PAL_HANDLE handle, uint64_t offset, uint64_t 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 int64_t dev_write(PAL_HANDLE handle, uint64_t offset, uint64_t 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);
- if (handle->dev.fd_in != PAL_IDX_POISON) {
- int fd = handle->dev.fd_in;
- ocall_close(fd);
- }
- if (handle->dev.fd_out != PAL_IDX_POISON) {
- int fd = handle->dev.fd_out;
- ocall_close(fd);
- }
- if (handle->file.realpath)
- free((void*)handle->file.realpath);
- return 0;
- }
- /* '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);
- /* try to flush input stream */
- if (handle->dev.fd_in != PAL_IDX_POISON) {
- int fd = handle->dev.fd_in;
- ocall_fsync(fd);
- }
- /* if output stream exists and does not equal to input stream,
- flush output stream as well */
- if (handle->dev.fd_out != PAL_IDX_POISON && handle->dev.fd_out != handle->dev.fd_in) {
- int fd = handle->dev.fd_out;
- ocall_fsync(fd);
- }
- return 0;
- }
- /* 'attrquery' operation for device streams */
- static int dev_attrquery(const char* type, const char* uri, PAL_STREAM_ATTR* attr) {
- if (strcmp_static(type, URI_TYPE_DEV))
- return -PAL_ERROR_INVAL;
- struct handle_ops* ops = NULL;
- 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;
- ret = ops->attrquery(dev_type, uri, attr);
- free(dev_type);
- return ret;
- }
- /* '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);
- struct stat stat_buf;
- struct stat* stat_in = NULL;
- struct stat* stat_out = NULL;
- int ret;
- attr->handle_type = pal_type_dev;
- if (handle->dev.fd_in != PAL_IDX_POISON) {
- ret = ocall_fstat(handle->dev.fd_in, &stat_buf);
- if (!IS_ERR(ret))
- stat_in = &stat_buf;
- }
- if (handle->dev.fd_in != PAL_IDX_POISON) {
- ret = ocall_fstat(handle->dev.fd_in, &stat_buf);
- if (!IS_ERR(ret))
- stat_out = &stat_buf;
- }
- attr->readable = (stat_in && stataccess(stat_in, ACCESS_R));
- attr->writable = (stat_in && stataccess(stat_in, ACCESS_W));
- attr->runnable = (stat_out && stataccess(stat_out, ACCESS_X));
- attr->pending_size = stat_in ? stat_in->st_size : (stat_out ? stat_out->st_size : 0);
- return 0;
- }
- static const char* dev_getrealpath(PAL_HANDLE handle) {
- return handle->dev.realpath;
- }
- 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,
- };
|