xref: /csrg-svn/sys/nfs/nfs_subs.c (revision 42878)
138420Smckusick /*
238420Smckusick  * Copyright (c) 1989 The Regents of the University of California.
338420Smckusick  * All rights reserved.
438420Smckusick  *
538420Smckusick  * This code is derived from software contributed to Berkeley by
638420Smckusick  * Rick Macklem at The University of Guelph.
738420Smckusick  *
838420Smckusick  * Redistribution and use in source and binary forms are permitted
938420Smckusick  * provided that the above copyright notice and this paragraph are
1038420Smckusick  * duplicated in all such forms and that any documentation,
1138420Smckusick  * advertising materials, and other materials related to such
1238420Smckusick  * distribution and use acknowledge that the software was developed
1338420Smckusick  * by the University of California, Berkeley.  The name of the
1438420Smckusick  * University may not be used to endorse or promote products derived
1538420Smckusick  * from this software without specific prior written permission.
1638420Smckusick  * THIS SOFTWARE IS PROVIDED ``AS IS'' AND WITHOUT ANY EXPRESS OR
1738420Smckusick  * IMPLIED WARRANTIES, INCLUDING, WITHOUT LIMITATION, THE IMPLIED
1838420Smckusick  * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE.
1938420Smckusick  *
20*42878Smckusick  *	@(#)nfs_subs.c	7.26 (Berkeley) 06/05/90
2138420Smckusick  */
2238420Smckusick 
2338420Smckusick /*
2438420Smckusick  * These functions support the macros and help fiddle mbuf chains for
2538420Smckusick  * the nfs op functions. They do things like create the rpc header and
2638420Smckusick  * copy data between mbuf chains and uio lists.
2738420Smckusick  */
2838420Smckusick #include "param.h"
2939345Smckusick #include "user.h"
3039345Smckusick #include "proc.h"
3140136Smckusick #include "systm.h"
3240136Smckusick #include "kernel.h"
3338420Smckusick #include "mount.h"
3438420Smckusick #include "file.h"
3538420Smckusick #include "vnode.h"
3640136Smckusick #include "mbuf.h"
3740136Smckusick #include "errno.h"
3838884Smacklem #include "map.h"
3938420Smckusick #include "rpcv2.h"
4038420Smckusick #include "nfsv2.h"
4138420Smckusick #include "nfsnode.h"
4238420Smckusick #include "nfs.h"
4338884Smacklem #include "nfsiom.h"
4438420Smckusick #include "xdr_subs.h"
4538420Smckusick #include "nfsm_subs.h"
4638420Smckusick 
4738420Smckusick #define TRUE	1
4838420Smckusick #define	FALSE	0
4938420Smckusick 
5038420Smckusick /*
5138420Smckusick  * Data items converted to xdr at startup, since they are constant
5238420Smckusick  * This is kinda hokey, but may save a little time doing byte swaps
5338420Smckusick  */
5438420Smckusick u_long nfs_procids[NFS_NPROCS];
5538420Smckusick u_long nfs_xdrneg1;
5638420Smckusick u_long rpc_call, rpc_vers, rpc_reply, rpc_msgdenied,
5738420Smckusick 	rpc_mismatch, rpc_auth_unix, rpc_msgaccepted;
5838420Smckusick u_long nfs_vers, nfs_prog, nfs_true, nfs_false;
5938420Smckusick /* And other global data */
6038420Smckusick static u_long *rpc_uidp = (u_long *)0;
6138420Smckusick static u_long nfs_xid = 1;
6238420Smckusick static char *rpc_unixauth;
6338420Smckusick extern long hostid;
6442244Smckusick enum vtype ntov_type[7] = { VNON, VREG, VDIR, VBLK, VCHR, VLNK, VNON };
6541902Smckusick extern struct proc *nfs_iodwant[NFS_MAXASYNCDAEMON];
6638884Smacklem extern struct map nfsmap[NFS_MSIZ];
6741902Smckusick extern struct nfsreq nfsreqh;
6838420Smckusick 
6938420Smckusick /* Function ret types */
7038420Smckusick static char *nfs_unixauth();
7138420Smckusick 
7238420Smckusick /*
7338737Smckusick  * Maximum number of groups passed through to NFS server.
7441902Smckusick  * According to RFC1057 it should be 16.
7538737Smckusick  * For release 3.X systems, the maximum value is 8.
7638737Smckusick  * For release 4.X systems, the maximum value is 10.
7738737Smckusick  */
7838737Smckusick int numgrps = 8;
7938737Smckusick 
8038737Smckusick /*
8138420Smckusick  * Create the header for an rpc request packet
8238420Smckusick  * The function nfs_unixauth() creates a unix style authorization string
8338420Smckusick  * and returns a ptr to it.
8438420Smckusick  * The hsiz is the size of the rest of the nfs request header.
8538420Smckusick  * (just used to decide if a cluster is a good idea)
8639494Smckusick  * nb: Note that the prog, vers and procid args are already in xdr byte order
8738420Smckusick  */
8839494Smckusick struct mbuf *nfsm_reqh(prog, vers, procid, cred, hsiz, bpos, mb, retxid)
8938420Smckusick 	u_long prog;
9038420Smckusick 	u_long vers;
9139494Smckusick 	u_long procid;
9238420Smckusick 	struct ucred *cred;
9338420Smckusick 	int hsiz;
9438420Smckusick 	caddr_t *bpos;
9538420Smckusick 	struct mbuf **mb;
9638420Smckusick 	u_long *retxid;
9738420Smckusick {
9838420Smckusick 	register struct mbuf *mreq, *m;
9938420Smckusick 	register u_long *p;
10038420Smckusick 	struct mbuf *m1;
10138420Smckusick 	char *ap;
10238420Smckusick 	int asiz, siz;
10338420Smckusick 
10438420Smckusick 	NFSMGETHDR(mreq);
10538737Smckusick 	asiz = (((cred->cr_ngroups > numgrps) ? numgrps : cred->cr_ngroups)<<2);
10638425Smckusick #ifdef FILLINHOST
10738420Smckusick 	asiz += nfsm_rndup(hostnamelen)+(9*NFSX_UNSIGNED);
10838425Smckusick #else
10938425Smckusick 	asiz += 9*NFSX_UNSIGNED;
11038425Smckusick #endif
11138420Smckusick 
11238420Smckusick 	/* If we need a lot, alloc a cluster ?? */
11338420Smckusick 	if ((asiz+hsiz+RPC_SIZ) > MHLEN)
11441902Smckusick 		MCLGET(mreq, M_WAIT);
11538420Smckusick 	mreq->m_len = NFSMSIZ(mreq);
11638420Smckusick 	siz = mreq->m_len;
11738420Smckusick 	m1 = mreq;
11838420Smckusick 	/*
11938420Smckusick 	 * Alloc enough mbufs
12038420Smckusick 	 * We do it now to avoid all sleeps after the call to nfs_unixauth()
12138420Smckusick 	 */
12238420Smckusick 	while ((asiz+RPC_SIZ) > siz) {
12338420Smckusick 		MGET(m, M_WAIT, MT_DATA);
12438420Smckusick 		m1->m_next = m;
12538420Smckusick 		m->m_len = MLEN;
12638420Smckusick 		siz += MLEN;
12738420Smckusick 		m1 = m;
12838420Smckusick 	}
12938420Smckusick 	p = mtod(mreq, u_long *);
13038420Smckusick 	*p++ = *retxid = txdr_unsigned(++nfs_xid);
13138420Smckusick 	*p++ = rpc_call;
13238420Smckusick 	*p++ = rpc_vers;
13338420Smckusick 	*p++ = prog;
13438420Smckusick 	*p++ = vers;
13539494Smckusick 	*p++ = procid;
13638420Smckusick 
13738420Smckusick 	/* Now we can call nfs_unixauth() and copy it in */
13838420Smckusick 	ap = nfs_unixauth(cred);
13938420Smckusick 	m = mreq;
14038420Smckusick 	siz = m->m_len-RPC_SIZ;
14138420Smckusick 	if (asiz <= siz) {
14238420Smckusick 		bcopy(ap, (caddr_t)p, asiz);
14338420Smckusick 		m->m_len = asiz+RPC_SIZ;
14438420Smckusick 	} else {
14538420Smckusick 		bcopy(ap, (caddr_t)p, siz);
14638420Smckusick 		ap += siz;
14738420Smckusick 		asiz -= siz;
14838420Smckusick 		while (asiz > 0) {
14938420Smckusick 			siz = (asiz > MLEN) ? MLEN : asiz;
15038420Smckusick 			m = m->m_next;
15138420Smckusick 			bcopy(ap, mtod(m, caddr_t), siz);
15238420Smckusick 			m->m_len = siz;
15338420Smckusick 			asiz -= siz;
15438420Smckusick 			ap += siz;
15538420Smckusick 		}
15638420Smckusick 	}
15738420Smckusick 
15838420Smckusick 	/* Finally, return values */
15938420Smckusick 	*mb = m;
16038420Smckusick 	*bpos = mtod(m, caddr_t)+m->m_len;
16138420Smckusick 	return (mreq);
16238420Smckusick }
16338420Smckusick 
16438420Smckusick /*
16538420Smckusick  * copies mbuf chain to the uio scatter/gather list
16638420Smckusick  */
16738420Smckusick nfsm_mbuftouio(mrep, uiop, siz, dpos)
16838420Smckusick 	struct mbuf **mrep;
16938420Smckusick 	struct uio *uiop;
17038420Smckusick 	int siz;
17138420Smckusick 	caddr_t *dpos;
17238420Smckusick {
17338420Smckusick 	register int xfer, left, len;
17438420Smckusick 	register struct mbuf *mp;
17538420Smckusick 	register char *mbufcp, *uiocp;
17638420Smckusick 	long uiosiz, rem;
17741902Smckusick 	int error = 0;
17838420Smckusick 
17938420Smckusick 	mp = *mrep;
18038420Smckusick 	mbufcp = *dpos;
18138420Smckusick 	len = mtod(mp, caddr_t)+mp->m_len-mbufcp;
18238420Smckusick 	rem = nfsm_rndup(siz)-siz;
18338420Smckusick 	while (siz > 0) {
18438420Smckusick 		if (uiop->uio_iovcnt <= 0 || uiop->uio_iov == NULL)
18541902Smckusick 			return (EFBIG);
18638420Smckusick 		left = uiop->uio_iov->iov_len;
18738420Smckusick 		uiocp = uiop->uio_iov->iov_base;
18838420Smckusick 		if (left > siz)
18938420Smckusick 			left = siz;
19038420Smckusick 		uiosiz = left;
19138420Smckusick 		while (left > 0) {
19238420Smckusick 			while (len == 0) {
19338420Smckusick 				mp = mp->m_next;
19438420Smckusick 				if (mp == NULL)
19538420Smckusick 					return (EBADRPC);
19638420Smckusick 				mbufcp = mtod(mp, caddr_t);
19738420Smckusick 				len = mp->m_len;
19838420Smckusick 			}
19938420Smckusick 			xfer = (left > len) ? len : left;
20038420Smckusick #ifdef notdef
20138420Smckusick 			/* Not Yet.. */
20238420Smckusick 			if (uiop->uio_iov->iov_op != NULL)
20338420Smckusick 				(*(uiop->uio_iov->iov_op))
20438420Smckusick 				(mbufcp, uiocp, xfer);
20538420Smckusick 			else
20638420Smckusick #endif
20738420Smckusick 			if (uiop->uio_segflg == UIO_SYSSPACE)
20838420Smckusick 				bcopy(mbufcp, uiocp, xfer);
20938420Smckusick 			else
21038420Smckusick 				copyout(mbufcp, uiocp, xfer);
21138420Smckusick 			left -= xfer;
21238420Smckusick 			len -= xfer;
21338420Smckusick 			mbufcp += xfer;
21438420Smckusick 			uiocp += xfer;
21539585Smckusick 			uiop->uio_offset += xfer;
21638420Smckusick 			uiop->uio_resid -= xfer;
21738420Smckusick 		}
21838420Smckusick 		if (uiop->uio_iov->iov_len <= siz) {
21938420Smckusick 			uiop->uio_iovcnt--;
22038420Smckusick 			uiop->uio_iov++;
22138420Smckusick 		} else {
22238420Smckusick 			uiop->uio_iov->iov_base += uiosiz;
22338420Smckusick 			uiop->uio_iov->iov_len -= uiosiz;
22438420Smckusick 		}
22538420Smckusick 		siz -= uiosiz;
22638420Smckusick 	}
22738420Smckusick 	*dpos = mbufcp;
22838420Smckusick 	*mrep = mp;
22941902Smckusick 	if (rem > 0) {
23041902Smckusick 		if (len < rem)
23141902Smckusick 			error = nfs_adv(mrep, dpos, rem, len);
23241902Smckusick 		else
23341902Smckusick 			*dpos += rem;
23441902Smckusick 	}
23541902Smckusick 	return (error);
23638420Smckusick }
23738420Smckusick 
23838420Smckusick /*
23938420Smckusick  * copies a uio scatter/gather list to an mbuf chain...
24038420Smckusick  */
24138420Smckusick nfsm_uiotombuf(uiop, mq, siz, bpos)
24238420Smckusick 	register struct uio *uiop;
24338420Smckusick 	struct mbuf **mq;
24438420Smckusick 	int siz;
24538420Smckusick 	caddr_t *bpos;
24638420Smckusick {
24738420Smckusick 	register struct mbuf *mp;
24838420Smckusick 	struct mbuf *mp2;
24939494Smckusick 	long xfer, left, uiosiz;
25038420Smckusick 	int clflg;
25138420Smckusick 	int rem, len;
25238420Smckusick 	char *cp, *uiocp;
25338420Smckusick 
25438420Smckusick 	if (siz > MLEN)		/* or should it >= MCLBYTES ?? */
25538420Smckusick 		clflg = 1;
25638420Smckusick 	else
25738420Smckusick 		clflg = 0;
25838420Smckusick 	rem = nfsm_rndup(siz)-siz;
25938420Smckusick 	mp2 = *mq;
26038420Smckusick 	while (siz > 0) {
26138420Smckusick 		if (uiop->uio_iovcnt <= 0 || uiop->uio_iov == NULL)
26241902Smckusick 			return (EINVAL);
26338420Smckusick 		left = uiop->uio_iov->iov_len;
26438420Smckusick 		uiocp = uiop->uio_iov->iov_base;
26538420Smckusick 		if (left > siz)
26638420Smckusick 			left = siz;
26738420Smckusick 		uiosiz = left;
26838420Smckusick 		while (left > 0) {
26938420Smckusick 			MGET(mp, M_WAIT, MT_DATA);
27038420Smckusick 			if (clflg)
27141902Smckusick 				MCLGET(mp, M_WAIT);
27238420Smckusick 			mp->m_len = NFSMSIZ(mp);
27338420Smckusick 			mp2->m_next = mp;
27438420Smckusick 			mp2 = mp;
27538420Smckusick 			xfer = (left > mp->m_len) ? mp->m_len : left;
27638420Smckusick #ifdef notdef
27738420Smckusick 			/* Not Yet.. */
27838420Smckusick 			if (uiop->uio_iov->iov_op != NULL)
27938420Smckusick 				(*(uiop->uio_iov->iov_op))
28038420Smckusick 				(uiocp, mtod(mp, caddr_t), xfer);
28138420Smckusick 			else
28238420Smckusick #endif
28338420Smckusick 			if (uiop->uio_segflg == UIO_SYSSPACE)
28438420Smckusick 				bcopy(uiocp, mtod(mp, caddr_t), xfer);
28538420Smckusick 			else
28638420Smckusick 				copyin(uiocp, mtod(mp, caddr_t), xfer);
28738420Smckusick 			len = mp->m_len;
28838420Smckusick 			mp->m_len = xfer;
28938420Smckusick 			left -= xfer;
29038420Smckusick 			uiocp += xfer;
29139585Smckusick 			uiop->uio_offset += xfer;
29238420Smckusick 			uiop->uio_resid -= xfer;
29338420Smckusick 		}
29438420Smckusick 		if (uiop->uio_iov->iov_len <= siz) {
29538420Smckusick 			uiop->uio_iovcnt--;
29638420Smckusick 			uiop->uio_iov++;
29738420Smckusick 		} else {
29838420Smckusick 			uiop->uio_iov->iov_base += uiosiz;
29938420Smckusick 			uiop->uio_iov->iov_len -= uiosiz;
30038420Smckusick 		}
30138420Smckusick 		siz -= uiosiz;
30238420Smckusick 	}
30338420Smckusick 	if (rem > 0) {
30438420Smckusick 		if (rem > (len-mp->m_len)) {
30538420Smckusick 			MGET(mp, M_WAIT, MT_DATA);
30638420Smckusick 			mp->m_len = 0;
30738420Smckusick 			mp2->m_next = mp;
30838420Smckusick 		}
30938420Smckusick 		cp = mtod(mp, caddr_t)+mp->m_len;
31038420Smckusick 		for (left = 0; left < rem; left++)
31138420Smckusick 			*cp++ = '\0';
31238420Smckusick 		mp->m_len += rem;
31338420Smckusick 		*bpos = cp;
31438420Smckusick 	} else
31538420Smckusick 		*bpos = mtod(mp, caddr_t)+mp->m_len;
31638420Smckusick 	*mq = mp;
31741902Smckusick 	return (0);
31838420Smckusick }
31938420Smckusick 
32038420Smckusick /*
32138420Smckusick  * Help break down an mbuf chain by setting the first siz bytes contiguous
32238420Smckusick  * pointed to by returned val.
32338420Smckusick  * If Updateflg == True we can overwrite the first part of the mbuf data
32438420Smckusick  * This is used by the macros nfsm_disect and nfsm_disecton for tough
32538420Smckusick  * cases. (The macros use the vars. dpos and dpos2)
32638420Smckusick  */
32738420Smckusick nfsm_disct(mdp, dposp, siz, left, updateflg, cp2)
32838420Smckusick 	struct mbuf **mdp;
32938420Smckusick 	caddr_t *dposp;
33038420Smckusick 	int siz;
33138420Smckusick 	int left;
33238420Smckusick 	int updateflg;
33338420Smckusick 	caddr_t *cp2;
33438420Smckusick {
33538420Smckusick 	register struct mbuf *mp, *mp2;
33638420Smckusick 	register int siz2, xfer;
33738420Smckusick 	register caddr_t p;
33838420Smckusick 
33938420Smckusick 	mp = *mdp;
34038420Smckusick 	while (left == 0) {
34138420Smckusick 		*mdp = mp = mp->m_next;
34238420Smckusick 		if (mp == NULL)
34341902Smckusick 			return (EBADRPC);
34438420Smckusick 		left = mp->m_len;
34538420Smckusick 		*dposp = mtod(mp, caddr_t);
34638420Smckusick 	}
34738420Smckusick 	if (left >= siz) {
34838420Smckusick 		*cp2 = *dposp;
34938420Smckusick 		*dposp += siz;
35038420Smckusick 	} else if (mp->m_next == NULL) {
35141902Smckusick 		return (EBADRPC);
35241902Smckusick 	} else if (siz > MHLEN) {
35338420Smckusick 		panic("nfs S too big");
35438420Smckusick 	} else {
35538420Smckusick 		/* Iff update, you can overwrite, else must alloc new mbuf */
35638420Smckusick 		if (updateflg) {
35738420Smckusick 			NFSMINOFF(mp);
35838420Smckusick 		} else {
35938420Smckusick 			MGET(mp2, M_WAIT, MT_DATA);
36038420Smckusick 			mp2->m_next = mp->m_next;
36138420Smckusick 			mp->m_next = mp2;
36238420Smckusick 			mp->m_len -= left;
36338420Smckusick 			mp = mp2;
36438420Smckusick 		}
36538420Smckusick 		*cp2 = p = mtod(mp, caddr_t);
36638420Smckusick 		bcopy(*dposp, p, left);		/* Copy what was left */
36738420Smckusick 		siz2 = siz-left;
36838420Smckusick 		p += left;
36938420Smckusick 		mp2 = mp->m_next;
37041902Smckusick 		/* Loop around copying up the siz2 bytes */
37138420Smckusick 		while (siz2 > 0) {
37238420Smckusick 			if (mp2 == NULL)
37338420Smckusick 				return (EBADRPC);
37438420Smckusick 			xfer = (siz2 > mp2->m_len) ? mp2->m_len : siz2;
37541902Smckusick 			if (xfer > 0) {
37641902Smckusick 				bcopy(mtod(mp2, caddr_t), p, xfer);
37741902Smckusick 				NFSMADV(mp2, xfer);
37841902Smckusick 				mp2->m_len -= xfer;
37941902Smckusick 				p += xfer;
38041902Smckusick 				siz2 -= xfer;
38141902Smckusick 			}
38238420Smckusick 			if (siz2 > 0)
38338420Smckusick 				mp2 = mp2->m_next;
38438420Smckusick 		}
38538420Smckusick 		mp->m_len = siz;
38638420Smckusick 		*mdp = mp2;
38738420Smckusick 		*dposp = mtod(mp2, caddr_t);
38838420Smckusick 	}
38939494Smckusick 	return (0);
39038420Smckusick }
39138420Smckusick 
39238420Smckusick /*
39341902Smckusick  * Advance the position in the mbuf chain.
39438420Smckusick  */
39538420Smckusick nfs_adv(mdp, dposp, offs, left)
39638420Smckusick 	struct mbuf **mdp;
39738420Smckusick 	caddr_t *dposp;
39838420Smckusick 	int offs;
39938420Smckusick 	int left;
40038420Smckusick {
40138420Smckusick 	register struct mbuf *m;
40238420Smckusick 	register int s;
40338420Smckusick 
40438420Smckusick 	m = *mdp;
40538420Smckusick 	s = left;
40638420Smckusick 	while (s < offs) {
40738420Smckusick 		offs -= s;
40838420Smckusick 		m = m->m_next;
40938420Smckusick 		if (m == NULL)
41041902Smckusick 			return (EBADRPC);
41138420Smckusick 		s = m->m_len;
41238420Smckusick 	}
41338420Smckusick 	*mdp = m;
41438420Smckusick 	*dposp = mtod(m, caddr_t)+offs;
41541902Smckusick 	return (0);
41638420Smckusick }
41738420Smckusick 
41838420Smckusick /*
41938420Smckusick  * Copy a string into mbufs for the hard cases...
42038420Smckusick  */
42138420Smckusick nfsm_strtmbuf(mb, bpos, cp, siz)
42238420Smckusick 	struct mbuf **mb;
42338420Smckusick 	char **bpos;
42438420Smckusick 	char *cp;
42538420Smckusick 	long siz;
42638420Smckusick {
42738420Smckusick 	register struct mbuf *m1, *m2;
42838420Smckusick 	long left, xfer, len, tlen;
42938420Smckusick 	u_long *p;
43038420Smckusick 	int putsize;
43138420Smckusick 
43238420Smckusick 	putsize = 1;
43338420Smckusick 	m2 = *mb;
43438420Smckusick 	left = NFSMSIZ(m2)-m2->m_len;
43538420Smckusick 	if (left > 0) {
43638420Smckusick 		p = ((u_long *)(*bpos));
43738420Smckusick 		*p++ = txdr_unsigned(siz);
43838420Smckusick 		putsize = 0;
43938420Smckusick 		left -= NFSX_UNSIGNED;
44038420Smckusick 		m2->m_len += NFSX_UNSIGNED;
44138420Smckusick 		if (left > 0) {
44238420Smckusick 			bcopy(cp, (caddr_t) p, left);
44338420Smckusick 			siz -= left;
44438420Smckusick 			cp += left;
44538420Smckusick 			m2->m_len += left;
44638420Smckusick 			left = 0;
44738420Smckusick 		}
44838420Smckusick 	}
44938420Smckusick 	/* Loop arround adding mbufs */
45038420Smckusick 	while (siz > 0) {
45138420Smckusick 		MGET(m1, M_WAIT, MT_DATA);
45238420Smckusick 		if (siz > MLEN)
45341902Smckusick 			MCLGET(m1, M_WAIT);
45438420Smckusick 		m1->m_len = NFSMSIZ(m1);
45538420Smckusick 		m2->m_next = m1;
45638420Smckusick 		m2 = m1;
45738420Smckusick 		p = mtod(m1, u_long *);
45838420Smckusick 		tlen = 0;
45938420Smckusick 		if (putsize) {
46038420Smckusick 			*p++ = txdr_unsigned(siz);
46138420Smckusick 			m1->m_len -= NFSX_UNSIGNED;
46238420Smckusick 			tlen = NFSX_UNSIGNED;
46338420Smckusick 			putsize = 0;
46438420Smckusick 		}
46538420Smckusick 		if (siz < m1->m_len) {
46638420Smckusick 			len = nfsm_rndup(siz);
46738420Smckusick 			xfer = siz;
46838420Smckusick 			if (xfer < len)
46938420Smckusick 				*(p+(xfer>>2)) = 0;
47038420Smckusick 		} else {
47138420Smckusick 			xfer = len = m1->m_len;
47238420Smckusick 		}
47338420Smckusick 		bcopy(cp, (caddr_t) p, xfer);
47438420Smckusick 		m1->m_len = len+tlen;
47538420Smckusick 		siz -= xfer;
47638420Smckusick 		cp += xfer;
47738420Smckusick 	}
47838420Smckusick 	*mb = m1;
47938420Smckusick 	*bpos = mtod(m1, caddr_t)+m1->m_len;
48041902Smckusick 	return (0);
48138420Smckusick }
48238420Smckusick 
48338420Smckusick /*
48438420Smckusick  * Called once to initialize data structures...
48538420Smckusick  */
48639444Smckusick nfs_init()
48738420Smckusick {
48838420Smckusick 	register int i;
48938420Smckusick 
49038420Smckusick 	rpc_vers = txdr_unsigned(RPC_VER2);
49138420Smckusick 	rpc_call = txdr_unsigned(RPC_CALL);
49238420Smckusick 	rpc_reply = txdr_unsigned(RPC_REPLY);
49338420Smckusick 	rpc_msgdenied = txdr_unsigned(RPC_MSGDENIED);
49438420Smckusick 	rpc_msgaccepted = txdr_unsigned(RPC_MSGACCEPTED);
49538420Smckusick 	rpc_mismatch = txdr_unsigned(RPC_MISMATCH);
49638420Smckusick 	rpc_auth_unix = txdr_unsigned(RPCAUTH_UNIX);
49738420Smckusick 	nfs_vers = txdr_unsigned(NFS_VER2);
49838420Smckusick 	nfs_prog = txdr_unsigned(NFS_PROG);
49938420Smckusick 	nfs_true = txdr_unsigned(TRUE);
50038420Smckusick 	nfs_false = txdr_unsigned(FALSE);
50138420Smckusick 	/* Loop thru nfs procids */
50238420Smckusick 	for (i = 0; i < NFS_NPROCS; i++)
50338420Smckusick 		nfs_procids[i] = txdr_unsigned(i);
50439345Smckusick 	/* Ensure async daemons disabled */
50541902Smckusick 	for (i = 0; i < NFS_MAXASYNCDAEMON; i++)
50639345Smckusick 		nfs_iodwant[i] = (struct proc *)0;
50738420Smckusick 	nfs_xdrneg1 = txdr_unsigned(-1);
50838420Smckusick 	nfs_nhinit();			/* Init the nfsnode table */
50939755Smckusick 	nfsrv_initcache();		/* Init the server request cache */
51038884Smacklem 	rminit(nfsmap, (long)NFS_MAPREG, (long)1, "nfs mapreg", NFS_MSIZ);
51141902Smckusick 
51241902Smckusick 	/*
51341902Smckusick 	 * Initialize reply list and start timer
51441902Smckusick 	 */
51541902Smckusick 	nfsreqh.r_prev = nfsreqh.r_next = &nfsreqh;
51638420Smckusick 	nfs_timer();
51738420Smckusick }
51838420Smckusick 
51938420Smckusick /*
52038420Smckusick  * Fill in the rest of the rpc_unixauth and return it
52138420Smckusick  */
52238420Smckusick static char *nfs_unixauth(cr)
52338420Smckusick 	register struct ucred *cr;
52438420Smckusick {
52538420Smckusick 	register u_long *p;
52638420Smckusick 	register int i;
52738420Smckusick 	int ngr;
52838420Smckusick 
52938420Smckusick 	/* Maybe someday there should be a cache of AUTH_SHORT's */
53038420Smckusick 	if ((p = rpc_uidp) == NULL) {
53138425Smckusick #ifdef FILLINHOST
53238420Smckusick 		i = nfsm_rndup(hostnamelen)+(19*NFSX_UNSIGNED);
53338425Smckusick #else
53438425Smckusick 		i = 19*NFSX_UNSIGNED;
53538425Smckusick #endif
53638420Smckusick 		MALLOC(p, u_long *, i, M_TEMP, M_WAITOK);
53738420Smckusick 		bzero((caddr_t)p, i);
53838420Smckusick 		rpc_unixauth = (caddr_t)p;
53938420Smckusick 		*p++ = txdr_unsigned(RPCAUTH_UNIX);
54038420Smckusick 		p++;	/* Fill in size later */
54138420Smckusick 		*p++ = hostid;
54238425Smckusick #ifdef FILLINHOST
54338420Smckusick 		*p++ = txdr_unsigned(hostnamelen);
54438420Smckusick 		i = nfsm_rndup(hostnamelen);
54538420Smckusick 		bcopy(hostname, (caddr_t)p, hostnamelen);
54638420Smckusick 		p += (i>>2);
54738425Smckusick #else
54838425Smckusick 		*p++ = 0;
54938425Smckusick #endif
55038420Smckusick 		rpc_uidp = p;
55138420Smckusick 	}
55238420Smckusick 	*p++ = txdr_unsigned(cr->cr_uid);
55338420Smckusick 	*p++ = txdr_unsigned(cr->cr_groups[0]);
55438737Smckusick 	ngr = (cr->cr_ngroups > numgrps) ? numgrps : cr->cr_ngroups;
55538420Smckusick 	*p++ = txdr_unsigned(ngr);
55638420Smckusick 	for (i = 0; i < ngr; i++)
55738420Smckusick 		*p++ = txdr_unsigned(cr->cr_groups[i]);
55838420Smckusick 	/* And add the AUTH_NULL */
55938420Smckusick 	*p++ = 0;
56038420Smckusick 	*p = 0;
56138420Smckusick 	i = (((caddr_t)p)-rpc_unixauth)-12;
56238420Smckusick 	p = (u_long *)(rpc_unixauth+4);
56338420Smckusick 	*p = txdr_unsigned(i);
56441902Smckusick 	return (rpc_unixauth);
56538420Smckusick }
56638420Smckusick 
56738420Smckusick /*
56838420Smckusick  * Attribute cache routines.
56938420Smckusick  * nfs_loadattrcache() - loads or updates the cache contents from attributes
57038420Smckusick  *	that are on the mbuf list
57138420Smckusick  * nfs_getattrcache() - returns valid attributes if found in cache, returns
57238420Smckusick  *	error otherwise
57338420Smckusick  */
57438420Smckusick 
57538420Smckusick /*
57639444Smckusick  * Load the attribute cache (that lives in the nfsnode entry) with
57738420Smckusick  * the values on the mbuf list and
57838420Smckusick  * Iff vap not NULL
57938420Smckusick  *    copy the attributes to *vaper
58038420Smckusick  */
58139457Smckusick nfs_loadattrcache(vpp, mdp, dposp, vaper)
58239457Smckusick 	struct vnode **vpp;
58338420Smckusick 	struct mbuf **mdp;
58438420Smckusick 	caddr_t *dposp;
58538420Smckusick 	struct vattr *vaper;
58638420Smckusick {
58739457Smckusick 	register struct vnode *vp = *vpp;
58838420Smckusick 	register struct vattr *vap;
58938884Smacklem 	register struct nfsv2_fattr *fp;
59039444Smckusick 	extern struct vnodeops spec_nfsv2nodeops;
59139457Smckusick 	register struct nfsnode *np;
59239494Smckusick 	register long t1;
59339494Smckusick 	caddr_t dpos, cp2;
59439494Smckusick 	int error = 0;
59539494Smckusick 	struct mbuf *md;
59639444Smckusick 	enum vtype type;
59742244Smckusick 	long rdev;
59839444Smckusick 	struct timeval mtime;
59939444Smckusick 	struct vnode *nvp;
60038420Smckusick 
60138420Smckusick 	md = *mdp;
60238420Smckusick 	dpos = *dposp;
60338420Smckusick 	t1 = (mtod(md, caddr_t)+md->m_len)-dpos;
60438420Smckusick 	if (error = nfsm_disct(&md, &dpos, NFSX_FATTR, t1, TRUE, &cp2))
60538420Smckusick 		return (error);
60638884Smacklem 	fp = (struct nfsv2_fattr *)cp2;
60739444Smckusick 	type = nfstov_type(fp->fa_type);
60842244Smckusick 	rdev = fxdr_unsigned(long, fp->fa_rdev);
60939444Smckusick 	fxdr_time(&fp->fa_mtime, &mtime);
61039444Smckusick 	/*
61139444Smckusick 	 * If v_type == VNON it is a new node, so fill in the v_type,
61239444Smckusick 	 * n_mtime fields. Check to see if it represents a special
61339444Smckusick 	 * device, and if so, check for a possible alias. Once the
61439444Smckusick 	 * correct vnode has been obtained, fill in the rest of the
61539444Smckusick 	 * information.
61639444Smckusick 	 */
61738420Smckusick 	np = VTONFS(vp);
61839444Smckusick 	if (vp->v_type == VNON) {
61942244Smckusick 		if (type == VCHR && rdev == 0xffffffff)
62042244Smckusick 			vp->v_type = type = VFIFO;
62142244Smckusick 		else
62242244Smckusick 			vp->v_type = type;
62340295Smckusick 		if (vp->v_type == VFIFO) {
62440295Smckusick #ifdef FIFO
62540295Smckusick 			extern struct vnodeops fifo_nfsv2nodeops;
62640295Smckusick 			vp->v_op = &fifo_nfsv2nodeops;
62740295Smckusick #else
62840295Smckusick 			return (EOPNOTSUPP);
62940295Smckusick #endif /* FIFO */
63040295Smckusick 		}
63139444Smckusick 		if (vp->v_type == VCHR || vp->v_type == VBLK) {
63239444Smckusick 			vp->v_op = &spec_nfsv2nodeops;
63342244Smckusick 			if (nvp = checkalias(vp, (dev_t)rdev, vp->v_mount)) {
63439444Smckusick 				/*
63539444Smckusick 				 * Reinitialize aliased node.
63639444Smckusick 				 */
63739444Smckusick 				np = VTONFS(nvp);
63839444Smckusick 				np->n_vnode = nvp;
63939907Smckusick 				np->n_flag = 0;
64039907Smckusick 				nfs_lock(nvp);
64139444Smckusick 				bcopy((caddr_t)&VTONFS(vp)->n_fh,
64239444Smckusick 					(caddr_t)&np->n_fh, NFSX_FH);
64339444Smckusick 				insque(np, nfs_hash(&np->n_fh));
64439444Smckusick 				np->n_attrstamp = 0;
64539444Smckusick 				np->n_sillyrename = (struct sillyrename *)0;
64639444Smckusick 				/*
64739457Smckusick 				 * Discard unneeded vnode and update actual one
64839444Smckusick 				 */
64939444Smckusick 				vput(vp);
65041902Smckusick 				*vpp = nvp;
65139444Smckusick 			}
65239444Smckusick 		}
65339444Smckusick 		np->n_mtime = mtime.tv_sec;
65439444Smckusick 	}
65538420Smckusick 	vap = &np->n_vattr;
65639444Smckusick 	vap->va_type = type;
65738884Smacklem 	vap->va_mode = nfstov_mode(fp->fa_mode);
65838884Smacklem 	vap->va_nlink = fxdr_unsigned(u_short, fp->fa_nlink);
65938884Smacklem 	vap->va_uid = fxdr_unsigned(uid_t, fp->fa_uid);
66038884Smacklem 	vap->va_gid = fxdr_unsigned(gid_t, fp->fa_gid);
66138884Smacklem 	vap->va_size = fxdr_unsigned(u_long, fp->fa_size);
66238884Smacklem 	if ((np->n_flag & NMODIFIED) == 0 || vap->va_size > np->n_size)
66338884Smacklem 		np->n_size = vap->va_size;
66440642Smckusick 	vap->va_size_rsv = 0;
66538884Smacklem 	vap->va_blocksize = fxdr_unsigned(long, fp->fa_blocksize);
66642244Smckusick 	vap->va_rdev = (dev_t)rdev;
66742244Smckusick 	vap->va_bytes = fxdr_unsigned(long, fp->fa_blocks) * NFS_FABLKSIZE;
66840642Smckusick 	vap->va_bytes_rsv = 0;
669*42878Smckusick 	vap->va_fsid = vp->v_mount->mnt_stat.f_fsid.val[0];
67038884Smacklem 	vap->va_fileid = fxdr_unsigned(long, fp->fa_fileid);
67139755Smckusick 	vap->va_atime.tv_sec = fxdr_unsigned(long, fp->fa_atime.tv_sec);
67239755Smckusick 	vap->va_atime.tv_usec = 0;
67339755Smckusick 	vap->va_flags = fxdr_unsigned(u_long, fp->fa_atime.tv_usec);
67439444Smckusick 	vap->va_mtime = mtime;
67539755Smckusick 	vap->va_ctime.tv_sec = fxdr_unsigned(long, fp->fa_ctime.tv_sec);
67639755Smckusick 	vap->va_ctime.tv_usec = 0;
67739755Smckusick 	vap->va_gen = fxdr_unsigned(u_long, fp->fa_ctime.tv_usec);
67838420Smckusick 	np->n_attrstamp = time.tv_sec;
67938420Smckusick 	*dposp = dpos;
68038420Smckusick 	*mdp = md;
68138884Smacklem 	if (vaper != NULL) {
68238420Smckusick 		bcopy((caddr_t)vap, (caddr_t)vaper, sizeof(*vap));
68338884Smacklem 		if ((np->n_flag & NMODIFIED) && (np->n_size > vap->va_size))
68438884Smacklem 			vaper->va_size = np->n_size;
68538884Smacklem 	}
68638420Smckusick 	return (0);
68738420Smckusick }
68838420Smckusick 
68938420Smckusick /*
69038420Smckusick  * Check the time stamp
69138420Smckusick  * If the cache is valid, copy contents to *vap and return 0
69238420Smckusick  * otherwise return an error
69338420Smckusick  */
69438420Smckusick nfs_getattrcache(vp, vap)
69538420Smckusick 	register struct vnode *vp;
69638420Smckusick 	struct vattr *vap;
69738420Smckusick {
69838420Smckusick 	register struct nfsnode *np;
69938420Smckusick 
70038420Smckusick 	np = VTONFS(vp);
70138420Smckusick 	if ((time.tv_sec-np->n_attrstamp) < NFS_ATTRTIMEO) {
70238420Smckusick 		nfsstats.attrcache_hits++;
70338420Smckusick 		bcopy((caddr_t)&np->n_vattr,(caddr_t)vap,sizeof(struct vattr));
70439361Smckusick 		if ((np->n_flag & NMODIFIED) == 0)
70539361Smckusick 			np->n_size = vap->va_size;
70639361Smckusick 		else if (np->n_size > vap->va_size)
70738884Smacklem 			vap->va_size = np->n_size;
70838420Smckusick 		return (0);
70938420Smckusick 	} else {
71038420Smckusick 		nfsstats.attrcache_misses++;
71138420Smckusick 		return (ENOENT);
71238420Smckusick 	}
71338420Smckusick }
71438420Smckusick 
71538420Smckusick /*
71641902Smckusick  * Set up nameidata for a namei() call and do it
71738420Smckusick  */
71838420Smckusick nfs_namei(ndp, fhp, len, mdp, dposp)
71938420Smckusick 	register struct nameidata *ndp;
72038420Smckusick 	fhandle_t *fhp;
72138420Smckusick 	int len;
72238420Smckusick 	struct mbuf **mdp;
72338420Smckusick 	caddr_t *dposp;
72438420Smckusick {
72538420Smckusick 	register int i, rem;
72638420Smckusick 	register struct mbuf *md;
72738420Smckusick 	register char *cp;
72841902Smckusick 	struct vnode *dp;
72938420Smckusick 	int flag;
73041902Smckusick 	int error;
73138420Smckusick 
73242244Smckusick 	if ((ndp->ni_nameiop & HASBUF) == 0) {
73342244Smckusick 		flag = ndp->ni_nameiop & OPFLAG;
73442244Smckusick 		/*
73542244Smckusick 		 * Copy the name from the mbuf list to the d_name field of ndp
73642244Smckusick 		 * and set the various ndp fields appropriately.
73742244Smckusick 		 */
73842244Smckusick 		cp = *dposp;
73942244Smckusick 		md = *mdp;
74042244Smckusick 		rem = mtod(md, caddr_t)+md->m_len-cp;
74142244Smckusick 		ndp->ni_hash = 0;
74242244Smckusick 		for (i = 0; i < len;) {
74342244Smckusick 			while (rem == 0) {
74442244Smckusick 				md = md->m_next;
74542244Smckusick 				if (md == NULL)
74642244Smckusick 					return (EBADRPC);
74742244Smckusick 				cp = mtod(md, caddr_t);
74842244Smckusick 				rem = md->m_len;
74942244Smckusick 			}
75042244Smckusick 			if (*cp == '\0' || *cp == '/')
75142244Smckusick 				return (EINVAL);
75242244Smckusick 			if (*cp & 0200)
75342244Smckusick 				if ((*cp&0377) == ('/'|0200) || flag != DELETE)
75442244Smckusick 					return (EINVAL);
75542244Smckusick 			ndp->ni_dent.d_name[i++] = *cp;
75642244Smckusick 			ndp->ni_hash += (unsigned char)*cp * i;
75742244Smckusick 			cp++;
75842244Smckusick 			rem--;
75938420Smckusick 		}
76042244Smckusick 		*mdp = md;
76142244Smckusick 		*dposp = cp;
76242244Smckusick 		len = nfsm_rndup(len)-len;
76342244Smckusick 		if (len > 0) {
76442244Smckusick 			if (rem < len) {
76542244Smckusick 				if (error = nfs_adv(mdp, dposp, len, rem))
76642244Smckusick 					return (error);
76742244Smckusick 			} else
76842244Smckusick 				*dposp += len;
76942244Smckusick 		}
77042244Smckusick 	} else
77142244Smckusick 		i = len;
77238420Smckusick 	ndp->ni_namelen = i;
77338420Smckusick 	ndp->ni_dent.d_namlen = i;
77438420Smckusick 	ndp->ni_dent.d_name[i] = '\0';
77542244Smckusick 	ndp->ni_segflg = UIO_SYSSPACE;
77638425Smckusick 	ndp->ni_pathlen = 1;
77741902Smckusick 	ndp->ni_pnbuf = ndp->ni_dirp = ndp->ni_ptr = &ndp->ni_dent.d_name[0];
77838420Smckusick 	ndp->ni_next = &ndp->ni_dent.d_name[i];
77941902Smckusick 	ndp->ni_nameiop |= (NOCROSSMOUNT | REMOTE | HASBUF);
78038420Smckusick 
78141902Smckusick 	if (error = nfsrv_fhtovp(fhp, FALSE, &dp, ndp->ni_cred))
78238420Smckusick 		return (error);
78338425Smckusick 	if (dp->v_type != VDIR) {
78441902Smckusick 		vrele(dp);
78538425Smckusick 		return (ENOTDIR);
78638425Smckusick 	}
78739345Smckusick 	/*
78839345Smckusick 	 * Must set current directory here to avoid confusion in namei()
78939345Smckusick 	 * called from rename()
79039345Smckusick 	 */
79138425Smckusick 	ndp->ni_cdir = dp;
79241398Smckusick 	ndp->ni_rdir = NULLVP;
79338420Smckusick 
79438420Smckusick 	/*
79541902Smckusick 	 * And call namei() to do the real work
79638420Smckusick 	 */
79741902Smckusick 	error = namei(ndp);
79841902Smckusick 	vrele(dp);
79938420Smckusick 	return (error);
80038420Smckusick }
80138420Smckusick 
80238420Smckusick /*
80338420Smckusick  * A fiddled version of m_adj() that ensures null fill to a long
80438420Smckusick  * boundary and only trims off the back end
80538420Smckusick  */
80638420Smckusick nfsm_adj(mp, len, nul)
80738420Smckusick 	struct mbuf *mp;
80838420Smckusick 	register int len;
80938420Smckusick 	int nul;
81038420Smckusick {
81138420Smckusick 	register struct mbuf *m;
81238420Smckusick 	register int count, i;
81338420Smckusick 	register char *cp;
81438420Smckusick 
81538420Smckusick 	/*
81638420Smckusick 	 * Trim from tail.  Scan the mbuf chain,
81738420Smckusick 	 * calculating its length and finding the last mbuf.
81838420Smckusick 	 * If the adjustment only affects this mbuf, then just
81938420Smckusick 	 * adjust and return.  Otherwise, rescan and truncate
82038420Smckusick 	 * after the remaining size.
82138420Smckusick 	 */
82238420Smckusick 	count = 0;
82338420Smckusick 	m = mp;
82438420Smckusick 	for (;;) {
82538420Smckusick 		count += m->m_len;
82638420Smckusick 		if (m->m_next == (struct mbuf *)0)
82738420Smckusick 			break;
82838420Smckusick 		m = m->m_next;
82938420Smckusick 	}
83038579Smckusick 	if (m->m_len > len) {
83138420Smckusick 		m->m_len -= len;
83238420Smckusick 		if (nul > 0) {
83338420Smckusick 			cp = mtod(m, caddr_t)+m->m_len-nul;
83438420Smckusick 			for (i = 0; i < nul; i++)
83538420Smckusick 				*cp++ = '\0';
83638420Smckusick 		}
83738420Smckusick 		return;
83838420Smckusick 	}
83938420Smckusick 	count -= len;
84038420Smckusick 	if (count < 0)
84138420Smckusick 		count = 0;
84238420Smckusick 	/*
84338420Smckusick 	 * Correct length for chain is "count".
84438420Smckusick 	 * Find the mbuf with last data, adjust its length,
84538420Smckusick 	 * and toss data from remaining mbufs on chain.
84638420Smckusick 	 */
84738420Smckusick 	for (m = mp; m; m = m->m_next) {
84838420Smckusick 		if (m->m_len >= count) {
84938420Smckusick 			m->m_len = count;
85038420Smckusick 			if (nul > 0) {
85138420Smckusick 				cp = mtod(m, caddr_t)+m->m_len-nul;
85238420Smckusick 				for (i = 0; i < nul; i++)
85338420Smckusick 					*cp++ = '\0';
85438420Smckusick 			}
85538420Smckusick 			break;
85638420Smckusick 		}
85738420Smckusick 		count -= m->m_len;
85838420Smckusick 	}
85938420Smckusick 	while (m = m->m_next)
86038420Smckusick 		m->m_len = 0;
86138420Smckusick }
86238420Smckusick 
86338420Smckusick /*
86438420Smckusick  * nfsrv_fhtovp() - convert a fh to a vnode ptr (optionally locked)
86538420Smckusick  * 	- look up fsid in mount list (if not found ret error)
86638420Smckusick  *	- check that it is exported
86738420Smckusick  *	- get vp by calling VFS_FHTOVP() macro
86838420Smckusick  *	- if not lockflag unlock it with VOP_UNLOCK()
86941902Smckusick  *	- if cred->cr_uid == 0 set it to m_exroot
87038420Smckusick  */
87138420Smckusick nfsrv_fhtovp(fhp, lockflag, vpp, cred)
87238420Smckusick 	fhandle_t *fhp;
87338420Smckusick 	int lockflag;
87438420Smckusick 	struct vnode **vpp;
87538420Smckusick 	struct ucred *cred;
87638420Smckusick {
87738420Smckusick 	register struct mount *mp;
87838420Smckusick 
87938420Smckusick 	if ((mp = getvfs(&fhp->fh_fsid)) == NULL)
88038420Smckusick 		return (ESTALE);
88141398Smckusick 	if ((mp->mnt_flag & MNT_EXPORTED) == 0)
88238420Smckusick 		return (EACCES);
88338420Smckusick 	if (VFS_FHTOVP(mp, &fhp->fh_fid, vpp))
88438420Smckusick 		return (ESTALE);
88538420Smckusick 	if (cred->cr_uid == 0)
88641398Smckusick 		cred->cr_uid = mp->mnt_exroot;
88738420Smckusick 	if (!lockflag)
88838420Smckusick 		VOP_UNLOCK(*vpp);
88938420Smckusick 	return (0);
89038420Smckusick }
891