Home | History | Annotate | Line # | Download | only in nfs
nfs_subs.c revision 1.10
      1   1.1      cgd /*
      2   1.1      cgd  * Copyright (c) 1989 The Regents of the University of California.
      3   1.1      cgd  * All rights reserved.
      4   1.1      cgd  *
      5   1.1      cgd  * This code is derived from software contributed to Berkeley by
      6   1.1      cgd  * Rick Macklem at The University of Guelph.
      7   1.1      cgd  *
      8   1.1      cgd  * Redistribution and use in source and binary forms, with or without
      9   1.1      cgd  * modification, are permitted provided that the following conditions
     10   1.1      cgd  * are met:
     11   1.1      cgd  * 1. Redistributions of source code must retain the above copyright
     12   1.1      cgd  *    notice, this list of conditions and the following disclaimer.
     13   1.1      cgd  * 2. Redistributions in binary form must reproduce the above copyright
     14   1.1      cgd  *    notice, this list of conditions and the following disclaimer in the
     15   1.1      cgd  *    documentation and/or other materials provided with the distribution.
     16   1.1      cgd  * 3. All advertising materials mentioning features or use of this software
     17   1.1      cgd  *    must display the following acknowledgement:
     18   1.1      cgd  *	This product includes software developed by the University of
     19   1.1      cgd  *	California, Berkeley and its contributors.
     20   1.1      cgd  * 4. Neither the name of the University nor the names of its contributors
     21   1.1      cgd  *    may be used to endorse or promote products derived from this software
     22   1.1      cgd  *    without specific prior written permission.
     23   1.1      cgd  *
     24   1.1      cgd  * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
     25   1.1      cgd  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
     26   1.1      cgd  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
     27   1.1      cgd  * ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
     28   1.1      cgd  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
     29   1.1      cgd  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
     30   1.1      cgd  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
     31   1.1      cgd  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
     32   1.1      cgd  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
     33   1.1      cgd  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
     34   1.1      cgd  * SUCH DAMAGE.
     35   1.1      cgd  *
     36   1.3      cgd  *	from: @(#)nfs_subs.c	7.41 (Berkeley) 5/15/91
     37  1.10  mycroft  *	$Id: nfs_subs.c,v 1.10 1994/02/06 11:28:37 mycroft Exp $
     38   1.1      cgd  */
     39   1.1      cgd 
     40   1.1      cgd /*
     41   1.1      cgd  * These functions support the macros and help fiddle mbuf chains for
     42   1.1      cgd  * the nfs op functions. They do things like create the rpc header and
     43   1.1      cgd  * copy data between mbuf chains and uio lists.
     44   1.1      cgd  */
     45   1.9  mycroft #include <sys/param.h>
     46   1.9  mycroft #include <sys/proc.h>
     47   1.9  mycroft #include <sys/filedesc.h>
     48   1.9  mycroft #include <sys/systm.h>
     49   1.9  mycroft #include <sys/kernel.h>
     50   1.9  mycroft #include <sys/mount.h>
     51   1.9  mycroft #include <sys/file.h>
     52   1.9  mycroft #include <sys/vnode.h>
     53   1.9  mycroft #include <sys/namei.h>
     54   1.9  mycroft #include <sys/mbuf.h>
     55  1.10  mycroft #ifdef NFSCLIENT
     56  1.10  mycroft #include <sys/buf.h>
     57  1.10  mycroft #endif
     58   1.1      cgd 
     59   1.9  mycroft #include <ufs/quota.h>
     60   1.9  mycroft #include <ufs/inode.h>
     61   1.1      cgd 
     62   1.9  mycroft #include <nfs/rpcv2.h>
     63   1.9  mycroft #include <nfs/nfsv2.h>
     64   1.9  mycroft #include <nfs/nfsnode.h>
     65   1.9  mycroft #include <nfs/nfs.h>
     66   1.9  mycroft #include <nfs/nfsiom.h>
     67   1.9  mycroft #include <nfs/xdr_subs.h>
     68   1.9  mycroft #include <nfs/nfsm_subs.h>
     69   1.9  mycroft #include <nfs/nfscompress.h>
     70   1.1      cgd 
     71   1.1      cgd #define TRUE	1
     72   1.1      cgd #define	FALSE	0
     73   1.1      cgd 
     74   1.1      cgd /*
     75   1.1      cgd  * Data items converted to xdr at startup, since they are constant
     76   1.1      cgd  * This is kinda hokey, but may save a little time doing byte swaps
     77   1.1      cgd  */
     78   1.1      cgd u_long nfs_procids[NFS_NPROCS];
     79   1.1      cgd u_long nfs_xdrneg1;
     80   1.1      cgd u_long rpc_call, rpc_vers, rpc_reply, rpc_msgdenied,
     81   1.1      cgd 	rpc_mismatch, rpc_auth_unix, rpc_msgaccepted;
     82   1.1      cgd u_long nfs_vers, nfs_prog, nfs_true, nfs_false;
     83   1.1      cgd /* And other global data */
     84   1.1      cgd static u_long *rpc_uidp = (u_long *)0;
     85   1.1      cgd static u_long nfs_xid = 1;
     86   1.1      cgd static char *rpc_unixauth;
     87   1.1      cgd extern long hostid;
     88  1.10  mycroft #ifdef NFSCLIENT
     89  1.10  mycroft extern struct buf nfs_bqueue;
     90  1.10  mycroft #endif
     91   1.2    glass 
     92   1.1      cgd extern struct proc *nfs_iodwant[NFS_MAXASYNCDAEMON];
     93   1.1      cgd extern struct nfsreq nfsreqh;
     94   1.1      cgd 
     95   1.1      cgd /* Function ret types */
     96   1.1      cgd static char *nfs_unixauth();
     97   1.1      cgd 
     98   1.1      cgd /*
     99   1.1      cgd  * Maximum number of groups passed through to NFS server.
    100   1.1      cgd  * According to RFC1057 it should be 16.
    101   1.1      cgd  * For release 3.X systems, the maximum value is 8.
    102   1.1      cgd  * For some other servers, the maximum value is 10.
    103   1.1      cgd  */
    104   1.1      cgd int numgrps = 8;
    105   1.1      cgd 
    106   1.1      cgd /*
    107   1.1      cgd  * Create the header for an rpc request packet
    108   1.1      cgd  * The function nfs_unixauth() creates a unix style authorization string
    109   1.1      cgd  * and returns a ptr to it.
    110   1.1      cgd  * The hsiz is the size of the rest of the nfs request header.
    111   1.1      cgd  * (just used to decide if a cluster is a good idea)
    112   1.1      cgd  * nb: Note that the prog, vers and procid args are already in xdr byte order
    113   1.1      cgd  */
    114   1.1      cgd struct mbuf *nfsm_reqh(prog, vers, procid, cred, hsiz, bpos, mb, retxid)
    115   1.1      cgd 	u_long prog;
    116   1.1      cgd 	u_long vers;
    117   1.1      cgd 	u_long procid;
    118   1.1      cgd 	struct ucred *cred;
    119   1.1      cgd 	int hsiz;
    120   1.7  mycroft 	caddr_t *bpos;
    121   1.1      cgd 	struct mbuf **mb;
    122   1.1      cgd 	u_long *retxid;
    123   1.1      cgd {
    124   1.1      cgd 	register struct mbuf *mreq, *m;
    125   1.1      cgd 	register u_long *tl;
    126   1.1      cgd 	struct mbuf *m1;
    127   1.1      cgd 	char *ap;
    128   1.1      cgd 	int asiz, siz;
    129   1.4      cgd 	static char authnull[4*NFSX_UNSIGNED];
    130   1.1      cgd 
    131   1.1      cgd 	NFSMGETHDR(mreq);
    132   1.5      cgd 	if (cred != NOCRED) {
    133   1.4      cgd 	    asiz = ((((cred->cr_ngroups - 1) > numgrps) ? numgrps :
    134   1.4      cgd 		      (cred->cr_ngroups - 1)) << 2);
    135   1.1      cgd #ifdef FILLINHOST
    136   1.4      cgd 	    asiz += nfsm_rndup(hostnamelen)+(9*NFSX_UNSIGNED);
    137   1.1      cgd #else
    138   1.4      cgd 	    asiz += 9*NFSX_UNSIGNED;
    139   1.1      cgd #endif
    140   1.4      cgd 	} else
    141   1.4      cgd 	    asiz = 4 * NFSX_UNSIGNED;
    142   1.1      cgd 
    143   1.1      cgd 	/* If we need a lot, alloc a cluster ?? */
    144   1.1      cgd 	if ((asiz+hsiz+RPC_SIZ) > MHLEN)
    145   1.1      cgd 		MCLGET(mreq, M_WAIT);
    146   1.1      cgd 	mreq->m_len = NFSMSIZ(mreq);
    147   1.1      cgd 	siz = mreq->m_len;
    148   1.1      cgd 	m1 = mreq;
    149   1.1      cgd 	/*
    150   1.1      cgd 	 * Alloc enough mbufs
    151   1.1      cgd 	 * We do it now to avoid all sleeps after the call to nfs_unixauth()
    152   1.1      cgd 	 */
    153   1.1      cgd 	while ((asiz+RPC_SIZ) > siz) {
    154   1.1      cgd 		MGET(m, M_WAIT, MT_DATA);
    155   1.1      cgd 		m1->m_next = m;
    156   1.1      cgd 		m->m_len = MLEN;
    157   1.1      cgd 		siz += MLEN;
    158   1.1      cgd 		m1 = m;
    159   1.1      cgd 	}
    160   1.1      cgd 	tl = mtod(mreq, u_long *);
    161   1.1      cgd 	*tl++ = *retxid = txdr_unsigned(++nfs_xid);
    162   1.1      cgd 	*tl++ = rpc_call;
    163   1.1      cgd 	*tl++ = rpc_vers;
    164   1.1      cgd 	*tl++ = prog;
    165   1.1      cgd 	*tl++ = vers;
    166   1.1      cgd 	*tl++ = procid;
    167   1.1      cgd 
    168   1.1      cgd 	/* Now we can call nfs_unixauth() and copy it in */
    169   1.5      cgd 	if (cred != NOCRED)
    170   1.4      cgd 	    ap = nfs_unixauth(cred);
    171   1.4      cgd 	else
    172   1.4      cgd 	    ap = authnull;
    173   1.1      cgd 	m = mreq;
    174   1.1      cgd 	siz = m->m_len-RPC_SIZ;
    175   1.1      cgd 	if (asiz <= siz) {
    176   1.1      cgd 		bcopy(ap, (caddr_t)tl, asiz);
    177   1.1      cgd 		m->m_len = asiz+RPC_SIZ;
    178   1.1      cgd 	} else {
    179   1.1      cgd 		bcopy(ap, (caddr_t)tl, siz);
    180   1.1      cgd 		ap += siz;
    181   1.1      cgd 		asiz -= siz;
    182   1.1      cgd 		while (asiz > 0) {
    183   1.1      cgd 			siz = (asiz > MLEN) ? MLEN : asiz;
    184   1.1      cgd 			m = m->m_next;
    185   1.1      cgd 			bcopy(ap, mtod(m, caddr_t), siz);
    186   1.1      cgd 			m->m_len = siz;
    187   1.1      cgd 			asiz -= siz;
    188   1.1      cgd 			ap += siz;
    189   1.1      cgd 		}
    190   1.1      cgd 	}
    191   1.1      cgd 
    192   1.1      cgd 	/* Finally, return values */
    193   1.1      cgd 	*mb = m;
    194   1.1      cgd 	*bpos = mtod(m, caddr_t)+m->m_len;
    195   1.1      cgd 	return (mreq);
    196   1.1      cgd }
    197   1.1      cgd 
    198   1.1      cgd /*
    199   1.1      cgd  * copies mbuf chain to the uio scatter/gather list
    200   1.1      cgd  */
    201   1.1      cgd nfsm_mbuftouio(mrep, uiop, siz, dpos)
    202   1.1      cgd 	struct mbuf **mrep;
    203   1.1      cgd 	register struct uio *uiop;
    204   1.1      cgd 	int siz;
    205   1.1      cgd 	caddr_t *dpos;
    206   1.1      cgd {
    207   1.1      cgd 	register char *mbufcp, *uiocp;
    208   1.1      cgd 	register int xfer, left, len;
    209   1.1      cgd 	register struct mbuf *mp;
    210   1.1      cgd 	long uiosiz, rem;
    211   1.1      cgd 	int error = 0;
    212   1.1      cgd 
    213   1.1      cgd 	mp = *mrep;
    214   1.1      cgd 	mbufcp = *dpos;
    215   1.1      cgd 	len = mtod(mp, caddr_t)+mp->m_len-mbufcp;
    216   1.1      cgd 	rem = nfsm_rndup(siz)-siz;
    217   1.1      cgd 	while (siz > 0) {
    218   1.1      cgd 		if (uiop->uio_iovcnt <= 0 || uiop->uio_iov == NULL)
    219   1.1      cgd 			return (EFBIG);
    220   1.1      cgd 		left = uiop->uio_iov->iov_len;
    221   1.1      cgd 		uiocp = uiop->uio_iov->iov_base;
    222   1.1      cgd 		if (left > siz)
    223   1.1      cgd 			left = siz;
    224   1.1      cgd 		uiosiz = left;
    225   1.1      cgd 		while (left > 0) {
    226   1.1      cgd 			while (len == 0) {
    227   1.1      cgd 				mp = mp->m_next;
    228   1.1      cgd 				if (mp == NULL)
    229   1.1      cgd 					return (EBADRPC);
    230   1.1      cgd 				mbufcp = mtod(mp, caddr_t);
    231   1.1      cgd 				len = mp->m_len;
    232   1.1      cgd 			}
    233   1.1      cgd 			xfer = (left > len) ? len : left;
    234   1.1      cgd #ifdef notdef
    235   1.1      cgd 			/* Not Yet.. */
    236   1.1      cgd 			if (uiop->uio_iov->iov_op != NULL)
    237   1.1      cgd 				(*(uiop->uio_iov->iov_op))
    238   1.1      cgd 				(mbufcp, uiocp, xfer);
    239   1.1      cgd 			else
    240   1.1      cgd #endif
    241   1.1      cgd 			if (uiop->uio_segflg == UIO_SYSSPACE)
    242   1.1      cgd 				bcopy(mbufcp, uiocp, xfer);
    243   1.1      cgd 			else
    244   1.1      cgd 				copyout(mbufcp, uiocp, xfer);
    245   1.1      cgd 			left -= xfer;
    246   1.1      cgd 			len -= xfer;
    247   1.1      cgd 			mbufcp += xfer;
    248   1.1      cgd 			uiocp += xfer;
    249   1.1      cgd 			uiop->uio_offset += xfer;
    250   1.1      cgd 			uiop->uio_resid -= xfer;
    251   1.1      cgd 		}
    252   1.1      cgd 		if (uiop->uio_iov->iov_len <= siz) {
    253   1.1      cgd 			uiop->uio_iovcnt--;
    254   1.1      cgd 			uiop->uio_iov++;
    255   1.1      cgd 		} else {
    256   1.1      cgd 			uiop->uio_iov->iov_base += uiosiz;
    257   1.1      cgd 			uiop->uio_iov->iov_len -= uiosiz;
    258   1.1      cgd 		}
    259   1.1      cgd 		siz -= uiosiz;
    260   1.1      cgd 	}
    261   1.1      cgd 	*dpos = mbufcp;
    262   1.1      cgd 	*mrep = mp;
    263   1.1      cgd 	if (rem > 0) {
    264   1.1      cgd 		if (len < rem)
    265   1.1      cgd 			error = nfs_adv(mrep, dpos, rem, len);
    266   1.1      cgd 		else
    267   1.1      cgd 			*dpos += rem;
    268   1.1      cgd 	}
    269   1.1      cgd 	return (error);
    270   1.1      cgd }
    271   1.1      cgd 
    272   1.1      cgd /*
    273   1.1      cgd  * copies a uio scatter/gather list to an mbuf chain...
    274   1.1      cgd  */
    275   1.1      cgd nfsm_uiotombuf(uiop, mq, siz, bpos)
    276   1.1      cgd 	register struct uio *uiop;
    277   1.1      cgd 	struct mbuf **mq;
    278   1.1      cgd 	int siz;
    279   1.1      cgd 	caddr_t *bpos;
    280   1.1      cgd {
    281   1.1      cgd 	register char *uiocp;
    282   1.1      cgd 	register struct mbuf *mp, *mp2;
    283   1.1      cgd 	register int xfer, left, len;
    284   1.1      cgd 	int uiosiz, clflg, rem;
    285   1.1      cgd 	char *cp;
    286   1.1      cgd 
    287   1.1      cgd 	if (siz > MLEN)		/* or should it >= MCLBYTES ?? */
    288   1.1      cgd 		clflg = 1;
    289   1.1      cgd 	else
    290   1.1      cgd 		clflg = 0;
    291   1.1      cgd 	rem = nfsm_rndup(siz)-siz;
    292   1.1      cgd 	mp2 = *mq;
    293   1.1      cgd 	while (siz > 0) {
    294   1.1      cgd 		if (uiop->uio_iovcnt <= 0 || uiop->uio_iov == NULL)
    295   1.1      cgd 			return (EINVAL);
    296   1.1      cgd 		left = uiop->uio_iov->iov_len;
    297   1.1      cgd 		uiocp = uiop->uio_iov->iov_base;
    298   1.1      cgd 		if (left > siz)
    299   1.1      cgd 			left = siz;
    300   1.1      cgd 		uiosiz = left;
    301   1.1      cgd 		while (left > 0) {
    302   1.1      cgd 			MGET(mp, M_WAIT, MT_DATA);
    303   1.1      cgd 			if (clflg)
    304   1.1      cgd 				MCLGET(mp, M_WAIT);
    305   1.1      cgd 			mp->m_len = NFSMSIZ(mp);
    306   1.1      cgd 			mp2->m_next = mp;
    307   1.1      cgd 			mp2 = mp;
    308   1.1      cgd 			xfer = (left > mp->m_len) ? mp->m_len : left;
    309   1.1      cgd #ifdef notdef
    310   1.1      cgd 			/* Not Yet.. */
    311   1.1      cgd 			if (uiop->uio_iov->iov_op != NULL)
    312   1.1      cgd 				(*(uiop->uio_iov->iov_op))
    313   1.1      cgd 				(uiocp, mtod(mp, caddr_t), xfer);
    314   1.1      cgd 			else
    315   1.1      cgd #endif
    316   1.1      cgd 			if (uiop->uio_segflg == UIO_SYSSPACE)
    317   1.1      cgd 				bcopy(uiocp, mtod(mp, caddr_t), xfer);
    318   1.1      cgd 			else
    319   1.1      cgd 				copyin(uiocp, mtod(mp, caddr_t), xfer);
    320   1.1      cgd 			len = mp->m_len;
    321   1.1      cgd 			mp->m_len = xfer;
    322   1.1      cgd 			left -= xfer;
    323   1.1      cgd 			uiocp += xfer;
    324   1.1      cgd 			uiop->uio_offset += xfer;
    325   1.1      cgd 			uiop->uio_resid -= xfer;
    326   1.1      cgd 		}
    327   1.1      cgd 		if (uiop->uio_iov->iov_len <= siz) {
    328   1.1      cgd 			uiop->uio_iovcnt--;
    329   1.1      cgd 			uiop->uio_iov++;
    330   1.1      cgd 		} else {
    331   1.1      cgd 			uiop->uio_iov->iov_base += uiosiz;
    332   1.1      cgd 			uiop->uio_iov->iov_len -= uiosiz;
    333   1.1      cgd 		}
    334   1.1      cgd 		siz -= uiosiz;
    335   1.1      cgd 	}
    336   1.1      cgd 	if (rem > 0) {
    337   1.1      cgd 		if (rem > (len-mp->m_len)) {
    338   1.1      cgd 			MGET(mp, M_WAIT, MT_DATA);
    339   1.1      cgd 			mp->m_len = 0;
    340   1.1      cgd 			mp2->m_next = mp;
    341   1.1      cgd 		}
    342   1.1      cgd 		cp = mtod(mp, caddr_t)+mp->m_len;
    343   1.1      cgd 		for (left = 0; left < rem; left++)
    344   1.1      cgd 			*cp++ = '\0';
    345   1.1      cgd 		mp->m_len += rem;
    346   1.1      cgd 		*bpos = cp;
    347   1.1      cgd 	} else
    348   1.1      cgd 		*bpos = mtod(mp, caddr_t)+mp->m_len;
    349   1.1      cgd 	*mq = mp;
    350   1.1      cgd 	return (0);
    351   1.1      cgd }
    352   1.1      cgd 
    353   1.1      cgd /*
    354   1.1      cgd  * Help break down an mbuf chain by setting the first siz bytes contiguous
    355   1.1      cgd  * pointed to by returned val.
    356   1.1      cgd  * If Updateflg == True we can overwrite the first part of the mbuf data
    357   1.1      cgd  * This is used by the macros nfsm_disect and nfsm_disecton for tough
    358   1.1      cgd  * cases. (The macros use the vars. dpos and dpos2)
    359   1.1      cgd  */
    360   1.1      cgd nfsm_disct(mdp, dposp, siz, left, updateflg, cp2)
    361   1.1      cgd 	struct mbuf **mdp;
    362   1.1      cgd 	caddr_t *dposp;
    363   1.1      cgd 	int siz;
    364   1.1      cgd 	int left;
    365   1.1      cgd 	int updateflg;
    366   1.1      cgd 	caddr_t *cp2;
    367   1.1      cgd {
    368   1.1      cgd 	register struct mbuf *mp, *mp2;
    369   1.1      cgd 	register int siz2, xfer;
    370   1.1      cgd 	register caddr_t tl;
    371   1.1      cgd 
    372   1.1      cgd 	mp = *mdp;
    373   1.1      cgd 	while (left == 0) {
    374   1.1      cgd 		*mdp = mp = mp->m_next;
    375   1.1      cgd 		if (mp == NULL)
    376   1.1      cgd 			return (EBADRPC);
    377   1.1      cgd 		left = mp->m_len;
    378   1.1      cgd 		*dposp = mtod(mp, caddr_t);
    379   1.1      cgd 	}
    380   1.1      cgd 	if (left >= siz) {
    381   1.1      cgd 		*cp2 = *dposp;
    382   1.1      cgd 		*dposp += siz;
    383   1.1      cgd 	} else if (mp->m_next == NULL) {
    384   1.1      cgd 		return (EBADRPC);
    385   1.1      cgd 	} else if (siz > MHLEN) {
    386   1.1      cgd 		panic("nfs S too big");
    387   1.1      cgd 	} else {
    388   1.1      cgd 		/* Iff update, you can overwrite, else must alloc new mbuf */
    389   1.1      cgd 		if (updateflg) {
    390   1.1      cgd 			NFSMINOFF(mp);
    391   1.1      cgd 		} else {
    392   1.1      cgd 			MGET(mp2, M_WAIT, MT_DATA);
    393   1.1      cgd 			mp2->m_next = mp->m_next;
    394   1.1      cgd 			mp->m_next = mp2;
    395   1.1      cgd 			mp->m_len -= left;
    396   1.1      cgd 			mp = mp2;
    397   1.1      cgd 		}
    398   1.1      cgd 		*cp2 = tl = mtod(mp, caddr_t);
    399   1.1      cgd 		bcopy(*dposp, tl, left);		/* Copy what was left */
    400   1.1      cgd 		siz2 = siz-left;
    401   1.1      cgd 		tl += left;
    402   1.1      cgd 		mp2 = mp->m_next;
    403   1.1      cgd 		/* Loop around copying up the siz2 bytes */
    404   1.1      cgd 		while (siz2 > 0) {
    405   1.1      cgd 			if (mp2 == NULL)
    406   1.1      cgd 				return (EBADRPC);
    407   1.1      cgd 			xfer = (siz2 > mp2->m_len) ? mp2->m_len : siz2;
    408   1.1      cgd 			if (xfer > 0) {
    409   1.1      cgd 				bcopy(mtod(mp2, caddr_t), tl, xfer);
    410   1.1      cgd 				NFSMADV(mp2, xfer);
    411   1.1      cgd 				mp2->m_len -= xfer;
    412   1.1      cgd 				tl += xfer;
    413   1.1      cgd 				siz2 -= xfer;
    414   1.1      cgd 			}
    415   1.1      cgd 			if (siz2 > 0)
    416   1.1      cgd 				mp2 = mp2->m_next;
    417   1.1      cgd 		}
    418   1.1      cgd 		mp->m_len = siz;
    419   1.1      cgd 		*mdp = mp2;
    420   1.1      cgd 		*dposp = mtod(mp2, caddr_t);
    421   1.1      cgd 	}
    422   1.1      cgd 	return (0);
    423   1.1      cgd }
    424   1.1      cgd 
    425   1.1      cgd /*
    426   1.1      cgd  * Advance the position in the mbuf chain.
    427   1.1      cgd  */
    428   1.1      cgd nfs_adv(mdp, dposp, offs, left)
    429   1.1      cgd 	struct mbuf **mdp;
    430   1.1      cgd 	caddr_t *dposp;
    431   1.1      cgd 	int offs;
    432   1.1      cgd 	int left;
    433   1.1      cgd {
    434   1.1      cgd 	register struct mbuf *m;
    435   1.1      cgd 	register int s;
    436   1.1      cgd 
    437   1.1      cgd 	m = *mdp;
    438   1.1      cgd 	s = left;
    439   1.1      cgd 	while (s < offs) {
    440   1.1      cgd 		offs -= s;
    441   1.1      cgd 		m = m->m_next;
    442   1.1      cgd 		if (m == NULL)
    443   1.1      cgd 			return (EBADRPC);
    444   1.1      cgd 		s = m->m_len;
    445   1.1      cgd 	}
    446   1.1      cgd 	*mdp = m;
    447   1.1      cgd 	*dposp = mtod(m, caddr_t)+offs;
    448   1.1      cgd 	return (0);
    449   1.1      cgd }
    450   1.1      cgd 
    451   1.1      cgd /*
    452   1.1      cgd  * Copy a string into mbufs for the hard cases...
    453   1.1      cgd  */
    454   1.1      cgd nfsm_strtmbuf(mb, bpos, cp, siz)
    455   1.1      cgd 	struct mbuf **mb;
    456   1.1      cgd 	char **bpos;
    457   1.1      cgd 	char *cp;
    458   1.1      cgd 	long siz;
    459   1.1      cgd {
    460   1.1      cgd 	register struct mbuf *m1, *m2;
    461   1.1      cgd 	long left, xfer, len, tlen;
    462   1.1      cgd 	u_long *tl;
    463   1.1      cgd 	int putsize;
    464   1.1      cgd 
    465   1.1      cgd 	putsize = 1;
    466   1.1      cgd 	m2 = *mb;
    467   1.1      cgd 	left = NFSMSIZ(m2)-m2->m_len;
    468   1.1      cgd 	if (left > 0) {
    469   1.1      cgd 		tl = ((u_long *)(*bpos));
    470   1.1      cgd 		*tl++ = txdr_unsigned(siz);
    471   1.1      cgd 		putsize = 0;
    472   1.1      cgd 		left -= NFSX_UNSIGNED;
    473   1.1      cgd 		m2->m_len += NFSX_UNSIGNED;
    474   1.1      cgd 		if (left > 0) {
    475   1.1      cgd 			bcopy(cp, (caddr_t) tl, left);
    476   1.1      cgd 			siz -= left;
    477   1.1      cgd 			cp += left;
    478   1.1      cgd 			m2->m_len += left;
    479   1.1      cgd 			left = 0;
    480   1.1      cgd 		}
    481   1.1      cgd 	}
    482   1.1      cgd 	/* Loop arround adding mbufs */
    483   1.1      cgd 	while (siz > 0) {
    484   1.1      cgd 		MGET(m1, M_WAIT, MT_DATA);
    485   1.1      cgd 		if (siz > MLEN)
    486   1.1      cgd 			MCLGET(m1, M_WAIT);
    487   1.1      cgd 		m1->m_len = NFSMSIZ(m1);
    488   1.1      cgd 		m2->m_next = m1;
    489   1.1      cgd 		m2 = m1;
    490   1.1      cgd 		tl = mtod(m1, u_long *);
    491   1.1      cgd 		tlen = 0;
    492   1.1      cgd 		if (putsize) {
    493   1.1      cgd 			*tl++ = txdr_unsigned(siz);
    494   1.1      cgd 			m1->m_len -= NFSX_UNSIGNED;
    495   1.1      cgd 			tlen = NFSX_UNSIGNED;
    496   1.1      cgd 			putsize = 0;
    497   1.1      cgd 		}
    498   1.1      cgd 		if (siz < m1->m_len) {
    499   1.1      cgd 			len = nfsm_rndup(siz);
    500   1.1      cgd 			xfer = siz;
    501   1.1      cgd 			if (xfer < len)
    502   1.1      cgd 				*(tl+(xfer>>2)) = 0;
    503   1.1      cgd 		} else {
    504   1.1      cgd 			xfer = len = m1->m_len;
    505   1.1      cgd 		}
    506   1.1      cgd 		bcopy(cp, (caddr_t) tl, xfer);
    507   1.1      cgd 		m1->m_len = len+tlen;
    508   1.1      cgd 		siz -= xfer;
    509   1.1      cgd 		cp += xfer;
    510   1.1      cgd 	}
    511   1.1      cgd 	*mb = m1;
    512   1.1      cgd 	*bpos = mtod(m1, caddr_t)+m1->m_len;
    513   1.1      cgd 	return (0);
    514   1.1      cgd }
    515   1.1      cgd 
    516   1.1      cgd /*
    517   1.1      cgd  * Called once to initialize data structures...
    518   1.1      cgd  */
    519   1.1      cgd nfs_init()
    520   1.1      cgd {
    521   1.1      cgd 	register int i;
    522   1.1      cgd 
    523   1.1      cgd 	rpc_vers = txdr_unsigned(RPC_VER2);
    524   1.1      cgd 	rpc_call = txdr_unsigned(RPC_CALL);
    525   1.1      cgd 	rpc_reply = txdr_unsigned(RPC_REPLY);
    526   1.1      cgd 	rpc_msgdenied = txdr_unsigned(RPC_MSGDENIED);
    527   1.1      cgd 	rpc_msgaccepted = txdr_unsigned(RPC_MSGACCEPTED);
    528   1.1      cgd 	rpc_mismatch = txdr_unsigned(RPC_MISMATCH);
    529   1.1      cgd 	rpc_auth_unix = txdr_unsigned(RPCAUTH_UNIX);
    530   1.1      cgd 	nfs_vers = txdr_unsigned(NFS_VER2);
    531   1.1      cgd 	nfs_prog = txdr_unsigned(NFS_PROG);
    532   1.1      cgd 	nfs_true = txdr_unsigned(TRUE);
    533   1.1      cgd 	nfs_false = txdr_unsigned(FALSE);
    534   1.1      cgd 	/* Loop thru nfs procids */
    535   1.1      cgd 	for (i = 0; i < NFS_NPROCS; i++)
    536   1.1      cgd 		nfs_procids[i] = txdr_unsigned(i);
    537   1.1      cgd 	/* Ensure async daemons disabled */
    538   1.2    glass 	nfs_xdrneg1 = txdr_unsigned(-1);
    539   1.2    glass #ifdef NFSCLIENT
    540  1.10  mycroft 	nfs_bqueue.b_actb = &nfs_bqueue.b_actf;
    541   1.1      cgd 	for (i = 0; i < NFS_MAXASYNCDAEMON; i++)
    542   1.1      cgd 		nfs_iodwant[i] = (struct proc *)0;
    543   1.1      cgd 	nfs_nhinit();			/* Init the nfsnode table */
    544   1.2    glass #endif /* NFSCLIENT */
    545   1.2    glass #ifdef NFSSERVER
    546   1.1      cgd 	nfsrv_initcache();		/* Init the server request cache */
    547   1.2    glass #endif /*NFSSERVER */
    548   1.1      cgd 	/*
    549   1.1      cgd 	 * Initialize reply list and start timer
    550   1.1      cgd 	 */
    551   1.1      cgd 	nfsreqh.r_prev = nfsreqh.r_next = &nfsreqh;
    552   1.1      cgd 	nfs_timer();
    553   1.1      cgd }
    554   1.1      cgd 
    555   1.1      cgd /*
    556   1.1      cgd  * Fill in the rest of the rpc_unixauth and return it
    557   1.1      cgd  */
    558   1.1      cgd static char *nfs_unixauth(cr)
    559   1.1      cgd 	register struct ucred *cr;
    560   1.1      cgd {
    561   1.1      cgd 	register u_long *tl;
    562   1.1      cgd 	register int i;
    563   1.1      cgd 	int ngr;
    564   1.1      cgd 
    565   1.1      cgd 	/* Maybe someday there should be a cache of AUTH_SHORT's */
    566   1.1      cgd 	if ((tl = rpc_uidp) == NULL) {
    567   1.1      cgd #ifdef FILLINHOST
    568   1.1      cgd 		i = nfsm_rndup(hostnamelen)+(25*NFSX_UNSIGNED);
    569   1.1      cgd #else
    570   1.1      cgd 		i = 25*NFSX_UNSIGNED;
    571   1.1      cgd #endif
    572   1.1      cgd 		MALLOC(tl, u_long *, i, M_TEMP, M_WAITOK);
    573   1.1      cgd 		bzero((caddr_t)tl, i);
    574   1.1      cgd 		rpc_unixauth = (caddr_t)tl;
    575   1.1      cgd 		*tl++ = txdr_unsigned(RPCAUTH_UNIX);
    576   1.1      cgd 		tl++;	/* Fill in size later */
    577   1.1      cgd 		*tl++ = hostid;
    578   1.1      cgd #ifdef FILLINHOST
    579   1.1      cgd 		*tl++ = txdr_unsigned(hostnamelen);
    580   1.1      cgd 		i = nfsm_rndup(hostnamelen);
    581   1.1      cgd 		bcopy(hostname, (caddr_t)tl, hostnamelen);
    582   1.1      cgd 		tl += (i>>2);
    583   1.1      cgd #else
    584   1.1      cgd 		*tl++ = 0;
    585   1.1      cgd #endif
    586   1.1      cgd 		rpc_uidp = tl;
    587   1.1      cgd 	}
    588   1.1      cgd 	*tl++ = txdr_unsigned(cr->cr_uid);
    589   1.1      cgd 	*tl++ = txdr_unsigned(cr->cr_groups[0]);
    590   1.1      cgd 	ngr = ((cr->cr_ngroups - 1) > numgrps) ? numgrps : (cr->cr_ngroups - 1);
    591   1.1      cgd 	*tl++ = txdr_unsigned(ngr);
    592   1.1      cgd 	for (i = 1; i <= ngr; i++)
    593   1.1      cgd 		*tl++ = txdr_unsigned(cr->cr_groups[i]);
    594   1.1      cgd 	/* And add the AUTH_NULL */
    595   1.1      cgd 	*tl++ = 0;
    596   1.1      cgd 	*tl = 0;
    597   1.1      cgd 	i = (((caddr_t)tl)-rpc_unixauth)-12;
    598   1.1      cgd 	tl = (u_long *)(rpc_unixauth+4);
    599   1.1      cgd 	*tl = txdr_unsigned(i);
    600   1.1      cgd 	return (rpc_unixauth);
    601   1.1      cgd }
    602   1.1      cgd 
    603   1.1      cgd /*
    604   1.1      cgd  * Set up nameidata for a namei() call and do it
    605   1.1      cgd  */
    606   1.1      cgd nfs_namei(ndp, fhp, len, mdp, dposp, p)
    607   1.1      cgd 	register struct nameidata *ndp;
    608   1.1      cgd 	fhandle_t *fhp;
    609   1.1      cgd 	int len;
    610   1.1      cgd 	struct mbuf **mdp;
    611   1.1      cgd 	caddr_t *dposp;
    612   1.1      cgd 	struct proc *p;
    613   1.1      cgd {
    614   1.1      cgd 	register int i, rem;
    615   1.1      cgd 	register struct mbuf *md;
    616   1.1      cgd 	register char *fromcp, *tocp;
    617   1.1      cgd 	struct vnode *dp;
    618   1.1      cgd 	int flag;
    619   1.1      cgd 	int error;
    620   1.1      cgd 
    621   1.1      cgd 	flag = ndp->ni_nameiop & OPMASK;
    622   1.1      cgd 	MALLOC(ndp->ni_pnbuf, char *, len + 1, M_NAMEI, M_WAITOK);
    623   1.1      cgd 	/*
    624   1.1      cgd 	 * Copy the name from the mbuf list to ndp->ni_pnbuf
    625   1.1      cgd 	 * and set the various ndp fields appropriately.
    626   1.1      cgd 	 */
    627   1.1      cgd 	fromcp = *dposp;
    628   1.1      cgd 	tocp = ndp->ni_pnbuf;
    629   1.1      cgd 	md = *mdp;
    630   1.1      cgd 	rem = mtod(md, caddr_t) + md->m_len - fromcp;
    631   1.1      cgd 	for (i = 0; i < len; i++) {
    632   1.1      cgd 		while (rem == 0) {
    633   1.1      cgd 			md = md->m_next;
    634   1.1      cgd 			if (md == NULL) {
    635   1.1      cgd 				error = EBADRPC;
    636   1.1      cgd 				goto out;
    637   1.1      cgd 			}
    638   1.1      cgd 			fromcp = mtod(md, caddr_t);
    639   1.1      cgd 			rem = md->m_len;
    640   1.1      cgd 		}
    641   1.1      cgd 		if (*fromcp == '\0' || *fromcp == '/') {
    642   1.1      cgd 			error = EINVAL;
    643   1.1      cgd 			goto out;
    644   1.1      cgd 		}
    645   1.1      cgd 		if (*fromcp & 0200)
    646   1.1      cgd 			if ((*fromcp&0377) == ('/'|0200) || flag != DELETE) {
    647   1.1      cgd 				error = EINVAL;
    648   1.1      cgd 				goto out;
    649   1.1      cgd 			}
    650   1.1      cgd 		*tocp++ = *fromcp++;
    651   1.1      cgd 		rem--;
    652   1.1      cgd 	}
    653   1.1      cgd 	*tocp = '\0';
    654   1.1      cgd 	*mdp = md;
    655   1.1      cgd 	*dposp = fromcp;
    656   1.1      cgd 	len = nfsm_rndup(len)-len;
    657   1.1      cgd 	if (len > 0) {
    658   1.1      cgd 		if (rem >= len)
    659   1.1      cgd 			*dposp += len;
    660   1.1      cgd 		else if (error = nfs_adv(mdp, dposp, len, rem))
    661   1.1      cgd 			goto out;
    662   1.1      cgd 	}
    663   1.1      cgd 	ndp->ni_pathlen = tocp - ndp->ni_pnbuf;
    664   1.1      cgd 	ndp->ni_ptr = ndp->ni_pnbuf;
    665   1.1      cgd 	/*
    666   1.1      cgd 	 * Extract and set starting directory.
    667   1.1      cgd 	 */
    668   1.1      cgd 	if (error = nfsrv_fhtovp(fhp, FALSE, &dp, ndp->ni_cred))
    669   1.1      cgd 		goto out;
    670   1.1      cgd 	if (dp->v_type != VDIR) {
    671   1.1      cgd 		vrele(dp);
    672   1.1      cgd 		error = ENOTDIR;
    673   1.1      cgd 		goto out;
    674   1.1      cgd 	}
    675   1.1      cgd 	ndp->ni_startdir = dp;
    676   1.1      cgd 	ndp->ni_nameiop |= (NOCROSSMOUNT | REMOTE);
    677   1.1      cgd 	/*
    678   1.1      cgd 	 * And call lookup() to do the real work
    679   1.1      cgd 	 */
    680   1.1      cgd 	if (error = lookup(ndp, p))
    681   1.1      cgd 		goto out;
    682   1.1      cgd 	/*
    683   1.1      cgd 	 * Check for encountering a symbolic link
    684   1.1      cgd 	 */
    685   1.1      cgd 	if (ndp->ni_more) {
    686   1.1      cgd 		if ((ndp->ni_nameiop & LOCKPARENT) && ndp->ni_pathlen == 1)
    687   1.1      cgd 			vput(ndp->ni_dvp);
    688   1.1      cgd 		else
    689   1.1      cgd 			vrele(ndp->ni_dvp);
    690   1.1      cgd 		vput(ndp->ni_vp);
    691   1.1      cgd 		ndp->ni_vp = NULL;
    692   1.1      cgd 		error = EINVAL;
    693   1.1      cgd 		goto out;
    694   1.1      cgd 	}
    695   1.1      cgd 	/*
    696   1.1      cgd 	 * Check for saved name request
    697   1.1      cgd 	 */
    698   1.1      cgd 	if (ndp->ni_nameiop & (SAVENAME | SAVESTART)) {
    699   1.1      cgd 		ndp->ni_nameiop |= HASBUF;
    700   1.1      cgd 		return (0);
    701   1.1      cgd 	}
    702   1.1      cgd out:
    703   1.1      cgd 	FREE(ndp->ni_pnbuf, M_NAMEI);
    704   1.1      cgd 	return (error);
    705   1.1      cgd }
    706   1.1      cgd 
    707   1.1      cgd /*
    708   1.1      cgd  * A fiddled version of m_adj() that ensures null fill to a long
    709   1.1      cgd  * boundary and only trims off the back end
    710   1.1      cgd  */
    711   1.1      cgd nfsm_adj(mp, len, nul)
    712   1.1      cgd 	struct mbuf *mp;
    713   1.1      cgd 	register int len;
    714   1.1      cgd 	int nul;
    715   1.1      cgd {
    716   1.1      cgd 	register struct mbuf *m;
    717   1.1      cgd 	register int count, i;
    718   1.1      cgd 	register char *cp;
    719   1.1      cgd 
    720   1.1      cgd 	/*
    721   1.1      cgd 	 * Trim from tail.  Scan the mbuf chain,
    722   1.1      cgd 	 * calculating its length and finding the last mbuf.
    723   1.1      cgd 	 * If the adjustment only affects this mbuf, then just
    724   1.1      cgd 	 * adjust and return.  Otherwise, rescan and truncate
    725   1.1      cgd 	 * after the remaining size.
    726   1.1      cgd 	 */
    727   1.1      cgd 	count = 0;
    728   1.1      cgd 	m = mp;
    729   1.1      cgd 	for (;;) {
    730   1.1      cgd 		count += m->m_len;
    731   1.1      cgd 		if (m->m_next == (struct mbuf *)0)
    732   1.1      cgd 			break;
    733   1.1      cgd 		m = m->m_next;
    734   1.1      cgd 	}
    735   1.1      cgd 	if (m->m_len > len) {
    736   1.1      cgd 		m->m_len -= len;
    737   1.1      cgd 		if (nul > 0) {
    738   1.1      cgd 			cp = mtod(m, caddr_t)+m->m_len-nul;
    739   1.1      cgd 			for (i = 0; i < nul; i++)
    740   1.1      cgd 				*cp++ = '\0';
    741   1.1      cgd 		}
    742   1.1      cgd 		return;
    743   1.1      cgd 	}
    744   1.1      cgd 	count -= len;
    745   1.1      cgd 	if (count < 0)
    746   1.1      cgd 		count = 0;
    747   1.1      cgd 	/*
    748   1.1      cgd 	 * Correct length for chain is "count".
    749   1.1      cgd 	 * Find the mbuf with last data, adjust its length,
    750   1.1      cgd 	 * and toss data from remaining mbufs on chain.
    751   1.1      cgd 	 */
    752   1.1      cgd 	for (m = mp; m; m = m->m_next) {
    753   1.1      cgd 		if (m->m_len >= count) {
    754   1.1      cgd 			m->m_len = count;
    755   1.1      cgd 			if (nul > 0) {
    756   1.1      cgd 				cp = mtod(m, caddr_t)+m->m_len-nul;
    757   1.1      cgd 				for (i = 0; i < nul; i++)
    758   1.1      cgd 					*cp++ = '\0';
    759   1.1      cgd 			}
    760   1.1      cgd 			break;
    761   1.1      cgd 		}
    762   1.1      cgd 		count -= m->m_len;
    763   1.1      cgd 	}
    764   1.1      cgd 	while (m = m->m_next)
    765   1.1      cgd 		m->m_len = 0;
    766   1.1      cgd }
    767   1.1      cgd 
    768   1.1      cgd /*
    769   1.1      cgd  * nfsrv_fhtovp() - convert a fh to a vnode ptr (optionally locked)
    770   1.1      cgd  * 	- look up fsid in mount list (if not found ret error)
    771   1.1      cgd  *	- check that it is exported
    772   1.1      cgd  *	- get vp by calling VFS_FHTOVP() macro
    773   1.1      cgd  *	- if not lockflag unlock it with VOP_UNLOCK()
    774   1.1      cgd  *	- if cred->cr_uid == 0 set it to m_exroot
    775   1.1      cgd  */
    776   1.1      cgd nfsrv_fhtovp(fhp, lockflag, vpp, cred)
    777   1.1      cgd 	fhandle_t *fhp;
    778   1.1      cgd 	int lockflag;
    779   1.1      cgd 	struct vnode **vpp;
    780   1.1      cgd 	struct ucred *cred;
    781   1.1      cgd {
    782   1.1      cgd 	register struct mount *mp;
    783   1.1      cgd 
    784   1.1      cgd 	if ((mp = getvfs(&fhp->fh_fsid)) == NULL)
    785   1.1      cgd 		return (ESTALE);
    786   1.1      cgd 	if ((mp->mnt_flag & MNT_EXPORTED) == 0)
    787   1.1      cgd 		return (EACCES);
    788   1.1      cgd 	if (VFS_FHTOVP(mp, &fhp->fh_fid, vpp))
    789   1.1      cgd 		return (ESTALE);
    790   1.1      cgd 	if (cred->cr_uid == 0)
    791   1.1      cgd 		cred->cr_uid = mp->mnt_exroot;
    792   1.1      cgd 	if (!lockflag)
    793   1.1      cgd 		VOP_UNLOCK(*vpp);
    794   1.1      cgd 	return (0);
    795   1.1      cgd }
    796   1.1      cgd 
    797   1.1      cgd /*
    798   1.1      cgd  * These two functions implement nfs rpc compression.
    799   1.1      cgd  * The algorithm is a trivial run length encoding of '\0' bytes. The high
    800   1.1      cgd  * order nibble of hex "e" is or'd with the number of zeroes - 2 in four
    801   1.1      cgd  * bits. (2 - 17 zeros) Any data byte with a high order nibble of hex "e"
    802   1.1      cgd  * is byte stuffed.
    803   1.1      cgd  * The compressed data is padded with 0x0 bytes to an even multiple of
    804   1.1      cgd  * 4 bytes in length to avoid any weird long pointer alignments.
    805   1.1      cgd  * If compression/uncompression is unsuccessful, the original mbuf list
    806   1.1      cgd  * is returned.
    807   1.1      cgd  * The first four bytes (the XID) are left uncompressed and the fifth
    808   1.1      cgd  * byte is set to 0x1 for request and 0x2 for reply.
    809   1.1      cgd  * An uncompressed RPC will always have the fifth byte == 0x0.
    810   1.1      cgd  */
    811   1.1      cgd struct mbuf *
    812   1.1      cgd nfs_compress(m0)
    813   1.1      cgd 	struct mbuf *m0;
    814   1.1      cgd {
    815   1.1      cgd 	register u_char ch, nextch;
    816   1.1      cgd 	register int i, rlelast;
    817   1.1      cgd 	register u_char *ip, *op;
    818   1.1      cgd 	register int ileft, oleft, noteof;
    819   1.1      cgd 	register struct mbuf *m, *om;
    820   1.1      cgd 	struct mbuf **mp, *retm;
    821   1.1      cgd 	int olen, clget;
    822   1.1      cgd 
    823   1.1      cgd 	i = rlelast = 0;
    824   1.1      cgd 	noteof = 1;
    825   1.1      cgd 	m = m0;
    826   1.1      cgd 	if (m->m_len < 12)
    827   1.1      cgd 		return (m0);
    828   1.1      cgd 	if (m->m_pkthdr.len >= MINCLSIZE)
    829   1.1      cgd 		clget = 1;
    830   1.1      cgd 	else
    831   1.1      cgd 		clget = 0;
    832   1.1      cgd 	ileft = m->m_len - 9;
    833   1.1      cgd 	ip = mtod(m, u_char *);
    834   1.1      cgd 	MGETHDR(om, M_WAIT, MT_DATA);
    835   1.1      cgd 	if (clget)
    836   1.1      cgd 		MCLGET(om, M_WAIT);
    837   1.1      cgd 	retm = om;
    838   1.1      cgd 	mp = &om->m_next;
    839   1.1      cgd 	olen = om->m_len = 5;
    840   1.1      cgd 	oleft = M_TRAILINGSPACE(om);
    841   1.1      cgd 	op = mtod(om, u_char *);
    842   1.1      cgd 	*((u_long *)op) = *((u_long *)ip);
    843   1.1      cgd 	ip += 7;
    844   1.1      cgd 	op += 4;
    845   1.1      cgd 	*op++ = *ip++ + 1;
    846   1.1      cgd 	nextch = *ip++;
    847   1.1      cgd 	while (noteof) {
    848   1.1      cgd 		ch = nextch;
    849   1.1      cgd 		if (ileft == 0) {
    850   1.1      cgd 			do {
    851   1.1      cgd 				m = m->m_next;
    852   1.1      cgd 			} while (m && m->m_len == 0);
    853   1.1      cgd 			if (m) {
    854   1.1      cgd 				ileft = m->m_len;
    855   1.1      cgd 				ip = mtod(m, u_char *);
    856   1.1      cgd 			} else {
    857   1.1      cgd 				noteof = 0;
    858   1.1      cgd 				nextch = 0x1;
    859   1.1      cgd 				goto doit;
    860   1.1      cgd 			}
    861   1.1      cgd 		}
    862   1.1      cgd 		nextch = *ip++;
    863   1.1      cgd 		ileft--;
    864   1.1      cgd doit:
    865   1.1      cgd 		if (ch == '\0') {
    866   1.1      cgd 			if (++i == NFSC_MAX || nextch != '\0') {
    867   1.1      cgd 				if (i < 2) {
    868   1.1      cgd 					nfscput('\0');
    869   1.1      cgd 				} else {
    870   1.1      cgd 					if (rlelast == i) {
    871   1.1      cgd 						nfscput('\0');
    872   1.1      cgd 						i--;
    873   1.1      cgd 					}
    874   1.1      cgd 					if (NFSCRLE(i) == (nextch & 0xff)) {
    875   1.1      cgd 						i--;
    876   1.1      cgd 						if (i < 2) {
    877   1.1      cgd 							nfscput('\0');
    878   1.1      cgd 						} else {
    879   1.1      cgd 							nfscput(NFSCRLE(i));
    880   1.1      cgd 						}
    881   1.1      cgd 						nfscput('\0');
    882   1.1      cgd 						rlelast = 0;
    883   1.1      cgd 					} else {
    884   1.1      cgd 						nfscput(NFSCRLE(i));
    885   1.1      cgd 						rlelast = i;
    886   1.1      cgd 					}
    887   1.1      cgd 				}
    888   1.1      cgd 				i = 0;
    889   1.1      cgd 			}
    890   1.1      cgd 		} else {
    891   1.1      cgd 			if ((ch & NFSCRL) == NFSCRL) {
    892   1.1      cgd 				nfscput(ch);
    893   1.1      cgd 			}
    894   1.1      cgd 			nfscput(ch);
    895   1.1      cgd 			i = rlelast = 0;
    896   1.1      cgd 		}
    897   1.1      cgd 	}
    898   1.1      cgd 	if (olen < m0->m_pkthdr.len) {
    899   1.1      cgd 		m_freem(m0);
    900   1.1      cgd 		if (i = (olen & 0x3)) {
    901   1.1      cgd 			i = 4 - i;
    902   1.1      cgd 			while (i-- > 0) {
    903   1.1      cgd 				nfscput('\0');
    904   1.1      cgd 			}
    905   1.1      cgd 		}
    906   1.1      cgd 		retm->m_pkthdr.len = olen;
    907   1.1      cgd 		retm->m_pkthdr.rcvif = (struct ifnet *)0;
    908   1.1      cgd 		return (retm);
    909   1.1      cgd 	} else {
    910   1.1      cgd 		m_freem(retm);
    911   1.1      cgd 		return (m0);
    912   1.1      cgd 	}
    913   1.1      cgd }
    914   1.1      cgd 
    915   1.1      cgd struct mbuf *
    916   1.1      cgd nfs_uncompress(m0)
    917   1.1      cgd 	struct mbuf *m0;
    918   1.1      cgd {
    919   1.1      cgd 	register u_char cp, nextcp, *ip, *op;
    920   1.1      cgd 	register struct mbuf *m, *om;
    921   1.1      cgd 	struct mbuf *retm, **mp;
    922   1.1      cgd 	int i, j, noteof, clget, ileft, oleft, olen;
    923   1.1      cgd 
    924   1.1      cgd 	m = m0;
    925   1.1      cgd 	i = 0;
    926   1.1      cgd 	while (m && i < MINCLSIZE) {
    927   1.1      cgd 		i += m->m_len;
    928   1.1      cgd 		m = m->m_next;
    929   1.1      cgd 	}
    930   1.1      cgd 	if (i < 6)
    931   1.1      cgd 		return (m0);
    932   1.1      cgd 	if (i >= MINCLSIZE)
    933   1.1      cgd 		clget = 1;
    934   1.1      cgd 	else
    935   1.1      cgd 		clget = 0;
    936   1.1      cgd 	m = m0;
    937   1.1      cgd 	MGET(om, M_WAIT, MT_DATA);
    938   1.1      cgd 	if (clget)
    939   1.1      cgd 		MCLGET(om, M_WAIT);
    940   1.1      cgd 	olen = om->m_len = 8;
    941   1.1      cgd 	oleft = M_TRAILINGSPACE(om);
    942   1.1      cgd 	op = mtod(om, u_char *);
    943   1.1      cgd 	retm = om;
    944   1.1      cgd 	mp = &om->m_next;
    945   1.1      cgd 	if (m->m_len >= 6) {
    946   1.1      cgd 		ileft = m->m_len - 6;
    947   1.1      cgd 		ip = mtod(m, u_char *);
    948   1.1      cgd 		*((u_long *)op) = *((u_long *)ip);
    949   1.1      cgd 		bzero(op + 4, 3);
    950   1.1      cgd 		ip += 4;
    951   1.1      cgd 		op += 7;
    952   1.1      cgd 		if (*ip == '\0') {
    953   1.1      cgd 			m_freem(om);
    954   1.1      cgd 			return (m0);
    955   1.1      cgd 		}
    956   1.1      cgd 		*op++ = *ip++ - 1;
    957   1.1      cgd 		cp = *ip++;
    958   1.1      cgd 	} else {
    959   1.1      cgd 		ileft = m->m_len;
    960   1.1      cgd 		ip = mtod(m, u_char *);
    961   1.1      cgd 		nfscget(*op++);
    962   1.1      cgd 		nfscget(*op++);
    963   1.1      cgd 		nfscget(*op++);
    964   1.1      cgd 		nfscget(*op++);
    965   1.1      cgd 		bzero(op, 3);
    966   1.1      cgd 		op += 3;
    967   1.1      cgd 		nfscget(*op);
    968   1.1      cgd 		if (*op == '\0') {
    969   1.1      cgd 			m_freem(om);
    970   1.1      cgd 			return (m0);
    971   1.1      cgd 		}
    972   1.1      cgd 		(*op)--;
    973   1.1      cgd 		op++;
    974   1.1      cgd 		nfscget(cp);
    975   1.1      cgd 	}
    976   1.1      cgd 	noteof = 1;
    977   1.1      cgd 	while (noteof) {
    978   1.1      cgd 		if ((cp & NFSCRL) == NFSCRL) {
    979   1.1      cgd 			nfscget(nextcp);
    980   1.1      cgd 			if (cp == nextcp) {
    981   1.1      cgd 				nfscput(cp);
    982   1.1      cgd 				goto readit;
    983   1.1      cgd 			} else {
    984   1.1      cgd 				i = (cp & 0xf) + 2;
    985   1.1      cgd 				for (j = 0; j < i; j++) {
    986   1.1      cgd 					nfscput('\0');
    987   1.1      cgd 				}
    988   1.1      cgd 				cp = nextcp;
    989   1.1      cgd 			}
    990   1.1      cgd 		} else {
    991   1.1      cgd 			nfscput(cp);
    992   1.1      cgd readit:
    993   1.1      cgd 			nfscget(cp);
    994   1.1      cgd 		}
    995   1.1      cgd 	}
    996   1.1      cgd 	m_freem(m0);
    997   1.1      cgd 	if (i = (olen & 0x3))
    998   1.1      cgd 		om->m_len -= i;
    999   1.1      cgd 	return (retm);
   1000   1.1      cgd }
   1001