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

Subversion Repositories or1k_old

[/] [or1k_old/] [trunk/] [rc203soc/] [sw/] [uClinux/] [fs/] [ncpfs/] [file.c] - Diff between revs 1765 and 1782

Only display areas with differences | Details | Blame | View Log

Rev 1765 Rev 1782
/*
/*
 *  file.c
 *  file.c
 *
 *
 *  Copyright (C) 1995, 1996 by Volker Lendecke
 *  Copyright (C) 1995, 1996 by Volker Lendecke
 *
 *
 */
 */
 
 
#include <asm/segment.h>
#include <asm/segment.h>
#include <asm/system.h>
#include <asm/system.h>
 
 
#include <linux/sched.h>
#include <linux/sched.h>
#include <linux/kernel.h>
#include <linux/kernel.h>
#include <linux/errno.h>
#include <linux/errno.h>
#include <linux/fcntl.h>
#include <linux/fcntl.h>
#include <linux/stat.h>
#include <linux/stat.h>
#include <linux/mm.h>
#include <linux/mm.h>
#include <linux/ncp_fs.h>
#include <linux/ncp_fs.h>
#include <linux/locks.h>
#include <linux/locks.h>
#include "ncplib_kernel.h"
#include "ncplib_kernel.h"
#include <linux/malloc.h>
#include <linux/malloc.h>
 
 
static inline int min(int a, int b)
static inline int min(int a, int b)
{
{
        return a<b ? a : b;
        return a<b ? a : b;
}
}
 
 
static int
static int
ncp_fsync(struct inode *inode, struct file *file)
ncp_fsync(struct inode *inode, struct file *file)
{
{
        return 0;
        return 0;
}
}
 
 
int
int
ncp_make_open(struct inode *i, int right)
ncp_make_open(struct inode *i, int right)
{
{
        struct nw_file_info *finfo;
        struct nw_file_info *finfo;
 
 
        if (i == NULL)
        if (i == NULL)
        {
        {
                printk("ncp_make_open: got NULL inode\n");
                printk("ncp_make_open: got NULL inode\n");
                return -EINVAL;
                return -EINVAL;
        }
        }
 
 
        finfo = NCP_FINFO(i);
        finfo = NCP_FINFO(i);
 
 
        DPRINTK("ncp_make_open: dirent->opened = %d\n", finfo->opened);
        DPRINTK("ncp_make_open: dirent->opened = %d\n", finfo->opened);
 
 
        lock_super(i->i_sb);
        lock_super(i->i_sb);
        if (finfo->opened == 0)
        if (finfo->opened == 0)
        {
        {
                finfo->access = -1;
                finfo->access = -1;
                /* tries max. rights */
                /* tries max. rights */
                if (ncp_open_create_file_or_subdir(NCP_SERVER(i),
                if (ncp_open_create_file_or_subdir(NCP_SERVER(i),
                                                   NULL, NULL,
                                                   NULL, NULL,
                                                   OC_MODE_OPEN, 0,
                                                   OC_MODE_OPEN, 0,
                                                   AR_READ | AR_WRITE,
                                                   AR_READ | AR_WRITE,
                                                   finfo) == 0)
                                                   finfo) == 0)
                {
                {
                        finfo->access = O_RDWR;
                        finfo->access = O_RDWR;
                }
                }
                else if (ncp_open_create_file_or_subdir(NCP_SERVER(i),
                else if (ncp_open_create_file_or_subdir(NCP_SERVER(i),
                                                        NULL, NULL,
                                                        NULL, NULL,
                                                        OC_MODE_OPEN, 0,
                                                        OC_MODE_OPEN, 0,
                                                        AR_READ,
                                                        AR_READ,
                                                        finfo) == 0)
                                                        finfo) == 0)
                {
                {
                        finfo->access = O_RDONLY;
                        finfo->access = O_RDONLY;
                }
                }
        }
        }
 
 
        unlock_super(i->i_sb);
        unlock_super(i->i_sb);
 
 
        if (   ((right == O_RDONLY) && (   (finfo->access == O_RDONLY)
        if (   ((right == O_RDONLY) && (   (finfo->access == O_RDONLY)
                                        || (finfo->access == O_RDWR)))
                                        || (finfo->access == O_RDWR)))
            || ((right == O_WRONLY) && (   (finfo->access == O_WRONLY)
            || ((right == O_WRONLY) && (   (finfo->access == O_WRONLY)
                                        || (finfo->access == O_RDWR)))
                                        || (finfo->access == O_RDWR)))
            || ((right == O_RDWR)   && (finfo->access == O_RDWR)))
            || ((right == O_RDWR)   && (finfo->access == O_RDWR)))
                return 0;
                return 0;
 
 
        return -EACCES;
        return -EACCES;
}
}
 
 
static int
static int
ncp_file_read(struct inode *inode, struct file *file, char *buf, int count)
ncp_file_read(struct inode *inode, struct file *file, char *buf, int count)
{
{
        int bufsize, already_read;
        int bufsize, already_read;
        off_t pos;
        off_t pos;
        int errno;
        int errno;
 
 
        DPRINTK("ncp_file_read: enter %s\n", NCP_ISTRUCT(inode)->entryName);
        DPRINTK("ncp_file_read: enter %s\n", NCP_ISTRUCT(inode)->entryName);
 
 
        if (inode == NULL)
        if (inode == NULL)
        {
        {
                DPRINTK("ncp_file_read: inode = NULL\n");
                DPRINTK("ncp_file_read: inode = NULL\n");
                return -EINVAL;
                return -EINVAL;
        }
        }
        if (!ncp_conn_valid(NCP_SERVER(inode)))
        if (!ncp_conn_valid(NCP_SERVER(inode)))
        {
        {
                return -EIO;
                return -EIO;
        }
        }
 
 
        if (!S_ISREG(inode->i_mode))
        if (!S_ISREG(inode->i_mode))
        {
        {
                DPRINTK("ncp_file_read: read from non-file, mode %07o\n",
                DPRINTK("ncp_file_read: read from non-file, mode %07o\n",
                        inode->i_mode);
                        inode->i_mode);
                return -EINVAL;
                return -EINVAL;
        }
        }
 
 
        pos = file->f_pos;
        pos = file->f_pos;
 
 
        if (pos + count > inode->i_size)
        if (pos + count > inode->i_size)
        {
        {
                count = inode->i_size - pos;
                count = inode->i_size - pos;
        }
        }
 
 
        if (count <= 0)
        if (count <= 0)
        {
        {
                return 0;
                return 0;
        }
        }
 
 
        if ((errno = ncp_make_open(inode, O_RDONLY)) != 0)
        if ((errno = ncp_make_open(inode, O_RDONLY)) != 0)
        {
        {
                return errno;
                return errno;
        }
        }
 
 
        bufsize = NCP_SERVER(inode)->buffer_size;
        bufsize = NCP_SERVER(inode)->buffer_size;
 
 
        already_read = 0;
        already_read = 0;
 
 
        /* First read in as much as possible for each bufsize. */
        /* First read in as much as possible for each bufsize. */
        while (already_read < count)
        while (already_read < count)
        {
        {
                int read_this_time;
                int read_this_time;
                int to_read = min(bufsize - (pos % bufsize),
                int to_read = min(bufsize - (pos % bufsize),
                                  count - already_read);
                                  count - already_read);
 
 
                if (ncp_read(NCP_SERVER(inode), NCP_FINFO(inode)->file_handle,
                if (ncp_read(NCP_SERVER(inode), NCP_FINFO(inode)->file_handle,
                             pos, to_read, buf, &read_this_time) != 0)
                             pos, to_read, buf, &read_this_time) != 0)
                {
                {
                        return -EIO; /* This is not exact, i know.. */
                        return -EIO; /* This is not exact, i know.. */
                }
                }
 
 
                pos += read_this_time;
                pos += read_this_time;
                buf += read_this_time;
                buf += read_this_time;
                already_read += read_this_time;
                already_read += read_this_time;
 
 
                if (read_this_time < to_read)
                if (read_this_time < to_read)
                {
                {
                        break;
                        break;
                }
                }
        }
        }
 
 
        file->f_pos = pos;
        file->f_pos = pos;
 
 
        if (!IS_RDONLY(inode))
        if (!IS_RDONLY(inode))
        {
        {
                inode->i_atime = CURRENT_TIME;
                inode->i_atime = CURRENT_TIME;
        }
        }
 
 
        inode->i_dirt = 1;
        inode->i_dirt = 1;
 
 
        DPRINTK("ncp_file_read: exit %s\n", NCP_ISTRUCT(inode)->entryName);
        DPRINTK("ncp_file_read: exit %s\n", NCP_ISTRUCT(inode)->entryName);
 
 
        return already_read;
        return already_read;
}
}
 
 
static int
static int
ncp_file_write(struct inode *inode, struct file *file, const char *buf,
ncp_file_write(struct inode *inode, struct file *file, const char *buf,
               int count)
               int count)
{
{
        int bufsize, already_written;
        int bufsize, already_written;
        off_t pos;
        off_t pos;
        int errno;
        int errno;
 
 
        if (inode == NULL)
        if (inode == NULL)
        {
        {
                DPRINTK("ncp_file_write: inode = NULL\n");
                DPRINTK("ncp_file_write: inode = NULL\n");
                return -EINVAL;
                return -EINVAL;
        }
        }
        if (!ncp_conn_valid(NCP_SERVER(inode)))
        if (!ncp_conn_valid(NCP_SERVER(inode)))
        {
        {
                return -EIO;
                return -EIO;
        }
        }
 
 
        if (!S_ISREG(inode->i_mode))
        if (!S_ISREG(inode->i_mode))
        {
        {
                DPRINTK("ncp_file_write: write to non-file, mode %07o\n",
                DPRINTK("ncp_file_write: write to non-file, mode %07o\n",
                       inode->i_mode);
                       inode->i_mode);
                return -EINVAL;
                return -EINVAL;
        }
        }
 
 
        DPRINTK("ncp_file_write: enter %s\n", NCP_ISTRUCT(inode)->entryName);
        DPRINTK("ncp_file_write: enter %s\n", NCP_ISTRUCT(inode)->entryName);
 
 
        if (count <= 0)
        if (count <= 0)
        {
        {
                return 0;
                return 0;
        }
        }
 
 
        if ((errno = ncp_make_open(inode, O_RDWR)) != 0)
        if ((errno = ncp_make_open(inode, O_RDWR)) != 0)
        {
        {
                return errno;
                return errno;
        }
        }
 
 
        pos = file->f_pos;
        pos = file->f_pos;
 
 
        if (file->f_flags & O_APPEND)
        if (file->f_flags & O_APPEND)
        {
        {
                pos = inode->i_size;
                pos = inode->i_size;
        }
        }
 
 
        bufsize = NCP_SERVER(inode)->buffer_size;
        bufsize = NCP_SERVER(inode)->buffer_size;
 
 
        already_written = 0;
        already_written = 0;
 
 
        while (already_written < count)
        while (already_written < count)
        {
        {
                int written_this_time;
                int written_this_time;
                int to_write = min(bufsize - (pos % bufsize),
                int to_write = min(bufsize - (pos % bufsize),
                                   count - already_written);
                                   count - already_written);
 
 
                if (ncp_write(NCP_SERVER(inode), NCP_FINFO(inode)->file_handle,
                if (ncp_write(NCP_SERVER(inode), NCP_FINFO(inode)->file_handle,
                              pos, to_write, buf, &written_this_time) != 0)
                              pos, to_write, buf, &written_this_time) != 0)
                {
                {
                        return -EIO;
                        return -EIO;
                }
                }
 
 
                pos += written_this_time;
                pos += written_this_time;
                buf += written_this_time;
                buf += written_this_time;
                already_written += written_this_time;
                already_written += written_this_time;
 
 
                if (written_this_time < to_write)
                if (written_this_time < to_write)
                {
                {
                        break;
                        break;
                }
                }
        }
        }
 
 
        inode->i_mtime = inode->i_ctime = CURRENT_TIME;
        inode->i_mtime = inode->i_ctime = CURRENT_TIME;
        inode->i_dirt = 1;
        inode->i_dirt = 1;
 
 
        file->f_pos = pos;
        file->f_pos = pos;
 
 
        if (pos > inode->i_size)
        if (pos > inode->i_size)
        {
        {
                inode->i_size = pos;
                inode->i_size = pos;
                ncp_invalid_dir_cache(NCP_INOP(inode)->dir->inode);
                ncp_invalid_dir_cache(NCP_INOP(inode)->dir->inode);
        }
        }
 
 
        DPRINTK("ncp_file_write: exit %s\n", NCP_ISTRUCT(inode)->entryName);
        DPRINTK("ncp_file_write: exit %s\n", NCP_ISTRUCT(inode)->entryName);
 
 
        return already_written;
        return already_written;
}
}
 
 
static struct file_operations ncp_file_operations = {
static struct file_operations ncp_file_operations = {
        NULL,                   /* lseek - default */
        NULL,                   /* lseek - default */
        ncp_file_read,          /* read */
        ncp_file_read,          /* read */
        ncp_file_write,         /* write */
        ncp_file_write,         /* write */
        NULL,                   /* readdir - bad */
        NULL,                   /* readdir - bad */
        NULL,                   /* select - default */
        NULL,                   /* select - default */
        ncp_ioctl,              /* ioctl */
        ncp_ioctl,              /* ioctl */
        ncp_mmap,               /* mmap */
        ncp_mmap,               /* mmap */
        NULL,                   /* open */
        NULL,                   /* open */
        NULL,                   /* release */
        NULL,                   /* release */
        ncp_fsync,              /* fsync */
        ncp_fsync,              /* fsync */
};
};
 
 
struct inode_operations ncp_file_inode_operations = {
struct inode_operations ncp_file_inode_operations = {
        &ncp_file_operations,   /* default file operations */
        &ncp_file_operations,   /* default file operations */
        NULL,                   /* create */
        NULL,                   /* create */
        NULL,                   /* lookup */
        NULL,                   /* lookup */
        NULL,                   /* link */
        NULL,                   /* link */
        NULL,                   /* unlink */
        NULL,                   /* unlink */
        NULL,                   /* symlink */
        NULL,                   /* symlink */
        NULL,                   /* mkdir */
        NULL,                   /* mkdir */
        NULL,                   /* rmdir */
        NULL,                   /* rmdir */
        NULL,                   /* mknod */
        NULL,                   /* mknod */
        NULL,                   /* rename */
        NULL,                   /* rename */
        NULL,                   /* readlink */
        NULL,                   /* readlink */
        NULL,                   /* follow_link */
        NULL,                   /* follow_link */
        NULL,                   /* bmap */
        NULL,                   /* bmap */
        NULL                    /* truncate */
        NULL                    /* truncate */
};
};
 
 

powered by: WebSVN 2.1.0

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