/* * Copyright (c) 1989 The Regents of the University of California. * All rights reserved. * * This code is derived from software contributed to Berkeley by * Rick Macklem at The University of Guelph. * * Redistribution and use in source and binary forms are permitted * provided that the above copyright notice and this paragraph are * duplicated in all such forms and that any documentation, * advertising materials, and other materials related to such * distribution and use acknowledge that the software was developed * by the University of California, Berkeley. The name of the * University may not be used to endorse or promote products derived * from this software without specific prior written permission. * THIS SOFTWARE IS PROVIDED ``AS IS'' AND WITHOUT ANY EXPRESS OR * IMPLIED WARRANTIES, INCLUDING, WITHOUT LIMITATION, THE IMPLIED * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE. * * @(#)nfs_serv.c 7.16 (Berkeley) 03/06/90 */ /* * nfs version 2 server calls to vnode ops * - these routines generally have 3 phases * 1 - break down and validate rpc request in mbuf list * 2 - do the vnode ops for the request * (surprisingly ?? many are very similar to syscalls in vfs_syscalls.c) * 3 - build the rpc reply in an mbuf list * nb: * - do not mix the phases, since the nfsm_?? macros can return failures * on mbuf exhaustion or similar and do not do any vrele() or vput()'s * * - the nfsm_reply() macro generates an nfs rpc reply with the nfs * error number iff error != 0 whereas * nfsm_srverr simply drops the mbufs and gives up * (==> nfsm_srverr implies an error here at the server, usually mbuf * exhaustion) */ #include "param.h" #include "user.h" #include "file.h" #include "vnode.h" #include "mount.h" #include "mbuf.h" #include "errno.h" #include "nfsv2.h" #include "nfs.h" #include "xdr_subs.h" #include "nfsm_subs.h" /* Defs */ #define TRUE 1 #define FALSE 0 /* Global vars */ extern u_long nfs_procids[NFS_NPROCS]; extern u_long nfs_xdrneg1; extern u_long nfs_false, nfs_true; nfstype nfs_type[VSOCK+1]={ NFNON, NFREG, NFDIR, NFBLK, NFCHR, NFLNK, NFNON, }; /* * nfs getattr service */ nfsrv_getattr(mrep, md, dpos, cred, xid, mrq, repstat) struct mbuf **mrq; struct mbuf *mrep, *md; caddr_t dpos; struct ucred *cred; u_long xid; int *repstat; { register struct nfsv2_fattr *fp; struct vattr va; register struct vattr *vap = &va; struct vnode *vp; nfsv2fh_t nfh; fhandle_t *fhp; register u_long *p; register long t1; caddr_t bpos; int error = 0; char *cp2; struct mbuf *mb, *mb2, *mreq; fhp = &nfh.fh_generic; nfsm_srvmtofh(fhp); if (error = nfsrv_fhtovp(fhp, TRUE, &vp, cred)) nfsm_reply(0); error = VOP_GETATTR(vp, vap, cred); vput(vp); nfsm_reply(NFSX_FATTR); nfsm_build(fp, struct nfsv2_fattr *, NFSX_FATTR); nfsm_srvfillattr; nfsm_srvdone; } /* * nfs setattr service */ nfsrv_setattr(mrep, md, dpos, cred, xid, mrq, repstat) struct mbuf **mrq; struct mbuf *mrep, *md; caddr_t dpos; struct ucred *cred; u_long xid; int *repstat; { struct vattr va; register struct vattr *vap = &va; register struct nfsv2_sattr *sp; register struct nfsv2_fattr *fp; struct vnode *vp; nfsv2fh_t nfh; fhandle_t *fhp; register u_long *p; register long t1; caddr_t bpos; int error = 0; char *cp2; struct mbuf *mb, *mb2, *mreq; fhp = &nfh.fh_generic; nfsm_srvmtofh(fhp); nfsm_disect(sp, struct nfsv2_sattr *, NFSX_SATTR); if (error = nfsrv_fhtovp(fhp, TRUE, &vp, cred)) nfsm_reply(0); if (error = nfsrv_access(vp, VWRITE, cred)) goto out; vattr_null(vap); /* * Nah nah nah nah na nah * There is a bug in the Sun client that puts 0xffff in the mode * field of sattr when it should put in 0xffffffff. The u_short * doesn't sign extend. * --> check the low order 2 bytes for 0xffff */ if ((fxdr_unsigned(int, sp->sa_mode) & 0xffff) != 0xffff) vap->va_mode = nfstov_mode(sp->sa_mode); if (sp->sa_uid != nfs_xdrneg1) vap->va_uid = fxdr_unsigned(uid_t, sp->sa_uid); if (sp->sa_gid != nfs_xdrneg1) vap->va_gid = fxdr_unsigned(gid_t, sp->sa_gid); if (sp->sa_size != nfs_xdrneg1) vap->va_size = fxdr_unsigned(u_long, sp->sa_size); /* * The usec field of sa_atime is overloaded with the va_flags field * for 4.4BSD clients. Hopefully other clients always set both the * sec and usec fields to -1 when not setting the atime. */ if (sp->sa_atime.tv_sec != nfs_xdrneg1) { vap->va_atime.tv_sec = fxdr_unsigned(long, sp->sa_atime.tv_sec); vap->va_atime.tv_usec = 0; } if (sp->sa_atime.tv_usec != nfs_xdrneg1) vap->va_flags = fxdr_unsigned(u_long, sp->sa_atime.tv_usec); if (sp->sa_mtime.tv_sec != nfs_xdrneg1) fxdr_time(&sp->sa_mtime, &vap->va_mtime); if (error = VOP_SETATTR(vp, vap, cred)) { vput(vp); nfsm_reply(0); } error = VOP_GETATTR(vp, vap, cred); out: vput(vp); nfsm_reply(NFSX_FATTR); nfsm_build(fp, struct nfsv2_fattr *, NFSX_FATTR); nfsm_srvfillattr; nfsm_srvdone; } /* * nfs lookup rpc */ nfsrv_lookup(mrep, md, dpos, cred, xid, mrq, repstat) struct mbuf **mrq; struct mbuf *mrep, *md; caddr_t dpos; struct ucred *cred; u_long xid; int *repstat; { register struct nfsv2_fattr *fp; struct nameidata nami; register struct nameidata *ndp = &nami; struct vnode *vp; nfsv2fh_t nfh; fhandle_t *fhp; register caddr_t cp; register u_long *p; register long t1; caddr_t bpos; int error = 0; char *cp2; struct mbuf *mb, *mb2, *mreq; long len; struct vattr va, *vap = &va; ndinit(ndp); fhp = &nfh.fh_generic; nfsm_srvmtofh(fhp); nfsm_srvstrsiz(len, NFS_MAXNAMLEN); ndp->ni_cred = cred; ndp->ni_nameiop = LOOKUP | LOCKLEAF; if (error = nfs_namei(ndp, fhp, len, &md, &dpos)) nfsm_reply(0); vp = ndp->ni_vp; bzero((caddr_t)fhp, sizeof(nfh)); fhp->fh_fsid = vp->v_mount->m_stat.f_fsid; if (error = VFS_VPTOFH(vp, &fhp->fh_fid)) { vput(vp); nfsm_reply(0); } error = VOP_GETATTR(vp, vap, cred); vput(vp); nfsm_reply(NFSX_FH+NFSX_FATTR); nfsm_srvfhtom(fhp); nfsm_build(fp, struct nfsv2_fattr *, NFSX_FATTR); nfsm_srvfillattr; nfsm_srvdone; } /* * nfs readlink service */ nfsrv_readlink(mrep, md, dpos, cred, xid, mrq, repstat) struct mbuf **mrq; struct mbuf *mrep, *md; caddr_t dpos; struct ucred *cred; u_long xid; int *repstat; { struct iovec iv[NFS_MAXPATHLEN/MLEN+1]; register struct iovec *ivp = iv; register struct mbuf *mp; register u_long *p; register long t1; caddr_t bpos; int error = 0; char *cp2; struct mbuf *mb, *mb2, *mp2, *mp3, *mreq; struct vnode *vp; nfsv2fh_t nfh; fhandle_t *fhp; struct uio io, *uiop = &io; int i, tlen, len; fhp = &nfh.fh_generic; nfsm_srvmtofh(fhp); len = 0; i = 0; while (len < NFS_MAXPATHLEN) { MGET(mp, M_WAIT, MT_DATA); NFSMCLGET(mp, M_WAIT); mp->m_len = NFSMSIZ(mp); if (len == 0) mp3 = mp2 = mp; else mp2->m_next = mp; if ((len+mp->m_len) > NFS_MAXPATHLEN) { mp->m_len = NFS_MAXPATHLEN-len; len = NFS_MAXPATHLEN; } else len += mp->m_len; ivp->iov_base = mtod(mp, caddr_t); ivp->iov_len = mp->m_len; i++; ivp++; } uiop->uio_iov = iv; uiop->uio_iovcnt = i; uiop->uio_offset = 0; uiop->uio_resid = len; uiop->uio_rw = UIO_READ; uiop->uio_segflg = UIO_SYSSPACE; if (error = nfsrv_fhtovp(fhp, TRUE, &vp, cred)) { m_freem(mp3); nfsm_reply(0); } if (vp->v_type != VLNK) { error = EINVAL; goto out; } error = VOP_READLINK(vp, uiop, cred); out: vput(vp); if (error) m_freem(mp3); nfsm_reply(NFSX_UNSIGNED); if (uiop->uio_resid > 0) { len -= uiop->uio_resid; tlen = nfsm_rndup(len); nfsm_adj(mp3, NFS_MAXPATHLEN-tlen, tlen-len); } nfsm_build(p, u_long *, NFSX_UNSIGNED); *p = txdr_unsigned(len); mb->m_next = mp3; nfsm_srvdone; } /* * nfs read service */ nfsrv_read(mrep, md, dpos, cred, xid, mrq, repstat) struct mbuf **mrq; struct mbuf *mrep, *md; caddr_t dpos; struct ucred *cred; u_long xid; int *repstat; { struct iovec iv[NFS_MAXDATA/MCLBYTES+1]; register struct iovec *ivp = iv; register struct mbuf *mp; register struct nfsv2_fattr *fp; register u_long *p; register long t1; caddr_t bpos; int error = 0; char *cp2; struct mbuf *mb, *mb2, *mreq; struct mbuf *mp2, *mp3; struct vnode *vp; nfsv2fh_t nfh; fhandle_t *fhp; struct uio io, *uiop = &io; struct vattr va, *vap = &va; int i, tlen, cnt, len, nio, left; off_t off; fhp = &nfh.fh_generic; nfsm_srvmtofh(fhp); nfsm_disect(p, u_long *, NFSX_UNSIGNED); off = fxdr_unsigned(off_t, *p); nfsm_srvstrsiz(cnt, NFS_MAXDATA); if (error = nfsrv_fhtovp(fhp, TRUE, &vp, cred)) nfsm_reply(0); if (error = nfsrv_access(vp, VREAD | VEXEC, cred)) { vput(vp); nfsm_reply(0); } len = left = cnt; nio = (cnt+MCLBYTES-1)/MCLBYTES; uiop->uio_iov = ivp; uiop->uio_iovcnt = nio; uiop->uio_offset = off; uiop->uio_resid = cnt; uiop->uio_rw = UIO_READ; uiop->uio_segflg = UIO_SYSSPACE; for (i = 0; i < nio; i++) { MGET(mp, M_WAIT, MT_DATA); if (left > MLEN) NFSMCLGET(mp, M_WAIT); mp->m_len = (M_HASCL(mp)) ? MCLBYTES : MLEN; if (i == 0) { mp3 = mp2 = mp; } else { mp2->m_next = mp; mp2 = mp; } if (left > MLEN && !M_HASCL(mp)) { m_freem(mp3); vput(vp); nfsm_srverr; } ivp->iov_base = mtod(mp, caddr_t); if (left > mp->m_len) { ivp->iov_len = mp->m_len; left -= mp->m_len; } else { ivp->iov_len = mp->m_len = left; left = 0; } ivp++; } error = VOP_READ(vp, uiop, IO_NODELOCKED, cred); off = uiop->uio_offset; if (error) { m_freem(mp3); vput(vp); nfsm_reply(0); } if (error = VOP_GETATTR(vp, vap, cred)) m_freem(mp3); vput(vp); nfsm_reply(NFSX_FATTR+NFSX_UNSIGNED); nfsm_build(fp, struct nfsv2_fattr *, NFSX_FATTR); nfsm_srvfillattr; if (uiop->uio_resid > 0) { len -= uiop->uio_resid; if (len > 0) { tlen = nfsm_rndup(len); nfsm_adj(mp3, cnt-tlen, tlen-len); } else { m_freem(mp3); mp3 = (struct mbuf *)0; } } nfsm_build(p, u_long *, NFSX_UNSIGNED); *p = txdr_unsigned(len); mb->m_next = mp3; nfsm_srvdone; } /* * nfs write service */ nfsrv_write(mrep, md, dpos, cred, xid, mrq, repstat) struct mbuf *mrep, *md, **mrq; caddr_t dpos; struct ucred *cred; u_long xid; int *repstat; { register struct iovec *ivp; register struct mbuf *mp; register struct nfsv2_fattr *fp; struct iovec iv[MAX_IOVEC]; struct vattr va; register struct vattr *vap = &va; register u_long *p; register long t1; caddr_t bpos; int error = 0; char *cp2; struct mbuf *mb, *mb2, *mreq; struct vnode *vp; nfsv2fh_t nfh; fhandle_t *fhp; struct uio io, *uiop = &io; off_t off; long siz, len, xfer; fhp = &nfh.fh_generic; nfsm_srvmtofh(fhp); nfsm_disect(p, u_long *, 4*NFSX_UNSIGNED); off = fxdr_unsigned(off_t, *++p); p += 2; len = fxdr_unsigned(long, *p); if (len > NFS_MAXDATA || len <= 0) { error = EBADRPC; nfsm_reply(0); } if (dpos == (mtod(md, caddr_t)+md->m_len)) { mp = md->m_next; if (mp == NULL) { error = EBADRPC; nfsm_reply(0); } } else { mp = md; siz = dpos-mtod(mp, caddr_t); mp->m_len -= siz; NFSMADV(mp, siz); } if (error = nfsrv_fhtovp(fhp, TRUE, &vp, cred)) nfsm_reply(0); if (error = nfsrv_access(vp, VWRITE, cred)) { vput(vp); nfsm_reply(0); } uiop->uio_resid = 0; uiop->uio_rw = UIO_WRITE; uiop->uio_segflg = UIO_SYSSPACE; /* * Do up to MAX_IOVEC mbufs of write each iteration of the * loop until done. */ while (len > 0 && uiop->uio_resid == 0) { ivp = iv; siz = 0; uiop->uio_iov = ivp; uiop->uio_iovcnt = 0; uiop->uio_offset = off; while (len > 0 && uiop->uio_iovcnt < MAX_IOVEC && mp != NULL) { ivp->iov_base = mtod(mp, caddr_t); if (len < mp->m_len) ivp->iov_len = xfer = len; else ivp->iov_len = xfer = mp->m_len; #ifdef notdef /* Not Yet .. */ if (M_HASCL(mp) && (((u_long)ivp->iov_base) & CLOFSET) == 0) ivp->iov_op = NULL; /* what should it be ?? */ else ivp->iov_op = NULL; #endif uiop->uio_iovcnt++; ivp++; len -= xfer; siz += xfer; mp = mp->m_next; } if (len > 0 && mp == NULL) { error = EBADRPC; vput(vp); nfsm_reply(0); } uiop->uio_resid = siz; if (error = VOP_WRITE(vp, uiop, IO_SYNC | IO_NODELOCKED, cred)) { vput(vp); nfsm_reply(0); } off = uiop->uio_offset; } error = VOP_GETATTR(vp, vap, cred); vput(vp); nfsm_reply(NFSX_FATTR); nfsm_build(fp, struct nfsv2_fattr *, NFSX_FATTR); nfsm_srvfillattr; nfsm_srvdone; } /* * nfs create service * now does a truncate to 0 length via. setattr if it already exists */ nfsrv_create(mrep, md, dpos, cred, xid, mrq, repstat) struct mbuf *mrep, *md, **mrq; caddr_t dpos; struct ucred *cred; u_long xid; int *repstat; { register struct nfsv2_fattr *fp; struct vattr va; register struct vattr *vap = &va; struct nameidata nami; register struct nameidata *ndp = &nami; register caddr_t cp; register u_long *p; register long t1; caddr_t bpos; int error = 0; char *cp2; struct mbuf *mb, *mb2, *mreq; struct vnode *vp; nfsv2fh_t nfh; fhandle_t *fhp; long len; ndinit(ndp); fhp = &nfh.fh_generic; nfsm_srvmtofh(fhp); nfsm_srvstrsiz(len, NFS_MAXNAMLEN); ndp->ni_cred = cred; ndp->ni_nameiop = CREATE | LOCKPARENT | LOCKLEAF; if (error = nfs_namei(ndp, fhp, len, &md, &dpos)) nfsm_reply(0); vattr_null(vap); nfsm_disect(p, u_long *, NFSX_UNSIGNED); /* * Iff doesn't exist, create it * otherwise just truncate to 0 length * should I set the mode too ?? */ if (ndp->ni_vp == NULL) { vap->va_type = VREG; vap->va_mode = nfstov_mode(*p++); if (error = VOP_CREATE(ndp, vap)) nfsm_reply(0); vp = ndp->ni_vp; } else { vp = ndp->ni_vp; ndp->ni_vp = (struct vnode *)0; VOP_ABORTOP(ndp); vap->va_size = 0; if (error = VOP_SETATTR(vp, vap, cred)) nfsm_reply(0); } bzero((caddr_t)fhp, sizeof(nfh)); fhp->fh_fsid = vp->v_mount->m_stat.f_fsid; if (error = VFS_VPTOFH(vp, &fhp->fh_fid)) { vput(vp); nfsm_reply(0); } error = VOP_GETATTR(vp, vap, cred); vput(vp); nfsm_reply(NFSX_FH+NFSX_FATTR); nfsm_srvfhtom(fhp); nfsm_build(fp, struct nfsv2_fattr *, NFSX_FATTR); nfsm_srvfillattr; return (error); nfsmout: VOP_ABORTOP(ndp); return (error); } /* * nfs remove service */ nfsrv_remove(mrep, md, dpos, cred, xid, mrq, repstat) struct mbuf *mrep, *md, **mrq; caddr_t dpos; struct ucred *cred; u_long xid; int *repstat; { struct nameidata nami; register struct nameidata *ndp = &nami; register u_long *p; register long t1; caddr_t bpos; int error = 0; char *cp2; struct mbuf *mb, *mreq; struct vnode *vp; nfsv2fh_t nfh; fhandle_t *fhp; long len; ndinit(ndp); fhp = &nfh.fh_generic; nfsm_srvmtofh(fhp); nfsm_srvstrsiz(len, NFS_MAXNAMLEN); ndp->ni_cred = cred; ndp->ni_nameiop = DELETE | LOCKPARENT | LOCKLEAF; if (error = nfs_namei(ndp, fhp, len, &md, &dpos)) nfsm_reply(0); vp = ndp->ni_vp; if (vp->v_type == VDIR && (error = suser(cred, (short *)0))) goto out; /* * Don't unlink a mounted file. */ if (vp->v_flag & VROOT) { error = EBUSY; goto out; } if (vp->v_flag & VTEXT) xrele(vp); /* try once to free text */ out: if (error) VOP_ABORTOP(ndp); else error = VOP_REMOVE(ndp); nfsm_reply(0); nfsm_srvdone; } /* * nfs rename service */ nfsrv_rename(mrep, md, dpos, cred, xid, mrq, repstat) struct mbuf *mrep, *md, **mrq; caddr_t dpos; struct ucred *cred; u_long xid; int *repstat; { register struct nameidata *ndp; register u_long *p; register long t1; caddr_t bpos; int error = 0; char *cp2; struct mbuf *mb, *mreq; struct nameidata nami, tond; struct vnode *fvp, *tvp, *tdvp; nfsv2fh_t fnfh, tnfh; fhandle_t *ffhp, *tfhp; long len, len2; int rootflg = 0; ndp = &nami; ndinit(ndp); ffhp = &fnfh.fh_generic; tfhp = &tnfh.fh_generic; nfsm_srvmtofh(ffhp); nfsm_srvstrsiz(len, NFS_MAXNAMLEN); /* * Remember if we are root so that we can reset cr_uid before * the second nfs_namei() call */ if (cred->cr_uid == 0) rootflg++; ndp->ni_cred = cred; ndp->ni_nameiop = DELETE | WANTPARENT; if (error = nfs_namei(ndp, ffhp, len, &md, &dpos)) nfsm_reply(0); fvp = ndp->ni_vp; nfsm_srvmtofh(tfhp); nfsm_srvstrsiz(len2, NFS_MAXNAMLEN); if (rootflg) cred->cr_uid = 0; ndinit(&tond); crhold(cred); tond.ni_cred = cred; tond.ni_nameiop = RENAME | LOCKPARENT | LOCKLEAF | NOCACHE; error = nfs_namei(&tond, tfhp, len2, &md, &dpos); tdvp = tond.ni_dvp; tvp = tond.ni_vp; if (tvp != NULL) { if (fvp->v_type == VDIR && tvp->v_type != VDIR) { error = EISDIR; goto out; } else if (fvp->v_type != VDIR && tvp->v_type == VDIR) { error = ENOTDIR; goto out; } } if (error) { VOP_ABORTOP(ndp); goto out1; } if (fvp->v_mount != tdvp->v_mount) { error = EXDEV; goto out; } if (fvp == tdvp || fvp == tvp) error = EINVAL; out: if (error) { VOP_ABORTOP(&tond); VOP_ABORTOP(ndp); } else { VREF(ndp->ni_cdir); VREF(tond.ni_cdir); error = VOP_RENAME(ndp, &tond); vrele(ndp->ni_cdir); vrele(tond.ni_cdir); } out1: crfree(cred); nfsm_reply(0); return (error); nfsmout: VOP_ABORTOP(ndp); return (error); } /* * nfs link service */ nfsrv_link(mrep, md, dpos, cred, xid, mrq, repstat) struct mbuf *mrep, *md, **mrq; caddr_t dpos; struct ucred *cred; u_long xid; int *repstat; { struct nameidata nami; register struct nameidata *ndp = &nami; register u_long *p; register long t1; caddr_t bpos; int error = 0; char *cp2; struct mbuf *mb, *mreq; struct vnode *vp, *xp; nfsv2fh_t nfh, dnfh; fhandle_t *fhp, *dfhp; long len; ndinit(ndp); fhp = &nfh.fh_generic; dfhp = &dnfh.fh_generic; nfsm_srvmtofh(fhp); nfsm_srvmtofh(dfhp); nfsm_srvstrsiz(len, NFS_MAXNAMLEN); if (error = nfsrv_fhtovp(fhp, FALSE, &vp, cred)) nfsm_reply(0); if (vp->v_type == VDIR && (error = suser(cred, NULL))) goto out1; ndp->ni_cred = cred; ndp->ni_nameiop = CREATE | LOCKPARENT; if (error = nfs_namei(ndp, dfhp, len, &md, &dpos)) goto out1; xp = ndp->ni_vp; if (xp != NULL) { error = EEXIST; goto out; } xp = ndp->ni_dvp; if (vp->v_mount != xp->v_mount) error = EXDEV; out: if (error) VOP_ABORTOP(ndp); else error = VOP_LINK(vp, ndp); out1: vrele(vp); nfsm_reply(0); nfsm_srvdone; } /* * nfs symbolic link service */ nfsrv_symlink(mrep, md, dpos, cred, xid, mrq, repstat) struct mbuf *mrep, *md, **mrq; caddr_t dpos; struct ucred *cred; u_long xid; int *repstat; { struct vattr va; struct nameidata nami; register struct nameidata *ndp = &nami; register struct vattr *vap = &va; register u_long *p; register long t1; caddr_t bpos; int error = 0; char *cp2; struct mbuf *mb, *mreq; struct vnode *vp; nfsv2fh_t nfh; fhandle_t *fhp; long len, tlen, len2; ndinit(ndp); fhp = &nfh.fh_generic; nfsm_srvmtofh(fhp); nfsm_srvstrsiz(len, NFS_MAXNAMLEN); ndp->ni_cred = cred; ndp->ni_nameiop = CREATE | LOCKPARENT; if (error = nfs_namei(ndp, fhp, len, &md, &dpos)) goto out1; nfsm_srvstrsiz(len2, NFS_MAXPATHLEN); tlen = nfsm_rndup(len2); if (len2 == tlen) { nfsm_disect(cp2, caddr_t, tlen+NFSX_UNSIGNED); *(cp2+tlen) = '\0'; } else { nfsm_disect(cp2, caddr_t, tlen); } vp = ndp->ni_vp; if (vp) { error = EEXIST; goto out; } vp = ndp->ni_dvp; vattr_null(vap); vap->va_mode = 0777; out: if (error) VOP_ABORTOP(ndp); else error = VOP_SYMLINK(ndp, vap, cp2); out1: nfsm_reply(0); return (error); nfsmout: VOP_ABORTOP(ndp); return (error); } /* * nfs mkdir service */ nfsrv_mkdir(mrep, md, dpos, cred, xid, mrq, repstat) struct mbuf *mrep, *md, **mrq; caddr_t dpos; struct ucred *cred; u_long xid; int *repstat; { struct vattr va; register struct vattr *vap = &va; register struct nfsv2_fattr *fp; struct nameidata nami; register struct nameidata *ndp = &nami; register caddr_t cp; register u_long *p; register long t1; caddr_t bpos; int error = 0; char *cp2; struct mbuf *mb, *mb2, *mreq; struct vnode *vp; nfsv2fh_t nfh; fhandle_t *fhp; long len; ndinit(ndp); fhp = &nfh.fh_generic; nfsm_srvmtofh(fhp); nfsm_srvstrsiz(len, NFS_MAXNAMLEN); ndp->ni_cred = cred; ndp->ni_nameiop = CREATE | LOCKPARENT; if (error = nfs_namei(ndp, fhp, len, &md, &dpos)) nfsm_reply(0); nfsm_disect(p, u_long *, NFSX_UNSIGNED); vattr_null(vap); vap->va_type = VDIR; vap->va_mode = nfstov_mode(*p++); vp = ndp->ni_vp; if (vp != NULL) { VOP_ABORTOP(ndp); error = EEXIST; nfsm_reply(0); } if (error = VOP_MKDIR(ndp, vap)) nfsm_reply(0); vp = ndp->ni_vp; bzero((caddr_t)fhp, sizeof(nfh)); fhp->fh_fsid = vp->v_mount->m_stat.f_fsid; if (error = VFS_VPTOFH(vp, &fhp->fh_fid)) { vput(vp); nfsm_reply(0); } error = VOP_GETATTR(vp, vap, cred); vput(vp); nfsm_reply(NFSX_FH+NFSX_FATTR); nfsm_srvfhtom(fhp); nfsm_build(fp, struct nfsv2_fattr *, NFSX_FATTR); nfsm_srvfillattr; return (error); nfsmout: VOP_ABORTOP(ndp); return (error); } /* * nfs rmdir service */ nfsrv_rmdir(mrep, md, dpos, cred, xid, mrq, repstat) struct mbuf *mrep, *md, **mrq; caddr_t dpos; struct ucred *cred; u_long xid; int *repstat; { struct nameidata nami; register struct nameidata *ndp = &nami; register u_long *p; register long t1; caddr_t bpos; int error = 0; char *cp2; struct mbuf *mb, *mreq; struct vnode *vp; nfsv2fh_t nfh; fhandle_t *fhp; long len; ndinit(ndp); fhp = &nfh.fh_generic; nfsm_srvmtofh(fhp); nfsm_srvstrsiz(len, NFS_MAXNAMLEN); ndp->ni_cred = cred; ndp->ni_nameiop = DELETE | LOCKPARENT | LOCKLEAF; if (error = nfs_namei(ndp, fhp, len, &md, &dpos)) nfsm_reply(0); vp = ndp->ni_vp; if (vp->v_type != VDIR) { error = ENOTDIR; goto out; } /* * No rmdir "." please. */ if (ndp->ni_dvp == vp) { error = EINVAL; goto out; } /* * Don't unlink a mounted file. */ if (vp->v_flag & VROOT) error = EBUSY; out: if (error) VOP_ABORTOP(ndp); else error = VOP_RMDIR(ndp); nfsm_reply(0); nfsm_srvdone; } /* * nfs readdir service * - mallocs what it thinks is enough to read * count rounded up to a multiple of DIRBLKSIZ <= MAX_READDIR * - calls VOP_READDIR() * - loops around building the reply * if the output generated exceeds count break out of loop * The nfsm_clget macro is used here so that the reply will be packed * tightly in mbuf clusters. * - it only knows that it has encountered eof when the VOP_READDIR() * reads nothing * - as such one readdir rpc will return eof false although you are there * and then the next will return eof * - it trims out records with d_ino == 0 * this doesn't matter for Unix clients, but they might confuse clients * for other os'. * NB: It is tempting to set eof to true if the VOP_READDIR() reads less * than requested, but this may not apply to all filesystems. For * example, client NFS does not { although it is never remote mounted * anyhow } * PS: The NFS protocol spec. does not clarify what the "count" byte * argument is a count of.. just name strings and file id's or the * entire reply rpc or ... * I tried just file name and id sizes and it confused the Sun client, * so I am using the full rpc size now. The "paranoia.." comment refers * to including the status longwords that are not a part of the dir. * "entry" structures, but are in the rpc. */ nfsrv_readdir(mrep, md, dpos, cred, xid, mrq, repstat) struct mbuf **mrq; struct mbuf *mrep, *md; caddr_t dpos; struct ucred *cred; u_long xid; int *repstat; { register char *bp, *be; register struct mbuf *mp; register struct direct *dp; register caddr_t cp; register u_long *p; register long t1; caddr_t bpos; int error = 0; char *cp2; struct mbuf *mb, *mb2, *mreq; char *cpos, *cend; int len, nlen, rem, xfer, tsiz, i; struct vnode *vp; struct mbuf *mp2, *mp3; nfsv2fh_t nfh; fhandle_t *fhp; struct uio io; struct iovec iv; int siz, cnt, fullsiz, eofflag; u_long on; char *rbuf; off_t off, toff; fhp = &nfh.fh_generic; nfsm_srvmtofh(fhp); nfsm_disect(p, u_long *, 2*NFSX_UNSIGNED); toff = fxdr_unsigned(off_t, *p++); off = (toff & ~(DIRBLKSIZ-1)); on = (toff & (DIRBLKSIZ-1)); cnt = fxdr_unsigned(int, *p); siz = ((cnt+DIRBLKSIZ) & ~(DIRBLKSIZ-1)); if (cnt > MAX_READDIR) siz = MAX_READDIR; fullsiz = siz; if (error = nfsrv_fhtovp(fhp, TRUE, &vp, cred)) nfsm_reply(0); if (error = nfsrv_access(vp, VEXEC, cred)) { vput(vp); nfsm_reply(0); } VOP_UNLOCK(vp); MALLOC(rbuf, caddr_t, siz, M_TEMP, M_WAITOK); again: iv.iov_base = rbuf; iv.iov_len = fullsiz; io.uio_iov = &iv; io.uio_iovcnt = 1; io.uio_offset = off; io.uio_resid = fullsiz; io.uio_segflg = UIO_SYSSPACE; io.uio_rw = UIO_READ; error = VOP_READDIR(vp, &io, cred, &eofflag); off = io.uio_offset; if (error) { vrele(vp); free((caddr_t)rbuf, M_TEMP); nfsm_reply(0); } if (io.uio_resid) { siz -= io.uio_resid; /* * If nothing read, return eof * rpc reply */ if (siz == 0) { vrele(vp); nfsm_reply(2*NFSX_UNSIGNED); nfsm_build(p, u_long *, 2*NFSX_UNSIGNED); *p++ = nfs_false; *p = nfs_true; FREE((caddr_t)rbuf, M_TEMP); return (0); } } /* * Check for degenerate cases of nothing useful read. * If so go try again */ cpos = rbuf + on; cend = rbuf + siz; dp = (struct direct *)cpos; while (cpos < cend && dp->d_ino == 0) { cpos += dp->d_reclen; dp = (struct direct *)cpos; } if (cpos >= cend) { toff = off; siz = fullsiz; on = 0; goto again; } cpos = rbuf + on; cend = rbuf + siz; dp = (struct direct *)cpos; vrele(vp); len = 3*NFSX_UNSIGNED; /* paranoia, probably can be 0 */ bp = be = (caddr_t)0; mp3 = (struct mbuf *)0; nfsm_reply(siz); /* Loop through the records and build reply */ while (cpos < cend) { if (dp->d_ino != 0) { nlen = dp->d_namlen; rem = nfsm_rndup(nlen)-nlen; /* * As noted above, the NFS spec. is not clear about what * should be included in "count" as totalled up here in * "len". */ len += (4*NFSX_UNSIGNED+nlen+rem); if (len > cnt) break; /* Build the directory record xdr from the direct entry */ nfsm_clget; *p = nfs_true; bp += NFSX_UNSIGNED; nfsm_clget; *p = txdr_unsigned(dp->d_ino); bp += NFSX_UNSIGNED; nfsm_clget; *p = txdr_unsigned(nlen); bp += NFSX_UNSIGNED; /* And loop arround copying the name */ xfer = nlen; cp = dp->d_name; while (xfer > 0) { nfsm_clget; if ((bp+xfer) > be) tsiz = be-bp; else tsiz = xfer; bcopy(cp, bp, tsiz); bp += tsiz; xfer -= tsiz; if (xfer > 0) cp += tsiz; } /* And null pad to a long boundary */ for (i = 0; i < rem; i++) *bp++ = '\0'; nfsm_clget; /* Finish off the record */ toff += dp->d_reclen; *p = txdr_unsigned(toff); bp += NFSX_UNSIGNED; } else toff += dp->d_reclen; cpos += dp->d_reclen; dp = (struct direct *)cpos; } nfsm_clget; *p = nfs_false; bp += NFSX_UNSIGNED; nfsm_clget; if (eofflag) *p = nfs_true; else *p = nfs_false; bp += NFSX_UNSIGNED; if (bp < be) mp->m_len = bp-mtod(mp, caddr_t); mb->m_next = mp3; FREE(rbuf, M_TEMP); nfsm_srvdone; } /* * nfs statfs service */ nfsrv_statfs(mrep, md, dpos, cred, xid, mrq, repstat) struct mbuf **mrq; struct mbuf *mrep, *md; caddr_t dpos; struct ucred *cred; u_long xid; int *repstat; { register struct statfs *sf; register struct nfsv2_statfs *sfp; register u_long *p; register long t1; caddr_t bpos; int error = 0; char *cp2; struct mbuf *mb, *mb2, *mreq; struct vnode *vp; nfsv2fh_t nfh; fhandle_t *fhp; struct statfs statfs; fhp = &nfh.fh_generic; nfsm_srvmtofh(fhp); if (error = nfsrv_fhtovp(fhp, TRUE, &vp, cred)) nfsm_reply(0); sf = &statfs; error = VFS_STATFS(vp->v_mount, sf); vput(vp); nfsm_reply(NFSX_STATFS); nfsm_build(sfp, struct nfsv2_statfs *, NFSX_STATFS); sfp->sf_tsize = txdr_unsigned(NFS_MAXDATA); sfp->sf_bsize = txdr_unsigned(sf->f_fsize); sfp->sf_blocks = txdr_unsigned(sf->f_blocks); sfp->sf_bfree = txdr_unsigned(sf->f_bfree); sfp->sf_bavail = txdr_unsigned(sf->f_bavail); nfsm_srvdone; } /* * Null operation, used by clients to ping server */ /* ARGSUSED */ nfsrv_null(mrep, md, dpos, cred, xid, mrq, repstat) struct mbuf **mrq; struct mbuf *mrep, *md; caddr_t dpos; struct ucred *cred; u_long xid; int *repstat; { caddr_t bpos; int error = 0; struct mbuf *mb, *mreq; error = VNOVAL; nfsm_reply(0); return (error); } /* * No operation, used for obsolete procedures */ /* ARGSUSED */ nfsrv_noop(mrep, md, dpos, cred, xid, mrq, repstat) struct mbuf **mrq; struct mbuf *mrep, *md; caddr_t dpos; struct ucred *cred; u_long xid; int *repstat; { caddr_t bpos; int error = 0; struct mbuf *mb, *mreq; error = EPROCUNAVAIL; nfsm_reply(0); return (error); } /* * Perform access checking for vnodes obtained from file handles that would * refer to files already opened by a Unix client. You cannot just use * vn_writechk() and VOP_ACCESS() for two reasons. * 1 - You must check for M_EXRDONLY as well as M_RDONLY for the write case * 2 - The owner is to be given access irrespective of mode bits so that * processes that chmod after opening a file don't break. I don't like * this because it opens a security hole, but since the nfs server opens * a security hole the size of a barn door anyhow, what the heck. */ nfsrv_access(vp, flags, cred) register struct vnode *vp; int flags; register struct ucred *cred; { struct vattr vattr; int error; if (flags & VWRITE) { /* Just vn_writechk() changed to check M_EXRDONLY */ /* * Disallow write attempts on read-only file systems; * unless the file is a socket or a block or character * device resident on the file system. */ if ((vp->v_mount->m_flag & (M_RDONLY | M_EXRDONLY)) && vp->v_type != VCHR && vp->v_type != VBLK && vp->v_type != VSOCK) return (EROFS); /* * If there's shared text associated with * the inode, try to free it up once. If * we fail, we can't allow writing. */ if (vp->v_flag & VTEXT) xrele(vp); if (vp->v_flag & VTEXT) return (ETXTBSY); if (error = VOP_GETATTR(vp, &vattr, cred)) return (error); if (cred->cr_uid == vattr.va_uid) return (0); } else { if (error = VOP_GETATTR(vp, &vattr, cred)) return (error); if (cred->cr_uid == vattr.va_uid) return (0); } return (VOP_ACCESS(vp, flags, cred)); }