Mercurial > ecos
diff packages/io/fileio/current/src/io.cxx @ 115:6ed91473a1cd ecos-sw-2000-08-21
Merge from eCos master repository on 2000-08-21-22:40:54-BST
| author | jlarmour |
|---|---|
| date | Fri, 25 Aug 2000 17:32:38 +0000 |
| parents | |
| children | eb9fd8c04db3 |
line wrap: on
line diff
new file mode 100644 --- /dev/null +++ b/packages/io/fileio/current/src/io.cxx @@ -0,0 +1,472 @@ +//========================================================================== +// +// io.cxx +// +// Fileio IO operations +// +//========================================================================== +//####COPYRIGHTBEGIN#### +// +// ------------------------------------------- +// The contents of this file are subject to the Red Hat eCos Public License +// Version 1.1 (the "License"); you may not use this file except in +// compliance with the License. You may obtain a copy of the License at +// http://www.redhat.com/ +// +// Software distributed under the License is distributed on an "AS IS" +// basis, WITHOUT WARRANTY OF ANY KIND, either express or implied. See the +// License for the specific language governing rights and limitations under +// the License. +// +// The Original Code is eCos - Embedded Configurable Operating System, +// released September 30, 1998. +// +// The Initial Developer of the Original Code is Red Hat. +// Portions created by Red Hat are +// Copyright (C) 1998, 1999, 2000 Red Hat, Inc. +// All Rights Reserved. +// ------------------------------------------- +// +//####COPYRIGHTEND#### +//========================================================================== +//#####DESCRIPTIONBEGIN#### +// +// Author(s): nickg +// Contributors: nickg +// Date: 2000-05-25 +// Purpose: Fileio IO operations +// Description: These are the functions that operate on open files, +// such as read(), write(), fstat() etc. +// +// +// +//####DESCRIPTIONEND#### +// +//========================================================================== + +#include <pkgconf/hal.h> +#include <pkgconf/kernel.h> +#include <pkgconf/io_fileio.h> + +#include <cyg/kernel/ktypes.h> // base kernel types +#include <cyg/infra/cyg_trac.h> // tracing macros +#include <cyg/infra/cyg_ass.h> // assertion macros + +#include <stdarg.h> // for fcntl() + +#include "fio.h" // Private header + +#include <cyg/kernel/mutex.hxx> // mutex definitions + +//========================================================================== +// File object locking + +#define LOCK_FILE( fp ) cyg_file_lock( fp, fp->f_syncmode ) + +#define UNLOCK_FILE( fp ) cyg_file_unlock( fp, fp->f_syncmode ) + +//========================================================================== +// Read from a file + +__externC ssize_t read( int fd, void *buf, size_t len ) +{ + FILEIO_ENTRY(); + + CYG_CANCELLATION_POINT; + + ssize_t cnt; + int ret; + cyg_file *fp; + + if( len > SSIZE_MAX ) + FILEIO_RETURN(EINVAL); + + fp = cyg_fp_get( fd ); + + if( fp == NULL ) + FILEIO_RETURN(EBADF); + + if( (fp->f_flag & CYG_FREAD) == 0 ) + { + cyg_fp_free( fp ); + FILEIO_RETURN(EBADF); + } + + cyg_uio uio; + cyg_iovec iov; + + iov.iov_base = buf; + iov.iov_len = len; + uio.uio_iov = &iov; + uio.uio_iovcnt = 1; + uio.uio_resid = len; + uio.uio_rw = UIO_READ; + uio.uio_segflg = UIO_USERSPACE; + + cnt = len; + + LOCK_FILE( fp ); + + ret = fp->f_ops->fo_read( fp, &uio ); + + UNLOCK_FILE( fp ); + + cnt -= uio.uio_resid; + + cyg_fp_free( fp ); + + CYG_CANCELLATION_POINT; + + CYG_REPORT_RETVAL(cnt); + return cnt; +} + +//========================================================================== +// Write to a file + +__externC ssize_t write( int fd, const void *buf, size_t len ) +{ + FILEIO_ENTRY(); + + CYG_CANCELLATION_POINT; + + ssize_t cnt; + int ret; + cyg_file *fp; + + if( len > SSIZE_MAX ) + FILEIO_RETURN(EINVAL); + + fp = cyg_fp_get( fd ); + + if( fp == NULL ) + FILEIO_RETURN(EBADF); + + if( (fp->f_flag & CYG_FWRITE) == 0) + { + cyg_fp_free( fp ); + FILEIO_RETURN(EBADF); + } + cyg_uio uio; + cyg_iovec iov; + + iov.iov_base = (void *)buf; + iov.iov_len = len; + uio.uio_iov = &iov; + uio.uio_iovcnt = 1; + uio.uio_resid = len; + uio.uio_rw = UIO_WRITE; + uio.uio_segflg = UIO_USERSPACE; + + cnt = len; + + LOCK_FILE( fp ); + + ret = fp->f_ops->fo_write( fp, &uio ); + + UNLOCK_FILE( fp ); + + cnt -= uio.uio_resid; + + cyg_fp_free( fp ); + + CYG_CANCELLATION_POINT; + + CYG_REPORT_RETVAL(cnt); + return cnt; +} + +//========================================================================== +// Close a file + +__externC int close( int fd ) +{ + FILEIO_ENTRY(); + + CYG_CANCELLATION_POINT; + + int ret; + cyg_file *fp; + + fp = cyg_fp_get( fd ); + + if( fp == NULL ) + FILEIO_RETURN(EBADF); + + cyg_fp_free( fp ); + + // The file's fo_close entry may be called as a side + // effect of this operation... + ret = cyg_fd_free( fd ); + + CYG_CANCELLATION_POINT; + + FILEIO_RETURN(ret); +} + +//========================================================================== +// Seek a file + +__externC off_t lseek( int fd, off_t pos, int whence ) +{ + FILEIO_ENTRY(); + + int ret; + cyg_file *fp; + + fp = cyg_fp_get( fd ); + + if( fp == NULL ) + FILEIO_RETURN(EBADF); + + LOCK_FILE( fp ); + + ret = fp->f_ops->fo_lseek( fp, &pos, whence ); + + UNLOCK_FILE( fp ); + + cyg_fp_free( fp ); + + if( ret != 0 ) + FILEIO_RETURN(ret); + + CYG_REPORT_RETVAL(pos); + return pos; +} + +//========================================================================== +// ioctl + +__externC int ioctl( int fd, CYG_ADDRWORD com, CYG_ADDRWORD data ) +{ + FILEIO_ENTRY(); + + int ret; + cyg_file *fp; + + fp = cyg_fp_get( fd ); + + if( fp == NULL ) + FILEIO_RETURN(EBADF); + + LOCK_FILE( fp ); + + ret = fp->f_ops->fo_ioctl( fp, com, data ); + + UNLOCK_FILE( fp ); + + cyg_fp_free( fp ); + + FILEIO_RETURN(ret); +} + +//========================================================================== +// fsync + +__externC int fsync( int fd ) +{ + FILEIO_ENTRY(); + + CYG_CANCELLATION_POINT; + + int ret; + cyg_file *fp; + + fp = cyg_fp_get( fd ); + + if( fp == NULL ) + FILEIO_RETURN(EBADF); + + LOCK_FILE( fp ); + + ret = fp->f_ops->fo_fsync( fp, CYG_FSYNC ); + + UNLOCK_FILE( fp ); + + cyg_fp_free( fp ); + + CYG_CANCELLATION_POINT; + + FILEIO_RETURN(ret); +} + +//========================================================================== +// fdatasync() + +__externC int fdatasync( int fd ) +{ + FILEIO_ENTRY(); + + CYG_CANCELLATION_POINT; + + int ret; + cyg_file *fp; + + fp = cyg_fp_get( fd ); + + if( fp == NULL ) + FILEIO_RETURN(EBADF); + + LOCK_FILE( fp ); + + ret = fp->f_ops->fo_fsync( fp, CYG_FDATASYNC ); + + UNLOCK_FILE( fp ); + + cyg_fp_free( fp ); + + CYG_CANCELLATION_POINT; + + FILEIO_RETURN(ret); +} + +//========================================================================== +// fstat + +__externC int fstat( int fd, struct stat *buf ) +{ + FILEIO_ENTRY(); + + int ret; + cyg_file *fp; + + fp = cyg_fp_get( fd ); + + if( fp == NULL ) + FILEIO_RETURN(EBADF); + + LOCK_FILE( fp ); + + ret = fp->f_ops->fo_fstat( fp, buf ); + + UNLOCK_FILE( fp ); + + cyg_fp_free( fp ); + + FILEIO_RETURN(ret); +} + +//========================================================================== +// fpathconf + +__externC long fpathconf( int fd, int name ) +{ + FILEIO_ENTRY(); + + int ret; + cyg_file *fp; + + fp = cyg_fp_get( fd ); + + if( fp == NULL ) + FILEIO_RETURN(EBADF); + + struct cyg_pathconf_info info; + + info.name = name; + info.value = 0; + + LOCK_FILE( fp ); + + ret = fp->f_ops->fo_getinfo( fp, FILE_INFO_CONF, (char *)&info, sizeof(info) ); + + UNLOCK_FILE( fp ); + + cyg_fp_free( fp ); + + if( ret != 0 ) + FILEIO_RETURN(ret); + + CYG_REPORT_RETVAL(info.value); + return info.value; +} + +//========================================================================== +// fcntl + +__externC int fcntl( int fd, int cmd, ... ) +{ + FILEIO_ENTRY(); + + CYG_CANCELLATION_POINT; + + int ret = 0; + cyg_file *fp; + va_list a; + + fp = cyg_fp_get( fd ); + + if( fp == NULL ) + FILEIO_RETURN(EBADF); + + va_start( a, cmd ); + + switch( cmd ) + { + case F_DUPFD: + { + int fda = va_arg(a, int); + + if( fda < 0 || fda >= OPEN_MAX ) + { + errno = EBADF; + break; + } + + int fd2 = cyg_fd_alloc( fda ); + + if( fd2 == -1 ) + { + ret = EMFILE; + break; + } + + cyg_fd_assign( fd2, fp ); + + break; + } + + default: + ret = ENOTSUP; + break; + } + + va_end(a); + + cyg_fp_free( fp ); + + CYG_CANCELLATION_POINT; + + FILEIO_RETURN(ret); +} + +//========================================================================== +// isatty() + +__externC int isatty( int fd ) +{ + FILEIO_ENTRY(); + + int ret = 0; + struct stat buf; + int err; + + err = fstat( fd, &buf ); + + // Any error and we return zero. If the client wants to + // they can always pick up the error code from errno. + if( err < 0 ) + FILEIO_RETURN_VALUE(0); + + // For now we assume that all char devices are ttys. + // In future we may need to have a special getinfo() + // call to decide this more specifically. + + if( S_ISCHR( buf.st_mode ) ) + ret = 1; + + FILEIO_RETURN_VALUE(ret); +} + +// ------------------------------------------------------------------------- +// EOF io.cxx
