openbsd-20031007
[openafs.git] / src / afs / OBSD / osi_file.c
index 58ba584..045b123 100644 (file)
 #include <afsconfig.h>
 #include "afs/param.h"
 
-RCSID("$Header$");
+RCSID
+    ("$Header$");
 
 #include "afs/sysincludes.h"   /* Standard vendor system headers */
 #include "afs/afsincludes.h"   /* Afs-based standard headers */
-#include "afs/afs_stats.h"  /* afs statistics */
+#include "afs/afs_stats.h"     /* afs statistics */
 
 
-int afs_osicred_initialized=0;
-struct  AFS_UCRED afs_osi_cred;
+int afs_osicred_initialized;
+struct AFS_UCRED afs_osi_cred;
 afs_lock_t afs_xosi;           /* lock is for tvattr */
 extern struct osi_dev cacheDev;
 extern struct mount *afs_cacheVfsp;
 
 
-void *osi_UFSOpen(afs_int32 ainode)
+void *
+osi_UFSOpen(afs_int32 ainode)
 {
-    struct osi_file *afile = NULL;
+    struct osi_file *afile;
     struct vnode *vp;
     extern int cacheDiskType;
-    afs_int32 code = 0;
+    afs_int32 code;
 
     AFS_STATCNT(osi_UFSOpen);
     if (cacheDiskType != AFS_FCACHE_TYPE_UFS)
        osi_Panic("UFSOpen called for non-UFS cache\n");
-    if (!afs_osicred_initialized) {
-       /* valid for alpha_osf, SunOS, Ultrix */
-       memset(&afs_osi_cred, 0, sizeof(struct AFS_UCRED));
-       crhold(&afs_osi_cred);
-       afs_osicred_initialized = 1;
-    }
-    afile = (struct osi_file *) osi_AllocSmallSpace(sizeof(struct osi_file));
+    afile = (struct osi_file *)osi_AllocSmallSpace(sizeof(struct osi_file));
     code = VFS_VGET(cacheDev.mp, (ino_t) ainode, &vp);
+    if (vp->v_type == VNON)
+       code = ENOENT;
     if (code) {
        osi_FreeSmallSpace(afile);
        osi_Panic("UFSOpen: igetinode failed");
     }
     afile->vnode = vp;
-    afile->size = 0;
+    afile->size = VTOI(vp)->i_ffs_size;
     afile->offset = 0;
-    afile->proc = (int (*)()) NULL;
+    afile->proc = NULL;
     afile->inum = ainode;      /* for hint validity checking */
     VOP_UNLOCK(vp, 0, curproc);
     return (void *)afile;
 }
 
