138414Smckusick /* 238414Smckusick * Copyright (c) 1989 The Regents of the University of California. 338414Smckusick * All rights reserved. 438414Smckusick * 538414Smckusick * This code is derived from software contributed to Berkeley by 638414Smckusick * Rick Macklem at The University of Guelph. 738414Smckusick * 838414Smckusick * Redistribution and use in source and binary forms are permitted 938414Smckusick * provided that the above copyright notice and this paragraph are 1038414Smckusick * duplicated in all such forms and that any documentation, 1138414Smckusick * advertising materials, and other materials related to such 1238414Smckusick * distribution and use acknowledge that the software was developed 1338414Smckusick * by the University of California, Berkeley. The name of the 1438414Smckusick * University may not be used to endorse or promote products derived 1538414Smckusick * from this software without specific prior written permission. 1638414Smckusick * THIS SOFTWARE IS PROVIDED ``AS IS'' AND WITHOUT ANY EXPRESS OR 1738414Smckusick * IMPLIED WARRANTIES, INCLUDING, WITHOUT LIMITATION, THE IMPLIED 1838414Smckusick * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE. 1938414Smckusick * 20*41398Smckusick * @(#)nfs_vnops.c 7.37 (Berkeley) 05/04/90 2138414Smckusick */ 2238414Smckusick 2338414Smckusick /* 2438414Smckusick * vnode op calls for sun nfs version 2 2538414Smckusick */ 2638414Smckusick 2738414Smckusick #include "machine/pte.h" 2838414Smckusick #include "machine/mtpr.h" 2938414Smckusick #include "param.h" 3038414Smckusick #include "user.h" 3138414Smckusick #include "proc.h" 3240296Smckusick #include "kernel.h" 3338414Smckusick #include "mount.h" 3438414Smckusick #include "buf.h" 3538414Smckusick #include "vm.h" 3638414Smckusick #include "malloc.h" 3738414Smckusick #include "mbuf.h" 3838414Smckusick #include "errno.h" 3938414Smckusick #include "file.h" 4038414Smckusick #include "conf.h" 4138414Smckusick #include "vnode.h" 4240251Smckusick #include "text.h" 4338884Smacklem #include "map.h" 4438414Smckusick #include "nfsv2.h" 4538414Smckusick #include "nfs.h" 4638414Smckusick #include "nfsnode.h" 4738414Smckusick #include "nfsmount.h" 4838414Smckusick #include "xdr_subs.h" 4938414Smckusick #include "nfsm_subs.h" 5038884Smacklem #include "nfsiom.h" 5138414Smckusick 5238414Smckusick /* Defs */ 5338414Smckusick #define TRUE 1 5438414Smckusick #define FALSE 0 5538414Smckusick 5638414Smckusick /* Global vars */ 5738414Smckusick int nfs_lookup(), 5838414Smckusick nfs_create(), 5939459Smckusick nfs_mknod(), 6038414Smckusick nfs_open(), 6138414Smckusick nfs_close(), 6238414Smckusick nfs_access(), 6338414Smckusick nfs_getattr(), 6438414Smckusick nfs_setattr(), 6538414Smckusick nfs_read(), 6638414Smckusick nfs_write(), 6738414Smckusick vfs_noop(), 6838414Smckusick vfs_nullop(), 6938414Smckusick nfs_remove(), 7038414Smckusick nfs_link(), 7138414Smckusick nfs_rename(), 7238414Smckusick nfs_mkdir(), 7338414Smckusick nfs_rmdir(), 7438414Smckusick nfs_symlink(), 7538414Smckusick nfs_readdir(), 7638414Smckusick nfs_readlink(), 7738414Smckusick nfs_abortop(), 7838414Smckusick nfs_lock(), 7938414Smckusick nfs_unlock(), 8038414Smckusick nfs_bmap(), 8138414Smckusick nfs_strategy(), 8238884Smacklem nfs_fsync(), 8339394Smckusick nfs_inactive(), 8439672Smckusick nfs_reclaim(), 8539906Smckusick nfs_print(), 8639906Smckusick nfs_islocked(); 8738414Smckusick 8838414Smckusick struct vnodeops nfsv2_vnodeops = { 8939672Smckusick nfs_lookup, /* lookup */ 9039672Smckusick nfs_create, /* create */ 9139672Smckusick nfs_mknod, /* mknod */ 9239672Smckusick nfs_open, /* open */ 9339672Smckusick nfs_close, /* close */ 9439672Smckusick nfs_access, /* access */ 9539672Smckusick nfs_getattr, /* getattr */ 9639672Smckusick nfs_setattr, /* setattr */ 9739672Smckusick nfs_read, /* read */ 9839672Smckusick nfs_write, /* write */ 9939672Smckusick vfs_noop, /* ioctl */ 10039672Smckusick vfs_noop, /* select */ 10139672Smckusick vfs_noop, /* mmap */ 10239672Smckusick nfs_fsync, /* fsync */ 10339672Smckusick vfs_nullop, /* seek */ 10439672Smckusick nfs_remove, /* remove */ 10539672Smckusick nfs_link, /* link */ 10639672Smckusick nfs_rename, /* rename */ 10739672Smckusick nfs_mkdir, /* mkdir */ 10839672Smckusick nfs_rmdir, /* rmdir */ 10939672Smckusick nfs_symlink, /* symlink */ 11039672Smckusick nfs_readdir, /* readdir */ 11139672Smckusick nfs_readlink, /* readlink */ 11239672Smckusick nfs_abortop, /* abortop */ 11339672Smckusick nfs_inactive, /* inactive */ 11439672Smckusick nfs_reclaim, /* reclaim */ 11539672Smckusick nfs_lock, /* lock */ 11639672Smckusick nfs_unlock, /* unlock */ 11739672Smckusick nfs_bmap, /* bmap */ 11839672Smckusick nfs_strategy, /* strategy */ 11939672Smckusick nfs_print, /* print */ 12039906Smckusick nfs_islocked, /* islocked */ 12138414Smckusick }; 12238414Smckusick 12338414Smckusick /* Special device vnode ops */ 12439441Smckusick int spec_lookup(), 12539441Smckusick spec_open(), 12639441Smckusick spec_read(), 12739441Smckusick spec_write(), 12839441Smckusick spec_strategy(), 12939672Smckusick spec_bmap(), 13039441Smckusick spec_ioctl(), 13139441Smckusick spec_select(), 13239441Smckusick spec_close(), 13339441Smckusick spec_badop(), 13439441Smckusick spec_nullop(); 13538414Smckusick 13639441Smckusick struct vnodeops spec_nfsv2nodeops = { 13739599Smckusick spec_lookup, /* lookup */ 13839599Smckusick spec_badop, /* create */ 13939599Smckusick spec_badop, /* mknod */ 14039599Smckusick spec_open, /* open */ 14139599Smckusick spec_close, /* close */ 14239599Smckusick nfs_access, /* access */ 14339599Smckusick nfs_getattr, /* getattr */ 14439599Smckusick nfs_setattr, /* setattr */ 14539599Smckusick spec_read, /* read */ 14639599Smckusick spec_write, /* write */ 14739599Smckusick spec_ioctl, /* ioctl */ 14839599Smckusick spec_select, /* select */ 14939599Smckusick spec_badop, /* mmap */ 15039599Smckusick spec_nullop, /* fsync */ 15139599Smckusick spec_badop, /* seek */ 15239599Smckusick spec_badop, /* remove */ 15339599Smckusick spec_badop, /* link */ 15439599Smckusick spec_badop, /* rename */ 15539599Smckusick spec_badop, /* mkdir */ 15639599Smckusick spec_badop, /* rmdir */ 15739599Smckusick spec_badop, /* symlink */ 15839599Smckusick spec_badop, /* readdir */ 15939599Smckusick spec_badop, /* readlink */ 16039599Smckusick spec_badop, /* abortop */ 16139599Smckusick nfs_inactive, /* inactive */ 16239599Smckusick nfs_reclaim, /* reclaim */ 16339599Smckusick nfs_lock, /* lock */ 16439599Smckusick nfs_unlock, /* unlock */ 16539672Smckusick spec_bmap, /* bmap */ 16639599Smckusick spec_strategy, /* strategy */ 16739672Smckusick nfs_print, /* print */ 16839906Smckusick nfs_islocked, /* islocked */ 16938414Smckusick }; 17038414Smckusick 17140294Smckusick #ifdef FIFO 17240294Smckusick int fifo_lookup(), 17340294Smckusick fifo_open(), 17440294Smckusick fifo_read(), 17540294Smckusick fifo_write(), 17640294Smckusick fifo_bmap(), 17740294Smckusick fifo_ioctl(), 17840294Smckusick fifo_select(), 17940294Smckusick fifo_close(), 18040294Smckusick fifo_print(), 18140294Smckusick fifo_badop(), 18240294Smckusick fifo_nullop(); 18340294Smckusick 18440294Smckusick struct vnodeops fifo_nfsv2nodeops = { 18540294Smckusick fifo_lookup, /* lookup */ 18640294Smckusick fifo_badop, /* create */ 18740294Smckusick fifo_badop, /* mknod */ 18840294Smckusick fifo_open, /* open */ 18940294Smckusick fifo_close, /* close */ 19040294Smckusick nfs_access, /* access */ 19140294Smckusick nfs_getattr, /* getattr */ 19240294Smckusick nfs_setattr, /* setattr */ 19340294Smckusick fifo_read, /* read */ 19440294Smckusick fifo_write, /* write */ 19540294Smckusick fifo_ioctl, /* ioctl */ 19640294Smckusick fifo_select, /* select */ 19740294Smckusick fifo_badop, /* mmap */ 19840294Smckusick fifo_nullop, /* fsync */ 19940294Smckusick fifo_badop, /* seek */ 20040294Smckusick fifo_badop, /* remove */ 20140294Smckusick fifo_badop, /* link */ 20240294Smckusick fifo_badop, /* rename */ 20340294Smckusick fifo_badop, /* mkdir */ 20440294Smckusick fifo_badop, /* rmdir */ 20540294Smckusick fifo_badop, /* symlink */ 20640294Smckusick fifo_badop, /* readdir */ 20740294Smckusick fifo_badop, /* readlink */ 20840294Smckusick fifo_badop, /* abortop */ 20940294Smckusick nfs_inactive, /* inactive */ 21040294Smckusick nfs_reclaim, /* reclaim */ 21140294Smckusick nfs_lock, /* lock */ 21240294Smckusick nfs_unlock, /* unlock */ 21340294Smckusick fifo_bmap, /* bmap */ 21440294Smckusick fifo_badop, /* strategy */ 21540294Smckusick nfs_print, /* print */ 21640294Smckusick nfs_islocked, /* islocked */ 21740294Smckusick }; 21840294Smckusick #endif /* FIFO */ 21940294Smckusick 22038414Smckusick extern u_long nfs_procids[NFS_NPROCS]; 22138414Smckusick extern u_long nfs_prog, nfs_vers; 22238414Smckusick extern char nfsiobuf[MAXPHYS+NBPG]; 22340112Smckusick extern int nonidempotent[NFS_NPROCS]; 22438884Smacklem struct map nfsmap[NFS_MSIZ]; 22538414Smckusick enum vtype v_type[NFLNK+1]; 22638884Smacklem struct buf nfs_bqueue; /* Queue head for nfsiod's */ 22739341Smckusick int nfs_asyncdaemons = 0; 22839341Smckusick struct proc *nfs_iodwant[MAX_ASYNCDAEMON]; 22938884Smacklem static int nfsmap_want = 0; 23038414Smckusick 23138414Smckusick /* 23238414Smckusick * nfs null call from vfs. 23338414Smckusick */ 23438414Smckusick nfs_null(vp, cred) 23538414Smckusick struct vnode *vp; 23638414Smckusick struct ucred *cred; 23738414Smckusick { 23839488Smckusick caddr_t bpos, dpos; 23939488Smckusick u_long xid; 24039488Smckusick int error = 0; 24139488Smckusick struct mbuf *mreq, *mrep, *md, *mb; 24238414Smckusick 24338414Smckusick nfsm_reqhead(nfs_procids[NFSPROC_NULL], cred, 0); 24440112Smckusick nfsm_request(vp, nonidempotent[NFSPROC_NULL]); 24538414Smckusick nfsm_reqdone; 24638414Smckusick return (error); 24738414Smckusick } 24838414Smckusick 24938414Smckusick /* 25038414Smckusick * nfs access vnode op. 25138414Smckusick * Essentially just get vattr and then imitate iaccess() 25238414Smckusick */ 25338414Smckusick nfs_access(vp, mode, cred) 25438414Smckusick struct vnode *vp; 25538414Smckusick int mode; 25638414Smckusick register struct ucred *cred; 25738414Smckusick { 25838414Smckusick register struct vattr *vap; 25938414Smckusick register gid_t *gp; 26038414Smckusick struct vattr vattr; 26138414Smckusick register int i; 26238414Smckusick int error; 26338414Smckusick 26438414Smckusick /* 26538414Smckusick * If you're the super-user, 26638414Smckusick * you always get access. 26738414Smckusick */ 26838414Smckusick if (cred->cr_uid == 0) 26938414Smckusick return (0); 27038414Smckusick vap = &vattr; 27138884Smacklem if (error = nfs_getattr(vp, vap, cred)) 27238884Smacklem return (error); 27338414Smckusick /* 27438414Smckusick * Access check is based on only one of owner, group, public. 27538414Smckusick * If not owner, then check group. If not a member of the 27638414Smckusick * group, then check public access. 27738414Smckusick */ 27838414Smckusick if (cred->cr_uid != vap->va_uid) { 27938414Smckusick mode >>= 3; 28038414Smckusick gp = cred->cr_groups; 28138414Smckusick for (i = 0; i < cred->cr_ngroups; i++, gp++) 28238414Smckusick if (vap->va_gid == *gp) 28338414Smckusick goto found; 28438414Smckusick mode >>= 3; 28538414Smckusick found: 28638414Smckusick ; 28738414Smckusick } 28838414Smckusick if ((vap->va_mode & mode) != 0) 28938414Smckusick return (0); 29038414Smckusick return (EACCES); 29138414Smckusick } 29238414Smckusick 29338414Smckusick /* 29438414Smckusick * nfs open vnode op 29538414Smckusick * Just check to see if the type is ok 29638414Smckusick */ 29739488Smckusick /* ARGSUSED */ 29838414Smckusick nfs_open(vp, mode, cred) 29938414Smckusick struct vnode *vp; 30038414Smckusick int mode; 30138414Smckusick struct ucred *cred; 30238414Smckusick { 30338414Smckusick register enum vtype vtyp; 30438414Smckusick 30538414Smckusick vtyp = vp->v_type; 30638414Smckusick if (vtyp == VREG || vtyp == VDIR || vtyp == VLNK) 30738414Smckusick return (0); 30838414Smckusick else 30938414Smckusick return (EACCES); 31038414Smckusick } 31138414Smckusick 31238414Smckusick /* 31338414Smckusick * nfs close vnode op 31438884Smacklem * For reg files, invalidate any buffer cache entries. 31538414Smckusick */ 31639488Smckusick /* ARGSUSED */ 31738414Smckusick nfs_close(vp, fflags, cred) 31838414Smckusick register struct vnode *vp; 31938414Smckusick int fflags; 32038414Smckusick struct ucred *cred; 32138414Smckusick { 32239488Smckusick register struct nfsnode *np = VTONFS(vp); 32339341Smckusick int error = 0; 32438414Smckusick 32539874Smckusick if (vp->v_type == VREG && ((np->n_flag & NMODIFIED) || 32639341Smckusick ((np->n_flag & NBUFFERED) && np->n_sillyrename))) { 32739441Smckusick nfs_lock(vp); 32839341Smckusick np->n_flag &= ~(NMODIFIED|NBUFFERED); 32939751Smckusick vinvalbuf(vp, TRUE); 33039341Smckusick if (np->n_flag & NWRITEERR) { 33139341Smckusick np->n_flag &= ~NWRITEERR; 33239751Smckusick error = np->n_error; 33339341Smckusick } 33439441Smckusick nfs_unlock(vp); 33538884Smacklem } 33638414Smckusick return (error); 33738414Smckusick } 33838414Smckusick 33938414Smckusick /* 34038414Smckusick * nfs getattr call from vfs. 34138414Smckusick */ 34238414Smckusick nfs_getattr(vp, vap, cred) 34339488Smckusick register struct vnode *vp; 34439488Smckusick struct vattr *vap; 34538414Smckusick struct ucred *cred; 34638414Smckusick { 34739488Smckusick register caddr_t cp; 34839488Smckusick register long t1; 34939488Smckusick caddr_t bpos, dpos; 35039488Smckusick u_long xid; 35139488Smckusick int error = 0; 35239488Smckusick struct mbuf *mreq, *mrep, *md, *mb, *mb2; 35338414Smckusick 35438414Smckusick /* First look in the cache.. */ 35538414Smckusick if (nfs_getattrcache(vp, vap) == 0) 35638414Smckusick return (0); 35738414Smckusick nfsstats.rpccnt[NFSPROC_GETATTR]++; 35838414Smckusick nfsm_reqhead(nfs_procids[NFSPROC_GETATTR], cred, NFSX_FH); 35938414Smckusick nfsm_fhtom(vp); 36040112Smckusick nfsm_request(vp, nonidempotent[NFSPROC_GETATTR]); 36138414Smckusick nfsm_loadattr(vp, vap); 36238414Smckusick nfsm_reqdone; 36338414Smckusick return (error); 36438414Smckusick } 36538414Smckusick 36638414Smckusick /* 36738414Smckusick * nfs setattr call. 36838414Smckusick */ 36938414Smckusick nfs_setattr(vp, vap, cred) 37039488Smckusick register struct vnode *vp; 37138414Smckusick register struct vattr *vap; 37238414Smckusick struct ucred *cred; 37338414Smckusick { 37438884Smacklem register struct nfsv2_sattr *sp; 37539488Smckusick register caddr_t cp; 37639488Smckusick register long t1; 37739488Smckusick caddr_t bpos, dpos; 37839488Smckusick u_long xid; 37939488Smckusick int error = 0; 38039488Smckusick struct mbuf *mreq, *mrep, *md, *mb, *mb2; 38139359Smckusick struct nfsnode *np; 38238414Smckusick 38338414Smckusick nfsstats.rpccnt[NFSPROC_SETATTR]++; 38438414Smckusick nfsm_reqhead(nfs_procids[NFSPROC_SETATTR], cred, NFSX_FH+NFSX_SATTR); 38538414Smckusick nfsm_fhtom(vp); 38638884Smacklem nfsm_build(sp, struct nfsv2_sattr *, NFSX_SATTR); 38738414Smckusick if (vap->va_mode == 0xffff) 38838884Smacklem sp->sa_mode = VNOVAL; 38938414Smckusick else 39038884Smacklem sp->sa_mode = vtonfs_mode(vp->v_type, vap->va_mode); 39138414Smckusick if (vap->va_uid == 0xffff) 39238884Smacklem sp->sa_uid = VNOVAL; 39338414Smckusick else 39438884Smacklem sp->sa_uid = txdr_unsigned(vap->va_uid); 39538414Smckusick if (vap->va_gid == 0xffff) 39638884Smacklem sp->sa_gid = VNOVAL; 39738414Smckusick else 39838884Smacklem sp->sa_gid = txdr_unsigned(vap->va_gid); 39938884Smacklem sp->sa_size = txdr_unsigned(vap->va_size); 40039359Smckusick if (vap->va_size != VNOVAL) { 40139359Smckusick np = VTONFS(vp); 40239359Smckusick if (np->n_flag & NMODIFIED) { 40339359Smckusick np->n_flag &= ~NMODIFIED; 40439874Smckusick vinvalbuf(vp, TRUE); 40539359Smckusick } 40639359Smckusick } 40739751Smckusick sp->sa_atime.tv_sec = txdr_unsigned(vap->va_atime.tv_sec); 40839751Smckusick sp->sa_atime.tv_usec = txdr_unsigned(vap->va_flags); 40938884Smacklem txdr_time(&vap->va_mtime, &sp->sa_mtime); 41040112Smckusick nfsm_request(vp, nonidempotent[NFSPROC_SETATTR]); 41138414Smckusick nfsm_loadattr(vp, (struct vattr *)0); 41238414Smckusick /* should we fill in any vap fields ?? */ 41338414Smckusick nfsm_reqdone; 41438414Smckusick return (error); 41538414Smckusick } 41638414Smckusick 41738414Smckusick /* 41838414Smckusick * nfs lookup call, one step at a time... 41938414Smckusick * First look in cache 42038414Smckusick * If not found, unlock the directory nfsnode and do the rpc 42138414Smckusick */ 42238414Smckusick nfs_lookup(vp, ndp) 42338414Smckusick register struct vnode *vp; 42438414Smckusick register struct nameidata *ndp; 42538414Smckusick { 42638414Smckusick register struct vnode *vdp; 42739488Smckusick register u_long *p; 42839488Smckusick register caddr_t cp; 42939488Smckusick register long t1, t2; 43039488Smckusick caddr_t bpos, dpos, cp2; 43139488Smckusick u_long xid; 43239488Smckusick struct mbuf *mreq, *mrep, *md, *mb, *mb2; 43338414Smckusick struct vnode *newvp; 43438414Smckusick long len; 43538414Smckusick nfsv2fh_t *fhp; 43638414Smckusick struct nfsnode *np; 43739488Smckusick int lockparent, wantparent, flag, error = 0; 43838414Smckusick 43938414Smckusick ndp->ni_dvp = vp; 44038414Smckusick ndp->ni_vp = NULL; 44138414Smckusick if (vp->v_type != VDIR) 44238414Smckusick return (ENOTDIR); 44338414Smckusick lockparent = ndp->ni_nameiop & LOCKPARENT; 44438414Smckusick flag = ndp->ni_nameiop & OPFLAG; 44538414Smckusick wantparent = ndp->ni_nameiop & (LOCKPARENT|WANTPARENT); 44639341Smckusick if ((error = cache_lookup(ndp)) && error != ENOENT) { 44738884Smacklem struct vattr vattr; 44838884Smacklem int vpid; 44938884Smacklem 45039441Smckusick if (vp == ndp->ni_rdir && ndp->ni_isdotdot) 45139441Smckusick panic("nfs_lookup: .. through root"); 45239441Smckusick vdp = ndp->ni_vp; 45338884Smacklem vpid = vdp->v_id; 45438414Smckusick /* 45538884Smacklem * See the comment starting `Step through' in ufs/ufs_lookup.c 45638884Smacklem * for an explanation of the locking protocol 45738414Smckusick */ 45838414Smckusick if (vp == vdp) { 45938425Smckusick VREF(vdp); 46039441Smckusick error = 0; 46138414Smckusick } else if (ndp->ni_isdotdot) { 46238414Smckusick nfs_unlock(vp); 46339441Smckusick error = vget(vdp); 46438414Smckusick } else { 46539441Smckusick error = vget(vdp); 46638414Smckusick nfs_unlock(vp); 46738414Smckusick } 46839441Smckusick if (!error) { 46940251Smckusick if (vpid == vdp->v_id) { 47040251Smckusick if (!nfs_getattr(vdp, &vattr, ndp->ni_cred) && 47140251Smckusick vattr.va_ctime.tv_sec == VTONFS(vdp)->n_ctime) { 47239441Smckusick nfsstats.lookupcache_hits++; 47339441Smckusick return (0); 47440251Smckusick } else { 47540251Smckusick cache_purge(vdp); 47640251Smckusick nfs_nput(vdp); 47740251Smckusick } 47839441Smckusick } else { 47939441Smckusick nfs_nput(vdp); 48039441Smckusick } 48138884Smacklem } 482*41398Smckusick ndp->ni_vp = NULLVP; 48339751Smckusick } else 48439751Smckusick nfs_unlock(vp); 48539341Smckusick error = 0; 48638414Smckusick nfsstats.lookupcache_misses++; 48738414Smckusick nfsstats.rpccnt[NFSPROC_LOOKUP]++; 48838414Smckusick len = ndp->ni_namelen; 48938414Smckusick nfsm_reqhead(nfs_procids[NFSPROC_LOOKUP], ndp->ni_cred, NFSX_FH+NFSX_UNSIGNED+nfsm_rndup(len)); 49038414Smckusick nfsm_fhtom(vp); 49138414Smckusick nfsm_strtom(ndp->ni_ptr, len, NFS_MAXNAMLEN); 49240112Smckusick nfsm_request(vp, nonidempotent[NFSPROC_LOOKUP]); 49338414Smckusick nfsmout: 49438414Smckusick if (error) { 49539751Smckusick if (lockparent || (flag != CREATE && flag != RENAME) || 49639751Smckusick *ndp->ni_next != 0) 49739751Smckusick nfs_lock(vp); 49840483Smckusick return (error); 49938414Smckusick } 50038414Smckusick nfsm_disect(fhp,nfsv2fh_t *,NFSX_FH); 50138414Smckusick 50238414Smckusick /* 50338414Smckusick * Handle DELETE and RENAME cases... 50438414Smckusick */ 50538414Smckusick if (flag == DELETE && *ndp->ni_next == 0) { 50638414Smckusick if (!bcmp(VTONFS(vp)->n_fh.fh_bytes, (caddr_t)fhp, NFSX_FH)) { 50738425Smckusick VREF(vp); 50838414Smckusick newvp = vp; 50938414Smckusick np = VTONFS(vp); 51038414Smckusick } else { 51138414Smckusick if (error = nfs_nget(vp->v_mount, fhp, &np)) { 51239751Smckusick nfs_lock(vp); 51338414Smckusick m_freem(mrep); 51438414Smckusick return (error); 51538414Smckusick } 51638414Smckusick newvp = NFSTOV(np); 51738414Smckusick } 51839459Smckusick if (error = 51939459Smckusick nfs_loadattrcache(&newvp, &md, &dpos, (struct vattr *)0)) { 52039751Smckusick nfs_lock(vp); 52138414Smckusick if (newvp != vp) 52238414Smckusick nfs_nput(newvp); 52338414Smckusick else 52438425Smckusick vrele(vp); 52538414Smckusick m_freem(mrep); 52638414Smckusick return (error); 52738414Smckusick } 52838414Smckusick ndp->ni_vp = newvp; 52939751Smckusick if (lockparent || vp == newvp) 53039751Smckusick nfs_lock(vp); 53138414Smckusick m_freem(mrep); 53238414Smckusick return (0); 53338414Smckusick } 53438414Smckusick 53538414Smckusick if (flag == RENAME && wantparent && *ndp->ni_next == 0) { 53638414Smckusick if (!bcmp(VTONFS(vp)->n_fh.fh_bytes, (caddr_t)fhp, NFSX_FH)) { 53739751Smckusick nfs_lock(vp); 53838414Smckusick m_freem(mrep); 53938414Smckusick return (EISDIR); 54038414Smckusick } 54138414Smckusick if (error = nfs_nget(vp->v_mount, fhp, &np)) { 54239751Smckusick nfs_lock(vp); 54338414Smckusick m_freem(mrep); 54438414Smckusick return (error); 54538414Smckusick } 54638414Smckusick newvp = NFSTOV(np); 54739459Smckusick if (error = 54839459Smckusick nfs_loadattrcache(&newvp, &md, &dpos, (struct vattr *)0)) { 54939751Smckusick nfs_lock(vp); 55038425Smckusick nfs_nput(newvp); 55138414Smckusick m_freem(mrep); 55238414Smckusick return (error); 55338414Smckusick } 55438414Smckusick ndp->ni_vp = newvp; 55539751Smckusick if (lockparent) 55639751Smckusick nfs_lock(vp); 55738414Smckusick return (0); 55838414Smckusick } 55938414Smckusick 56038414Smckusick if (!bcmp(VTONFS(vp)->n_fh.fh_bytes, (caddr_t)fhp, NFSX_FH)) { 56138425Smckusick VREF(vp); 56238414Smckusick newvp = vp; 56338414Smckusick np = VTONFS(vp); 56438414Smckusick } else if (ndp->ni_isdotdot) { 56538414Smckusick if (error = nfs_nget(vp->v_mount, fhp, &np)) { 56638414Smckusick nfs_lock(vp); 56738414Smckusick m_freem(mrep); 56838414Smckusick return (error); 56938414Smckusick } 57038414Smckusick newvp = NFSTOV(np); 57138414Smckusick } else { 57238414Smckusick if (error = nfs_nget(vp->v_mount, fhp, &np)) { 57339751Smckusick nfs_lock(vp); 57438414Smckusick m_freem(mrep); 57538414Smckusick return (error); 57638414Smckusick } 57738414Smckusick newvp = NFSTOV(np); 57838414Smckusick } 57939459Smckusick if (error = nfs_loadattrcache(&newvp, &md, &dpos, (struct vattr *)0)) { 58039751Smckusick nfs_lock(vp); 58138414Smckusick if (newvp != vp) 58238414Smckusick nfs_nput(newvp); 58338414Smckusick else 58438425Smckusick vrele(vp); 58538414Smckusick m_freem(mrep); 58638414Smckusick return (error); 58738414Smckusick } 58838414Smckusick m_freem(mrep); 58938414Smckusick 59039751Smckusick if (vp == newvp || (lockparent && *ndp->ni_next == '\0')) 59139751Smckusick nfs_lock(vp); 59238414Smckusick ndp->ni_vp = newvp; 59340251Smckusick if (error == 0 && ndp->ni_makeentry) { 59440251Smckusick np->n_ctime = np->n_vattr.va_ctime.tv_sec; 59538414Smckusick cache_enter(ndp); 59640251Smckusick } 59738414Smckusick return (error); 59838414Smckusick } 59938414Smckusick 60038414Smckusick /* 60138414Smckusick * nfs readlink call 60238414Smckusick */ 60338414Smckusick nfs_readlink(vp, uiop, cred) 60439488Smckusick register struct vnode *vp; 60538414Smckusick struct uio *uiop; 60638414Smckusick struct ucred *cred; 60738414Smckusick { 60839488Smckusick register u_long *p; 60939488Smckusick register caddr_t cp; 61039488Smckusick register long t1; 61139488Smckusick caddr_t bpos, dpos, cp2; 61239488Smckusick u_long xid; 61339488Smckusick int error = 0; 61439488Smckusick struct mbuf *mreq, *mrep, *md, *mb, *mb2; 61538414Smckusick long len; 61638414Smckusick 61738414Smckusick nfsstats.rpccnt[NFSPROC_READLINK]++; 61838414Smckusick nfsm_reqhead(nfs_procids[NFSPROC_READLINK], cred, NFSX_FH); 61938414Smckusick nfsm_fhtom(vp); 62040834Smckusick nfs_unlock(vp); 62140112Smckusick nfsm_request(vp, nonidempotent[NFSPROC_READLINK]); 62238414Smckusick nfsm_strsiz(len, NFS_MAXPATHLEN); 62338414Smckusick nfsm_mtouio(uiop, len); 62438414Smckusick nfsm_reqdone; 62540834Smckusick nfs_lock(vp); 62638414Smckusick return (error); 62738414Smckusick } 62838414Smckusick 62938414Smckusick /* 63038414Smckusick * nfs read call 63138414Smckusick */ 63239587Smckusick nfs_readrpc(vp, uiop, cred) 63339488Smckusick register struct vnode *vp; 63438414Smckusick struct uio *uiop; 63538414Smckusick struct ucred *cred; 63638414Smckusick { 63739488Smckusick register u_long *p; 63839488Smckusick register caddr_t cp; 63939488Smckusick register long t1; 64039488Smckusick caddr_t bpos, dpos, cp2; 64139488Smckusick u_long xid; 64239488Smckusick int error = 0; 64339488Smckusick struct mbuf *mreq, *mrep, *md, *mb, *mb2; 64438414Smckusick struct nfsmount *nmp; 64538414Smckusick long len, retlen, tsiz; 64638414Smckusick 647*41398Smckusick nmp = VFSTONFS(vp->v_mount); 64838414Smckusick tsiz = uiop->uio_resid; 64938414Smckusick while (tsiz > 0) { 65038414Smckusick nfsstats.rpccnt[NFSPROC_READ]++; 65138414Smckusick len = (tsiz > nmp->nm_rsize) ? nmp->nm_rsize : tsiz; 65238414Smckusick nfsm_reqhead(nfs_procids[NFSPROC_READ], cred, NFSX_FH+NFSX_UNSIGNED*3); 65338414Smckusick nfsm_fhtom(vp); 65438414Smckusick nfsm_build(p, u_long *, NFSX_UNSIGNED*3); 65539587Smckusick *p++ = txdr_unsigned(uiop->uio_offset); 65638414Smckusick *p++ = txdr_unsigned(len); 65738414Smckusick *p = 0; 65840112Smckusick nfsm_request(vp, nonidempotent[NFSPROC_READ]); 65938414Smckusick nfsm_loadattr(vp, (struct vattr *)0); 66038414Smckusick nfsm_strsiz(retlen, nmp->nm_rsize); 66138414Smckusick nfsm_mtouio(uiop, retlen); 66238414Smckusick m_freem(mrep); 66338414Smckusick if (retlen < len) 66438414Smckusick tsiz = 0; 66538414Smckusick else 66638414Smckusick tsiz -= len; 66738414Smckusick } 66838414Smckusick nfsmout: 66938414Smckusick return (error); 67038414Smckusick } 67138414Smckusick 67238414Smckusick /* 67338414Smckusick * nfs write call 67438414Smckusick */ 67539587Smckusick nfs_writerpc(vp, uiop, cred) 67639488Smckusick register struct vnode *vp; 67738414Smckusick struct uio *uiop; 67838414Smckusick struct ucred *cred; 67938414Smckusick { 68039488Smckusick register u_long *p; 68139488Smckusick register caddr_t cp; 68239488Smckusick register long t1; 68339488Smckusick caddr_t bpos, dpos; 68439488Smckusick u_long xid; 68539488Smckusick int error = 0; 68639488Smckusick struct mbuf *mreq, *mrep, *md, *mb, *mb2; 68738414Smckusick struct nfsmount *nmp; 68838414Smckusick long len, tsiz; 68938414Smckusick 690*41398Smckusick nmp = VFSTONFS(vp->v_mount); 69138414Smckusick tsiz = uiop->uio_resid; 69238414Smckusick while (tsiz > 0) { 69338414Smckusick nfsstats.rpccnt[NFSPROC_WRITE]++; 69438414Smckusick len = (tsiz > nmp->nm_wsize) ? nmp->nm_wsize : tsiz; 69538414Smckusick nfsm_reqhead(nfs_procids[NFSPROC_WRITE], cred, 69638414Smckusick NFSX_FH+NFSX_UNSIGNED*4); 69738414Smckusick nfsm_fhtom(vp); 69838414Smckusick nfsm_build(p, u_long *, NFSX_UNSIGNED*4); 69939587Smckusick *(p+1) = txdr_unsigned(uiop->uio_offset); 70038414Smckusick *(p+3) = txdr_unsigned(len); 70138414Smckusick nfsm_uiotom(uiop, len); 70240112Smckusick nfsm_request(vp, nonidempotent[NFSPROC_WRITE]); 70338414Smckusick nfsm_loadattr(vp, (struct vattr *)0); 70438414Smckusick m_freem(mrep); 70538414Smckusick tsiz -= len; 70638414Smckusick } 70738414Smckusick nfsmout: 70838414Smckusick return (error); 70938414Smckusick } 71038414Smckusick 71138414Smckusick /* 71239459Smckusick * nfs mknod call 71339459Smckusick * This call is currently not supported. 71439459Smckusick */ 71539459Smckusick /* ARGSUSED */ 71639459Smckusick nfs_mknod(ndp, vap, cred) 71739459Smckusick struct nameidata *ndp; 71839459Smckusick struct ucred *cred; 71939459Smckusick struct vattr *vap; 72039459Smckusick { 72139459Smckusick 72239459Smckusick nfs_abortop(ndp); 72339459Smckusick return (EOPNOTSUPP); 72439459Smckusick } 72539459Smckusick 72639459Smckusick /* 72738414Smckusick * nfs file create call 72838414Smckusick */ 72938414Smckusick nfs_create(ndp, vap) 73038414Smckusick register struct nameidata *ndp; 73138414Smckusick register struct vattr *vap; 73238414Smckusick { 73338884Smacklem register struct nfsv2_sattr *sp; 73439488Smckusick register u_long *p; 73539488Smckusick register caddr_t cp; 73639488Smckusick register long t1, t2; 73739488Smckusick caddr_t bpos, dpos, cp2; 73839488Smckusick u_long xid; 73939488Smckusick int error = 0; 74039488Smckusick struct mbuf *mreq, *mrep, *md, *mb, *mb2; 74138414Smckusick 74238414Smckusick nfsstats.rpccnt[NFSPROC_CREATE]++; 74338414Smckusick nfsm_reqhead(nfs_procids[NFSPROC_CREATE], ndp->ni_cred, 74438414Smckusick NFSX_FH+NFSX_UNSIGNED+nfsm_rndup(ndp->ni_dent.d_namlen)+NFSX_SATTR); 74538414Smckusick nfsm_fhtom(ndp->ni_dvp); 74638414Smckusick nfsm_strtom(ndp->ni_dent.d_name, ndp->ni_dent.d_namlen, NFS_MAXNAMLEN); 74738884Smacklem nfsm_build(sp, struct nfsv2_sattr *, NFSX_SATTR); 74838884Smacklem sp->sa_mode = vtonfs_mode(VREG, vap->va_mode); 74938884Smacklem sp->sa_uid = txdr_unsigned(ndp->ni_cred->cr_uid); 75038884Smacklem sp->sa_gid = txdr_unsigned(ndp->ni_cred->cr_gid); 75138884Smacklem sp->sa_size = txdr_unsigned(0); 75238414Smckusick /* or should these be VNOVAL ?? */ 75338884Smacklem txdr_time(&vap->va_atime, &sp->sa_atime); 75438884Smacklem txdr_time(&vap->va_mtime, &sp->sa_mtime); 75540112Smckusick nfsm_request(ndp->ni_dvp, nonidempotent[NFSPROC_CREATE]); 75638414Smckusick nfsm_mtofh(ndp->ni_dvp, ndp->ni_vp); 75738414Smckusick nfsm_reqdone; 75840296Smckusick VTONFS(ndp->ni_dvp)->n_direofstamp = 0; 75938414Smckusick nfs_nput(ndp->ni_dvp); 76038414Smckusick return (error); 76138414Smckusick } 76238414Smckusick 76338414Smckusick /* 76438414Smckusick * nfs file remove call 76539341Smckusick * To try and make nfs semantics closer to vfs semantics, a file that has 76639341Smckusick * other references to the vnode is renamed instead of removed and then 76739341Smckusick * removed later on the last close. 76839341Smckusick * Unfortunately you must flush the buffer cache and cmap to get rid of 76939341Smckusick * all extraneous vnode references before you check the reference cnt. 77039341Smckusick * 1 - If the file could have blocks in the buffer cache 77139341Smckusick * flush them out and invalidate them 77239341Smckusick * mpurge the vnode to flush out cmap references 77339341Smckusick * (This is necessary to update the vnode ref cnt as well as sensible 77439341Smckusick * for actual removes, to free up the buffers) 77539810Smckusick * 2 - If v_usecount > 1 77639341Smckusick * If a rename is not already in the works 77739341Smckusick * call nfs_sillyrename() to set it up 77839341Smckusick * else 77939341Smckusick * do the remove rpc 78038414Smckusick */ 78138414Smckusick nfs_remove(ndp) 78238414Smckusick register struct nameidata *ndp; 78338414Smckusick { 78439341Smckusick register struct vnode *vp = ndp->ni_vp; 78539341Smckusick register struct nfsnode *np = VTONFS(ndp->ni_vp); 78639488Smckusick register u_long *p; 78739488Smckusick register caddr_t cp; 78839488Smckusick register long t1, t2; 78939488Smckusick caddr_t bpos, dpos; 79039488Smckusick u_long xid; 79139488Smckusick int error = 0; 79239488Smckusick struct mbuf *mreq, *mrep, *md, *mb, *mb2; 79338414Smckusick 79439341Smckusick if (vp->v_type == VREG) { 79539341Smckusick if (np->n_flag & (NMODIFIED|NBUFFERED)) { 79639341Smckusick np->n_flag &= ~(NMODIFIED|NBUFFERED); 79739874Smckusick vinvalbuf(vp, TRUE); 79839341Smckusick } 79939751Smckusick if (np->n_flag & NPAGEDON) { 80039751Smckusick np->n_flag &= ~NPAGEDON; 80139341Smckusick mpurge(vp); /* In case cmap entries still ref it */ 80239751Smckusick } 80339341Smckusick } 80439810Smckusick if (vp->v_usecount > 1) { 80539341Smckusick if (!np->n_sillyrename) 80639341Smckusick error = nfs_sillyrename(ndp, REMOVE); 80739341Smckusick } else { 80838414Smckusick nfsstats.rpccnt[NFSPROC_REMOVE]++; 80938414Smckusick nfsm_reqhead(nfs_procids[NFSPROC_REMOVE], ndp->ni_cred, 81038414Smckusick NFSX_FH+NFSX_UNSIGNED+nfsm_rndup(ndp->ni_dent.d_namlen)); 81138414Smckusick nfsm_fhtom(ndp->ni_dvp); 81238414Smckusick nfsm_strtom(ndp->ni_dent.d_name, ndp->ni_dent.d_namlen, NFS_MAXNAMLEN); 81340112Smckusick nfsm_request(ndp->ni_dvp, nonidempotent[NFSPROC_REMOVE]); 81438414Smckusick nfsm_reqdone; 81540296Smckusick VTONFS(ndp->ni_dvp)->n_direofstamp = 0; 81639751Smckusick /* 81739751Smckusick * Kludge City: If the first reply to the remove rpc is lost.. 81839751Smckusick * the reply to the retransmitted request will be ENOENT 81939751Smckusick * since the file was in fact removed 82039751Smckusick * Therefore, we cheat and return success. 82139751Smckusick */ 82239751Smckusick if (error == ENOENT) 82339751Smckusick error = 0; 82438414Smckusick } 82540042Smckusick np->n_attrstamp = 0; 82640112Smckusick if (ndp->ni_dvp == vp) 82740112Smckusick vrele(vp); 82838414Smckusick else 82940112Smckusick nfs_nput(ndp->ni_dvp); 83040112Smckusick nfs_nput(vp); 83138414Smckusick return (error); 83238414Smckusick } 83338414Smckusick 83438414Smckusick /* 83538414Smckusick * nfs file remove rpc called from nfs_inactive 83638414Smckusick */ 83738414Smckusick nfs_removeit(ndp) 83838414Smckusick register struct nameidata *ndp; 83938414Smckusick { 84039488Smckusick register u_long *p; 84139488Smckusick register caddr_t cp; 84239488Smckusick register long t1, t2; 84339488Smckusick caddr_t bpos, dpos; 84439488Smckusick u_long xid; 84539488Smckusick int error = 0; 84639488Smckusick struct mbuf *mreq, *mrep, *md, *mb, *mb2; 84738414Smckusick 84838414Smckusick nfsstats.rpccnt[NFSPROC_REMOVE]++; 84938414Smckusick nfsm_reqhead(nfs_procids[NFSPROC_REMOVE], ndp->ni_cred, 85038414Smckusick NFSX_FH+NFSX_UNSIGNED+nfsm_rndup(ndp->ni_dent.d_namlen)); 85138414Smckusick nfsm_fhtom(ndp->ni_dvp); 85238414Smckusick nfsm_strtom(ndp->ni_dent.d_name, ndp->ni_dent.d_namlen, NFS_MAXNAMLEN); 85340112Smckusick nfsm_request(ndp->ni_dvp, nonidempotent[NFSPROC_REMOVE]); 85438414Smckusick nfsm_reqdone; 85540296Smckusick VTONFS(ndp->ni_dvp)->n_direofstamp = 0; 85638414Smckusick return (error); 85738414Smckusick } 85838414Smckusick 85938414Smckusick /* 86038414Smckusick * nfs file rename call 86138414Smckusick */ 86238414Smckusick nfs_rename(sndp, tndp) 86338414Smckusick register struct nameidata *sndp, *tndp; 86438414Smckusick { 86539488Smckusick register u_long *p; 86639488Smckusick register caddr_t cp; 86739488Smckusick register long t1, t2; 86839488Smckusick caddr_t bpos, dpos; 86939488Smckusick u_long xid; 87039488Smckusick int error = 0; 87139488Smckusick struct mbuf *mreq, *mrep, *md, *mb, *mb2; 87238414Smckusick 87338414Smckusick nfsstats.rpccnt[NFSPROC_RENAME]++; 87438414Smckusick nfsm_reqhead(nfs_procids[NFSPROC_RENAME], tndp->ni_cred, 87538414Smckusick (NFSX_FH+NFSX_UNSIGNED)*2+nfsm_rndup(sndp->ni_dent.d_namlen)+ 87638414Smckusick nfsm_rndup(tndp->ni_dent.d_namlen)); /* or sndp->ni_cred?*/ 87738414Smckusick nfsm_fhtom(sndp->ni_dvp); 87838414Smckusick nfsm_strtom(sndp->ni_dent.d_name,sndp->ni_dent.d_namlen,NFS_MAXNAMLEN); 87938414Smckusick nfsm_fhtom(tndp->ni_dvp); 88038414Smckusick nfsm_strtom(tndp->ni_dent.d_name,tndp->ni_dent.d_namlen,NFS_MAXNAMLEN); 88140112Smckusick nfsm_request(sndp->ni_dvp, nonidempotent[NFSPROC_RENAME]); 88238414Smckusick nfsm_reqdone; 88340296Smckusick VTONFS(sndp->ni_dvp)->n_direofstamp = 0; 88440296Smckusick VTONFS(tndp->ni_dvp)->n_direofstamp = 0; 88538414Smckusick if (sndp->ni_vp->v_type == VDIR) { 88638414Smckusick if (tndp->ni_vp != NULL && tndp->ni_vp->v_type == VDIR) 88738414Smckusick cache_purge(tndp->ni_dvp); 88838414Smckusick cache_purge(sndp->ni_dvp); 88938414Smckusick } 89038414Smckusick nfs_abortop(sndp); 89138414Smckusick nfs_abortop(tndp); 89240112Smckusick /* 89340112Smckusick * Kludge: Map ENOENT => 0 assuming that it is a reply to a retry. 89440112Smckusick */ 89540112Smckusick if (error == ENOENT) 89640112Smckusick error = 0; 89738414Smckusick return (error); 89838414Smckusick } 89938414Smckusick 90038414Smckusick /* 90138414Smckusick * nfs file rename rpc called from above 90238414Smckusick */ 90338414Smckusick nfs_renameit(sndp, tndp) 90438414Smckusick register struct nameidata *sndp, *tndp; 90538414Smckusick { 90639488Smckusick register u_long *p; 90739488Smckusick register caddr_t cp; 90839488Smckusick register long t1, t2; 90939488Smckusick caddr_t bpos, dpos; 91039488Smckusick u_long xid; 91139488Smckusick int error = 0; 91239488Smckusick struct mbuf *mreq, *mrep, *md, *mb, *mb2; 91338414Smckusick 91438414Smckusick nfsstats.rpccnt[NFSPROC_RENAME]++; 91538414Smckusick nfsm_reqhead(nfs_procids[NFSPROC_RENAME], tndp->ni_cred, 91638414Smckusick (NFSX_FH+NFSX_UNSIGNED)*2+nfsm_rndup(sndp->ni_dent.d_namlen)+ 91738414Smckusick nfsm_rndup(tndp->ni_dent.d_namlen)); /* or sndp->ni_cred?*/ 91838414Smckusick nfsm_fhtom(sndp->ni_dvp); 91938414Smckusick nfsm_strtom(sndp->ni_dent.d_name,sndp->ni_dent.d_namlen,NFS_MAXNAMLEN); 92038414Smckusick nfsm_fhtom(tndp->ni_dvp); 92138414Smckusick nfsm_strtom(tndp->ni_dent.d_name,tndp->ni_dent.d_namlen,NFS_MAXNAMLEN); 92240112Smckusick nfsm_request(sndp->ni_dvp, nonidempotent[NFSPROC_RENAME]); 92338414Smckusick nfsm_reqdone; 92440296Smckusick VTONFS(sndp->ni_dvp)->n_direofstamp = 0; 92540296Smckusick VTONFS(tndp->ni_dvp)->n_direofstamp = 0; 92638414Smckusick return (error); 92738414Smckusick } 92838414Smckusick 92938414Smckusick /* 93038414Smckusick * nfs hard link create call 93138414Smckusick */ 93238414Smckusick nfs_link(vp, ndp) 93339488Smckusick register struct vnode *vp; 93438414Smckusick register struct nameidata *ndp; 93538414Smckusick { 93639488Smckusick register u_long *p; 93739488Smckusick register caddr_t cp; 93839488Smckusick register long t1, t2; 93939488Smckusick caddr_t bpos, dpos; 94039488Smckusick u_long xid; 94139488Smckusick int error = 0; 94239488Smckusick struct mbuf *mreq, *mrep, *md, *mb, *mb2; 94338414Smckusick 94438425Smckusick if (ndp->ni_dvp != vp) 94538425Smckusick nfs_lock(vp); 94638414Smckusick nfsstats.rpccnt[NFSPROC_LINK]++; 94738414Smckusick nfsm_reqhead(nfs_procids[NFSPROC_LINK], ndp->ni_cred, 94838414Smckusick NFSX_FH*2+NFSX_UNSIGNED+nfsm_rndup(ndp->ni_dent.d_namlen)); 94938414Smckusick nfsm_fhtom(vp); 95038414Smckusick nfsm_fhtom(ndp->ni_dvp); 95138414Smckusick nfsm_strtom(ndp->ni_dent.d_name, ndp->ni_dent.d_namlen, NFS_MAXNAMLEN); 95240112Smckusick nfsm_request(vp, nonidempotent[NFSPROC_LINK]); 95338414Smckusick nfsm_reqdone; 95440042Smckusick VTONFS(vp)->n_attrstamp = 0; 95540296Smckusick VTONFS(ndp->ni_dvp)->n_direofstamp = 0; 95638425Smckusick if (ndp->ni_dvp != vp) 95738425Smckusick nfs_unlock(vp); 95838414Smckusick nfs_nput(ndp->ni_dvp); 95940112Smckusick /* 96040112Smckusick * Kludge: Map EEXIST => 0 assuming that it is a reply to a retry. 96140112Smckusick */ 96240112Smckusick if (error == EEXIST) 96340112Smckusick error = 0; 96438414Smckusick return (error); 96538414Smckusick } 96638414Smckusick 96738414Smckusick /* 96838414Smckusick * nfs symbolic link create call 96938414Smckusick */ 97038414Smckusick nfs_symlink(ndp, vap, nm) 97138414Smckusick struct nameidata *ndp; 97238414Smckusick struct vattr *vap; 97338414Smckusick char *nm; /* is this the path ?? */ 97438414Smckusick { 97538884Smacklem register struct nfsv2_sattr *sp; 97639488Smckusick register u_long *p; 97739488Smckusick register caddr_t cp; 97839488Smckusick register long t1, t2; 97939488Smckusick caddr_t bpos, dpos; 98039488Smckusick u_long xid; 98139488Smckusick int error = 0; 98239488Smckusick struct mbuf *mreq, *mrep, *md, *mb, *mb2; 98338414Smckusick 98438414Smckusick nfsstats.rpccnt[NFSPROC_SYMLINK]++; 98538414Smckusick nfsm_reqhead(nfs_procids[NFSPROC_SYMLINK], ndp->ni_cred, 98638414Smckusick NFSX_FH+NFSX_UNSIGNED+nfsm_rndup(ndp->ni_dent.d_namlen)+NFSX_UNSIGNED); 98738414Smckusick nfsm_fhtom(ndp->ni_dvp); 98838414Smckusick nfsm_strtom(ndp->ni_dent.d_name, ndp->ni_dent.d_namlen, NFS_MAXNAMLEN); 98938414Smckusick nfsm_strtom(nm, strlen(nm), NFS_MAXPATHLEN); 99038884Smacklem nfsm_build(sp, struct nfsv2_sattr *, NFSX_SATTR); 99138884Smacklem sp->sa_mode = vtonfs_mode(VLNK, vap->va_mode); 99238884Smacklem sp->sa_uid = txdr_unsigned(ndp->ni_cred->cr_uid); 99338884Smacklem sp->sa_gid = txdr_unsigned(ndp->ni_cred->cr_gid); 99438884Smacklem sp->sa_size = txdr_unsigned(VNOVAL); 99540112Smckusick txdr_time(&vap->va_atime, &sp->sa_atime); /* or VNOVAL ?? */ 99638884Smacklem txdr_time(&vap->va_mtime, &sp->sa_mtime); /* or VNOVAL ?? */ 99740112Smckusick nfsm_request(ndp->ni_dvp, nonidempotent[NFSPROC_SYMLINK]); 99838414Smckusick nfsm_reqdone; 99940296Smckusick VTONFS(ndp->ni_dvp)->n_direofstamp = 0; 100038414Smckusick nfs_nput(ndp->ni_dvp); 100140112Smckusick /* 100240112Smckusick * Kludge: Map EEXIST => 0 assuming that it is a reply to a retry. 100340112Smckusick */ 100440112Smckusick if (error == EEXIST) 100540112Smckusick error = 0; 100638414Smckusick return (error); 100738414Smckusick } 100838414Smckusick 100938414Smckusick /* 101038414Smckusick * nfs make dir call 101138414Smckusick */ 101238414Smckusick nfs_mkdir(ndp, vap) 101339488Smckusick register struct nameidata *ndp; 101438414Smckusick struct vattr *vap; 101538414Smckusick { 101638884Smacklem register struct nfsv2_sattr *sp; 101739488Smckusick register u_long *p; 101839488Smckusick register caddr_t cp; 101939488Smckusick register long t1, t2; 102039488Smckusick caddr_t bpos, dpos, cp2; 102139488Smckusick u_long xid; 102239488Smckusick int error = 0; 102339488Smckusick struct mbuf *mreq, *mrep, *md, *mb, *mb2; 102438414Smckusick 102538414Smckusick nfsstats.rpccnt[NFSPROC_MKDIR]++; 102638414Smckusick nfsm_reqhead(nfs_procids[NFSPROC_MKDIR], ndp->ni_cred, 102738414Smckusick NFSX_FH+NFSX_UNSIGNED+nfsm_rndup(ndp->ni_dent.d_namlen)+NFSX_SATTR); 102838414Smckusick nfsm_fhtom(ndp->ni_dvp); 102938414Smckusick nfsm_strtom(ndp->ni_dent.d_name, ndp->ni_dent.d_namlen, NFS_MAXNAMLEN); 103038884Smacklem nfsm_build(sp, struct nfsv2_sattr *, NFSX_SATTR); 103138884Smacklem sp->sa_mode = vtonfs_mode(VDIR, vap->va_mode); 103238884Smacklem sp->sa_uid = txdr_unsigned(ndp->ni_cred->cr_uid); 103338884Smacklem sp->sa_gid = txdr_unsigned(ndp->ni_cred->cr_gid); 103438884Smacklem sp->sa_size = txdr_unsigned(VNOVAL); 103540112Smckusick txdr_time(&vap->va_atime, &sp->sa_atime); /* or VNOVAL ?? */ 103638884Smacklem txdr_time(&vap->va_mtime, &sp->sa_mtime); /* or VNOVAL ?? */ 103740112Smckusick nfsm_request(ndp->ni_dvp, nonidempotent[NFSPROC_MKDIR]); 103838414Smckusick nfsm_mtofh(ndp->ni_dvp, ndp->ni_vp); 103938414Smckusick nfsm_reqdone; 104040296Smckusick VTONFS(ndp->ni_dvp)->n_direofstamp = 0; 104138414Smckusick nfs_nput(ndp->ni_dvp); 104240112Smckusick /* 104340112Smckusick * Kludge: Map EEXIST => 0 assuming that you have a reply to a retry. 104440112Smckusick */ 104540112Smckusick if (error == EEXIST) 104640112Smckusick error = 0; 104738414Smckusick return (error); 104838414Smckusick } 104938414Smckusick 105038414Smckusick /* 105138414Smckusick * nfs remove directory call 105238414Smckusick */ 105338414Smckusick nfs_rmdir(ndp) 105438414Smckusick register struct nameidata *ndp; 105538414Smckusick { 105639488Smckusick register u_long *p; 105739488Smckusick register caddr_t cp; 105839488Smckusick register long t1, t2; 105939488Smckusick caddr_t bpos, dpos; 106039488Smckusick u_long xid; 106139488Smckusick int error = 0; 106239488Smckusick struct mbuf *mreq, *mrep, *md, *mb, *mb2; 106338414Smckusick 106438414Smckusick if (ndp->ni_dvp == ndp->ni_vp) { 106538414Smckusick vrele(ndp->ni_dvp); 106638414Smckusick nfs_nput(ndp->ni_dvp); 106738414Smckusick return (EINVAL); 106838414Smckusick } 106938414Smckusick nfsstats.rpccnt[NFSPROC_RMDIR]++; 107038414Smckusick nfsm_reqhead(nfs_procids[NFSPROC_RMDIR], ndp->ni_cred, 107138414Smckusick NFSX_FH+NFSX_UNSIGNED+nfsm_rndup(ndp->ni_dent.d_namlen)); 107238414Smckusick nfsm_fhtom(ndp->ni_dvp); 107338414Smckusick nfsm_strtom(ndp->ni_dent.d_name, ndp->ni_dent.d_namlen, NFS_MAXNAMLEN); 107440112Smckusick nfsm_request(ndp->ni_dvp, nonidempotent[NFSPROC_RMDIR]); 107538414Smckusick nfsm_reqdone; 107640296Smckusick VTONFS(ndp->ni_dvp)->n_direofstamp = 0; 107738884Smacklem cache_purge(ndp->ni_dvp); 107838884Smacklem cache_purge(ndp->ni_vp); 107938884Smacklem nfs_nput(ndp->ni_vp); 108038884Smacklem nfs_nput(ndp->ni_dvp); 108140112Smckusick /* 108240112Smckusick * Kludge: Map ENOENT => 0 assuming that you have a reply to a retry. 108340112Smckusick */ 108440112Smckusick if (error == ENOENT) 108540112Smckusick error = 0; 108638414Smckusick return (error); 108738414Smckusick } 108838414Smckusick 108938414Smckusick /* 109038414Smckusick * nfs readdir call 109138414Smckusick * Although cookie is defined as opaque, I translate it to/from net byte 109238414Smckusick * order so that it looks more sensible. This appears consistent with the 109338414Smckusick * Ultrix implementation of NFS. 109438414Smckusick */ 109540833Smckusick int direof = 0; 109640296Smckusick nfs_readdir(vp, uiop, cred, eofflagp) 109739488Smckusick register struct vnode *vp; 109838414Smckusick struct uio *uiop; 109938414Smckusick struct ucred *cred; 110040296Smckusick int *eofflagp; 110138414Smckusick { 110238414Smckusick register long len; 110338414Smckusick register struct direct *dp; 110439488Smckusick register u_long *p; 110539488Smckusick register caddr_t cp; 110639488Smckusick register long t1; 110740113Smckusick long tlen; 110839488Smckusick caddr_t bpos, dpos, cp2; 110939488Smckusick u_long xid; 111039488Smckusick int error = 0; 111139488Smckusick struct mbuf *mreq, *mrep, *md, *mb, *mb2; 111238414Smckusick struct mbuf *md2; 111338414Smckusick caddr_t dpos2; 111438414Smckusick int siz; 111540296Smckusick int more_dirs = 1; 111638414Smckusick off_t off, savoff; 111738414Smckusick struct direct *savdp; 111840296Smckusick struct nfsmount *nmp; 111940296Smckusick struct nfsnode *np = VTONFS(vp); 112040296Smckusick long tresid; 112138414Smckusick 112240296Smckusick /* 112340296Smckusick * First, check for hit on the EOF offset cache 112440296Smckusick */ 112540833Smckusick if (direof) 112640296Smckusick if (uiop->uio_offset != 0 && uiop->uio_offset == np->n_direofoffset && 112740296Smckusick (time.tv_sec - np->n_direofstamp) < NFS_ATTRTIMEO) { 112840296Smckusick *eofflagp = 1; 112940296Smckusick nfsstats.direofcache_hits++; 113040296Smckusick return (0); 113140296Smckusick } 113238414Smckusick 1133*41398Smckusick nmp = VFSTONFS(vp->v_mount); 113440296Smckusick tresid = uiop->uio_resid; 113540296Smckusick /* 113640296Smckusick * Loop around doing readdir rpc's of size uio_resid or nm_rsize, 113740296Smckusick * whichever is smaller, truncated to a multiple of DIRBLKSIZ. 113840296Smckusick * The stopping criteria is EOF or less than DIRBLKSIZ of the 113940296Smckusick * request left. 114040296Smckusick */ 114140296Smckusick while (more_dirs && uiop->uio_resid >= DIRBLKSIZ) { 114240296Smckusick nfsstats.rpccnt[NFSPROC_READDIR]++; 114340296Smckusick nfsm_reqhead(nfs_procids[NFSPROC_READDIR], cred, xid); 114440296Smckusick nfsm_fhtom(vp); 114540296Smckusick nfsm_build(p, u_long *, 2*NFSX_UNSIGNED); 114640296Smckusick *p++ = txdr_unsigned(uiop->uio_offset); 114740296Smckusick *p = txdr_unsigned(((uiop->uio_resid > nmp->nm_rsize) ? 114840296Smckusick nmp->nm_rsize : uiop->uio_resid) & ~(DIRBLKSIZ-1)); 114940296Smckusick nfsm_request(vp, nonidempotent[NFSPROC_READDIR]); 115040296Smckusick siz = 0; 115140296Smckusick nfsm_disect(p, u_long *, NFSX_UNSIGNED); 115240296Smckusick more_dirs = fxdr_unsigned(int, *p); 115340296Smckusick 115440296Smckusick /* Save the position so that we can do nfsm_mtouio() later */ 115540296Smckusick dpos2 = dpos; 115640296Smckusick md2 = md; 115740296Smckusick 115840296Smckusick /* loop thru the dir entries, doctoring them to 4bsd form */ 115940296Smckusick savoff = off = 0; 116040296Smckusick savdp = dp = NULL; 116140296Smckusick while (more_dirs && siz < uiop->uio_resid) { 116240296Smckusick savoff = off; /* Hold onto offset and dp */ 116340296Smckusick savdp = dp; 116440296Smckusick nfsm_disecton(p, u_long *, 2*NFSX_UNSIGNED); 116540296Smckusick dp = (struct direct *)p; 116640296Smckusick dp->d_ino = fxdr_unsigned(u_long, *p++); 116740296Smckusick len = fxdr_unsigned(int, *p); 116840296Smckusick if (len <= 0 || len > NFS_MAXNAMLEN) { 116940296Smckusick error = EBADRPC; 117040296Smckusick m_freem(mrep); 117140296Smckusick goto nfsmout; 117240296Smckusick } 117340296Smckusick dp->d_namlen = (u_short)len; 117440296Smckusick nfsm_adv(len); /* Point past name */ 117540296Smckusick tlen = nfsm_rndup(len); 117640296Smckusick /* 117740296Smckusick * This should not be necessary, but some servers have 117840296Smckusick * broken XDR such that these bytes are not null filled. 117940296Smckusick */ 118040296Smckusick if (tlen != len) { 118140296Smckusick *dpos = '\0'; /* Null-terminate */ 118240296Smckusick nfsm_adv(tlen - len); 118340296Smckusick len = tlen; 118440296Smckusick } 118540296Smckusick nfsm_disecton(p, u_long *, 2*NFSX_UNSIGNED); 118640296Smckusick off = fxdr_unsigned(off_t, *p); 118740296Smckusick *p++ = 0; /* Ensures null termination of name */ 118840296Smckusick more_dirs = fxdr_unsigned(int, *p); 118940296Smckusick dp->d_reclen = len+4*NFSX_UNSIGNED; 119040296Smckusick siz += dp->d_reclen; 119140296Smckusick } 119240296Smckusick /* 119340296Smckusick * If at end of rpc data, get the eof boolean 119440296Smckusick */ 119540296Smckusick if (!more_dirs) { 119640296Smckusick nfsm_disecton(p, u_long *, NFSX_UNSIGNED); 119740296Smckusick more_dirs = (fxdr_unsigned(int, *p) == 0); 119838414Smckusick 119940296Smckusick /* 120040296Smckusick * If at EOF, cache directory offset 120140296Smckusick */ 120240296Smckusick if (!more_dirs) { 120340296Smckusick np->n_direofoffset = off; 120440296Smckusick np->n_direofstamp = time.tv_sec; 120540296Smckusick } 120638414Smckusick } 120740296Smckusick /* 120840296Smckusick * If there is too much to fit in the data buffer, use savoff and 120940296Smckusick * savdp to trim off the last record. 121040296Smckusick * --> we are not at eof 121140296Smckusick */ 121240296Smckusick if (siz > uiop->uio_resid) { 121340296Smckusick off = savoff; 121440296Smckusick siz -= dp->d_reclen; 121540296Smckusick dp = savdp; 121640296Smckusick more_dirs = 0; /* Paranoia */ 121740113Smckusick } 121840296Smckusick if (siz > 0) { 121940296Smckusick md = md2; 122040296Smckusick dpos = dpos2; 122140296Smckusick nfsm_mtouio(uiop, siz); 122240296Smckusick uiop->uio_offset = off; 122340296Smckusick } else 122440296Smckusick more_dirs = 0; /* Ugh, never happens, but in case.. */ 122540296Smckusick m_freem(mrep); 122638414Smckusick } 122740296Smckusick nfsmout: 122840296Smckusick if (tresid == uiop->uio_resid) { 122940296Smckusick *eofflagp = 1; 123040296Smckusick nfsstats.direofcache_misses++; 123140296Smckusick } else { 123240296Smckusick *eofflagp = 0; 123338414Smckusick } 123438414Smckusick return (error); 123538414Smckusick } 123638414Smckusick 123738414Smckusick /* 123838414Smckusick * nfs statfs call 123938414Smckusick * (Actually a vfsop, not a vnode op) 124038414Smckusick */ 124138414Smckusick nfs_statfs(mp, sbp) 124238414Smckusick struct mount *mp; 124338414Smckusick register struct statfs *sbp; 124438414Smckusick { 124539488Smckusick register struct vnode *vp; 124638884Smacklem register struct nfsv2_statfs *sfp; 124739488Smckusick register caddr_t cp; 124839488Smckusick register long t1; 124939488Smckusick caddr_t bpos, dpos, cp2; 125039488Smckusick u_long xid; 125139488Smckusick int error = 0; 125239488Smckusick struct mbuf *mreq, *mrep, *md, *mb, *mb2; 125338884Smacklem struct nfsmount *nmp; 125438414Smckusick struct ucred *cred; 125538414Smckusick struct nfsnode *np; 125638414Smckusick 1257*41398Smckusick nmp = VFSTONFS(mp); 125838414Smckusick if (error = nfs_nget(mp, &nmp->nm_fh, &np)) 125938414Smckusick return (error); 126038414Smckusick vp = NFSTOV(np); 126138414Smckusick nfsstats.rpccnt[NFSPROC_STATFS]++; 126238414Smckusick cred = crget(); 126338414Smckusick cred->cr_ngroups = 1; 126438414Smckusick nfsm_reqhead(nfs_procids[NFSPROC_STATFS], cred, NFSX_FH); 126538414Smckusick nfsm_fhtom(vp); 126640112Smckusick nfsm_request(vp, nonidempotent[NFSPROC_STATFS]); 126738884Smacklem nfsm_disect(sfp, struct nfsv2_statfs *, NFSX_STATFS); 126838414Smckusick sbp->f_type = MOUNT_NFS; 126939751Smckusick sbp->f_flags = nmp->nm_flag; 127038884Smacklem sbp->f_bsize = fxdr_unsigned(long, sfp->sf_tsize); 127138884Smacklem sbp->f_fsize = fxdr_unsigned(long, sfp->sf_bsize); 127238884Smacklem sbp->f_blocks = fxdr_unsigned(long, sfp->sf_blocks); 127338884Smacklem sbp->f_bfree = fxdr_unsigned(long, sfp->sf_bfree); 127438884Smacklem sbp->f_bavail = fxdr_unsigned(long, sfp->sf_bavail); 127538739Smckusick sbp->f_files = 0; 127638739Smckusick sbp->f_ffree = 0; 1277*41398Smckusick if (sbp != &mp->mnt_stat) { 1278*41398Smckusick bcopy(mp->mnt_stat.f_mntonname, sbp->f_mntonname, MNAMELEN); 1279*41398Smckusick bcopy(mp->mnt_stat.f_mntfromname, sbp->f_mntfromname, MNAMELEN); 128040349Smckusick } 128138414Smckusick nfsm_reqdone; 128238414Smckusick nfs_nput(vp); 128338414Smckusick crfree(cred); 128438414Smckusick return (error); 128538414Smckusick } 128638414Smckusick 128739488Smckusick static char hextoasc[] = "0123456789abcdef"; 128838414Smckusick 128938414Smckusick /* 129038414Smckusick * Silly rename. To make the NFS filesystem that is stateless look a little 129138414Smckusick * more like the "ufs" a remove of an active vnode is translated to a rename 129238414Smckusick * to a funny looking filename that is removed by nfs_inactive on the 129338414Smckusick * nfsnode. There is the potential for another process on a different client 129438414Smckusick * to create the same funny name between the nfs_lookitup() fails and the 129538414Smckusick * nfs_rename() completes, but... 129638414Smckusick */ 129738414Smckusick nfs_sillyrename(ndp, flag) 129839488Smckusick register struct nameidata *ndp; 129938414Smckusick int flag; 130038414Smckusick { 130138414Smckusick register struct nfsnode *np; 130238414Smckusick register struct sillyrename *sp; 130338414Smckusick register struct nameidata *tndp; 130438414Smckusick int error; 130538414Smckusick short pid; 130638414Smckusick 130738414Smckusick np = VTONFS(ndp->ni_dvp); 130839341Smckusick cache_purge(ndp->ni_dvp); 130938414Smckusick MALLOC(sp, struct sillyrename *, sizeof (struct sillyrename), 131038884Smacklem M_TEMP, M_WAITOK); 131138414Smckusick sp->s_flag = flag; 131238414Smckusick bcopy((caddr_t)&np->n_fh, (caddr_t)&sp->s_fh, NFSX_FH); 131338414Smckusick np = VTONFS(ndp->ni_vp); 131438414Smckusick tndp = &sp->s_namei; 131538414Smckusick tndp->ni_cred = crdup(ndp->ni_cred); 131638414Smckusick 131738414Smckusick /* Fudge together a funny name */ 131838414Smckusick pid = u.u_procp->p_pid; 131938414Smckusick bcopy(".nfsAxxxx4.4", tndp->ni_dent.d_name, 13); 132038414Smckusick tndp->ni_dent.d_namlen = 12; 132139488Smckusick tndp->ni_dent.d_name[8] = hextoasc[pid & 0xf]; 132239488Smckusick tndp->ni_dent.d_name[7] = hextoasc[(pid >> 4) & 0xf]; 132339488Smckusick tndp->ni_dent.d_name[6] = hextoasc[(pid >> 8) & 0xf]; 132439488Smckusick tndp->ni_dent.d_name[5] = hextoasc[(pid >> 12) & 0xf]; 132538414Smckusick 132638414Smckusick /* Try lookitups until we get one that isn't there */ 132738414Smckusick while (nfs_lookitup(ndp->ni_dvp, tndp, (nfsv2fh_t *)0) == 0) { 132838414Smckusick tndp->ni_dent.d_name[4]++; 132938414Smckusick if (tndp->ni_dent.d_name[4] > 'z') { 133038414Smckusick error = EINVAL; 133138414Smckusick goto bad; 133238414Smckusick } 133338414Smckusick } 133438414Smckusick if (error = nfs_renameit(ndp, tndp)) 133538414Smckusick goto bad; 133638414Smckusick nfs_lookitup(ndp->ni_dvp, tndp, &np->n_fh); 133738414Smckusick np->n_sillyrename = sp; 133838414Smckusick return (0); 133938414Smckusick bad: 134038884Smacklem crfree(tndp->ni_cred); 134138414Smckusick free((caddr_t)sp, M_TEMP); 134238414Smckusick return (error); 134338414Smckusick } 134438414Smckusick 134538414Smckusick /* 134638414Smckusick * Look up a file name for silly rename stuff. 134738414Smckusick * Just like nfs_lookup() except that it doesn't load returned values 134838414Smckusick * into the nfsnode table. 134938414Smckusick * If fhp != NULL it copies the returned file handle out 135038414Smckusick */ 135138414Smckusick nfs_lookitup(vp, ndp, fhp) 135238414Smckusick register struct vnode *vp; 135338414Smckusick register struct nameidata *ndp; 135438414Smckusick nfsv2fh_t *fhp; 135538414Smckusick { 135639488Smckusick register u_long *p; 135739488Smckusick register caddr_t cp; 135839488Smckusick register long t1, t2; 135939488Smckusick caddr_t bpos, dpos, cp2; 136039488Smckusick u_long xid; 136139488Smckusick int error = 0; 136239488Smckusick struct mbuf *mreq, *mrep, *md, *mb, *mb2; 136338414Smckusick long len; 136438414Smckusick 136538414Smckusick nfsstats.rpccnt[NFSPROC_LOOKUP]++; 136638414Smckusick ndp->ni_dvp = vp; 136738414Smckusick ndp->ni_vp = NULL; 136838414Smckusick len = ndp->ni_dent.d_namlen; 136938414Smckusick nfsm_reqhead(nfs_procids[NFSPROC_LOOKUP], ndp->ni_cred, NFSX_FH+NFSX_UNSIGNED+nfsm_rndup(len)); 137038414Smckusick nfsm_fhtom(vp); 137138414Smckusick nfsm_strtom(ndp->ni_dent.d_name, len, NFS_MAXNAMLEN); 137240112Smckusick nfsm_request(vp, nonidempotent[NFSPROC_LOOKUP]); 137338414Smckusick if (fhp != NULL) { 137438414Smckusick nfsm_disect(cp, caddr_t, NFSX_FH); 137538414Smckusick bcopy(cp, (caddr_t)fhp, NFSX_FH); 137638414Smckusick } 137738414Smckusick nfsm_reqdone; 137838414Smckusick return (error); 137938414Smckusick } 138038414Smckusick 138138414Smckusick /* 138238414Smckusick * Kludge City.. 138338414Smckusick * - make nfs_bmap() essentially a no-op that does no translation 138438414Smckusick * - do nfs_strategy() by faking physical I/O with nfs_readit/nfs_writeit 138538414Smckusick * after mapping the physical addresses into Kernel Virtual space in the 138638414Smckusick * nfsiobuf area. 138738414Smckusick * (Maybe I could use the process's page mapping, but I was concerned that 138838414Smckusick * Kernel Write might not be enabled and also figured copyout() would do 138938414Smckusick * a lot more work than bcopy() and also it currently happens in the 139038414Smckusick * context of the swapper process (2). 139138414Smckusick */ 139238414Smckusick nfs_bmap(vp, bn, vpp, bnp) 139338414Smckusick struct vnode *vp; 139438414Smckusick daddr_t bn; 139538414Smckusick struct vnode **vpp; 139638414Smckusick daddr_t *bnp; 139738414Smckusick { 139838414Smckusick if (vpp != NULL) 139938414Smckusick *vpp = vp; 140038414Smckusick if (bnp != NULL) 1401*41398Smckusick *bnp = bn * btodb(vp->v_mount->mnt_stat.f_bsize); 140238414Smckusick return (0); 140338414Smckusick } 140438414Smckusick 140538414Smckusick /* 140638884Smacklem * Strategy routine for phys. i/o 140738884Smacklem * If the biod's are running, queue a request 140838884Smacklem * otherwise just call nfs_doio() to get it done 140938414Smckusick */ 141038414Smckusick nfs_strategy(bp) 141138414Smckusick register struct buf *bp; 141238414Smckusick { 141338884Smacklem register struct buf *dp; 141439341Smckusick register int i; 141538884Smacklem struct proc *rp; 141638884Smacklem int error = 0; 141739341Smckusick int fnd = 0; 141838884Smacklem 141938884Smacklem /* 142038884Smacklem * If an i/o daemon is waiting 142138884Smacklem * queue the request, wake it up and wait for completion 142238884Smacklem * otherwise just do it ourselves 142338884Smacklem */ 142439341Smckusick for (i = 0; i < nfs_asyncdaemons; i++) { 142539341Smckusick if (rp = nfs_iodwant[i]) { 142639341Smckusick /* 142739341Smckusick * Ensure that the async_daemon is still waiting here 142839341Smckusick */ 142939341Smckusick if (rp->p_stat != SSLEEP || 143039341Smckusick rp->p_wchan != ((caddr_t)&nfs_iodwant[i])) { 143139341Smckusick nfs_iodwant[i] = (struct proc *)0; 143239341Smckusick continue; 143339341Smckusick } 143439341Smckusick dp = &nfs_bqueue; 143539341Smckusick if (dp->b_actf == NULL) { 143639341Smckusick dp->b_actl = bp; 143739341Smckusick bp->b_actf = dp; 143839341Smckusick } else { 143939341Smckusick dp->b_actf->b_actl = bp; 144039341Smckusick bp->b_actf = dp->b_actf; 144139341Smckusick } 144239341Smckusick dp->b_actf = bp; 144339341Smckusick bp->b_actl = dp; 144439341Smckusick fnd++; 144539341Smckusick nfs_iodwant[i] = (struct proc *)0; 144639341Smckusick wakeup((caddr_t)&nfs_iodwant[i]); 144739341Smckusick break; 144838884Smacklem } 144939341Smckusick } 145039341Smckusick if (!fnd) 145138884Smacklem error = nfs_doio(bp); 145238884Smacklem return (error); 145338884Smacklem } 145438884Smacklem 145538884Smacklem /* 145638884Smacklem * Fun and games with i/o 145738884Smacklem * Essentially play ubasetup() and disk interrupt service routine by 145838884Smacklem * mapping the data buffer into kernel virtual space and doing the 145938884Smacklem * nfs read or write rpc's from it. 146038884Smacklem * If the biod's are not running, this is just called from nfs_strategy(), 146138884Smacklem * otherwise it is called by the biod's to do what would normally be 146238884Smacklem * partially disk interrupt driven. 146338884Smacklem */ 146438884Smacklem nfs_doio(bp) 146538884Smacklem register struct buf *bp; 146638884Smacklem { 146738414Smckusick register struct pte *pte, *ppte; 146838414Smckusick register caddr_t vaddr; 146938414Smckusick register struct uio *uiop; 147038414Smckusick register struct vnode *vp; 147139341Smckusick struct nfsnode *np; 147238884Smacklem struct ucred *cr; 147338884Smacklem int npf, npf2; 147438884Smacklem int reg; 147538884Smacklem caddr_t vbase; 147638414Smckusick unsigned v; 147738414Smckusick struct proc *rp; 147838414Smckusick int o, error; 147938414Smckusick struct uio uio; 148038414Smckusick struct iovec io; 148138414Smckusick 148238414Smckusick vp = bp->b_vp; 148340251Smckusick np = VTONFS(vp); 148438414Smckusick uiop = &uio; 148538414Smckusick uiop->uio_iov = &io; 148638414Smckusick uiop->uio_iovcnt = 1; 148738414Smckusick uiop->uio_segflg = UIO_SYSSPACE; 148839751Smckusick 148938414Smckusick /* 149038884Smacklem * For phys i/o, map the b_addr into kernel virtual space using 149138884Smacklem * the Nfsiomap pte's 149238884Smacklem * Also, add a temporary b_rcred for reading using the process's uid 149338884Smacklem * and a guess at a group 149438414Smckusick */ 149538884Smacklem if (bp->b_flags & B_PHYS) { 149640251Smckusick np->n_flag |= NPAGEDON; 149738884Smacklem bp->b_rcred = cr = crget(); 149838884Smacklem rp = (bp->b_flags & B_DIRTY) ? &proc[2] : bp->b_proc; 149938884Smacklem cr->cr_uid = rp->p_uid; 150038884Smacklem cr->cr_gid = 0; /* Anything ?? */ 150138884Smacklem cr->cr_ngroups = 1; 150239751Smckusick o = (int)bp->b_un.b_addr & PGOFSET; 150339751Smckusick npf2 = npf = btoc(bp->b_bcount + o); 150439751Smckusick 150538884Smacklem /* 150638884Smacklem * Get some mapping page table entries 150738884Smacklem */ 150838884Smacklem while ((reg = rmalloc(nfsmap, (long)npf)) == 0) { 150938884Smacklem nfsmap_want++; 151038884Smacklem sleep((caddr_t)&nfsmap_want, PZERO-1); 151138884Smacklem } 151238884Smacklem reg--; 151339751Smckusick if (bp->b_flags & B_PAGET) 151439751Smckusick pte = &Usrptmap[btokmx((struct pte *)bp->b_un.b_addr)]; 151538884Smacklem else { 151639751Smckusick v = btop(bp->b_un.b_addr); 151738884Smacklem if (bp->b_flags & B_UAREA) 151838884Smacklem pte = &rp->p_addr[v]; 151938884Smacklem else 152038884Smacklem pte = vtopte(rp, v); 152138884Smacklem } 152239751Smckusick 152338884Smacklem /* 152438884Smacklem * Play vmaccess() but with the Nfsiomap page table 152538884Smacklem */ 152638884Smacklem ppte = &Nfsiomap[reg]; 152738884Smacklem vbase = vaddr = &nfsiobuf[reg*NBPG]; 152838884Smacklem while (npf != 0) { 152938884Smacklem mapin(ppte, (u_int)vaddr, pte->pg_pfnum, (int)(PG_V|PG_KW)); 153038414Smckusick #if defined(tahoe) 153138884Smacklem mtpr(P1DC, vaddr); 153238414Smckusick #endif 153338884Smacklem ppte++; 153438884Smacklem pte++; 153538884Smacklem vaddr += NBPG; 153638884Smacklem --npf; 153738884Smacklem } 153839751Smckusick 153939751Smckusick /* 154039751Smckusick * And do the i/o rpc 154139751Smckusick */ 154238884Smacklem io.iov_base = vbase+o; 154339751Smckusick io.iov_len = uiop->uio_resid = bp->b_bcount; 154439823Smckusick uiop->uio_offset = bp->b_blkno * DEV_BSIZE; 154539751Smckusick if (bp->b_flags & B_READ) { 154639751Smckusick uiop->uio_rw = UIO_READ; 154739751Smckusick nfsstats.read_physios++; 154839751Smckusick bp->b_error = error = nfs_readrpc(vp, uiop, bp->b_rcred); 154940251Smckusick /* 155040251Smckusick * If a text file has been modified since it was exec'd 155140251Smckusick * blow the process' out of the water. This is the 155240251Smckusick * closest we can come to "Text File Busy" in good old 155340251Smckusick * stateless nfs. 155440251Smckusick */ 155540251Smckusick if ((vp->v_flag & VTEXT) && 155640251Smckusick (vp->v_text->x_mtime != np->n_vattr.va_mtime.tv_sec)) 155740251Smckusick xinval(vp); 155839751Smckusick } else { 155939751Smckusick uiop->uio_rw = UIO_WRITE; 156039751Smckusick nfsstats.write_physios++; 156139751Smckusick bp->b_error = error = nfs_writerpc(vp, uiop, bp->b_wcred); 156239341Smckusick } 156339751Smckusick 156439751Smckusick /* 156539751Smckusick * Finally, release pte's used by physical i/o 156639751Smckusick */ 156738884Smacklem crfree(cr); 156838884Smacklem rmfree(nfsmap, (long)npf2, (long)++reg); 156938884Smacklem if (nfsmap_want) { 157038884Smacklem nfsmap_want = 0; 157138884Smacklem wakeup((caddr_t)&nfsmap_want); 157238884Smacklem } 157339751Smckusick } else { 157439751Smckusick if (bp->b_flags & B_READ) { 157539751Smckusick io.iov_len = uiop->uio_resid = bp->b_bcount; 157639823Smckusick uiop->uio_offset = bp->b_blkno * DEV_BSIZE; 157739751Smckusick io.iov_base = bp->b_un.b_addr; 157839751Smckusick uiop->uio_rw = UIO_READ; 157939751Smckusick nfsstats.read_bios++; 158039751Smckusick bp->b_error = error = nfs_readrpc(vp, uiop, bp->b_rcred); 158139751Smckusick } else { 158239751Smckusick io.iov_len = uiop->uio_resid = bp->b_dirtyend 158339751Smckusick - bp->b_dirtyoff; 158439823Smckusick uiop->uio_offset = (bp->b_blkno * DEV_BSIZE) 158539751Smckusick + bp->b_dirtyoff; 158639751Smckusick io.iov_base = bp->b_un.b_addr + bp->b_dirtyoff; 158739751Smckusick uiop->uio_rw = UIO_WRITE; 158839751Smckusick nfsstats.write_bios++; 158939751Smckusick bp->b_error = error = nfs_writerpc(vp, uiop, bp->b_wcred); 159039751Smckusick if (error) { 159139751Smckusick np->n_error = error; 159239751Smckusick np->n_flag |= NWRITEERR; 159339751Smckusick } 159439751Smckusick bp->b_dirtyoff = bp->b_dirtyend = 0; 159539751Smckusick } 159638884Smacklem } 159739751Smckusick if (error) 159839751Smckusick bp->b_flags |= B_ERROR; 159939751Smckusick bp->b_resid = uiop->uio_resid; 160038414Smckusick biodone(bp); 160138414Smckusick return (error); 160238414Smckusick } 160338884Smacklem 160438884Smacklem /* 160538884Smacklem * Flush all the blocks associated with a vnode. 160638884Smacklem * Walk through the buffer pool and push any dirty pages 160738884Smacklem * associated with the vnode. 160838884Smacklem */ 160939488Smckusick /* ARGSUSED */ 161039587Smckusick nfs_fsync(vp, fflags, cred, waitfor) 161138884Smacklem register struct vnode *vp; 161238884Smacklem int fflags; 161338884Smacklem struct ucred *cred; 161439587Smckusick int waitfor; 161538884Smacklem { 161638884Smacklem register struct nfsnode *np = VTONFS(vp); 161739751Smckusick int error = 0; 161838884Smacklem 161938884Smacklem if (np->n_flag & NMODIFIED) { 162038884Smacklem np->n_flag &= ~NMODIFIED; 162139751Smckusick vflushbuf(vp, waitfor == MNT_WAIT ? B_SYNC : 0); 162238884Smacklem } 162339751Smckusick if (!error && (np->n_flag & NWRITEERR)) 162439751Smckusick error = np->n_error; 162538884Smacklem return (error); 162638884Smacklem } 162739672Smckusick 162839672Smckusick /* 162939672Smckusick * Print out the contents of an nfsnode. 163039672Smckusick */ 163139672Smckusick nfs_print(vp) 163239672Smckusick struct vnode *vp; 163339672Smckusick { 163439672Smckusick register struct nfsnode *np = VTONFS(vp); 163539672Smckusick 163640294Smckusick printf("tag VT_NFS, fileid %d fsid 0x%x", 163740294Smckusick np->n_vattr.va_fileid, np->n_vattr.va_fsid); 163840294Smckusick #ifdef FIFO 163940294Smckusick if (vp->v_type == VFIFO) 164040294Smckusick fifo_printinfo(vp); 164140294Smckusick #endif /* FIFO */ 164240294Smckusick printf("%s\n", (np->n_flag & NLOCKED) ? " (LOCKED)" : ""); 164339914Smckusick if (np->n_lockholder == 0) 164439914Smckusick return; 164539914Smckusick printf("\towner pid %d", np->n_lockholder); 164639914Smckusick if (np->n_lockwaiter) 164739914Smckusick printf(" waiting pid %d", np->n_lockwaiter); 164839914Smckusick printf("\n"); 164939672Smckusick } 1650