Home | History | Annotate | Line # | Download | only in nfs
nfs_serv.c revision 1.101.2.2
      1  1.101.2.2      yamt /*	$NetBSD: nfs_serv.c,v 1.101.2.2 2006/05/24 10:59:15 yamt Exp $	*/
      2       1.16       cgd 
      3        1.1       cgd /*
      4       1.15   mycroft  * Copyright (c) 1989, 1993
      5       1.15   mycroft  *	The Regents of the University of California.  All rights reserved.
      6        1.1       cgd  *
      7        1.1       cgd  * This code is derived from software contributed to Berkeley by
      8        1.1       cgd  * Rick Macklem at The University of Guelph.
      9        1.1       cgd  *
     10        1.1       cgd  * Redistribution and use in source and binary forms, with or without
     11        1.1       cgd  * modification, are permitted provided that the following conditions
     12        1.1       cgd  * are met:
     13        1.1       cgd  * 1. Redistributions of source code must retain the above copyright
     14        1.1       cgd  *    notice, this list of conditions and the following disclaimer.
     15        1.1       cgd  * 2. Redistributions in binary form must reproduce the above copyright
     16        1.1       cgd  *    notice, this list of conditions and the following disclaimer in the
     17        1.1       cgd  *    documentation and/or other materials provided with the distribution.
     18       1.81       agc  * 3. Neither the name of the University nor the names of its contributors
     19        1.1       cgd  *    may be used to endorse or promote products derived from this software
     20        1.1       cgd  *    without specific prior written permission.
     21        1.1       cgd  *
     22        1.1       cgd  * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
     23        1.1       cgd  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
     24        1.1       cgd  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
     25        1.1       cgd  * ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
     26        1.1       cgd  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
     27        1.1       cgd  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
     28        1.1       cgd  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
     29        1.1       cgd  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
     30        1.1       cgd  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
     31        1.1       cgd  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
     32        1.1       cgd  * SUCH DAMAGE.
     33        1.1       cgd  *
     34       1.42      fvdl  *	@(#)nfs_serv.c	8.8 (Berkeley) 7/31/95
     35        1.1       cgd  */
     36        1.1       cgd 
     37        1.1       cgd /*
     38       1.23      fvdl  * nfs version 2 and 3 server calls to vnode ops
     39        1.1       cgd  * - these routines generally have 3 phases
     40        1.1       cgd  *   1 - break down and validate rpc request in mbuf list
     41        1.1       cgd  *   2 - do the vnode ops for the request
     42        1.1       cgd  *       (surprisingly ?? many are very similar to syscalls in vfs_syscalls.c)
     43        1.1       cgd  *   3 - build the rpc reply in an mbuf list
     44        1.1       cgd  *   nb:
     45        1.1       cgd  *	- do not mix the phases, since the nfsm_?? macros can return failures
     46        1.1       cgd  *	  on a bad rpc or similar and do not do any vrele() or vput()'s
     47        1.1       cgd  *
     48        1.1       cgd  *      - the nfsm_reply() macro generates an nfs rpc reply with the nfs
     49        1.1       cgd  *	error number iff error != 0 whereas
     50        1.1       cgd  *	returning an error from the server function implies a fatal error
     51        1.1       cgd  *	such as a badly constructed rpc request that should be dropped without
     52        1.1       cgd  *	a reply.
     53       1.23      fvdl  *	For Version 3, nfsm_reply() does not return for the error case, since
     54       1.23      fvdl  *	most version 3 rpcs return more than the status for error cases.
     55        1.1       cgd  */
     56       1.62     lukem 
     57       1.62     lukem #include <sys/cdefs.h>
     58  1.101.2.2      yamt __KERNEL_RCSID(0, "$NetBSD: nfs_serv.c,v 1.101.2.2 2006/05/24 10:59:15 yamt Exp $");
     59       1.41       mrg 
     60       1.10   mycroft #include <sys/param.h>
     61       1.10   mycroft #include <sys/systm.h>
     62       1.10   mycroft #include <sys/proc.h>
     63       1.10   mycroft #include <sys/file.h>
     64       1.10   mycroft #include <sys/namei.h>
     65       1.10   mycroft #include <sys/vnode.h>
     66       1.10   mycroft #include <sys/mount.h>
     67       1.23      fvdl #include <sys/socket.h>
     68       1.23      fvdl #include <sys/socketvar.h>
     69       1.10   mycroft #include <sys/mbuf.h>
     70       1.15   mycroft #include <sys/dirent.h>
     71       1.15   mycroft #include <sys/stat.h>
     72       1.23      fvdl #include <sys/kernel.h>
     73  1.101.2.2      yamt #include <sys/kauth.h>
     74        1.1       cgd 
     75       1.72      yamt #include <uvm/uvm.h>
     76       1.40       mrg 
     77       1.23      fvdl #include <nfs/nfsproto.h>
     78       1.15   mycroft #include <nfs/rpcv2.h>
     79       1.10   mycroft #include <nfs/nfs.h>
     80       1.10   mycroft #include <nfs/xdr_subs.h>
     81       1.10   mycroft #include <nfs/nfsm_subs.h>
     82       1.15   mycroft #include <nfs/nqnfs.h>
     83       1.22  christos #include <nfs/nfs_var.h>
     84        1.1       cgd 
     85        1.1       cgd /* Global vars */
     86       1.19       cgd extern u_int32_t nfs_xdrneg1;
     87       1.19       cgd extern u_int32_t nfs_false, nfs_true;
     88       1.23      fvdl extern enum vtype nv3tov_type[8];
     89       1.23      fvdl extern struct nfsstats nfsstats;
     90       1.66      matt extern const nfstype nfsv2_type[9];
     91       1.66      matt extern const nfstype nfsv3_type[9];
     92       1.23      fvdl int nfsrvw_procrastinate = NFS_GATHERDELAY * 1000;
     93       1.72      yamt int nfsd_use_loan = 1;	/* use page-loan for READ OP */
     94        1.1       cgd 
     95       1.15   mycroft /*
     96       1.23      fvdl  * nfs v3 access service
     97       1.15   mycroft  */
     98       1.22  christos int
     99       1.99  christos nfsrv3_access(nfsd, slp, lwp, mrq)
    100       1.23      fvdl 	struct nfsrv_descript *nfsd;
    101       1.23      fvdl 	struct nfssvc_sock *slp;
    102       1.99  christos 	struct lwp *lwp;
    103       1.23      fvdl 	struct mbuf **mrq;
    104       1.15   mycroft {
    105       1.23      fvdl 	struct mbuf *mrep = nfsd->nd_mrep, *md = nfsd->nd_md;
    106       1.23      fvdl 	struct mbuf *nam = nfsd->nd_nam;
    107       1.23      fvdl 	caddr_t dpos = nfsd->nd_dpos;
    108  1.101.2.2      yamt 	kauth_cred_t cred = nfsd->nd_cr;
    109       1.15   mycroft 	struct vnode *vp;
    110       1.23      fvdl 	nfsfh_t nfh;
    111       1.15   mycroft 	fhandle_t *fhp;
    112       1.54  augustss 	u_int32_t *tl;
    113       1.54  augustss 	int32_t t1;
    114       1.15   mycroft 	caddr_t bpos;
    115       1.23      fvdl 	int error = 0, rdonly, cache = 0, getret;
    116       1.15   mycroft 	char *cp2;
    117       1.67      matt 	struct mbuf *mb, *mreq;
    118       1.23      fvdl 	struct vattr va;
    119       1.32   mycroft 	u_long inmode, testmode, outmode;
    120       1.15   mycroft 	u_quad_t frev;
    121       1.15   mycroft 
    122       1.15   mycroft 	fhp = &nfh.fh_generic;
    123       1.15   mycroft 	nfsm_srvmtofh(fhp);
    124       1.23      fvdl 	nfsm_dissect(tl, u_int32_t *, NFSX_UNSIGNED);
    125       1.23      fvdl 	error = nfsrv_fhtovp(fhp, 1, &vp, cred, slp, nam, &rdonly,
    126       1.78   thorpej 	    (nfsd->nd_flag & ND_KERBAUTH), FALSE);
    127       1.23      fvdl 	if (error) {
    128       1.23      fvdl 		nfsm_reply(NFSX_UNSIGNED);
    129       1.23      fvdl 		nfsm_srvpostop_attr(1, (struct vattr *)0);
    130       1.23      fvdl 		return (0);
    131       1.23      fvdl 	}
    132       1.32   mycroft 	inmode = fxdr_unsigned(u_int32_t, *tl);
    133       1.32   mycroft 	outmode = 0;
    134       1.32   mycroft 	if ((inmode & NFSV3ACCESS_READ) &&
    135       1.99  christos 	    nfsrv_access(vp, VREAD, cred, rdonly, lwp, 0) == 0)
    136       1.32   mycroft 		outmode |= NFSV3ACCESS_READ;
    137       1.32   mycroft 	if (vp->v_type != VDIR) {
    138       1.32   mycroft 		testmode = inmode & (NFSV3ACCESS_MODIFY | NFSV3ACCESS_EXTEND);
    139       1.32   mycroft 		if (testmode &&
    140       1.99  christos 		    nfsrv_access(vp, VWRITE, cred, rdonly, lwp, 0) == 0)
    141       1.32   mycroft 			outmode |= testmode;
    142       1.32   mycroft 		if ((inmode & NFSV3ACCESS_EXECUTE) &&
    143       1.99  christos 		    nfsrv_access(vp, VEXEC, cred, rdonly, lwp, 0) == 0)
    144       1.32   mycroft 			outmode |= NFSV3ACCESS_EXECUTE;
    145       1.32   mycroft 	} else {
    146       1.32   mycroft 		testmode = inmode & (NFSV3ACCESS_MODIFY | NFSV3ACCESS_EXTEND |
    147       1.32   mycroft 		    NFSV3ACCESS_DELETE);
    148       1.32   mycroft 		if (testmode &&
    149       1.99  christos 		    nfsrv_access(vp, VWRITE, cred, rdonly, lwp, 0) == 0)
    150       1.32   mycroft 			outmode |= testmode;
    151       1.32   mycroft 		if ((inmode & NFSV3ACCESS_LOOKUP) &&
    152       1.99  christos 		    nfsrv_access(vp, VEXEC, cred, rdonly, lwp, 0) == 0)
    153       1.32   mycroft 			outmode |= NFSV3ACCESS_LOOKUP;
    154       1.32   mycroft 	}
    155       1.99  christos 	getret = VOP_GETATTR(vp, &va, cred, lwp);
    156       1.15   mycroft 	vput(vp);
    157       1.23      fvdl 	nfsm_reply(NFSX_POSTOPATTR(1) + NFSX_UNSIGNED);
    158       1.23      fvdl 	nfsm_srvpostop_attr(getret, &va);
    159       1.23      fvdl 	nfsm_build(tl, u_int32_t *, NFSX_UNSIGNED);
    160       1.32   mycroft 	*tl = txdr_unsigned(outmode);
    161       1.15   mycroft 	nfsm_srvdone;
    162       1.15   mycroft }
    163       1.15   mycroft 
    164        1.1       cgd /*
    165        1.1       cgd  * nfs getattr service
    166        1.1       cgd  */
    167       1.22  christos int
    168       1.99  christos nfsrv_getattr(nfsd, slp, lwp, mrq)
    169       1.23      fvdl 	struct nfsrv_descript *nfsd;
    170       1.23      fvdl 	struct nfssvc_sock *slp;
    171       1.99  christos 	struct lwp *lwp;
    172       1.23      fvdl 	struct mbuf **mrq;
    173        1.1       cgd {
    174       1.23      fvdl 	struct mbuf *mrep = nfsd->nd_mrep, *md = nfsd->nd_md;
    175       1.23      fvdl 	struct mbuf *nam = nfsd->nd_nam;
    176       1.23      fvdl 	caddr_t dpos = nfsd->nd_dpos;
    177  1.101.2.2      yamt 	kauth_cred_t cred = nfsd->nd_cr;
    178       1.54  augustss 	struct nfs_fattr *fp;
    179        1.1       cgd 	struct vattr va;
    180        1.1       cgd 	struct vnode *vp;
    181       1.23      fvdl 	nfsfh_t nfh;
    182        1.1       cgd 	fhandle_t *fhp;
    183       1.54  augustss 	u_int32_t *tl;
    184       1.54  augustss 	int32_t t1;
    185        1.1       cgd 	caddr_t bpos;
    186  1.101.2.2      yamt 	int error = 0, rdonly, cache = 0;
    187        1.1       cgd 	char *cp2;
    188       1.67      matt 	struct mbuf *mb, *mreq;
    189       1.15   mycroft 	u_quad_t frev;
    190        1.1       cgd 
    191        1.1       cgd 	fhp = &nfh.fh_generic;
    192        1.1       cgd 	nfsm_srvmtofh(fhp);
    193       1.23      fvdl 	error = nfsrv_fhtovp(fhp, 1, &vp, cred, slp, nam, &rdonly,
    194       1.78   thorpej 	    (nfsd->nd_flag & ND_KERBAUTH), FALSE);
    195       1.23      fvdl 	if (error) {
    196        1.1       cgd 		nfsm_reply(0);
    197       1.23      fvdl 		return (0);
    198       1.23      fvdl 	}
    199       1.23      fvdl 	nqsrv_getl(vp, ND_READ);
    200       1.99  christos 	error = VOP_GETATTR(vp, &va, cred, lwp);
    201        1.1       cgd 	vput(vp);
    202       1.23      fvdl 	nfsm_reply(NFSX_FATTR(nfsd->nd_flag & ND_NFSV3));
    203       1.23      fvdl 	if (error)
    204       1.23      fvdl 		return (0);
    205       1.23      fvdl 	nfsm_build(fp, struct nfs_fattr *, NFSX_FATTR(nfsd->nd_flag & ND_NFSV3));
    206       1.23      fvdl 	nfsm_srvfillattr(&va, fp);
    207        1.1       cgd 	nfsm_srvdone;
    208        1.1       cgd }
    209        1.1       cgd 
    210        1.1       cgd /*
    211        1.1       cgd  * nfs setattr service
    212        1.1       cgd  */
    213       1.22  christos int
    214       1.99  christos nfsrv_setattr(nfsd, slp, lwp, mrq)
    215       1.23      fvdl 	struct nfsrv_descript *nfsd;
    216       1.23      fvdl 	struct nfssvc_sock *slp;
    217       1.99  christos 	struct lwp *lwp;
    218       1.23      fvdl 	struct mbuf **mrq;
    219        1.1       cgd {
    220       1.23      fvdl 	struct mbuf *mrep = nfsd->nd_mrep, *md = nfsd->nd_md;
    221       1.23      fvdl 	struct mbuf *nam = nfsd->nd_nam;
    222       1.23      fvdl 	caddr_t dpos = nfsd->nd_dpos;
    223  1.101.2.2      yamt 	kauth_cred_t cred = nfsd->nd_cr;
    224       1.23      fvdl 	struct vattr va, preat;
    225       1.54  augustss 	struct nfsv2_sattr *sp;
    226       1.54  augustss 	struct nfs_fattr *fp;
    227        1.1       cgd 	struct vnode *vp;
    228       1.23      fvdl 	nfsfh_t nfh;
    229        1.1       cgd 	fhandle_t *fhp;
    230       1.54  augustss 	u_int32_t *tl;
    231       1.54  augustss 	int32_t t1;
    232        1.1       cgd 	caddr_t bpos;
    233  1.101.2.2      yamt 	int error = 0, rdonly, cache = 0, preat_ret = 1, postat_ret = 1;
    234       1.23      fvdl 	int v3 = (nfsd->nd_flag & ND_NFSV3), gcheck = 0;
    235        1.1       cgd 	char *cp2;
    236       1.67      matt 	struct mbuf *mb, *mreq;
    237       1.23      fvdl 	u_quad_t frev;
    238       1.23      fvdl 	struct timespec guard;
    239       1.82   hannken 	struct mount *mp = NULL;
    240        1.1       cgd 
    241  1.101.2.2      yamt 	memset(&guard, 0, sizeof guard);	/* XXX gcc */
    242  1.101.2.2      yamt 
    243        1.1       cgd 	fhp = &nfh.fh_generic;
    244        1.1       cgd 	nfsm_srvmtofh(fhp);
    245       1.82   hannken 	if ((mp = vfs_getvfs(&fhp->fh_fsid)) == NULL)
    246       1.82   hannken 		return (ESTALE);
    247       1.82   hannken 	vn_start_write(NULL, &mp, V_WAIT);
    248       1.18   mycroft 	VATTR_NULL(&va);
    249       1.23      fvdl 	if (v3) {
    250       1.23      fvdl 		nfsm_srvsattr(&va);
    251       1.23      fvdl 		nfsm_dissect(tl, u_int32_t *, NFSX_UNSIGNED);
    252       1.23      fvdl 		gcheck = fxdr_unsigned(int, *tl);
    253       1.23      fvdl 		if (gcheck) {
    254       1.23      fvdl 			nfsm_dissect(tl, u_int32_t *, 2 * NFSX_UNSIGNED);
    255       1.23      fvdl 			fxdr_nfsv3time(tl, &guard);
    256       1.23      fvdl 		}
    257       1.23      fvdl 	} else {
    258       1.23      fvdl 		nfsm_dissect(sp, struct nfsv2_sattr *, NFSX_V2SATTR);
    259       1.23      fvdl 		/*
    260       1.23      fvdl 		 * Nah nah nah nah na nah
    261       1.23      fvdl 		 * There is a bug in the Sun client that puts 0xffff in the mode
    262       1.23      fvdl 		 * field of sattr when it should put in 0xffffffff. The u_short
    263       1.23      fvdl 		 * doesn't sign extend.
    264       1.23      fvdl 		 * --> check the low order 2 bytes for 0xffff
    265       1.23      fvdl 		 */
    266       1.23      fvdl 		if ((fxdr_unsigned(int, sp->sa_mode) & 0xffff) != 0xffff)
    267       1.23      fvdl 			va.va_mode = nfstov_mode(sp->sa_mode);
    268       1.23      fvdl 		if (sp->sa_uid != nfs_xdrneg1)
    269       1.23      fvdl 			va.va_uid = fxdr_unsigned(uid_t, sp->sa_uid);
    270       1.23      fvdl 		if (sp->sa_gid != nfs_xdrneg1)
    271       1.23      fvdl 			va.va_gid = fxdr_unsigned(gid_t, sp->sa_gid);
    272       1.23      fvdl 		if (sp->sa_size != nfs_xdrneg1)
    273       1.23      fvdl 			va.va_size = fxdr_unsigned(u_quad_t, sp->sa_size);
    274       1.23      fvdl 		if (sp->sa_atime.nfsv2_sec != nfs_xdrneg1) {
    275       1.15   mycroft #ifdef notyet
    276       1.23      fvdl 			fxdr_nfsv2time(&sp->sa_atime, &va.va_atime);
    277       1.15   mycroft #else
    278       1.20       jtc 			va.va_atime.tv_sec =
    279       1.23      fvdl 				fxdr_unsigned(u_int32_t,sp->sa_atime.nfsv2_sec);
    280       1.20       jtc 			va.va_atime.tv_nsec = 0;
    281       1.15   mycroft #endif
    282       1.15   mycroft 		}
    283       1.23      fvdl 		if (sp->sa_mtime.nfsv2_sec != nfs_xdrneg1)
    284       1.23      fvdl 			fxdr_nfsv2time(&sp->sa_mtime, &va.va_mtime);
    285       1.23      fvdl 
    286       1.23      fvdl 	}
    287       1.23      fvdl 
    288       1.23      fvdl 	/*
    289       1.23      fvdl 	 * Now that we have all the fields, lets do it.
    290       1.23      fvdl 	 */
    291       1.23      fvdl 	error = nfsrv_fhtovp(fhp, 1, &vp, cred, slp, nam, &rdonly,
    292       1.78   thorpej 	    (nfsd->nd_flag & ND_KERBAUTH), FALSE);
    293       1.23      fvdl 	if (error) {
    294       1.23      fvdl 		nfsm_reply(2 * NFSX_UNSIGNED);
    295       1.23      fvdl 		nfsm_srvwcc_data(preat_ret, &preat, postat_ret, &va);
    296       1.82   hannken 		vn_finished_write(mp, 0);
    297       1.23      fvdl 		return (0);
    298       1.23      fvdl 	}
    299       1.23      fvdl 	nqsrv_getl(vp, ND_WRITE);
    300       1.23      fvdl 	if (v3) {
    301       1.99  christos 		error = preat_ret = VOP_GETATTR(vp, &preat, cred, lwp);
    302       1.23      fvdl 		if (!error && gcheck &&
    303       1.23      fvdl 			(preat.va_ctime.tv_sec != guard.tv_sec ||
    304       1.23      fvdl 			 preat.va_ctime.tv_nsec != guard.tv_nsec))
    305       1.23      fvdl 			error = NFSERR_NOT_SYNC;
    306       1.23      fvdl 		if (error) {
    307       1.23      fvdl 			vput(vp);
    308       1.23      fvdl 			nfsm_reply(NFSX_WCCDATA(v3));
    309       1.23      fvdl 			nfsm_srvwcc_data(preat_ret, &preat, postat_ret, &va);
    310       1.82   hannken 			vn_finished_write(mp, 0);
    311       1.23      fvdl 			return (0);
    312       1.23      fvdl 		}
    313       1.15   mycroft 	}
    314       1.15   mycroft 
    315        1.1       cgd 	/*
    316       1.15   mycroft 	 * If the size is being changed write acces is required, otherwise
    317       1.15   mycroft 	 * just check for a read only file system.
    318        1.1       cgd 	 */
    319       1.18   mycroft 	if (va.va_size == ((u_quad_t)((quad_t) -1))) {
    320       1.15   mycroft 		if (rdonly || (vp->v_mount->mnt_flag & MNT_RDONLY)) {
    321       1.15   mycroft 			error = EROFS;
    322       1.15   mycroft 			goto out;
    323       1.15   mycroft 		}
    324       1.15   mycroft 	} else {
    325       1.15   mycroft 		if (vp->v_type == VDIR) {
    326       1.15   mycroft 			error = EISDIR;
    327       1.15   mycroft 			goto out;
    328       1.22  christos 		} else if ((error = nfsrv_access(vp, VWRITE, cred, rdonly,
    329       1.99  christos 			lwp, 0)) != 0)
    330       1.15   mycroft 			goto out;
    331        1.1       cgd 	}
    332       1.99  christos 	error = VOP_SETATTR(vp, &va, cred, lwp);
    333       1.99  christos 	postat_ret = VOP_GETATTR(vp, &va, cred, lwp);
    334       1.23      fvdl 	if (!error)
    335       1.23      fvdl 		error = postat_ret;
    336        1.1       cgd out:
    337        1.1       cgd 	vput(vp);
    338       1.82   hannken 	vn_finished_write(mp, 0);
    339       1.23      fvdl 	nfsm_reply(NFSX_WCCORFATTR(v3));
    340       1.23      fvdl 	if (v3) {
    341       1.23      fvdl 		nfsm_srvwcc_data(preat_ret, &preat, postat_ret, &va);
    342       1.23      fvdl 		return (0);
    343       1.23      fvdl 	} else {
    344       1.23      fvdl 		nfsm_build(fp, struct nfs_fattr *, NFSX_V2FATTR);
    345       1.23      fvdl 		nfsm_srvfillattr(&va, fp);
    346       1.15   mycroft 	}
    347        1.1       cgd 	nfsm_srvdone;
    348        1.1       cgd }
    349        1.1       cgd 
    350        1.1       cgd /*
    351        1.1       cgd  * nfs lookup rpc
    352        1.1       cgd  */
    353       1.22  christos int
    354       1.99  christos nfsrv_lookup(nfsd, slp, lwp, mrq)
    355       1.23      fvdl 	struct nfsrv_descript *nfsd;
    356       1.23      fvdl 	struct nfssvc_sock *slp;
    357       1.99  christos 	struct lwp *lwp;
    358       1.23      fvdl 	struct mbuf **mrq;
    359        1.1       cgd {
    360       1.23      fvdl 	struct mbuf *mrep = nfsd->nd_mrep, *md = nfsd->nd_md;
    361       1.23      fvdl 	struct mbuf *nam = nfsd->nd_nam;
    362       1.23      fvdl 	caddr_t dpos = nfsd->nd_dpos;
    363  1.101.2.2      yamt 	kauth_cred_t cred = nfsd->nd_cr;
    364       1.54  augustss 	struct nfs_fattr *fp;
    365       1.35      fvdl 	struct nameidata nd, ind, *ndp = &nd;
    366       1.23      fvdl 	struct vnode *vp, *dirp;
    367       1.23      fvdl 	nfsfh_t nfh;
    368        1.1       cgd 	fhandle_t *fhp;
    369       1.54  augustss 	caddr_t cp;
    370       1.54  augustss 	u_int32_t *tl;
    371       1.54  augustss 	int32_t t1;
    372        1.1       cgd 	caddr_t bpos;
    373  1.101.2.2      yamt 	int error = 0, cache = 0, dirattr_ret = 1;
    374       1.68      yamt 	uint32_t len;
    375       1.35      fvdl 	int v3 = (nfsd->nd_flag & ND_NFSV3), pubflag;
    376        1.1       cgd 	char *cp2;
    377       1.67      matt 	struct mbuf *mb, *mreq;
    378       1.23      fvdl 	struct vattr va, dirattr;
    379       1.23      fvdl 	u_quad_t frev;
    380        1.1       cgd 
    381        1.1       cgd 	fhp = &nfh.fh_generic;
    382        1.1       cgd 	nfsm_srvmtofh(fhp);
    383       1.23      fvdl 	nfsm_srvnamesiz(len);
    384       1.35      fvdl 
    385       1.35      fvdl 	pubflag = nfs_ispublicfh(fhp);
    386       1.35      fvdl 
    387       1.15   mycroft 	nd.ni_cnd.cn_cred = cred;
    388       1.15   mycroft 	nd.ni_cnd.cn_nameiop = LOOKUP;
    389       1.15   mycroft 	nd.ni_cnd.cn_flags = LOCKLEAF | SAVESTART;
    390       1.23      fvdl 	error = nfs_namei(&nd, fhp, len, slp, nam, &md, &dpos,
    391       1.99  christos 		&dirp, lwp, (nfsd->nd_flag & ND_KERBAUTH), pubflag);
    392       1.35      fvdl 
    393       1.35      fvdl 	if (!error && pubflag) {
    394       1.35      fvdl 		if (nd.ni_vp->v_type == VDIR && nfs_pub.np_index != NULL) {
    395       1.35      fvdl 			/*
    396       1.35      fvdl 			 * Setup call to lookup() to see if we can find
    397       1.35      fvdl 			 * the index file. Arguably, this doesn't belong
    398       1.35      fvdl 			 * in a kernel.. Ugh.
    399       1.35      fvdl 			 */
    400       1.35      fvdl 			ind = nd;
    401       1.42      fvdl 			VOP_UNLOCK(nd.ni_vp, 0);
    402       1.35      fvdl 			ind.ni_pathlen = strlen(nfs_pub.np_index);
    403       1.35      fvdl 			ind.ni_cnd.cn_nameptr = ind.ni_cnd.cn_pnbuf =
    404       1.35      fvdl 			    nfs_pub.np_index;
    405       1.35      fvdl 			ind.ni_startdir = nd.ni_vp;
    406       1.35      fvdl 			VREF(ind.ni_startdir);
    407       1.35      fvdl 			error = lookup(&ind);
    408       1.35      fvdl 			if (!error) {
    409       1.35      fvdl 				/*
    410       1.35      fvdl 				 * Found an index file. Get rid of
    411       1.35      fvdl 				 * the old references.
    412       1.35      fvdl 				 */
    413       1.94     perry 				if (dirp)
    414       1.35      fvdl 					vrele(dirp);
    415       1.35      fvdl 				dirp = nd.ni_vp;
    416       1.35      fvdl 				vrele(nd.ni_startdir);
    417       1.35      fvdl 				ndp = &ind;
    418       1.35      fvdl 			} else
    419       1.35      fvdl 				error = 0;
    420       1.35      fvdl 		}
    421       1.35      fvdl 		/*
    422       1.35      fvdl 		 * If the public filehandle was used, check that this lookup
    423       1.35      fvdl 		 * didn't result in a filehandle outside the publicly exported
    424       1.35      fvdl 		 * filesystem.
    425       1.35      fvdl 		 */
    426       1.35      fvdl 
    427       1.35      fvdl 		if (!error && ndp->ni_vp->v_mount != nfs_pub.np_mount) {
    428       1.35      fvdl 			vput(nd.ni_vp);
    429       1.35      fvdl 			error = EPERM;
    430       1.35      fvdl 		}
    431       1.35      fvdl 	}
    432       1.35      fvdl 
    433       1.23      fvdl 	if (dirp) {
    434       1.23      fvdl 		if (v3)
    435       1.99  christos 			dirattr_ret = VOP_GETATTR(dirp, &dirattr, cred, lwp);
    436       1.23      fvdl 		vrele(dirp);
    437       1.23      fvdl 	}
    438       1.35      fvdl 
    439       1.23      fvdl 	if (error) {
    440       1.23      fvdl 		nfsm_reply(NFSX_POSTOPATTR(v3));
    441       1.23      fvdl 		nfsm_srvpostop_attr(dirattr_ret, &dirattr);
    442       1.23      fvdl 		return (0);
    443       1.23      fvdl 	}
    444       1.35      fvdl 
    445       1.35      fvdl 	nqsrv_getl(ndp->ni_startdir, ND_READ);
    446       1.35      fvdl 	vrele(ndp->ni_startdir);
    447       1.57   thorpej 	PNBUF_PUT(nd.ni_cnd.cn_pnbuf);
    448       1.35      fvdl 	vp = ndp->ni_vp;
    449       1.44     perry 	memset((caddr_t)fhp, 0, sizeof(nfh));
    450       1.88  christos 	fhp->fh_fsid = vp->v_mount->mnt_stat.f_fsidx;
    451       1.23      fvdl 	error = VFS_VPTOFH(vp, &fhp->fh_fid);
    452       1.23      fvdl 	if (!error)
    453       1.99  christos 		error = VOP_GETATTR(vp, &va, cred, lwp);
    454       1.23      fvdl 	vput(vp);
    455  1.101.2.1      yamt 	KASSERT(fhp->fh_fid.fid_len <= _VFS_MAXFIDSZ);
    456       1.23      fvdl 	nfsm_reply(NFSX_SRVFH(v3) + NFSX_POSTOPORFATTR(v3) + NFSX_POSTOPATTR(v3));
    457       1.23      fvdl 	if (error) {
    458       1.23      fvdl 		nfsm_srvpostop_attr(dirattr_ret, &dirattr);
    459       1.23      fvdl 		return (0);
    460        1.1       cgd 	}
    461       1.23      fvdl 	nfsm_srvfhtom(fhp, v3);
    462       1.23      fvdl 	if (v3) {
    463       1.23      fvdl 		nfsm_srvpostop_attr(0, &va);
    464       1.23      fvdl 		nfsm_srvpostop_attr(dirattr_ret, &dirattr);
    465       1.23      fvdl 	} else {
    466       1.23      fvdl 		nfsm_build(fp, struct nfs_fattr *, NFSX_V2FATTR);
    467       1.23      fvdl 		nfsm_srvfillattr(&va, fp);
    468       1.15   mycroft 	}
    469        1.1       cgd 	nfsm_srvdone;
    470        1.1       cgd }
    471        1.1       cgd 
    472        1.1       cgd /*
    473        1.1       cgd  * nfs readlink service
    474        1.1       cgd  */
    475       1.22  christos int
    476       1.99  christos nfsrv_readlink(nfsd, slp, lwp, mrq)
    477       1.23      fvdl 	struct nfsrv_descript *nfsd;
    478       1.23      fvdl 	struct nfssvc_sock *slp;
    479       1.99  christos 	struct lwp *lwp;
    480       1.23      fvdl 	struct mbuf **mrq;
    481        1.1       cgd {
    482       1.23      fvdl 	struct mbuf *mrep = nfsd->nd_mrep, *md = nfsd->nd_md;
    483       1.23      fvdl 	struct mbuf *nam = nfsd->nd_nam;
    484       1.23      fvdl 	caddr_t dpos = nfsd->nd_dpos;
    485  1.101.2.2      yamt 	kauth_cred_t cred = nfsd->nd_cr;
    486        1.1       cgd 	struct iovec iv[(NFS_MAXPATHLEN+MLEN-1)/MLEN];
    487       1.54  augustss 	struct iovec *ivp = iv;
    488       1.54  augustss 	struct mbuf *mp;
    489       1.54  augustss 	u_int32_t *tl;
    490       1.54  augustss 	int32_t t1;
    491        1.1       cgd 	caddr_t bpos;
    492  1.101.2.2      yamt 	int error = 0, rdonly, cache = 0, i, padlen, getret;
    493       1.76      yamt 	uint32_t len;
    494       1.23      fvdl 	int v3 = (nfsd->nd_flag & ND_NFSV3);
    495        1.1       cgd 	char *cp2;
    496       1.67      matt 	struct mbuf *mb, *mp2 = NULL, *mp3 = NULL, *mreq;
    497        1.1       cgd 	struct vnode *vp;
    498       1.23      fvdl 	struct vattr attr;
    499       1.23      fvdl 	nfsfh_t nfh;
    500        1.1       cgd 	fhandle_t *fhp;
    501        1.1       cgd 	struct uio io, *uiop = &io;
    502       1.15   mycroft 	u_quad_t frev;
    503        1.1       cgd 
    504        1.1       cgd 	fhp = &nfh.fh_generic;
    505        1.1       cgd 	nfsm_srvmtofh(fhp);
    506        1.1       cgd 	len = 0;
    507        1.1       cgd 	i = 0;
    508        1.1       cgd 	while (len < NFS_MAXPATHLEN) {
    509       1.67      matt 		mp = m_get(M_WAIT, MT_DATA);
    510       1.67      matt 		MCLAIM(mp, &nfs_mowner);
    511       1.67      matt 		m_clget(mp, M_WAIT);
    512        1.1       cgd 		mp->m_len = NFSMSIZ(mp);
    513        1.1       cgd 		if (len == 0)
    514        1.1       cgd 			mp3 = mp2 = mp;
    515        1.1       cgd 		else {
    516        1.1       cgd 			mp2->m_next = mp;
    517        1.1       cgd 			mp2 = mp;
    518        1.1       cgd 		}
    519        1.1       cgd 		if ((len+mp->m_len) > NFS_MAXPATHLEN) {
    520        1.1       cgd 			mp->m_len = NFS_MAXPATHLEN-len;
    521        1.1       cgd 			len = NFS_MAXPATHLEN;
    522        1.1       cgd 		} else
    523        1.1       cgd 			len += mp->m_len;
    524        1.1       cgd 		ivp->iov_base = mtod(mp, caddr_t);
    525        1.1       cgd 		ivp->iov_len = mp->m_len;
    526        1.1       cgd 		i++;
    527        1.1       cgd 		ivp++;
    528        1.1       cgd 	}
    529        1.1       cgd 	uiop->uio_iov = iv;
    530        1.1       cgd 	uiop->uio_iovcnt = i;
    531        1.1       cgd 	uiop->uio_offset = 0;
    532        1.1       cgd 	uiop->uio_resid = len;
    533        1.1       cgd 	uiop->uio_rw = UIO_READ;
    534      1.101      yamt 	UIO_SETUP_SYSSPACE(uiop);
    535       1.23      fvdl 	error = nfsrv_fhtovp(fhp, 1, &vp, cred, slp, nam,
    536       1.78   thorpej 		 &rdonly, (nfsd->nd_flag & ND_KERBAUTH), FALSE);
    537       1.22  christos 	if (error) {
    538        1.1       cgd 		m_freem(mp3);
    539       1.23      fvdl 		nfsm_reply(2 * NFSX_UNSIGNED);
    540       1.23      fvdl 		nfsm_srvpostop_attr(1, (struct vattr *)0);
    541       1.23      fvdl 		return (0);
    542        1.1       cgd 	}
    543        1.1       cgd 	if (vp->v_type != VLNK) {
    544       1.23      fvdl 		if (v3)
    545       1.23      fvdl 			error = EINVAL;
    546       1.23      fvdl 		else
    547       1.23      fvdl 			error = ENXIO;
    548        1.1       cgd 		goto out;
    549        1.1       cgd 	}
    550       1.23      fvdl 	nqsrv_getl(vp, ND_READ);
    551        1.1       cgd 	error = VOP_READLINK(vp, uiop, cred);
    552        1.1       cgd out:
    553       1.99  christos 	getret = VOP_GETATTR(vp, &attr, cred, lwp);
    554        1.1       cgd 	vput(vp);
    555        1.1       cgd 	if (error)
    556        1.1       cgd 		m_freem(mp3);
    557       1.23      fvdl 	nfsm_reply(NFSX_POSTOPATTR(v3) + NFSX_UNSIGNED);
    558       1.23      fvdl 	if (v3) {
    559       1.23      fvdl 		nfsm_srvpostop_attr(getret, &attr);
    560       1.23      fvdl 		if (error)
    561       1.23      fvdl 			return (0);
    562       1.23      fvdl 	}
    563       1.76      yamt 	len -= uiop->uio_resid;
    564       1.76      yamt 	padlen = nfsm_padlen(len);
    565       1.76      yamt 	if (uiop->uio_resid || padlen)
    566       1.76      yamt 		nfs_zeropad(mp3, uiop->uio_resid, padlen);
    567       1.19       cgd 	nfsm_build(tl, u_int32_t *, NFSX_UNSIGNED);
    568        1.1       cgd 	*tl = txdr_unsigned(len);
    569        1.1       cgd 	mb->m_next = mp3;
    570        1.1       cgd 	nfsm_srvdone;
    571        1.1       cgd }
    572        1.1       cgd 
    573        1.1       cgd /*
    574        1.1       cgd  * nfs read service
    575        1.1       cgd  */
    576       1.22  christos int
    577       1.99  christos nfsrv_read(nfsd, slp, lwp, mrq)
    578       1.23      fvdl 	struct nfsrv_descript *nfsd;
    579       1.23      fvdl 	struct nfssvc_sock *slp;
    580       1.99  christos 	struct lwp *lwp;
    581       1.23      fvdl 	struct mbuf **mrq;
    582        1.1       cgd {
    583       1.23      fvdl 	struct mbuf *mrep = nfsd->nd_mrep, *md = nfsd->nd_md;
    584       1.23      fvdl 	struct mbuf *nam = nfsd->nd_nam;
    585       1.23      fvdl 	caddr_t dpos = nfsd->nd_dpos;
    586  1.101.2.2      yamt 	kauth_cred_t cred = nfsd->nd_cr;
    587       1.54  augustss 	struct mbuf *m;
    588       1.54  augustss 	struct nfs_fattr *fp;
    589       1.54  augustss 	u_int32_t *tl;
    590       1.54  augustss 	int32_t t1;
    591       1.54  augustss 	int i;
    592        1.1       cgd 	caddr_t bpos;
    593  1.101.2.2      yamt 	int error = 0, rdonly, cache = 0, getret;
    594       1.68      yamt 	int v3 = (nfsd->nd_flag & ND_NFSV3);
    595       1.76      yamt 	uint32_t reqlen, len, cnt, left;
    596       1.76      yamt 	int padlen;
    597        1.1       cgd 	char *cp2;
    598       1.67      matt 	struct mbuf *mb, *mreq;
    599        1.1       cgd 	struct vnode *vp;
    600       1.23      fvdl 	nfsfh_t nfh;
    601        1.1       cgd 	fhandle_t *fhp;
    602        1.1       cgd 	struct uio io, *uiop = &io;
    603       1.18   mycroft 	struct vattr va;
    604        1.1       cgd 	off_t off;
    605       1.15   mycroft 	u_quad_t frev;
    606        1.1       cgd 
    607        1.1       cgd 	fhp = &nfh.fh_generic;
    608        1.1       cgd 	nfsm_srvmtofh(fhp);
    609       1.23      fvdl 	if (v3) {
    610       1.23      fvdl 		nfsm_dissect(tl, u_int32_t *, 2 * NFSX_UNSIGNED);
    611       1.48      fair 		off = fxdr_hyper(tl);
    612       1.23      fvdl 	} else {
    613       1.19       cgd 		nfsm_dissect(tl, u_int32_t *, NFSX_UNSIGNED);
    614       1.19       cgd 		off = (off_t)fxdr_unsigned(u_int32_t, *tl);
    615       1.15   mycroft 	}
    616       1.71      yamt 	nfsm_dissect(tl, uint32_t *, NFSX_UNSIGNED);
    617       1.71      yamt 	reqlen = fxdr_unsigned(uint32_t, *tl);
    618       1.71      yamt 	reqlen = MIN(reqlen, NFS_SRVMAXDATA(nfsd));
    619       1.23      fvdl 	error = nfsrv_fhtovp(fhp, 1, &vp, cred, slp, nam,
    620       1.78   thorpej 		 &rdonly, (nfsd->nd_flag & ND_KERBAUTH), FALSE);
    621       1.23      fvdl 	if (error) {
    622       1.23      fvdl 		nfsm_reply(2 * NFSX_UNSIGNED);
    623       1.23      fvdl 		nfsm_srvpostop_attr(1, (struct vattr *)0);
    624       1.23      fvdl 		return (0);
    625       1.23      fvdl 	}
    626       1.15   mycroft 	if (vp->v_type != VREG) {
    627       1.23      fvdl 		if (v3)
    628       1.23      fvdl 			error = EINVAL;
    629       1.23      fvdl 		else
    630       1.23      fvdl 			error = (vp->v_type == VDIR) ? EISDIR : EACCES;
    631        1.1       cgd 	}
    632       1.23      fvdl 	if (!error) {
    633       1.23      fvdl 	    nqsrv_getl(vp, ND_READ);
    634       1.99  christos 	    if ((error = nfsrv_access(vp, VREAD, cred, rdonly, lwp, 1)) != 0)
    635       1.99  christos 		error = nfsrv_access(vp, VEXEC, cred, rdonly, lwp, 1);
    636       1.23      fvdl 	}
    637       1.99  christos 	getret = VOP_GETATTR(vp, &va, cred, lwp);
    638       1.23      fvdl 	if (!error)
    639       1.23      fvdl 		error = getret;
    640       1.22  christos 	if (error) {
    641        1.1       cgd 		vput(vp);
    642       1.23      fvdl 		nfsm_reply(NFSX_POSTOPATTR(v3));
    643       1.23      fvdl 		nfsm_srvpostop_attr(getret, &va);
    644       1.23      fvdl 		return (0);
    645        1.1       cgd 	}
    646       1.18   mycroft 	if (off >= va.va_size)
    647       1.15   mycroft 		cnt = 0;
    648       1.23      fvdl 	else if ((off + reqlen) > va.va_size)
    649       1.76      yamt 		cnt = va.va_size - off;
    650       1.23      fvdl 	else
    651       1.23      fvdl 		cnt = reqlen;
    652       1.23      fvdl 	nfsm_reply(NFSX_POSTOPORFATTR(v3) + 3 * NFSX_UNSIGNED+nfsm_rndup(cnt));
    653       1.23      fvdl 	if (v3) {
    654       1.23      fvdl 		nfsm_build(tl, u_int32_t *, NFSX_V3FATTR + 4 * NFSX_UNSIGNED);
    655       1.23      fvdl 		*tl++ = nfs_true;
    656       1.23      fvdl 		fp = (struct nfs_fattr *)tl;
    657       1.23      fvdl 		tl += (NFSX_V3FATTR / sizeof (u_int32_t));
    658       1.23      fvdl 	} else {
    659       1.23      fvdl 		nfsm_build(tl, u_int32_t *, NFSX_V2FATTR + NFSX_UNSIGNED);
    660       1.23      fvdl 		fp = (struct nfs_fattr *)tl;
    661       1.23      fvdl 		tl += (NFSX_V2FATTR / sizeof (u_int32_t));
    662       1.23      fvdl 	}
    663       1.15   mycroft 	len = left = cnt;
    664       1.73      yamt 	if (cnt > 0) {
    665       1.72      yamt 		if (nfsd_use_loan) {
    666       1.72      yamt 			struct vm_page **pgpp;
    667       1.72      yamt 			voff_t pgoff = trunc_page(off);
    668       1.87      yamt 			int npages;
    669       1.87      yamt 			vaddr_t lva;
    670       1.72      yamt 
    671       1.87      yamt 			npages = (round_page(off + cnt) - pgoff) >> PAGE_SHIFT;
    672       1.87      yamt 			KASSERT(npages <= M_EXT_MAXPAGES); /* XXX */
    673       1.72      yamt 
    674       1.87      yamt 			/* allocate kva for mbuf data */
    675       1.87      yamt 			lva = sokvaalloc(npages << PAGE_SHIFT, slp->ns_so);
    676       1.72      yamt 			if (lva == 0) {
    677       1.72      yamt 				/* fall back to VOP_READ */
    678       1.72      yamt 				goto loan_fail;
    679       1.72      yamt 			}
    680       1.72      yamt 
    681       1.87      yamt 			/* allocate mbuf */
    682       1.72      yamt 			m = m_get(M_WAIT, MT_DATA);
    683       1.87      yamt 			MCLAIM(m, &nfs_mowner);
    684       1.72      yamt 			pgpp = m->m_ext.ext_pgs;
    685       1.75      yamt 
    686       1.87      yamt 			/* loan pages */
    687       1.87      yamt 			error = uvm_loanuobjpages(&vp->v_uobj, pgoff, npages,
    688       1.87      yamt 			    pgpp);
    689       1.87      yamt 			if (error) {
    690       1.87      yamt 				sokvafree(lva, npages << PAGE_SHIFT);
    691       1.87      yamt 				m_free(m);
    692       1.91      yamt 				if (error == EBUSY)
    693       1.91      yamt 					goto loan_fail;
    694       1.87      yamt 				goto read_error;
    695       1.15   mycroft 			}
    696       1.72      yamt 
    697       1.87      yamt 			/* associate kva to mbuf */
    698       1.87      yamt 			MEXTADD(m, (void *)(lva + ((vaddr_t)off & PAGE_MASK)),
    699       1.87      yamt 			    cnt, M_MBUF, soloanfree, slp->ns_so);
    700       1.72      yamt 			m->m_flags |= M_EXT_PAGES | M_EXT_ROMAP;
    701       1.72      yamt 			m->m_len = cnt;
    702       1.72      yamt 
    703       1.87      yamt 			/* map pages */
    704       1.87      yamt 			for (i = 0; i < npages; i++) {
    705       1.87      yamt 				pmap_kenter_pa(lva, VM_PAGE_TO_PHYS(pgpp[i]),
    706       1.87      yamt 				    VM_PROT_READ);
    707       1.87      yamt 				lva += PAGE_SIZE;
    708       1.87      yamt 			}
    709       1.87      yamt 
    710       1.72      yamt 			pmap_update(pmap_kernel());
    711       1.87      yamt 
    712       1.72      yamt 			mb->m_next = m;
    713       1.72      yamt 			mb = m;
    714       1.72      yamt 			error = 0;
    715       1.72      yamt 			uiop->uio_resid = 0;
    716       1.72      yamt 		} else {
    717       1.72      yamt 			struct iovec *iv;
    718       1.72      yamt 			struct iovec *iv2;
    719       1.72      yamt 			struct mbuf *m2;
    720       1.72      yamt 			int siz;
    721       1.72      yamt loan_fail:
    722       1.72      yamt 			/*
    723       1.72      yamt 			 * Generate the mbuf list with the uio_iov ref. to it.
    724       1.72      yamt 			 */
    725       1.72      yamt 			i = 0;
    726       1.72      yamt 			m = m2 = mb;
    727       1.72      yamt 			while (left > 0) {
    728       1.72      yamt 				siz = min(M_TRAILINGSPACE(m), left);
    729       1.72      yamt 				if (siz > 0) {
    730       1.72      yamt 					left -= siz;
    731       1.72      yamt 					i++;
    732       1.72      yamt 				}
    733       1.72      yamt 				if (left > 0) {
    734       1.72      yamt 					m = m_get(M_WAIT, MT_DATA);
    735       1.72      yamt 					MCLAIM(m, &nfs_mowner);
    736       1.72      yamt 					m_clget(m, M_WAIT);
    737       1.72      yamt 					m->m_len = 0;
    738       1.72      yamt 					m2->m_next = m;
    739       1.72      yamt 					m2 = m;
    740       1.72      yamt 				}
    741       1.72      yamt 			}
    742       1.72      yamt 			iv = malloc(i * sizeof(struct iovec), M_TEMP, M_WAITOK);
    743       1.72      yamt 			uiop->uio_iov = iv2 = iv;
    744       1.72      yamt 			m = mb;
    745       1.72      yamt 			left = cnt;
    746       1.72      yamt 			i = 0;
    747       1.72      yamt 			while (left > 0) {
    748       1.72      yamt 				if (m == NULL)
    749       1.72      yamt 					panic("nfsrv_read iov");
    750       1.72      yamt 				siz = min(M_TRAILINGSPACE(m), left);
    751       1.72      yamt 				if (siz > 0) {
    752       1.72      yamt 					iv->iov_base = mtod(m, caddr_t) +
    753       1.72      yamt 					    m->m_len;
    754       1.72      yamt 					iv->iov_len = siz;
    755       1.72      yamt 					m->m_len += siz;
    756       1.72      yamt 					left -= siz;
    757       1.72      yamt 					iv++;
    758       1.72      yamt 					i++;
    759       1.72      yamt 				}
    760       1.72      yamt 				m = m->m_next;
    761       1.23      fvdl 			}
    762       1.72      yamt 			uiop->uio_iovcnt = i;
    763       1.72      yamt 			uiop->uio_offset = off;
    764       1.72      yamt 			uiop->uio_resid = cnt;
    765       1.72      yamt 			uiop->uio_rw = UIO_READ;
    766      1.101      yamt 			UIO_SETUP_SYSSPACE(uiop);
    767       1.72      yamt 			error = VOP_READ(vp, uiop, IO_NODELOCKED, cred);
    768       1.72      yamt 			free((caddr_t)iv2, M_TEMP);
    769       1.23      fvdl 		}
    770       1.72      yamt read_error:
    771       1.99  christos 		if (error || (getret = VOP_GETATTR(vp, &va, cred, lwp)) != 0){
    772       1.23      fvdl 			if (!error)
    773       1.23      fvdl 				error = getret;
    774       1.15   mycroft 			m_freem(mreq);
    775       1.15   mycroft 			vput(vp);
    776       1.23      fvdl 			nfsm_reply(NFSX_POSTOPATTR(v3));
    777       1.23      fvdl 			nfsm_srvpostop_attr(getret, &va);
    778       1.23      fvdl 			return (0);
    779       1.15   mycroft 		}
    780       1.72      yamt 	} else {
    781       1.15   mycroft 		uiop->uio_resid = 0;
    782       1.72      yamt 	}
    783        1.1       cgd 	vput(vp);
    784       1.23      fvdl 	nfsm_srvfillattr(&va, fp);
    785        1.1       cgd 	len -= uiop->uio_resid;
    786       1.76      yamt 	padlen = nfsm_padlen(len);
    787       1.76      yamt 	if (uiop->uio_resid || padlen)
    788       1.76      yamt 		nfs_zeropad(mb, uiop->uio_resid, padlen);
    789       1.23      fvdl 	if (v3) {
    790       1.83      yamt 		/* count */
    791       1.23      fvdl 		*tl++ = txdr_unsigned(len);
    792       1.83      yamt 		/* eof */
    793       1.83      yamt 		if (off + len >= va.va_size)
    794       1.23      fvdl 			*tl++ = nfs_true;
    795       1.23      fvdl 		else
    796       1.23      fvdl 			*tl++ = nfs_false;
    797       1.23      fvdl 	}
    798        1.1       cgd 	*tl = txdr_unsigned(len);
    799        1.1       cgd 	nfsm_srvdone;
    800        1.1       cgd }
    801        1.1       cgd 
    802        1.1       cgd /*
    803        1.1       cgd  * nfs write service
    804        1.1       cgd  */
    805       1.22  christos int
    806       1.99  christos nfsrv_write(nfsd, slp, lwp, mrq)
    807       1.23      fvdl 	struct nfsrv_descript *nfsd;
    808       1.23      fvdl 	struct nfssvc_sock *slp;
    809       1.99  christos 	struct lwp *lwp;
    810       1.23      fvdl 	struct mbuf **mrq;
    811        1.1       cgd {
    812       1.23      fvdl 	struct mbuf *mrep = nfsd->nd_mrep, *md = nfsd->nd_md;
    813       1.23      fvdl 	struct mbuf *nam = nfsd->nd_nam;
    814       1.23      fvdl 	caddr_t dpos = nfsd->nd_dpos;
    815  1.101.2.2      yamt 	kauth_cred_t cred = nfsd->nd_cr;
    816       1.54  augustss 	struct iovec *ivp;
    817       1.54  augustss 	int i, cnt;
    818       1.54  augustss 	struct mbuf *mp;
    819       1.54  augustss 	struct nfs_fattr *fp;
    820       1.23      fvdl 	struct iovec *iv;
    821       1.23      fvdl 	struct vattr va, forat;
    822       1.54  augustss 	u_int32_t *tl;
    823       1.54  augustss 	int32_t t1;
    824        1.1       cgd 	caddr_t bpos;
    825  1.101.2.2      yamt 	int error = 0, rdonly, cache = 0, len, forat_ret = 1;
    826       1.23      fvdl 	int ioflags, aftat_ret = 1, retlen, zeroing, adjust;
    827       1.23      fvdl 	int stable = NFSV3WRITE_FILESYNC;
    828       1.23      fvdl 	int v3 = (nfsd->nd_flag & ND_NFSV3);
    829        1.1       cgd 	char *cp2;
    830       1.67      matt 	struct mbuf *mb, *mreq;
    831        1.1       cgd 	struct vnode *vp;
    832       1.23      fvdl 	nfsfh_t nfh;
    833        1.1       cgd 	fhandle_t *fhp;
    834        1.1       cgd 	struct uio io, *uiop = &io;
    835        1.1       cgd 	off_t off;
    836       1.15   mycroft 	u_quad_t frev;
    837       1.82   hannken 	struct mount *mntp = NULL;
    838        1.1       cgd 
    839       1.23      fvdl 	if (mrep == NULL) {
    840       1.23      fvdl 		*mrq = NULL;
    841       1.23      fvdl 		return (0);
    842       1.23      fvdl 	}
    843        1.1       cgd 	fhp = &nfh.fh_generic;
    844        1.1       cgd 	nfsm_srvmtofh(fhp);
    845       1.82   hannken 	if ((mntp = vfs_getvfs(&fhp->fh_fsid)) == NULL)
    846       1.82   hannken 		return (ESTALE);
    847       1.82   hannken 	vn_start_write(NULL, &mntp, V_WAIT);
    848       1.23      fvdl 	if (v3) {
    849       1.23      fvdl 		nfsm_dissect(tl, u_int32_t *, 5 * NFSX_UNSIGNED);
    850       1.48      fair 		off = fxdr_hyper(tl);
    851       1.23      fvdl 		tl += 3;
    852       1.23      fvdl 		stable = fxdr_unsigned(int, *tl++);
    853       1.23      fvdl 	} else {
    854       1.23      fvdl 		nfsm_dissect(tl, u_int32_t *, 4 * NFSX_UNSIGNED);
    855       1.19       cgd 		off = (off_t)fxdr_unsigned(u_int32_t, *++tl);
    856       1.15   mycroft 		tl += 2;
    857       1.15   mycroft 	}
    858       1.23      fvdl 	retlen = len = fxdr_unsigned(int32_t, *tl);
    859       1.23      fvdl 	cnt = i = 0;
    860       1.23      fvdl 
    861       1.23      fvdl 	/*
    862       1.23      fvdl 	 * For NFS Version 2, it is not obvious what a write of zero length
    863       1.23      fvdl 	 * should do, but I might as well be consistent with Version 3,
    864       1.23      fvdl 	 * which is to return ok so long as there are no permission problems.
    865       1.23      fvdl 	 */
    866       1.23      fvdl 	if (len > 0) {
    867       1.74      yamt 		zeroing = 1;
    868       1.74      yamt 		mp = mrep;
    869       1.74      yamt 		while (mp) {
    870       1.74      yamt 			if (mp == md) {
    871       1.74      yamt 				zeroing = 0;
    872       1.74      yamt 				adjust = dpos - mtod(mp, caddr_t);
    873       1.74      yamt 				mp->m_len -= adjust;
    874       1.74      yamt 				if (mp->m_len > 0 && adjust > 0)
    875       1.74      yamt 					NFSMADV(mp, adjust);
    876       1.23      fvdl 			}
    877       1.74      yamt 			if (zeroing)
    878       1.74      yamt 				mp->m_len = 0;
    879       1.74      yamt 			else if (mp->m_len > 0) {
    880       1.74      yamt 				i += mp->m_len;
    881       1.74      yamt 				if (i > len) {
    882       1.74      yamt 					mp->m_len -= (i - len);
    883       1.74      yamt 					zeroing	= 1;
    884       1.74      yamt 				}
    885       1.74      yamt 				if (mp->m_len > 0)
    886       1.74      yamt 					cnt++;
    887       1.74      yamt 			}
    888       1.74      yamt 			mp = mp->m_next;
    889       1.23      fvdl 		}
    890       1.23      fvdl 	}
    891       1.23      fvdl 	if (len > NFS_MAXDATA || len < 0 || i < len) {
    892       1.23      fvdl 		error = EIO;
    893       1.23      fvdl 		nfsm_reply(2 * NFSX_UNSIGNED);
    894       1.23      fvdl 		nfsm_srvwcc_data(forat_ret, &forat, aftat_ret, &va);
    895       1.82   hannken 		vn_finished_write(mntp, 0);
    896       1.23      fvdl 		return (0);
    897        1.1       cgd 	}
    898       1.23      fvdl 	error = nfsrv_fhtovp(fhp, 1, &vp, cred, slp, nam,
    899       1.78   thorpej 		 &rdonly, (nfsd->nd_flag & ND_KERBAUTH), FALSE);
    900       1.23      fvdl 	if (error) {
    901       1.23      fvdl 		nfsm_reply(2 * NFSX_UNSIGNED);
    902       1.23      fvdl 		nfsm_srvwcc_data(forat_ret, &forat, aftat_ret, &va);
    903       1.82   hannken 		vn_finished_write(mntp, 0);
    904       1.23      fvdl 		return (0);
    905        1.1       cgd 	}
    906       1.23      fvdl 	if (v3)
    907       1.99  christos 		forat_ret = VOP_GETATTR(vp, &forat, cred, lwp);
    908       1.15   mycroft 	if (vp->v_type != VREG) {
    909       1.23      fvdl 		if (v3)
    910       1.23      fvdl 			error = EINVAL;
    911       1.23      fvdl 		else
    912       1.23      fvdl 			error = (vp->v_type == VDIR) ? EISDIR : EACCES;
    913       1.23      fvdl 	}
    914       1.23      fvdl 	if (!error) {
    915       1.23      fvdl 		nqsrv_getl(vp, ND_WRITE);
    916       1.99  christos 		error = nfsrv_access(vp, VWRITE, cred, rdonly, lwp, 1);
    917       1.15   mycroft 	}
    918       1.22  christos 	if (error) {
    919        1.1       cgd 		vput(vp);
    920       1.23      fvdl 		nfsm_reply(NFSX_WCCDATA(v3));
    921       1.23      fvdl 		nfsm_srvwcc_data(forat_ret, &forat, aftat_ret, &va);
    922       1.82   hannken 		vn_finished_write(mntp, 0);
    923       1.23      fvdl 		return (0);
    924       1.23      fvdl 	}
    925       1.23      fvdl 
    926       1.23      fvdl 	if (len > 0) {
    927       1.74      yamt 		ivp = malloc(cnt * sizeof (struct iovec), M_TEMP, M_WAITOK);
    928       1.74      yamt 		uiop->uio_iov = iv = ivp;
    929       1.74      yamt 		uiop->uio_iovcnt = cnt;
    930       1.74      yamt 		mp = mrep;
    931       1.74      yamt 		while (mp) {
    932       1.74      yamt 			if (mp->m_len > 0) {
    933       1.74      yamt 				ivp->iov_base = mtod(mp, caddr_t);
    934       1.74      yamt 				ivp->iov_len = mp->m_len;
    935       1.74      yamt 				ivp++;
    936       1.74      yamt 			}
    937       1.74      yamt 			mp = mp->m_next;
    938       1.74      yamt 		}
    939       1.74      yamt 
    940       1.74      yamt 		/*
    941       1.74      yamt 		 * XXX
    942       1.74      yamt 		 * The IO_METASYNC flag indicates that all metadata (and not
    943       1.74      yamt 		 * just enough to ensure data integrity) must be written to
    944       1.74      yamt 		 * stable storage synchronously.
    945       1.74      yamt 		 * (IO_METASYNC is not yet implemented in 4.4BSD-Lite.)
    946       1.74      yamt 		 */
    947       1.74      yamt 		if (stable == NFSV3WRITE_UNSTABLE)
    948       1.74      yamt 			ioflags = IO_NODELOCKED;
    949       1.74      yamt 		else if (stable == NFSV3WRITE_DATASYNC)
    950       1.74      yamt 			ioflags = (IO_SYNC | IO_NODELOCKED);
    951       1.74      yamt 		else
    952       1.74      yamt 			ioflags = (IO_METASYNC | IO_SYNC | IO_NODELOCKED);
    953       1.74      yamt 		uiop->uio_resid = len;
    954       1.74      yamt 		uiop->uio_rw = UIO_WRITE;
    955       1.74      yamt 		uiop->uio_offset = off;
    956      1.101      yamt 		UIO_SETUP_SYSSPACE(uiop);
    957       1.74      yamt 		error = VOP_WRITE(vp, uiop, ioflags, cred);
    958       1.74      yamt 		nfsstats.srvvop_writes++;
    959       1.74      yamt 		free(iv, M_TEMP);
    960       1.23      fvdl 	}
    961       1.99  christos 	aftat_ret = VOP_GETATTR(vp, &va, cred, lwp);
    962       1.23      fvdl 	vput(vp);
    963       1.82   hannken 	vn_finished_write(mntp, 0);
    964       1.23      fvdl 	if (!error)
    965       1.23      fvdl 		error = aftat_ret;
    966       1.23      fvdl 	nfsm_reply(NFSX_PREOPATTR(v3) + NFSX_POSTOPORFATTR(v3) +
    967       1.23      fvdl 		2 * NFSX_UNSIGNED + NFSX_WRITEVERF(v3));
    968       1.23      fvdl 	if (v3) {
    969       1.23      fvdl 		nfsm_srvwcc_data(forat_ret, &forat, aftat_ret, &va);
    970       1.23      fvdl 		if (error)
    971       1.23      fvdl 			return (0);
    972       1.23      fvdl 		nfsm_build(tl, u_int32_t *, 4 * NFSX_UNSIGNED);
    973       1.23      fvdl 		*tl++ = txdr_unsigned(retlen);
    974       1.23      fvdl 		if (stable == NFSV3WRITE_UNSTABLE)
    975       1.23      fvdl 			*tl++ = txdr_unsigned(stable);
    976       1.23      fvdl 		else
    977       1.23      fvdl 			*tl++ = txdr_unsigned(NFSV3WRITE_FILESYNC);
    978       1.23      fvdl 		/*
    979       1.23      fvdl 		 * Actually, there is no need to txdr these fields,
    980       1.23      fvdl 		 * but it may make the values more human readable,
    981       1.23      fvdl 		 * for debugging purposes.
    982       1.23      fvdl 		 */
    983       1.23      fvdl 		*tl++ = txdr_unsigned(boottime.tv_sec);
    984       1.23      fvdl 		*tl = txdr_unsigned(boottime.tv_usec);
    985       1.23      fvdl 	} else {
    986       1.23      fvdl 		nfsm_build(fp, struct nfs_fattr *, NFSX_V2FATTR);
    987       1.23      fvdl 		nfsm_srvfillattr(&va, fp);
    988       1.23      fvdl 	}
    989       1.23      fvdl 	nfsm_srvdone;
    990       1.23      fvdl }
    991       1.23      fvdl 
    992       1.23      fvdl /*
    993  1.101.2.2      yamt  * XXX elad: the original NFSW_SAMECRED() macro also made sure the
    994  1.101.2.2      yamt  *	     two nd_flag fields of the descriptors contained
    995  1.101.2.2      yamt  *	     ND_KERBAUTH.
    996  1.101.2.2      yamt  */
    997  1.101.2.2      yamt static int
    998  1.101.2.2      yamt nfsrv_samecred(kauth_cred_t cred1, kauth_cred_t cred2)
    999  1.101.2.2      yamt {
   1000  1.101.2.2      yamt 	int i, do_ngroups;
   1001  1.101.2.2      yamt 
   1002  1.101.2.2      yamt 	if (kauth_cred_geteuid(cred1) != kauth_cred_geteuid(cred2))
   1003  1.101.2.2      yamt 		return (0);
   1004  1.101.2.2      yamt 	if (kauth_cred_ngroups(cred1) != kauth_cred_ngroups(cred2))
   1005  1.101.2.2      yamt 		return (0);
   1006  1.101.2.2      yamt 	do_ngroups = kauth_cred_ngroups(cred1);
   1007  1.101.2.2      yamt 	for (i = 0; i < do_ngroups; i++)
   1008  1.101.2.2      yamt 		if (kauth_cred_group(cred1, i) !=
   1009  1.101.2.2      yamt 		    kauth_cred_group(cred2, i))
   1010  1.101.2.2      yamt 			return (0);
   1011  1.101.2.2      yamt 
   1012  1.101.2.2      yamt 	return (1);
   1013  1.101.2.2      yamt }
   1014  1.101.2.2      yamt 
   1015  1.101.2.2      yamt /*
   1016       1.23      fvdl  * NFS write service with write gathering support. Called when
   1017       1.23      fvdl  * nfsrvw_procrastinate > 0.
   1018       1.23      fvdl  * See: Chet Juszczak, "Improving the Write Performance of an NFS Server",
   1019       1.23      fvdl  * in Proc. of the Winter 1994 Usenix Conference, pg. 247-259, San Franscisco,
   1020       1.23      fvdl  * Jan. 1994.
   1021       1.23      fvdl  */
   1022       1.23      fvdl int
   1023       1.99  christos nfsrv_writegather(ndp, slp, lwp, mrq)
   1024       1.23      fvdl 	struct nfsrv_descript **ndp;
   1025       1.23      fvdl 	struct nfssvc_sock *slp;
   1026       1.99  christos 	struct lwp *lwp;
   1027       1.23      fvdl 	struct mbuf **mrq;
   1028       1.23      fvdl {
   1029       1.54  augustss 	struct iovec *ivp;
   1030       1.54  augustss 	struct mbuf *mp;
   1031       1.54  augustss 	struct nfsrv_descript *wp, *nfsd, *owp, *swp;
   1032       1.54  augustss 	struct nfs_fattr *fp;
   1033       1.54  augustss 	int i = 0;
   1034       1.23      fvdl 	struct iovec *iov;
   1035       1.23      fvdl 	struct nfsrvw_delayhash *wpp;
   1036  1.101.2.2      yamt 	kauth_cred_t cred;
   1037       1.23      fvdl 	struct vattr va, forat;
   1038       1.54  augustss 	u_int32_t *tl;
   1039       1.54  augustss 	int32_t t1;
   1040       1.23      fvdl 	caddr_t bpos, dpos;
   1041  1.101.2.2      yamt 	int error = 0, rdonly, cache = 0, len = 0, forat_ret = 1;
   1042       1.23      fvdl 	int ioflags, aftat_ret = 1, s, adjust, v3, zeroing;
   1043       1.23      fvdl 	char *cp2;
   1044       1.67      matt 	struct mbuf *mb, *mreq, *mrep, *md;
   1045       1.23      fvdl 	struct vnode *vp;
   1046       1.23      fvdl 	struct uio io, *uiop = &io;
   1047       1.23      fvdl 	u_quad_t frev, cur_usec;
   1048       1.82   hannken 	struct mount *mntp = NULL;
   1049       1.23      fvdl 
   1050       1.23      fvdl 	*mrq = NULL;
   1051       1.23      fvdl 	if (*ndp) {
   1052       1.23      fvdl 	    nfsd = *ndp;
   1053       1.23      fvdl 	    *ndp = NULL;
   1054       1.23      fvdl 	    mrep = nfsd->nd_mrep;
   1055       1.23      fvdl 	    md = nfsd->nd_md;
   1056       1.23      fvdl 	    dpos = nfsd->nd_dpos;
   1057  1.101.2.2      yamt 	    cred = nfsd->nd_cr;
   1058       1.23      fvdl 	    v3 = (nfsd->nd_flag & ND_NFSV3);
   1059       1.23      fvdl 	    LIST_INIT(&nfsd->nd_coalesce);
   1060       1.23      fvdl 	    nfsd->nd_mreq = NULL;
   1061       1.23      fvdl 	    nfsd->nd_stable = NFSV3WRITE_FILESYNC;
   1062       1.23      fvdl 	    cur_usec = (u_quad_t)time.tv_sec * 1000000 + (u_quad_t)time.tv_usec;
   1063       1.23      fvdl 	    nfsd->nd_time = cur_usec + nfsrvw_procrastinate;
   1064       1.94     perry 
   1065       1.23      fvdl 	    /*
   1066       1.23      fvdl 	     * Now, get the write header..
   1067       1.23      fvdl 	     */
   1068       1.23      fvdl 	    nfsm_srvmtofh(&nfsd->nd_fh);
   1069       1.23      fvdl 	    if (v3) {
   1070       1.23      fvdl 		nfsm_dissect(tl, u_int32_t *, 5 * NFSX_UNSIGNED);
   1071       1.48      fair 		nfsd->nd_off = fxdr_hyper(tl);
   1072       1.23      fvdl 		tl += 3;
   1073       1.23      fvdl 		nfsd->nd_stable = fxdr_unsigned(int, *tl++);
   1074       1.23      fvdl 	    } else {
   1075       1.23      fvdl 		nfsm_dissect(tl, u_int32_t *, 4 * NFSX_UNSIGNED);
   1076       1.23      fvdl 		nfsd->nd_off = (off_t)fxdr_unsigned(u_int32_t, *++tl);
   1077       1.23      fvdl 		tl += 2;
   1078       1.23      fvdl 	    }
   1079       1.23      fvdl 	    len = fxdr_unsigned(int32_t, *tl);
   1080       1.23      fvdl 	    nfsd->nd_len = len;
   1081       1.23      fvdl 	    nfsd->nd_eoff = nfsd->nd_off + len;
   1082       1.94     perry 
   1083       1.23      fvdl 	    /*
   1084       1.23      fvdl 	     * Trim the header out of the mbuf list and trim off any trailing
   1085       1.23      fvdl 	     * junk so that the mbuf list has only the write data.
   1086       1.23      fvdl 	     */
   1087       1.23      fvdl 	    zeroing = 1;
   1088       1.23      fvdl 	    i = 0;
   1089       1.23      fvdl 	    mp = mrep;
   1090       1.23      fvdl 	    while (mp) {
   1091       1.23      fvdl 		if (mp == md) {
   1092       1.23      fvdl 		    zeroing = 0;
   1093       1.23      fvdl 		    adjust = dpos - mtod(mp, caddr_t);
   1094       1.23      fvdl 		    mp->m_len -= adjust;
   1095       1.23      fvdl 		    if (mp->m_len > 0 && adjust > 0)
   1096       1.23      fvdl 			NFSMADV(mp, adjust);
   1097       1.23      fvdl 		}
   1098       1.23      fvdl 		if (zeroing)
   1099       1.23      fvdl 		    mp->m_len = 0;
   1100       1.23      fvdl 		else {
   1101       1.23      fvdl 		    i += mp->m_len;
   1102       1.23      fvdl 		    if (i > len) {
   1103       1.23      fvdl 			mp->m_len -= (i - len);
   1104       1.23      fvdl 			zeroing = 1;
   1105       1.23      fvdl 		    }
   1106       1.23      fvdl 		}
   1107       1.23      fvdl 		mp = mp->m_next;
   1108       1.23      fvdl 	    }
   1109       1.23      fvdl 	    if (len > NFS_MAXDATA || len < 0  || i < len) {
   1110       1.23      fvdl nfsmout:
   1111       1.23      fvdl 		m_freem(mrep);
   1112       1.23      fvdl 		error = EIO;
   1113       1.23      fvdl 		nfsm_writereply(2 * NFSX_UNSIGNED, v3);
   1114       1.23      fvdl 		if (v3)
   1115       1.23      fvdl 		    nfsm_srvwcc_data(forat_ret, &forat, aftat_ret, &va);
   1116       1.23      fvdl 		nfsd->nd_mreq = mreq;
   1117       1.23      fvdl 		nfsd->nd_mrep = NULL;
   1118       1.23      fvdl 		nfsd->nd_time = 0;
   1119       1.23      fvdl 	    }
   1120       1.94     perry 
   1121       1.23      fvdl 	    /*
   1122       1.23      fvdl 	     * Add this entry to the hash and time queues.
   1123       1.23      fvdl 	     */
   1124       1.23      fvdl 	    s = splsoftclock();
   1125       1.23      fvdl 	    owp = NULL;
   1126       1.70      yamt 	    wp = LIST_FIRST(&slp->ns_tq);
   1127       1.23      fvdl 	    while (wp && wp->nd_time < nfsd->nd_time) {
   1128       1.23      fvdl 		owp = wp;
   1129       1.70      yamt 		wp = LIST_NEXT(wp, nd_tq);
   1130       1.23      fvdl 	    }
   1131       1.23      fvdl 	    if (owp) {
   1132       1.23      fvdl 		LIST_INSERT_AFTER(owp, nfsd, nd_tq);
   1133       1.23      fvdl 	    } else {
   1134       1.23      fvdl 		LIST_INSERT_HEAD(&slp->ns_tq, nfsd, nd_tq);
   1135       1.23      fvdl 	    }
   1136       1.23      fvdl 	    if (nfsd->nd_mrep) {
   1137       1.23      fvdl 		wpp = NWDELAYHASH(slp, nfsd->nd_fh.fh_fid.fid_data);
   1138       1.23      fvdl 		owp = NULL;
   1139       1.70      yamt 		wp = LIST_FIRST(wpp);
   1140       1.23      fvdl 		while (wp &&
   1141      1.100      yamt 		    memcmp(&nfsd->nd_fh, &wp->nd_fh, NFSX_V3FH)) {
   1142       1.23      fvdl 		    owp = wp;
   1143       1.70      yamt 		    wp = LIST_NEXT(wp, nd_hash);
   1144       1.23      fvdl 		}
   1145       1.23      fvdl 		while (wp && wp->nd_off < nfsd->nd_off &&
   1146      1.100      yamt 		    !memcmp(&nfsd->nd_fh, &wp->nd_fh, NFSX_V3FH)) {
   1147       1.23      fvdl 		    owp = wp;
   1148       1.70      yamt 		    wp = LIST_NEXT(wp, nd_hash);
   1149       1.23      fvdl 		}
   1150       1.23      fvdl 		if (owp) {
   1151       1.23      fvdl 		    LIST_INSERT_AFTER(owp, nfsd, nd_hash);
   1152       1.23      fvdl 
   1153       1.23      fvdl 		    /*
   1154       1.23      fvdl 		     * Search the hash list for overlapping entries and
   1155       1.23      fvdl 		     * coalesce.
   1156       1.23      fvdl 		     */
   1157       1.23      fvdl 		    for(; nfsd && NFSW_CONTIG(owp, nfsd); nfsd = wp) {
   1158       1.70      yamt 			wp = LIST_NEXT(nfsd, nd_hash);
   1159  1.101.2.2      yamt 			if (nfsrv_samecred(owp->nd_cr, nfsd->nd_cr))
   1160       1.23      fvdl 			    nfsrvw_coalesce(owp, nfsd);
   1161       1.23      fvdl 		    }
   1162       1.23      fvdl 		} else {
   1163       1.23      fvdl 		    LIST_INSERT_HEAD(wpp, nfsd, nd_hash);
   1164       1.23      fvdl 		}
   1165       1.23      fvdl 	    }
   1166       1.23      fvdl 	    splx(s);
   1167        1.1       cgd 	}
   1168       1.94     perry 
   1169        1.1       cgd 	/*
   1170       1.23      fvdl 	 * Now, do VOP_WRITE()s for any one(s) that need to be done now
   1171       1.23      fvdl 	 * and generate the associated reply mbuf list(s).
   1172        1.1       cgd 	 */
   1173       1.23      fvdl loop1:
   1174       1.23      fvdl 	cur_usec = (u_quad_t)time.tv_sec * 1000000 + (u_quad_t)time.tv_usec;
   1175       1.23      fvdl 	s = splsoftclock();
   1176       1.70      yamt 	for (nfsd = LIST_FIRST(&slp->ns_tq); nfsd; nfsd = owp) {
   1177       1.70      yamt 		owp = LIST_NEXT(nfsd, nd_tq);
   1178       1.23      fvdl 		if (nfsd->nd_time > cur_usec)
   1179       1.23      fvdl 		    break;
   1180       1.23      fvdl 		if (nfsd->nd_mreq)
   1181       1.23      fvdl 		    continue;
   1182       1.23      fvdl 		LIST_REMOVE(nfsd, nd_tq);
   1183       1.23      fvdl 		LIST_REMOVE(nfsd, nd_hash);
   1184       1.23      fvdl 		splx(s);
   1185       1.23      fvdl 		mrep = nfsd->nd_mrep;
   1186       1.23      fvdl 		nfsd->nd_mrep = NULL;
   1187  1.101.2.2      yamt 		cred = nfsd->nd_cr;
   1188       1.23      fvdl 		v3 = (nfsd->nd_flag & ND_NFSV3);
   1189       1.23      fvdl 		forat_ret = aftat_ret = 1;
   1190       1.94     perry 		error = nfsrv_fhtovp(&nfsd->nd_fh, 1, &vp, cred, slp,
   1191       1.35      fvdl 		    nfsd->nd_nam, &rdonly, (nfsd->nd_flag & ND_KERBAUTH),
   1192       1.78   thorpej 		    FALSE);
   1193       1.23      fvdl 		if (!error) {
   1194       1.23      fvdl 		    if (v3)
   1195       1.99  christos 			forat_ret = VOP_GETATTR(vp, &forat, cred, lwp);
   1196       1.23      fvdl 		    if (vp->v_type != VREG) {
   1197       1.23      fvdl 			if (v3)
   1198       1.23      fvdl 			    error = EINVAL;
   1199        1.1       cgd 			else
   1200       1.23      fvdl 			    error = (vp->v_type == VDIR) ? EISDIR : EACCES;
   1201       1.23      fvdl 		    }
   1202       1.23      fvdl 		} else
   1203       1.23      fvdl 		    vp = NULL;
   1204       1.23      fvdl 		if (!error) {
   1205       1.23      fvdl 		    nqsrv_getl(vp, ND_WRITE);
   1206       1.99  christos 		    error = nfsrv_access(vp, VWRITE, cred, rdonly, lwp, 1);
   1207       1.23      fvdl 		}
   1208       1.94     perry 
   1209       1.23      fvdl 		if (nfsd->nd_stable == NFSV3WRITE_UNSTABLE)
   1210       1.23      fvdl 		    ioflags = IO_NODELOCKED;
   1211       1.23      fvdl 		else if (nfsd->nd_stable == NFSV3WRITE_DATASYNC)
   1212       1.23      fvdl 		    ioflags = (IO_SYNC | IO_NODELOCKED);
   1213       1.23      fvdl 		else
   1214       1.23      fvdl 		    ioflags = (IO_METASYNC | IO_SYNC | IO_NODELOCKED);
   1215       1.23      fvdl 		uiop->uio_rw = UIO_WRITE;
   1216       1.23      fvdl 		uiop->uio_offset = nfsd->nd_off;
   1217       1.23      fvdl 		uiop->uio_resid = nfsd->nd_eoff - nfsd->nd_off;
   1218      1.101      yamt 		UIO_SETUP_SYSSPACE(uiop);
   1219       1.23      fvdl 		if (uiop->uio_resid > 0) {
   1220       1.23      fvdl 		    mp = mrep;
   1221       1.23      fvdl 		    i = 0;
   1222       1.23      fvdl 		    while (mp) {
   1223       1.23      fvdl 			if (mp->m_len > 0)
   1224       1.23      fvdl 			    i++;
   1225       1.23      fvdl 			mp = mp->m_next;
   1226       1.23      fvdl 		    }
   1227       1.23      fvdl 		    uiop->uio_iovcnt = i;
   1228       1.56   thorpej 		    iov = malloc(i * sizeof (struct iovec), M_TEMP, M_WAITOK);
   1229       1.23      fvdl 		    uiop->uio_iov = ivp = iov;
   1230       1.23      fvdl 		    mp = mrep;
   1231       1.23      fvdl 		    while (mp) {
   1232       1.23      fvdl 			if (mp->m_len > 0) {
   1233       1.23      fvdl 			    ivp->iov_base = mtod(mp, caddr_t);
   1234       1.23      fvdl 			    ivp->iov_len = mp->m_len;
   1235       1.23      fvdl 			    ivp++;
   1236       1.23      fvdl 			}
   1237        1.1       cgd 			mp = mp->m_next;
   1238       1.23      fvdl 		    }
   1239       1.23      fvdl 		    if (!error) {
   1240       1.82   hannken 			if (vn_start_write(vp, &mntp, V_NOWAIT) != 0) {
   1241       1.82   hannken 			    VOP_UNLOCK(vp, 0);
   1242       1.86   hannken 			    vn_start_write(NULL, &mntp, V_WAIT);
   1243       1.82   hannken 			    vn_lock(vp, LK_EXCLUSIVE | LK_RETRY);
   1244       1.82   hannken 			}
   1245       1.82   hannken 			if (!error) {
   1246       1.82   hannken 			    error = VOP_WRITE(vp, uiop, ioflags, cred);
   1247       1.82   hannken 			    nfsstats.srvvop_writes++;
   1248       1.82   hannken 			    vn_finished_write(mntp, 0);
   1249       1.82   hannken 			}
   1250       1.23      fvdl 		    }
   1251       1.56   thorpej 		    free((caddr_t)iov, M_TEMP);
   1252        1.1       cgd 		}
   1253       1.23      fvdl 		m_freem(mrep);
   1254       1.23      fvdl 		if (vp) {
   1255       1.99  christos 		    aftat_ret = VOP_GETATTR(vp, &va, cred, lwp);
   1256       1.23      fvdl 		    vput(vp);
   1257        1.1       cgd 		}
   1258       1.23      fvdl 
   1259       1.23      fvdl 		/*
   1260       1.23      fvdl 		 * Loop around generating replies for all write rpcs that have
   1261       1.23      fvdl 		 * now been completed.
   1262       1.23      fvdl 		 */
   1263       1.23      fvdl 		swp = nfsd;
   1264       1.23      fvdl 		do {
   1265       1.23      fvdl 		    if (error) {
   1266       1.23      fvdl 			nfsm_writereply(NFSX_WCCDATA(v3), v3);
   1267       1.23      fvdl 			if (v3) {
   1268       1.23      fvdl 			    nfsm_srvwcc_data(forat_ret, &forat, aftat_ret, &va);
   1269       1.23      fvdl 			}
   1270       1.23      fvdl 		    } else {
   1271       1.23      fvdl 			nfsm_writereply(NFSX_PREOPATTR(v3) +
   1272       1.23      fvdl 			    NFSX_POSTOPORFATTR(v3) + 2 * NFSX_UNSIGNED +
   1273       1.23      fvdl 			    NFSX_WRITEVERF(v3), v3);
   1274       1.23      fvdl 			if (v3) {
   1275       1.23      fvdl 			    nfsm_srvwcc_data(forat_ret, &forat, aftat_ret, &va);
   1276       1.23      fvdl 			    nfsm_build(tl, u_int32_t *, 4 * NFSX_UNSIGNED);
   1277       1.23      fvdl 			    *tl++ = txdr_unsigned(nfsd->nd_len);
   1278       1.23      fvdl 			    *tl++ = txdr_unsigned(swp->nd_stable);
   1279       1.23      fvdl 			    /*
   1280       1.23      fvdl 			     * Actually, there is no need to txdr these fields,
   1281       1.23      fvdl 			     * but it may make the values more human readable,
   1282       1.23      fvdl 			     * for debugging purposes.
   1283       1.23      fvdl 			     */
   1284       1.23      fvdl 			    *tl++ = txdr_unsigned(boottime.tv_sec);
   1285       1.23      fvdl 			    *tl = txdr_unsigned(boottime.tv_usec);
   1286       1.23      fvdl 			} else {
   1287       1.23      fvdl 			    nfsm_build(fp, struct nfs_fattr *, NFSX_V2FATTR);
   1288       1.23      fvdl 			    nfsm_srvfillattr(&va, fp);
   1289       1.23      fvdl 			}
   1290       1.23      fvdl 		    }
   1291       1.23      fvdl 		    nfsd->nd_mreq = mreq;
   1292       1.23      fvdl 		    if (nfsd->nd_mrep)
   1293       1.23      fvdl 			panic("nfsrv_write: nd_mrep not free");
   1294       1.23      fvdl 
   1295       1.23      fvdl 		    /*
   1296       1.23      fvdl 		     * Done. Put it at the head of the timer queue so that
   1297       1.23      fvdl 		     * the final phase can return the reply.
   1298       1.23      fvdl 		     */
   1299       1.23      fvdl 		    s = splsoftclock();
   1300       1.23      fvdl 		    if (nfsd != swp) {
   1301       1.23      fvdl 			nfsd->nd_time = 0;
   1302       1.23      fvdl 			LIST_INSERT_HEAD(&slp->ns_tq, nfsd, nd_tq);
   1303       1.23      fvdl 		    }
   1304       1.70      yamt 		    nfsd = LIST_FIRST(&swp->nd_coalesce);
   1305       1.23      fvdl 		    if (nfsd) {
   1306       1.23      fvdl 			LIST_REMOVE(nfsd, nd_tq);
   1307       1.23      fvdl 		    }
   1308       1.23      fvdl 		    splx(s);
   1309       1.23      fvdl 		} while (nfsd);
   1310       1.23      fvdl 		s = splsoftclock();
   1311       1.23      fvdl 		swp->nd_time = 0;
   1312       1.23      fvdl 		LIST_INSERT_HEAD(&slp->ns_tq, swp, nd_tq);
   1313       1.23      fvdl 		splx(s);
   1314       1.23      fvdl 		goto loop1;
   1315       1.23      fvdl 	}
   1316       1.23      fvdl 	splx(s);
   1317       1.23      fvdl 
   1318       1.23      fvdl 	/*
   1319       1.23      fvdl 	 * Search for a reply to return.
   1320       1.23      fvdl 	 */
   1321       1.23      fvdl 	s = splsoftclock();
   1322       1.70      yamt 	LIST_FOREACH(nfsd, &slp->ns_tq, nd_tq) {
   1323       1.23      fvdl 		if (nfsd->nd_mreq) {
   1324       1.23      fvdl 		    LIST_REMOVE(nfsd, nd_tq);
   1325       1.23      fvdl 		    *mrq = nfsd->nd_mreq;
   1326       1.23      fvdl 		    *ndp = nfsd;
   1327       1.23      fvdl 		    break;
   1328        1.1       cgd 		}
   1329       1.70      yamt 	}
   1330       1.23      fvdl 	splx(s);
   1331       1.23      fvdl 	return (0);
   1332       1.23      fvdl }
   1333       1.23      fvdl 
   1334       1.23      fvdl /*
   1335       1.23      fvdl  * Coalesce the write request nfsd into owp. To do this we must:
   1336       1.23      fvdl  * - remove nfsd from the queues
   1337       1.23      fvdl  * - merge nfsd->nd_mrep into owp->nd_mrep
   1338       1.23      fvdl  * - update the nd_eoff and nd_stable for owp
   1339       1.23      fvdl  * - put nfsd on owp's nd_coalesce list
   1340       1.23      fvdl  * NB: Must be called at splsoftclock().
   1341       1.23      fvdl  */
   1342       1.23      fvdl void
   1343       1.23      fvdl nfsrvw_coalesce(owp, nfsd)
   1344       1.54  augustss         struct nfsrv_descript *owp;
   1345       1.54  augustss         struct nfsrv_descript *nfsd;
   1346       1.23      fvdl {
   1347       1.54  augustss         int overlap;
   1348       1.54  augustss         struct mbuf *mp;
   1349       1.70      yamt 	struct nfsrv_descript *m;
   1350       1.23      fvdl 
   1351       1.23      fvdl         LIST_REMOVE(nfsd, nd_hash);
   1352       1.23      fvdl         LIST_REMOVE(nfsd, nd_tq);
   1353       1.23      fvdl         if (owp->nd_eoff < nfsd->nd_eoff) {
   1354       1.23      fvdl             overlap = owp->nd_eoff - nfsd->nd_off;
   1355       1.23      fvdl             if (overlap < 0)
   1356       1.23      fvdl                 panic("nfsrv_coalesce: bad off");
   1357       1.23      fvdl             if (overlap > 0)
   1358       1.23      fvdl                 m_adj(nfsd->nd_mrep, overlap);
   1359       1.23      fvdl             mp = owp->nd_mrep;
   1360       1.23      fvdl             while (mp->m_next)
   1361       1.23      fvdl                 mp = mp->m_next;
   1362       1.23      fvdl             mp->m_next = nfsd->nd_mrep;
   1363       1.23      fvdl             owp->nd_eoff = nfsd->nd_eoff;
   1364       1.23      fvdl         } else
   1365       1.23      fvdl             m_freem(nfsd->nd_mrep);
   1366       1.23      fvdl         nfsd->nd_mrep = NULL;
   1367       1.23      fvdl         if (nfsd->nd_stable == NFSV3WRITE_FILESYNC)
   1368       1.23      fvdl             owp->nd_stable = NFSV3WRITE_FILESYNC;
   1369       1.23      fvdl         else if (nfsd->nd_stable == NFSV3WRITE_DATASYNC &&
   1370       1.23      fvdl             owp->nd_stable == NFSV3WRITE_UNSTABLE)
   1371       1.23      fvdl             owp->nd_stable = NFSV3WRITE_DATASYNC;
   1372       1.23      fvdl         LIST_INSERT_HEAD(&owp->nd_coalesce, nfsd, nd_tq);
   1373       1.34      fvdl  	/*
   1374       1.34      fvdl  	 * nfsd might hold coalesce elements! Move them to owp.
   1375       1.34      fvdl  	 * Otherwise, requests may be lost and clients will be stuck.
   1376       1.34      fvdl  	 */
   1377       1.70      yamt 	while ((m = LIST_FIRST(&nfsd->nd_coalesce)) != NULL) {
   1378       1.70      yamt 		LIST_REMOVE(m, nd_tq);
   1379       1.70      yamt 		LIST_INSERT_HEAD(&owp->nd_coalesce, m, nd_tq);
   1380       1.70      yamt 	}
   1381        1.1       cgd }
   1382        1.1       cgd 
   1383        1.1       cgd /*
   1384        1.1       cgd  * nfs create service
   1385       1.15   mycroft  * now does a truncate to 0 length via. setattr if it already exists
   1386        1.1       cgd  */
   1387       1.22  christos int
   1388       1.99  christos nfsrv_create(nfsd, slp, lwp, mrq)
   1389       1.23      fvdl 	struct nfsrv_descript *nfsd;
   1390       1.23      fvdl 	struct nfssvc_sock *slp;
   1391       1.99  christos 	struct lwp *lwp;
   1392       1.23      fvdl 	struct mbuf **mrq;
   1393        1.1       cgd {
   1394       1.23      fvdl 	struct mbuf *mrep = nfsd->nd_mrep, *md = nfsd->nd_md;
   1395       1.23      fvdl 	struct mbuf *nam = nfsd->nd_nam;
   1396       1.23      fvdl 	caddr_t dpos = nfsd->nd_dpos;
   1397  1.101.2.2      yamt 	kauth_cred_t cred = nfsd->nd_cr;
   1398       1.54  augustss 	struct nfs_fattr *fp;
   1399       1.23      fvdl 	struct vattr va, dirfor, diraft;
   1400       1.54  augustss 	struct nfsv2_sattr *sp;
   1401       1.54  augustss 	u_int32_t *tl;
   1402        1.1       cgd 	struct nameidata nd;
   1403       1.54  augustss 	caddr_t cp;
   1404       1.54  augustss 	int32_t t1;
   1405        1.1       cgd 	caddr_t bpos;
   1406  1.101.2.2      yamt 	int error = 0, cache = 0, len, tsize, dirfor_ret = 1, diraft_ret = 1;
   1407       1.23      fvdl 	int rdev = 0;
   1408       1.23      fvdl 	int v3 = (nfsd->nd_flag & ND_NFSV3), how, exclusive_flag = 0;
   1409        1.1       cgd 	char *cp2;
   1410       1.67      matt 	struct mbuf *mb, *mreq;
   1411       1.23      fvdl 	struct vnode *vp = NULL, *dirp = NULL;
   1412       1.23      fvdl 	nfsfh_t nfh;
   1413        1.1       cgd 	fhandle_t *fhp;
   1414       1.23      fvdl 	u_quad_t frev, tempsize;
   1415       1.23      fvdl 	u_char cverf[NFSX_V3CREATEVERF];
   1416       1.82   hannken 	struct mount *mp = NULL;
   1417        1.1       cgd 
   1418       1.15   mycroft 	nd.ni_cnd.cn_nameiop = 0;
   1419        1.1       cgd 	fhp = &nfh.fh_generic;
   1420        1.1       cgd 	nfsm_srvmtofh(fhp);
   1421       1.82   hannken 	if ((mp = vfs_getvfs(&fhp->fh_fsid)) == NULL)
   1422       1.82   hannken 		return (ESTALE);
   1423       1.82   hannken 	vn_start_write(NULL, &mp, V_WAIT);
   1424       1.23      fvdl 	nfsm_srvnamesiz(len);
   1425       1.15   mycroft 	nd.ni_cnd.cn_cred = cred;
   1426       1.15   mycroft 	nd.ni_cnd.cn_nameiop = CREATE;
   1427       1.61       chs 	nd.ni_cnd.cn_flags = LOCKPARENT | LOCKLEAF;
   1428       1.23      fvdl 	error = nfs_namei(&nd, fhp, len, slp, nam, &md, &dpos,
   1429       1.99  christos 		&dirp, lwp, (nfsd->nd_flag & ND_KERBAUTH), FALSE);
   1430       1.23      fvdl 	if (dirp) {
   1431       1.23      fvdl 		if (v3)
   1432       1.99  christos 			dirfor_ret = VOP_GETATTR(dirp, &dirfor, cred, lwp);
   1433       1.23      fvdl 		else {
   1434       1.23      fvdl 			vrele(dirp);
   1435       1.23      fvdl 			dirp = (struct vnode *)0;
   1436       1.23      fvdl 		}
   1437       1.23      fvdl 	}
   1438       1.23      fvdl 	if (error) {
   1439       1.23      fvdl 		nfsm_reply(NFSX_WCCDATA(v3));
   1440       1.23      fvdl 		nfsm_srvwcc_data(dirfor_ret, &dirfor, diraft_ret, &diraft);
   1441       1.23      fvdl 		if (dirp)
   1442       1.23      fvdl 			vrele(dirp);
   1443       1.82   hannken 		vn_finished_write(mp, 0);
   1444       1.23      fvdl 		return (0);
   1445       1.23      fvdl 	}
   1446       1.18   mycroft 	VATTR_NULL(&va);
   1447       1.23      fvdl 	if (v3) {
   1448       1.92      yamt 		va.va_mode = 0;
   1449       1.23      fvdl 		nfsm_dissect(tl, u_int32_t *, NFSX_UNSIGNED);
   1450       1.23      fvdl 		how = fxdr_unsigned(int, *tl);
   1451       1.23      fvdl 		switch (how) {
   1452       1.23      fvdl 		case NFSV3CREATE_GUARDED:
   1453       1.23      fvdl 			if (nd.ni_vp) {
   1454       1.23      fvdl 				error = EEXIST;
   1455       1.23      fvdl 				break;
   1456       1.23      fvdl 			}
   1457       1.23      fvdl 		case NFSV3CREATE_UNCHECKED:
   1458       1.23      fvdl 			nfsm_srvsattr(&va);
   1459       1.23      fvdl 			break;
   1460       1.23      fvdl 		case NFSV3CREATE_EXCLUSIVE:
   1461       1.23      fvdl 			nfsm_dissect(cp, caddr_t, NFSX_V3CREATEVERF);
   1462       1.44     perry 			memcpy(cverf, cp, NFSX_V3CREATEVERF);
   1463       1.23      fvdl 			exclusive_flag = 1;
   1464       1.23      fvdl 			break;
   1465       1.23      fvdl 		};
   1466       1.23      fvdl 		va.va_type = VREG;
   1467       1.23      fvdl 	} else {
   1468       1.23      fvdl 		nfsm_dissect(sp, struct nfsv2_sattr *, NFSX_V2SATTR);
   1469       1.23      fvdl 		va.va_type = IFTOVT(fxdr_unsigned(u_int32_t, sp->sa_mode));
   1470       1.23      fvdl 		if (va.va_type == VNON)
   1471       1.23      fvdl 			va.va_type = VREG;
   1472       1.23      fvdl 		va.va_mode = nfstov_mode(sp->sa_mode);
   1473       1.23      fvdl 		switch (va.va_type) {
   1474       1.23      fvdl 		case VREG:
   1475       1.23      fvdl 			tsize = fxdr_unsigned(int32_t, sp->sa_size);
   1476       1.23      fvdl 			if (tsize != -1)
   1477       1.23      fvdl 				va.va_size = (u_quad_t)tsize;
   1478       1.23      fvdl 			break;
   1479       1.23      fvdl 		case VCHR:
   1480       1.23      fvdl 		case VBLK:
   1481       1.23      fvdl 		case VFIFO:
   1482       1.23      fvdl 			rdev = fxdr_unsigned(int32_t, sp->sa_size);
   1483       1.23      fvdl 			break;
   1484       1.23      fvdl 		default:
   1485       1.23      fvdl 			break;
   1486       1.23      fvdl 		};
   1487       1.23      fvdl 	}
   1488       1.23      fvdl 
   1489        1.1       cgd 	/*
   1490       1.15   mycroft 	 * Iff doesn't exist, create it
   1491       1.15   mycroft 	 * otherwise just truncate to 0 length
   1492        1.1       cgd 	 *   should I set the mode too ??
   1493        1.1       cgd 	 */
   1494        1.1       cgd 	if (nd.ni_vp == NULL) {
   1495       1.18   mycroft 		if (va.va_type == VREG || va.va_type == VSOCK) {
   1496       1.23      fvdl 			nqsrv_getl(nd.ni_dvp, ND_WRITE);
   1497       1.23      fvdl 			error = VOP_CREATE(nd.ni_dvp, &nd.ni_vp, &nd.ni_cnd, &va);
   1498       1.23      fvdl 			if (!error) {
   1499       1.23      fvdl 				if (exclusive_flag) {
   1500       1.23      fvdl 					exclusive_flag = 0;
   1501       1.23      fvdl 					VATTR_NULL(&va);
   1502       1.89      yamt 					/*
   1503       1.89      yamt 					 * XXX
   1504       1.89      yamt 					 * assuming NFSX_V3CREATEVERF
   1505       1.89      yamt 					 * == sizeof(nfstime3)
   1506       1.89      yamt 					 */
   1507       1.89      yamt 					fxdr_nfsv3time(cverf, &va.va_atime);
   1508       1.23      fvdl 					error = VOP_SETATTR(nd.ni_vp, &va, cred,
   1509       1.99  christos 						lwp);
   1510       1.23      fvdl 				}
   1511       1.23      fvdl 			}
   1512       1.18   mycroft 		} else if (va.va_type == VCHR || va.va_type == VBLK ||
   1513       1.18   mycroft 			va.va_type == VFIFO) {
   1514       1.18   mycroft 			if (va.va_type == VCHR && rdev == 0xffffffff)
   1515       1.18   mycroft 				va.va_type = VFIFO;
   1516       1.46       mrg 			if (va.va_type != VFIFO &&
   1517  1.101.2.2      yamt 			    (error = kauth_authorize_generic(cred,
   1518  1.101.2.2      yamt 				KAUTH_GENERIC_ISSUSER, (u_short *)0))) {
   1519       1.15   mycroft 				VOP_ABORTOP(nd.ni_dvp, &nd.ni_cnd);
   1520        1.1       cgd 				vput(nd.ni_dvp);
   1521       1.23      fvdl 				nfsm_reply(0);
   1522       1.82   hannken 				vn_finished_write(mp, 0);
   1523       1.23      fvdl 				return (error);
   1524        1.1       cgd 			} else
   1525       1.18   mycroft 				va.va_rdev = (dev_t)rdev;
   1526       1.23      fvdl 			nqsrv_getl(nd.ni_dvp, ND_WRITE);
   1527       1.22  christos 			error = VOP_MKNOD(nd.ni_dvp, &nd.ni_vp, &nd.ni_cnd,
   1528       1.23      fvdl 			    &va);
   1529       1.22  christos 			if (error) {
   1530        1.1       cgd 				nfsm_reply(0);
   1531        1.1       cgd 			}
   1532       1.15   mycroft 			if (nd.ni_cnd.cn_flags & ISSYMLINK) {
   1533        1.1       cgd 				vrele(nd.ni_dvp);
   1534        1.1       cgd 				vput(nd.ni_vp);
   1535       1.15   mycroft 				VOP_ABORTOP(nd.ni_dvp, &nd.ni_cnd);
   1536        1.1       cgd 				error = EINVAL;
   1537        1.1       cgd 				nfsm_reply(0);
   1538        1.1       cgd 			}
   1539        1.1       cgd 		} else {
   1540       1.15   mycroft 			VOP_ABORTOP(nd.ni_dvp, &nd.ni_cnd);
   1541        1.1       cgd 			vput(nd.ni_dvp);
   1542        1.1       cgd 			error = ENXIO;
   1543        1.1       cgd 		}
   1544        1.1       cgd 		vp = nd.ni_vp;
   1545        1.1       cgd 	} else {
   1546        1.1       cgd 		vp = nd.ni_vp;
   1547        1.1       cgd 		if (nd.ni_dvp == vp)
   1548        1.1       cgd 			vrele(nd.ni_dvp);
   1549        1.1       cgd 		else
   1550        1.1       cgd 			vput(nd.ni_dvp);
   1551       1.15   mycroft 		VOP_ABORTOP(nd.ni_dvp, &nd.ni_cnd);
   1552       1.50   mycroft 		if (!error && va.va_size != -1) {
   1553       1.22  christos 			error = nfsrv_access(vp, VWRITE, cred,
   1554       1.99  christos 			    (nd.ni_cnd.cn_flags & RDONLY), lwp, 0);
   1555       1.23      fvdl 			if (!error) {
   1556       1.23      fvdl 				nqsrv_getl(vp, ND_WRITE);
   1557       1.23      fvdl 				tempsize = va.va_size;
   1558       1.23      fvdl 				VATTR_NULL(&va);
   1559       1.23      fvdl 				va.va_size = tempsize;
   1560       1.99  christos 				error = VOP_SETATTR(vp, &va, cred, lwp);
   1561       1.15   mycroft 			}
   1562        1.1       cgd 		}
   1563       1.50   mycroft 		if (error)
   1564       1.50   mycroft 			vput(vp);
   1565        1.1       cgd 	}
   1566       1.23      fvdl 	if (!error) {
   1567       1.44     perry 		memset((caddr_t)fhp, 0, sizeof(nfh));
   1568       1.88  christos 		fhp->fh_fsid = vp->v_mount->mnt_stat.f_fsidx;
   1569       1.23      fvdl 		error = VFS_VPTOFH(vp, &fhp->fh_fid);
   1570       1.23      fvdl 		if (!error)
   1571       1.99  christos 			error = VOP_GETATTR(vp, &va, cred, lwp);
   1572        1.1       cgd 		vput(vp);
   1573  1.101.2.1      yamt 		KASSERT(fhp->fh_fid.fid_len <= _VFS_MAXFIDSZ);
   1574        1.1       cgd 	}
   1575       1.23      fvdl 	if (v3) {
   1576       1.89      yamt 		if (exclusive_flag && !error) {
   1577       1.89      yamt 			/*
   1578       1.89      yamt 			 * XXX assuming NFSX_V3CREATEVERF == sizeof(nfstime3)
   1579       1.89      yamt 			 */
   1580       1.89      yamt 			char oldverf[NFSX_V3CREATEVERF];
   1581       1.89      yamt 
   1582       1.89      yamt 			txdr_nfsv3time(&va.va_atime, oldverf);
   1583       1.89      yamt 			if (memcmp(cverf, oldverf, NFSX_V3CREATEVERF))
   1584       1.89      yamt 				error = EEXIST;
   1585       1.89      yamt 		}
   1586  1.101.2.2      yamt 		if (dirp) {
   1587  1.101.2.2      yamt 			diraft_ret = VOP_GETATTR(dirp, &diraft, cred, lwp);
   1588  1.101.2.2      yamt 			vrele(dirp);
   1589  1.101.2.2      yamt 		}
   1590       1.23      fvdl 	}
   1591       1.23      fvdl 	nfsm_reply(NFSX_SRVFH(v3) + NFSX_FATTR(v3) + NFSX_WCCDATA(v3));
   1592       1.23      fvdl 	if (v3) {
   1593       1.23      fvdl 		if (!error) {
   1594       1.23      fvdl 			nfsm_srvpostop_fh(fhp);
   1595       1.23      fvdl 			nfsm_srvpostop_attr(0, &va);
   1596       1.23      fvdl 		}
   1597       1.23      fvdl 		nfsm_srvwcc_data(dirfor_ret, &dirfor, diraft_ret, &diraft);
   1598       1.23      fvdl 	} else {
   1599       1.23      fvdl 		nfsm_srvfhtom(fhp, v3);
   1600       1.23      fvdl 		nfsm_build(fp, struct nfs_fattr *, NFSX_V2FATTR);
   1601       1.23      fvdl 		nfsm_srvfillattr(&va, fp);
   1602       1.23      fvdl 	}
   1603       1.82   hannken 	vn_finished_write(mp, 0);
   1604       1.23      fvdl 	return (0);
   1605        1.1       cgd nfsmout:
   1606       1.23      fvdl 	if (dirp)
   1607       1.23      fvdl 		vrele(dirp);
   1608       1.15   mycroft 	VOP_ABORTOP(nd.ni_dvp, &nd.ni_cnd);
   1609        1.1       cgd 	if (nd.ni_dvp == nd.ni_vp)
   1610        1.1       cgd 		vrele(nd.ni_dvp);
   1611        1.1       cgd 	else
   1612        1.1       cgd 		vput(nd.ni_dvp);
   1613        1.1       cgd 	if (nd.ni_vp)
   1614        1.1       cgd 		vput(nd.ni_vp);
   1615       1.82   hannken 	vn_finished_write(mp, 0);
   1616        1.1       cgd 	return (error);
   1617       1.23      fvdl }
   1618       1.23      fvdl 
   1619       1.23      fvdl /*
   1620       1.23      fvdl  * nfs v3 mknod service
   1621       1.23      fvdl  */
   1622       1.23      fvdl int
   1623       1.99  christos nfsrv_mknod(nfsd, slp, lwp, mrq)
   1624       1.23      fvdl 	struct nfsrv_descript *nfsd;
   1625       1.23      fvdl 	struct nfssvc_sock *slp;
   1626       1.99  christos 	struct lwp *lwp;
   1627       1.23      fvdl 	struct mbuf **mrq;
   1628       1.23      fvdl {
   1629       1.23      fvdl 	struct mbuf *mrep = nfsd->nd_mrep, *md = nfsd->nd_md;
   1630       1.23      fvdl 	struct mbuf *nam = nfsd->nd_nam;
   1631       1.23      fvdl 	caddr_t dpos = nfsd->nd_dpos;
   1632  1.101.2.2      yamt 	kauth_cred_t cred = nfsd->nd_cr;
   1633       1.23      fvdl 	struct vattr va, dirfor, diraft;
   1634       1.54  augustss 	u_int32_t *tl;
   1635       1.23      fvdl 	struct nameidata nd;
   1636       1.54  augustss 	int32_t t1;
   1637       1.23      fvdl 	caddr_t bpos;
   1638  1.101.2.2      yamt 	int error = 0, cache = 0, len, dirfor_ret = 1, diraft_ret = 1;
   1639       1.23      fvdl 	u_int32_t major, minor;
   1640       1.23      fvdl 	enum vtype vtyp;
   1641       1.23      fvdl 	char *cp2;
   1642       1.67      matt 	struct mbuf *mb, *mreq;
   1643       1.23      fvdl 	struct vnode *vp, *dirp = (struct vnode *)0;
   1644       1.23      fvdl 	nfsfh_t nfh;
   1645       1.23      fvdl 	fhandle_t *fhp;
   1646       1.23      fvdl 	u_quad_t frev;
   1647       1.82   hannken 	struct mount *mp = NULL;
   1648       1.23      fvdl 
   1649       1.23      fvdl 	nd.ni_cnd.cn_nameiop = 0;
   1650       1.23      fvdl 	fhp = &nfh.fh_generic;
   1651       1.23      fvdl 	nfsm_srvmtofh(fhp);
   1652       1.82   hannken 	if ((mp = vfs_getvfs(&fhp->fh_fsid)) == NULL)
   1653       1.82   hannken 		return (ESTALE);
   1654       1.82   hannken 	vn_start_write(NULL, &mp, V_WAIT);
   1655       1.23      fvdl 	nfsm_srvnamesiz(len);
   1656       1.23      fvdl 	nd.ni_cnd.cn_cred = cred;
   1657       1.23      fvdl 	nd.ni_cnd.cn_nameiop = CREATE;
   1658       1.61       chs 	nd.ni_cnd.cn_flags = LOCKPARENT | LOCKLEAF;
   1659       1.23      fvdl 	error = nfs_namei(&nd, fhp, len, slp, nam, &md, &dpos,
   1660       1.99  christos 		&dirp, lwp, (nfsd->nd_flag & ND_KERBAUTH), FALSE);
   1661       1.23      fvdl 	if (dirp)
   1662       1.99  christos 		dirfor_ret = VOP_GETATTR(dirp, &dirfor, cred, lwp);
   1663       1.23      fvdl 	if (error) {
   1664       1.23      fvdl 		nfsm_reply(NFSX_WCCDATA(1));
   1665       1.23      fvdl 		nfsm_srvwcc_data(dirfor_ret, &dirfor, diraft_ret, &diraft);
   1666       1.23      fvdl 		if (dirp)
   1667       1.23      fvdl 			vrele(dirp);
   1668       1.82   hannken 		vn_finished_write(mp, 0);
   1669       1.23      fvdl 		return (0);
   1670       1.23      fvdl 	}
   1671       1.23      fvdl 	nfsm_dissect(tl, u_int32_t *, NFSX_UNSIGNED);
   1672       1.23      fvdl 	vtyp = nfsv3tov_type(*tl);
   1673       1.23      fvdl 	if (vtyp != VCHR && vtyp != VBLK && vtyp != VSOCK && vtyp != VFIFO) {
   1674       1.23      fvdl 		error = NFSERR_BADTYPE;
   1675       1.95      yamt 		goto abort;
   1676       1.23      fvdl 	}
   1677       1.23      fvdl 	VATTR_NULL(&va);
   1678       1.92      yamt 	va.va_mode = 0;
   1679       1.23      fvdl 	nfsm_srvsattr(&va);
   1680       1.23      fvdl 	if (vtyp == VCHR || vtyp == VBLK) {
   1681       1.95      yamt 		dev_t rdev;
   1682       1.95      yamt 
   1683       1.23      fvdl 		nfsm_dissect(tl, u_int32_t *, 2 * NFSX_UNSIGNED);
   1684       1.23      fvdl 		major = fxdr_unsigned(u_int32_t, *tl++);
   1685       1.23      fvdl 		minor = fxdr_unsigned(u_int32_t, *tl);
   1686       1.95      yamt 		rdev = makedev(major, minor);
   1687       1.95      yamt 		if (major(rdev) != major || minor(rdev) != minor) {
   1688       1.95      yamt 			error = EINVAL;
   1689       1.95      yamt 			goto abort;
   1690       1.95      yamt 		}
   1691       1.95      yamt 		va.va_rdev = rdev;
   1692       1.23      fvdl 	}
   1693        1.1       cgd 
   1694       1.23      fvdl 	/*
   1695       1.23      fvdl 	 * Iff doesn't exist, create it.
   1696       1.23      fvdl 	 */
   1697       1.23      fvdl 	if (nd.ni_vp) {
   1698       1.23      fvdl 		error = EEXIST;
   1699       1.95      yamt abort:
   1700       1.23      fvdl 		VOP_ABORTOP(nd.ni_dvp, &nd.ni_cnd);
   1701       1.51  sommerfe 		if (nd.ni_dvp == nd.ni_vp)
   1702       1.51  sommerfe 			vrele(nd.ni_dvp);
   1703       1.51  sommerfe 		else
   1704       1.51  sommerfe 			vput(nd.ni_dvp);
   1705       1.95      yamt 		if (nd.ni_vp)
   1706       1.95      yamt 			vput(nd.ni_vp);
   1707       1.23      fvdl 		goto out;
   1708       1.23      fvdl 	}
   1709       1.23      fvdl 	va.va_type = vtyp;
   1710       1.23      fvdl 	if (vtyp == VSOCK) {
   1711       1.23      fvdl 		nqsrv_getl(nd.ni_dvp, ND_WRITE);
   1712       1.23      fvdl 		error = VOP_CREATE(nd.ni_dvp, &nd.ni_vp, &nd.ni_cnd, &va);
   1713       1.23      fvdl 	} else {
   1714       1.46       mrg 		if (va.va_type != VFIFO &&
   1715  1.101.2.2      yamt 		    (error = kauth_authorize_generic(cred, KAUTH_GENERIC_ISSUSER,
   1716  1.101.2.2      yamt 			(u_short *)0))) {
   1717       1.23      fvdl 			VOP_ABORTOP(nd.ni_dvp, &nd.ni_cnd);
   1718       1.23      fvdl 			vput(nd.ni_dvp);
   1719       1.23      fvdl 			goto out;
   1720       1.23      fvdl 		}
   1721       1.23      fvdl 		nqsrv_getl(nd.ni_dvp, ND_WRITE);
   1722       1.23      fvdl 		error = VOP_MKNOD(nd.ni_dvp, &nd.ni_vp, &nd.ni_cnd, &va);
   1723       1.23      fvdl 		if (error)
   1724       1.23      fvdl 			goto out;
   1725       1.23      fvdl 		if (nd.ni_cnd.cn_flags & ISSYMLINK) {
   1726       1.23      fvdl 			vput(nd.ni_vp);
   1727       1.23      fvdl 			VOP_ABORTOP(nd.ni_dvp, &nd.ni_cnd);
   1728       1.23      fvdl 			error = EINVAL;
   1729       1.23      fvdl 		}
   1730       1.23      fvdl 	}
   1731        1.1       cgd out:
   1732       1.23      fvdl 	vp = nd.ni_vp;
   1733       1.23      fvdl 	if (!error) {
   1734       1.44     perry 		memset((caddr_t)fhp, 0, sizeof(nfh));
   1735       1.88  christos 		fhp->fh_fsid = vp->v_mount->mnt_stat.f_fsidx;
   1736       1.23      fvdl 		error = VFS_VPTOFH(vp, &fhp->fh_fid);
   1737       1.23      fvdl 		if (!error)
   1738       1.99  christos 			error = VOP_GETATTR(vp, &va, cred, lwp);
   1739       1.23      fvdl 		vput(vp);
   1740  1.101.2.1      yamt 		KASSERT(fhp->fh_fid.fid_len <= _VFS_MAXFIDSZ);
   1741       1.23      fvdl 	}
   1742  1.101.2.2      yamt 	if (dirp) {
   1743  1.101.2.2      yamt 		diraft_ret = VOP_GETATTR(dirp, &diraft, cred, lwp);
   1744  1.101.2.2      yamt 		vrele(dirp);
   1745  1.101.2.2      yamt 	}
   1746       1.23      fvdl 	nfsm_reply(NFSX_SRVFH(1) + NFSX_POSTOPATTR(1) + NFSX_WCCDATA(1));
   1747       1.23      fvdl 	if (!error) {
   1748       1.23      fvdl 		nfsm_srvpostop_fh(fhp);
   1749       1.23      fvdl 		nfsm_srvpostop_attr(0, &va);
   1750       1.23      fvdl 	}
   1751       1.23      fvdl 	nfsm_srvwcc_data(dirfor_ret, &dirfor, diraft_ret, &diraft);
   1752       1.82   hannken 	vn_finished_write(mp, 0);
   1753       1.23      fvdl 	return (0);
   1754       1.23      fvdl nfsmout:
   1755       1.23      fvdl 	if (dirp)
   1756       1.23      fvdl 		vrele(dirp);
   1757       1.23      fvdl 	VOP_ABORTOP(nd.ni_dvp, &nd.ni_cnd);
   1758       1.23      fvdl 	if (nd.ni_dvp == nd.ni_vp)
   1759       1.23      fvdl 		vrele(nd.ni_dvp);
   1760       1.23      fvdl 	else
   1761       1.23      fvdl 		vput(nd.ni_dvp);
   1762       1.23      fvdl 	if (nd.ni_vp)
   1763       1.23      fvdl 		vput(nd.ni_vp);
   1764       1.82   hannken 	vn_finished_write(mp, 0);
   1765       1.23      fvdl 	return (error);
   1766        1.1       cgd }
   1767        1.1       cgd 
   1768        1.1       cgd /*
   1769        1.1       cgd  * nfs remove service
   1770        1.1       cgd  */
   1771       1.22  christos int
   1772       1.99  christos nfsrv_remove(nfsd, slp, lwp, mrq)
   1773       1.23      fvdl 	struct nfsrv_descript *nfsd;
   1774       1.23      fvdl 	struct nfssvc_sock *slp;
   1775       1.99  christos 	struct lwp *lwp;
   1776       1.23      fvdl 	struct mbuf **mrq;
   1777        1.1       cgd {
   1778       1.23      fvdl 	struct mbuf *mrep = nfsd->nd_mrep, *md = nfsd->nd_md;
   1779       1.23      fvdl 	struct mbuf *nam = nfsd->nd_nam;
   1780       1.23      fvdl 	caddr_t dpos = nfsd->nd_dpos;
   1781  1.101.2.2      yamt 	kauth_cred_t cred = nfsd->nd_cr;
   1782        1.1       cgd 	struct nameidata nd;
   1783       1.54  augustss 	u_int32_t *tl;
   1784       1.54  augustss 	int32_t t1;
   1785        1.1       cgd 	caddr_t bpos;
   1786  1.101.2.2      yamt 	int error = 0, cache = 0, len, dirfor_ret = 1, diraft_ret = 1;
   1787       1.23      fvdl 	int v3 = (nfsd->nd_flag & ND_NFSV3);
   1788        1.1       cgd 	char *cp2;
   1789        1.1       cgd 	struct mbuf *mb, *mreq;
   1790       1.23      fvdl 	struct vnode *vp, *dirp;
   1791       1.23      fvdl 	struct vattr dirfor, diraft;
   1792       1.23      fvdl 	nfsfh_t nfh;
   1793        1.1       cgd 	fhandle_t *fhp;
   1794       1.15   mycroft 	u_quad_t frev;
   1795       1.82   hannken 	struct mount *mp = NULL;
   1796        1.1       cgd 
   1797       1.23      fvdl #ifndef nolint
   1798       1.23      fvdl 	vp = (struct vnode *)0;
   1799       1.23      fvdl #endif
   1800        1.1       cgd 	fhp = &nfh.fh_generic;
   1801        1.1       cgd 	nfsm_srvmtofh(fhp);
   1802       1.82   hannken 	if ((mp = vfs_getvfs(&fhp->fh_fsid)) == NULL)
   1803       1.82   hannken 		return (ESTALE);
   1804       1.82   hannken 	vn_start_write(NULL, &mp, V_WAIT);
   1805       1.23      fvdl 	nfsm_srvnamesiz(len);
   1806       1.15   mycroft 	nd.ni_cnd.cn_cred = cred;
   1807       1.15   mycroft 	nd.ni_cnd.cn_nameiop = DELETE;
   1808       1.15   mycroft 	nd.ni_cnd.cn_flags = LOCKPARENT | LOCKLEAF;
   1809       1.23      fvdl 	error = nfs_namei(&nd, fhp, len, slp, nam, &md, &dpos,
   1810       1.99  christos 		&dirp, lwp, (nfsd->nd_flag & ND_KERBAUTH), FALSE);
   1811       1.23      fvdl 	if (dirp) {
   1812       1.23      fvdl 		if (v3)
   1813       1.99  christos 			dirfor_ret = VOP_GETATTR(dirp, &dirfor, cred, lwp);
   1814        1.1       cgd 		else
   1815       1.23      fvdl 			vrele(dirp);
   1816        1.1       cgd 	}
   1817       1.23      fvdl 	if (!error) {
   1818       1.23      fvdl 		vp = nd.ni_vp;
   1819       1.23      fvdl 		if (vp->v_type == VDIR &&
   1820  1.101.2.2      yamt 		    (error = kauth_authorize_generic(cred, KAUTH_GENERIC_ISSUSER,
   1821  1.101.2.2      yamt 				(u_short *)0)) != 0)
   1822       1.23      fvdl 			goto out;
   1823       1.23      fvdl 		/*
   1824       1.23      fvdl 		 * The root of a mounted filesystem cannot be deleted.
   1825       1.23      fvdl 		 */
   1826       1.23      fvdl 		if (vp->v_flag & VROOT) {
   1827       1.23      fvdl 			error = EBUSY;
   1828       1.23      fvdl 			goto out;
   1829       1.23      fvdl 		}
   1830       1.21   mycroft out:
   1831       1.23      fvdl 		if (!error) {
   1832       1.23      fvdl 			nqsrv_getl(nd.ni_dvp, ND_WRITE);
   1833       1.23      fvdl 			nqsrv_getl(vp, ND_WRITE);
   1834       1.23      fvdl 			error = VOP_REMOVE(nd.ni_dvp, nd.ni_vp, &nd.ni_cnd);
   1835       1.23      fvdl 		} else {
   1836       1.23      fvdl 			VOP_ABORTOP(nd.ni_dvp, &nd.ni_cnd);
   1837       1.23      fvdl 			if (nd.ni_dvp == vp)
   1838       1.23      fvdl 				vrele(nd.ni_dvp);
   1839       1.23      fvdl 			else
   1840       1.23      fvdl 				vput(nd.ni_dvp);
   1841       1.23      fvdl 			vput(vp);
   1842       1.23      fvdl 		}
   1843       1.23      fvdl 	}
   1844       1.23      fvdl 	if (dirp && v3) {
   1845       1.99  christos 		diraft_ret = VOP_GETATTR(dirp, &diraft, cred, lwp);
   1846       1.23      fvdl 		vrele(dirp);
   1847       1.23      fvdl 	}
   1848       1.23      fvdl 	nfsm_reply(NFSX_WCCDATA(v3));
   1849       1.23      fvdl 	if (v3) {
   1850       1.23      fvdl 		nfsm_srvwcc_data(dirfor_ret, &dirfor, diraft_ret, &diraft);
   1851       1.82   hannken 		vn_finished_write(mp, 0);
   1852       1.23      fvdl 		return (0);
   1853       1.23      fvdl 	}
   1854       1.82   hannken 	vn_finished_write(mp, 0);
   1855        1.1       cgd 	nfsm_srvdone;
   1856        1.1       cgd }
   1857        1.1       cgd 
   1858        1.1       cgd /*
   1859        1.1       cgd  * nfs rename service
   1860        1.1       cgd  */
   1861       1.22  christos int
   1862       1.99  christos nfsrv_rename(nfsd, slp, lwp, mrq)
   1863       1.23      fvdl 	struct nfsrv_descript *nfsd;
   1864       1.23      fvdl 	struct nfssvc_sock *slp;
   1865       1.99  christos 	struct lwp *lwp;
   1866       1.23      fvdl 	struct mbuf **mrq;
   1867        1.1       cgd {
   1868       1.23      fvdl 	struct mbuf *mrep = nfsd->nd_mrep, *md = nfsd->nd_md;
   1869       1.23      fvdl 	struct mbuf *nam = nfsd->nd_nam;
   1870       1.23      fvdl 	caddr_t dpos = nfsd->nd_dpos;
   1871  1.101.2.2      yamt 	kauth_cred_t cred = nfsd->nd_cr;
   1872       1.54  augustss 	u_int32_t *tl;
   1873       1.54  augustss 	int32_t t1;
   1874        1.1       cgd 	caddr_t bpos;
   1875  1.101.2.2      yamt 	int error = 0, cache = 0, fdirfor_ret = 1, fdiraft_ret = 1;
   1876       1.68      yamt 	uint32_t len, len2;
   1877       1.23      fvdl 	int tdirfor_ret = 1, tdiraft_ret = 1;
   1878       1.23      fvdl 	int v3 = (nfsd->nd_flag & ND_NFSV3);
   1879        1.1       cgd 	char *cp2;
   1880        1.1       cgd 	struct mbuf *mb, *mreq;
   1881        1.1       cgd 	struct nameidata fromnd, tond;
   1882       1.23      fvdl 	struct vnode *fvp, *tvp, *tdvp, *fdirp = (struct vnode *)0;
   1883       1.23      fvdl 	struct vnode *tdirp = (struct vnode *)0;
   1884       1.23      fvdl 	struct vattr fdirfor, fdiraft, tdirfor, tdiraft;
   1885       1.23      fvdl 	nfsfh_t fnfh, tnfh;
   1886        1.1       cgd 	fhandle_t *ffhp, *tfhp;
   1887       1.15   mycroft 	u_quad_t frev;
   1888       1.15   mycroft 	uid_t saved_uid;
   1889       1.82   hannken 	struct mount *mp = NULL;
   1890        1.1       cgd 
   1891       1.23      fvdl #ifndef nolint
   1892       1.23      fvdl 	fvp = (struct vnode *)0;
   1893       1.23      fvdl #endif
   1894        1.1       cgd 	ffhp = &fnfh.fh_generic;
   1895        1.1       cgd 	tfhp = &tnfh.fh_generic;
   1896       1.15   mycroft 	fromnd.ni_cnd.cn_nameiop = 0;
   1897       1.15   mycroft 	tond.ni_cnd.cn_nameiop = 0;
   1898        1.1       cgd 	nfsm_srvmtofh(ffhp);
   1899       1.82   hannken 	if ((mp = vfs_getvfs(&ffhp->fh_fsid)) == NULL)
   1900       1.82   hannken 		return (ESTALE);
   1901       1.82   hannken 	vn_start_write(NULL, &mp, V_WAIT);
   1902       1.23      fvdl 	nfsm_srvnamesiz(len);
   1903        1.1       cgd 	/*
   1904       1.15   mycroft 	 * Remember our original uid so that we can reset cr_uid before
   1905       1.15   mycroft 	 * the second nfs_namei() call, in case it is remapped.
   1906        1.1       cgd 	 */
   1907  1.101.2.2      yamt 	saved_uid = kauth_cred_geteuid(cred);
   1908       1.15   mycroft 	fromnd.ni_cnd.cn_cred = cred;
   1909       1.15   mycroft 	fromnd.ni_cnd.cn_nameiop = DELETE;
   1910       1.15   mycroft 	fromnd.ni_cnd.cn_flags = WANTPARENT | SAVESTART;
   1911       1.23      fvdl 	error = nfs_namei(&fromnd, ffhp, len, slp, nam, &md,
   1912       1.99  christos 		&dpos, &fdirp, lwp, (nfsd->nd_flag & ND_KERBAUTH), FALSE);
   1913       1.23      fvdl 	if (fdirp) {
   1914       1.23      fvdl 		if (v3)
   1915       1.99  christos 			fdirfor_ret = VOP_GETATTR(fdirp, &fdirfor, cred, lwp);
   1916       1.23      fvdl 		else {
   1917       1.23      fvdl 			vrele(fdirp);
   1918       1.23      fvdl 			fdirp = (struct vnode *)0;
   1919       1.23      fvdl 		}
   1920       1.23      fvdl 	}
   1921       1.23      fvdl 	if (error) {
   1922       1.23      fvdl 		nfsm_reply(2 * NFSX_WCCDATA(v3));
   1923       1.23      fvdl 		nfsm_srvwcc_data(fdirfor_ret, &fdirfor, fdiraft_ret, &fdiraft);
   1924       1.23      fvdl 		nfsm_srvwcc_data(tdirfor_ret, &tdirfor, tdiraft_ret, &tdiraft);
   1925       1.23      fvdl 		if (fdirp)
   1926       1.23      fvdl 			vrele(fdirp);
   1927       1.82   hannken 		vn_finished_write(mp, 0);
   1928       1.23      fvdl 		return (0);
   1929       1.23      fvdl 	}
   1930        1.1       cgd 	fvp = fromnd.ni_vp;
   1931        1.1       cgd 	nfsm_srvmtofh(tfhp);
   1932       1.68      yamt 	if (v3) {
   1933       1.68      yamt 		nfsm_dissect(tl, uint32_t *, NFSX_UNSIGNED);
   1934       1.68      yamt 		len2 = fxdr_unsigned(uint32_t, *tl);
   1935       1.68      yamt 		/* len2 will be checked by nfs_namei */
   1936       1.68      yamt 	}
   1937       1.68      yamt 	else {
   1938       1.68      yamt 		/* NFSv2 */
   1939       1.68      yamt 		nfsm_strsiz(len2, NFS_MAXNAMLEN);
   1940       1.68      yamt 	}
   1941  1.101.2.2      yamt 	kauth_cred_seteuid(cred, saved_uid);
   1942       1.15   mycroft 	tond.ni_cnd.cn_cred = cred;
   1943       1.15   mycroft 	tond.ni_cnd.cn_nameiop = RENAME;
   1944       1.15   mycroft 	tond.ni_cnd.cn_flags = LOCKPARENT | LOCKLEAF | NOCACHE | SAVESTART;
   1945       1.23      fvdl 	error = nfs_namei(&tond, tfhp, len2, slp, nam, &md,
   1946       1.99  christos 		&dpos, &tdirp, lwp, (nfsd->nd_flag & ND_KERBAUTH), FALSE);
   1947       1.23      fvdl 	if (tdirp) {
   1948       1.23      fvdl 		if (v3)
   1949       1.99  christos 			tdirfor_ret = VOP_GETATTR(tdirp, &tdirfor, cred, lwp);
   1950       1.23      fvdl 		else {
   1951       1.23      fvdl 			vrele(tdirp);
   1952       1.23      fvdl 			tdirp = (struct vnode *)0;
   1953       1.23      fvdl 		}
   1954       1.23      fvdl 	}
   1955       1.22  christos 	if (error) {
   1956       1.15   mycroft 		VOP_ABORTOP(fromnd.ni_dvp, &fromnd.ni_cnd);
   1957        1.1       cgd 		vrele(fromnd.ni_dvp);
   1958        1.1       cgd 		vrele(fvp);
   1959        1.1       cgd 		goto out1;
   1960        1.1       cgd 	}
   1961        1.1       cgd 	tdvp = tond.ni_dvp;
   1962        1.1       cgd 	tvp = tond.ni_vp;
   1963        1.1       cgd 	if (tvp != NULL) {
   1964        1.1       cgd 		if (fvp->v_type == VDIR && tvp->v_type != VDIR) {
   1965       1.23      fvdl 			if (v3)
   1966       1.23      fvdl 				error = EEXIST;
   1967       1.23      fvdl 			else
   1968       1.23      fvdl 				error = EISDIR;
   1969        1.1       cgd 			goto out;
   1970        1.1       cgd 		} else if (fvp->v_type != VDIR && tvp->v_type == VDIR) {
   1971       1.23      fvdl 			if (v3)
   1972       1.23      fvdl 				error = EEXIST;
   1973       1.23      fvdl 			else
   1974       1.23      fvdl 				error = ENOTDIR;
   1975        1.1       cgd 			goto out;
   1976        1.1       cgd 		}
   1977       1.15   mycroft 		if (tvp->v_type == VDIR && tvp->v_mountedhere) {
   1978       1.23      fvdl 			if (v3)
   1979       1.23      fvdl 				error = EXDEV;
   1980       1.23      fvdl 			else
   1981       1.23      fvdl 				error = ENOTEMPTY;
   1982       1.15   mycroft 			goto out;
   1983       1.15   mycroft 		}
   1984       1.15   mycroft 	}
   1985       1.15   mycroft 	if (fvp->v_type == VDIR && fvp->v_mountedhere) {
   1986       1.23      fvdl 		if (v3)
   1987       1.23      fvdl 			error = EXDEV;
   1988       1.23      fvdl 		else
   1989       1.23      fvdl 			error = ENOTEMPTY;
   1990       1.15   mycroft 		goto out;
   1991        1.1       cgd 	}
   1992        1.1       cgd 	if (fvp->v_mount != tdvp->v_mount) {
   1993       1.23      fvdl 		if (v3)
   1994       1.23      fvdl 			error = EXDEV;
   1995       1.23      fvdl 		else
   1996       1.23      fvdl 			error = ENOTEMPTY;
   1997        1.1       cgd 		goto out;
   1998        1.1       cgd 	}
   1999       1.45   thorpej 	if (fvp == tdvp) {
   2000       1.23      fvdl 		if (v3)
   2001       1.23      fvdl 			error = EINVAL;
   2002       1.23      fvdl 		else
   2003       1.23      fvdl 			error = ENOTEMPTY;
   2004       1.45   thorpej 	}
   2005        1.1       cgd 	/*
   2006        1.1       cgd 	 * If source is the same as the destination (that is the
   2007        1.1       cgd 	 * same vnode with the same name in the same directory),
   2008        1.1       cgd 	 * then there is nothing to do.
   2009        1.1       cgd 	 */
   2010        1.1       cgd 	if (fvp == tvp && fromnd.ni_dvp == tdvp &&
   2011       1.15   mycroft 	    fromnd.ni_cnd.cn_namelen == tond.ni_cnd.cn_namelen &&
   2012       1.44     perry 	    !memcmp(fromnd.ni_cnd.cn_nameptr, tond.ni_cnd.cn_nameptr,
   2013       1.15   mycroft 	      fromnd.ni_cnd.cn_namelen))
   2014        1.1       cgd 		error = -1;
   2015        1.1       cgd out:
   2016        1.1       cgd 	if (!error) {
   2017       1.23      fvdl 		nqsrv_getl(fromnd.ni_dvp, ND_WRITE);
   2018       1.23      fvdl 		nqsrv_getl(tdvp, ND_WRITE);
   2019       1.30      fvdl 		if (tvp) {
   2020       1.23      fvdl 			nqsrv_getl(tvp, ND_WRITE);
   2021       1.30      fvdl 		}
   2022       1.15   mycroft 		error = VOP_RENAME(fromnd.ni_dvp, fromnd.ni_vp, &fromnd.ni_cnd,
   2023       1.15   mycroft 				   tond.ni_dvp, tond.ni_vp, &tond.ni_cnd);
   2024        1.1       cgd 	} else {
   2025       1.15   mycroft 		VOP_ABORTOP(tond.ni_dvp, &tond.ni_cnd);
   2026        1.1       cgd 		if (tdvp == tvp)
   2027        1.1       cgd 			vrele(tdvp);
   2028        1.1       cgd 		else
   2029        1.1       cgd 			vput(tdvp);
   2030        1.1       cgd 		if (tvp)
   2031        1.1       cgd 			vput(tvp);
   2032       1.15   mycroft 		VOP_ABORTOP(fromnd.ni_dvp, &fromnd.ni_cnd);
   2033        1.1       cgd 		vrele(fromnd.ni_dvp);
   2034        1.1       cgd 		vrele(fvp);
   2035       1.23      fvdl 		if (error == -1)
   2036       1.23      fvdl 			error = 0;
   2037        1.1       cgd 	}
   2038        1.1       cgd 	vrele(tond.ni_startdir);
   2039       1.57   thorpej 	PNBUF_PUT(tond.ni_cnd.cn_pnbuf);
   2040        1.1       cgd out1:
   2041       1.23      fvdl 	if (fdirp) {
   2042       1.99  christos 		fdiraft_ret = VOP_GETATTR(fdirp, &fdiraft, cred, lwp);
   2043       1.23      fvdl 		vrele(fdirp);
   2044       1.23      fvdl 	}
   2045       1.23      fvdl 	if (tdirp) {
   2046       1.99  christos 		tdiraft_ret = VOP_GETATTR(tdirp, &tdiraft, cred, lwp);
   2047       1.23      fvdl 		vrele(tdirp);
   2048       1.23      fvdl 	}
   2049        1.1       cgd 	vrele(fromnd.ni_startdir);
   2050       1.57   thorpej 	PNBUF_PUT(fromnd.ni_cnd.cn_pnbuf);
   2051       1.23      fvdl 	nfsm_reply(2 * NFSX_WCCDATA(v3));
   2052       1.23      fvdl 	if (v3) {
   2053       1.23      fvdl 		nfsm_srvwcc_data(fdirfor_ret, &fdirfor, fdiraft_ret, &fdiraft);
   2054       1.23      fvdl 		nfsm_srvwcc_data(tdirfor_ret, &tdirfor, tdiraft_ret, &tdiraft);
   2055       1.23      fvdl 	}
   2056       1.82   hannken 	vn_finished_write(mp, 0);
   2057       1.23      fvdl 	return (0);
   2058        1.1       cgd 
   2059        1.1       cgd nfsmout:
   2060       1.23      fvdl 	if (fdirp)
   2061       1.23      fvdl 		vrele(fdirp);
   2062  1.101.2.2      yamt #ifdef notdef
   2063       1.23      fvdl 	if (tdirp)
   2064       1.23      fvdl 		vrele(tdirp);
   2065  1.101.2.2      yamt #endif
   2066       1.23      fvdl 	if (tond.ni_cnd.cn_nameiop) {
   2067        1.1       cgd 		vrele(tond.ni_startdir);
   2068       1.57   thorpej 		PNBUF_PUT(tond.ni_cnd.cn_pnbuf);
   2069        1.1       cgd 	}
   2070       1.23      fvdl 	if (fromnd.ni_cnd.cn_nameiop) {
   2071        1.1       cgd 		vrele(fromnd.ni_startdir);
   2072       1.57   thorpej 		PNBUF_PUT(fromnd.ni_cnd.cn_pnbuf);
   2073       1.15   mycroft 		VOP_ABORTOP(fromnd.ni_dvp, &fromnd.ni_cnd);
   2074        1.1       cgd 		vrele(fromnd.ni_dvp);
   2075        1.1       cgd 		vrele(fvp);
   2076        1.1       cgd 	}
   2077        1.1       cgd 	return (error);
   2078        1.1       cgd }
   2079        1.1       cgd 
   2080        1.1       cgd /*
   2081        1.1       cgd  * nfs link service
   2082        1.1       cgd  */
   2083       1.22  christos int
   2084       1.99  christos nfsrv_link(nfsd, slp, lwp, mrq)
   2085       1.23      fvdl 	struct nfsrv_descript *nfsd;
   2086       1.23      fvdl 	struct nfssvc_sock *slp;
   2087       1.99  christos 	struct lwp *lwp;
   2088       1.23      fvdl 	struct mbuf **mrq;
   2089        1.1       cgd {
   2090       1.23      fvdl 	struct mbuf *mrep = nfsd->nd_mrep, *md = nfsd->nd_md;
   2091       1.23      fvdl 	struct mbuf *nam = nfsd->nd_nam;
   2092       1.23      fvdl 	caddr_t dpos = nfsd->nd_dpos;
   2093  1.101.2.2      yamt 	kauth_cred_t cred = nfsd->nd_cr;
   2094        1.1       cgd 	struct nameidata nd;
   2095       1.54  augustss 	u_int32_t *tl;
   2096       1.54  augustss 	int32_t t1;
   2097        1.1       cgd 	caddr_t bpos;
   2098  1.101.2.2      yamt 	int error = 0, rdonly, cache = 0, len, dirfor_ret = 1, diraft_ret = 1;
   2099       1.23      fvdl 	int getret = 1, v3 = (nfsd->nd_flag & ND_NFSV3);
   2100        1.1       cgd 	char *cp2;
   2101        1.1       cgd 	struct mbuf *mb, *mreq;
   2102       1.23      fvdl 	struct vnode *vp, *xp, *dirp = (struct vnode *)0;
   2103       1.23      fvdl 	struct vattr dirfor, diraft, at;
   2104       1.23      fvdl 	nfsfh_t nfh, dnfh;
   2105        1.1       cgd 	fhandle_t *fhp, *dfhp;
   2106       1.15   mycroft 	u_quad_t frev;
   2107       1.82   hannken 	struct mount *mp = NULL;
   2108        1.1       cgd 
   2109        1.1       cgd 	fhp = &nfh.fh_generic;
   2110        1.1       cgd 	dfhp = &dnfh.fh_generic;
   2111        1.1       cgd 	nfsm_srvmtofh(fhp);
   2112       1.82   hannken 	if ((mp = vfs_getvfs(&fhp->fh_fsid)) == NULL)
   2113       1.82   hannken 		return (ESTALE);
   2114       1.82   hannken 	vn_start_write(NULL, &mp, V_WAIT);
   2115        1.1       cgd 	nfsm_srvmtofh(dfhp);
   2116       1.23      fvdl 	nfsm_srvnamesiz(len);
   2117       1.23      fvdl 	error = nfsrv_fhtovp(fhp, FALSE, &vp, cred, slp, nam,
   2118       1.78   thorpej 		 &rdonly, (nfsd->nd_flag & ND_KERBAUTH), FALSE);
   2119       1.23      fvdl 	if (error) {
   2120       1.23      fvdl 		nfsm_reply(NFSX_POSTOPATTR(v3) + NFSX_WCCDATA(v3));
   2121       1.23      fvdl 		nfsm_srvpostop_attr(getret, &at);
   2122       1.23      fvdl 		nfsm_srvwcc_data(dirfor_ret, &dirfor, diraft_ret, &diraft);
   2123       1.82   hannken 		vn_finished_write(mp, 0);
   2124       1.23      fvdl 		return (0);
   2125       1.23      fvdl 	}
   2126  1.101.2.2      yamt 	if (vp->v_type == VDIR && (error = kauth_authorize_generic(cred,
   2127  1.101.2.2      yamt 					KAUTH_GENERIC_ISSUSER, (u_short *)0)) != 0)
   2128       1.23      fvdl 		goto out1;
   2129       1.15   mycroft 	nd.ni_cnd.cn_cred = cred;
   2130       1.15   mycroft 	nd.ni_cnd.cn_nameiop = CREATE;
   2131       1.15   mycroft 	nd.ni_cnd.cn_flags = LOCKPARENT;
   2132       1.23      fvdl 	error = nfs_namei(&nd, dfhp, len, slp, nam, &md, &dpos,
   2133       1.99  christos 		&dirp, lwp, (nfsd->nd_flag & ND_KERBAUTH), FALSE);
   2134       1.23      fvdl 	if (dirp) {
   2135       1.23      fvdl 		if (v3)
   2136       1.99  christos 			dirfor_ret = VOP_GETATTR(dirp, &dirfor, cred, lwp);
   2137       1.23      fvdl 		else {
   2138       1.23      fvdl 			vrele(dirp);
   2139       1.23      fvdl 			dirp = (struct vnode *)0;
   2140       1.23      fvdl 		}
   2141       1.23      fvdl 	}
   2142       1.22  christos 	if (error)
   2143       1.23      fvdl 		goto out1;
   2144       1.23      fvdl 	xp = nd.ni_vp;
   2145       1.23      fvdl 	if (xp != NULL) {
   2146       1.23      fvdl 		error = EEXIST;
   2147        1.1       cgd 		goto out;
   2148       1.23      fvdl 	}
   2149       1.23      fvdl 	xp = nd.ni_dvp;
   2150       1.23      fvdl 	if (vp->v_mount != xp->v_mount)
   2151       1.23      fvdl 		error = EXDEV;
   2152       1.23      fvdl out:
   2153       1.23      fvdl 	if (!error) {
   2154       1.23      fvdl 		nqsrv_getl(vp, ND_WRITE);
   2155       1.23      fvdl 		nqsrv_getl(xp, ND_WRITE);
   2156       1.23      fvdl 		error = VOP_LINK(nd.ni_dvp, vp, &nd.ni_cnd);
   2157       1.23      fvdl 	} else {
   2158       1.15   mycroft 		VOP_ABORTOP(nd.ni_dvp, &nd.ni_cnd);
   2159        1.1       cgd 		if (nd.ni_dvp == nd.ni_vp)
   2160        1.1       cgd 			vrele(nd.ni_dvp);
   2161        1.1       cgd 		else
   2162        1.1       cgd 			vput(nd.ni_dvp);
   2163       1.23      fvdl 		if (nd.ni_vp)
   2164       1.23      fvdl 			vrele(nd.ni_vp);
   2165       1.23      fvdl 	}
   2166       1.23      fvdl out1:
   2167       1.23      fvdl 	if (v3)
   2168       1.99  christos 		getret = VOP_GETATTR(vp, &at, cred, lwp);
   2169       1.23      fvdl 	if (dirp) {
   2170       1.99  christos 		diraft_ret = VOP_GETATTR(dirp, &diraft, cred, lwp);
   2171       1.23      fvdl 		vrele(dirp);
   2172        1.1       cgd 	}
   2173        1.1       cgd 	vrele(vp);
   2174       1.23      fvdl 	nfsm_reply(NFSX_POSTOPATTR(v3) + NFSX_WCCDATA(v3));
   2175       1.23      fvdl 	if (v3) {
   2176       1.23      fvdl 		nfsm_srvpostop_attr(getret, &at);
   2177       1.23      fvdl 		nfsm_srvwcc_data(dirfor_ret, &dirfor, diraft_ret, &diraft);
   2178       1.82   hannken 		vn_finished_write(mp, 0);
   2179       1.23      fvdl 		return (0);
   2180       1.23      fvdl 	}
   2181       1.82   hannken 	vn_finished_write(mp, 0);
   2182        1.1       cgd 	nfsm_srvdone;
   2183        1.1       cgd }
   2184        1.1       cgd 
   2185        1.1       cgd /*
   2186        1.1       cgd  * nfs symbolic link service
   2187        1.1       cgd  */
   2188       1.22  christos int
   2189       1.99  christos nfsrv_symlink(nfsd, slp, lwp, mrq)
   2190       1.23      fvdl 	struct nfsrv_descript *nfsd;
   2191       1.23      fvdl 	struct nfssvc_sock *slp;
   2192       1.99  christos 	struct lwp *lwp;
   2193       1.23      fvdl 	struct mbuf **mrq;
   2194        1.1       cgd {
   2195       1.23      fvdl 	struct mbuf *mrep = nfsd->nd_mrep, *md = nfsd->nd_md;
   2196       1.23      fvdl 	struct mbuf *nam = nfsd->nd_nam;
   2197       1.23      fvdl 	caddr_t dpos = nfsd->nd_dpos;
   2198  1.101.2.2      yamt 	kauth_cred_t cred = nfsd->nd_cr;
   2199       1.23      fvdl 	struct vattr va, dirfor, diraft;
   2200        1.1       cgd 	struct nameidata nd;
   2201       1.54  augustss 	u_int32_t *tl;
   2202       1.54  augustss 	int32_t t1;
   2203        1.1       cgd 	struct nfsv2_sattr *sp;
   2204       1.23      fvdl 	char *bpos, *pathcp = NULL, *cp2;
   2205        1.1       cgd 	struct uio io;
   2206        1.1       cgd 	struct iovec iv;
   2207  1.101.2.2      yamt 	int error = 0, cache = 0, dirfor_ret = 1, diraft_ret = 1;
   2208       1.68      yamt 	uint32_t len, len2;
   2209       1.23      fvdl 	int v3 = (nfsd->nd_flag & ND_NFSV3);
   2210       1.67      matt 	struct mbuf *mb, *mreq;
   2211       1.23      fvdl 	struct vnode *dirp = (struct vnode *)0;
   2212       1.23      fvdl 	nfsfh_t nfh;
   2213        1.1       cgd 	fhandle_t *fhp;
   2214       1.15   mycroft 	u_quad_t frev;
   2215       1.82   hannken 	struct mount *mp = NULL;
   2216        1.1       cgd 
   2217       1.23      fvdl 	nd.ni_cnd.cn_nameiop = 0;
   2218        1.1       cgd 	fhp = &nfh.fh_generic;
   2219        1.1       cgd 	nfsm_srvmtofh(fhp);
   2220       1.82   hannken 	if ((mp = vfs_getvfs(&fhp->fh_fsid)) == NULL)
   2221       1.82   hannken 		return (ESTALE);
   2222       1.82   hannken 	vn_start_write(NULL, &mp, V_WAIT);
   2223       1.23      fvdl 	nfsm_srvnamesiz(len);
   2224       1.15   mycroft 	nd.ni_cnd.cn_cred = cred;
   2225       1.15   mycroft 	nd.ni_cnd.cn_nameiop = CREATE;
   2226       1.61       chs 	nd.ni_cnd.cn_flags = LOCKPARENT;
   2227       1.23      fvdl 	error = nfs_namei(&nd, fhp, len, slp, nam, &md, &dpos,
   2228       1.99  christos 		&dirp, lwp, (nfsd->nd_flag & ND_KERBAUTH), FALSE);
   2229       1.23      fvdl 	if (dirp) {
   2230       1.23      fvdl 		if (v3)
   2231       1.99  christos 			dirfor_ret = VOP_GETATTR(dirp, &dirfor, cred, lwp);
   2232       1.23      fvdl 		else {
   2233       1.23      fvdl 			vrele(dirp);
   2234       1.23      fvdl 			dirp = (struct vnode *)0;
   2235       1.23      fvdl 		}
   2236       1.23      fvdl 	}
   2237       1.22  christos 	if (error)
   2238        1.1       cgd 		goto out;
   2239       1.23      fvdl 	VATTR_NULL(&va);
   2240       1.97      jmmv 	va.va_type = VLNK;
   2241       1.68      yamt 	if (v3) {
   2242       1.92      yamt 		va.va_mode = 0;
   2243       1.23      fvdl 		nfsm_srvsattr(&va);
   2244       1.68      yamt 		nfsm_dissect(tl, uint32_t *, NFSX_UNSIGNED);
   2245       1.68      yamt 		len2 = fxdr_unsigned(uint32_t, *tl);
   2246       1.68      yamt 		if (len2 > PATH_MAX) {
   2247       1.68      yamt 			/* XXX should check _PC_NO_TRUNC */
   2248       1.68      yamt 			error = ENAMETOOLONG;
   2249       1.68      yamt 			goto abortop;
   2250       1.68      yamt 		}
   2251       1.68      yamt 	}
   2252       1.68      yamt 	else {
   2253       1.68      yamt 		/* NFSv2 */
   2254       1.68      yamt 		nfsm_strsiz(len2, NFS_MAXPATHLEN);
   2255       1.68      yamt 	}
   2256       1.56   thorpej 	pathcp = malloc(len2 + 1, M_TEMP, M_WAITOK);
   2257        1.1       cgd 	iv.iov_base = pathcp;
   2258        1.1       cgd 	iv.iov_len = len2;
   2259        1.1       cgd 	io.uio_resid = len2;
   2260        1.1       cgd 	io.uio_offset = 0;
   2261        1.1       cgd 	io.uio_iov = &iv;
   2262        1.1       cgd 	io.uio_iovcnt = 1;
   2263        1.1       cgd 	io.uio_rw = UIO_READ;
   2264      1.101      yamt 	UIO_SETUP_SYSSPACE(&io);
   2265        1.1       cgd 	nfsm_mtouio(&io, len2);
   2266       1.23      fvdl 	if (!v3) {
   2267       1.23      fvdl 		nfsm_dissect(sp, struct nfsv2_sattr *, NFSX_V2SATTR);
   2268       1.23      fvdl 		va.va_mode = fxdr_unsigned(u_int16_t, sp->sa_mode);
   2269       1.23      fvdl 	}
   2270        1.1       cgd 	*(pathcp + len2) = '\0';
   2271        1.1       cgd 	if (nd.ni_vp) {
   2272       1.68      yamt 		error = EEXIST;
   2273       1.68      yamt abortop:
   2274       1.15   mycroft 		VOP_ABORTOP(nd.ni_dvp, &nd.ni_cnd);
   2275        1.1       cgd 		if (nd.ni_dvp == nd.ni_vp)
   2276        1.1       cgd 			vrele(nd.ni_dvp);
   2277        1.1       cgd 		else
   2278        1.1       cgd 			vput(nd.ni_dvp);
   2279       1.68      yamt 		if (nd.ni_vp)
   2280       1.68      yamt 			vrele(nd.ni_vp);
   2281        1.1       cgd 		goto out;
   2282        1.1       cgd 	}
   2283       1.23      fvdl 	nqsrv_getl(nd.ni_dvp, ND_WRITE);
   2284       1.23      fvdl 	error = VOP_SYMLINK(nd.ni_dvp, &nd.ni_vp, &nd.ni_cnd, &va, pathcp);
   2285       1.61       chs 	if (!error) {
   2286       1.23      fvdl 	    if (v3) {
   2287       1.60     assar 		memset((caddr_t)fhp, 0, sizeof(nfh));
   2288       1.88  christos 		fhp->fh_fsid = nd.ni_vp->v_mount->mnt_stat.f_fsidx;
   2289       1.60     assar 		error = VFS_VPTOFH(nd.ni_vp, &fhp->fh_fid);
   2290       1.60     assar 		if (!error)
   2291       1.99  christos 		    error = VOP_GETATTR(nd.ni_vp, &va, cred, lwp);
   2292       1.60     assar 		vput(nd.ni_vp);
   2293  1.101.2.1      yamt 		KASSERT(fhp->fh_fid.fid_len <= _VFS_MAXFIDSZ);
   2294       1.60     assar 	    } else {
   2295       1.60     assar 		vput(nd.ni_vp);
   2296       1.60     assar 	    }
   2297       1.23      fvdl 	}
   2298        1.1       cgd out:
   2299        1.1       cgd 	if (pathcp)
   2300       1.56   thorpej 		free(pathcp, M_TEMP);
   2301       1.23      fvdl 	if (dirp) {
   2302       1.99  christos 		diraft_ret = VOP_GETATTR(dirp, &diraft, cred, lwp);
   2303       1.23      fvdl 		vrele(dirp);
   2304       1.23      fvdl 	}
   2305       1.23      fvdl 	nfsm_reply(NFSX_SRVFH(v3) + NFSX_POSTOPATTR(v3) + NFSX_WCCDATA(v3));
   2306       1.23      fvdl 	if (v3) {
   2307       1.23      fvdl 		if (!error) {
   2308       1.23      fvdl 			nfsm_srvpostop_fh(fhp);
   2309       1.23      fvdl 			nfsm_srvpostop_attr(0, &va);
   2310       1.23      fvdl 		}
   2311       1.23      fvdl 		nfsm_srvwcc_data(dirfor_ret, &dirfor, diraft_ret, &diraft);
   2312       1.23      fvdl 	}
   2313       1.82   hannken 	vn_finished_write(mp, 0);
   2314       1.23      fvdl 	return (0);
   2315        1.1       cgd nfsmout:
   2316       1.23      fvdl 	if (dirp)
   2317       1.23      fvdl 		vrele(dirp);
   2318       1.15   mycroft 	VOP_ABORTOP(nd.ni_dvp, &nd.ni_cnd);
   2319        1.1       cgd 	if (nd.ni_dvp == nd.ni_vp)
   2320        1.1       cgd 		vrele(nd.ni_dvp);
   2321        1.1       cgd 	else
   2322        1.1       cgd 		vput(nd.ni_dvp);
   2323        1.1       cgd 	if (nd.ni_vp)
   2324        1.1       cgd 		vrele(nd.ni_vp);
   2325        1.1       cgd 	if (pathcp)
   2326       1.56   thorpej 		free(pathcp, M_TEMP);
   2327       1.82   hannken 	vn_finished_write(mp, 0);
   2328        1.1       cgd 	return (error);
   2329        1.1       cgd }
   2330        1.1       cgd 
   2331        1.1       cgd /*
   2332        1.1       cgd  * nfs mkdir service
   2333        1.1       cgd  */
   2334       1.22  christos int
   2335       1.99  christos nfsrv_mkdir(nfsd, slp, lwp, mrq)
   2336       1.23      fvdl 	struct nfsrv_descript *nfsd;
   2337       1.23      fvdl 	struct nfssvc_sock *slp;
   2338       1.99  christos 	struct lwp *lwp;
   2339       1.23      fvdl 	struct mbuf **mrq;
   2340        1.1       cgd {
   2341       1.23      fvdl 	struct mbuf *mrep = nfsd->nd_mrep, *md = nfsd->nd_md;
   2342       1.23      fvdl 	struct mbuf *nam = nfsd->nd_nam;
   2343       1.23      fvdl 	caddr_t dpos = nfsd->nd_dpos;
   2344  1.101.2.2      yamt 	kauth_cred_t cred = nfsd->nd_cr;
   2345       1.23      fvdl 	struct vattr va, dirfor, diraft;
   2346       1.54  augustss 	struct nfs_fattr *fp;
   2347        1.1       cgd 	struct nameidata nd;
   2348       1.54  augustss 	caddr_t cp;
   2349       1.54  augustss 	u_int32_t *tl;
   2350       1.54  augustss 	int32_t t1;
   2351        1.1       cgd 	caddr_t bpos;
   2352  1.101.2.2      yamt 	int error = 0, cache = 0, len, dirfor_ret = 1, diraft_ret = 1;
   2353       1.23      fvdl 	int v3 = (nfsd->nd_flag & ND_NFSV3);
   2354        1.1       cgd 	char *cp2;
   2355       1.67      matt 	struct mbuf *mb, *mreq;
   2356       1.23      fvdl 	struct vnode *vp, *dirp = (struct vnode *)0;
   2357       1.23      fvdl 	nfsfh_t nfh;
   2358        1.1       cgd 	fhandle_t *fhp;
   2359       1.15   mycroft 	u_quad_t frev;
   2360       1.82   hannken 	struct mount *mp = NULL;
   2361        1.1       cgd 
   2362        1.1       cgd 	fhp = &nfh.fh_generic;
   2363        1.1       cgd 	nfsm_srvmtofh(fhp);
   2364       1.82   hannken 	if ((mp = vfs_getvfs(&fhp->fh_fsid)) == NULL)
   2365       1.82   hannken 		return (ESTALE);
   2366       1.82   hannken 	vn_start_write(NULL, &mp, V_WAIT);
   2367       1.23      fvdl 	nfsm_srvnamesiz(len);
   2368       1.15   mycroft 	nd.ni_cnd.cn_cred = cred;
   2369       1.15   mycroft 	nd.ni_cnd.cn_nameiop = CREATE;
   2370       1.15   mycroft 	nd.ni_cnd.cn_flags = LOCKPARENT;
   2371       1.23      fvdl 	error = nfs_namei(&nd, fhp, len, slp, nam, &md, &dpos,
   2372       1.99  christos 		&dirp, lwp, (nfsd->nd_flag & ND_KERBAUTH), FALSE);
   2373       1.23      fvdl 	if (dirp) {
   2374       1.23      fvdl 		if (v3)
   2375       1.99  christos 			dirfor_ret = VOP_GETATTR(dirp, &dirfor, cred, lwp);
   2376       1.23      fvdl 		else {
   2377       1.23      fvdl 			vrele(dirp);
   2378       1.23      fvdl 			dirp = (struct vnode *)0;
   2379       1.23      fvdl 		}
   2380       1.23      fvdl 	}
   2381       1.23      fvdl 	if (error) {
   2382       1.23      fvdl 		nfsm_reply(NFSX_WCCDATA(v3));
   2383       1.23      fvdl 		nfsm_srvwcc_data(dirfor_ret, &dirfor, diraft_ret, &diraft);
   2384       1.23      fvdl 		if (dirp)
   2385       1.23      fvdl 			vrele(dirp);
   2386       1.82   hannken 		vn_finished_write(mp, 0);
   2387       1.23      fvdl 		return (0);
   2388       1.23      fvdl 	}
   2389       1.18   mycroft 	VATTR_NULL(&va);
   2390       1.23      fvdl 	if (v3) {
   2391       1.92      yamt 		va.va_mode = 0;
   2392       1.23      fvdl 		nfsm_srvsattr(&va);
   2393       1.23      fvdl 	} else {
   2394       1.23      fvdl 		nfsm_dissect(tl, u_int32_t *, NFSX_UNSIGNED);
   2395       1.23      fvdl 		va.va_mode = nfstov_mode(*tl++);
   2396       1.23      fvdl 	}
   2397       1.18   mycroft 	va.va_type = VDIR;
   2398        1.1       cgd 	vp = nd.ni_vp;
   2399        1.1       cgd 	if (vp != NULL) {
   2400       1.15   mycroft 		VOP_ABORTOP(nd.ni_dvp, &nd.ni_cnd);
   2401        1.1       cgd 		if (nd.ni_dvp == vp)
   2402        1.1       cgd 			vrele(nd.ni_dvp);
   2403        1.1       cgd 		else
   2404        1.1       cgd 			vput(nd.ni_dvp);
   2405        1.1       cgd 		vrele(vp);
   2406        1.1       cgd 		error = EEXIST;
   2407       1.23      fvdl 		goto out;
   2408        1.1       cgd 	}
   2409       1.23      fvdl 	nqsrv_getl(nd.ni_dvp, ND_WRITE);
   2410       1.23      fvdl 	error = VOP_MKDIR(nd.ni_dvp, &nd.ni_vp, &nd.ni_cnd, &va);
   2411       1.23      fvdl 	if (!error) {
   2412       1.23      fvdl 		vp = nd.ni_vp;
   2413       1.44     perry 		memset((caddr_t)fhp, 0, sizeof(nfh));
   2414       1.88  christos 		fhp->fh_fsid = vp->v_mount->mnt_stat.f_fsidx;
   2415       1.23      fvdl 		error = VFS_VPTOFH(vp, &fhp->fh_fid);
   2416       1.23      fvdl 		if (!error)
   2417       1.99  christos 			error = VOP_GETATTR(vp, &va, cred, lwp);
   2418        1.1       cgd 		vput(vp);
   2419  1.101.2.1      yamt 		KASSERT(fhp->fh_fid.fid_len <= _VFS_MAXFIDSZ);
   2420        1.1       cgd 	}
   2421       1.23      fvdl out:
   2422       1.23      fvdl 	if (dirp) {
   2423       1.99  christos 		diraft_ret = VOP_GETATTR(dirp, &diraft, cred, lwp);
   2424       1.23      fvdl 		vrele(dirp);
   2425       1.23      fvdl 	}
   2426       1.23      fvdl 	nfsm_reply(NFSX_SRVFH(v3) + NFSX_POSTOPATTR(v3) + NFSX_WCCDATA(v3));
   2427       1.23      fvdl 	if (v3) {
   2428       1.23      fvdl 		if (!error) {
   2429       1.23      fvdl 			nfsm_srvpostop_fh(fhp);
   2430       1.23      fvdl 			nfsm_srvpostop_attr(0, &va);
   2431       1.23      fvdl 		}
   2432       1.23      fvdl 		nfsm_srvwcc_data(dirfor_ret, &dirfor, diraft_ret, &diraft);
   2433       1.23      fvdl 	} else {
   2434       1.23      fvdl 		nfsm_srvfhtom(fhp, v3);
   2435       1.23      fvdl 		nfsm_build(fp, struct nfs_fattr *, NFSX_V2FATTR);
   2436       1.23      fvdl 		nfsm_srvfillattr(&va, fp);
   2437       1.23      fvdl 	}
   2438       1.82   hannken 	vn_finished_write(mp, 0);
   2439       1.23      fvdl 	return (0);
   2440        1.1       cgd nfsmout:
   2441       1.23      fvdl 	if (dirp)
   2442       1.23      fvdl 		vrele(dirp);
   2443       1.15   mycroft 	VOP_ABORTOP(nd.ni_dvp, &nd.ni_cnd);
   2444        1.1       cgd 	if (nd.ni_dvp == nd.ni_vp)
   2445        1.1       cgd 		vrele(nd.ni_dvp);
   2446        1.1       cgd 	else
   2447        1.1       cgd 		vput(nd.ni_dvp);
   2448        1.1       cgd 	if (nd.ni_vp)
   2449        1.1       cgd 		vrele(nd.ni_vp);
   2450       1.82   hannken 	vn_finished_write(mp, 0);
   2451        1.1       cgd 	return (error);
   2452        1.1       cgd }
   2453        1.1       cgd 
   2454        1.1       cgd /*
   2455        1.1       cgd  * nfs rmdir service
   2456        1.1       cgd  */
   2457       1.22  christos int
   2458       1.99  christos nfsrv_rmdir(nfsd, slp, lwp, mrq)
   2459       1.23      fvdl 	struct nfsrv_descript *nfsd;
   2460       1.23      fvdl 	struct nfssvc_sock *slp;
   2461       1.99  christos 	struct lwp *lwp;
   2462       1.23      fvdl 	struct mbuf **mrq;
   2463        1.1       cgd {
   2464       1.23      fvdl 	struct mbuf *mrep = nfsd->nd_mrep, *md = nfsd->nd_md;
   2465       1.23      fvdl 	struct mbuf *nam = nfsd->nd_nam;
   2466       1.23      fvdl 	caddr_t dpos = nfsd->nd_dpos;
   2467  1.101.2.2      yamt 	kauth_cred_t cred = nfsd->nd_cr;
   2468       1.54  augustss 	u_int32_t *tl;
   2469       1.54  augustss 	int32_t t1;
   2470        1.1       cgd 	caddr_t bpos;
   2471  1.101.2.2      yamt 	int error = 0, cache = 0, len, dirfor_ret = 1, diraft_ret = 1;
   2472       1.23      fvdl 	int v3 = (nfsd->nd_flag & ND_NFSV3);
   2473        1.1       cgd 	char *cp2;
   2474        1.1       cgd 	struct mbuf *mb, *mreq;
   2475       1.23      fvdl 	struct vnode *vp, *dirp = (struct vnode *)0;
   2476       1.23      fvdl 	struct vattr dirfor, diraft;
   2477       1.23      fvdl 	nfsfh_t nfh;
   2478        1.1       cgd 	fhandle_t *fhp;
   2479        1.1       cgd 	struct nameidata nd;
   2480       1.15   mycroft 	u_quad_t frev;
   2481       1.82   hannken 	struct mount *mp = NULL;
   2482        1.1       cgd 
   2483        1.1       cgd 	fhp = &nfh.fh_generic;
   2484        1.1       cgd 	nfsm_srvmtofh(fhp);
   2485       1.82   hannken 	if ((mp = vfs_getvfs(&fhp->fh_fsid)) == NULL)
   2486       1.82   hannken 		return (ESTALE);
   2487       1.82   hannken 	vn_start_write(NULL, &mp, V_WAIT);
   2488       1.23      fvdl 	nfsm_srvnamesiz(len);
   2489       1.15   mycroft 	nd.ni_cnd.cn_cred = cred;
   2490       1.15   mycroft 	nd.ni_cnd.cn_nameiop = DELETE;
   2491       1.15   mycroft 	nd.ni_cnd.cn_flags = LOCKPARENT | LOCKLEAF;
   2492       1.23      fvdl 	error = nfs_namei(&nd, fhp, len, slp, nam, &md, &dpos,
   2493       1.99  christos 		&dirp, lwp, (nfsd->nd_flag & ND_KERBAUTH), FALSE);
   2494       1.23      fvdl 	if (dirp) {
   2495       1.23      fvdl 		if (v3)
   2496       1.99  christos 			dirfor_ret = VOP_GETATTR(dirp, &dirfor, cred, lwp);
   2497       1.23      fvdl 		else {
   2498       1.23      fvdl 			vrele(dirp);
   2499       1.23      fvdl 			dirp = (struct vnode *)0;
   2500       1.23      fvdl 		}
   2501       1.23      fvdl 	}
   2502       1.23      fvdl 	if (error) {
   2503       1.23      fvdl 		nfsm_reply(NFSX_WCCDATA(v3));
   2504       1.23      fvdl 		nfsm_srvwcc_data(dirfor_ret, &dirfor, diraft_ret, &diraft);
   2505       1.23      fvdl 		if (dirp)
   2506       1.23      fvdl 			vrele(dirp);
   2507       1.82   hannken 		vn_finished_write(mp, 0);
   2508       1.23      fvdl 		return (0);
   2509       1.23      fvdl 	}
   2510        1.1       cgd 	vp = nd.ni_vp;
   2511        1.1       cgd 	if (vp->v_type != VDIR) {
   2512        1.1       cgd 		error = ENOTDIR;
   2513        1.1       cgd 		goto out;
   2514        1.1       cgd 	}
   2515        1.1       cgd 	/*
   2516        1.1       cgd 	 * No rmdir "." please.
   2517        1.1       cgd 	 */
   2518        1.1       cgd 	if (nd.ni_dvp == vp) {
   2519        1.1       cgd 		error = EINVAL;
   2520        1.1       cgd 		goto out;
   2521        1.1       cgd 	}
   2522        1.1       cgd 	/*
   2523        1.1       cgd 	 * The root of a mounted filesystem cannot be deleted.
   2524        1.1       cgd 	 */
   2525        1.1       cgd 	if (vp->v_flag & VROOT)
   2526        1.1       cgd 		error = EBUSY;
   2527        1.1       cgd out:
   2528        1.1       cgd 	if (!error) {
   2529       1.23      fvdl 		nqsrv_getl(nd.ni_dvp, ND_WRITE);
   2530       1.23      fvdl 		nqsrv_getl(vp, ND_WRITE);
   2531       1.15   mycroft 		error = VOP_RMDIR(nd.ni_dvp, nd.ni_vp, &nd.ni_cnd);
   2532        1.1       cgd 	} else {
   2533       1.15   mycroft 		VOP_ABORTOP(nd.ni_dvp, &nd.ni_cnd);
   2534        1.1       cgd 		if (nd.ni_dvp == nd.ni_vp)
   2535        1.1       cgd 			vrele(nd.ni_dvp);
   2536        1.1       cgd 		else
   2537        1.1       cgd 			vput(nd.ni_dvp);
   2538        1.1       cgd 		vput(vp);
   2539        1.1       cgd 	}
   2540       1.23      fvdl 	if (dirp) {
   2541       1.99  christos 		diraft_ret = VOP_GETATTR(dirp, &diraft, cred, lwp);
   2542       1.23      fvdl 		vrele(dirp);
   2543       1.23      fvdl 	}
   2544       1.23      fvdl 	nfsm_reply(NFSX_WCCDATA(v3));
   2545       1.23      fvdl 	if (v3) {
   2546       1.23      fvdl 		nfsm_srvwcc_data(dirfor_ret, &dirfor, diraft_ret, &diraft);
   2547       1.82   hannken 		vn_finished_write(mp, 0);
   2548       1.23      fvdl 		return (0);
   2549       1.23      fvdl 	}
   2550       1.82   hannken 	vn_finished_write(mp, 0);
   2551        1.1       cgd 	nfsm_srvdone;
   2552        1.1       cgd }
   2553        1.1       cgd 
   2554        1.1       cgd /*
   2555        1.1       cgd  * nfs readdir service
   2556        1.1       cgd  * - mallocs what it thinks is enough to read
   2557       1.98      yamt  *	count rounded up to a multiple of NFS_SRVDIRBLKSIZ <= NFS_MAXREADDIR
   2558        1.1       cgd  * - calls VOP_READDIR()
   2559        1.1       cgd  * - loops around building the reply
   2560        1.1       cgd  *	if the output generated exceeds count break out of loop
   2561        1.1       cgd  *	The nfsm_clget macro is used here so that the reply will be packed
   2562        1.1       cgd  *	tightly in mbuf clusters.
   2563        1.1       cgd  * - it only knows that it has encountered eof when the VOP_READDIR()
   2564        1.1       cgd  *	reads nothing
   2565        1.1       cgd  * - as such one readdir rpc will return eof false although you are there
   2566        1.1       cgd  *	and then the next will return eof
   2567       1.11        ws  * - it trims out records with d_fileno == 0
   2568        1.1       cgd  *	this doesn't matter for Unix clients, but they might confuse clients
   2569        1.1       cgd  *	for other os'.
   2570       1.25       jtk  * - it trims out records with d_type == DT_WHT
   2571       1.25       jtk  *	these cannot be seen through NFS (unless we extend the protocol)
   2572        1.1       cgd  * NB: It is tempting to set eof to true if the VOP_READDIR() reads less
   2573        1.1       cgd  *	than requested, but this may not apply to all filesystems. For
   2574        1.1       cgd  *	example, client NFS does not { although it is never remote mounted
   2575        1.1       cgd  *	anyhow }
   2576       1.23      fvdl  *     The alternate call nfsrv_readdirplus() does lookups as well.
   2577        1.1       cgd  * PS: The NFS protocol spec. does not clarify what the "count" byte
   2578        1.1       cgd  *	argument is a count of.. just name strings and file id's or the
   2579        1.1       cgd  *	entire reply rpc or ...
   2580        1.1       cgd  *	I tried just file name and id sizes and it confused the Sun client,
   2581        1.1       cgd  *	so I am using the full rpc size now. The "paranoia.." comment refers
   2582        1.1       cgd  *	to including the status longwords that are not a part of the dir.
   2583        1.1       cgd  *	"entry" structures, but are in the rpc.
   2584        1.1       cgd  */
   2585       1.98      yamt 
   2586       1.98      yamt #define	NFS_SRVDIRBLKSIZ	1024
   2587       1.98      yamt 
   2588       1.15   mycroft struct flrep {
   2589       1.23      fvdl 	nfsuint64 fl_off;
   2590       1.23      fvdl 	u_int32_t fl_postopok;
   2591       1.23      fvdl 	u_int32_t fl_fattr[NFSX_V3FATTR / sizeof (u_int32_t)];
   2592       1.23      fvdl 	u_int32_t fl_fhok;
   2593       1.23      fvdl 	u_int32_t fl_fhsize;
   2594       1.23      fvdl 	u_int32_t fl_nfh[NFSX_V3FH / sizeof (u_int32_t)];
   2595       1.15   mycroft };
   2596       1.15   mycroft 
   2597       1.22  christos int
   2598       1.99  christos nfsrv_readdir(nfsd, slp, lwp, mrq)
   2599       1.23      fvdl 	struct nfsrv_descript *nfsd;
   2600       1.23      fvdl 	struct nfssvc_sock *slp;
   2601       1.99  christos 	struct lwp *lwp;
   2602       1.23      fvdl 	struct mbuf **mrq;
   2603        1.1       cgd {
   2604       1.23      fvdl 	struct mbuf *mrep = nfsd->nd_mrep, *md = nfsd->nd_md;
   2605       1.23      fvdl 	struct mbuf *nam = nfsd->nd_nam;
   2606       1.23      fvdl 	caddr_t dpos = nfsd->nd_dpos;
   2607  1.101.2.2      yamt 	kauth_cred_t cred = nfsd->nd_cr;
   2608       1.54  augustss 	char *bp, *be;
   2609       1.54  augustss 	struct mbuf *mp;
   2610       1.54  augustss 	struct dirent *dp;
   2611       1.54  augustss 	caddr_t cp;
   2612       1.54  augustss 	u_int32_t *tl;
   2613       1.54  augustss 	int32_t t1;
   2614        1.1       cgd 	caddr_t bpos;
   2615       1.67      matt 	struct mbuf *mb, *mreq, *mp2;
   2616       1.15   mycroft 	char *cpos, *cend, *cp2, *rbuf;
   2617        1.1       cgd 	struct vnode *vp;
   2618       1.23      fvdl 	struct vattr at;
   2619       1.23      fvdl 	nfsfh_t nfh;
   2620        1.1       cgd 	fhandle_t *fhp;
   2621        1.1       cgd 	struct uio io;
   2622        1.1       cgd 	struct iovec iv;
   2623       1.23      fvdl 	int len, nlen, rem, xfer, tsiz, i, error = 0, getret = 1;
   2624  1.101.2.2      yamt 	int siz, cnt, fullsiz, eofflag, rdonly, cache = 0, ncookies;
   2625       1.23      fvdl 	int v3 = (nfsd->nd_flag & ND_NFSV3);
   2626       1.23      fvdl 	u_quad_t frev, off, toff, verf;
   2627       1.38      fvdl 	off_t *cookies = NULL, *cookiep;
   2628       1.38      fvdl 	nfsuint64 jar;
   2629       1.15   mycroft 
   2630        1.1       cgd 	fhp = &nfh.fh_generic;
   2631        1.1       cgd 	nfsm_srvmtofh(fhp);
   2632       1.23      fvdl 	if (v3) {
   2633       1.23      fvdl 		nfsm_dissect(tl, u_int32_t *, 5 * NFSX_UNSIGNED);
   2634       1.48      fair 		toff = fxdr_hyper(tl);
   2635       1.23      fvdl 		tl += 2;
   2636       1.48      fair 		verf = fxdr_hyper(tl);
   2637       1.23      fvdl 		tl += 2;
   2638       1.23      fvdl 	} else {
   2639       1.23      fvdl 		nfsm_dissect(tl, u_int32_t *, 2 * NFSX_UNSIGNED);
   2640       1.23      fvdl 		toff = fxdr_unsigned(u_quad_t, *tl++);
   2641       1.23      fvdl 	}
   2642       1.23      fvdl 	off = toff;
   2643        1.1       cgd 	cnt = fxdr_unsigned(int, *tl);
   2644       1.98      yamt 	siz = ((cnt + NFS_SRVDIRBLKSIZ - 1) & ~(NFS_SRVDIRBLKSIZ - 1));
   2645       1.23      fvdl 	xfer = NFS_SRVMAXDATA(nfsd);
   2646       1.23      fvdl 	if (siz > xfer)
   2647       1.23      fvdl 		siz = xfer;
   2648        1.1       cgd 	fullsiz = siz;
   2649       1.23      fvdl 	error = nfsrv_fhtovp(fhp, 1, &vp, cred, slp, nam,
   2650       1.78   thorpej 		 &rdonly, (nfsd->nd_flag & ND_KERBAUTH), FALSE);
   2651       1.39      fvdl 	if (!error && vp->v_type != VDIR) {
   2652       1.39      fvdl 		error = ENOTDIR;
   2653       1.39      fvdl 		vput(vp);
   2654       1.39      fvdl 	}
   2655       1.23      fvdl 	if (error) {
   2656       1.23      fvdl 		nfsm_reply(NFSX_UNSIGNED);
   2657       1.23      fvdl 		nfsm_srvpostop_attr(getret, &at);
   2658       1.23      fvdl 		return (0);
   2659       1.23      fvdl 	}
   2660       1.23      fvdl 	nqsrv_getl(vp, ND_READ);
   2661       1.23      fvdl 	if (v3) {
   2662       1.99  christos 		error = getret = VOP_GETATTR(vp, &at, cred, lwp);
   2663       1.23      fvdl #ifdef NFS3_STRICTVERF
   2664       1.23      fvdl 		/*
   2665       1.23      fvdl 		 * XXX This check is too strict for Solaris 2.5 clients.
   2666       1.23      fvdl 		 */
   2667       1.23      fvdl 		if (!error && toff && verf != at.va_filerev)
   2668       1.23      fvdl 			error = NFSERR_BAD_COOKIE;
   2669       1.23      fvdl #endif
   2670       1.23      fvdl 	}
   2671       1.23      fvdl 	if (!error)
   2672       1.99  christos 		error = nfsrv_access(vp, VEXEC, cred, rdonly, lwp, 0);
   2673       1.22  christos 	if (error) {
   2674        1.1       cgd 		vput(vp);
   2675       1.23      fvdl 		nfsm_reply(NFSX_POSTOPATTR(v3));
   2676       1.23      fvdl 		nfsm_srvpostop_attr(getret, &at);
   2677       1.23      fvdl 		return (0);
   2678        1.1       cgd 	}
   2679       1.42      fvdl 	VOP_UNLOCK(vp, 0);
   2680       1.56   thorpej 	rbuf = malloc(siz, M_TEMP, M_WAITOK);
   2681        1.1       cgd again:
   2682        1.1       cgd 	iv.iov_base = rbuf;
   2683        1.1       cgd 	iv.iov_len = fullsiz;
   2684        1.1       cgd 	io.uio_iov = &iv;
   2685        1.1       cgd 	io.uio_iovcnt = 1;
   2686       1.15   mycroft 	io.uio_offset = (off_t)off;
   2687        1.1       cgd 	io.uio_resid = fullsiz;
   2688        1.1       cgd 	io.uio_rw = UIO_READ;
   2689      1.101      yamt 	UIO_SETUP_SYSSPACE(&io);
   2690       1.23      fvdl 	eofflag = 0;
   2691       1.42      fvdl 	vn_lock(vp, LK_EXCLUSIVE | LK_RETRY);
   2692       1.23      fvdl 
   2693       1.42      fvdl 	error = VOP_READDIR(vp, &io, cred, &eofflag, &cookies, &ncookies);
   2694       1.23      fvdl 
   2695       1.15   mycroft 	off = (off_t)io.uio_offset;
   2696       1.23      fvdl 	if (!cookies && !error)
   2697       1.23      fvdl 		error = NFSERR_PERM;
   2698       1.23      fvdl 	if (v3) {
   2699       1.99  christos 		getret = VOP_GETATTR(vp, &at, cred, lwp);
   2700       1.23      fvdl 		if (!error)
   2701       1.23      fvdl 			error = getret;
   2702       1.23      fvdl 	}
   2703       1.23      fvdl 
   2704       1.42      fvdl 	VOP_UNLOCK(vp, 0);
   2705        1.1       cgd 	if (error) {
   2706        1.1       cgd 		vrele(vp);
   2707       1.56   thorpej 		free((caddr_t)rbuf, M_TEMP);
   2708       1.23      fvdl 		if (cookies)
   2709       1.23      fvdl 			free((caddr_t)cookies, M_TEMP);
   2710       1.23      fvdl 		nfsm_reply(NFSX_POSTOPATTR(v3));
   2711       1.23      fvdl 		nfsm_srvpostop_attr(getret, &at);
   2712       1.23      fvdl 		return (0);
   2713        1.1       cgd 	}
   2714        1.1       cgd 	if (io.uio_resid) {
   2715        1.1       cgd 		siz -= io.uio_resid;
   2716        1.1       cgd 
   2717        1.1       cgd 		/*
   2718        1.1       cgd 		 * If nothing read, return eof
   2719        1.1       cgd 		 * rpc reply
   2720        1.1       cgd 		 */
   2721        1.1       cgd 		if (siz == 0) {
   2722        1.1       cgd 			vrele(vp);
   2723       1.23      fvdl 			nfsm_reply(NFSX_POSTOPATTR(v3) + NFSX_COOKIEVERF(v3) +
   2724       1.23      fvdl 				2 * NFSX_UNSIGNED);
   2725       1.23      fvdl 			if (v3) {
   2726       1.23      fvdl 				nfsm_srvpostop_attr(getret, &at);
   2727       1.23      fvdl 				nfsm_build(tl, u_int32_t *, 4 * NFSX_UNSIGNED);
   2728       1.48      fair 				txdr_hyper(at.va_filerev, tl);
   2729       1.23      fvdl 				tl += 2;
   2730       1.23      fvdl 			} else
   2731       1.23      fvdl 				nfsm_build(tl, u_int32_t *, 2 * NFSX_UNSIGNED);
   2732        1.1       cgd 			*tl++ = nfs_false;
   2733        1.1       cgd 			*tl = nfs_true;
   2734       1.56   thorpej 			free((caddr_t)rbuf, M_TEMP);
   2735       1.56   thorpej 			free((caddr_t)cookies, M_TEMP);
   2736        1.1       cgd 			return (0);
   2737        1.1       cgd 		}
   2738        1.1       cgd 	}
   2739        1.1       cgd 
   2740        1.1       cgd 	/*
   2741        1.1       cgd 	 * Check for degenerate cases of nothing useful read.
   2742        1.1       cgd 	 * If so go try again
   2743        1.1       cgd 	 */
   2744        1.8        ws 	cpos = rbuf;
   2745        1.1       cgd 	cend = rbuf + siz;
   2746       1.23      fvdl 	dp = (struct dirent *)cpos;
   2747       1.23      fvdl 	cookiep = cookies;
   2748       1.23      fvdl 
   2749       1.28      fvdl 	while (cpos < cend && ncookies > 0 &&
   2750       1.28      fvdl 		(dp->d_fileno == 0 || dp->d_type == DT_WHT)) {
   2751       1.23      fvdl 		cpos += dp->d_reclen;
   2752       1.11        ws 		dp = (struct dirent *)cpos;
   2753       1.23      fvdl 		cookiep++;
   2754       1.23      fvdl 		ncookies--;
   2755        1.1       cgd 	}
   2756       1.23      fvdl 	if (cpos >= cend || ncookies == 0) {
   2757       1.23      fvdl 		toff = off;
   2758        1.1       cgd 		siz = fullsiz;
   2759        1.1       cgd 		goto again;
   2760        1.1       cgd 	}
   2761        1.1       cgd 
   2762       1.23      fvdl 	len = 3 * NFSX_UNSIGNED;	/* paranoia, probably can be 0 */
   2763       1.23      fvdl 	nfsm_reply(NFSX_POSTOPATTR(v3) + NFSX_COOKIEVERF(v3) + siz);
   2764       1.23      fvdl 	if (v3) {
   2765       1.23      fvdl 		nfsm_srvpostop_attr(getret, &at);
   2766       1.23      fvdl 		nfsm_build(tl, u_int32_t *, 2 * NFSX_UNSIGNED);
   2767       1.48      fair 		txdr_hyper(at.va_filerev, tl);
   2768       1.23      fvdl 	}
   2769       1.15   mycroft 	mp = mp2 = mb;
   2770       1.15   mycroft 	bp = bpos;
   2771       1.15   mycroft 	be = bp + M_TRAILINGSPACE(mp);
   2772       1.15   mycroft 
   2773       1.15   mycroft 	/* Loop through the records and build reply */
   2774       1.23      fvdl 	while (cpos < cend && ncookies > 0) {
   2775       1.25       jtk 		if (dp->d_fileno != 0 && dp->d_type != DT_WHT) {
   2776       1.15   mycroft 			nlen = dp->d_namlen;
   2777       1.15   mycroft 			rem = nfsm_rndup(nlen)-nlen;
   2778       1.23      fvdl 			len += (4 * NFSX_UNSIGNED + nlen + rem);
   2779       1.23      fvdl 			if (v3)
   2780       1.23      fvdl 				len += 2 * NFSX_UNSIGNED;
   2781       1.15   mycroft 			if (len > cnt) {
   2782       1.15   mycroft 				eofflag = 0;
   2783       1.15   mycroft 				break;
   2784       1.15   mycroft 			}
   2785       1.15   mycroft 			/*
   2786       1.15   mycroft 			 * Build the directory record xdr from
   2787       1.15   mycroft 			 * the dirent entry.
   2788       1.15   mycroft 			 */
   2789       1.15   mycroft 			nfsm_clget;
   2790       1.15   mycroft 			*tl = nfs_true;
   2791       1.15   mycroft 			bp += NFSX_UNSIGNED;
   2792       1.23      fvdl 			if (v3) {
   2793       1.23      fvdl 				nfsm_clget;
   2794       1.96      yamt 				*tl = txdr_unsigned(dp->d_fileno >> 32);
   2795       1.23      fvdl 				bp += NFSX_UNSIGNED;
   2796       1.23      fvdl 			}
   2797       1.15   mycroft 			nfsm_clget;
   2798       1.15   mycroft 			*tl = txdr_unsigned(dp->d_fileno);
   2799       1.15   mycroft 			bp += NFSX_UNSIGNED;
   2800       1.15   mycroft 			nfsm_clget;
   2801       1.15   mycroft 			*tl = txdr_unsigned(nlen);
   2802       1.15   mycroft 			bp += NFSX_UNSIGNED;
   2803       1.94     perry 
   2804       1.15   mycroft 			/* And loop around copying the name */
   2805       1.15   mycroft 			xfer = nlen;
   2806       1.15   mycroft 			cp = dp->d_name;
   2807       1.15   mycroft 			while (xfer > 0) {
   2808       1.15   mycroft 				nfsm_clget;
   2809       1.15   mycroft 				if ((bp+xfer) > be)
   2810       1.15   mycroft 					tsiz = be-bp;
   2811       1.15   mycroft 				else
   2812       1.15   mycroft 					tsiz = xfer;
   2813       1.44     perry 				memcpy(bp, cp, tsiz);
   2814       1.15   mycroft 				bp += tsiz;
   2815       1.15   mycroft 				xfer -= tsiz;
   2816       1.15   mycroft 				if (xfer > 0)
   2817       1.15   mycroft 					cp += tsiz;
   2818       1.15   mycroft 			}
   2819       1.23      fvdl 			/* And null pad to an int32_t boundary */
   2820       1.15   mycroft 			for (i = 0; i < rem; i++)
   2821       1.15   mycroft 				*bp++ = '\0';
   2822       1.15   mycroft 			nfsm_clget;
   2823       1.94     perry 
   2824       1.15   mycroft 			/* Finish off the record */
   2825       1.48      fair 			txdr_hyper(*cookiep, &jar);
   2826       1.23      fvdl 			if (v3) {
   2827       1.38      fvdl 				*tl = jar.nfsuquad[0];
   2828       1.23      fvdl 				bp += NFSX_UNSIGNED;
   2829       1.23      fvdl 				nfsm_clget;
   2830       1.23      fvdl 			}
   2831       1.38      fvdl 			*tl = jar.nfsuquad[1];
   2832       1.15   mycroft 			bp += NFSX_UNSIGNED;
   2833       1.15   mycroft 		}
   2834       1.15   mycroft 		cpos += dp->d_reclen;
   2835       1.15   mycroft 		dp = (struct dirent *)cpos;
   2836       1.23      fvdl 		cookiep++;
   2837       1.23      fvdl 		ncookies--;
   2838       1.15   mycroft 	}
   2839        1.1       cgd 	vrele(vp);
   2840       1.15   mycroft 	nfsm_clget;
   2841       1.15   mycroft 	*tl = nfs_false;
   2842       1.15   mycroft 	bp += NFSX_UNSIGNED;
   2843       1.15   mycroft 	nfsm_clget;
   2844       1.15   mycroft 	if (eofflag)
   2845       1.15   mycroft 		*tl = nfs_true;
   2846       1.15   mycroft 	else
   2847       1.15   mycroft 		*tl = nfs_false;
   2848       1.15   mycroft 	bp += NFSX_UNSIGNED;
   2849       1.15   mycroft 	if (mp != mb) {
   2850       1.15   mycroft 		if (bp < be)
   2851       1.15   mycroft 			mp->m_len = bp - mtod(mp, caddr_t);
   2852       1.15   mycroft 	} else
   2853       1.15   mycroft 		mp->m_len += bp - bpos;
   2854       1.56   thorpej 	free((caddr_t)rbuf, M_TEMP);
   2855       1.56   thorpej 	free((caddr_t)cookies, M_TEMP);
   2856       1.15   mycroft 	nfsm_srvdone;
   2857       1.15   mycroft }
   2858       1.15   mycroft 
   2859       1.22  christos int
   2860       1.99  christos nfsrv_readdirplus(nfsd, slp, lwp, mrq)
   2861       1.23      fvdl 	struct nfsrv_descript *nfsd;
   2862       1.23      fvdl 	struct nfssvc_sock *slp;
   2863       1.99  christos 	struct lwp *lwp;
   2864       1.23      fvdl 	struct mbuf **mrq;
   2865       1.15   mycroft {
   2866       1.23      fvdl 	struct mbuf *mrep = nfsd->nd_mrep, *md = nfsd->nd_md;
   2867       1.23      fvdl 	struct mbuf *nam = nfsd->nd_nam;
   2868       1.23      fvdl 	caddr_t dpos = nfsd->nd_dpos;
   2869  1.101.2.2      yamt 	kauth_cred_t cred = nfsd->nd_cr;
   2870       1.54  augustss 	char *bp, *be;
   2871       1.54  augustss 	struct mbuf *mp;
   2872       1.54  augustss 	struct dirent *dp;
   2873       1.54  augustss 	caddr_t cp;
   2874       1.54  augustss 	u_int32_t *tl;
   2875       1.54  augustss 	int32_t t1;
   2876       1.15   mycroft 	caddr_t bpos;
   2877       1.67      matt 	struct mbuf *mb, *mreq, *mp2;
   2878       1.15   mycroft 	char *cpos, *cend, *cp2, *rbuf;
   2879       1.15   mycroft 	struct vnode *vp, *nvp;
   2880       1.15   mycroft 	struct flrep fl;
   2881       1.23      fvdl 	nfsfh_t nfh;
   2882       1.23      fvdl 	fhandle_t *fhp, *nfhp = (fhandle_t *)fl.fl_nfh;
   2883       1.15   mycroft 	struct uio io;
   2884       1.15   mycroft 	struct iovec iv;
   2885       1.23      fvdl 	struct vattr va, at, *vap = &va;
   2886       1.23      fvdl 	struct nfs_fattr *fp;
   2887       1.23      fvdl 	int len, nlen, rem, xfer, tsiz, i, error = 0, getret = 1;
   2888  1.101.2.2      yamt 	int siz, cnt, fullsiz, eofflag, rdonly, cache = 0, dirlen, ncookies;
   2889       1.23      fvdl 	u_quad_t frev, off, toff, verf;
   2890       1.38      fvdl 	off_t *cookies = NULL, *cookiep;
   2891       1.15   mycroft 
   2892       1.15   mycroft 	fhp = &nfh.fh_generic;
   2893       1.15   mycroft 	nfsm_srvmtofh(fhp);
   2894       1.23      fvdl 	nfsm_dissect(tl, u_int32_t *, 6 * NFSX_UNSIGNED);
   2895       1.48      fair 	toff = fxdr_hyper(tl);
   2896       1.23      fvdl 	tl += 2;
   2897       1.48      fair 	verf = fxdr_hyper(tl);
   2898       1.23      fvdl 	tl += 2;
   2899       1.23      fvdl 	siz = fxdr_unsigned(int, *tl++);
   2900       1.23      fvdl 	cnt = fxdr_unsigned(int, *tl);
   2901       1.23      fvdl 	off = toff;
   2902       1.98      yamt 	siz = ((siz + NFS_SRVDIRBLKSIZ - 1) & ~(NFS_SRVDIRBLKSIZ - 1));
   2903       1.23      fvdl 	xfer = NFS_SRVMAXDATA(nfsd);
   2904       1.23      fvdl 	if (siz > xfer)
   2905       1.23      fvdl 		siz = xfer;
   2906       1.15   mycroft 	fullsiz = siz;
   2907       1.23      fvdl 	error = nfsrv_fhtovp(fhp, 1, &vp, cred, slp, nam,
   2908       1.78   thorpej 		 &rdonly, (nfsd->nd_flag & ND_KERBAUTH), FALSE);
   2909       1.39      fvdl 	if (!error && vp->v_type != VDIR) {
   2910       1.39      fvdl 		error = ENOTDIR;
   2911       1.39      fvdl 		vput(vp);
   2912       1.39      fvdl 	}
   2913       1.23      fvdl 	if (error) {
   2914       1.23      fvdl 		nfsm_reply(NFSX_UNSIGNED);
   2915       1.23      fvdl 		nfsm_srvpostop_attr(getret, &at);
   2916       1.23      fvdl 		return (0);
   2917       1.23      fvdl 	}
   2918       1.99  christos 	error = getret = VOP_GETATTR(vp, &at, cred, lwp);
   2919       1.23      fvdl #ifdef NFS3_STRICTVERF
   2920       1.23      fvdl 	/*
   2921       1.23      fvdl 	 * XXX This check is too strict for Solaris 2.5 clients.
   2922       1.23      fvdl 	 */
   2923       1.23      fvdl 	if (!error && toff && verf != at.va_filerev)
   2924       1.23      fvdl 		error = NFSERR_BAD_COOKIE;
   2925       1.23      fvdl #endif
   2926       1.23      fvdl 	if (!error) {
   2927       1.23      fvdl 		nqsrv_getl(vp, ND_READ);
   2928       1.99  christos 		error = nfsrv_access(vp, VEXEC, cred, rdonly, lwp, 0);
   2929       1.23      fvdl 	}
   2930       1.22  christos 	if (error) {
   2931       1.15   mycroft 		vput(vp);
   2932       1.23      fvdl 		nfsm_reply(NFSX_V3POSTOPATTR);
   2933       1.23      fvdl 		nfsm_srvpostop_attr(getret, &at);
   2934       1.23      fvdl 		return (0);
   2935       1.15   mycroft 	}
   2936       1.42      fvdl 	VOP_UNLOCK(vp, 0);
   2937       1.23      fvdl 
   2938       1.56   thorpej 	rbuf = malloc(siz, M_TEMP, M_WAITOK);
   2939       1.15   mycroft again:
   2940       1.15   mycroft 	iv.iov_base = rbuf;
   2941       1.15   mycroft 	iv.iov_len = fullsiz;
   2942       1.15   mycroft 	io.uio_iov = &iv;
   2943       1.15   mycroft 	io.uio_iovcnt = 1;
   2944       1.15   mycroft 	io.uio_offset = (off_t)off;
   2945       1.15   mycroft 	io.uio_resid = fullsiz;
   2946       1.15   mycroft 	io.uio_rw = UIO_READ;
   2947      1.101      yamt 	UIO_SETUP_SYSSPACE(&io);
   2948       1.23      fvdl 	eofflag = 0;
   2949       1.23      fvdl 
   2950       1.42      fvdl 	vn_lock(vp, LK_EXCLUSIVE | LK_RETRY);
   2951       1.42      fvdl 
   2952       1.42      fvdl 	error = VOP_READDIR(vp, &io, cred, &eofflag, &cookies, &ncookies);
   2953       1.23      fvdl 
   2954       1.23      fvdl 	off = (u_quad_t)io.uio_offset;
   2955       1.99  christos 	getret = VOP_GETATTR(vp, &at, cred, lwp);
   2956       1.23      fvdl 
   2957       1.42      fvdl 	VOP_UNLOCK(vp, 0);
   2958       1.36      fvdl 
   2959       1.36      fvdl 	/*
   2960       1.36      fvdl 	 * If the VGET operation doesn't work for this filesystem,
   2961       1.36      fvdl 	 * we can't support readdirplus. Returning NOTSUPP should
   2962       1.36      fvdl 	 * make clients fall back to plain readdir.
   2963       1.36      fvdl 	 * There's no need to check for VPTOFH as well, we wouldn't
   2964       1.36      fvdl 	 * even be here otherwise.
   2965       1.36      fvdl 	 */
   2966       1.36      fvdl 	if (!getret) {
   2967       1.78   thorpej 		if ((getret = VFS_VGET(vp->v_mount, at.va_fileid, &nvp)))
   2968       1.36      fvdl 			getret = (getret == EOPNOTSUPP) ?
   2969       1.36      fvdl 				NFSERR_NOTSUPP : NFSERR_IO;
   2970       1.36      fvdl 		else
   2971       1.36      fvdl 			vput(nvp);
   2972       1.36      fvdl 	}
   2973       1.36      fvdl 
   2974       1.23      fvdl 	if (!cookies && !error)
   2975       1.23      fvdl 		error = NFSERR_PERM;
   2976       1.23      fvdl 	if (!error)
   2977       1.23      fvdl 		error = getret;
   2978       1.15   mycroft 	if (error) {
   2979       1.15   mycroft 		vrele(vp);
   2980       1.23      fvdl 		if (cookies)
   2981       1.56   thorpej 			free((caddr_t)cookies, M_TEMP);
   2982       1.56   thorpej 		free((caddr_t)rbuf, M_TEMP);
   2983       1.23      fvdl 		nfsm_reply(NFSX_V3POSTOPATTR);
   2984       1.23      fvdl 		nfsm_srvpostop_attr(getret, &at);
   2985       1.23      fvdl 		return (0);
   2986       1.15   mycroft 	}
   2987       1.15   mycroft 	if (io.uio_resid) {
   2988       1.15   mycroft 		siz -= io.uio_resid;
   2989       1.15   mycroft 
   2990       1.15   mycroft 		/*
   2991       1.15   mycroft 		 * If nothing read, return eof
   2992       1.15   mycroft 		 * rpc reply
   2993       1.15   mycroft 		 */
   2994       1.15   mycroft 		if (siz == 0) {
   2995       1.15   mycroft 			vrele(vp);
   2996       1.23      fvdl 			nfsm_reply(NFSX_V3POSTOPATTR + NFSX_V3COOKIEVERF +
   2997       1.23      fvdl 				2 * NFSX_UNSIGNED);
   2998       1.23      fvdl 			nfsm_srvpostop_attr(getret, &at);
   2999       1.23      fvdl 			nfsm_build(tl, u_int32_t *, 4 * NFSX_UNSIGNED);
   3000       1.48      fair 			txdr_hyper(at.va_filerev, tl);
   3001       1.23      fvdl 			tl += 2;
   3002       1.15   mycroft 			*tl++ = nfs_false;
   3003       1.15   mycroft 			*tl = nfs_true;
   3004       1.56   thorpej 			free((caddr_t)cookies, M_TEMP);
   3005       1.56   thorpej 			free((caddr_t)rbuf, M_TEMP);
   3006       1.15   mycroft 			return (0);
   3007       1.15   mycroft 		}
   3008       1.15   mycroft 	}
   3009       1.15   mycroft 
   3010       1.15   mycroft 	/*
   3011       1.15   mycroft 	 * Check for degenerate cases of nothing useful read.
   3012       1.15   mycroft 	 * If so go try again
   3013       1.15   mycroft 	 */
   3014       1.15   mycroft 	cpos = rbuf;
   3015       1.15   mycroft 	cend = rbuf + siz;
   3016       1.23      fvdl 	dp = (struct dirent *)cpos;
   3017       1.23      fvdl 	cookiep = cookies;
   3018       1.23      fvdl 
   3019       1.29      fvdl 	while (cpos < cend && ncookies > 0 &&
   3020       1.29      fvdl 		(dp->d_fileno == 0 || dp->d_type == DT_WHT)) {
   3021       1.23      fvdl 		cpos += dp->d_reclen;
   3022       1.15   mycroft 		dp = (struct dirent *)cpos;
   3023       1.23      fvdl 		cookiep++;
   3024       1.23      fvdl 		ncookies--;
   3025       1.15   mycroft 	}
   3026       1.23      fvdl 	if (cpos >= cend || ncookies == 0) {
   3027       1.23      fvdl 		toff = off;
   3028       1.15   mycroft 		siz = fullsiz;
   3029       1.15   mycroft 		goto again;
   3030       1.15   mycroft 	}
   3031       1.15   mycroft 
   3032       1.23      fvdl 	dirlen = len = NFSX_V3POSTOPATTR + NFSX_V3COOKIEVERF + 2 * NFSX_UNSIGNED;
   3033       1.23      fvdl 	nfsm_reply(cnt);
   3034       1.23      fvdl 	nfsm_srvpostop_attr(getret, &at);
   3035       1.23      fvdl 	nfsm_build(tl, u_int32_t *, 2 * NFSX_UNSIGNED);
   3036       1.48      fair 	txdr_hyper(at.va_filerev, tl);
   3037       1.15   mycroft 	mp = mp2 = mb;
   3038       1.15   mycroft 	bp = bpos;
   3039       1.15   mycroft 	be = bp + M_TRAILINGSPACE(mp);
   3040        1.1       cgd 
   3041        1.1       cgd 	/* Loop through the records and build reply */
   3042       1.23      fvdl 	while (cpos < cend && ncookies > 0) {
   3043       1.25       jtk 		if (dp->d_fileno != 0 && dp->d_type != DT_WHT) {
   3044        1.1       cgd 			nlen = dp->d_namlen;
   3045        1.1       cgd 			rem = nfsm_rndup(nlen)-nlen;
   3046       1.94     perry 
   3047        1.1       cgd 			/*
   3048       1.15   mycroft 			 * For readdir_and_lookup get the vnode using
   3049       1.15   mycroft 			 * the file number.
   3050        1.1       cgd 			 */
   3051       1.78   thorpej 			if (VFS_VGET(vp->v_mount, dp->d_fileno, &nvp))
   3052       1.15   mycroft 				goto invalid;
   3053       1.44     perry 			memset((caddr_t)nfhp, 0, NFSX_V3FH);
   3054       1.23      fvdl 			nfhp->fh_fsid =
   3055       1.88  christos 				nvp->v_mount->mnt_stat.f_fsidx;
   3056       1.23      fvdl 			if (VFS_VPTOFH(nvp, &nfhp->fh_fid)) {
   3057       1.15   mycroft 				vput(nvp);
   3058       1.15   mycroft 				goto invalid;
   3059       1.15   mycroft 			}
   3060       1.99  christos 			if (VOP_GETATTR(nvp, vap, cred, lwp)) {
   3061       1.15   mycroft 				vput(nvp);
   3062       1.15   mycroft 				goto invalid;
   3063       1.15   mycroft 			}
   3064       1.15   mycroft 			vput(nvp);
   3065  1.101.2.1      yamt 			KASSERT(fhp->fh_fid.fid_len <= _VFS_MAXFIDSZ);
   3066       1.23      fvdl 
   3067       1.23      fvdl 			/*
   3068       1.23      fvdl 			 * If either the dircount or maxcount will be
   3069       1.23      fvdl 			 * exceeded, get out now. Both of these lengths
   3070       1.23      fvdl 			 * are calculated conservatively, including all
   3071       1.23      fvdl 			 * XDR overheads.
   3072       1.23      fvdl 			 */
   3073       1.52      fvdl 			len += (8 * NFSX_UNSIGNED + nlen + rem + NFSX_V3FH +
   3074       1.23      fvdl 				NFSX_V3POSTOPATTR);
   3075       1.23      fvdl 			dirlen += (6 * NFSX_UNSIGNED + nlen + rem);
   3076       1.23      fvdl 			if (len > cnt || dirlen > fullsiz) {
   3077        1.1       cgd 				eofflag = 0;
   3078        1.1       cgd 				break;
   3079        1.1       cgd 			}
   3080       1.23      fvdl 
   3081       1.15   mycroft 			/*
   3082       1.15   mycroft 			 * Build the directory record xdr from
   3083       1.15   mycroft 			 * the dirent entry.
   3084       1.15   mycroft 			 */
   3085       1.23      fvdl 			fp = (struct nfs_fattr *)&fl.fl_fattr;
   3086       1.23      fvdl 			nfsm_srvfillattr(vap, fp);
   3087       1.23      fvdl 			fl.fl_fhsize = txdr_unsigned(NFSX_V3FH);
   3088       1.23      fvdl 			fl.fl_fhok = nfs_true;
   3089       1.23      fvdl 			fl.fl_postopok = nfs_true;
   3090       1.48      fair 			txdr_hyper(*cookiep, fl.fl_off.nfsuquad);
   3091       1.23      fvdl 
   3092        1.1       cgd 			nfsm_clget;
   3093        1.1       cgd 			*tl = nfs_true;
   3094        1.1       cgd 			bp += NFSX_UNSIGNED;
   3095       1.23      fvdl 			nfsm_clget;
   3096       1.96      yamt 			*tl = txdr_unsigned(dp->d_fileno >> 32);
   3097       1.23      fvdl 			bp += NFSX_UNSIGNED;
   3098        1.1       cgd 			nfsm_clget;
   3099       1.11        ws 			*tl = txdr_unsigned(dp->d_fileno);
   3100        1.1       cgd 			bp += NFSX_UNSIGNED;
   3101        1.1       cgd 			nfsm_clget;
   3102        1.1       cgd 			*tl = txdr_unsigned(nlen);
   3103        1.1       cgd 			bp += NFSX_UNSIGNED;
   3104       1.94     perry 
   3105       1.15   mycroft 			/* And loop around copying the name */
   3106        1.1       cgd 			xfer = nlen;
   3107        1.1       cgd 			cp = dp->d_name;
   3108        1.1       cgd 			while (xfer > 0) {
   3109        1.1       cgd 				nfsm_clget;
   3110       1.23      fvdl 				if ((bp + xfer) > be)
   3111       1.23      fvdl 					tsiz = be - bp;
   3112        1.1       cgd 				else
   3113        1.1       cgd 					tsiz = xfer;
   3114       1.44     perry 				memcpy(bp, cp, tsiz);
   3115        1.1       cgd 				bp += tsiz;
   3116        1.1       cgd 				xfer -= tsiz;
   3117        1.1       cgd 				if (xfer > 0)
   3118        1.1       cgd 					cp += tsiz;
   3119        1.1       cgd 			}
   3120       1.23      fvdl 			/* And null pad to an int32_t boundary */
   3121        1.1       cgd 			for (i = 0; i < rem; i++)
   3122        1.1       cgd 				*bp++ = '\0';
   3123       1.94     perry 
   3124       1.23      fvdl 			/*
   3125       1.23      fvdl 			 * Now copy the flrep structure out.
   3126       1.23      fvdl 			 */
   3127       1.23      fvdl 			xfer = sizeof (struct flrep);
   3128       1.23      fvdl 			cp = (caddr_t)&fl;
   3129       1.23      fvdl 			while (xfer > 0) {
   3130       1.23      fvdl 				nfsm_clget;
   3131       1.23      fvdl 				if ((bp + xfer) > be)
   3132       1.23      fvdl 					tsiz = be - bp;
   3133       1.23      fvdl 				else
   3134       1.23      fvdl 					tsiz = xfer;
   3135       1.44     perry 				memcpy(bp, cp, tsiz);
   3136       1.23      fvdl 				bp += tsiz;
   3137       1.23      fvdl 				xfer -= tsiz;
   3138       1.23      fvdl 				if (xfer > 0)
   3139       1.23      fvdl 					cp += tsiz;
   3140       1.23      fvdl 			}
   3141        1.8        ws 		}
   3142       1.15   mycroft invalid:
   3143        1.1       cgd 		cpos += dp->d_reclen;
   3144       1.11        ws 		dp = (struct dirent *)cpos;
   3145       1.23      fvdl 		cookiep++;
   3146       1.23      fvdl 		ncookies--;
   3147        1.1       cgd 	}
   3148       1.15   mycroft 	vrele(vp);
   3149        1.1       cgd 	nfsm_clget;
   3150        1.1       cgd 	*tl = nfs_false;
   3151        1.1       cgd 	bp += NFSX_UNSIGNED;
   3152        1.1       cgd 	nfsm_clget;
   3153        1.1       cgd 	if (eofflag)
   3154        1.1       cgd 		*tl = nfs_true;
   3155        1.1       cgd 	else
   3156        1.1       cgd 		*tl = nfs_false;
   3157        1.1       cgd 	bp += NFSX_UNSIGNED;
   3158       1.15   mycroft 	if (mp != mb) {
   3159       1.15   mycroft 		if (bp < be)
   3160       1.15   mycroft 			mp->m_len = bp - mtod(mp, caddr_t);
   3161       1.15   mycroft 	} else
   3162       1.15   mycroft 		mp->m_len += bp - bpos;
   3163       1.56   thorpej 	free((caddr_t)cookies, M_TEMP);
   3164       1.56   thorpej 	free((caddr_t)rbuf, M_TEMP);
   3165       1.23      fvdl 	nfsm_srvdone;
   3166       1.23      fvdl }
   3167       1.23      fvdl 
   3168       1.23      fvdl /*
   3169       1.23      fvdl  * nfs commit service
   3170       1.23      fvdl  */
   3171       1.23      fvdl int
   3172       1.99  christos nfsrv_commit(nfsd, slp, lwp, mrq)
   3173       1.23      fvdl 	struct nfsrv_descript *nfsd;
   3174       1.23      fvdl 	struct nfssvc_sock *slp;
   3175       1.99  christos 	struct lwp *lwp;
   3176       1.23      fvdl 	struct mbuf **mrq;
   3177       1.23      fvdl {
   3178       1.23      fvdl 	struct mbuf *mrep = nfsd->nd_mrep, *md = nfsd->nd_md;
   3179       1.23      fvdl 	struct mbuf *nam = nfsd->nd_nam;
   3180       1.23      fvdl 	caddr_t dpos = nfsd->nd_dpos;
   3181  1.101.2.2      yamt 	kauth_cred_t cred = nfsd->nd_cr;
   3182       1.23      fvdl 	struct vattr bfor, aft;
   3183       1.23      fvdl 	struct vnode *vp;
   3184       1.23      fvdl 	nfsfh_t nfh;
   3185       1.23      fvdl 	fhandle_t *fhp;
   3186       1.54  augustss 	u_int32_t *tl;
   3187       1.54  augustss 	int32_t t1;
   3188       1.23      fvdl 	caddr_t bpos;
   3189  1.101.2.2      yamt 	int error = 0, rdonly, for_ret = 1, aft_ret = 1, cache = 0;
   3190       1.93      yamt 	uint32_t cnt;
   3191       1.23      fvdl 	char *cp2;
   3192       1.67      matt 	struct mbuf *mb, *mreq;
   3193       1.65    bouyer 	u_quad_t frev, off, end;
   3194       1.82   hannken 	struct mount *mp = NULL;
   3195       1.23      fvdl 
   3196       1.23      fvdl 	fhp = &nfh.fh_generic;
   3197       1.23      fvdl 	nfsm_srvmtofh(fhp);
   3198       1.82   hannken 	if ((mp = vfs_getvfs(&fhp->fh_fsid)) == NULL)
   3199       1.82   hannken 		return (ESTALE);
   3200       1.82   hannken 	vn_start_write(NULL, &mp, V_WAIT);
   3201       1.23      fvdl 	nfsm_dissect(tl, u_int32_t *, 3 * NFSX_UNSIGNED);
   3202       1.23      fvdl 
   3203       1.48      fair 	off = fxdr_hyper(tl);
   3204       1.23      fvdl 	tl += 2;
   3205       1.93      yamt 	cnt = fxdr_unsigned(uint32_t, *tl);
   3206       1.23      fvdl 	error = nfsrv_fhtovp(fhp, 1, &vp, cred, slp, nam,
   3207       1.78   thorpej 		 &rdonly, (nfsd->nd_flag & ND_KERBAUTH), FALSE);
   3208       1.23      fvdl 	if (error) {
   3209       1.23      fvdl 		nfsm_reply(2 * NFSX_UNSIGNED);
   3210       1.23      fvdl 		nfsm_srvwcc_data(for_ret, &bfor, aft_ret, &aft);
   3211       1.82   hannken 		vn_finished_write(mp, 0);
   3212       1.23      fvdl 		return (0);
   3213       1.23      fvdl 	}
   3214       1.99  christos 	for_ret = VOP_GETATTR(vp, &bfor, cred, lwp);
   3215       1.65    bouyer 	end = (cnt > 0) ? off + cnt : vp->v_size;
   3216       1.65    bouyer 	if (end < off || end > vp->v_size)
   3217       1.65    bouyer 		end = vp->v_size;
   3218       1.80    bouyer 	if (off < vp->v_size)
   3219       1.99  christos 		error = VOP_FSYNC(vp, cred, FSYNC_WAIT, off, end, lwp);
   3220       1.80    bouyer 	/* else error == 0, from nfsrv_fhtovp() */
   3221       1.99  christos 	aft_ret = VOP_GETATTR(vp, &aft, cred, lwp);
   3222       1.23      fvdl 	vput(vp);
   3223       1.23      fvdl 	nfsm_reply(NFSX_V3WCCDATA + NFSX_V3WRITEVERF);
   3224       1.23      fvdl 	nfsm_srvwcc_data(for_ret, &bfor, aft_ret, &aft);
   3225       1.23      fvdl 	if (!error) {
   3226       1.23      fvdl 		nfsm_build(tl, u_int32_t *, NFSX_V3WRITEVERF);
   3227       1.23      fvdl 		*tl++ = txdr_unsigned(boottime.tv_sec);
   3228       1.23      fvdl 		*tl = txdr_unsigned(boottime.tv_usec);
   3229       1.82   hannken 	} else {
   3230       1.82   hannken 		vn_finished_write(mp, 0);
   3231       1.23      fvdl 		return (0);
   3232       1.82   hannken 	}
   3233       1.82   hannken 	vn_finished_write(mp, 0);
   3234        1.1       cgd 	nfsm_srvdone;
   3235        1.1       cgd }
   3236        1.1       cgd 
   3237        1.1       cgd /*
   3238        1.1       cgd  * nfs statfs service
   3239        1.1       cgd  */
   3240       1.22  christos int
   3241       1.99  christos nfsrv_statfs(nfsd, slp, lwp, mrq)
   3242       1.23      fvdl 	struct nfsrv_descript *nfsd;
   3243       1.23      fvdl 	struct nfssvc_sock *slp;
   3244       1.99  christos 	struct lwp *lwp;
   3245       1.23      fvdl 	struct mbuf **mrq;
   3246        1.1       cgd {
   3247       1.23      fvdl 	struct mbuf *mrep = nfsd->nd_mrep, *md = nfsd->nd_md;
   3248       1.23      fvdl 	struct mbuf *nam = nfsd->nd_nam;
   3249       1.23      fvdl 	caddr_t dpos = nfsd->nd_dpos;
   3250  1.101.2.2      yamt 	kauth_cred_t cred = nfsd->nd_cr;
   3251       1.88  christos 	struct statvfs *sf;
   3252       1.54  augustss 	struct nfs_statfs *sfp;
   3253       1.54  augustss 	u_int32_t *tl;
   3254       1.54  augustss 	int32_t t1;
   3255        1.1       cgd 	caddr_t bpos;
   3256  1.101.2.2      yamt 	int error = 0, rdonly, cache = 0, getret = 1;
   3257       1.23      fvdl 	int v3 = (nfsd->nd_flag & ND_NFSV3);
   3258        1.1       cgd 	char *cp2;
   3259       1.67      matt 	struct mbuf *mb, *mreq;
   3260        1.1       cgd 	struct vnode *vp;
   3261       1.23      fvdl 	struct vattr at;
   3262       1.23      fvdl 	nfsfh_t nfh;
   3263        1.1       cgd 	fhandle_t *fhp;
   3264       1.88  christos 	struct statvfs statvfs;
   3265       1.23      fvdl 	u_quad_t frev, tval;
   3266        1.1       cgd 
   3267        1.1       cgd 	fhp = &nfh.fh_generic;
   3268        1.1       cgd 	nfsm_srvmtofh(fhp);
   3269       1.23      fvdl 	error = nfsrv_fhtovp(fhp, 1, &vp, cred, slp, nam,
   3270       1.78   thorpej 		 &rdonly, (nfsd->nd_flag & ND_KERBAUTH), FALSE);
   3271       1.23      fvdl 	if (error) {
   3272       1.23      fvdl 		nfsm_reply(NFSX_UNSIGNED);
   3273       1.23      fvdl 		nfsm_srvpostop_attr(getret, &at);
   3274       1.23      fvdl 		return (0);
   3275       1.23      fvdl 	}
   3276       1.88  christos 	sf = &statvfs;
   3277       1.99  christos 	error = VFS_STATVFS(vp->v_mount, sf, lwp);
   3278       1.99  christos 	getret = VOP_GETATTR(vp, &at, cred, lwp);
   3279        1.1       cgd 	vput(vp);
   3280       1.23      fvdl 	nfsm_reply(NFSX_POSTOPATTR(v3) + NFSX_STATFS(v3));
   3281       1.23      fvdl 	if (v3)
   3282       1.23      fvdl 		nfsm_srvpostop_attr(getret, &at);
   3283       1.23      fvdl 	if (error)
   3284       1.23      fvdl 		return (0);
   3285       1.23      fvdl 	nfsm_build(sfp, struct nfs_statfs *, NFSX_STATFS(v3));
   3286       1.23      fvdl 	if (v3) {
   3287       1.88  christos 		tval = (u_quad_t)((quad_t)sf->f_blocks * (quad_t)sf->f_frsize);
   3288       1.48      fair 		txdr_hyper(tval, &sfp->sf_tbytes);
   3289       1.88  christos 		tval = (u_quad_t)((quad_t)sf->f_bfree * (quad_t)sf->f_frsize);
   3290       1.48      fair 		txdr_hyper(tval, &sfp->sf_fbytes);
   3291       1.88  christos 		tval = (u_quad_t)((quad_t)sf->f_bavail * (quad_t)sf->f_frsize);
   3292       1.48      fair 		txdr_hyper(tval, &sfp->sf_abytes);
   3293       1.47   mycroft 		tval = (u_quad_t)sf->f_files;
   3294       1.48      fair 		txdr_hyper(tval, &sfp->sf_tfiles);
   3295       1.47   mycroft 		tval = (u_quad_t)sf->f_ffree;
   3296       1.48      fair 		txdr_hyper(tval, &sfp->sf_ffiles);
   3297       1.48      fair 		txdr_hyper(tval, &sfp->sf_afiles);
   3298       1.23      fvdl 		sfp->sf_invarsec = 0;
   3299       1.23      fvdl 	} else {
   3300       1.23      fvdl 		sfp->sf_tsize = txdr_unsigned(NFS_MAXDGRAMDATA);
   3301       1.88  christos 		sfp->sf_bsize = txdr_unsigned(sf->f_frsize);
   3302       1.23      fvdl 		sfp->sf_blocks = txdr_unsigned(sf->f_blocks);
   3303       1.23      fvdl 		sfp->sf_bfree = txdr_unsigned(sf->f_bfree);
   3304       1.23      fvdl 		sfp->sf_bavail = txdr_unsigned(sf->f_bavail);
   3305       1.23      fvdl 	}
   3306       1.23      fvdl 	nfsm_srvdone;
   3307       1.23      fvdl }
   3308       1.23      fvdl 
   3309       1.23      fvdl /*
   3310       1.23      fvdl  * nfs fsinfo service
   3311       1.23      fvdl  */
   3312       1.23      fvdl int
   3313       1.99  christos nfsrv_fsinfo(nfsd, slp, lwp, mrq)
   3314       1.23      fvdl 	struct nfsrv_descript *nfsd;
   3315       1.23      fvdl 	struct nfssvc_sock *slp;
   3316       1.99  christos 	struct lwp *lwp;
   3317       1.23      fvdl 	struct mbuf **mrq;
   3318       1.23      fvdl {
   3319       1.23      fvdl 	struct mbuf *mrep = nfsd->nd_mrep, *md = nfsd->nd_md;
   3320       1.23      fvdl 	struct mbuf *nam = nfsd->nd_nam;
   3321       1.23      fvdl 	caddr_t dpos = nfsd->nd_dpos;
   3322  1.101.2.2      yamt 	kauth_cred_t cred = nfsd->nd_cr;
   3323       1.54  augustss 	u_int32_t *tl;
   3324       1.54  augustss 	struct nfsv3_fsinfo *sip;
   3325       1.54  augustss 	int32_t t1;
   3326       1.23      fvdl 	caddr_t bpos;
   3327  1.101.2.2      yamt 	int error = 0, rdonly, cache = 0, getret = 1;
   3328       1.69      yamt 	uint32_t maxdata;
   3329       1.23      fvdl 	char *cp2;
   3330       1.67      matt 	struct mbuf *mb, *mreq;
   3331       1.23      fvdl 	struct vnode *vp;
   3332       1.23      fvdl 	struct vattr at;
   3333       1.23      fvdl 	nfsfh_t nfh;
   3334       1.23      fvdl 	fhandle_t *fhp;
   3335       1.37      fvdl 	u_quad_t frev, maxfsize;
   3336       1.88  christos 	struct statvfs sb;
   3337       1.23      fvdl 
   3338       1.23      fvdl 	fhp = &nfh.fh_generic;
   3339       1.23      fvdl 	nfsm_srvmtofh(fhp);
   3340       1.23      fvdl 	error = nfsrv_fhtovp(fhp, 1, &vp, cred, slp, nam,
   3341       1.78   thorpej 		 &rdonly, (nfsd->nd_flag & ND_KERBAUTH), FALSE);
   3342       1.23      fvdl 	if (error) {
   3343       1.23      fvdl 		nfsm_reply(NFSX_UNSIGNED);
   3344       1.23      fvdl 		nfsm_srvpostop_attr(getret, &at);
   3345       1.23      fvdl 		return (0);
   3346       1.15   mycroft 	}
   3347       1.37      fvdl 
   3348       1.37      fvdl 	/* XXX Try to make a guess on the max file size. */
   3349       1.99  christos 	VFS_STATVFS(vp->v_mount, &sb, (struct lwp *)0);
   3350       1.88  christos 	maxfsize = (u_quad_t)0x80000000 * sb.f_frsize - 1;
   3351       1.37      fvdl 
   3352       1.99  christos 	getret = VOP_GETATTR(vp, &at, cred, lwp);
   3353       1.23      fvdl 	vput(vp);
   3354       1.23      fvdl 	nfsm_reply(NFSX_V3POSTOPATTR + NFSX_V3FSINFO);
   3355       1.23      fvdl 	nfsm_srvpostop_attr(getret, &at);
   3356       1.23      fvdl 	nfsm_build(sip, struct nfsv3_fsinfo *, NFSX_V3FSINFO);
   3357       1.23      fvdl 
   3358       1.23      fvdl 	/*
   3359       1.23      fvdl 	 * XXX
   3360       1.23      fvdl 	 * There should be file system VFS OP(s) to get this information.
   3361       1.23      fvdl 	 * For now, assume ufs.
   3362       1.23      fvdl 	 */
   3363       1.23      fvdl 	if (slp->ns_so->so_type == SOCK_DGRAM)
   3364       1.69      yamt 		maxdata = NFS_MAXDGRAMDATA;
   3365       1.23      fvdl 	else
   3366       1.69      yamt 		maxdata = NFS_MAXDATA;
   3367       1.69      yamt 	sip->fs_rtmax = txdr_unsigned(maxdata);
   3368       1.69      yamt 	sip->fs_rtpref = txdr_unsigned(maxdata);
   3369       1.23      fvdl 	sip->fs_rtmult = txdr_unsigned(NFS_FABLKSIZE);
   3370       1.69      yamt 	sip->fs_wtmax = txdr_unsigned(maxdata);
   3371       1.69      yamt 	sip->fs_wtpref = txdr_unsigned(maxdata);
   3372       1.23      fvdl 	sip->fs_wtmult = txdr_unsigned(NFS_FABLKSIZE);
   3373       1.69      yamt 	sip->fs_dtpref = txdr_unsigned(maxdata);
   3374       1.48      fair 	txdr_hyper(maxfsize, &sip->fs_maxfilesize);
   3375       1.23      fvdl 	sip->fs_timedelta.nfsv3_sec = 0;
   3376       1.23      fvdl 	sip->fs_timedelta.nfsv3_nsec = txdr_unsigned(1);
   3377       1.23      fvdl 	sip->fs_properties = txdr_unsigned(NFSV3FSINFO_LINK |
   3378       1.23      fvdl 		NFSV3FSINFO_SYMLINK | NFSV3FSINFO_HOMOGENEOUS |
   3379       1.23      fvdl 		NFSV3FSINFO_CANSETTIME);
   3380       1.23      fvdl 	nfsm_srvdone;
   3381       1.23      fvdl }
   3382       1.23      fvdl 
   3383       1.23      fvdl /*
   3384       1.23      fvdl  * nfs pathconf service
   3385       1.23      fvdl  */
   3386       1.23      fvdl int
   3387       1.99  christos nfsrv_pathconf(nfsd, slp, lwp, mrq)
   3388       1.23      fvdl 	struct nfsrv_descript *nfsd;
   3389       1.23      fvdl 	struct nfssvc_sock *slp;
   3390       1.99  christos 	struct lwp *lwp;
   3391       1.23      fvdl 	struct mbuf **mrq;
   3392       1.23      fvdl {
   3393       1.23      fvdl 	struct mbuf *mrep = nfsd->nd_mrep, *md = nfsd->nd_md;
   3394       1.23      fvdl 	struct mbuf *nam = nfsd->nd_nam;
   3395       1.23      fvdl 	caddr_t dpos = nfsd->nd_dpos;
   3396  1.101.2.2      yamt 	kauth_cred_t cred = nfsd->nd_cr;
   3397       1.54  augustss 	u_int32_t *tl;
   3398       1.54  augustss 	struct nfsv3_pathconf *pc;
   3399       1.54  augustss 	int32_t t1;
   3400       1.23      fvdl 	caddr_t bpos;
   3401  1.101.2.2      yamt 	int error = 0, rdonly, cache = 0, getret = 1;
   3402       1.24       cgd 	register_t linkmax, namemax, chownres, notrunc;
   3403       1.23      fvdl 	char *cp2;
   3404       1.67      matt 	struct mbuf *mb, *mreq;
   3405       1.23      fvdl 	struct vnode *vp;
   3406       1.23      fvdl 	struct vattr at;
   3407       1.23      fvdl 	nfsfh_t nfh;
   3408       1.23      fvdl 	fhandle_t *fhp;
   3409       1.23      fvdl 	u_quad_t frev;
   3410       1.23      fvdl 
   3411       1.23      fvdl 	fhp = &nfh.fh_generic;
   3412       1.23      fvdl 	nfsm_srvmtofh(fhp);
   3413       1.23      fvdl 	error = nfsrv_fhtovp(fhp, 1, &vp, cred, slp, nam,
   3414       1.78   thorpej 		 &rdonly, (nfsd->nd_flag & ND_KERBAUTH), FALSE);
   3415       1.23      fvdl 	if (error) {
   3416       1.23      fvdl 		nfsm_reply(NFSX_UNSIGNED);
   3417       1.23      fvdl 		nfsm_srvpostop_attr(getret, &at);
   3418       1.23      fvdl 		return (0);
   3419       1.23      fvdl 	}
   3420       1.23      fvdl 	error = VOP_PATHCONF(vp, _PC_LINK_MAX, &linkmax);
   3421       1.23      fvdl 	if (!error)
   3422       1.23      fvdl 		error = VOP_PATHCONF(vp, _PC_NAME_MAX, &namemax);
   3423       1.23      fvdl 	if (!error)
   3424       1.23      fvdl 		error = VOP_PATHCONF(vp, _PC_CHOWN_RESTRICTED, &chownres);
   3425       1.23      fvdl 	if (!error)
   3426       1.23      fvdl 		error = VOP_PATHCONF(vp, _PC_NO_TRUNC, &notrunc);
   3427       1.99  christos 	getret = VOP_GETATTR(vp, &at, cred, lwp);
   3428       1.23      fvdl 	vput(vp);
   3429       1.23      fvdl 	nfsm_reply(NFSX_V3POSTOPATTR + NFSX_V3PATHCONF);
   3430       1.23      fvdl 	nfsm_srvpostop_attr(getret, &at);
   3431       1.23      fvdl 	if (error)
   3432       1.23      fvdl 		return (0);
   3433       1.23      fvdl 	nfsm_build(pc, struct nfsv3_pathconf *, NFSX_V3PATHCONF);
   3434       1.23      fvdl 
   3435       1.23      fvdl 	pc->pc_linkmax = txdr_unsigned(linkmax);
   3436       1.23      fvdl 	pc->pc_namemax = txdr_unsigned(namemax);
   3437       1.23      fvdl 	pc->pc_notrunc = txdr_unsigned(notrunc);
   3438       1.23      fvdl 	pc->pc_chownrestricted = txdr_unsigned(chownres);
   3439       1.23      fvdl 
   3440       1.23      fvdl 	/*
   3441       1.23      fvdl 	 * These should probably be supported by VOP_PATHCONF(), but
   3442       1.23      fvdl 	 * until msdosfs is exportable (why would you want to?), the
   3443       1.23      fvdl 	 * Unix defaults should be ok.
   3444       1.23      fvdl 	 */
   3445       1.23      fvdl 	pc->pc_caseinsensitive = nfs_false;
   3446       1.23      fvdl 	pc->pc_casepreserving = nfs_true;
   3447        1.1       cgd 	nfsm_srvdone;
   3448        1.1       cgd }
   3449        1.1       cgd 
   3450        1.1       cgd /*
   3451        1.1       cgd  * Null operation, used by clients to ping server
   3452        1.1       cgd  */
   3453        1.1       cgd /* ARGSUSED */
   3454       1.22  christos int
   3455       1.99  christos nfsrv_null(nfsd, slp, lwp, mrq)
   3456       1.23      fvdl 	struct nfsrv_descript *nfsd;
   3457       1.23      fvdl 	struct nfssvc_sock *slp;
   3458       1.99  christos 	struct lwp *lwp;
   3459       1.23      fvdl 	struct mbuf **mrq;
   3460        1.1       cgd {
   3461       1.23      fvdl 	struct mbuf *mrep = nfsd->nd_mrep;
   3462        1.1       cgd 	caddr_t bpos;
   3463       1.23      fvdl 	int error = NFSERR_RETVOID, cache = 0;
   3464        1.1       cgd 	struct mbuf *mb, *mreq;
   3465       1.15   mycroft 	u_quad_t frev;
   3466        1.1       cgd 
   3467        1.1       cgd 	nfsm_reply(0);
   3468       1.23      fvdl 	return (0);
   3469        1.1       cgd }
   3470        1.1       cgd 
   3471        1.1       cgd /*
   3472        1.1       cgd  * No operation, used for obsolete procedures
   3473        1.1       cgd  */
   3474        1.1       cgd /* ARGSUSED */
   3475       1.22  christos int
   3476       1.99  christos nfsrv_noop(nfsd, slp, lwp, mrq)
   3477       1.23      fvdl 	struct nfsrv_descript *nfsd;
   3478       1.23      fvdl 	struct nfssvc_sock *slp;
   3479       1.99  christos 	struct lwp *lwp;
   3480       1.23      fvdl 	struct mbuf **mrq;
   3481        1.1       cgd {
   3482       1.23      fvdl 	struct mbuf *mrep = nfsd->nd_mrep;
   3483        1.1       cgd 	caddr_t bpos;
   3484       1.22  christos 	int error, cache = 0;
   3485        1.1       cgd 	struct mbuf *mb, *mreq;
   3486       1.15   mycroft 	u_quad_t frev;
   3487        1.1       cgd 
   3488       1.15   mycroft 	if (nfsd->nd_repstat)
   3489       1.15   mycroft 		error = nfsd->nd_repstat;
   3490        1.2       cgd 	else
   3491        1.2       cgd 		error = EPROCUNAVAIL;
   3492        1.1       cgd 	nfsm_reply(0);
   3493       1.23      fvdl 	return (0);
   3494        1.1       cgd }
   3495        1.1       cgd 
   3496        1.1       cgd /*
   3497        1.1       cgd  * Perform access checking for vnodes obtained from file handles that would
   3498        1.1       cgd  * refer to files already opened by a Unix client. You cannot just use
   3499        1.1       cgd  * vn_writechk() and VOP_ACCESS() for two reasons.
   3500       1.15   mycroft  * 1 - You must check for exported rdonly as well as MNT_RDONLY for the write case
   3501       1.27      fvdl  * 2 - The owner is to be given access irrespective of mode bits for some
   3502       1.27      fvdl  *     operations, so that processes that chmod after opening a file don't
   3503       1.27      fvdl  *     break. I don't like this because it opens a security hole, but since
   3504       1.27      fvdl  *     the nfs server opens a security hole the size of a barn door anyhow,
   3505       1.27      fvdl  *     what the heck.
   3506       1.31      fvdl  *
   3507       1.31      fvdl  * The exception to rule 2 is EPERM. If a file is IMMUTABLE, VOP_ACCESS()
   3508       1.31      fvdl  * will return EPERM instead of EACCESS. EPERM is always an error.
   3509        1.1       cgd  */
   3510       1.22  christos int
   3511       1.99  christos nfsrv_access(vp, flags, cred, rdonly, lwp, override)
   3512       1.54  augustss 	struct vnode *vp;
   3513        1.1       cgd 	int flags;
   3514  1.101.2.2      yamt 	kauth_cred_t cred;
   3515       1.15   mycroft 	int rdonly;
   3516       1.99  christos 	struct lwp *lwp;
   3517        1.1       cgd {
   3518        1.1       cgd 	struct vattr vattr;
   3519        1.1       cgd 	int error;
   3520        1.1       cgd 	if (flags & VWRITE) {
   3521       1.15   mycroft 		/* Just vn_writechk() changed to check rdonly */
   3522        1.1       cgd 		/*
   3523        1.1       cgd 		 * Disallow write attempts on read-only file systems;
   3524        1.1       cgd 		 * unless the file is a socket or a block or character
   3525        1.1       cgd 		 * device resident on the file system.
   3526        1.1       cgd 		 */
   3527       1.15   mycroft 		if (rdonly || (vp->v_mount->mnt_flag & MNT_RDONLY)) {
   3528        1.1       cgd 			switch (vp->v_type) {
   3529       1.23      fvdl 			case VREG:
   3530       1.23      fvdl 			case VDIR:
   3531       1.23      fvdl 			case VLNK:
   3532        1.1       cgd 				return (EROFS);
   3533       1.23      fvdl 			default:
   3534       1.22  christos 				break;
   3535        1.1       cgd 			}
   3536        1.1       cgd 		}
   3537       1.59       chs 
   3538        1.1       cgd 		/*
   3539       1.59       chs 		 * If the vnode is in use as a process's text,
   3540       1.59       chs 		 * we can't allow writing.
   3541        1.1       cgd 		 */
   3542       1.94     perry 		if (vp->v_flag & VTEXT)
   3543       1.40       mrg 			return (ETXTBSY);
   3544        1.1       cgd 	}
   3545       1.99  christos 	error = VOP_GETATTR(vp, &vattr, cred, lwp);
   3546       1.23      fvdl 	if (error)
   3547        1.1       cgd 		return (error);
   3548       1.99  christos 	error = VOP_ACCESS(vp, flags, cred, lwp);
   3549       1.27      fvdl 	/*
   3550       1.27      fvdl 	 * Allow certain operations for the owner (reads and writes
   3551       1.27      fvdl 	 * on files that are already open).
   3552       1.27      fvdl 	 */
   3553  1.101.2.2      yamt 	if (override && error == EACCES && kauth_cred_geteuid(cred) == vattr.va_uid)
   3554       1.27      fvdl 		error = 0;
   3555       1.27      fvdl 	return error;
   3556        1.1       cgd }
   3557