-int afs_osi_Stat(struct osi_file *afile, struct osi_stat *astat)
+int
+afs_osi_Stat(struct osi_file *afile, struct osi_stat *astat)
 {
     afs_int32 code;
     struct vattr tvattr;
@@ -63,10 +62,10 @@ int afs_osi_Stat(struct osi_file *afile, struct osi_stat *astat)
     AFS_STATCNT(osi_Stat);
     MObtainWriteLock(&afs_xosi, 320);
     AFS_GUNLOCK();
-    code = VOP_GETATTR(afile->vnode, &tvattr, &afs_osi_cred, curproc);
+    code = VOP_GETATTR(afile->vnode, &tvattr, afs_osi_credp, curproc);
     AFS_GLOCK();
     if (code == 0) {
-       astat->size = tvattr.va_size;
+       astat->size = afile->size = tvattr.va_size;
        astat->blksize = tvattr.va_blocksize;
        astat->mtime = tvattr.va_mtime.tv_sec;
        astat->atime = tvattr.va_atime.tv_sec;
@@ -75,7 +74,8 @@ int afs_osi_Stat(struct osi_file *afile, struct osi_stat *astat)
     return code;
 }
 
-int osi_UFSClose(struct osi_file *afile)
+int
+osi_UFSClose(struct osi_file *afile)
 {
     AFS_STATCNT(osi_Close);
 
@@ -86,7 +86,8 @@ int osi_UFSClose(struct osi_file *afile)
     return 0;
 }
 
-int osi_UFSTruncate(struct osi_file *afile, afs_int32 asize)
+int
+osi_UFSTruncate(struct osi_file *afile, afs_int32 asize)
 {
     struct vattr tvattr;
     afs_int32 code;
@@ -94,7 +95,8 @@ int osi_UFSTruncate(struct osi_file *afile, afs_int32 asize)
 
     AFS_STATCNT(osi_Truncate);
 
-    /* This routine only shrinks files, and most systems
+    /*
+     * This routine only shrinks files, and most systems
      * have very slow truncates, even when the file is already
      * small enough.  Check now and save some time.
      */
@@ -102,55 +104,61 @@ int osi_UFSTruncate(struct osi_file *afile, afs_int32 asize)
     if (code || tstat.size <= asize)
        return code;
 
-    MObtainWriteLock(&afs_xosi,321);
+    MObtainWriteLock(&afs_xosi, 321);
     VATTR_NULL(&tvattr);
     tvattr.va_size = asize;
     AFS_GUNLOCK();
     VOP_LOCK(afile->vnode, LK_EXCLUSIVE | LK_RETRY, curproc);
-    code = VOP_SETATTR(afile->vnode, &tvattr, &afs_osi_cred, curproc);
+    code = VOP_SETATTR(afile->vnode, &tvattr, afs_osi_credp, curproc);
     VOP_UNLOCK(afile->vnode, 0, curproc);
     AFS_GLOCK();
+    if (code == 0)
+       afile->size = asize;
     MReleaseWriteLock(&afs_xosi);
     return code;
 }
 
-void osi_DisableAtimes(struct vnode *avp)
+void
+osi_DisableAtimes(struct vnode *avp)
 {
-    struct inode *ip = VTOI(avp);
-    ip->i_flag &= ~IACC;
+#if 0
+    VTOI(avp)->i_flag &= ~IN_ACCESS;
+#endif
 }
 
 
 /* Generic read interface */
-int afs_osi_Read(struct osi_file *afile, int offset, void *aptr, afs_int32 asize)
+int
+afs_osi_Read(struct osi_file *afile, int offset, void *aptr, afs_int32 asize)
 {
     unsigned int resid;
     afs_int32 code;
 
     AFS_STATCNT(osi_Read);
 
-    /**
+    /*
      * If the osi_file passed in is NULL, panic only if AFS is not shutting
      * down. No point in crashing when we are already shutting down
      */
-    if ( !afile ) {
-       if ( !afs_shuttingdown )
+    if (!afile) {
+       if (!afs_shuttingdown)
            osi_Panic("osi_Read called with null param");
        else
            return EIO;
     }
 
-    if (offset != -1) afile->offset = offset;
+    if (offset != -1)
+       afile->offset = offset;
     AFS_GUNLOCK();
-    code = gop_rdwr(UIO_READ, afile->vnode, (caddr_t) aptr, asize, afile->offset,
-                   AFS_UIOSYS, IO_UNIT, &afs_osi_cred, &resid);
+    code =
+       vn_rdwr(UIO_READ, afile->vnode, aptr, asize, afile->offset,
+               AFS_UIOSYS, IO_UNIT, afs_osi_credp, &resid, curproc);
     AFS_GLOCK();
     if (code == 0) {
        code = asize - resid;
        afile->offset += code;
        osi_DisableAtimes(afile->vnode);
-    }
-    else {
+    } else {
        afs_Trace2(afs_iclSetp, CM_TRACE_READFAILED, ICL_TYPE_INT32, resid,
                   ICL_TYPE_INT32, code);
        code = -1;
@@ -159,53 +167,59 @@ int afs_osi_Read(struct osi_file *afile, int offset, void *aptr, afs_int32 asize
 }
 
 /* Generic write interface */
-int afs_osi_Write(struct osi_file *afile, afs_int32 offset, void *aptr, afs_int32 asize)
+int
+afs_osi_Write(struct osi_file *afile, afs_int32 offset, void *aptr,
+             afs_int32 asize)
 {
     unsigned int resid;
     afs_int32 code;
 
     AFS_STATCNT(osi_Write);
     if (!afile)
-        osi_Panic("afs_osi_Write called with null afile");
+       osi_Panic("afs_osi_Write called with null afile");
     if (offset != -1)
        afile->offset = offset;
 
     AFS_GUNLOCK();
     VOP_LOCK(afile->vnode, LK_EXCLUSIVE | LK_RETRY, curproc);
-    code = gop_rdwr(UIO_WRITE, afile->vnode, (caddr_t) aptr, asize, afile->offset,
-                   AFS_UIOSYS, IO_UNIT, &afs_osi_cred, &resid);
+    code =
+       vn_rdwr(UIO_WRITE, afile->vnode, (caddr_t) aptr, asize, afile->offset,
+               AFS_UIOSYS, IO_UNIT, afs_osi_credp, &resid, curproc);
     VOP_UNLOCK(afile->vnode, 0, curproc);
     AFS_GLOCK();
 
     if (code == 0) {
        code = asize - resid;
        afile->offset += code;
+       if (afile->offset > afile->size)
+           afile->size = afile->offset;
     } else
        code = -1;
 
     if (afile->proc)
-       (*afile->proc)(afile, code);
+       (*afile->proc) (afile, code);
 
     return code;
 }
 
-
-/*  This work should be handled by physstrat in ca/machdep.c.
-    This routine written from the RT NFS port strategy routine.
-    It has been generalized a bit, but should still be pretty clear. */
-int afs_osi_MapStrategy(int (*aproc)(), struct buf *bp)
+/*
+ * This work should be handled by physstrat in ca/machdep.c.  This routine
+ * written from the RT NFS port strategy routine.  It has been generalized a
+ * bit, but should still be pretty clear.
+ */
+int
+afs_osi_MapStrategy(int (*aproc) (), struct buf *bp)
 {
     afs_int32 returnCode;
 
     AFS_STATCNT(osi_MapStrategy);
-    returnCode = (*aproc)(bp);
+    returnCode = (*aproc) (bp);
 
     return returnCode;
 }
 
-
-
-void shutdown_osifile(void)
+void
+shutdown_osifile(void)
 {
     AFS_STATCNT(shutdown_osifile);
     if (afs_cold_shutdown)