Home | History | Annotate | Line # | Download | only in nfs
nfs_serv.c revision 1.101.2.3
      1  1.101.2.3      yamt /*	$NetBSD: nfs_serv.c,v 1.101.2.3 2006/06/26 12:54:28 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.3      yamt __KERNEL_RCSID(0, "$NetBSD: nfs_serv.c,v 1.101.2.3 2006/06/26 12:54:28 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.101.2.3      yamt 	error = vfs_composefh(vp, fhp);
    450       1.23      fvdl 	if (!error)
    451       1.99  christos 		error = VOP_GETATTR(vp, &va, cred, lwp);
    452       1.23      fvdl 	vput(vp);
    453       1.23      fvdl 	nfsm_reply(NFSX_SRVFH(v3) + NFSX_POSTOPORFATTR(v3) + NFSX_POSTOPATTR(v3));
    454       1.23      fvdl 	if (error) {
    455       1.23      fvdl 		nfsm_srvpostop_attr(dirattr_ret, &dirattr);
    456       1.23      fvdl 		return (0);
    457        1.1       cgd 	}
    458       1.23      fvdl 	nfsm_srvfhtom(fhp, v3);
    459       1.23      fvdl 	if (v3) {
    460       1.23      fvdl 		nfsm_srvpostop_attr(0, &va);
    461       1.23      fvdl 		nfsm_srvpostop_attr(dirattr_ret, &dirattr);
    462       1.23      fvdl 	} else {
    463       1.23      fvdl 		nfsm_build(fp, struct nfs_fattr *, NFSX_V2FATTR);
    464       1.23      fvdl 		nfsm_srvfillattr(&va, fp);
    465       1.15   mycroft 	}
    466        1.1       cgd 	nfsm_srvdone;
    467        1.1       cgd }
    468        1.1       cgd 
    469        1.1       cgd /*
    470        1.1       cgd  * nfs readlink service
    471        1.1       cgd  */
    472       1.22  christos int
    473       1.99  christos nfsrv_readlink(nfsd, slp, lwp, mrq)
    474       1.23      fvdl 	struct nfsrv_descript *nfsd;
    475       1.23      fvdl 	struct nfssvc_sock *slp;
    476       1.99  christos 	struct lwp *lwp;
    477       1.23      fvdl 	struct mbuf **mrq;
    478        1.1       cgd {
    479       1.23      fvdl 	struct mbuf *mrep = nfsd->nd_mrep, *md = nfsd->nd_md;
    480       1.23      fvdl 	struct mbuf *nam = nfsd->nd_nam;
    481       1.23      fvdl 	caddr_t dpos = nfsd->nd_dpos;
    482  1.101.2.2      yamt 	kauth_cred_t cred = nfsd->nd_cr;
    483        1.1       cgd 	struct iovec iv[(NFS_MAXPATHLEN+MLEN-1)/MLEN];
    484       1.54  augustss 	struct iovec *ivp = iv;
    485       1.54  augustss 	struct mbuf *mp;
    486       1.54  augustss 	u_int32_t *tl;
    487       1.54  augustss 	int32_t t1;
    488        1.1       cgd 	caddr_t bpos;
    489  1.101.2.2      yamt 	int error = 0, rdonly, cache = 0, i, padlen, getret;
    490       1.76      yamt 	uint32_t len;
    491       1.23      fvdl 	int v3 = (nfsd->nd_flag & ND_NFSV3);
    492        1.1       cgd 	char *cp2;
    493       1.67      matt 	struct mbuf *mb, *mp2 = NULL, *mp3 = NULL, *mreq;
    494        1.1       cgd 	struct vnode *vp;
    495       1.23      fvdl 	struct vattr attr;
    496       1.23      fvdl 	nfsfh_t nfh;
    497        1.1       cgd 	fhandle_t *fhp;
    498        1.1       cgd 	struct uio io, *uiop = &io;
    499       1.15   mycroft 	u_quad_t frev;
    500        1.1       cgd 
    501        1.1       cgd 	fhp = &nfh.fh_generic;
    502        1.1       cgd 	nfsm_srvmtofh(fhp);
    503        1.1       cgd 	len = 0;
    504        1.1       cgd 	i = 0;
    505        1.1       cgd 	while (len < NFS_MAXPATHLEN) {
    506       1.67      matt 		mp = m_get(M_WAIT, MT_DATA);
    507       1.67      matt 		MCLAIM(mp, &nfs_mowner);
    508       1.67      matt 		m_clget(mp, M_WAIT);
    509        1.1       cgd 		mp->m_len = NFSMSIZ(mp);
    510        1.1       cgd 		if (len == 0)
    511        1.1       cgd 			mp3 = mp2 = mp;
    512        1.1       cgd 		else {
    513        1.1       cgd 			mp2->m_next = mp;
    514        1.1       cgd 			mp2 = mp;
    515        1.1       cgd 		}
    516        1.1       cgd 		if ((len+mp->m_len) > NFS_MAXPATHLEN) {
    517        1.1       cgd 			mp->m_len = NFS_MAXPATHLEN-len;
    518        1.1       cgd 			len = NFS_MAXPATHLEN;
    519        1.1       cgd 		} else
    520        1.1       cgd 			len += mp->m_len;
    521        1.1       cgd 		ivp->iov_base = mtod(mp, caddr_t);
    522        1.1       cgd 		ivp->iov_len = mp->m_len;
    523        1.1       cgd 		i++;
    524        1.1       cgd 		ivp++;
    525        1.1       cgd 	}
    526        1.1       cgd 	uiop->uio_iov = iv;
    527        1.1       cgd 	uiop->uio_iovcnt = i;
    528        1.1       cgd 	uiop->uio_offset = 0;
    529        1.1       cgd 	uiop->uio_resid = len;
    530        1.1       cgd 	uiop->uio_rw = UIO_READ;
    531      1.101      yamt 	UIO_SETUP_SYSSPACE(uiop);
    532       1.23      fvdl 	error = nfsrv_fhtovp(fhp, 1, &vp, cred, slp, nam,
    533       1.78   thorpej 		 &rdonly, (nfsd->nd_flag & ND_KERBAUTH), FALSE);
    534       1.22  christos 	if (error) {
    535        1.1       cgd 		m_freem(mp3);
    536       1.23      fvdl 		nfsm_reply(2 * NFSX_UNSIGNED);
    537       1.23      fvdl 		nfsm_srvpostop_attr(1, (struct vattr *)0);
    538       1.23      fvdl 		return (0);
    539        1.1       cgd 	}
    540        1.1       cgd 	if (vp->v_type != VLNK) {
    541       1.23      fvdl 		if (v3)
    542       1.23      fvdl 			error = EINVAL;
    543       1.23      fvdl 		else
    544       1.23      fvdl 			error = ENXIO;
    545        1.1       cgd 		goto out;
    546        1.1       cgd 	}
    547       1.23      fvdl 	nqsrv_getl(vp, ND_READ);
    548        1.1       cgd 	error = VOP_READLINK(vp, uiop, cred);
    549        1.1       cgd out:
    550       1.99  christos 	getret = VOP_GETATTR(vp, &attr, cred, lwp);
    551        1.1       cgd 	vput(vp);
    552        1.1       cgd 	if (error)
    553        1.1       cgd 		m_freem(mp3);
    554       1.23      fvdl 	nfsm_reply(NFSX_POSTOPATTR(v3) + NFSX_UNSIGNED);
    555       1.23      fvdl 	if (v3) {
    556       1.23      fvdl 		nfsm_srvpostop_attr(getret, &attr);
    557       1.23      fvdl 		if (error)
    558       1.23      fvdl 			return (0);
    559       1.23      fvdl 	}
    560       1.76      yamt 	len -= uiop->uio_resid;
    561       1.76      yamt 	padlen = nfsm_padlen(len);
    562       1.76      yamt 	if (uiop->uio_resid || padlen)
    563       1.76      yamt 		nfs_zeropad(mp3, uiop->uio_resid, padlen);
    564       1.19       cgd 	nfsm_build(tl, u_int32_t *, NFSX_UNSIGNED);
    565        1.1       cgd 	*tl = txdr_unsigned(len);
    566        1.1       cgd 	mb->m_next = mp3;
    567        1.1       cgd 	nfsm_srvdone;
    568        1.1       cgd }
    569        1.1       cgd 
    570        1.1       cgd /*
    571        1.1       cgd  * nfs read service
    572        1.1       cgd  */
    573       1.22  christos int
    574       1.99  christos nfsrv_read(nfsd, slp, lwp, mrq)
    575       1.23      fvdl 	struct nfsrv_descript *nfsd;
    576       1.23      fvdl 	struct nfssvc_sock *slp;
    577       1.99  christos 	struct lwp *lwp;
    578       1.23      fvdl 	struct mbuf **mrq;
    579        1.1       cgd {
    580       1.23      fvdl 	struct mbuf *mrep = nfsd->nd_mrep, *md = nfsd->nd_md;
    581       1.23      fvdl 	struct mbuf *nam = nfsd->nd_nam;
    582       1.23      fvdl 	caddr_t dpos = nfsd->nd_dpos;
    583  1.101.2.2      yamt 	kauth_cred_t cred = nfsd->nd_cr;
    584       1.54  augustss 	struct mbuf *m;
    585       1.54  augustss 	struct nfs_fattr *fp;
    586       1.54  augustss 	u_int32_t *tl;
    587       1.54  augustss 	int32_t t1;
    588       1.54  augustss 	int i;
    589        1.1       cgd 	caddr_t bpos;
    590  1.101.2.2      yamt 	int error = 0, rdonly, cache = 0, getret;
    591       1.68      yamt 	int v3 = (nfsd->nd_flag & ND_NFSV3);
    592       1.76      yamt 	uint32_t reqlen, len, cnt, left;
    593       1.76      yamt 	int padlen;
    594        1.1       cgd 	char *cp2;
    595       1.67      matt 	struct mbuf *mb, *mreq;
    596        1.1       cgd 	struct vnode *vp;
    597       1.23      fvdl 	nfsfh_t nfh;
    598        1.1       cgd 	fhandle_t *fhp;
    599        1.1       cgd 	struct uio io, *uiop = &io;
    600       1.18   mycroft 	struct vattr va;
    601        1.1       cgd 	off_t off;
    602       1.15   mycroft 	u_quad_t frev;
    603        1.1       cgd 
    604        1.1       cgd 	fhp = &nfh.fh_generic;
    605        1.1       cgd 	nfsm_srvmtofh(fhp);
    606       1.23      fvdl 	if (v3) {
    607       1.23      fvdl 		nfsm_dissect(tl, u_int32_t *, 2 * NFSX_UNSIGNED);
    608       1.48      fair 		off = fxdr_hyper(tl);
    609       1.23      fvdl 	} else {
    610       1.19       cgd 		nfsm_dissect(tl, u_int32_t *, NFSX_UNSIGNED);
    611       1.19       cgd 		off = (off_t)fxdr_unsigned(u_int32_t, *tl);
    612       1.15   mycroft 	}
    613       1.71      yamt 	nfsm_dissect(tl, uint32_t *, NFSX_UNSIGNED);
    614       1.71      yamt 	reqlen = fxdr_unsigned(uint32_t, *tl);
    615       1.71      yamt 	reqlen = MIN(reqlen, NFS_SRVMAXDATA(nfsd));
    616       1.23      fvdl 	error = nfsrv_fhtovp(fhp, 1, &vp, cred, slp, nam,
    617       1.78   thorpej 		 &rdonly, (nfsd->nd_flag & ND_KERBAUTH), FALSE);
    618       1.23      fvdl 	if (error) {
    619       1.23      fvdl 		nfsm_reply(2 * NFSX_UNSIGNED);
    620       1.23      fvdl 		nfsm_srvpostop_attr(1, (struct vattr *)0);
    621       1.23      fvdl 		return (0);
    622       1.23      fvdl 	}
    623       1.15   mycroft 	if (vp->v_type != VREG) {
    624       1.23      fvdl 		if (v3)
    625       1.23      fvdl 			error = EINVAL;
    626       1.23      fvdl 		else
    627       1.23      fvdl 			error = (vp->v_type == VDIR) ? EISDIR : EACCES;
    628        1.1       cgd 	}
    629       1.23      fvdl 	if (!error) {
    630       1.23      fvdl 	    nqsrv_getl(vp, ND_READ);
    631       1.99  christos 	    if ((error = nfsrv_access(vp, VREAD, cred, rdonly, lwp, 1)) != 0)
    632       1.99  christos 		error = nfsrv_access(vp, VEXEC, cred, rdonly, lwp, 1);
    633       1.23      fvdl 	}
    634       1.99  christos 	getret = VOP_GETATTR(vp, &va, cred, lwp);
    635       1.23      fvdl 	if (!error)
    636       1.23      fvdl 		error = getret;
    637       1.22  christos 	if (error) {
    638        1.1       cgd 		vput(vp);
    639       1.23      fvdl 		nfsm_reply(NFSX_POSTOPATTR(v3));
    640       1.23      fvdl 		nfsm_srvpostop_attr(getret, &va);
    641       1.23      fvdl 		return (0);
    642        1.1       cgd 	}
    643       1.18   mycroft 	if (off >= va.va_size)
    644       1.15   mycroft 		cnt = 0;
    645       1.23      fvdl 	else if ((off + reqlen) > va.va_size)
    646       1.76      yamt 		cnt = va.va_size - off;
    647       1.23      fvdl 	else
    648       1.23      fvdl 		cnt = reqlen;
    649       1.23      fvdl 	nfsm_reply(NFSX_POSTOPORFATTR(v3) + 3 * NFSX_UNSIGNED+nfsm_rndup(cnt));
    650       1.23      fvdl 	if (v3) {
    651       1.23      fvdl 		nfsm_build(tl, u_int32_t *, NFSX_V3FATTR + 4 * NFSX_UNSIGNED);
    652       1.23      fvdl 		*tl++ = nfs_true;
    653       1.23      fvdl 		fp = (struct nfs_fattr *)tl;
    654       1.23      fvdl 		tl += (NFSX_V3FATTR / sizeof (u_int32_t));
    655       1.23      fvdl 	} else {
    656       1.23      fvdl 		nfsm_build(tl, u_int32_t *, NFSX_V2FATTR + NFSX_UNSIGNED);
    657       1.23      fvdl 		fp = (struct nfs_fattr *)tl;
    658       1.23      fvdl 		tl += (NFSX_V2FATTR / sizeof (u_int32_t));
    659       1.23      fvdl 	}
    660       1.15   mycroft 	len = left = cnt;
    661       1.73      yamt 	if (cnt > 0) {
    662       1.72      yamt 		if (nfsd_use_loan) {
    663       1.72      yamt 			struct vm_page **pgpp;
    664       1.72      yamt 			voff_t pgoff = trunc_page(off);
    665       1.87      yamt 			int npages;
    666       1.87      yamt 			vaddr_t lva;
    667       1.72      yamt 
    668       1.87      yamt 			npages = (round_page(off + cnt) - pgoff) >> PAGE_SHIFT;
    669       1.87      yamt 			KASSERT(npages <= M_EXT_MAXPAGES); /* XXX */
    670       1.72      yamt 
    671       1.87      yamt 			/* allocate kva for mbuf data */
    672       1.87      yamt 			lva = sokvaalloc(npages << PAGE_SHIFT, slp->ns_so);
    673       1.72      yamt 			if (lva == 0) {
    674       1.72      yamt 				/* fall back to VOP_READ */
    675       1.72      yamt 				goto loan_fail;
    676       1.72      yamt 			}
    677       1.72      yamt 
    678       1.87      yamt 			/* allocate mbuf */
    679       1.72      yamt 			m = m_get(M_WAIT, MT_DATA);
    680       1.87      yamt 			MCLAIM(m, &nfs_mowner);
    681       1.72      yamt 			pgpp = m->m_ext.ext_pgs;
    682       1.75      yamt 
    683       1.87      yamt 			/* loan pages */
    684       1.87      yamt 			error = uvm_loanuobjpages(&vp->v_uobj, pgoff, npages,
    685       1.87      yamt 			    pgpp);
    686       1.87      yamt 			if (error) {
    687       1.87      yamt 				sokvafree(lva, npages << PAGE_SHIFT);
    688       1.87      yamt 				m_free(m);
    689       1.91      yamt 				if (error == EBUSY)
    690       1.91      yamt 					goto loan_fail;
    691       1.87      yamt 				goto read_error;
    692       1.15   mycroft 			}
    693       1.72      yamt 
    694       1.87      yamt 			/* associate kva to mbuf */
    695       1.87      yamt 			MEXTADD(m, (void *)(lva + ((vaddr_t)off & PAGE_MASK)),
    696       1.87      yamt 			    cnt, M_MBUF, soloanfree, slp->ns_so);
    697       1.72      yamt 			m->m_flags |= M_EXT_PAGES | M_EXT_ROMAP;
    698       1.72      yamt 			m->m_len = cnt;
    699       1.72      yamt 
    700       1.87      yamt 			/* map pages */
    701       1.87      yamt 			for (i = 0; i < npages; i++) {
    702       1.87      yamt 				pmap_kenter_pa(lva, VM_PAGE_TO_PHYS(pgpp[i]),
    703       1.87      yamt 				    VM_PROT_READ);
    704       1.87      yamt 				lva += PAGE_SIZE;
    705       1.87      yamt 			}
    706       1.87      yamt 
    707       1.72      yamt 			pmap_update(pmap_kernel());
    708       1.87      yamt 
    709       1.72      yamt 			mb->m_next = m;
    710       1.72      yamt 			mb = m;
    711       1.72      yamt 			error = 0;
    712       1.72      yamt 			uiop->uio_resid = 0;
    713       1.72      yamt 		} else {
    714       1.72      yamt 			struct iovec *iv;
    715       1.72      yamt 			struct iovec *iv2;
    716       1.72      yamt 			struct mbuf *m2;
    717       1.72      yamt 			int siz;
    718       1.72      yamt loan_fail:
    719       1.72      yamt 			/*
    720       1.72      yamt 			 * Generate the mbuf list with the uio_iov ref. to it.
    721       1.72      yamt 			 */
    722       1.72      yamt 			i = 0;
    723       1.72      yamt 			m = m2 = mb;
    724       1.72      yamt 			while (left > 0) {
    725       1.72      yamt 				siz = min(M_TRAILINGSPACE(m), left);
    726       1.72      yamt 				if (siz > 0) {
    727       1.72      yamt 					left -= siz;
    728       1.72      yamt 					i++;
    729       1.72      yamt 				}
    730       1.72      yamt 				if (left > 0) {
    731       1.72      yamt 					m = m_get(M_WAIT, MT_DATA);
    732       1.72      yamt 					MCLAIM(m, &nfs_mowner);
    733       1.72      yamt 					m_clget(m, M_WAIT);
    734       1.72      yamt 					m->m_len = 0;
    735       1.72      yamt 					m2->m_next = m;
    736       1.72      yamt 					m2 = m;
    737       1.72      yamt 				}
    738       1.72      yamt 			}
    739       1.72      yamt 			iv = malloc(i * sizeof(struct iovec), M_TEMP, M_WAITOK);
    740       1.72      yamt 			uiop->uio_iov = iv2 = iv;
    741       1.72      yamt 			m = mb;
    742       1.72      yamt 			left = cnt;
    743       1.72      yamt 			i = 0;
    744       1.72      yamt 			while (left > 0) {
    745       1.72      yamt 				if (m == NULL)
    746       1.72      yamt 					panic("nfsrv_read iov");
    747       1.72      yamt 				siz = min(M_TRAILINGSPACE(m), left);
    748       1.72      yamt 				if (siz > 0) {
    749       1.72      yamt 					iv->iov_base = mtod(m, caddr_t) +
    750       1.72      yamt 					    m->m_len;
    751       1.72      yamt 					iv->iov_len = siz;
    752       1.72      yamt 					m->m_len += siz;
    753       1.72      yamt 					left -= siz;
    754       1.72      yamt 					iv++;
    755       1.72      yamt 					i++;
    756       1.72      yamt 				}
    757       1.72      yamt 				m = m->m_next;
    758       1.23      fvdl 			}
    759       1.72      yamt 			uiop->uio_iovcnt = i;
    760       1.72      yamt 			uiop->uio_offset = off;
    761       1.72      yamt 			uiop->uio_resid = cnt;
    762       1.72      yamt 			uiop->uio_rw = UIO_READ;
    763      1.101      yamt 			UIO_SETUP_SYSSPACE(uiop);
    764       1.72      yamt 			error = VOP_READ(vp, uiop, IO_NODELOCKED, cred);
    765       1.72      yamt 			free((caddr_t)iv2, M_TEMP);
    766       1.23      fvdl 		}
    767       1.72      yamt read_error:
    768       1.99  christos 		if (error || (getret = VOP_GETATTR(vp, &va, cred, lwp)) != 0){
    769       1.23      fvdl 			if (!error)
    770       1.23      fvdl 				error = getret;
    771       1.15   mycroft 			m_freem(mreq);
    772       1.15   mycroft 			vput(vp);
    773       1.23      fvdl 			nfsm_reply(NFSX_POSTOPATTR(v3));
    774       1.23      fvdl 			nfsm_srvpostop_attr(getret, &va);
    775       1.23      fvdl 			return (0);
    776       1.15   mycroft 		}
    777       1.72      yamt 	} else {
    778       1.15   mycroft 		uiop->uio_resid = 0;
    779       1.72      yamt 	}
    780        1.1       cgd 	vput(vp);
    781       1.23      fvdl 	nfsm_srvfillattr(&va, fp);
    782        1.1       cgd 	len -= uiop->uio_resid;
    783       1.76      yamt 	padlen = nfsm_padlen(len);
    784       1.76      yamt 	if (uiop->uio_resid || padlen)
    785       1.76      yamt 		nfs_zeropad(mb, uiop->uio_resid, padlen);
    786       1.23      fvdl 	if (v3) {
    787       1.83      yamt 		/* count */
    788       1.23      fvdl 		*tl++ = txdr_unsigned(len);
    789       1.83      yamt 		/* eof */
    790       1.83      yamt 		if (off + len >= va.va_size)
    791       1.23      fvdl 			*tl++ = nfs_true;
    792       1.23      fvdl 		else
    793       1.23      fvdl 			*tl++ = nfs_false;
    794       1.23      fvdl 	}
    795        1.1       cgd 	*tl = txdr_unsigned(len);
    796        1.1       cgd 	nfsm_srvdone;
    797        1.1       cgd }
    798        1.1       cgd 
    799        1.1       cgd /*
    800        1.1       cgd  * nfs write service
    801        1.1       cgd  */
    802       1.22  christos int
    803       1.99  christos nfsrv_write(nfsd, slp, lwp, mrq)
    804       1.23      fvdl 	struct nfsrv_descript *nfsd;
    805       1.23      fvdl 	struct nfssvc_sock *slp;
    806       1.99  christos 	struct lwp *lwp;
    807       1.23      fvdl 	struct mbuf **mrq;
    808        1.1       cgd {
    809       1.23      fvdl 	struct mbuf *mrep = nfsd->nd_mrep, *md = nfsd->nd_md;
    810       1.23      fvdl 	struct mbuf *nam = nfsd->nd_nam;
    811       1.23      fvdl 	caddr_t dpos = nfsd->nd_dpos;
    812  1.101.2.2      yamt 	kauth_cred_t cred = nfsd->nd_cr;
    813       1.54  augustss 	struct iovec *ivp;
    814       1.54  augustss 	int i, cnt;
    815       1.54  augustss 	struct mbuf *mp;
    816       1.54  augustss 	struct nfs_fattr *fp;
    817       1.23      fvdl 	struct iovec *iv;
    818       1.23      fvdl 	struct vattr va, forat;
    819       1.54  augustss 	u_int32_t *tl;
    820       1.54  augustss 	int32_t t1;
    821        1.1       cgd 	caddr_t bpos;
    822  1.101.2.2      yamt 	int error = 0, rdonly, cache = 0, len, forat_ret = 1;
    823       1.23      fvdl 	int ioflags, aftat_ret = 1, retlen, zeroing, adjust;
    824       1.23      fvdl 	int stable = NFSV3WRITE_FILESYNC;
    825       1.23      fvdl 	int v3 = (nfsd->nd_flag & ND_NFSV3);
    826        1.1       cgd 	char *cp2;
    827       1.67      matt 	struct mbuf *mb, *mreq;
    828        1.1       cgd 	struct vnode *vp;
    829       1.23      fvdl 	nfsfh_t nfh;
    830        1.1       cgd 	fhandle_t *fhp;
    831        1.1       cgd 	struct uio io, *uiop = &io;
    832        1.1       cgd 	off_t off;
    833       1.15   mycroft 	u_quad_t frev;
    834       1.82   hannken 	struct mount *mntp = NULL;
    835        1.1       cgd 
    836       1.23      fvdl 	if (mrep == NULL) {
    837       1.23      fvdl 		*mrq = NULL;
    838       1.23      fvdl 		return (0);
    839       1.23      fvdl 	}
    840        1.1       cgd 	fhp = &nfh.fh_generic;
    841        1.1       cgd 	nfsm_srvmtofh(fhp);
    842       1.82   hannken 	if ((mntp = vfs_getvfs(&fhp->fh_fsid)) == NULL)
    843       1.82   hannken 		return (ESTALE);
    844       1.82   hannken 	vn_start_write(NULL, &mntp, V_WAIT);
    845       1.23      fvdl 	if (v3) {
    846       1.23      fvdl 		nfsm_dissect(tl, u_int32_t *, 5 * NFSX_UNSIGNED);
    847       1.48      fair 		off = fxdr_hyper(tl);
    848       1.23      fvdl 		tl += 3;
    849       1.23      fvdl 		stable = fxdr_unsigned(int, *tl++);
    850       1.23      fvdl 	} else {
    851       1.23      fvdl 		nfsm_dissect(tl, u_int32_t *, 4 * NFSX_UNSIGNED);
    852       1.19       cgd 		off = (off_t)fxdr_unsigned(u_int32_t, *++tl);
    853       1.15   mycroft 		tl += 2;
    854       1.15   mycroft 	}
    855       1.23      fvdl 	retlen = len = fxdr_unsigned(int32_t, *tl);
    856       1.23      fvdl 	cnt = i = 0;
    857       1.23      fvdl 
    858       1.23      fvdl 	/*
    859       1.23      fvdl 	 * For NFS Version 2, it is not obvious what a write of zero length
    860       1.23      fvdl 	 * should do, but I might as well be consistent with Version 3,
    861       1.23      fvdl 	 * which is to return ok so long as there are no permission problems.
    862       1.23      fvdl 	 */
    863       1.23      fvdl 	if (len > 0) {
    864       1.74      yamt 		zeroing = 1;
    865       1.74      yamt 		mp = mrep;
    866       1.74      yamt 		while (mp) {
    867       1.74      yamt 			if (mp == md) {
    868       1.74      yamt 				zeroing = 0;
    869       1.74      yamt 				adjust = dpos - mtod(mp, caddr_t);
    870       1.74      yamt 				mp->m_len -= adjust;
    871       1.74      yamt 				if (mp->m_len > 0 && adjust > 0)
    872       1.74      yamt 					NFSMADV(mp, adjust);
    873       1.23      fvdl 			}
    874       1.74      yamt 			if (zeroing)
    875       1.74      yamt 				mp->m_len = 0;
    876       1.74      yamt 			else if (mp->m_len > 0) {
    877       1.74      yamt 				i += mp->m_len;
    878       1.74      yamt 				if (i > len) {
    879       1.74      yamt 					mp->m_len -= (i - len);
    880       1.74      yamt 					zeroing	= 1;
    881       1.74      yamt 				}
    882       1.74      yamt 				if (mp->m_len > 0)
    883       1.74      yamt 					cnt++;
    884       1.74      yamt 			}
    885       1.74      yamt 			mp = mp->m_next;
    886       1.23      fvdl 		}
    887       1.23      fvdl 	}
    888       1.23      fvdl 	if (len > NFS_MAXDATA || len < 0 || i < len) {
    889       1.23      fvdl 		error = EIO;
    890       1.23      fvdl 		nfsm_reply(2 * NFSX_UNSIGNED);
    891       1.23      fvdl 		nfsm_srvwcc_data(forat_ret, &forat, aftat_ret, &va);
    892       1.82   hannken 		vn_finished_write(mntp, 0);
    893       1.23      fvdl 		return (0);
    894        1.1       cgd 	}
    895       1.23      fvdl 	error = nfsrv_fhtovp(fhp, 1, &vp, cred, slp, nam,
    896       1.78   thorpej 		 &rdonly, (nfsd->nd_flag & ND_KERBAUTH), FALSE);
    897       1.23      fvdl 	if (error) {
    898       1.23      fvdl 		nfsm_reply(2 * NFSX_UNSIGNED);
    899       1.23      fvdl 		nfsm_srvwcc_data(forat_ret, &forat, aftat_ret, &va);
    900       1.82   hannken 		vn_finished_write(mntp, 0);
    901       1.23      fvdl 		return (0);
    902        1.1       cgd 	}
    903       1.23      fvdl 	if (v3)
    904       1.99  christos 		forat_ret = VOP_GETATTR(vp, &forat, cred, lwp);
    905       1.15   mycroft 	if (vp->v_type != VREG) {
    906       1.23      fvdl 		if (v3)
    907       1.23      fvdl 			error = EINVAL;
    908       1.23      fvdl 		else
    909       1.23      fvdl 			error = (vp->v_type == VDIR) ? EISDIR : EACCES;
    910       1.23      fvdl 	}
    911       1.23      fvdl 	if (!error) {
    912       1.23      fvdl 		nqsrv_getl(vp, ND_WRITE);
    913       1.99  christos 		error = nfsrv_access(vp, VWRITE, cred, rdonly, lwp, 1);
    914       1.15   mycroft 	}
    915       1.22  christos 	if (error) {
    916        1.1       cgd 		vput(vp);
    917       1.23      fvdl 		nfsm_reply(NFSX_WCCDATA(v3));
    918       1.23      fvdl 		nfsm_srvwcc_data(forat_ret, &forat, aftat_ret, &va);
    919       1.82   hannken 		vn_finished_write(mntp, 0);
    920       1.23      fvdl 		return (0);
    921       1.23      fvdl 	}
    922       1.23      fvdl 
    923       1.23      fvdl 	if (len > 0) {
    924       1.74      yamt 		ivp = malloc(cnt * sizeof (struct iovec), M_TEMP, M_WAITOK);
    925       1.74      yamt 		uiop->uio_iov = iv = ivp;
    926       1.74      yamt 		uiop->uio_iovcnt = cnt;
    927       1.74      yamt 		mp = mrep;
    928       1.74      yamt 		while (mp) {
    929       1.74      yamt 			if (mp->m_len > 0) {
    930       1.74      yamt 				ivp->iov_base = mtod(mp, caddr_t);
    931       1.74      yamt 				ivp->iov_len = mp->m_len;
    932       1.74      yamt 				ivp++;
    933       1.74      yamt 			}
    934       1.74      yamt 			mp = mp->m_next;
    935       1.74      yamt 		}
    936       1.74      yamt 
    937       1.74      yamt 		/*
    938       1.74      yamt 		 * XXX
    939       1.74      yamt 		 * The IO_METASYNC flag indicates that all metadata (and not
    940       1.74      yamt 		 * just enough to ensure data integrity) must be written to
    941       1.74      yamt 		 * stable storage synchronously.
    942       1.74      yamt 		 * (IO_METASYNC is not yet implemented in 4.4BSD-Lite.)
    943       1.74      yamt 		 */
    944       1.74      yamt 		if (stable == NFSV3WRITE_UNSTABLE)
    945       1.74      yamt 			ioflags = IO_NODELOCKED;
    946       1.74      yamt 		else if (stable == NFSV3WRITE_DATASYNC)
    947       1.74      yamt 			ioflags = (IO_SYNC | IO_NODELOCKED);
    948       1.74      yamt 		else
    949       1.74      yamt 			ioflags = (IO_METASYNC | IO_SYNC | IO_NODELOCKED);
    950       1.74      yamt 		uiop->uio_resid = len;
    951       1.74      yamt 		uiop->uio_rw = UIO_WRITE;
    952       1.74      yamt 		uiop->uio_offset = off;
    953      1.101      yamt 		UIO_SETUP_SYSSPACE(uiop);
    954       1.74      yamt 		error = VOP_WRITE(vp, uiop, ioflags, cred);
    955       1.74      yamt 		nfsstats.srvvop_writes++;
    956       1.74      yamt 		free(iv, M_TEMP);
    957       1.23      fvdl 	}
    958       1.99  christos 	aftat_ret = VOP_GETATTR(vp, &va, cred, lwp);
    959       1.23      fvdl 	vput(vp);
    960       1.82   hannken 	vn_finished_write(mntp, 0);
    961       1.23      fvdl 	if (!error)
    962       1.23      fvdl 		error = aftat_ret;
    963       1.23      fvdl 	nfsm_reply(NFSX_PREOPATTR(v3) + NFSX_POSTOPORFATTR(v3) +
    964       1.23      fvdl 		2 * NFSX_UNSIGNED + NFSX_WRITEVERF(v3));
    965       1.23      fvdl 	if (v3) {
    966       1.23      fvdl 		nfsm_srvwcc_data(forat_ret, &forat, aftat_ret, &va);
    967       1.23      fvdl 		if (error)
    968       1.23      fvdl 			return (0);
    969       1.23      fvdl 		nfsm_build(tl, u_int32_t *, 4 * NFSX_UNSIGNED);
    970       1.23      fvdl 		*tl++ = txdr_unsigned(retlen);
    971       1.23      fvdl 		if (stable == NFSV3WRITE_UNSTABLE)
    972       1.23      fvdl 			*tl++ = txdr_unsigned(stable);
    973       1.23      fvdl 		else
    974       1.23      fvdl 			*tl++ = txdr_unsigned(NFSV3WRITE_FILESYNC);
    975       1.23      fvdl 		/*
    976       1.23      fvdl 		 * Actually, there is no need to txdr these fields,
    977       1.23      fvdl 		 * but it may make the values more human readable,
    978       1.23      fvdl 		 * for debugging purposes.
    979       1.23      fvdl 		 */
    980       1.23      fvdl 		*tl++ = txdr_unsigned(boottime.tv_sec);
    981       1.23      fvdl 		*tl = txdr_unsigned(boottime.tv_usec);
    982       1.23      fvdl 	} else {
    983       1.23      fvdl 		nfsm_build(fp, struct nfs_fattr *, NFSX_V2FATTR);
    984       1.23      fvdl 		nfsm_srvfillattr(&va, fp);
    985       1.23      fvdl 	}
    986       1.23      fvdl 	nfsm_srvdone;
    987       1.23      fvdl }
    988       1.23      fvdl 
    989       1.23      fvdl /*
    990  1.101.2.2      yamt  * XXX elad: the original NFSW_SAMECRED() macro also made sure the
    991  1.101.2.2      yamt  *	     two nd_flag fields of the descriptors contained
    992  1.101.2.2      yamt  *	     ND_KERBAUTH.
    993  1.101.2.2      yamt  */
    994  1.101.2.2      yamt static int
    995  1.101.2.2      yamt nfsrv_samecred(kauth_cred_t cred1, kauth_cred_t cred2)
    996  1.101.2.2      yamt {
    997  1.101.2.2      yamt 	int i, do_ngroups;
    998  1.101.2.2      yamt 
    999  1.101.2.2      yamt 	if (kauth_cred_geteuid(cred1) != kauth_cred_geteuid(cred2))
   1000  1.101.2.2      yamt 		return (0);
   1001  1.101.2.2      yamt 	if (kauth_cred_ngroups(cred1) != kauth_cred_ngroups(cred2))
   1002  1.101.2.2      yamt 		return (0);
   1003  1.101.2.2      yamt 	do_ngroups = kauth_cred_ngroups(cred1);
   1004  1.101.2.2      yamt 	for (i = 0; i < do_ngroups; i++)
   1005  1.101.2.2      yamt 		if (kauth_cred_group(cred1, i) !=
   1006  1.101.2.2      yamt 		    kauth_cred_group(cred2, i))
   1007  1.101.2.2      yamt 			return (0);
   1008  1.101.2.2      yamt 
   1009  1.101.2.2      yamt 	return (1);
   1010  1.101.2.2      yamt }
   1011  1.101.2.2      yamt 
   1012  1.101.2.2      yamt /*
   1013       1.23      fvdl  * NFS write service with write gathering support. Called when
   1014       1.23      fvdl  * nfsrvw_procrastinate > 0.
   1015       1.23      fvdl  * See: Chet Juszczak, "Improving the Write Performance of an NFS Server",
   1016       1.23      fvdl  * in Proc. of the Winter 1994 Usenix Conference, pg. 247-259, San Franscisco,
   1017       1.23      fvdl  * Jan. 1994.
   1018       1.23      fvdl  */
   1019       1.23      fvdl int
   1020       1.99  christos nfsrv_writegather(ndp, slp, lwp, mrq)
   1021       1.23      fvdl 	struct nfsrv_descript **ndp;
   1022       1.23      fvdl 	struct nfssvc_sock *slp;
   1023       1.99  christos 	struct lwp *lwp;
   1024       1.23      fvdl 	struct mbuf **mrq;
   1025       1.23      fvdl {
   1026  1.101.2.3      yamt 	struct timeval now;
   1027       1.54  augustss 	struct iovec *ivp;
   1028       1.54  augustss 	struct mbuf *mp;
   1029       1.54  augustss 	struct nfsrv_descript *wp, *nfsd, *owp, *swp;
   1030       1.54  augustss 	struct nfs_fattr *fp;
   1031       1.54  augustss 	int i = 0;
   1032       1.23      fvdl 	struct iovec *iov;
   1033       1.23      fvdl 	struct nfsrvw_delayhash *wpp;
   1034  1.101.2.2      yamt 	kauth_cred_t cred;
   1035       1.23      fvdl 	struct vattr va, forat;
   1036       1.54  augustss 	u_int32_t *tl;
   1037       1.54  augustss 	int32_t t1;
   1038       1.23      fvdl 	caddr_t bpos, dpos;
   1039  1.101.2.2      yamt 	int error = 0, rdonly, cache = 0, len = 0, forat_ret = 1;
   1040       1.23      fvdl 	int ioflags, aftat_ret = 1, s, adjust, v3, zeroing;
   1041       1.23      fvdl 	char *cp2;
   1042       1.67      matt 	struct mbuf *mb, *mreq, *mrep, *md;
   1043       1.23      fvdl 	struct vnode *vp;
   1044       1.23      fvdl 	struct uio io, *uiop = &io;
   1045       1.23      fvdl 	u_quad_t frev, cur_usec;
   1046       1.82   hannken 	struct mount *mntp = NULL;
   1047       1.23      fvdl 
   1048       1.23      fvdl 	*mrq = NULL;
   1049       1.23      fvdl 	if (*ndp) {
   1050       1.23      fvdl 	    nfsd = *ndp;
   1051       1.23      fvdl 	    *ndp = NULL;
   1052       1.23      fvdl 	    mrep = nfsd->nd_mrep;
   1053       1.23      fvdl 	    md = nfsd->nd_md;
   1054       1.23      fvdl 	    dpos = nfsd->nd_dpos;
   1055  1.101.2.2      yamt 	    cred = nfsd->nd_cr;
   1056       1.23      fvdl 	    v3 = (nfsd->nd_flag & ND_NFSV3);
   1057       1.23      fvdl 	    LIST_INIT(&nfsd->nd_coalesce);
   1058       1.23      fvdl 	    nfsd->nd_mreq = NULL;
   1059       1.23      fvdl 	    nfsd->nd_stable = NFSV3WRITE_FILESYNC;
   1060  1.101.2.3      yamt 	    getmicrotime(&now);
   1061  1.101.2.3      yamt 	    cur_usec = (u_quad_t)now.tv_sec * 1000000 + (u_quad_t)now.tv_usec;
   1062       1.23      fvdl 	    nfsd->nd_time = cur_usec + nfsrvw_procrastinate;
   1063       1.94     perry 
   1064       1.23      fvdl 	    /*
   1065       1.23      fvdl 	     * Now, get the write header..
   1066       1.23      fvdl 	     */
   1067       1.23      fvdl 	    nfsm_srvmtofh(&nfsd->nd_fh);
   1068       1.23      fvdl 	    if (v3) {
   1069       1.23      fvdl 		nfsm_dissect(tl, u_int32_t *, 5 * NFSX_UNSIGNED);
   1070       1.48      fair 		nfsd->nd_off = fxdr_hyper(tl);
   1071       1.23      fvdl 		tl += 3;
   1072       1.23      fvdl 		nfsd->nd_stable = fxdr_unsigned(int, *tl++);
   1073       1.23      fvdl 	    } else {
   1074       1.23      fvdl 		nfsm_dissect(tl, u_int32_t *, 4 * NFSX_UNSIGNED);
   1075       1.23      fvdl 		nfsd->nd_off = (off_t)fxdr_unsigned(u_int32_t, *++tl);
   1076       1.23      fvdl 		tl += 2;
   1077       1.23      fvdl 	    }
   1078       1.23      fvdl 	    len = fxdr_unsigned(int32_t, *tl);
   1079       1.23      fvdl 	    nfsd->nd_len = len;
   1080       1.23      fvdl 	    nfsd->nd_eoff = nfsd->nd_off + len;
   1081       1.94     perry 
   1082       1.23      fvdl 	    /*
   1083       1.23      fvdl 	     * Trim the header out of the mbuf list and trim off any trailing
   1084       1.23      fvdl 	     * junk so that the mbuf list has only the write data.
   1085       1.23      fvdl 	     */
   1086       1.23      fvdl 	    zeroing = 1;
   1087       1.23      fvdl 	    i = 0;
   1088       1.23      fvdl 	    mp = mrep;
   1089       1.23      fvdl 	    while (mp) {
   1090       1.23      fvdl 		if (mp == md) {
   1091       1.23      fvdl 		    zeroing = 0;
   1092       1.23      fvdl 		    adjust = dpos - mtod(mp, caddr_t);
   1093       1.23      fvdl 		    mp->m_len -= adjust;
   1094       1.23      fvdl 		    if (mp->m_len > 0 && adjust > 0)
   1095       1.23      fvdl 			NFSMADV(mp, adjust);
   1096       1.23      fvdl 		}
   1097       1.23      fvdl 		if (zeroing)
   1098       1.23      fvdl 		    mp->m_len = 0;
   1099       1.23      fvdl 		else {
   1100       1.23      fvdl 		    i += mp->m_len;
   1101       1.23      fvdl 		    if (i > len) {
   1102       1.23      fvdl 			mp->m_len -= (i - len);
   1103       1.23      fvdl 			zeroing = 1;
   1104       1.23      fvdl 		    }
   1105       1.23      fvdl 		}
   1106       1.23      fvdl 		mp = mp->m_next;
   1107       1.23      fvdl 	    }
   1108       1.23      fvdl 	    if (len > NFS_MAXDATA || len < 0  || i < len) {
   1109       1.23      fvdl nfsmout:
   1110       1.23      fvdl 		m_freem(mrep);
   1111       1.23      fvdl 		error = EIO;
   1112       1.23      fvdl 		nfsm_writereply(2 * NFSX_UNSIGNED, v3);
   1113       1.23      fvdl 		if (v3)
   1114       1.23      fvdl 		    nfsm_srvwcc_data(forat_ret, &forat, aftat_ret, &va);
   1115       1.23      fvdl 		nfsd->nd_mreq = mreq;
   1116       1.23      fvdl 		nfsd->nd_mrep = NULL;
   1117       1.23      fvdl 		nfsd->nd_time = 0;
   1118       1.23      fvdl 	    }
   1119       1.94     perry 
   1120       1.23      fvdl 	    /*
   1121       1.23      fvdl 	     * Add this entry to the hash and time queues.
   1122       1.23      fvdl 	     */
   1123       1.23      fvdl 	    s = splsoftclock();
   1124       1.23      fvdl 	    owp = NULL;
   1125       1.70      yamt 	    wp = LIST_FIRST(&slp->ns_tq);
   1126       1.23      fvdl 	    while (wp && wp->nd_time < nfsd->nd_time) {
   1127       1.23      fvdl 		owp = wp;
   1128       1.70      yamt 		wp = LIST_NEXT(wp, nd_tq);
   1129       1.23      fvdl 	    }
   1130       1.23      fvdl 	    if (owp) {
   1131       1.23      fvdl 		LIST_INSERT_AFTER(owp, nfsd, nd_tq);
   1132       1.23      fvdl 	    } else {
   1133       1.23      fvdl 		LIST_INSERT_HEAD(&slp->ns_tq, nfsd, nd_tq);
   1134       1.23      fvdl 	    }
   1135       1.23      fvdl 	    if (nfsd->nd_mrep) {
   1136       1.23      fvdl 		wpp = NWDELAYHASH(slp, nfsd->nd_fh.fh_fid.fid_data);
   1137       1.23      fvdl 		owp = NULL;
   1138       1.70      yamt 		wp = LIST_FIRST(wpp);
   1139       1.23      fvdl 		while (wp &&
   1140      1.100      yamt 		    memcmp(&nfsd->nd_fh, &wp->nd_fh, NFSX_V3FH)) {
   1141       1.23      fvdl 		    owp = wp;
   1142       1.70      yamt 		    wp = LIST_NEXT(wp, nd_hash);
   1143       1.23      fvdl 		}
   1144       1.23      fvdl 		while (wp && wp->nd_off < nfsd->nd_off &&
   1145      1.100      yamt 		    !memcmp(&nfsd->nd_fh, &wp->nd_fh, NFSX_V3FH)) {
   1146       1.23      fvdl 		    owp = wp;
   1147       1.70      yamt 		    wp = LIST_NEXT(wp, nd_hash);
   1148       1.23      fvdl 		}
   1149       1.23      fvdl 		if (owp) {
   1150       1.23      fvdl 		    LIST_INSERT_AFTER(owp, nfsd, nd_hash);
   1151       1.23      fvdl 
   1152       1.23      fvdl 		    /*
   1153       1.23      fvdl 		     * Search the hash list for overlapping entries and
   1154       1.23      fvdl 		     * coalesce.
   1155       1.23      fvdl 		     */
   1156       1.23      fvdl 		    for(; nfsd && NFSW_CONTIG(owp, nfsd); nfsd = wp) {
   1157       1.70      yamt 			wp = LIST_NEXT(nfsd, nd_hash);
   1158  1.101.2.2      yamt 			if (nfsrv_samecred(owp->nd_cr, nfsd->nd_cr))
   1159       1.23      fvdl 			    nfsrvw_coalesce(owp, nfsd);
   1160       1.23      fvdl 		    }
   1161       1.23      fvdl 		} else {
   1162       1.23      fvdl 		    LIST_INSERT_HEAD(wpp, nfsd, nd_hash);
   1163       1.23      fvdl 		}
   1164       1.23      fvdl 	    }
   1165       1.23      fvdl 	    splx(s);
   1166        1.1       cgd 	}
   1167       1.94     perry 
   1168        1.1       cgd 	/*
   1169       1.23      fvdl 	 * Now, do VOP_WRITE()s for any one(s) that need to be done now
   1170       1.23      fvdl 	 * and generate the associated reply mbuf list(s).
   1171        1.1       cgd 	 */
   1172       1.23      fvdl loop1:
   1173  1.101.2.3      yamt 	getmicrotime(&now);
   1174  1.101.2.3      yamt 	cur_usec = (u_quad_t)now.tv_sec * 1000000 + (u_quad_t)now.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.101.2.3      yamt 		error = vfs_composefh(vp, fhp);
   1568       1.23      fvdl 		if (!error)
   1569       1.99  christos 			error = VOP_GETATTR(vp, &va, cred, lwp);
   1570        1.1       cgd 		vput(vp);
   1571        1.1       cgd 	}
   1572       1.23      fvdl 	if (v3) {
   1573       1.89      yamt 		if (exclusive_flag && !error) {
   1574       1.89      yamt 			/*
   1575       1.89      yamt 			 * XXX assuming NFSX_V3CREATEVERF == sizeof(nfstime3)
   1576       1.89      yamt 			 */
   1577       1.89      yamt 			char oldverf[NFSX_V3CREATEVERF];
   1578       1.89      yamt 
   1579       1.89      yamt 			txdr_nfsv3time(&va.va_atime, oldverf);
   1580       1.89      yamt 			if (memcmp(cverf, oldverf, NFSX_V3CREATEVERF))
   1581       1.89      yamt 				error = EEXIST;
   1582       1.89      yamt 		}
   1583  1.101.2.2      yamt 		if (dirp) {
   1584  1.101.2.2      yamt 			diraft_ret = VOP_GETATTR(dirp, &diraft, cred, lwp);
   1585  1.101.2.2      yamt 			vrele(dirp);
   1586  1.101.2.2      yamt 		}
   1587       1.23      fvdl 	}
   1588       1.23      fvdl 	nfsm_reply(NFSX_SRVFH(v3) + NFSX_FATTR(v3) + NFSX_WCCDATA(v3));
   1589       1.23      fvdl 	if (v3) {
   1590       1.23      fvdl 		if (!error) {
   1591       1.23      fvdl 			nfsm_srvpostop_fh(fhp);
   1592       1.23      fvdl 			nfsm_srvpostop_attr(0, &va);
   1593       1.23      fvdl 		}
   1594       1.23      fvdl 		nfsm_srvwcc_data(dirfor_ret, &dirfor, diraft_ret, &diraft);
   1595       1.23      fvdl 	} else {
   1596       1.23      fvdl 		nfsm_srvfhtom(fhp, v3);
   1597       1.23      fvdl 		nfsm_build(fp, struct nfs_fattr *, NFSX_V2FATTR);
   1598       1.23      fvdl 		nfsm_srvfillattr(&va, fp);
   1599       1.23      fvdl 	}
   1600       1.82   hannken 	vn_finished_write(mp, 0);
   1601       1.23      fvdl 	return (0);
   1602        1.1       cgd nfsmout:
   1603       1.23      fvdl 	if (dirp)
   1604       1.23      fvdl 		vrele(dirp);
   1605       1.15   mycroft 	VOP_ABORTOP(nd.ni_dvp, &nd.ni_cnd);
   1606        1.1       cgd 	if (nd.ni_dvp == nd.ni_vp)
   1607        1.1       cgd 		vrele(nd.ni_dvp);
   1608        1.1       cgd 	else
   1609        1.1       cgd 		vput(nd.ni_dvp);
   1610        1.1       cgd 	if (nd.ni_vp)
   1611        1.1       cgd 		vput(nd.ni_vp);
   1612       1.82   hannken 	vn_finished_write(mp, 0);
   1613        1.1       cgd 	return (error);
   1614       1.23      fvdl }
   1615       1.23      fvdl 
   1616       1.23      fvdl /*
   1617       1.23      fvdl  * nfs v3 mknod service
   1618       1.23      fvdl  */
   1619       1.23      fvdl int
   1620       1.99  christos nfsrv_mknod(nfsd, slp, lwp, mrq)
   1621       1.23      fvdl 	struct nfsrv_descript *nfsd;
   1622       1.23      fvdl 	struct nfssvc_sock *slp;
   1623       1.99  christos 	struct lwp *lwp;
   1624       1.23      fvdl 	struct mbuf **mrq;
   1625       1.23      fvdl {
   1626       1.23      fvdl 	struct mbuf *mrep = nfsd->nd_mrep, *md = nfsd->nd_md;
   1627       1.23      fvdl 	struct mbuf *nam = nfsd->nd_nam;
   1628       1.23      fvdl 	caddr_t dpos = nfsd->nd_dpos;
   1629  1.101.2.2      yamt 	kauth_cred_t cred = nfsd->nd_cr;
   1630       1.23      fvdl 	struct vattr va, dirfor, diraft;
   1631       1.54  augustss 	u_int32_t *tl;
   1632       1.23      fvdl 	struct nameidata nd;
   1633       1.54  augustss 	int32_t t1;
   1634       1.23      fvdl 	caddr_t bpos;
   1635  1.101.2.2      yamt 	int error = 0, cache = 0, len, dirfor_ret = 1, diraft_ret = 1;
   1636       1.23      fvdl 	u_int32_t major, minor;
   1637       1.23      fvdl 	enum vtype vtyp;
   1638       1.23      fvdl 	char *cp2;
   1639       1.67      matt 	struct mbuf *mb, *mreq;
   1640       1.23      fvdl 	struct vnode *vp, *dirp = (struct vnode *)0;
   1641       1.23      fvdl 	nfsfh_t nfh;
   1642       1.23      fvdl 	fhandle_t *fhp;
   1643       1.23      fvdl 	u_quad_t frev;
   1644       1.82   hannken 	struct mount *mp = NULL;
   1645       1.23      fvdl 
   1646       1.23      fvdl 	nd.ni_cnd.cn_nameiop = 0;
   1647       1.23      fvdl 	fhp = &nfh.fh_generic;
   1648       1.23      fvdl 	nfsm_srvmtofh(fhp);
   1649       1.82   hannken 	if ((mp = vfs_getvfs(&fhp->fh_fsid)) == NULL)
   1650       1.82   hannken 		return (ESTALE);
   1651       1.82   hannken 	vn_start_write(NULL, &mp, V_WAIT);
   1652       1.23      fvdl 	nfsm_srvnamesiz(len);
   1653       1.23      fvdl 	nd.ni_cnd.cn_cred = cred;
   1654       1.23      fvdl 	nd.ni_cnd.cn_nameiop = CREATE;
   1655       1.61       chs 	nd.ni_cnd.cn_flags = LOCKPARENT | LOCKLEAF;
   1656       1.23      fvdl 	error = nfs_namei(&nd, fhp, len, slp, nam, &md, &dpos,
   1657       1.99  christos 		&dirp, lwp, (nfsd->nd_flag & ND_KERBAUTH), FALSE);
   1658       1.23      fvdl 	if (dirp)
   1659       1.99  christos 		dirfor_ret = VOP_GETATTR(dirp, &dirfor, cred, lwp);
   1660       1.23      fvdl 	if (error) {
   1661       1.23      fvdl 		nfsm_reply(NFSX_WCCDATA(1));
   1662       1.23      fvdl 		nfsm_srvwcc_data(dirfor_ret, &dirfor, diraft_ret, &diraft);
   1663       1.23      fvdl 		if (dirp)
   1664       1.23      fvdl 			vrele(dirp);
   1665       1.82   hannken 		vn_finished_write(mp, 0);
   1666       1.23      fvdl 		return (0);
   1667       1.23      fvdl 	}
   1668       1.23      fvdl 	nfsm_dissect(tl, u_int32_t *, NFSX_UNSIGNED);
   1669       1.23      fvdl 	vtyp = nfsv3tov_type(*tl);
   1670       1.23      fvdl 	if (vtyp != VCHR && vtyp != VBLK && vtyp != VSOCK && vtyp != VFIFO) {
   1671       1.23      fvdl 		error = NFSERR_BADTYPE;
   1672       1.95      yamt 		goto abort;
   1673       1.23      fvdl 	}
   1674       1.23      fvdl 	VATTR_NULL(&va);
   1675       1.92      yamt 	va.va_mode = 0;
   1676       1.23      fvdl 	nfsm_srvsattr(&va);
   1677       1.23      fvdl 	if (vtyp == VCHR || vtyp == VBLK) {
   1678       1.95      yamt 		dev_t rdev;
   1679       1.95      yamt 
   1680       1.23      fvdl 		nfsm_dissect(tl, u_int32_t *, 2 * NFSX_UNSIGNED);
   1681       1.23      fvdl 		major = fxdr_unsigned(u_int32_t, *tl++);
   1682       1.23      fvdl 		minor = fxdr_unsigned(u_int32_t, *tl);
   1683       1.95      yamt 		rdev = makedev(major, minor);
   1684       1.95      yamt 		if (major(rdev) != major || minor(rdev) != minor) {
   1685       1.95      yamt 			error = EINVAL;
   1686       1.95      yamt 			goto abort;
   1687       1.95      yamt 		}
   1688       1.95      yamt 		va.va_rdev = rdev;
   1689       1.23      fvdl 	}
   1690        1.1       cgd 
   1691       1.23      fvdl 	/*
   1692       1.23      fvdl 	 * Iff doesn't exist, create it.
   1693       1.23      fvdl 	 */
   1694       1.23      fvdl 	if (nd.ni_vp) {
   1695       1.23      fvdl 		error = EEXIST;
   1696       1.95      yamt abort:
   1697       1.23      fvdl 		VOP_ABORTOP(nd.ni_dvp, &nd.ni_cnd);
   1698       1.51  sommerfe 		if (nd.ni_dvp == nd.ni_vp)
   1699       1.51  sommerfe 			vrele(nd.ni_dvp);
   1700       1.51  sommerfe 		else
   1701       1.51  sommerfe 			vput(nd.ni_dvp);
   1702       1.95      yamt 		if (nd.ni_vp)
   1703       1.95      yamt 			vput(nd.ni_vp);
   1704       1.23      fvdl 		goto out;
   1705       1.23      fvdl 	}
   1706       1.23      fvdl 	va.va_type = vtyp;
   1707       1.23      fvdl 	if (vtyp == VSOCK) {
   1708       1.23      fvdl 		nqsrv_getl(nd.ni_dvp, ND_WRITE);
   1709       1.23      fvdl 		error = VOP_CREATE(nd.ni_dvp, &nd.ni_vp, &nd.ni_cnd, &va);
   1710       1.23      fvdl 	} else {
   1711       1.46       mrg 		if (va.va_type != VFIFO &&
   1712  1.101.2.2      yamt 		    (error = kauth_authorize_generic(cred, KAUTH_GENERIC_ISSUSER,
   1713  1.101.2.2      yamt 			(u_short *)0))) {
   1714       1.23      fvdl 			VOP_ABORTOP(nd.ni_dvp, &nd.ni_cnd);
   1715       1.23      fvdl 			vput(nd.ni_dvp);
   1716       1.23      fvdl 			goto out;
   1717       1.23      fvdl 		}
   1718       1.23      fvdl 		nqsrv_getl(nd.ni_dvp, ND_WRITE);
   1719       1.23      fvdl 		error = VOP_MKNOD(nd.ni_dvp, &nd.ni_vp, &nd.ni_cnd, &va);
   1720       1.23      fvdl 		if (error)
   1721       1.23      fvdl 			goto out;
   1722       1.23      fvdl 		if (nd.ni_cnd.cn_flags & ISSYMLINK) {
   1723       1.23      fvdl 			vput(nd.ni_vp);
   1724       1.23      fvdl 			VOP_ABORTOP(nd.ni_dvp, &nd.ni_cnd);
   1725       1.23      fvdl 			error = EINVAL;
   1726       1.23      fvdl 		}
   1727       1.23      fvdl 	}
   1728        1.1       cgd out:
   1729       1.23      fvdl 	vp = nd.ni_vp;
   1730       1.23      fvdl 	if (!error) {
   1731  1.101.2.3      yamt 		error = vfs_composefh(vp, fhp);
   1732       1.23      fvdl 		if (!error)
   1733       1.99  christos 			error = VOP_GETATTR(vp, &va, cred, lwp);
   1734       1.23      fvdl 		vput(vp);
   1735       1.23      fvdl 	}
   1736  1.101.2.2      yamt 	if (dirp) {
   1737  1.101.2.2      yamt 		diraft_ret = VOP_GETATTR(dirp, &diraft, cred, lwp);
   1738  1.101.2.2      yamt 		vrele(dirp);
   1739  1.101.2.2      yamt 	}
   1740       1.23      fvdl 	nfsm_reply(NFSX_SRVFH(1) + NFSX_POSTOPATTR(1) + NFSX_WCCDATA(1));
   1741       1.23      fvdl 	if (!error) {
   1742       1.23      fvdl 		nfsm_srvpostop_fh(fhp);
   1743       1.23      fvdl 		nfsm_srvpostop_attr(0, &va);
   1744       1.23      fvdl 	}
   1745       1.23      fvdl 	nfsm_srvwcc_data(dirfor_ret, &dirfor, diraft_ret, &diraft);
   1746       1.82   hannken 	vn_finished_write(mp, 0);
   1747       1.23      fvdl 	return (0);
   1748       1.23      fvdl nfsmout:
   1749       1.23      fvdl 	if (dirp)
   1750       1.23      fvdl 		vrele(dirp);
   1751       1.23      fvdl 	VOP_ABORTOP(nd.ni_dvp, &nd.ni_cnd);
   1752       1.23      fvdl 	if (nd.ni_dvp == nd.ni_vp)
   1753       1.23      fvdl 		vrele(nd.ni_dvp);
   1754       1.23      fvdl 	else
   1755       1.23      fvdl 		vput(nd.ni_dvp);
   1756       1.23      fvdl 	if (nd.ni_vp)
   1757       1.23      fvdl 		vput(nd.ni_vp);
   1758       1.82   hannken 	vn_finished_write(mp, 0);
   1759       1.23      fvdl 	return (error);
   1760        1.1       cgd }
   1761        1.1       cgd 
   1762        1.1       cgd /*
   1763        1.1       cgd  * nfs remove service
   1764        1.1       cgd  */
   1765       1.22  christos int
   1766       1.99  christos nfsrv_remove(nfsd, slp, lwp, mrq)
   1767       1.23      fvdl 	struct nfsrv_descript *nfsd;
   1768       1.23      fvdl 	struct nfssvc_sock *slp;
   1769       1.99  christos 	struct lwp *lwp;
   1770       1.23      fvdl 	struct mbuf **mrq;
   1771        1.1       cgd {
   1772       1.23      fvdl 	struct mbuf *mrep = nfsd->nd_mrep, *md = nfsd->nd_md;
   1773       1.23      fvdl 	struct mbuf *nam = nfsd->nd_nam;
   1774       1.23      fvdl 	caddr_t dpos = nfsd->nd_dpos;
   1775  1.101.2.2      yamt 	kauth_cred_t cred = nfsd->nd_cr;
   1776        1.1       cgd 	struct nameidata nd;
   1777       1.54  augustss 	u_int32_t *tl;
   1778       1.54  augustss 	int32_t t1;
   1779        1.1       cgd 	caddr_t bpos;
   1780  1.101.2.2      yamt 	int error = 0, cache = 0, len, dirfor_ret = 1, diraft_ret = 1;
   1781       1.23      fvdl 	int v3 = (nfsd->nd_flag & ND_NFSV3);
   1782        1.1       cgd 	char *cp2;
   1783        1.1       cgd 	struct mbuf *mb, *mreq;
   1784       1.23      fvdl 	struct vnode *vp, *dirp;
   1785       1.23      fvdl 	struct vattr dirfor, diraft;
   1786       1.23      fvdl 	nfsfh_t nfh;
   1787        1.1       cgd 	fhandle_t *fhp;
   1788       1.15   mycroft 	u_quad_t frev;
   1789       1.82   hannken 	struct mount *mp = NULL;
   1790        1.1       cgd 
   1791       1.23      fvdl #ifndef nolint
   1792       1.23      fvdl 	vp = (struct vnode *)0;
   1793       1.23      fvdl #endif
   1794        1.1       cgd 	fhp = &nfh.fh_generic;
   1795        1.1       cgd 	nfsm_srvmtofh(fhp);
   1796       1.82   hannken 	if ((mp = vfs_getvfs(&fhp->fh_fsid)) == NULL)
   1797       1.82   hannken 		return (ESTALE);
   1798       1.82   hannken 	vn_start_write(NULL, &mp, V_WAIT);
   1799       1.23      fvdl 	nfsm_srvnamesiz(len);
   1800       1.15   mycroft 	nd.ni_cnd.cn_cred = cred;
   1801       1.15   mycroft 	nd.ni_cnd.cn_nameiop = DELETE;
   1802       1.15   mycroft 	nd.ni_cnd.cn_flags = LOCKPARENT | LOCKLEAF;
   1803       1.23      fvdl 	error = nfs_namei(&nd, fhp, len, slp, nam, &md, &dpos,
   1804       1.99  christos 		&dirp, lwp, (nfsd->nd_flag & ND_KERBAUTH), FALSE);
   1805       1.23      fvdl 	if (dirp) {
   1806       1.23      fvdl 		if (v3)
   1807       1.99  christos 			dirfor_ret = VOP_GETATTR(dirp, &dirfor, cred, lwp);
   1808        1.1       cgd 		else
   1809       1.23      fvdl 			vrele(dirp);
   1810        1.1       cgd 	}
   1811       1.23      fvdl 	if (!error) {
   1812       1.23      fvdl 		vp = nd.ni_vp;
   1813       1.23      fvdl 		if (vp->v_type == VDIR &&
   1814  1.101.2.2      yamt 		    (error = kauth_authorize_generic(cred, KAUTH_GENERIC_ISSUSER,
   1815  1.101.2.2      yamt 				(u_short *)0)) != 0)
   1816       1.23      fvdl 			goto out;
   1817       1.23      fvdl 		/*
   1818       1.23      fvdl 		 * The root of a mounted filesystem cannot be deleted.
   1819       1.23      fvdl 		 */
   1820       1.23      fvdl 		if (vp->v_flag & VROOT) {
   1821       1.23      fvdl 			error = EBUSY;
   1822       1.23      fvdl 			goto out;
   1823       1.23      fvdl 		}
   1824       1.21   mycroft out:
   1825       1.23      fvdl 		if (!error) {
   1826       1.23      fvdl 			nqsrv_getl(nd.ni_dvp, ND_WRITE);
   1827       1.23      fvdl 			nqsrv_getl(vp, ND_WRITE);
   1828       1.23      fvdl 			error = VOP_REMOVE(nd.ni_dvp, nd.ni_vp, &nd.ni_cnd);
   1829       1.23      fvdl 		} else {
   1830       1.23      fvdl 			VOP_ABORTOP(nd.ni_dvp, &nd.ni_cnd);
   1831       1.23      fvdl 			if (nd.ni_dvp == vp)
   1832       1.23      fvdl 				vrele(nd.ni_dvp);
   1833       1.23      fvdl 			else
   1834       1.23      fvdl 				vput(nd.ni_dvp);
   1835       1.23      fvdl 			vput(vp);
   1836       1.23      fvdl 		}
   1837       1.23      fvdl 	}
   1838       1.23      fvdl 	if (dirp && v3) {
   1839       1.99  christos 		diraft_ret = VOP_GETATTR(dirp, &diraft, cred, lwp);
   1840       1.23      fvdl 		vrele(dirp);
   1841       1.23      fvdl 	}
   1842       1.23      fvdl 	nfsm_reply(NFSX_WCCDATA(v3));
   1843       1.23      fvdl 	if (v3) {
   1844       1.23      fvdl 		nfsm_srvwcc_data(dirfor_ret, &dirfor, diraft_ret, &diraft);
   1845       1.82   hannken 		vn_finished_write(mp, 0);
   1846       1.23      fvdl 		return (0);
   1847       1.23      fvdl 	}
   1848       1.82   hannken 	vn_finished_write(mp, 0);
   1849        1.1       cgd 	nfsm_srvdone;
   1850        1.1       cgd }
   1851        1.1       cgd 
   1852        1.1       cgd /*
   1853        1.1       cgd  * nfs rename service
   1854        1.1       cgd  */
   1855       1.22  christos int
   1856       1.99  christos nfsrv_rename(nfsd, slp, lwp, mrq)
   1857       1.23      fvdl 	struct nfsrv_descript *nfsd;
   1858       1.23      fvdl 	struct nfssvc_sock *slp;
   1859       1.99  christos 	struct lwp *lwp;
   1860       1.23      fvdl 	struct mbuf **mrq;
   1861        1.1       cgd {
   1862       1.23      fvdl 	struct mbuf *mrep = nfsd->nd_mrep, *md = nfsd->nd_md;
   1863       1.23      fvdl 	struct mbuf *nam = nfsd->nd_nam;
   1864       1.23      fvdl 	caddr_t dpos = nfsd->nd_dpos;
   1865  1.101.2.2      yamt 	kauth_cred_t cred = nfsd->nd_cr;
   1866       1.54  augustss 	u_int32_t *tl;
   1867       1.54  augustss 	int32_t t1;
   1868        1.1       cgd 	caddr_t bpos;
   1869  1.101.2.2      yamt 	int error = 0, cache = 0, fdirfor_ret = 1, fdiraft_ret = 1;
   1870       1.68      yamt 	uint32_t len, len2;
   1871       1.23      fvdl 	int tdirfor_ret = 1, tdiraft_ret = 1;
   1872       1.23      fvdl 	int v3 = (nfsd->nd_flag & ND_NFSV3);
   1873        1.1       cgd 	char *cp2;
   1874        1.1       cgd 	struct mbuf *mb, *mreq;
   1875        1.1       cgd 	struct nameidata fromnd, tond;
   1876       1.23      fvdl 	struct vnode *fvp, *tvp, *tdvp, *fdirp = (struct vnode *)0;
   1877       1.23      fvdl 	struct vnode *tdirp = (struct vnode *)0;
   1878       1.23      fvdl 	struct vattr fdirfor, fdiraft, tdirfor, tdiraft;
   1879       1.23      fvdl 	nfsfh_t fnfh, tnfh;
   1880        1.1       cgd 	fhandle_t *ffhp, *tfhp;
   1881       1.15   mycroft 	u_quad_t frev;
   1882       1.15   mycroft 	uid_t saved_uid;
   1883       1.82   hannken 	struct mount *mp = NULL;
   1884        1.1       cgd 
   1885       1.23      fvdl #ifndef nolint
   1886       1.23      fvdl 	fvp = (struct vnode *)0;
   1887       1.23      fvdl #endif
   1888        1.1       cgd 	ffhp = &fnfh.fh_generic;
   1889        1.1       cgd 	tfhp = &tnfh.fh_generic;
   1890       1.15   mycroft 	fromnd.ni_cnd.cn_nameiop = 0;
   1891       1.15   mycroft 	tond.ni_cnd.cn_nameiop = 0;
   1892        1.1       cgd 	nfsm_srvmtofh(ffhp);
   1893       1.82   hannken 	if ((mp = vfs_getvfs(&ffhp->fh_fsid)) == NULL)
   1894       1.82   hannken 		return (ESTALE);
   1895       1.82   hannken 	vn_start_write(NULL, &mp, V_WAIT);
   1896       1.23      fvdl 	nfsm_srvnamesiz(len);
   1897        1.1       cgd 	/*
   1898       1.15   mycroft 	 * Remember our original uid so that we can reset cr_uid before
   1899       1.15   mycroft 	 * the second nfs_namei() call, in case it is remapped.
   1900        1.1       cgd 	 */
   1901  1.101.2.2      yamt 	saved_uid = kauth_cred_geteuid(cred);
   1902       1.15   mycroft 	fromnd.ni_cnd.cn_cred = cred;
   1903       1.15   mycroft 	fromnd.ni_cnd.cn_nameiop = DELETE;
   1904       1.15   mycroft 	fromnd.ni_cnd.cn_flags = WANTPARENT | SAVESTART;
   1905       1.23      fvdl 	error = nfs_namei(&fromnd, ffhp, len, slp, nam, &md,
   1906       1.99  christos 		&dpos, &fdirp, lwp, (nfsd->nd_flag & ND_KERBAUTH), FALSE);
   1907       1.23      fvdl 	if (fdirp) {
   1908       1.23      fvdl 		if (v3)
   1909       1.99  christos 			fdirfor_ret = VOP_GETATTR(fdirp, &fdirfor, cred, lwp);
   1910       1.23      fvdl 		else {
   1911       1.23      fvdl 			vrele(fdirp);
   1912       1.23      fvdl 			fdirp = (struct vnode *)0;
   1913       1.23      fvdl 		}
   1914       1.23      fvdl 	}
   1915       1.23      fvdl 	if (error) {
   1916       1.23      fvdl 		nfsm_reply(2 * NFSX_WCCDATA(v3));
   1917       1.23      fvdl 		nfsm_srvwcc_data(fdirfor_ret, &fdirfor, fdiraft_ret, &fdiraft);
   1918       1.23      fvdl 		nfsm_srvwcc_data(tdirfor_ret, &tdirfor, tdiraft_ret, &tdiraft);
   1919       1.23      fvdl 		if (fdirp)
   1920       1.23      fvdl 			vrele(fdirp);
   1921       1.82   hannken 		vn_finished_write(mp, 0);
   1922       1.23      fvdl 		return (0);
   1923       1.23      fvdl 	}
   1924        1.1       cgd 	fvp = fromnd.ni_vp;
   1925        1.1       cgd 	nfsm_srvmtofh(tfhp);
   1926       1.68      yamt 	if (v3) {
   1927       1.68      yamt 		nfsm_dissect(tl, uint32_t *, NFSX_UNSIGNED);
   1928       1.68      yamt 		len2 = fxdr_unsigned(uint32_t, *tl);
   1929       1.68      yamt 		/* len2 will be checked by nfs_namei */
   1930       1.68      yamt 	}
   1931       1.68      yamt 	else {
   1932       1.68      yamt 		/* NFSv2 */
   1933       1.68      yamt 		nfsm_strsiz(len2, NFS_MAXNAMLEN);
   1934       1.68      yamt 	}
   1935  1.101.2.2      yamt 	kauth_cred_seteuid(cred, saved_uid);
   1936       1.15   mycroft 	tond.ni_cnd.cn_cred = cred;
   1937       1.15   mycroft 	tond.ni_cnd.cn_nameiop = RENAME;
   1938       1.15   mycroft 	tond.ni_cnd.cn_flags = LOCKPARENT | LOCKLEAF | NOCACHE | SAVESTART;
   1939       1.23      fvdl 	error = nfs_namei(&tond, tfhp, len2, slp, nam, &md,
   1940       1.99  christos 		&dpos, &tdirp, lwp, (nfsd->nd_flag & ND_KERBAUTH), FALSE);
   1941       1.23      fvdl 	if (tdirp) {
   1942       1.23      fvdl 		if (v3)
   1943       1.99  christos 			tdirfor_ret = VOP_GETATTR(tdirp, &tdirfor, cred, lwp);
   1944       1.23      fvdl 		else {
   1945       1.23      fvdl 			vrele(tdirp);
   1946       1.23      fvdl 			tdirp = (struct vnode *)0;
   1947       1.23      fvdl 		}
   1948       1.23      fvdl 	}
   1949       1.22  christos 	if (error) {
   1950       1.15   mycroft 		VOP_ABORTOP(fromnd.ni_dvp, &fromnd.ni_cnd);
   1951        1.1       cgd 		vrele(fromnd.ni_dvp);
   1952        1.1       cgd 		vrele(fvp);
   1953        1.1       cgd 		goto out1;
   1954        1.1       cgd 	}
   1955        1.1       cgd 	tdvp = tond.ni_dvp;
   1956        1.1       cgd 	tvp = tond.ni_vp;
   1957        1.1       cgd 	if (tvp != NULL) {
   1958        1.1       cgd 		if (fvp->v_type == VDIR && tvp->v_type != VDIR) {
   1959       1.23      fvdl 			if (v3)
   1960       1.23      fvdl 				error = EEXIST;
   1961       1.23      fvdl 			else
   1962       1.23      fvdl 				error = EISDIR;
   1963        1.1       cgd 			goto out;
   1964        1.1       cgd 		} else 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 = ENOTDIR;
   1969        1.1       cgd 			goto out;
   1970        1.1       cgd 		}
   1971       1.15   mycroft 		if (tvp->v_type == VDIR && tvp->v_mountedhere) {
   1972       1.23      fvdl 			if (v3)
   1973       1.23      fvdl 				error = EXDEV;
   1974       1.23      fvdl 			else
   1975       1.23      fvdl 				error = ENOTEMPTY;
   1976       1.15   mycroft 			goto out;
   1977       1.15   mycroft 		}
   1978       1.15   mycroft 	}
   1979       1.15   mycroft 	if (fvp->v_type == VDIR && fvp->v_mountedhere) {
   1980       1.23      fvdl 		if (v3)
   1981       1.23      fvdl 			error = EXDEV;
   1982       1.23      fvdl 		else
   1983       1.23      fvdl 			error = ENOTEMPTY;
   1984       1.15   mycroft 		goto out;
   1985        1.1       cgd 	}
   1986        1.1       cgd 	if (fvp->v_mount != tdvp->v_mount) {
   1987       1.23      fvdl 		if (v3)
   1988       1.23      fvdl 			error = EXDEV;
   1989       1.23      fvdl 		else
   1990       1.23      fvdl 			error = ENOTEMPTY;
   1991        1.1       cgd 		goto out;
   1992        1.1       cgd 	}
   1993       1.45   thorpej 	if (fvp == tdvp) {
   1994       1.23      fvdl 		if (v3)
   1995       1.23      fvdl 			error = EINVAL;
   1996       1.23      fvdl 		else
   1997       1.23      fvdl 			error = ENOTEMPTY;
   1998       1.45   thorpej 	}
   1999        1.1       cgd 	/*
   2000        1.1       cgd 	 * If source is the same as the destination (that is the
   2001        1.1       cgd 	 * same vnode with the same name in the same directory),
   2002        1.1       cgd 	 * then there is nothing to do.
   2003        1.1       cgd 	 */
   2004        1.1       cgd 	if (fvp == tvp && fromnd.ni_dvp == tdvp &&
   2005       1.15   mycroft 	    fromnd.ni_cnd.cn_namelen == tond.ni_cnd.cn_namelen &&
   2006       1.44     perry 	    !memcmp(fromnd.ni_cnd.cn_nameptr, tond.ni_cnd.cn_nameptr,
   2007       1.15   mycroft 	      fromnd.ni_cnd.cn_namelen))
   2008        1.1       cgd 		error = -1;
   2009        1.1       cgd out:
   2010        1.1       cgd 	if (!error) {
   2011       1.23      fvdl 		nqsrv_getl(fromnd.ni_dvp, ND_WRITE);
   2012       1.23      fvdl 		nqsrv_getl(tdvp, ND_WRITE);
   2013       1.30      fvdl 		if (tvp) {
   2014       1.23      fvdl 			nqsrv_getl(tvp, ND_WRITE);
   2015       1.30      fvdl 		}
   2016       1.15   mycroft 		error = VOP_RENAME(fromnd.ni_dvp, fromnd.ni_vp, &fromnd.ni_cnd,
   2017       1.15   mycroft 				   tond.ni_dvp, tond.ni_vp, &tond.ni_cnd);
   2018        1.1       cgd 	} else {
   2019       1.15   mycroft 		VOP_ABORTOP(tond.ni_dvp, &tond.ni_cnd);
   2020        1.1       cgd 		if (tdvp == tvp)
   2021        1.1       cgd 			vrele(tdvp);
   2022        1.1       cgd 		else
   2023        1.1       cgd 			vput(tdvp);
   2024        1.1       cgd 		if (tvp)
   2025        1.1       cgd 			vput(tvp);
   2026       1.15   mycroft 		VOP_ABORTOP(fromnd.ni_dvp, &fromnd.ni_cnd);
   2027        1.1       cgd 		vrele(fromnd.ni_dvp);
   2028        1.1       cgd 		vrele(fvp);
   2029       1.23      fvdl 		if (error == -1)
   2030       1.23      fvdl 			error = 0;
   2031        1.1       cgd 	}
   2032        1.1       cgd 	vrele(tond.ni_startdir);
   2033       1.57   thorpej 	PNBUF_PUT(tond.ni_cnd.cn_pnbuf);
   2034        1.1       cgd out1:
   2035       1.23      fvdl 	if (fdirp) {
   2036       1.99  christos 		fdiraft_ret = VOP_GETATTR(fdirp, &fdiraft, cred, lwp);
   2037       1.23      fvdl 		vrele(fdirp);
   2038       1.23      fvdl 	}
   2039       1.23      fvdl 	if (tdirp) {
   2040       1.99  christos 		tdiraft_ret = VOP_GETATTR(tdirp, &tdiraft, cred, lwp);
   2041       1.23      fvdl 		vrele(tdirp);
   2042       1.23      fvdl 	}
   2043        1.1       cgd 	vrele(fromnd.ni_startdir);
   2044       1.57   thorpej 	PNBUF_PUT(fromnd.ni_cnd.cn_pnbuf);
   2045       1.23      fvdl 	nfsm_reply(2 * NFSX_WCCDATA(v3));
   2046       1.23      fvdl 	if (v3) {
   2047       1.23      fvdl 		nfsm_srvwcc_data(fdirfor_ret, &fdirfor, fdiraft_ret, &fdiraft);
   2048       1.23      fvdl 		nfsm_srvwcc_data(tdirfor_ret, &tdirfor, tdiraft_ret, &tdiraft);
   2049       1.23      fvdl 	}
   2050       1.82   hannken 	vn_finished_write(mp, 0);
   2051       1.23      fvdl 	return (0);
   2052        1.1       cgd 
   2053        1.1       cgd nfsmout:
   2054       1.23      fvdl 	if (fdirp)
   2055       1.23      fvdl 		vrele(fdirp);
   2056  1.101.2.2      yamt #ifdef notdef
   2057       1.23      fvdl 	if (tdirp)
   2058       1.23      fvdl 		vrele(tdirp);
   2059  1.101.2.2      yamt #endif
   2060       1.23      fvdl 	if (tond.ni_cnd.cn_nameiop) {
   2061        1.1       cgd 		vrele(tond.ni_startdir);
   2062       1.57   thorpej 		PNBUF_PUT(tond.ni_cnd.cn_pnbuf);
   2063        1.1       cgd 	}
   2064       1.23      fvdl 	if (fromnd.ni_cnd.cn_nameiop) {
   2065        1.1       cgd 		vrele(fromnd.ni_startdir);
   2066       1.57   thorpej 		PNBUF_PUT(fromnd.ni_cnd.cn_pnbuf);
   2067       1.15   mycroft 		VOP_ABORTOP(fromnd.ni_dvp, &fromnd.ni_cnd);
   2068        1.1       cgd 		vrele(fromnd.ni_dvp);
   2069        1.1       cgd 		vrele(fvp);
   2070        1.1       cgd 	}
   2071        1.1       cgd 	return (error);
   2072        1.1       cgd }
   2073        1.1       cgd 
   2074        1.1       cgd /*
   2075        1.1       cgd  * nfs link service
   2076        1.1       cgd  */
   2077       1.22  christos int
   2078       1.99  christos nfsrv_link(nfsd, slp, lwp, mrq)
   2079       1.23      fvdl 	struct nfsrv_descript *nfsd;
   2080       1.23      fvdl 	struct nfssvc_sock *slp;
   2081       1.99  christos 	struct lwp *lwp;
   2082       1.23      fvdl 	struct mbuf **mrq;
   2083        1.1       cgd {
   2084       1.23      fvdl 	struct mbuf *mrep = nfsd->nd_mrep, *md = nfsd->nd_md;
   2085       1.23      fvdl 	struct mbuf *nam = nfsd->nd_nam;
   2086       1.23      fvdl 	caddr_t dpos = nfsd->nd_dpos;
   2087  1.101.2.2      yamt 	kauth_cred_t cred = nfsd->nd_cr;
   2088        1.1       cgd 	struct nameidata nd;
   2089       1.54  augustss 	u_int32_t *tl;
   2090       1.54  augustss 	int32_t t1;
   2091        1.1       cgd 	caddr_t bpos;
   2092  1.101.2.2      yamt 	int error = 0, rdonly, cache = 0, len, dirfor_ret = 1, diraft_ret = 1;
   2093       1.23      fvdl 	int getret = 1, v3 = (nfsd->nd_flag & ND_NFSV3);
   2094        1.1       cgd 	char *cp2;
   2095        1.1       cgd 	struct mbuf *mb, *mreq;
   2096       1.23      fvdl 	struct vnode *vp, *xp, *dirp = (struct vnode *)0;
   2097       1.23      fvdl 	struct vattr dirfor, diraft, at;
   2098       1.23      fvdl 	nfsfh_t nfh, dnfh;
   2099        1.1       cgd 	fhandle_t *fhp, *dfhp;
   2100       1.15   mycroft 	u_quad_t frev;
   2101       1.82   hannken 	struct mount *mp = NULL;
   2102        1.1       cgd 
   2103        1.1       cgd 	fhp = &nfh.fh_generic;
   2104        1.1       cgd 	dfhp = &dnfh.fh_generic;
   2105        1.1       cgd 	nfsm_srvmtofh(fhp);
   2106       1.82   hannken 	if ((mp = vfs_getvfs(&fhp->fh_fsid)) == NULL)
   2107       1.82   hannken 		return (ESTALE);
   2108       1.82   hannken 	vn_start_write(NULL, &mp, V_WAIT);
   2109        1.1       cgd 	nfsm_srvmtofh(dfhp);
   2110       1.23      fvdl 	nfsm_srvnamesiz(len);
   2111       1.23      fvdl 	error = nfsrv_fhtovp(fhp, FALSE, &vp, cred, slp, nam,
   2112       1.78   thorpej 		 &rdonly, (nfsd->nd_flag & ND_KERBAUTH), FALSE);
   2113       1.23      fvdl 	if (error) {
   2114       1.23      fvdl 		nfsm_reply(NFSX_POSTOPATTR(v3) + NFSX_WCCDATA(v3));
   2115       1.23      fvdl 		nfsm_srvpostop_attr(getret, &at);
   2116       1.23      fvdl 		nfsm_srvwcc_data(dirfor_ret, &dirfor, diraft_ret, &diraft);
   2117       1.82   hannken 		vn_finished_write(mp, 0);
   2118       1.23      fvdl 		return (0);
   2119       1.23      fvdl 	}
   2120  1.101.2.2      yamt 	if (vp->v_type == VDIR && (error = kauth_authorize_generic(cred,
   2121  1.101.2.2      yamt 					KAUTH_GENERIC_ISSUSER, (u_short *)0)) != 0)
   2122       1.23      fvdl 		goto out1;
   2123       1.15   mycroft 	nd.ni_cnd.cn_cred = cred;
   2124       1.15   mycroft 	nd.ni_cnd.cn_nameiop = CREATE;
   2125       1.15   mycroft 	nd.ni_cnd.cn_flags = LOCKPARENT;
   2126       1.23      fvdl 	error = nfs_namei(&nd, dfhp, len, slp, nam, &md, &dpos,
   2127       1.99  christos 		&dirp, lwp, (nfsd->nd_flag & ND_KERBAUTH), FALSE);
   2128       1.23      fvdl 	if (dirp) {
   2129       1.23      fvdl 		if (v3)
   2130       1.99  christos 			dirfor_ret = VOP_GETATTR(dirp, &dirfor, cred, lwp);
   2131       1.23      fvdl 		else {
   2132       1.23      fvdl 			vrele(dirp);
   2133       1.23      fvdl 			dirp = (struct vnode *)0;
   2134       1.23      fvdl 		}
   2135       1.23      fvdl 	}
   2136       1.22  christos 	if (error)
   2137       1.23      fvdl 		goto out1;
   2138       1.23      fvdl 	xp = nd.ni_vp;
   2139       1.23      fvdl 	if (xp != NULL) {
   2140       1.23      fvdl 		error = EEXIST;
   2141        1.1       cgd 		goto out;
   2142       1.23      fvdl 	}
   2143       1.23      fvdl 	xp = nd.ni_dvp;
   2144       1.23      fvdl 	if (vp->v_mount != xp->v_mount)
   2145       1.23      fvdl 		error = EXDEV;
   2146       1.23      fvdl out:
   2147       1.23      fvdl 	if (!error) {
   2148       1.23      fvdl 		nqsrv_getl(vp, ND_WRITE);
   2149       1.23      fvdl 		nqsrv_getl(xp, ND_WRITE);
   2150       1.23      fvdl 		error = VOP_LINK(nd.ni_dvp, vp, &nd.ni_cnd);
   2151       1.23      fvdl 	} else {
   2152       1.15   mycroft 		VOP_ABORTOP(nd.ni_dvp, &nd.ni_cnd);
   2153        1.1       cgd 		if (nd.ni_dvp == nd.ni_vp)
   2154        1.1       cgd 			vrele(nd.ni_dvp);
   2155        1.1       cgd 		else
   2156        1.1       cgd 			vput(nd.ni_dvp);
   2157       1.23      fvdl 		if (nd.ni_vp)
   2158       1.23      fvdl 			vrele(nd.ni_vp);
   2159       1.23      fvdl 	}
   2160       1.23      fvdl out1:
   2161       1.23      fvdl 	if (v3)
   2162       1.99  christos 		getret = VOP_GETATTR(vp, &at, cred, lwp);
   2163       1.23      fvdl 	if (dirp) {
   2164       1.99  christos 		diraft_ret = VOP_GETATTR(dirp, &diraft, cred, lwp);
   2165       1.23      fvdl 		vrele(dirp);
   2166        1.1       cgd 	}
   2167        1.1       cgd 	vrele(vp);
   2168       1.23      fvdl 	nfsm_reply(NFSX_POSTOPATTR(v3) + NFSX_WCCDATA(v3));
   2169       1.23      fvdl 	if (v3) {
   2170       1.23      fvdl 		nfsm_srvpostop_attr(getret, &at);
   2171       1.23      fvdl 		nfsm_srvwcc_data(dirfor_ret, &dirfor, diraft_ret, &diraft);
   2172       1.82   hannken 		vn_finished_write(mp, 0);
   2173       1.23      fvdl 		return (0);
   2174       1.23      fvdl 	}
   2175       1.82   hannken 	vn_finished_write(mp, 0);
   2176        1.1       cgd 	nfsm_srvdone;
   2177        1.1       cgd }
   2178        1.1       cgd 
   2179        1.1       cgd /*
   2180        1.1       cgd  * nfs symbolic link service
   2181        1.1       cgd  */
   2182       1.22  christos int
   2183       1.99  christos nfsrv_symlink(nfsd, slp, lwp, mrq)
   2184       1.23      fvdl 	struct nfsrv_descript *nfsd;
   2185       1.23      fvdl 	struct nfssvc_sock *slp;
   2186       1.99  christos 	struct lwp *lwp;
   2187       1.23      fvdl 	struct mbuf **mrq;
   2188        1.1       cgd {
   2189       1.23      fvdl 	struct mbuf *mrep = nfsd->nd_mrep, *md = nfsd->nd_md;
   2190       1.23      fvdl 	struct mbuf *nam = nfsd->nd_nam;
   2191       1.23      fvdl 	caddr_t dpos = nfsd->nd_dpos;
   2192  1.101.2.2      yamt 	kauth_cred_t cred = nfsd->nd_cr;
   2193       1.23      fvdl 	struct vattr va, dirfor, diraft;
   2194        1.1       cgd 	struct nameidata nd;
   2195       1.54  augustss 	u_int32_t *tl;
   2196       1.54  augustss 	int32_t t1;
   2197        1.1       cgd 	struct nfsv2_sattr *sp;
   2198       1.23      fvdl 	char *bpos, *pathcp = NULL, *cp2;
   2199        1.1       cgd 	struct uio io;
   2200        1.1       cgd 	struct iovec iv;
   2201  1.101.2.2      yamt 	int error = 0, cache = 0, dirfor_ret = 1, diraft_ret = 1;
   2202       1.68      yamt 	uint32_t len, len2;
   2203       1.23      fvdl 	int v3 = (nfsd->nd_flag & ND_NFSV3);
   2204       1.67      matt 	struct mbuf *mb, *mreq;
   2205       1.23      fvdl 	struct vnode *dirp = (struct vnode *)0;
   2206       1.23      fvdl 	nfsfh_t nfh;
   2207        1.1       cgd 	fhandle_t *fhp;
   2208       1.15   mycroft 	u_quad_t frev;
   2209       1.82   hannken 	struct mount *mp = NULL;
   2210        1.1       cgd 
   2211       1.23      fvdl 	nd.ni_cnd.cn_nameiop = 0;
   2212        1.1       cgd 	fhp = &nfh.fh_generic;
   2213        1.1       cgd 	nfsm_srvmtofh(fhp);
   2214       1.82   hannken 	if ((mp = vfs_getvfs(&fhp->fh_fsid)) == NULL)
   2215       1.82   hannken 		return (ESTALE);
   2216       1.82   hannken 	vn_start_write(NULL, &mp, V_WAIT);
   2217       1.23      fvdl 	nfsm_srvnamesiz(len);
   2218       1.15   mycroft 	nd.ni_cnd.cn_cred = cred;
   2219       1.15   mycroft 	nd.ni_cnd.cn_nameiop = CREATE;
   2220       1.61       chs 	nd.ni_cnd.cn_flags = LOCKPARENT;
   2221       1.23      fvdl 	error = nfs_namei(&nd, fhp, len, slp, nam, &md, &dpos,
   2222       1.99  christos 		&dirp, lwp, (nfsd->nd_flag & ND_KERBAUTH), FALSE);
   2223       1.23      fvdl 	if (dirp) {
   2224       1.23      fvdl 		if (v3)
   2225       1.99  christos 			dirfor_ret = VOP_GETATTR(dirp, &dirfor, cred, lwp);
   2226       1.23      fvdl 		else {
   2227       1.23      fvdl 			vrele(dirp);
   2228       1.23      fvdl 			dirp = (struct vnode *)0;
   2229       1.23      fvdl 		}
   2230       1.23      fvdl 	}
   2231       1.22  christos 	if (error)
   2232        1.1       cgd 		goto out;
   2233       1.23      fvdl 	VATTR_NULL(&va);
   2234       1.97      jmmv 	va.va_type = VLNK;
   2235       1.68      yamt 	if (v3) {
   2236       1.92      yamt 		va.va_mode = 0;
   2237       1.23      fvdl 		nfsm_srvsattr(&va);
   2238       1.68      yamt 		nfsm_dissect(tl, uint32_t *, NFSX_UNSIGNED);
   2239       1.68      yamt 		len2 = fxdr_unsigned(uint32_t, *tl);
   2240       1.68      yamt 		if (len2 > PATH_MAX) {
   2241       1.68      yamt 			/* XXX should check _PC_NO_TRUNC */
   2242       1.68      yamt 			error = ENAMETOOLONG;
   2243       1.68      yamt 			goto abortop;
   2244       1.68      yamt 		}
   2245       1.68      yamt 	}
   2246       1.68      yamt 	else {
   2247       1.68      yamt 		/* NFSv2 */
   2248       1.68      yamt 		nfsm_strsiz(len2, NFS_MAXPATHLEN);
   2249       1.68      yamt 	}
   2250       1.56   thorpej 	pathcp = malloc(len2 + 1, M_TEMP, M_WAITOK);
   2251        1.1       cgd 	iv.iov_base = pathcp;
   2252        1.1       cgd 	iv.iov_len = len2;
   2253        1.1       cgd 	io.uio_resid = len2;
   2254        1.1       cgd 	io.uio_offset = 0;
   2255        1.1       cgd 	io.uio_iov = &iv;
   2256        1.1       cgd 	io.uio_iovcnt = 1;
   2257        1.1       cgd 	io.uio_rw = UIO_READ;
   2258      1.101      yamt 	UIO_SETUP_SYSSPACE(&io);
   2259        1.1       cgd 	nfsm_mtouio(&io, len2);
   2260       1.23      fvdl 	if (!v3) {
   2261       1.23      fvdl 		nfsm_dissect(sp, struct nfsv2_sattr *, NFSX_V2SATTR);
   2262       1.23      fvdl 		va.va_mode = fxdr_unsigned(u_int16_t, sp->sa_mode);
   2263       1.23      fvdl 	}
   2264        1.1       cgd 	*(pathcp + len2) = '\0';
   2265        1.1       cgd 	if (nd.ni_vp) {
   2266       1.68      yamt 		error = EEXIST;
   2267       1.68      yamt abortop:
   2268       1.15   mycroft 		VOP_ABORTOP(nd.ni_dvp, &nd.ni_cnd);
   2269        1.1       cgd 		if (nd.ni_dvp == nd.ni_vp)
   2270        1.1       cgd 			vrele(nd.ni_dvp);
   2271        1.1       cgd 		else
   2272        1.1       cgd 			vput(nd.ni_dvp);
   2273       1.68      yamt 		if (nd.ni_vp)
   2274       1.68      yamt 			vrele(nd.ni_vp);
   2275        1.1       cgd 		goto out;
   2276        1.1       cgd 	}
   2277       1.23      fvdl 	nqsrv_getl(nd.ni_dvp, ND_WRITE);
   2278       1.23      fvdl 	error = VOP_SYMLINK(nd.ni_dvp, &nd.ni_vp, &nd.ni_cnd, &va, pathcp);
   2279       1.61       chs 	if (!error) {
   2280       1.23      fvdl 	    if (v3) {
   2281  1.101.2.3      yamt 		error = vfs_composefh(nd.ni_vp, fhp);
   2282       1.60     assar 		if (!error)
   2283       1.99  christos 		    error = VOP_GETATTR(nd.ni_vp, &va, cred, lwp);
   2284       1.60     assar 		vput(nd.ni_vp);
   2285       1.60     assar 	    } else {
   2286       1.60     assar 		vput(nd.ni_vp);
   2287       1.60     assar 	    }
   2288       1.23      fvdl 	}
   2289        1.1       cgd out:
   2290        1.1       cgd 	if (pathcp)
   2291       1.56   thorpej 		free(pathcp, M_TEMP);
   2292       1.23      fvdl 	if (dirp) {
   2293       1.99  christos 		diraft_ret = VOP_GETATTR(dirp, &diraft, cred, lwp);
   2294       1.23      fvdl 		vrele(dirp);
   2295       1.23      fvdl 	}
   2296       1.23      fvdl 	nfsm_reply(NFSX_SRVFH(v3) + NFSX_POSTOPATTR(v3) + NFSX_WCCDATA(v3));
   2297       1.23      fvdl 	if (v3) {
   2298       1.23      fvdl 		if (!error) {
   2299       1.23      fvdl 			nfsm_srvpostop_fh(fhp);
   2300       1.23      fvdl 			nfsm_srvpostop_attr(0, &va);
   2301       1.23      fvdl 		}
   2302       1.23      fvdl 		nfsm_srvwcc_data(dirfor_ret, &dirfor, diraft_ret, &diraft);
   2303       1.23      fvdl 	}
   2304       1.82   hannken 	vn_finished_write(mp, 0);
   2305       1.23      fvdl 	return (0);
   2306        1.1       cgd nfsmout:
   2307       1.23      fvdl 	if (dirp)
   2308       1.23      fvdl 		vrele(dirp);
   2309       1.15   mycroft 	VOP_ABORTOP(nd.ni_dvp, &nd.ni_cnd);
   2310        1.1       cgd 	if (nd.ni_dvp == nd.ni_vp)
   2311        1.1       cgd 		vrele(nd.ni_dvp);
   2312        1.1       cgd 	else
   2313        1.1       cgd 		vput(nd.ni_dvp);
   2314        1.1       cgd 	if (nd.ni_vp)
   2315        1.1       cgd 		vrele(nd.ni_vp);
   2316        1.1       cgd 	if (pathcp)
   2317       1.56   thorpej 		free(pathcp, M_TEMP);
   2318       1.82   hannken 	vn_finished_write(mp, 0);
   2319        1.1       cgd 	return (error);
   2320        1.1       cgd }
   2321        1.1       cgd 
   2322        1.1       cgd /*
   2323        1.1       cgd  * nfs mkdir service
   2324        1.1       cgd  */
   2325       1.22  christos int
   2326       1.99  christos nfsrv_mkdir(nfsd, slp, lwp, mrq)
   2327       1.23      fvdl 	struct nfsrv_descript *nfsd;
   2328       1.23      fvdl 	struct nfssvc_sock *slp;
   2329       1.99  christos 	struct lwp *lwp;
   2330       1.23      fvdl 	struct mbuf **mrq;
   2331        1.1       cgd {
   2332       1.23      fvdl 	struct mbuf *mrep = nfsd->nd_mrep, *md = nfsd->nd_md;
   2333       1.23      fvdl 	struct mbuf *nam = nfsd->nd_nam;
   2334       1.23      fvdl 	caddr_t dpos = nfsd->nd_dpos;
   2335  1.101.2.2      yamt 	kauth_cred_t cred = nfsd->nd_cr;
   2336       1.23      fvdl 	struct vattr va, dirfor, diraft;
   2337       1.54  augustss 	struct nfs_fattr *fp;
   2338        1.1       cgd 	struct nameidata nd;
   2339       1.54  augustss 	caddr_t cp;
   2340       1.54  augustss 	u_int32_t *tl;
   2341       1.54  augustss 	int32_t t1;
   2342        1.1       cgd 	caddr_t bpos;
   2343  1.101.2.2      yamt 	int error = 0, cache = 0, len, dirfor_ret = 1, diraft_ret = 1;
   2344       1.23      fvdl 	int v3 = (nfsd->nd_flag & ND_NFSV3);
   2345        1.1       cgd 	char *cp2;
   2346       1.67      matt 	struct mbuf *mb, *mreq;
   2347       1.23      fvdl 	struct vnode *vp, *dirp = (struct vnode *)0;
   2348       1.23      fvdl 	nfsfh_t nfh;
   2349        1.1       cgd 	fhandle_t *fhp;
   2350       1.15   mycroft 	u_quad_t frev;
   2351       1.82   hannken 	struct mount *mp = NULL;
   2352        1.1       cgd 
   2353        1.1       cgd 	fhp = &nfh.fh_generic;
   2354        1.1       cgd 	nfsm_srvmtofh(fhp);
   2355       1.82   hannken 	if ((mp = vfs_getvfs(&fhp->fh_fsid)) == NULL)
   2356       1.82   hannken 		return (ESTALE);
   2357       1.82   hannken 	vn_start_write(NULL, &mp, V_WAIT);
   2358       1.23      fvdl 	nfsm_srvnamesiz(len);
   2359       1.15   mycroft 	nd.ni_cnd.cn_cred = cred;
   2360       1.15   mycroft 	nd.ni_cnd.cn_nameiop = CREATE;
   2361       1.15   mycroft 	nd.ni_cnd.cn_flags = LOCKPARENT;
   2362       1.23      fvdl 	error = nfs_namei(&nd, fhp, len, slp, nam, &md, &dpos,
   2363       1.99  christos 		&dirp, lwp, (nfsd->nd_flag & ND_KERBAUTH), FALSE);
   2364       1.23      fvdl 	if (dirp) {
   2365       1.23      fvdl 		if (v3)
   2366       1.99  christos 			dirfor_ret = VOP_GETATTR(dirp, &dirfor, cred, lwp);
   2367       1.23      fvdl 		else {
   2368       1.23      fvdl 			vrele(dirp);
   2369       1.23      fvdl 			dirp = (struct vnode *)0;
   2370       1.23      fvdl 		}
   2371       1.23      fvdl 	}
   2372       1.23      fvdl 	if (error) {
   2373       1.23      fvdl 		nfsm_reply(NFSX_WCCDATA(v3));
   2374       1.23      fvdl 		nfsm_srvwcc_data(dirfor_ret, &dirfor, diraft_ret, &diraft);
   2375       1.23      fvdl 		if (dirp)
   2376       1.23      fvdl 			vrele(dirp);
   2377       1.82   hannken 		vn_finished_write(mp, 0);
   2378       1.23      fvdl 		return (0);
   2379       1.23      fvdl 	}
   2380       1.18   mycroft 	VATTR_NULL(&va);
   2381       1.23      fvdl 	if (v3) {
   2382       1.92      yamt 		va.va_mode = 0;
   2383       1.23      fvdl 		nfsm_srvsattr(&va);
   2384       1.23      fvdl 	} else {
   2385       1.23      fvdl 		nfsm_dissect(tl, u_int32_t *, NFSX_UNSIGNED);
   2386       1.23      fvdl 		va.va_mode = nfstov_mode(*tl++);
   2387       1.23      fvdl 	}
   2388       1.18   mycroft 	va.va_type = VDIR;
   2389        1.1       cgd 	vp = nd.ni_vp;
   2390        1.1       cgd 	if (vp != NULL) {
   2391       1.15   mycroft 		VOP_ABORTOP(nd.ni_dvp, &nd.ni_cnd);
   2392        1.1       cgd 		if (nd.ni_dvp == vp)
   2393        1.1       cgd 			vrele(nd.ni_dvp);
   2394        1.1       cgd 		else
   2395        1.1       cgd 			vput(nd.ni_dvp);
   2396        1.1       cgd 		vrele(vp);
   2397        1.1       cgd 		error = EEXIST;
   2398       1.23      fvdl 		goto out;
   2399        1.1       cgd 	}
   2400       1.23      fvdl 	nqsrv_getl(nd.ni_dvp, ND_WRITE);
   2401       1.23      fvdl 	error = VOP_MKDIR(nd.ni_dvp, &nd.ni_vp, &nd.ni_cnd, &va);
   2402       1.23      fvdl 	if (!error) {
   2403       1.23      fvdl 		vp = nd.ni_vp;
   2404  1.101.2.3      yamt 		error = vfs_composefh(vp, fhp);
   2405       1.23      fvdl 		if (!error)
   2406       1.99  christos 			error = VOP_GETATTR(vp, &va, cred, lwp);
   2407        1.1       cgd 		vput(vp);
   2408        1.1       cgd 	}
   2409       1.23      fvdl out:
   2410       1.23      fvdl 	if (dirp) {
   2411       1.99  christos 		diraft_ret = VOP_GETATTR(dirp, &diraft, cred, lwp);
   2412       1.23      fvdl 		vrele(dirp);
   2413       1.23      fvdl 	}
   2414       1.23      fvdl 	nfsm_reply(NFSX_SRVFH(v3) + NFSX_POSTOPATTR(v3) + NFSX_WCCDATA(v3));
   2415       1.23      fvdl 	if (v3) {
   2416       1.23      fvdl 		if (!error) {
   2417       1.23      fvdl 			nfsm_srvpostop_fh(fhp);
   2418       1.23      fvdl 			nfsm_srvpostop_attr(0, &va);
   2419       1.23      fvdl 		}
   2420       1.23      fvdl 		nfsm_srvwcc_data(dirfor_ret, &dirfor, diraft_ret, &diraft);
   2421       1.23      fvdl 	} else {
   2422       1.23      fvdl 		nfsm_srvfhtom(fhp, v3);
   2423       1.23      fvdl 		nfsm_build(fp, struct nfs_fattr *, NFSX_V2FATTR);
   2424       1.23      fvdl 		nfsm_srvfillattr(&va, fp);
   2425       1.23      fvdl 	}
   2426       1.82   hannken 	vn_finished_write(mp, 0);
   2427       1.23      fvdl 	return (0);
   2428        1.1       cgd nfsmout:
   2429       1.23      fvdl 	if (dirp)
   2430       1.23      fvdl 		vrele(dirp);
   2431       1.15   mycroft 	VOP_ABORTOP(nd.ni_dvp, &nd.ni_cnd);
   2432        1.1       cgd 	if (nd.ni_dvp == nd.ni_vp)
   2433        1.1       cgd 		vrele(nd.ni_dvp);
   2434        1.1       cgd 	else
   2435        1.1       cgd 		vput(nd.ni_dvp);
   2436        1.1       cgd 	if (nd.ni_vp)
   2437        1.1       cgd 		vrele(nd.ni_vp);
   2438       1.82   hannken 	vn_finished_write(mp, 0);
   2439        1.1       cgd 	return (error);
   2440        1.1       cgd }
   2441        1.1       cgd 
   2442        1.1       cgd /*
   2443        1.1       cgd  * nfs rmdir service
   2444        1.1       cgd  */
   2445       1.22  christos int
   2446       1.99  christos nfsrv_rmdir(nfsd, slp, lwp, mrq)
   2447       1.23      fvdl 	struct nfsrv_descript *nfsd;
   2448       1.23      fvdl 	struct nfssvc_sock *slp;
   2449       1.99  christos 	struct lwp *lwp;
   2450       1.23      fvdl 	struct mbuf **mrq;
   2451        1.1       cgd {
   2452       1.23      fvdl 	struct mbuf *mrep = nfsd->nd_mrep, *md = nfsd->nd_md;
   2453       1.23      fvdl 	struct mbuf *nam = nfsd->nd_nam;
   2454       1.23      fvdl 	caddr_t dpos = nfsd->nd_dpos;
   2455  1.101.2.2      yamt 	kauth_cred_t cred = nfsd->nd_cr;
   2456       1.54  augustss 	u_int32_t *tl;
   2457       1.54  augustss 	int32_t t1;
   2458        1.1       cgd 	caddr_t bpos;
   2459  1.101.2.2      yamt 	int error = 0, cache = 0, len, dirfor_ret = 1, diraft_ret = 1;
   2460       1.23      fvdl 	int v3 = (nfsd->nd_flag & ND_NFSV3);
   2461        1.1       cgd 	char *cp2;
   2462        1.1       cgd 	struct mbuf *mb, *mreq;
   2463       1.23      fvdl 	struct vnode *vp, *dirp = (struct vnode *)0;
   2464       1.23      fvdl 	struct vattr dirfor, diraft;
   2465       1.23      fvdl 	nfsfh_t nfh;
   2466        1.1       cgd 	fhandle_t *fhp;
   2467        1.1       cgd 	struct nameidata nd;
   2468       1.15   mycroft 	u_quad_t frev;
   2469       1.82   hannken 	struct mount *mp = NULL;
   2470        1.1       cgd 
   2471        1.1       cgd 	fhp = &nfh.fh_generic;
   2472        1.1       cgd 	nfsm_srvmtofh(fhp);
   2473       1.82   hannken 	if ((mp = vfs_getvfs(&fhp->fh_fsid)) == NULL)
   2474       1.82   hannken 		return (ESTALE);
   2475       1.82   hannken 	vn_start_write(NULL, &mp, V_WAIT);
   2476       1.23      fvdl 	nfsm_srvnamesiz(len);
   2477       1.15   mycroft 	nd.ni_cnd.cn_cred = cred;
   2478       1.15   mycroft 	nd.ni_cnd.cn_nameiop = DELETE;
   2479       1.15   mycroft 	nd.ni_cnd.cn_flags = LOCKPARENT | LOCKLEAF;
   2480       1.23      fvdl 	error = nfs_namei(&nd, fhp, len, slp, nam, &md, &dpos,
   2481       1.99  christos 		&dirp, lwp, (nfsd->nd_flag & ND_KERBAUTH), FALSE);
   2482       1.23      fvdl 	if (dirp) {
   2483       1.23      fvdl 		if (v3)
   2484       1.99  christos 			dirfor_ret = VOP_GETATTR(dirp, &dirfor, cred, lwp);
   2485       1.23      fvdl 		else {
   2486       1.23      fvdl 			vrele(dirp);
   2487       1.23      fvdl 			dirp = (struct vnode *)0;
   2488       1.23      fvdl 		}
   2489       1.23      fvdl 	}
   2490       1.23      fvdl 	if (error) {
   2491       1.23      fvdl 		nfsm_reply(NFSX_WCCDATA(v3));
   2492       1.23      fvdl 		nfsm_srvwcc_data(dirfor_ret, &dirfor, diraft_ret, &diraft);
   2493       1.23      fvdl 		if (dirp)
   2494       1.23      fvdl 			vrele(dirp);
   2495       1.82   hannken 		vn_finished_write(mp, 0);
   2496       1.23      fvdl 		return (0);
   2497       1.23      fvdl 	}
   2498        1.1       cgd 	vp = nd.ni_vp;
   2499        1.1       cgd 	if (vp->v_type != VDIR) {
   2500        1.1       cgd 		error = ENOTDIR;
   2501        1.1       cgd 		goto out;
   2502        1.1       cgd 	}
   2503        1.1       cgd 	/*
   2504        1.1       cgd 	 * No rmdir "." please.
   2505        1.1       cgd 	 */
   2506        1.1       cgd 	if (nd.ni_dvp == vp) {
   2507        1.1       cgd 		error = EINVAL;
   2508        1.1       cgd 		goto out;
   2509        1.1       cgd 	}
   2510        1.1       cgd 	/*
   2511        1.1       cgd 	 * The root of a mounted filesystem cannot be deleted.
   2512        1.1       cgd 	 */
   2513        1.1       cgd 	if (vp->v_flag & VROOT)
   2514        1.1       cgd 		error = EBUSY;
   2515        1.1       cgd out:
   2516        1.1       cgd 	if (!error) {
   2517       1.23      fvdl 		nqsrv_getl(nd.ni_dvp, ND_WRITE);
   2518       1.23      fvdl 		nqsrv_getl(vp, ND_WRITE);
   2519       1.15   mycroft 		error = VOP_RMDIR(nd.ni_dvp, nd.ni_vp, &nd.ni_cnd);
   2520        1.1       cgd 	} else {
   2521       1.15   mycroft 		VOP_ABORTOP(nd.ni_dvp, &nd.ni_cnd);
   2522        1.1       cgd 		if (nd.ni_dvp == nd.ni_vp)
   2523        1.1       cgd 			vrele(nd.ni_dvp);
   2524        1.1       cgd 		else
   2525        1.1       cgd 			vput(nd.ni_dvp);
   2526        1.1       cgd 		vput(vp);
   2527        1.1       cgd 	}
   2528       1.23      fvdl 	if (dirp) {
   2529       1.99  christos 		diraft_ret = VOP_GETATTR(dirp, &diraft, cred, lwp);
   2530       1.23      fvdl 		vrele(dirp);
   2531       1.23      fvdl 	}
   2532       1.23      fvdl 	nfsm_reply(NFSX_WCCDATA(v3));
   2533       1.23      fvdl 	if (v3) {
   2534       1.23      fvdl 		nfsm_srvwcc_data(dirfor_ret, &dirfor, diraft_ret, &diraft);
   2535       1.82   hannken 		vn_finished_write(mp, 0);
   2536       1.23      fvdl 		return (0);
   2537       1.23      fvdl 	}
   2538       1.82   hannken 	vn_finished_write(mp, 0);
   2539        1.1       cgd 	nfsm_srvdone;
   2540        1.1       cgd }
   2541        1.1       cgd 
   2542        1.1       cgd /*
   2543        1.1       cgd  * nfs readdir service
   2544        1.1       cgd  * - mallocs what it thinks is enough to read
   2545       1.98      yamt  *	count rounded up to a multiple of NFS_SRVDIRBLKSIZ <= NFS_MAXREADDIR
   2546        1.1       cgd  * - calls VOP_READDIR()
   2547        1.1       cgd  * - loops around building the reply
   2548        1.1       cgd  *	if the output generated exceeds count break out of loop
   2549        1.1       cgd  *	The nfsm_clget macro is used here so that the reply will be packed
   2550        1.1       cgd  *	tightly in mbuf clusters.
   2551        1.1       cgd  * - it only knows that it has encountered eof when the VOP_READDIR()
   2552        1.1       cgd  *	reads nothing
   2553        1.1       cgd  * - as such one readdir rpc will return eof false although you are there
   2554        1.1       cgd  *	and then the next will return eof
   2555       1.11        ws  * - it trims out records with d_fileno == 0
   2556        1.1       cgd  *	this doesn't matter for Unix clients, but they might confuse clients
   2557        1.1       cgd  *	for other os'.
   2558       1.25       jtk  * - it trims out records with d_type == DT_WHT
   2559       1.25       jtk  *	these cannot be seen through NFS (unless we extend the protocol)
   2560        1.1       cgd  * NB: It is tempting to set eof to true if the VOP_READDIR() reads less
   2561        1.1       cgd  *	than requested, but this may not apply to all filesystems. For
   2562        1.1       cgd  *	example, client NFS does not { although it is never remote mounted
   2563        1.1       cgd  *	anyhow }
   2564       1.23      fvdl  *     The alternate call nfsrv_readdirplus() does lookups as well.
   2565        1.1       cgd  * PS: The NFS protocol spec. does not clarify what the "count" byte
   2566        1.1       cgd  *	argument is a count of.. just name strings and file id's or the
   2567        1.1       cgd  *	entire reply rpc or ...
   2568        1.1       cgd  *	I tried just file name and id sizes and it confused the Sun client,
   2569        1.1       cgd  *	so I am using the full rpc size now. The "paranoia.." comment refers
   2570        1.1       cgd  *	to including the status longwords that are not a part of the dir.
   2571        1.1       cgd  *	"entry" structures, but are in the rpc.
   2572        1.1       cgd  */
   2573       1.98      yamt 
   2574       1.98      yamt #define	NFS_SRVDIRBLKSIZ	1024
   2575       1.98      yamt 
   2576       1.15   mycroft struct flrep {
   2577       1.23      fvdl 	nfsuint64 fl_off;
   2578       1.23      fvdl 	u_int32_t fl_postopok;
   2579       1.23      fvdl 	u_int32_t fl_fattr[NFSX_V3FATTR / sizeof (u_int32_t)];
   2580       1.23      fvdl 	u_int32_t fl_fhok;
   2581       1.23      fvdl 	u_int32_t fl_fhsize;
   2582       1.23      fvdl 	u_int32_t fl_nfh[NFSX_V3FH / sizeof (u_int32_t)];
   2583       1.15   mycroft };
   2584       1.15   mycroft 
   2585       1.22  christos int
   2586       1.99  christos nfsrv_readdir(nfsd, slp, lwp, mrq)
   2587       1.23      fvdl 	struct nfsrv_descript *nfsd;
   2588       1.23      fvdl 	struct nfssvc_sock *slp;
   2589       1.99  christos 	struct lwp *lwp;
   2590       1.23      fvdl 	struct mbuf **mrq;
   2591        1.1       cgd {
   2592       1.23      fvdl 	struct mbuf *mrep = nfsd->nd_mrep, *md = nfsd->nd_md;
   2593       1.23      fvdl 	struct mbuf *nam = nfsd->nd_nam;
   2594       1.23      fvdl 	caddr_t dpos = nfsd->nd_dpos;
   2595  1.101.2.2      yamt 	kauth_cred_t cred = nfsd->nd_cr;
   2596       1.54  augustss 	char *bp, *be;
   2597       1.54  augustss 	struct mbuf *mp;
   2598       1.54  augustss 	struct dirent *dp;
   2599       1.54  augustss 	caddr_t cp;
   2600       1.54  augustss 	u_int32_t *tl;
   2601       1.54  augustss 	int32_t t1;
   2602        1.1       cgd 	caddr_t bpos;
   2603       1.67      matt 	struct mbuf *mb, *mreq, *mp2;
   2604       1.15   mycroft 	char *cpos, *cend, *cp2, *rbuf;
   2605        1.1       cgd 	struct vnode *vp;
   2606       1.23      fvdl 	struct vattr at;
   2607       1.23      fvdl 	nfsfh_t nfh;
   2608        1.1       cgd 	fhandle_t *fhp;
   2609        1.1       cgd 	struct uio io;
   2610        1.1       cgd 	struct iovec iv;
   2611       1.23      fvdl 	int len, nlen, rem, xfer, tsiz, i, error = 0, getret = 1;
   2612  1.101.2.2      yamt 	int siz, cnt, fullsiz, eofflag, rdonly, cache = 0, ncookies;
   2613       1.23      fvdl 	int v3 = (nfsd->nd_flag & ND_NFSV3);
   2614       1.23      fvdl 	u_quad_t frev, off, toff, verf;
   2615       1.38      fvdl 	off_t *cookies = NULL, *cookiep;
   2616       1.38      fvdl 	nfsuint64 jar;
   2617       1.15   mycroft 
   2618        1.1       cgd 	fhp = &nfh.fh_generic;
   2619        1.1       cgd 	nfsm_srvmtofh(fhp);
   2620       1.23      fvdl 	if (v3) {
   2621       1.23      fvdl 		nfsm_dissect(tl, u_int32_t *, 5 * NFSX_UNSIGNED);
   2622       1.48      fair 		toff = fxdr_hyper(tl);
   2623       1.23      fvdl 		tl += 2;
   2624       1.48      fair 		verf = fxdr_hyper(tl);
   2625       1.23      fvdl 		tl += 2;
   2626       1.23      fvdl 	} else {
   2627       1.23      fvdl 		nfsm_dissect(tl, u_int32_t *, 2 * NFSX_UNSIGNED);
   2628       1.23      fvdl 		toff = fxdr_unsigned(u_quad_t, *tl++);
   2629       1.23      fvdl 	}
   2630       1.23      fvdl 	off = toff;
   2631        1.1       cgd 	cnt = fxdr_unsigned(int, *tl);
   2632       1.98      yamt 	siz = ((cnt + NFS_SRVDIRBLKSIZ - 1) & ~(NFS_SRVDIRBLKSIZ - 1));
   2633       1.23      fvdl 	xfer = NFS_SRVMAXDATA(nfsd);
   2634       1.23      fvdl 	if (siz > xfer)
   2635       1.23      fvdl 		siz = xfer;
   2636        1.1       cgd 	fullsiz = siz;
   2637       1.23      fvdl 	error = nfsrv_fhtovp(fhp, 1, &vp, cred, slp, nam,
   2638       1.78   thorpej 		 &rdonly, (nfsd->nd_flag & ND_KERBAUTH), FALSE);
   2639       1.39      fvdl 	if (!error && vp->v_type != VDIR) {
   2640       1.39      fvdl 		error = ENOTDIR;
   2641       1.39      fvdl 		vput(vp);
   2642       1.39      fvdl 	}
   2643       1.23      fvdl 	if (error) {
   2644       1.23      fvdl 		nfsm_reply(NFSX_UNSIGNED);
   2645       1.23      fvdl 		nfsm_srvpostop_attr(getret, &at);
   2646       1.23      fvdl 		return (0);
   2647       1.23      fvdl 	}
   2648       1.23      fvdl 	nqsrv_getl(vp, ND_READ);
   2649       1.23      fvdl 	if (v3) {
   2650       1.99  christos 		error = getret = VOP_GETATTR(vp, &at, cred, lwp);
   2651       1.23      fvdl #ifdef NFS3_STRICTVERF
   2652       1.23      fvdl 		/*
   2653       1.23      fvdl 		 * XXX This check is too strict for Solaris 2.5 clients.
   2654       1.23      fvdl 		 */
   2655       1.23      fvdl 		if (!error && toff && verf != at.va_filerev)
   2656       1.23      fvdl 			error = NFSERR_BAD_COOKIE;
   2657       1.23      fvdl #endif
   2658       1.23      fvdl 	}
   2659       1.23      fvdl 	if (!error)
   2660       1.99  christos 		error = nfsrv_access(vp, VEXEC, cred, rdonly, lwp, 0);
   2661       1.22  christos 	if (error) {
   2662        1.1       cgd 		vput(vp);
   2663       1.23      fvdl 		nfsm_reply(NFSX_POSTOPATTR(v3));
   2664       1.23      fvdl 		nfsm_srvpostop_attr(getret, &at);
   2665       1.23      fvdl 		return (0);
   2666        1.1       cgd 	}
   2667       1.42      fvdl 	VOP_UNLOCK(vp, 0);
   2668       1.56   thorpej 	rbuf = malloc(siz, M_TEMP, M_WAITOK);
   2669        1.1       cgd again:
   2670        1.1       cgd 	iv.iov_base = rbuf;
   2671        1.1       cgd 	iv.iov_len = fullsiz;
   2672        1.1       cgd 	io.uio_iov = &iv;
   2673        1.1       cgd 	io.uio_iovcnt = 1;
   2674       1.15   mycroft 	io.uio_offset = (off_t)off;
   2675        1.1       cgd 	io.uio_resid = fullsiz;
   2676        1.1       cgd 	io.uio_rw = UIO_READ;
   2677      1.101      yamt 	UIO_SETUP_SYSSPACE(&io);
   2678       1.23      fvdl 	eofflag = 0;
   2679       1.42      fvdl 	vn_lock(vp, LK_EXCLUSIVE | LK_RETRY);
   2680       1.23      fvdl 
   2681       1.42      fvdl 	error = VOP_READDIR(vp, &io, cred, &eofflag, &cookies, &ncookies);
   2682       1.23      fvdl 
   2683       1.15   mycroft 	off = (off_t)io.uio_offset;
   2684       1.23      fvdl 	if (!cookies && !error)
   2685       1.23      fvdl 		error = NFSERR_PERM;
   2686       1.23      fvdl 	if (v3) {
   2687       1.99  christos 		getret = VOP_GETATTR(vp, &at, cred, lwp);
   2688       1.23      fvdl 		if (!error)
   2689       1.23      fvdl 			error = getret;
   2690       1.23      fvdl 	}
   2691       1.23      fvdl 
   2692       1.42      fvdl 	VOP_UNLOCK(vp, 0);
   2693        1.1       cgd 	if (error) {
   2694        1.1       cgd 		vrele(vp);
   2695       1.56   thorpej 		free((caddr_t)rbuf, M_TEMP);
   2696       1.23      fvdl 		if (cookies)
   2697       1.23      fvdl 			free((caddr_t)cookies, M_TEMP);
   2698       1.23      fvdl 		nfsm_reply(NFSX_POSTOPATTR(v3));
   2699       1.23      fvdl 		nfsm_srvpostop_attr(getret, &at);
   2700       1.23      fvdl 		return (0);
   2701        1.1       cgd 	}
   2702        1.1       cgd 	if (io.uio_resid) {
   2703        1.1       cgd 		siz -= io.uio_resid;
   2704        1.1       cgd 
   2705        1.1       cgd 		/*
   2706        1.1       cgd 		 * If nothing read, return eof
   2707        1.1       cgd 		 * rpc reply
   2708        1.1       cgd 		 */
   2709        1.1       cgd 		if (siz == 0) {
   2710        1.1       cgd 			vrele(vp);
   2711       1.23      fvdl 			nfsm_reply(NFSX_POSTOPATTR(v3) + NFSX_COOKIEVERF(v3) +
   2712       1.23      fvdl 				2 * NFSX_UNSIGNED);
   2713       1.23      fvdl 			if (v3) {
   2714       1.23      fvdl 				nfsm_srvpostop_attr(getret, &at);
   2715       1.23      fvdl 				nfsm_build(tl, u_int32_t *, 4 * NFSX_UNSIGNED);
   2716       1.48      fair 				txdr_hyper(at.va_filerev, tl);
   2717       1.23      fvdl 				tl += 2;
   2718       1.23      fvdl 			} else
   2719       1.23      fvdl 				nfsm_build(tl, u_int32_t *, 2 * NFSX_UNSIGNED);
   2720        1.1       cgd 			*tl++ = nfs_false;
   2721        1.1       cgd 			*tl = nfs_true;
   2722       1.56   thorpej 			free((caddr_t)rbuf, M_TEMP);
   2723       1.56   thorpej 			free((caddr_t)cookies, M_TEMP);
   2724        1.1       cgd 			return (0);
   2725        1.1       cgd 		}
   2726        1.1       cgd 	}
   2727        1.1       cgd 
   2728        1.1       cgd 	/*
   2729        1.1       cgd 	 * Check for degenerate cases of nothing useful read.
   2730        1.1       cgd 	 * If so go try again
   2731        1.1       cgd 	 */
   2732        1.8        ws 	cpos = rbuf;
   2733        1.1       cgd 	cend = rbuf + siz;
   2734       1.23      fvdl 	dp = (struct dirent *)cpos;
   2735       1.23      fvdl 	cookiep = cookies;
   2736       1.23      fvdl 
   2737       1.28      fvdl 	while (cpos < cend && ncookies > 0 &&
   2738       1.28      fvdl 		(dp->d_fileno == 0 || dp->d_type == DT_WHT)) {
   2739       1.23      fvdl 		cpos += dp->d_reclen;
   2740       1.11        ws 		dp = (struct dirent *)cpos;
   2741       1.23      fvdl 		cookiep++;
   2742       1.23      fvdl 		ncookies--;
   2743        1.1       cgd 	}
   2744       1.23      fvdl 	if (cpos >= cend || ncookies == 0) {
   2745       1.23      fvdl 		toff = off;
   2746        1.1       cgd 		siz = fullsiz;
   2747        1.1       cgd 		goto again;
   2748        1.1       cgd 	}
   2749        1.1       cgd 
   2750       1.23      fvdl 	len = 3 * NFSX_UNSIGNED;	/* paranoia, probably can be 0 */
   2751       1.23      fvdl 	nfsm_reply(NFSX_POSTOPATTR(v3) + NFSX_COOKIEVERF(v3) + siz);
   2752       1.23      fvdl 	if (v3) {
   2753       1.23      fvdl 		nfsm_srvpostop_attr(getret, &at);
   2754       1.23      fvdl 		nfsm_build(tl, u_int32_t *, 2 * NFSX_UNSIGNED);
   2755       1.48      fair 		txdr_hyper(at.va_filerev, tl);
   2756       1.23      fvdl 	}
   2757       1.15   mycroft 	mp = mp2 = mb;
   2758       1.15   mycroft 	bp = bpos;
   2759       1.15   mycroft 	be = bp + M_TRAILINGSPACE(mp);
   2760       1.15   mycroft 
   2761       1.15   mycroft 	/* Loop through the records and build reply */
   2762       1.23      fvdl 	while (cpos < cend && ncookies > 0) {
   2763       1.25       jtk 		if (dp->d_fileno != 0 && dp->d_type != DT_WHT) {
   2764       1.15   mycroft 			nlen = dp->d_namlen;
   2765       1.15   mycroft 			rem = nfsm_rndup(nlen)-nlen;
   2766       1.23      fvdl 			len += (4 * NFSX_UNSIGNED + nlen + rem);
   2767       1.23      fvdl 			if (v3)
   2768       1.23      fvdl 				len += 2 * NFSX_UNSIGNED;
   2769       1.15   mycroft 			if (len > cnt) {
   2770       1.15   mycroft 				eofflag = 0;
   2771       1.15   mycroft 				break;
   2772       1.15   mycroft 			}
   2773       1.15   mycroft 			/*
   2774       1.15   mycroft 			 * Build the directory record xdr from
   2775       1.15   mycroft 			 * the dirent entry.
   2776       1.15   mycroft 			 */
   2777       1.15   mycroft 			nfsm_clget;
   2778       1.15   mycroft 			*tl = nfs_true;
   2779       1.15   mycroft 			bp += NFSX_UNSIGNED;
   2780       1.23      fvdl 			if (v3) {
   2781       1.23      fvdl 				nfsm_clget;
   2782       1.96      yamt 				*tl = txdr_unsigned(dp->d_fileno >> 32);
   2783       1.23      fvdl 				bp += NFSX_UNSIGNED;
   2784       1.23      fvdl 			}
   2785       1.15   mycroft 			nfsm_clget;
   2786       1.15   mycroft 			*tl = txdr_unsigned(dp->d_fileno);
   2787       1.15   mycroft 			bp += NFSX_UNSIGNED;
   2788       1.15   mycroft 			nfsm_clget;
   2789       1.15   mycroft 			*tl = txdr_unsigned(nlen);
   2790       1.15   mycroft 			bp += NFSX_UNSIGNED;
   2791       1.94     perry 
   2792       1.15   mycroft 			/* And loop around copying the name */
   2793       1.15   mycroft 			xfer = nlen;
   2794       1.15   mycroft 			cp = dp->d_name;
   2795       1.15   mycroft 			while (xfer > 0) {
   2796       1.15   mycroft 				nfsm_clget;
   2797       1.15   mycroft 				if ((bp+xfer) > be)
   2798       1.15   mycroft 					tsiz = be-bp;
   2799       1.15   mycroft 				else
   2800       1.15   mycroft 					tsiz = xfer;
   2801       1.44     perry 				memcpy(bp, cp, tsiz);
   2802       1.15   mycroft 				bp += tsiz;
   2803       1.15   mycroft 				xfer -= tsiz;
   2804       1.15   mycroft 				if (xfer > 0)
   2805       1.15   mycroft 					cp += tsiz;
   2806       1.15   mycroft 			}
   2807       1.23      fvdl 			/* And null pad to an int32_t boundary */
   2808       1.15   mycroft 			for (i = 0; i < rem; i++)
   2809       1.15   mycroft 				*bp++ = '\0';
   2810       1.15   mycroft 			nfsm_clget;
   2811       1.94     perry 
   2812       1.15   mycroft 			/* Finish off the record */
   2813       1.48      fair 			txdr_hyper(*cookiep, &jar);
   2814       1.23      fvdl 			if (v3) {
   2815       1.38      fvdl 				*tl = jar.nfsuquad[0];
   2816       1.23      fvdl 				bp += NFSX_UNSIGNED;
   2817       1.23      fvdl 				nfsm_clget;
   2818       1.23      fvdl 			}
   2819       1.38      fvdl 			*tl = jar.nfsuquad[1];
   2820       1.15   mycroft 			bp += NFSX_UNSIGNED;
   2821       1.15   mycroft 		}
   2822       1.15   mycroft 		cpos += dp->d_reclen;
   2823       1.15   mycroft 		dp = (struct dirent *)cpos;
   2824       1.23      fvdl 		cookiep++;
   2825       1.23      fvdl 		ncookies--;
   2826       1.15   mycroft 	}
   2827        1.1       cgd 	vrele(vp);
   2828       1.15   mycroft 	nfsm_clget;
   2829       1.15   mycroft 	*tl = nfs_false;
   2830       1.15   mycroft 	bp += NFSX_UNSIGNED;
   2831       1.15   mycroft 	nfsm_clget;
   2832       1.15   mycroft 	if (eofflag)
   2833       1.15   mycroft 		*tl = nfs_true;
   2834       1.15   mycroft 	else
   2835       1.15   mycroft 		*tl = nfs_false;
   2836       1.15   mycroft 	bp += NFSX_UNSIGNED;
   2837       1.15   mycroft 	if (mp != mb) {
   2838       1.15   mycroft 		if (bp < be)
   2839       1.15   mycroft 			mp->m_len = bp - mtod(mp, caddr_t);
   2840       1.15   mycroft 	} else
   2841       1.15   mycroft 		mp->m_len += bp - bpos;
   2842       1.56   thorpej 	free((caddr_t)rbuf, M_TEMP);
   2843       1.56   thorpej 	free((caddr_t)cookies, M_TEMP);
   2844       1.15   mycroft 	nfsm_srvdone;
   2845       1.15   mycroft }
   2846       1.15   mycroft 
   2847       1.22  christos int
   2848       1.99  christos nfsrv_readdirplus(nfsd, slp, lwp, mrq)
   2849       1.23      fvdl 	struct nfsrv_descript *nfsd;
   2850       1.23      fvdl 	struct nfssvc_sock *slp;
   2851       1.99  christos 	struct lwp *lwp;
   2852       1.23      fvdl 	struct mbuf **mrq;
   2853       1.15   mycroft {
   2854       1.23      fvdl 	struct mbuf *mrep = nfsd->nd_mrep, *md = nfsd->nd_md;
   2855       1.23      fvdl 	struct mbuf *nam = nfsd->nd_nam;
   2856       1.23      fvdl 	caddr_t dpos = nfsd->nd_dpos;
   2857  1.101.2.2      yamt 	kauth_cred_t cred = nfsd->nd_cr;
   2858       1.54  augustss 	char *bp, *be;
   2859       1.54  augustss 	struct mbuf *mp;
   2860       1.54  augustss 	struct dirent *dp;
   2861       1.54  augustss 	caddr_t cp;
   2862       1.54  augustss 	u_int32_t *tl;
   2863       1.54  augustss 	int32_t t1;
   2864       1.15   mycroft 	caddr_t bpos;
   2865       1.67      matt 	struct mbuf *mb, *mreq, *mp2;
   2866       1.15   mycroft 	char *cpos, *cend, *cp2, *rbuf;
   2867       1.15   mycroft 	struct vnode *vp, *nvp;
   2868       1.15   mycroft 	struct flrep fl;
   2869       1.23      fvdl 	nfsfh_t nfh;
   2870       1.23      fvdl 	fhandle_t *fhp, *nfhp = (fhandle_t *)fl.fl_nfh;
   2871       1.15   mycroft 	struct uio io;
   2872       1.15   mycroft 	struct iovec iv;
   2873       1.23      fvdl 	struct vattr va, at, *vap = &va;
   2874       1.23      fvdl 	struct nfs_fattr *fp;
   2875       1.23      fvdl 	int len, nlen, rem, xfer, tsiz, i, error = 0, getret = 1;
   2876  1.101.2.2      yamt 	int siz, cnt, fullsiz, eofflag, rdonly, cache = 0, dirlen, ncookies;
   2877       1.23      fvdl 	u_quad_t frev, off, toff, verf;
   2878       1.38      fvdl 	off_t *cookies = NULL, *cookiep;
   2879       1.15   mycroft 
   2880       1.15   mycroft 	fhp = &nfh.fh_generic;
   2881       1.15   mycroft 	nfsm_srvmtofh(fhp);
   2882       1.23      fvdl 	nfsm_dissect(tl, u_int32_t *, 6 * NFSX_UNSIGNED);
   2883       1.48      fair 	toff = fxdr_hyper(tl);
   2884       1.23      fvdl 	tl += 2;
   2885       1.48      fair 	verf = fxdr_hyper(tl);
   2886       1.23      fvdl 	tl += 2;
   2887       1.23      fvdl 	siz = fxdr_unsigned(int, *tl++);
   2888       1.23      fvdl 	cnt = fxdr_unsigned(int, *tl);
   2889       1.23      fvdl 	off = toff;
   2890       1.98      yamt 	siz = ((siz + NFS_SRVDIRBLKSIZ - 1) & ~(NFS_SRVDIRBLKSIZ - 1));
   2891       1.23      fvdl 	xfer = NFS_SRVMAXDATA(nfsd);
   2892       1.23      fvdl 	if (siz > xfer)
   2893       1.23      fvdl 		siz = xfer;
   2894       1.15   mycroft 	fullsiz = siz;
   2895       1.23      fvdl 	error = nfsrv_fhtovp(fhp, 1, &vp, cred, slp, nam,
   2896       1.78   thorpej 		 &rdonly, (nfsd->nd_flag & ND_KERBAUTH), FALSE);
   2897       1.39      fvdl 	if (!error && vp->v_type != VDIR) {
   2898       1.39      fvdl 		error = ENOTDIR;
   2899       1.39      fvdl 		vput(vp);
   2900       1.39      fvdl 	}
   2901       1.23      fvdl 	if (error) {
   2902       1.23      fvdl 		nfsm_reply(NFSX_UNSIGNED);
   2903       1.23      fvdl 		nfsm_srvpostop_attr(getret, &at);
   2904       1.23      fvdl 		return (0);
   2905       1.23      fvdl 	}
   2906       1.99  christos 	error = getret = VOP_GETATTR(vp, &at, cred, lwp);
   2907       1.23      fvdl #ifdef NFS3_STRICTVERF
   2908       1.23      fvdl 	/*
   2909       1.23      fvdl 	 * XXX This check is too strict for Solaris 2.5 clients.
   2910       1.23      fvdl 	 */
   2911       1.23      fvdl 	if (!error && toff && verf != at.va_filerev)
   2912       1.23      fvdl 		error = NFSERR_BAD_COOKIE;
   2913       1.23      fvdl #endif
   2914       1.23      fvdl 	if (!error) {
   2915       1.23      fvdl 		nqsrv_getl(vp, ND_READ);
   2916       1.99  christos 		error = nfsrv_access(vp, VEXEC, cred, rdonly, lwp, 0);
   2917       1.23      fvdl 	}
   2918       1.22  christos 	if (error) {
   2919       1.15   mycroft 		vput(vp);
   2920       1.23      fvdl 		nfsm_reply(NFSX_V3POSTOPATTR);
   2921       1.23      fvdl 		nfsm_srvpostop_attr(getret, &at);
   2922       1.23      fvdl 		return (0);
   2923       1.15   mycroft 	}
   2924       1.42      fvdl 	VOP_UNLOCK(vp, 0);
   2925       1.23      fvdl 
   2926       1.56   thorpej 	rbuf = malloc(siz, M_TEMP, M_WAITOK);
   2927       1.15   mycroft again:
   2928       1.15   mycroft 	iv.iov_base = rbuf;
   2929       1.15   mycroft 	iv.iov_len = fullsiz;
   2930       1.15   mycroft 	io.uio_iov = &iv;
   2931       1.15   mycroft 	io.uio_iovcnt = 1;
   2932       1.15   mycroft 	io.uio_offset = (off_t)off;
   2933       1.15   mycroft 	io.uio_resid = fullsiz;
   2934       1.15   mycroft 	io.uio_rw = UIO_READ;
   2935      1.101      yamt 	UIO_SETUP_SYSSPACE(&io);
   2936       1.23      fvdl 	eofflag = 0;
   2937       1.23      fvdl 
   2938       1.42      fvdl 	vn_lock(vp, LK_EXCLUSIVE | LK_RETRY);
   2939       1.42      fvdl 
   2940       1.42      fvdl 	error = VOP_READDIR(vp, &io, cred, &eofflag, &cookies, &ncookies);
   2941       1.23      fvdl 
   2942       1.23      fvdl 	off = (u_quad_t)io.uio_offset;
   2943       1.99  christos 	getret = VOP_GETATTR(vp, &at, cred, lwp);
   2944       1.23      fvdl 
   2945       1.42      fvdl 	VOP_UNLOCK(vp, 0);
   2946       1.36      fvdl 
   2947       1.36      fvdl 	/*
   2948       1.36      fvdl 	 * If the VGET operation doesn't work for this filesystem,
   2949       1.36      fvdl 	 * we can't support readdirplus. Returning NOTSUPP should
   2950       1.36      fvdl 	 * make clients fall back to plain readdir.
   2951       1.36      fvdl 	 * There's no need to check for VPTOFH as well, we wouldn't
   2952       1.36      fvdl 	 * even be here otherwise.
   2953       1.36      fvdl 	 */
   2954       1.36      fvdl 	if (!getret) {
   2955       1.78   thorpej 		if ((getret = VFS_VGET(vp->v_mount, at.va_fileid, &nvp)))
   2956       1.36      fvdl 			getret = (getret == EOPNOTSUPP) ?
   2957       1.36      fvdl 				NFSERR_NOTSUPP : NFSERR_IO;
   2958       1.36      fvdl 		else
   2959       1.36      fvdl 			vput(nvp);
   2960       1.36      fvdl 	}
   2961       1.36      fvdl 
   2962       1.23      fvdl 	if (!cookies && !error)
   2963       1.23      fvdl 		error = NFSERR_PERM;
   2964       1.23      fvdl 	if (!error)
   2965       1.23      fvdl 		error = getret;
   2966       1.15   mycroft 	if (error) {
   2967       1.15   mycroft 		vrele(vp);
   2968       1.23      fvdl 		if (cookies)
   2969       1.56   thorpej 			free((caddr_t)cookies, M_TEMP);
   2970       1.56   thorpej 		free((caddr_t)rbuf, M_TEMP);
   2971       1.23      fvdl 		nfsm_reply(NFSX_V3POSTOPATTR);
   2972       1.23      fvdl 		nfsm_srvpostop_attr(getret, &at);
   2973       1.23      fvdl 		return (0);
   2974       1.15   mycroft 	}
   2975       1.15   mycroft 	if (io.uio_resid) {
   2976       1.15   mycroft 		siz -= io.uio_resid;
   2977       1.15   mycroft 
   2978       1.15   mycroft 		/*
   2979       1.15   mycroft 		 * If nothing read, return eof
   2980       1.15   mycroft 		 * rpc reply
   2981       1.15   mycroft 		 */
   2982       1.15   mycroft 		if (siz == 0) {
   2983       1.15   mycroft 			vrele(vp);
   2984       1.23      fvdl 			nfsm_reply(NFSX_V3POSTOPATTR + NFSX_V3COOKIEVERF +
   2985       1.23      fvdl 				2 * NFSX_UNSIGNED);
   2986       1.23      fvdl 			nfsm_srvpostop_attr(getret, &at);
   2987       1.23      fvdl 			nfsm_build(tl, u_int32_t *, 4 * NFSX_UNSIGNED);
   2988       1.48      fair 			txdr_hyper(at.va_filerev, tl);
   2989       1.23      fvdl 			tl += 2;
   2990       1.15   mycroft 			*tl++ = nfs_false;
   2991       1.15   mycroft 			*tl = nfs_true;
   2992       1.56   thorpej 			free((caddr_t)cookies, M_TEMP);
   2993       1.56   thorpej 			free((caddr_t)rbuf, M_TEMP);
   2994       1.15   mycroft 			return (0);
   2995       1.15   mycroft 		}
   2996       1.15   mycroft 	}
   2997       1.15   mycroft 
   2998       1.15   mycroft 	/*
   2999       1.15   mycroft 	 * Check for degenerate cases of nothing useful read.
   3000       1.15   mycroft 	 * If so go try again
   3001       1.15   mycroft 	 */
   3002       1.15   mycroft 	cpos = rbuf;
   3003       1.15   mycroft 	cend = rbuf + siz;
   3004       1.23      fvdl 	dp = (struct dirent *)cpos;
   3005       1.23      fvdl 	cookiep = cookies;
   3006       1.23      fvdl 
   3007       1.29      fvdl 	while (cpos < cend && ncookies > 0 &&
   3008       1.29      fvdl 		(dp->d_fileno == 0 || dp->d_type == DT_WHT)) {
   3009       1.23      fvdl 		cpos += dp->d_reclen;
   3010       1.15   mycroft 		dp = (struct dirent *)cpos;
   3011       1.23      fvdl 		cookiep++;
   3012       1.23      fvdl 		ncookies--;
   3013       1.15   mycroft 	}
   3014       1.23      fvdl 	if (cpos >= cend || ncookies == 0) {
   3015       1.23      fvdl 		toff = off;
   3016       1.15   mycroft 		siz = fullsiz;
   3017       1.15   mycroft 		goto again;
   3018       1.15   mycroft 	}
   3019       1.15   mycroft 
   3020       1.23      fvdl 	dirlen = len = NFSX_V3POSTOPATTR + NFSX_V3COOKIEVERF + 2 * NFSX_UNSIGNED;
   3021       1.23      fvdl 	nfsm_reply(cnt);
   3022       1.23      fvdl 	nfsm_srvpostop_attr(getret, &at);
   3023       1.23      fvdl 	nfsm_build(tl, u_int32_t *, 2 * NFSX_UNSIGNED);
   3024       1.48      fair 	txdr_hyper(at.va_filerev, tl);
   3025       1.15   mycroft 	mp = mp2 = mb;
   3026       1.15   mycroft 	bp = bpos;
   3027       1.15   mycroft 	be = bp + M_TRAILINGSPACE(mp);
   3028        1.1       cgd 
   3029        1.1       cgd 	/* Loop through the records and build reply */
   3030       1.23      fvdl 	while (cpos < cend && ncookies > 0) {
   3031       1.25       jtk 		if (dp->d_fileno != 0 && dp->d_type != DT_WHT) {
   3032        1.1       cgd 			nlen = dp->d_namlen;
   3033        1.1       cgd 			rem = nfsm_rndup(nlen)-nlen;
   3034       1.94     perry 
   3035        1.1       cgd 			/*
   3036       1.15   mycroft 			 * For readdir_and_lookup get the vnode using
   3037       1.15   mycroft 			 * the file number.
   3038        1.1       cgd 			 */
   3039       1.78   thorpej 			if (VFS_VGET(vp->v_mount, dp->d_fileno, &nvp))
   3040       1.15   mycroft 				goto invalid;
   3041  1.101.2.3      yamt 			if (vfs_composefh(nvp, nfhp)) {
   3042       1.15   mycroft 				vput(nvp);
   3043       1.15   mycroft 				goto invalid;
   3044       1.15   mycroft 			}
   3045       1.99  christos 			if (VOP_GETATTR(nvp, vap, cred, lwp)) {
   3046       1.15   mycroft 				vput(nvp);
   3047       1.15   mycroft 				goto invalid;
   3048       1.15   mycroft 			}
   3049       1.15   mycroft 			vput(nvp);
   3050       1.23      fvdl 
   3051       1.23      fvdl 			/*
   3052       1.23      fvdl 			 * If either the dircount or maxcount will be
   3053       1.23      fvdl 			 * exceeded, get out now. Both of these lengths
   3054       1.23      fvdl 			 * are calculated conservatively, including all
   3055       1.23      fvdl 			 * XDR overheads.
   3056       1.23      fvdl 			 */
   3057       1.52      fvdl 			len += (8 * NFSX_UNSIGNED + nlen + rem + NFSX_V3FH +
   3058       1.23      fvdl 				NFSX_V3POSTOPATTR);
   3059       1.23      fvdl 			dirlen += (6 * NFSX_UNSIGNED + nlen + rem);
   3060       1.23      fvdl 			if (len > cnt || dirlen > fullsiz) {
   3061        1.1       cgd 				eofflag = 0;
   3062        1.1       cgd 				break;
   3063        1.1       cgd 			}
   3064       1.23      fvdl 
   3065       1.15   mycroft 			/*
   3066       1.15   mycroft 			 * Build the directory record xdr from
   3067       1.15   mycroft 			 * the dirent entry.
   3068       1.15   mycroft 			 */
   3069       1.23      fvdl 			fp = (struct nfs_fattr *)&fl.fl_fattr;
   3070       1.23      fvdl 			nfsm_srvfillattr(vap, fp);
   3071       1.23      fvdl 			fl.fl_fhsize = txdr_unsigned(NFSX_V3FH);
   3072       1.23      fvdl 			fl.fl_fhok = nfs_true;
   3073       1.23      fvdl 			fl.fl_postopok = nfs_true;
   3074       1.48      fair 			txdr_hyper(*cookiep, fl.fl_off.nfsuquad);
   3075       1.23      fvdl 
   3076        1.1       cgd 			nfsm_clget;
   3077        1.1       cgd 			*tl = nfs_true;
   3078        1.1       cgd 			bp += NFSX_UNSIGNED;
   3079       1.23      fvdl 			nfsm_clget;
   3080       1.96      yamt 			*tl = txdr_unsigned(dp->d_fileno >> 32);
   3081       1.23      fvdl 			bp += NFSX_UNSIGNED;
   3082        1.1       cgd 			nfsm_clget;
   3083       1.11        ws 			*tl = txdr_unsigned(dp->d_fileno);
   3084        1.1       cgd 			bp += NFSX_UNSIGNED;
   3085        1.1       cgd 			nfsm_clget;
   3086        1.1       cgd 			*tl = txdr_unsigned(nlen);
   3087        1.1       cgd 			bp += NFSX_UNSIGNED;
   3088       1.94     perry 
   3089       1.15   mycroft 			/* And loop around copying the name */
   3090        1.1       cgd 			xfer = nlen;
   3091        1.1       cgd 			cp = dp->d_name;
   3092        1.1       cgd 			while (xfer > 0) {
   3093        1.1       cgd 				nfsm_clget;
   3094       1.23      fvdl 				if ((bp + xfer) > be)
   3095       1.23      fvdl 					tsiz = be - bp;
   3096        1.1       cgd 				else
   3097        1.1       cgd 					tsiz = xfer;
   3098       1.44     perry 				memcpy(bp, cp, tsiz);
   3099        1.1       cgd 				bp += tsiz;
   3100        1.1       cgd 				xfer -= tsiz;
   3101        1.1       cgd 				if (xfer > 0)
   3102        1.1       cgd 					cp += tsiz;
   3103        1.1       cgd 			}
   3104       1.23      fvdl 			/* And null pad to an int32_t boundary */
   3105        1.1       cgd 			for (i = 0; i < rem; i++)
   3106        1.1       cgd 				*bp++ = '\0';
   3107       1.94     perry 
   3108       1.23      fvdl 			/*
   3109       1.23      fvdl 			 * Now copy the flrep structure out.
   3110       1.23      fvdl 			 */
   3111       1.23      fvdl 			xfer = sizeof (struct flrep);
   3112       1.23      fvdl 			cp = (caddr_t)&fl;
   3113       1.23      fvdl 			while (xfer > 0) {
   3114       1.23      fvdl 				nfsm_clget;
   3115       1.23      fvdl 				if ((bp + xfer) > be)
   3116       1.23      fvdl 					tsiz = be - bp;
   3117       1.23      fvdl 				else
   3118       1.23      fvdl 					tsiz = xfer;
   3119       1.44     perry 				memcpy(bp, cp, tsiz);
   3120       1.23      fvdl 				bp += tsiz;
   3121       1.23      fvdl 				xfer -= tsiz;
   3122       1.23      fvdl 				if (xfer > 0)
   3123       1.23      fvdl 					cp += tsiz;
   3124       1.23      fvdl 			}
   3125        1.8        ws 		}
   3126       1.15   mycroft invalid:
   3127        1.1       cgd 		cpos += dp->d_reclen;
   3128       1.11        ws 		dp = (struct dirent *)cpos;
   3129       1.23      fvdl 		cookiep++;
   3130       1.23      fvdl 		ncookies--;
   3131        1.1       cgd 	}
   3132       1.15   mycroft 	vrele(vp);
   3133        1.1       cgd 	nfsm_clget;
   3134        1.1       cgd 	*tl = nfs_false;
   3135        1.1       cgd 	bp += NFSX_UNSIGNED;
   3136        1.1       cgd 	nfsm_clget;
   3137        1.1       cgd 	if (eofflag)
   3138        1.1       cgd 		*tl = nfs_true;
   3139        1.1       cgd 	else
   3140        1.1       cgd 		*tl = nfs_false;
   3141        1.1       cgd 	bp += NFSX_UNSIGNED;
   3142       1.15   mycroft 	if (mp != mb) {
   3143       1.15   mycroft 		if (bp < be)
   3144       1.15   mycroft 			mp->m_len = bp - mtod(mp, caddr_t);
   3145       1.15   mycroft 	} else
   3146       1.15   mycroft 		mp->m_len += bp - bpos;
   3147       1.56   thorpej 	free((caddr_t)cookies, M_TEMP);
   3148       1.56   thorpej 	free((caddr_t)rbuf, M_TEMP);
   3149       1.23      fvdl 	nfsm_srvdone;
   3150       1.23      fvdl }
   3151       1.23      fvdl 
   3152       1.23      fvdl /*
   3153       1.23      fvdl  * nfs commit service
   3154       1.23      fvdl  */
   3155       1.23      fvdl int
   3156       1.99  christos nfsrv_commit(nfsd, slp, lwp, mrq)
   3157       1.23      fvdl 	struct nfsrv_descript *nfsd;
   3158       1.23      fvdl 	struct nfssvc_sock *slp;
   3159       1.99  christos 	struct lwp *lwp;
   3160       1.23      fvdl 	struct mbuf **mrq;
   3161       1.23      fvdl {
   3162       1.23      fvdl 	struct mbuf *mrep = nfsd->nd_mrep, *md = nfsd->nd_md;
   3163       1.23      fvdl 	struct mbuf *nam = nfsd->nd_nam;
   3164       1.23      fvdl 	caddr_t dpos = nfsd->nd_dpos;
   3165  1.101.2.2      yamt 	kauth_cred_t cred = nfsd->nd_cr;
   3166       1.23      fvdl 	struct vattr bfor, aft;
   3167       1.23      fvdl 	struct vnode *vp;
   3168       1.23      fvdl 	nfsfh_t nfh;
   3169       1.23      fvdl 	fhandle_t *fhp;
   3170       1.54  augustss 	u_int32_t *tl;
   3171       1.54  augustss 	int32_t t1;
   3172       1.23      fvdl 	caddr_t bpos;
   3173  1.101.2.2      yamt 	int error = 0, rdonly, for_ret = 1, aft_ret = 1, cache = 0;
   3174       1.93      yamt 	uint32_t cnt;
   3175       1.23      fvdl 	char *cp2;
   3176       1.67      matt 	struct mbuf *mb, *mreq;
   3177       1.65    bouyer 	u_quad_t frev, off, end;
   3178       1.82   hannken 	struct mount *mp = NULL;
   3179       1.23      fvdl 
   3180       1.23      fvdl 	fhp = &nfh.fh_generic;
   3181       1.23      fvdl 	nfsm_srvmtofh(fhp);
   3182       1.82   hannken 	if ((mp = vfs_getvfs(&fhp->fh_fsid)) == NULL)
   3183       1.82   hannken 		return (ESTALE);
   3184       1.82   hannken 	vn_start_write(NULL, &mp, V_WAIT);
   3185       1.23      fvdl 	nfsm_dissect(tl, u_int32_t *, 3 * NFSX_UNSIGNED);
   3186       1.23      fvdl 
   3187       1.48      fair 	off = fxdr_hyper(tl);
   3188       1.23      fvdl 	tl += 2;
   3189       1.93      yamt 	cnt = fxdr_unsigned(uint32_t, *tl);
   3190       1.23      fvdl 	error = nfsrv_fhtovp(fhp, 1, &vp, cred, slp, nam,
   3191       1.78   thorpej 		 &rdonly, (nfsd->nd_flag & ND_KERBAUTH), FALSE);
   3192       1.23      fvdl 	if (error) {
   3193       1.23      fvdl 		nfsm_reply(2 * NFSX_UNSIGNED);
   3194       1.23      fvdl 		nfsm_srvwcc_data(for_ret, &bfor, aft_ret, &aft);
   3195       1.82   hannken 		vn_finished_write(mp, 0);
   3196       1.23      fvdl 		return (0);
   3197       1.23      fvdl 	}
   3198       1.99  christos 	for_ret = VOP_GETATTR(vp, &bfor, cred, lwp);
   3199       1.65    bouyer 	end = (cnt > 0) ? off + cnt : vp->v_size;
   3200       1.65    bouyer 	if (end < off || end > vp->v_size)
   3201       1.65    bouyer 		end = vp->v_size;
   3202       1.80    bouyer 	if (off < vp->v_size)
   3203       1.99  christos 		error = VOP_FSYNC(vp, cred, FSYNC_WAIT, off, end, lwp);
   3204       1.80    bouyer 	/* else error == 0, from nfsrv_fhtovp() */
   3205       1.99  christos 	aft_ret = VOP_GETATTR(vp, &aft, cred, lwp);
   3206       1.23      fvdl 	vput(vp);
   3207       1.23      fvdl 	nfsm_reply(NFSX_V3WCCDATA + NFSX_V3WRITEVERF);
   3208       1.23      fvdl 	nfsm_srvwcc_data(for_ret, &bfor, aft_ret, &aft);
   3209       1.23      fvdl 	if (!error) {
   3210       1.23      fvdl 		nfsm_build(tl, u_int32_t *, NFSX_V3WRITEVERF);
   3211       1.23      fvdl 		*tl++ = txdr_unsigned(boottime.tv_sec);
   3212       1.23      fvdl 		*tl = txdr_unsigned(boottime.tv_usec);
   3213       1.82   hannken 	} else {
   3214       1.82   hannken 		vn_finished_write(mp, 0);
   3215       1.23      fvdl 		return (0);
   3216       1.82   hannken 	}
   3217       1.82   hannken 	vn_finished_write(mp, 0);
   3218        1.1       cgd 	nfsm_srvdone;
   3219        1.1       cgd }
   3220        1.1       cgd 
   3221        1.1       cgd /*
   3222        1.1       cgd  * nfs statfs service
   3223        1.1       cgd  */
   3224       1.22  christos int
   3225       1.99  christos nfsrv_statfs(nfsd, slp, lwp, mrq)
   3226       1.23      fvdl 	struct nfsrv_descript *nfsd;
   3227       1.23      fvdl 	struct nfssvc_sock *slp;
   3228       1.99  christos 	struct lwp *lwp;
   3229       1.23      fvdl 	struct mbuf **mrq;
   3230        1.1       cgd {
   3231       1.23      fvdl 	struct mbuf *mrep = nfsd->nd_mrep, *md = nfsd->nd_md;
   3232       1.23      fvdl 	struct mbuf *nam = nfsd->nd_nam;
   3233       1.23      fvdl 	caddr_t dpos = nfsd->nd_dpos;
   3234  1.101.2.2      yamt 	kauth_cred_t cred = nfsd->nd_cr;
   3235  1.101.2.3      yamt 	struct statvfs *sf = NULL;
   3236       1.54  augustss 	struct nfs_statfs *sfp;
   3237       1.54  augustss 	u_int32_t *tl;
   3238       1.54  augustss 	int32_t t1;
   3239        1.1       cgd 	caddr_t bpos;
   3240  1.101.2.2      yamt 	int error = 0, rdonly, cache = 0, getret = 1;
   3241       1.23      fvdl 	int v3 = (nfsd->nd_flag & ND_NFSV3);
   3242        1.1       cgd 	char *cp2;
   3243       1.67      matt 	struct mbuf *mb, *mreq;
   3244        1.1       cgd 	struct vnode *vp;
   3245       1.23      fvdl 	struct vattr at;
   3246       1.23      fvdl 	nfsfh_t nfh;
   3247        1.1       cgd 	fhandle_t *fhp;
   3248       1.23      fvdl 	u_quad_t frev, tval;
   3249        1.1       cgd 
   3250        1.1       cgd 	fhp = &nfh.fh_generic;
   3251        1.1       cgd 	nfsm_srvmtofh(fhp);
   3252       1.23      fvdl 	error = nfsrv_fhtovp(fhp, 1, &vp, cred, slp, nam,
   3253       1.78   thorpej 		 &rdonly, (nfsd->nd_flag & ND_KERBAUTH), FALSE);
   3254       1.23      fvdl 	if (error) {
   3255       1.23      fvdl 		nfsm_reply(NFSX_UNSIGNED);
   3256       1.23      fvdl 		nfsm_srvpostop_attr(getret, &at);
   3257       1.23      fvdl 		return (0);
   3258       1.23      fvdl 	}
   3259  1.101.2.3      yamt 	sf = malloc(sizeof(*sf), M_TEMP, M_WAITOK);
   3260       1.99  christos 	error = VFS_STATVFS(vp->v_mount, sf, lwp);
   3261       1.99  christos 	getret = VOP_GETATTR(vp, &at, cred, lwp);
   3262        1.1       cgd 	vput(vp);
   3263       1.23      fvdl 	nfsm_reply(NFSX_POSTOPATTR(v3) + NFSX_STATFS(v3));
   3264       1.23      fvdl 	if (v3)
   3265       1.23      fvdl 		nfsm_srvpostop_attr(getret, &at);
   3266  1.101.2.3      yamt 	if (error) {
   3267  1.101.2.3      yamt 		free(sf, M_TEMP);
   3268       1.23      fvdl 		return (0);
   3269  1.101.2.3      yamt 	}
   3270       1.23      fvdl 	nfsm_build(sfp, struct nfs_statfs *, NFSX_STATFS(v3));
   3271       1.23      fvdl 	if (v3) {
   3272       1.88  christos 		tval = (u_quad_t)((quad_t)sf->f_blocks * (quad_t)sf->f_frsize);
   3273       1.48      fair 		txdr_hyper(tval, &sfp->sf_tbytes);
   3274       1.88  christos 		tval = (u_quad_t)((quad_t)sf->f_bfree * (quad_t)sf->f_frsize);
   3275       1.48      fair 		txdr_hyper(tval, &sfp->sf_fbytes);
   3276       1.88  christos 		tval = (u_quad_t)((quad_t)sf->f_bavail * (quad_t)sf->f_frsize);
   3277       1.48      fair 		txdr_hyper(tval, &sfp->sf_abytes);
   3278       1.47   mycroft 		tval = (u_quad_t)sf->f_files;
   3279       1.48      fair 		txdr_hyper(tval, &sfp->sf_tfiles);
   3280       1.47   mycroft 		tval = (u_quad_t)sf->f_ffree;
   3281       1.48      fair 		txdr_hyper(tval, &sfp->sf_ffiles);
   3282       1.48      fair 		txdr_hyper(tval, &sfp->sf_afiles);
   3283       1.23      fvdl 		sfp->sf_invarsec = 0;
   3284       1.23      fvdl 	} else {
   3285       1.23      fvdl 		sfp->sf_tsize = txdr_unsigned(NFS_MAXDGRAMDATA);
   3286       1.88  christos 		sfp->sf_bsize = txdr_unsigned(sf->f_frsize);
   3287       1.23      fvdl 		sfp->sf_blocks = txdr_unsigned(sf->f_blocks);
   3288       1.23      fvdl 		sfp->sf_bfree = txdr_unsigned(sf->f_bfree);
   3289       1.23      fvdl 		sfp->sf_bavail = txdr_unsigned(sf->f_bavail);
   3290       1.23      fvdl 	}
   3291  1.101.2.3      yamt nfsmout:
   3292  1.101.2.3      yamt 	if (sf)
   3293  1.101.2.3      yamt 	    free(sf, M_TEMP);
   3294  1.101.2.3      yamt 	return error;
   3295       1.23      fvdl }
   3296       1.23      fvdl 
   3297       1.23      fvdl /*
   3298       1.23      fvdl  * nfs fsinfo service
   3299       1.23      fvdl  */
   3300       1.23      fvdl int
   3301       1.99  christos nfsrv_fsinfo(nfsd, slp, lwp, mrq)
   3302       1.23      fvdl 	struct nfsrv_descript *nfsd;
   3303       1.23      fvdl 	struct nfssvc_sock *slp;
   3304       1.99  christos 	struct lwp *lwp;
   3305       1.23      fvdl 	struct mbuf **mrq;
   3306       1.23      fvdl {
   3307       1.23      fvdl 	struct mbuf *mrep = nfsd->nd_mrep, *md = nfsd->nd_md;
   3308       1.23      fvdl 	struct mbuf *nam = nfsd->nd_nam;
   3309       1.23      fvdl 	caddr_t dpos = nfsd->nd_dpos;
   3310  1.101.2.2      yamt 	kauth_cred_t cred = nfsd->nd_cr;
   3311       1.54  augustss 	u_int32_t *tl;
   3312       1.54  augustss 	struct nfsv3_fsinfo *sip;
   3313       1.54  augustss 	int32_t t1;
   3314       1.23      fvdl 	caddr_t bpos;
   3315  1.101.2.2      yamt 	int error = 0, rdonly, cache = 0, getret = 1;
   3316       1.69      yamt 	uint32_t maxdata;
   3317       1.23      fvdl 	char *cp2;
   3318       1.67      matt 	struct mbuf *mb, *mreq;
   3319       1.23      fvdl 	struct vnode *vp;
   3320       1.23      fvdl 	struct vattr at;
   3321       1.23      fvdl 	nfsfh_t nfh;
   3322       1.23      fvdl 	fhandle_t *fhp;
   3323       1.37      fvdl 	u_quad_t frev, maxfsize;
   3324  1.101.2.3      yamt 	struct statvfs *sb;
   3325       1.23      fvdl 
   3326       1.23      fvdl 	fhp = &nfh.fh_generic;
   3327       1.23      fvdl 	nfsm_srvmtofh(fhp);
   3328       1.23      fvdl 	error = nfsrv_fhtovp(fhp, 1, &vp, cred, slp, nam,
   3329       1.78   thorpej 		 &rdonly, (nfsd->nd_flag & ND_KERBAUTH), FALSE);
   3330       1.23      fvdl 	if (error) {
   3331       1.23      fvdl 		nfsm_reply(NFSX_UNSIGNED);
   3332       1.23      fvdl 		nfsm_srvpostop_attr(getret, &at);
   3333       1.23      fvdl 		return (0);
   3334       1.15   mycroft 	}
   3335       1.37      fvdl 
   3336       1.37      fvdl 	/* XXX Try to make a guess on the max file size. */
   3337  1.101.2.3      yamt 	sb = malloc(sizeof(*sb), M_TEMP, M_WAITOK);
   3338  1.101.2.3      yamt 	VFS_STATVFS(vp->v_mount, sb, (struct lwp *)0);
   3339  1.101.2.3      yamt 	maxfsize = (u_quad_t)0x80000000 * sb->f_frsize - 1;
   3340  1.101.2.3      yamt 	free(sb, M_TEMP);
   3341       1.37      fvdl 
   3342       1.99  christos 	getret = VOP_GETATTR(vp, &at, cred, lwp);
   3343       1.23      fvdl 	vput(vp);
   3344       1.23      fvdl 	nfsm_reply(NFSX_V3POSTOPATTR + NFSX_V3FSINFO);
   3345       1.23      fvdl 	nfsm_srvpostop_attr(getret, &at);
   3346       1.23      fvdl 	nfsm_build(sip, struct nfsv3_fsinfo *, NFSX_V3FSINFO);
   3347       1.23      fvdl 
   3348       1.23      fvdl 	/*
   3349       1.23      fvdl 	 * XXX
   3350       1.23      fvdl 	 * There should be file system VFS OP(s) to get this information.
   3351       1.23      fvdl 	 * For now, assume ufs.
   3352       1.23      fvdl 	 */
   3353       1.23      fvdl 	if (slp->ns_so->so_type == SOCK_DGRAM)
   3354       1.69      yamt 		maxdata = NFS_MAXDGRAMDATA;
   3355       1.23      fvdl 	else
   3356       1.69      yamt 		maxdata = NFS_MAXDATA;
   3357       1.69      yamt 	sip->fs_rtmax = txdr_unsigned(maxdata);
   3358       1.69      yamt 	sip->fs_rtpref = txdr_unsigned(maxdata);
   3359       1.23      fvdl 	sip->fs_rtmult = txdr_unsigned(NFS_FABLKSIZE);
   3360       1.69      yamt 	sip->fs_wtmax = txdr_unsigned(maxdata);
   3361       1.69      yamt 	sip->fs_wtpref = txdr_unsigned(maxdata);
   3362       1.23      fvdl 	sip->fs_wtmult = txdr_unsigned(NFS_FABLKSIZE);
   3363       1.69      yamt 	sip->fs_dtpref = txdr_unsigned(maxdata);
   3364       1.48      fair 	txdr_hyper(maxfsize, &sip->fs_maxfilesize);
   3365       1.23      fvdl 	sip->fs_timedelta.nfsv3_sec = 0;
   3366       1.23      fvdl 	sip->fs_timedelta.nfsv3_nsec = txdr_unsigned(1);
   3367       1.23      fvdl 	sip->fs_properties = txdr_unsigned(NFSV3FSINFO_LINK |
   3368       1.23      fvdl 		NFSV3FSINFO_SYMLINK | NFSV3FSINFO_HOMOGENEOUS |
   3369       1.23      fvdl 		NFSV3FSINFO_CANSETTIME);
   3370       1.23      fvdl 	nfsm_srvdone;
   3371       1.23      fvdl }
   3372       1.23      fvdl 
   3373       1.23      fvdl /*
   3374       1.23      fvdl  * nfs pathconf service
   3375       1.23      fvdl  */
   3376       1.23      fvdl int
   3377       1.99  christos nfsrv_pathconf(nfsd, slp, lwp, mrq)
   3378       1.23      fvdl 	struct nfsrv_descript *nfsd;
   3379       1.23      fvdl 	struct nfssvc_sock *slp;
   3380       1.99  christos 	struct lwp *lwp;
   3381       1.23      fvdl 	struct mbuf **mrq;
   3382       1.23      fvdl {
   3383       1.23      fvdl 	struct mbuf *mrep = nfsd->nd_mrep, *md = nfsd->nd_md;
   3384       1.23      fvdl 	struct mbuf *nam = nfsd->nd_nam;
   3385       1.23      fvdl 	caddr_t dpos = nfsd->nd_dpos;
   3386  1.101.2.2      yamt 	kauth_cred_t cred = nfsd->nd_cr;
   3387       1.54  augustss 	u_int32_t *tl;
   3388       1.54  augustss 	struct nfsv3_pathconf *pc;
   3389       1.54  augustss 	int32_t t1;
   3390       1.23      fvdl 	caddr_t bpos;
   3391  1.101.2.2      yamt 	int error = 0, rdonly, cache = 0, getret = 1;
   3392       1.24       cgd 	register_t linkmax, namemax, chownres, notrunc;
   3393       1.23      fvdl 	char *cp2;
   3394       1.67      matt 	struct mbuf *mb, *mreq;
   3395       1.23      fvdl 	struct vnode *vp;
   3396       1.23      fvdl 	struct vattr at;
   3397       1.23      fvdl 	nfsfh_t nfh;
   3398       1.23      fvdl 	fhandle_t *fhp;
   3399       1.23      fvdl 	u_quad_t frev;
   3400       1.23      fvdl 
   3401       1.23      fvdl 	fhp = &nfh.fh_generic;
   3402       1.23      fvdl 	nfsm_srvmtofh(fhp);
   3403       1.23      fvdl 	error = nfsrv_fhtovp(fhp, 1, &vp, cred, slp, nam,
   3404       1.78   thorpej 		 &rdonly, (nfsd->nd_flag & ND_KERBAUTH), FALSE);
   3405       1.23      fvdl 	if (error) {
   3406       1.23      fvdl 		nfsm_reply(NFSX_UNSIGNED);
   3407       1.23      fvdl 		nfsm_srvpostop_attr(getret, &at);
   3408       1.23      fvdl 		return (0);
   3409       1.23      fvdl 	}
   3410       1.23      fvdl 	error = VOP_PATHCONF(vp, _PC_LINK_MAX, &linkmax);
   3411       1.23      fvdl 	if (!error)
   3412       1.23      fvdl 		error = VOP_PATHCONF(vp, _PC_NAME_MAX, &namemax);
   3413       1.23      fvdl 	if (!error)
   3414       1.23      fvdl 		error = VOP_PATHCONF(vp, _PC_CHOWN_RESTRICTED, &chownres);
   3415       1.23      fvdl 	if (!error)
   3416       1.23      fvdl 		error = VOP_PATHCONF(vp, _PC_NO_TRUNC, &notrunc);
   3417       1.99  christos 	getret = VOP_GETATTR(vp, &at, cred, lwp);
   3418       1.23      fvdl 	vput(vp);
   3419       1.23      fvdl 	nfsm_reply(NFSX_V3POSTOPATTR + NFSX_V3PATHCONF);
   3420       1.23      fvdl 	nfsm_srvpostop_attr(getret, &at);
   3421       1.23      fvdl 	if (error)
   3422       1.23      fvdl 		return (0);
   3423       1.23      fvdl 	nfsm_build(pc, struct nfsv3_pathconf *, NFSX_V3PATHCONF);
   3424       1.23      fvdl 
   3425       1.23      fvdl 	pc->pc_linkmax = txdr_unsigned(linkmax);
   3426       1.23      fvdl 	pc->pc_namemax = txdr_unsigned(namemax);
   3427       1.23      fvdl 	pc->pc_notrunc = txdr_unsigned(notrunc);
   3428       1.23      fvdl 	pc->pc_chownrestricted = txdr_unsigned(chownres);
   3429       1.23      fvdl 
   3430       1.23      fvdl 	/*
   3431       1.23      fvdl 	 * These should probably be supported by VOP_PATHCONF(), but
   3432       1.23      fvdl 	 * until msdosfs is exportable (why would you want to?), the
   3433       1.23      fvdl 	 * Unix defaults should be ok.
   3434       1.23      fvdl 	 */
   3435       1.23      fvdl 	pc->pc_caseinsensitive = nfs_false;
   3436       1.23      fvdl 	pc->pc_casepreserving = nfs_true;
   3437        1.1       cgd 	nfsm_srvdone;
   3438        1.1       cgd }
   3439        1.1       cgd 
   3440        1.1       cgd /*
   3441        1.1       cgd  * Null operation, used by clients to ping server
   3442        1.1       cgd  */
   3443        1.1       cgd /* ARGSUSED */
   3444       1.22  christos int
   3445       1.99  christos nfsrv_null(nfsd, slp, lwp, mrq)
   3446       1.23      fvdl 	struct nfsrv_descript *nfsd;
   3447       1.23      fvdl 	struct nfssvc_sock *slp;
   3448       1.99  christos 	struct lwp *lwp;
   3449       1.23      fvdl 	struct mbuf **mrq;
   3450        1.1       cgd {
   3451       1.23      fvdl 	struct mbuf *mrep = nfsd->nd_mrep;
   3452        1.1       cgd 	caddr_t bpos;
   3453       1.23      fvdl 	int error = NFSERR_RETVOID, cache = 0;
   3454        1.1       cgd 	struct mbuf *mb, *mreq;
   3455       1.15   mycroft 	u_quad_t frev;
   3456        1.1       cgd 
   3457        1.1       cgd 	nfsm_reply(0);
   3458       1.23      fvdl 	return (0);
   3459        1.1       cgd }
   3460        1.1       cgd 
   3461        1.1       cgd /*
   3462        1.1       cgd  * No operation, used for obsolete procedures
   3463        1.1       cgd  */
   3464        1.1       cgd /* ARGSUSED */
   3465       1.22  christos int
   3466       1.99  christos nfsrv_noop(nfsd, slp, lwp, mrq)
   3467       1.23      fvdl 	struct nfsrv_descript *nfsd;
   3468       1.23      fvdl 	struct nfssvc_sock *slp;
   3469       1.99  christos 	struct lwp *lwp;
   3470       1.23      fvdl 	struct mbuf **mrq;
   3471        1.1       cgd {
   3472       1.23      fvdl 	struct mbuf *mrep = nfsd->nd_mrep;
   3473        1.1       cgd 	caddr_t bpos;
   3474       1.22  christos 	int error, cache = 0;
   3475        1.1       cgd 	struct mbuf *mb, *mreq;
   3476       1.15   mycroft 	u_quad_t frev;
   3477        1.1       cgd 
   3478       1.15   mycroft 	if (nfsd->nd_repstat)
   3479       1.15   mycroft 		error = nfsd->nd_repstat;
   3480        1.2       cgd 	else
   3481        1.2       cgd 		error = EPROCUNAVAIL;
   3482        1.1       cgd 	nfsm_reply(0);
   3483       1.23      fvdl 	return (0);
   3484        1.1       cgd }
   3485        1.1       cgd 
   3486        1.1       cgd /*
   3487        1.1       cgd  * Perform access checking for vnodes obtained from file handles that would
   3488        1.1       cgd  * refer to files already opened by a Unix client. You cannot just use
   3489        1.1       cgd  * vn_writechk() and VOP_ACCESS() for two reasons.
   3490       1.15   mycroft  * 1 - You must check for exported rdonly as well as MNT_RDONLY for the write case
   3491       1.27      fvdl  * 2 - The owner is to be given access irrespective of mode bits for some
   3492       1.27      fvdl  *     operations, so that processes that chmod after opening a file don't
   3493       1.27      fvdl  *     break. I don't like this because it opens a security hole, but since
   3494       1.27      fvdl  *     the nfs server opens a security hole the size of a barn door anyhow,
   3495       1.27      fvdl  *     what the heck.
   3496       1.31      fvdl  *
   3497       1.31      fvdl  * The exception to rule 2 is EPERM. If a file is IMMUTABLE, VOP_ACCESS()
   3498       1.31      fvdl  * will return EPERM instead of EACCESS. EPERM is always an error.
   3499        1.1       cgd  */
   3500       1.22  christos int
   3501       1.99  christos nfsrv_access(vp, flags, cred, rdonly, lwp, override)
   3502       1.54  augustss 	struct vnode *vp;
   3503        1.1       cgd 	int flags;
   3504  1.101.2.2      yamt 	kauth_cred_t cred;
   3505       1.15   mycroft 	int rdonly;
   3506       1.99  christos 	struct lwp *lwp;
   3507        1.1       cgd {
   3508        1.1       cgd 	struct vattr vattr;
   3509        1.1       cgd 	int error;
   3510        1.1       cgd 	if (flags & VWRITE) {
   3511       1.15   mycroft 		/* Just vn_writechk() changed to check rdonly */
   3512        1.1       cgd 		/*
   3513        1.1       cgd 		 * Disallow write attempts on read-only file systems;
   3514        1.1       cgd 		 * unless the file is a socket or a block or character
   3515        1.1       cgd 		 * device resident on the file system.
   3516        1.1       cgd 		 */
   3517       1.15   mycroft 		if (rdonly || (vp->v_mount->mnt_flag & MNT_RDONLY)) {
   3518        1.1       cgd 			switch (vp->v_type) {
   3519       1.23      fvdl 			case VREG:
   3520       1.23      fvdl 			case VDIR:
   3521       1.23      fvdl 			case VLNK:
   3522        1.1       cgd 				return (EROFS);
   3523       1.23      fvdl 			default:
   3524       1.22  christos 				break;
   3525        1.1       cgd 			}
   3526        1.1       cgd 		}
   3527       1.59       chs 
   3528        1.1       cgd 		/*
   3529       1.59       chs 		 * If the vnode is in use as a process's text,
   3530       1.59       chs 		 * we can't allow writing.
   3531        1.1       cgd 		 */
   3532       1.94     perry 		if (vp->v_flag & VTEXT)
   3533       1.40       mrg 			return (ETXTBSY);
   3534        1.1       cgd 	}
   3535       1.99  christos 	error = VOP_GETATTR(vp, &vattr, cred, lwp);
   3536       1.23      fvdl 	if (error)
   3537        1.1       cgd 		return (error);
   3538       1.99  christos 	error = VOP_ACCESS(vp, flags, cred, lwp);
   3539       1.27      fvdl 	/*
   3540       1.27      fvdl 	 * Allow certain operations for the owner (reads and writes
   3541       1.27      fvdl 	 * on files that are already open).
   3542       1.27      fvdl 	 */
   3543  1.101.2.2      yamt 	if (override && error == EACCES && kauth_cred_geteuid(cred) == vattr.va_uid)
   3544       1.27      fvdl 		error = 0;
   3545       1.27      fvdl 	return error;
   3546        1.1       cgd }
   3547