nfs_subs.c revision 1.14 1 1.14 cgd /* $NetBSD: nfs_subs.c,v 1.14 1994/06/29 06:42:22 cgd Exp $ */
2 1.14 cgd
3 1.1 cgd /*
4 1.12 mycroft * Copyright (c) 1989, 1993
5 1.12 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.1 cgd * 3. All advertising materials mentioning features or use of this software
19 1.1 cgd * must display the following acknowledgement:
20 1.1 cgd * This product includes software developed by the University of
21 1.1 cgd * California, Berkeley and its contributors.
22 1.1 cgd * 4. Neither the name of the University nor the names of its contributors
23 1.1 cgd * may be used to endorse or promote products derived from this software
24 1.1 cgd * without specific prior written permission.
25 1.1 cgd *
26 1.1 cgd * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
27 1.1 cgd * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
28 1.1 cgd * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
29 1.1 cgd * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
30 1.1 cgd * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
31 1.1 cgd * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
32 1.1 cgd * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
33 1.1 cgd * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
34 1.1 cgd * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
35 1.1 cgd * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
36 1.1 cgd * SUCH DAMAGE.
37 1.1 cgd *
38 1.14 cgd * @(#)nfs_subs.c 8.3 (Berkeley) 1/4/94
39 1.1 cgd */
40 1.1 cgd
41 1.1 cgd /*
42 1.1 cgd * These functions support the macros and help fiddle mbuf chains for
43 1.1 cgd * the nfs op functions. They do things like create the rpc header and
44 1.1 cgd * copy data between mbuf chains and uio lists.
45 1.1 cgd */
46 1.9 mycroft #include <sys/param.h>
47 1.9 mycroft #include <sys/proc.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/vnode.h>
52 1.9 mycroft #include <sys/namei.h>
53 1.9 mycroft #include <sys/mbuf.h>
54 1.12 mycroft #include <sys/socket.h>
55 1.12 mycroft #include <sys/stat.h>
56 1.1 cgd
57 1.9 mycroft #include <nfs/rpcv2.h>
58 1.9 mycroft #include <nfs/nfsv2.h>
59 1.9 mycroft #include <nfs/nfsnode.h>
60 1.9 mycroft #include <nfs/nfs.h>
61 1.9 mycroft #include <nfs/xdr_subs.h>
62 1.9 mycroft #include <nfs/nfsm_subs.h>
63 1.12 mycroft #include <nfs/nfsmount.h>
64 1.12 mycroft #include <nfs/nqnfs.h>
65 1.12 mycroft #include <nfs/nfsrtt.h>
66 1.12 mycroft
67 1.12 mycroft #include <miscfs/specfs/specdev.h>
68 1.12 mycroft
69 1.12 mycroft #include <netinet/in.h>
70 1.12 mycroft #ifdef ISO
71 1.12 mycroft #include <netiso/iso.h>
72 1.12 mycroft #endif
73 1.1 cgd
74 1.1 cgd #define TRUE 1
75 1.1 cgd #define FALSE 0
76 1.1 cgd
77 1.1 cgd /*
78 1.1 cgd * Data items converted to xdr at startup, since they are constant
79 1.1 cgd * This is kinda hokey, but may save a little time doing byte swaps
80 1.1 cgd */
81 1.1 cgd u_long nfs_procids[NFS_NPROCS];
82 1.1 cgd u_long nfs_xdrneg1;
83 1.12 mycroft u_long rpc_call, rpc_vers, rpc_reply, rpc_msgdenied, rpc_autherr,
84 1.12 mycroft rpc_mismatch, rpc_auth_unix, rpc_msgaccepted, rpc_rejectedcred,
85 1.12 mycroft rpc_auth_kerb;
86 1.1 cgd u_long nfs_vers, nfs_prog, nfs_true, nfs_false;
87 1.12 mycroft
88 1.1 cgd /* And other global data */
89 1.12 mycroft static u_long nfs_xid = 0;
90 1.12 mycroft enum vtype ntov_type[7] = { VNON, VREG, VDIR, VBLK, VCHR, VLNK, VNON };
91 1.1 cgd extern struct proc *nfs_iodwant[NFS_MAXASYNCDAEMON];
92 1.1 cgd extern struct nfsreq nfsreqh;
93 1.12 mycroft extern int nqnfs_piggy[NFS_NPROCS];
94 1.12 mycroft extern struct nfsrtt nfsrtt;
95 1.12 mycroft extern time_t nqnfsstarttime;
96 1.12 mycroft extern u_long nqnfs_prog, nqnfs_vers;
97 1.12 mycroft extern int nqsrv_clockskew;
98 1.12 mycroft extern int nqsrv_writeslack;
99 1.12 mycroft extern int nqsrv_maxlease;
100 1.1 cgd
101 1.1 cgd /*
102 1.1 cgd * Create the header for an rpc request packet
103 1.1 cgd * The hsiz is the size of the rest of the nfs request header.
104 1.1 cgd * (just used to decide if a cluster is a good idea)
105 1.1 cgd */
106 1.12 mycroft struct mbuf *
107 1.12 mycroft nfsm_reqh(vp, procid, hsiz, bposp)
108 1.12 mycroft struct vnode *vp;
109 1.1 cgd u_long procid;
110 1.1 cgd int hsiz;
111 1.12 mycroft caddr_t *bposp;
112 1.12 mycroft {
113 1.12 mycroft register struct mbuf *mb;
114 1.12 mycroft register u_long *tl;
115 1.12 mycroft register caddr_t bpos;
116 1.12 mycroft struct mbuf *mb2;
117 1.12 mycroft struct nfsmount *nmp;
118 1.12 mycroft int nqflag;
119 1.12 mycroft
120 1.12 mycroft MGET(mb, M_WAIT, MT_DATA);
121 1.12 mycroft if (hsiz >= MINCLSIZE)
122 1.12 mycroft MCLGET(mb, M_WAIT);
123 1.12 mycroft mb->m_len = 0;
124 1.12 mycroft bpos = mtod(mb, caddr_t);
125 1.12 mycroft
126 1.12 mycroft /*
127 1.12 mycroft * For NQNFS, add lease request.
128 1.12 mycroft */
129 1.12 mycroft if (vp) {
130 1.12 mycroft nmp = VFSTONFS(vp->v_mount);
131 1.12 mycroft if (nmp->nm_flag & NFSMNT_NQNFS) {
132 1.12 mycroft nqflag = NQNFS_NEEDLEASE(vp, procid);
133 1.12 mycroft if (nqflag) {
134 1.12 mycroft nfsm_build(tl, u_long *, 2*NFSX_UNSIGNED);
135 1.12 mycroft *tl++ = txdr_unsigned(nqflag);
136 1.12 mycroft *tl = txdr_unsigned(nmp->nm_leaseterm);
137 1.12 mycroft } else {
138 1.12 mycroft nfsm_build(tl, u_long *, NFSX_UNSIGNED);
139 1.12 mycroft *tl = 0;
140 1.12 mycroft }
141 1.12 mycroft }
142 1.12 mycroft }
143 1.12 mycroft /* Finally, return values */
144 1.12 mycroft *bposp = bpos;
145 1.12 mycroft return (mb);
146 1.12 mycroft }
147 1.12 mycroft
148 1.12 mycroft /*
149 1.12 mycroft * Build the RPC header and fill in the authorization info.
150 1.12 mycroft * The authorization string argument is only used when the credentials
151 1.12 mycroft * come from outside of the kernel.
152 1.12 mycroft * Returns the head of the mbuf list.
153 1.12 mycroft */
154 1.12 mycroft struct mbuf *
155 1.12 mycroft nfsm_rpchead(cr, nqnfs, procid, auth_type, auth_len, auth_str, mrest,
156 1.12 mycroft mrest_len, mbp, xidp)
157 1.12 mycroft register struct ucred *cr;
158 1.12 mycroft int nqnfs;
159 1.12 mycroft int procid;
160 1.12 mycroft int auth_type;
161 1.12 mycroft int auth_len;
162 1.12 mycroft char *auth_str;
163 1.12 mycroft struct mbuf *mrest;
164 1.12 mycroft int mrest_len;
165 1.12 mycroft struct mbuf **mbp;
166 1.12 mycroft u_long *xidp;
167 1.1 cgd {
168 1.12 mycroft register struct mbuf *mb;
169 1.1 cgd register u_long *tl;
170 1.12 mycroft register caddr_t bpos;
171 1.12 mycroft register int i;
172 1.12 mycroft struct mbuf *mreq, *mb2;
173 1.12 mycroft int siz, grpsiz, authsiz;
174 1.1 cgd
175 1.12 mycroft authsiz = nfsm_rndup(auth_len);
176 1.12 mycroft if (auth_type == RPCAUTH_NQNFS)
177 1.12 mycroft authsiz += 2 * NFSX_UNSIGNED;
178 1.12 mycroft MGETHDR(mb, M_WAIT, MT_DATA);
179 1.12 mycroft if ((authsiz + 10*NFSX_UNSIGNED) >= MINCLSIZE) {
180 1.12 mycroft MCLGET(mb, M_WAIT);
181 1.12 mycroft } else if ((authsiz + 10*NFSX_UNSIGNED) < MHLEN) {
182 1.12 mycroft MH_ALIGN(mb, authsiz + 10*NFSX_UNSIGNED);
183 1.12 mycroft } else {
184 1.12 mycroft MH_ALIGN(mb, 8*NFSX_UNSIGNED);
185 1.1 cgd }
186 1.12 mycroft mb->m_len = 0;
187 1.12 mycroft mreq = mb;
188 1.12 mycroft bpos = mtod(mb, caddr_t);
189 1.12 mycroft
190 1.12 mycroft /*
191 1.12 mycroft * First the RPC header.
192 1.12 mycroft */
193 1.12 mycroft nfsm_build(tl, u_long *, 8*NFSX_UNSIGNED);
194 1.12 mycroft if (++nfs_xid == 0)
195 1.12 mycroft nfs_xid++;
196 1.12 mycroft *tl++ = *xidp = txdr_unsigned(nfs_xid);
197 1.1 cgd *tl++ = rpc_call;
198 1.1 cgd *tl++ = rpc_vers;
199 1.12 mycroft if (nqnfs) {
200 1.12 mycroft *tl++ = txdr_unsigned(NQNFS_PROG);
201 1.12 mycroft *tl++ = txdr_unsigned(NQNFS_VER1);
202 1.1 cgd } else {
203 1.12 mycroft *tl++ = txdr_unsigned(NFS_PROG);
204 1.12 mycroft *tl++ = txdr_unsigned(NFS_VER2);
205 1.1 cgd }
206 1.12 mycroft *tl++ = txdr_unsigned(procid);
207 1.12 mycroft
208 1.12 mycroft /*
209 1.12 mycroft * And then the authorization cred.
210 1.12 mycroft */
211 1.12 mycroft *tl++ = txdr_unsigned(auth_type);
212 1.12 mycroft *tl = txdr_unsigned(authsiz);
213 1.12 mycroft switch (auth_type) {
214 1.12 mycroft case RPCAUTH_UNIX:
215 1.12 mycroft nfsm_build(tl, u_long *, auth_len);
216 1.12 mycroft *tl++ = 0; /* stamp ?? */
217 1.12 mycroft *tl++ = 0; /* NULL hostname */
218 1.12 mycroft *tl++ = txdr_unsigned(cr->cr_uid);
219 1.12 mycroft *tl++ = txdr_unsigned(cr->cr_groups[0]);
220 1.12 mycroft grpsiz = (auth_len >> 2) - 5;
221 1.12 mycroft *tl++ = txdr_unsigned(grpsiz);
222 1.12 mycroft for (i = 1; i <= grpsiz; i++)
223 1.12 mycroft *tl++ = txdr_unsigned(cr->cr_groups[i]);
224 1.12 mycroft break;
225 1.12 mycroft case RPCAUTH_NQNFS:
226 1.12 mycroft nfsm_build(tl, u_long *, 2*NFSX_UNSIGNED);
227 1.12 mycroft *tl++ = txdr_unsigned(cr->cr_uid);
228 1.12 mycroft *tl = txdr_unsigned(auth_len);
229 1.12 mycroft siz = auth_len;
230 1.12 mycroft while (siz > 0) {
231 1.12 mycroft if (M_TRAILINGSPACE(mb) == 0) {
232 1.12 mycroft MGET(mb2, M_WAIT, MT_DATA);
233 1.12 mycroft if (siz >= MINCLSIZE)
234 1.12 mycroft MCLGET(mb2, M_WAIT);
235 1.12 mycroft mb->m_next = mb2;
236 1.12 mycroft mb = mb2;
237 1.12 mycroft mb->m_len = 0;
238 1.12 mycroft bpos = mtod(mb, caddr_t);
239 1.12 mycroft }
240 1.12 mycroft i = min(siz, M_TRAILINGSPACE(mb));
241 1.12 mycroft bcopy(auth_str, bpos, i);
242 1.12 mycroft mb->m_len += i;
243 1.12 mycroft auth_str += i;
244 1.12 mycroft bpos += i;
245 1.12 mycroft siz -= i;
246 1.12 mycroft }
247 1.12 mycroft if ((siz = (nfsm_rndup(auth_len) - auth_len)) > 0) {
248 1.12 mycroft for (i = 0; i < siz; i++)
249 1.12 mycroft *bpos++ = '\0';
250 1.12 mycroft mb->m_len += siz;
251 1.12 mycroft }
252 1.12 mycroft break;
253 1.12 mycroft };
254 1.12 mycroft nfsm_build(tl, u_long *, 2*NFSX_UNSIGNED);
255 1.12 mycroft *tl++ = txdr_unsigned(RPCAUTH_NULL);
256 1.12 mycroft *tl = 0;
257 1.12 mycroft mb->m_next = mrest;
258 1.12 mycroft mreq->m_pkthdr.len = authsiz + 10*NFSX_UNSIGNED + mrest_len;
259 1.12 mycroft mreq->m_pkthdr.rcvif = (struct ifnet *)0;
260 1.12 mycroft *mbp = mb;
261 1.1 cgd return (mreq);
262 1.1 cgd }
263 1.1 cgd
264 1.1 cgd /*
265 1.1 cgd * copies mbuf chain to the uio scatter/gather list
266 1.1 cgd */
267 1.1 cgd nfsm_mbuftouio(mrep, uiop, siz, dpos)
268 1.1 cgd struct mbuf **mrep;
269 1.1 cgd register struct uio *uiop;
270 1.1 cgd int siz;
271 1.1 cgd caddr_t *dpos;
272 1.1 cgd {
273 1.1 cgd register char *mbufcp, *uiocp;
274 1.1 cgd register int xfer, left, len;
275 1.1 cgd register struct mbuf *mp;
276 1.1 cgd long uiosiz, rem;
277 1.1 cgd int error = 0;
278 1.1 cgd
279 1.1 cgd mp = *mrep;
280 1.1 cgd mbufcp = *dpos;
281 1.1 cgd len = mtod(mp, caddr_t)+mp->m_len-mbufcp;
282 1.1 cgd rem = nfsm_rndup(siz)-siz;
283 1.1 cgd while (siz > 0) {
284 1.1 cgd if (uiop->uio_iovcnt <= 0 || uiop->uio_iov == NULL)
285 1.1 cgd return (EFBIG);
286 1.1 cgd left = uiop->uio_iov->iov_len;
287 1.1 cgd uiocp = uiop->uio_iov->iov_base;
288 1.1 cgd if (left > siz)
289 1.1 cgd left = siz;
290 1.1 cgd uiosiz = left;
291 1.1 cgd while (left > 0) {
292 1.1 cgd while (len == 0) {
293 1.1 cgd mp = mp->m_next;
294 1.1 cgd if (mp == NULL)
295 1.1 cgd return (EBADRPC);
296 1.1 cgd mbufcp = mtod(mp, caddr_t);
297 1.1 cgd len = mp->m_len;
298 1.1 cgd }
299 1.1 cgd xfer = (left > len) ? len : left;
300 1.1 cgd #ifdef notdef
301 1.1 cgd /* Not Yet.. */
302 1.1 cgd if (uiop->uio_iov->iov_op != NULL)
303 1.1 cgd (*(uiop->uio_iov->iov_op))
304 1.1 cgd (mbufcp, uiocp, xfer);
305 1.1 cgd else
306 1.1 cgd #endif
307 1.1 cgd if (uiop->uio_segflg == UIO_SYSSPACE)
308 1.1 cgd bcopy(mbufcp, uiocp, xfer);
309 1.1 cgd else
310 1.1 cgd copyout(mbufcp, uiocp, xfer);
311 1.1 cgd left -= xfer;
312 1.1 cgd len -= xfer;
313 1.1 cgd mbufcp += xfer;
314 1.1 cgd uiocp += xfer;
315 1.1 cgd uiop->uio_offset += xfer;
316 1.1 cgd uiop->uio_resid -= xfer;
317 1.1 cgd }
318 1.1 cgd if (uiop->uio_iov->iov_len <= siz) {
319 1.1 cgd uiop->uio_iovcnt--;
320 1.1 cgd uiop->uio_iov++;
321 1.1 cgd } else {
322 1.1 cgd uiop->uio_iov->iov_base += uiosiz;
323 1.1 cgd uiop->uio_iov->iov_len -= uiosiz;
324 1.1 cgd }
325 1.1 cgd siz -= uiosiz;
326 1.1 cgd }
327 1.1 cgd *dpos = mbufcp;
328 1.1 cgd *mrep = mp;
329 1.1 cgd if (rem > 0) {
330 1.1 cgd if (len < rem)
331 1.1 cgd error = nfs_adv(mrep, dpos, rem, len);
332 1.1 cgd else
333 1.1 cgd *dpos += rem;
334 1.1 cgd }
335 1.1 cgd return (error);
336 1.1 cgd }
337 1.1 cgd
338 1.1 cgd /*
339 1.1 cgd * copies a uio scatter/gather list to an mbuf chain...
340 1.1 cgd */
341 1.1 cgd nfsm_uiotombuf(uiop, mq, siz, bpos)
342 1.1 cgd register struct uio *uiop;
343 1.1 cgd struct mbuf **mq;
344 1.1 cgd int siz;
345 1.1 cgd caddr_t *bpos;
346 1.1 cgd {
347 1.1 cgd register char *uiocp;
348 1.1 cgd register struct mbuf *mp, *mp2;
349 1.12 mycroft register int xfer, left, mlen;
350 1.1 cgd int uiosiz, clflg, rem;
351 1.1 cgd char *cp;
352 1.1 cgd
353 1.1 cgd if (siz > MLEN) /* or should it >= MCLBYTES ?? */
354 1.1 cgd clflg = 1;
355 1.1 cgd else
356 1.1 cgd clflg = 0;
357 1.1 cgd rem = nfsm_rndup(siz)-siz;
358 1.12 mycroft mp = mp2 = *mq;
359 1.1 cgd while (siz > 0) {
360 1.1 cgd if (uiop->uio_iovcnt <= 0 || uiop->uio_iov == NULL)
361 1.1 cgd return (EINVAL);
362 1.1 cgd left = uiop->uio_iov->iov_len;
363 1.1 cgd uiocp = uiop->uio_iov->iov_base;
364 1.1 cgd if (left > siz)
365 1.1 cgd left = siz;
366 1.1 cgd uiosiz = left;
367 1.1 cgd while (left > 0) {
368 1.12 mycroft mlen = M_TRAILINGSPACE(mp);
369 1.12 mycroft if (mlen == 0) {
370 1.12 mycroft MGET(mp, M_WAIT, MT_DATA);
371 1.12 mycroft if (clflg)
372 1.12 mycroft MCLGET(mp, M_WAIT);
373 1.12 mycroft mp->m_len = 0;
374 1.12 mycroft mp2->m_next = mp;
375 1.12 mycroft mp2 = mp;
376 1.12 mycroft mlen = M_TRAILINGSPACE(mp);
377 1.12 mycroft }
378 1.12 mycroft xfer = (left > mlen) ? mlen : left;
379 1.1 cgd #ifdef notdef
380 1.1 cgd /* Not Yet.. */
381 1.1 cgd if (uiop->uio_iov->iov_op != NULL)
382 1.1 cgd (*(uiop->uio_iov->iov_op))
383 1.12 mycroft (uiocp, mtod(mp, caddr_t)+mp->m_len, xfer);
384 1.1 cgd else
385 1.1 cgd #endif
386 1.1 cgd if (uiop->uio_segflg == UIO_SYSSPACE)
387 1.12 mycroft bcopy(uiocp, mtod(mp, caddr_t)+mp->m_len, xfer);
388 1.1 cgd else
389 1.12 mycroft copyin(uiocp, mtod(mp, caddr_t)+mp->m_len, xfer);
390 1.12 mycroft mp->m_len += xfer;
391 1.1 cgd left -= xfer;
392 1.1 cgd uiocp += xfer;
393 1.1 cgd uiop->uio_offset += xfer;
394 1.1 cgd uiop->uio_resid -= xfer;
395 1.1 cgd }
396 1.1 cgd if (uiop->uio_iov->iov_len <= siz) {
397 1.1 cgd uiop->uio_iovcnt--;
398 1.1 cgd uiop->uio_iov++;
399 1.1 cgd } else {
400 1.1 cgd uiop->uio_iov->iov_base += uiosiz;
401 1.1 cgd uiop->uio_iov->iov_len -= uiosiz;
402 1.1 cgd }
403 1.1 cgd siz -= uiosiz;
404 1.1 cgd }
405 1.1 cgd if (rem > 0) {
406 1.12 mycroft if (rem > M_TRAILINGSPACE(mp)) {
407 1.1 cgd MGET(mp, M_WAIT, MT_DATA);
408 1.1 cgd mp->m_len = 0;
409 1.1 cgd mp2->m_next = mp;
410 1.1 cgd }
411 1.1 cgd cp = mtod(mp, caddr_t)+mp->m_len;
412 1.1 cgd for (left = 0; left < rem; left++)
413 1.1 cgd *cp++ = '\0';
414 1.1 cgd mp->m_len += rem;
415 1.1 cgd *bpos = cp;
416 1.1 cgd } else
417 1.1 cgd *bpos = mtod(mp, caddr_t)+mp->m_len;
418 1.1 cgd *mq = mp;
419 1.1 cgd return (0);
420 1.1 cgd }
421 1.1 cgd
422 1.1 cgd /*
423 1.1 cgd * Help break down an mbuf chain by setting the first siz bytes contiguous
424 1.1 cgd * pointed to by returned val.
425 1.12 mycroft * This is used by the macros nfsm_dissect and nfsm_dissecton for tough
426 1.1 cgd * cases. (The macros use the vars. dpos and dpos2)
427 1.1 cgd */
428 1.12 mycroft nfsm_disct(mdp, dposp, siz, left, cp2)
429 1.1 cgd struct mbuf **mdp;
430 1.1 cgd caddr_t *dposp;
431 1.1 cgd int siz;
432 1.1 cgd int left;
433 1.1 cgd caddr_t *cp2;
434 1.1 cgd {
435 1.1 cgd register struct mbuf *mp, *mp2;
436 1.1 cgd register int siz2, xfer;
437 1.12 mycroft register caddr_t p;
438 1.1 cgd
439 1.1 cgd mp = *mdp;
440 1.1 cgd while (left == 0) {
441 1.1 cgd *mdp = mp = mp->m_next;
442 1.1 cgd if (mp == NULL)
443 1.1 cgd return (EBADRPC);
444 1.1 cgd left = mp->m_len;
445 1.1 cgd *dposp = mtod(mp, caddr_t);
446 1.1 cgd }
447 1.1 cgd if (left >= siz) {
448 1.1 cgd *cp2 = *dposp;
449 1.1 cgd *dposp += siz;
450 1.1 cgd } else if (mp->m_next == NULL) {
451 1.1 cgd return (EBADRPC);
452 1.1 cgd } else if (siz > MHLEN) {
453 1.1 cgd panic("nfs S too big");
454 1.1 cgd } else {
455 1.12 mycroft MGET(mp2, M_WAIT, MT_DATA);
456 1.12 mycroft mp2->m_next = mp->m_next;
457 1.12 mycroft mp->m_next = mp2;
458 1.12 mycroft mp->m_len -= left;
459 1.12 mycroft mp = mp2;
460 1.12 mycroft *cp2 = p = mtod(mp, caddr_t);
461 1.12 mycroft bcopy(*dposp, p, left); /* Copy what was left */
462 1.1 cgd siz2 = siz-left;
463 1.12 mycroft p += left;
464 1.1 cgd mp2 = mp->m_next;
465 1.1 cgd /* Loop around copying up the siz2 bytes */
466 1.1 cgd while (siz2 > 0) {
467 1.1 cgd if (mp2 == NULL)
468 1.1 cgd return (EBADRPC);
469 1.1 cgd xfer = (siz2 > mp2->m_len) ? mp2->m_len : siz2;
470 1.1 cgd if (xfer > 0) {
471 1.12 mycroft bcopy(mtod(mp2, caddr_t), p, xfer);
472 1.1 cgd NFSMADV(mp2, xfer);
473 1.1 cgd mp2->m_len -= xfer;
474 1.12 mycroft p += xfer;
475 1.1 cgd siz2 -= xfer;
476 1.1 cgd }
477 1.1 cgd if (siz2 > 0)
478 1.1 cgd mp2 = mp2->m_next;
479 1.1 cgd }
480 1.1 cgd mp->m_len = siz;
481 1.1 cgd *mdp = mp2;
482 1.1 cgd *dposp = mtod(mp2, caddr_t);
483 1.1 cgd }
484 1.1 cgd return (0);
485 1.1 cgd }
486 1.1 cgd
487 1.1 cgd /*
488 1.1 cgd * Advance the position in the mbuf chain.
489 1.1 cgd */
490 1.1 cgd nfs_adv(mdp, dposp, offs, left)
491 1.1 cgd struct mbuf **mdp;
492 1.1 cgd caddr_t *dposp;
493 1.1 cgd int offs;
494 1.1 cgd int left;
495 1.1 cgd {
496 1.1 cgd register struct mbuf *m;
497 1.1 cgd register int s;
498 1.1 cgd
499 1.1 cgd m = *mdp;
500 1.1 cgd s = left;
501 1.1 cgd while (s < offs) {
502 1.1 cgd offs -= s;
503 1.1 cgd m = m->m_next;
504 1.1 cgd if (m == NULL)
505 1.1 cgd return (EBADRPC);
506 1.1 cgd s = m->m_len;
507 1.1 cgd }
508 1.1 cgd *mdp = m;
509 1.1 cgd *dposp = mtod(m, caddr_t)+offs;
510 1.1 cgd return (0);
511 1.1 cgd }
512 1.1 cgd
513 1.1 cgd /*
514 1.1 cgd * Copy a string into mbufs for the hard cases...
515 1.1 cgd */
516 1.1 cgd nfsm_strtmbuf(mb, bpos, cp, siz)
517 1.1 cgd struct mbuf **mb;
518 1.1 cgd char **bpos;
519 1.1 cgd char *cp;
520 1.1 cgd long siz;
521 1.1 cgd {
522 1.1 cgd register struct mbuf *m1, *m2;
523 1.1 cgd long left, xfer, len, tlen;
524 1.1 cgd u_long *tl;
525 1.1 cgd int putsize;
526 1.1 cgd
527 1.1 cgd putsize = 1;
528 1.1 cgd m2 = *mb;
529 1.12 mycroft left = M_TRAILINGSPACE(m2);
530 1.1 cgd if (left > 0) {
531 1.1 cgd tl = ((u_long *)(*bpos));
532 1.1 cgd *tl++ = txdr_unsigned(siz);
533 1.1 cgd putsize = 0;
534 1.1 cgd left -= NFSX_UNSIGNED;
535 1.1 cgd m2->m_len += NFSX_UNSIGNED;
536 1.1 cgd if (left > 0) {
537 1.1 cgd bcopy(cp, (caddr_t) tl, left);
538 1.1 cgd siz -= left;
539 1.1 cgd cp += left;
540 1.1 cgd m2->m_len += left;
541 1.1 cgd left = 0;
542 1.1 cgd }
543 1.1 cgd }
544 1.12 mycroft /* Loop around adding mbufs */
545 1.1 cgd while (siz > 0) {
546 1.1 cgd MGET(m1, M_WAIT, MT_DATA);
547 1.1 cgd if (siz > MLEN)
548 1.1 cgd MCLGET(m1, M_WAIT);
549 1.1 cgd m1->m_len = NFSMSIZ(m1);
550 1.1 cgd m2->m_next = m1;
551 1.1 cgd m2 = m1;
552 1.1 cgd tl = mtod(m1, u_long *);
553 1.1 cgd tlen = 0;
554 1.1 cgd if (putsize) {
555 1.1 cgd *tl++ = txdr_unsigned(siz);
556 1.1 cgd m1->m_len -= NFSX_UNSIGNED;
557 1.1 cgd tlen = NFSX_UNSIGNED;
558 1.1 cgd putsize = 0;
559 1.1 cgd }
560 1.1 cgd if (siz < m1->m_len) {
561 1.1 cgd len = nfsm_rndup(siz);
562 1.1 cgd xfer = siz;
563 1.1 cgd if (xfer < len)
564 1.1 cgd *(tl+(xfer>>2)) = 0;
565 1.1 cgd } else {
566 1.1 cgd xfer = len = m1->m_len;
567 1.1 cgd }
568 1.1 cgd bcopy(cp, (caddr_t) tl, xfer);
569 1.1 cgd m1->m_len = len+tlen;
570 1.1 cgd siz -= xfer;
571 1.1 cgd cp += xfer;
572 1.1 cgd }
573 1.1 cgd *mb = m1;
574 1.1 cgd *bpos = mtod(m1, caddr_t)+m1->m_len;
575 1.1 cgd return (0);
576 1.1 cgd }
577 1.1 cgd
578 1.1 cgd /*
579 1.1 cgd * Called once to initialize data structures...
580 1.1 cgd */
581 1.1 cgd nfs_init()
582 1.1 cgd {
583 1.1 cgd register int i;
584 1.1 cgd
585 1.12 mycroft nfsrtt.pos = 0;
586 1.1 cgd rpc_vers = txdr_unsigned(RPC_VER2);
587 1.1 cgd rpc_call = txdr_unsigned(RPC_CALL);
588 1.1 cgd rpc_reply = txdr_unsigned(RPC_REPLY);
589 1.1 cgd rpc_msgdenied = txdr_unsigned(RPC_MSGDENIED);
590 1.1 cgd rpc_msgaccepted = txdr_unsigned(RPC_MSGACCEPTED);
591 1.1 cgd rpc_mismatch = txdr_unsigned(RPC_MISMATCH);
592 1.12 mycroft rpc_autherr = txdr_unsigned(RPC_AUTHERR);
593 1.12 mycroft rpc_rejectedcred = txdr_unsigned(AUTH_REJECTCRED);
594 1.1 cgd rpc_auth_unix = txdr_unsigned(RPCAUTH_UNIX);
595 1.12 mycroft rpc_auth_kerb = txdr_unsigned(RPCAUTH_NQNFS);
596 1.1 cgd nfs_vers = txdr_unsigned(NFS_VER2);
597 1.1 cgd nfs_prog = txdr_unsigned(NFS_PROG);
598 1.1 cgd nfs_true = txdr_unsigned(TRUE);
599 1.1 cgd nfs_false = txdr_unsigned(FALSE);
600 1.12 mycroft nfs_xdrneg1 = txdr_unsigned(-1);
601 1.1 cgd /* Loop thru nfs procids */
602 1.1 cgd for (i = 0; i < NFS_NPROCS; i++)
603 1.1 cgd nfs_procids[i] = txdr_unsigned(i);
604 1.12 mycroft #ifdef NFSCLIENT
605 1.1 cgd /* Ensure async daemons disabled */
606 1.1 cgd for (i = 0; i < NFS_MAXASYNCDAEMON; i++)
607 1.1 cgd nfs_iodwant[i] = (struct proc *)0;
608 1.12 mycroft TAILQ_INIT(&nfs_bufq);
609 1.1 cgd nfs_nhinit(); /* Init the nfsnode table */
610 1.13 mycroft #endif /* NFSCLIENT */
611 1.2 glass #ifdef NFSSERVER
612 1.12 mycroft nfsrv_init(0); /* Init server data structures */
613 1.1 cgd nfsrv_initcache(); /* Init the server request cache */
614 1.13 mycroft #endif /* NFSSERVER */
615 1.12 mycroft
616 1.12 mycroft /*
617 1.12 mycroft * Initialize the nqnfs server stuff.
618 1.12 mycroft */
619 1.12 mycroft if (nqnfsstarttime == 0) {
620 1.12 mycroft nqnfsstarttime = boottime.tv_sec + nqsrv_maxlease
621 1.12 mycroft + nqsrv_clockskew + nqsrv_writeslack;
622 1.12 mycroft NQLOADNOVRAM(nqnfsstarttime);
623 1.12 mycroft nqnfs_prog = txdr_unsigned(NQNFS_PROG);
624 1.12 mycroft nqnfs_vers = txdr_unsigned(NQNFS_VER1);
625 1.12 mycroft nqthead.th_head[0] = &nqthead;
626 1.12 mycroft nqthead.th_head[1] = &nqthead;
627 1.12 mycroft nqfhead = hashinit(NQLCHSZ, M_NQLEASE, &nqfheadhash);
628 1.12 mycroft }
629 1.12 mycroft
630 1.1 cgd /*
631 1.1 cgd * Initialize reply list and start timer
632 1.1 cgd */
633 1.1 cgd nfsreqh.r_prev = nfsreqh.r_next = &nfsreqh;
634 1.1 cgd nfs_timer();
635 1.1 cgd }
636 1.1 cgd
637 1.12 mycroft #ifdef NFSCLIENT
638 1.1 cgd /*
639 1.12 mycroft * Attribute cache routines.
640 1.12 mycroft * nfs_loadattrcache() - loads or updates the cache contents from attributes
641 1.12 mycroft * that are on the mbuf list
642 1.12 mycroft * nfs_getattrcache() - returns valid attributes if found in cache, returns
643 1.12 mycroft * error otherwise
644 1.1 cgd */
645 1.12 mycroft
646 1.12 mycroft /*
647 1.12 mycroft * Load the attribute cache (that lives in the nfsnode entry) with
648 1.12 mycroft * the values on the mbuf list and
649 1.12 mycroft * Iff vap not NULL
650 1.12 mycroft * copy the attributes to *vaper
651 1.12 mycroft */
652 1.12 mycroft nfs_loadattrcache(vpp, mdp, dposp, vaper)
653 1.12 mycroft struct vnode **vpp;
654 1.12 mycroft struct mbuf **mdp;
655 1.12 mycroft caddr_t *dposp;
656 1.12 mycroft struct vattr *vaper;
657 1.1 cgd {
658 1.12 mycroft register struct vnode *vp = *vpp;
659 1.12 mycroft register struct vattr *vap;
660 1.12 mycroft register struct nfsv2_fattr *fp;
661 1.12 mycroft extern int (**spec_nfsv2nodeop_p)();
662 1.12 mycroft register struct nfsnode *np, *nq, **nhpp;
663 1.12 mycroft register long t1;
664 1.12 mycroft caddr_t dpos, cp2;
665 1.12 mycroft int error = 0, isnq;
666 1.12 mycroft struct mbuf *md;
667 1.12 mycroft enum vtype vtyp;
668 1.12 mycroft u_short vmode;
669 1.12 mycroft long rdev;
670 1.12 mycroft struct timespec mtime;
671 1.12 mycroft struct vnode *nvp;
672 1.1 cgd
673 1.12 mycroft md = *mdp;
674 1.12 mycroft dpos = *dposp;
675 1.12 mycroft t1 = (mtod(md, caddr_t) + md->m_len) - dpos;
676 1.12 mycroft isnq = (VFSTONFS(vp->v_mount)->nm_flag & NFSMNT_NQNFS);
677 1.12 mycroft if (error = nfsm_disct(&md, &dpos, NFSX_FATTR(isnq), t1, &cp2))
678 1.12 mycroft return (error);
679 1.12 mycroft fp = (struct nfsv2_fattr *)cp2;
680 1.12 mycroft vtyp = nfstov_type(fp->fa_type);
681 1.12 mycroft vmode = fxdr_unsigned(u_short, fp->fa_mode);
682 1.12 mycroft if (vtyp == VNON || vtyp == VREG)
683 1.12 mycroft vtyp = IFTOVT(vmode);
684 1.12 mycroft if (isnq) {
685 1.12 mycroft rdev = fxdr_unsigned(long, fp->fa_nqrdev);
686 1.12 mycroft fxdr_nqtime(&fp->fa_nqmtime, &mtime);
687 1.12 mycroft } else {
688 1.12 mycroft rdev = fxdr_unsigned(long, fp->fa_nfsrdev);
689 1.12 mycroft fxdr_nfstime(&fp->fa_nfsmtime, &mtime);
690 1.12 mycroft }
691 1.12 mycroft /*
692 1.12 mycroft * If v_type == VNON it is a new node, so fill in the v_type,
693 1.12 mycroft * n_mtime fields. Check to see if it represents a special
694 1.12 mycroft * device, and if so, check for a possible alias. Once the
695 1.12 mycroft * correct vnode has been obtained, fill in the rest of the
696 1.12 mycroft * information.
697 1.12 mycroft */
698 1.12 mycroft np = VTONFS(vp);
699 1.12 mycroft if (vp->v_type == VNON) {
700 1.12 mycroft if (vtyp == VCHR && rdev == 0xffffffff)
701 1.12 mycroft vp->v_type = vtyp = VFIFO;
702 1.12 mycroft else
703 1.12 mycroft vp->v_type = vtyp;
704 1.12 mycroft if (vp->v_type == VFIFO) {
705 1.12 mycroft #ifdef FIFO
706 1.12 mycroft extern int (**fifo_nfsv2nodeop_p)();
707 1.12 mycroft vp->v_op = fifo_nfsv2nodeop_p;
708 1.1 cgd #else
709 1.12 mycroft return (EOPNOTSUPP);
710 1.12 mycroft #endif /* FIFO */
711 1.12 mycroft }
712 1.12 mycroft if (vp->v_type == VCHR || vp->v_type == VBLK) {
713 1.12 mycroft vp->v_op = spec_nfsv2nodeop_p;
714 1.12 mycroft if (nvp = checkalias(vp, (dev_t)rdev, vp->v_mount)) {
715 1.12 mycroft /*
716 1.12 mycroft * Discard unneeded vnode, but save its nfsnode.
717 1.12 mycroft */
718 1.12 mycroft if (nq = np->n_forw)
719 1.12 mycroft nq->n_back = np->n_back;
720 1.12 mycroft *np->n_back = nq;
721 1.12 mycroft nvp->v_data = vp->v_data;
722 1.12 mycroft vp->v_data = NULL;
723 1.12 mycroft vp->v_op = spec_vnodeop_p;
724 1.12 mycroft vrele(vp);
725 1.12 mycroft vgone(vp);
726 1.12 mycroft /*
727 1.12 mycroft * Reinitialize aliased node.
728 1.12 mycroft */
729 1.12 mycroft np->n_vnode = nvp;
730 1.12 mycroft nhpp = (struct nfsnode **)nfs_hash(&np->n_fh);
731 1.12 mycroft if (nq = *nhpp)
732 1.12 mycroft nq->n_back = &np->n_forw;
733 1.12 mycroft np->n_forw = nq;
734 1.12 mycroft np->n_back = nhpp;
735 1.12 mycroft *nhpp = np;
736 1.12 mycroft *vpp = vp = nvp;
737 1.12 mycroft }
738 1.12 mycroft }
739 1.12 mycroft np->n_mtime = mtime.ts_sec;
740 1.12 mycroft }
741 1.12 mycroft vap = &np->n_vattr;
742 1.12 mycroft vap->va_type = vtyp;
743 1.12 mycroft vap->va_mode = (vmode & 07777);
744 1.12 mycroft vap->va_nlink = fxdr_unsigned(u_short, fp->fa_nlink);
745 1.12 mycroft vap->va_uid = fxdr_unsigned(uid_t, fp->fa_uid);
746 1.12 mycroft vap->va_gid = fxdr_unsigned(gid_t, fp->fa_gid);
747 1.12 mycroft vap->va_rdev = (dev_t)rdev;
748 1.12 mycroft vap->va_mtime = mtime;
749 1.12 mycroft vap->va_fsid = vp->v_mount->mnt_stat.f_fsid.val[0];
750 1.12 mycroft if (isnq) {
751 1.12 mycroft fxdr_hyper(&fp->fa_nqsize, &vap->va_size);
752 1.12 mycroft vap->va_blocksize = fxdr_unsigned(long, fp->fa_nqblocksize);
753 1.12 mycroft fxdr_hyper(&fp->fa_nqbytes, &vap->va_bytes);
754 1.12 mycroft vap->va_fileid = fxdr_unsigned(long, fp->fa_nqfileid);
755 1.12 mycroft fxdr_nqtime(&fp->fa_nqatime, &vap->va_atime);
756 1.12 mycroft vap->va_flags = fxdr_unsigned(u_long, fp->fa_nqflags);
757 1.12 mycroft fxdr_nqtime(&fp->fa_nqctime, &vap->va_ctime);
758 1.12 mycroft vap->va_gen = fxdr_unsigned(u_long, fp->fa_nqgen);
759 1.12 mycroft fxdr_hyper(&fp->fa_nqfilerev, &vap->va_filerev);
760 1.12 mycroft } else {
761 1.12 mycroft vap->va_size = fxdr_unsigned(u_long, fp->fa_nfssize);
762 1.12 mycroft vap->va_blocksize = fxdr_unsigned(long, fp->fa_nfsblocksize);
763 1.12 mycroft vap->va_bytes = fxdr_unsigned(long, fp->fa_nfsblocks) * NFS_FABLKSIZE;
764 1.12 mycroft vap->va_fileid = fxdr_unsigned(long, fp->fa_nfsfileid);
765 1.12 mycroft fxdr_nfstime(&fp->fa_nfsatime, &vap->va_atime);
766 1.12 mycroft vap->va_flags = 0;
767 1.12 mycroft fxdr_nfstime(&fp->fa_nfsctime, &vap->va_ctime);
768 1.12 mycroft vap->va_gen = 0;
769 1.12 mycroft vap->va_filerev = 0;
770 1.12 mycroft }
771 1.12 mycroft if (vap->va_size != np->n_size) {
772 1.12 mycroft if (vap->va_type == VREG) {
773 1.12 mycroft if (np->n_flag & NMODIFIED) {
774 1.12 mycroft if (vap->va_size < np->n_size)
775 1.12 mycroft vap->va_size = np->n_size;
776 1.12 mycroft else
777 1.12 mycroft np->n_size = vap->va_size;
778 1.12 mycroft } else
779 1.12 mycroft np->n_size = vap->va_size;
780 1.12 mycroft vnode_pager_setsize(vp, (u_long)np->n_size);
781 1.12 mycroft } else
782 1.12 mycroft np->n_size = vap->va_size;
783 1.12 mycroft }
784 1.12 mycroft np->n_attrstamp = time.tv_sec;
785 1.12 mycroft *dposp = dpos;
786 1.12 mycroft *mdp = md;
787 1.12 mycroft if (vaper != NULL) {
788 1.12 mycroft bcopy((caddr_t)vap, (caddr_t)vaper, sizeof(*vap));
789 1.12 mycroft #ifdef notdef
790 1.12 mycroft if ((np->n_flag & NMODIFIED) && np->n_size > vap->va_size)
791 1.12 mycroft if (np->n_size > vap->va_size)
792 1.12 mycroft vaper->va_size = np->n_size;
793 1.1 cgd #endif
794 1.12 mycroft if (np->n_flag & NCHG) {
795 1.12 mycroft if (np->n_flag & NACC) {
796 1.12 mycroft vaper->va_atime.ts_sec = np->n_atim.tv_sec;
797 1.12 mycroft vaper->va_atime.ts_nsec =
798 1.12 mycroft np->n_atim.tv_usec * 1000;
799 1.12 mycroft }
800 1.12 mycroft if (np->n_flag & NUPD) {
801 1.12 mycroft vaper->va_mtime.ts_sec = np->n_mtim.tv_sec;
802 1.12 mycroft vaper->va_mtime.ts_nsec =
803 1.12 mycroft np->n_mtim.tv_usec * 1000;
804 1.12 mycroft }
805 1.12 mycroft }
806 1.12 mycroft }
807 1.12 mycroft return (0);
808 1.12 mycroft }
809 1.12 mycroft
810 1.12 mycroft /*
811 1.12 mycroft * Check the time stamp
812 1.12 mycroft * If the cache is valid, copy contents to *vap and return 0
813 1.12 mycroft * otherwise return an error
814 1.12 mycroft */
815 1.12 mycroft nfs_getattrcache(vp, vaper)
816 1.12 mycroft register struct vnode *vp;
817 1.12 mycroft struct vattr *vaper;
818 1.12 mycroft {
819 1.12 mycroft register struct nfsnode *np = VTONFS(vp);
820 1.12 mycroft register struct vattr *vap;
821 1.12 mycroft
822 1.12 mycroft if (VFSTONFS(vp->v_mount)->nm_flag & NFSMNT_NQLOOKLEASE) {
823 1.12 mycroft if (!NQNFS_CKCACHABLE(vp, NQL_READ) || np->n_attrstamp == 0) {
824 1.12 mycroft nfsstats.attrcache_misses++;
825 1.12 mycroft return (ENOENT);
826 1.12 mycroft }
827 1.12 mycroft } else if ((time.tv_sec - np->n_attrstamp) >= NFS_ATTRTIMEO(np)) {
828 1.12 mycroft nfsstats.attrcache_misses++;
829 1.12 mycroft return (ENOENT);
830 1.12 mycroft }
831 1.12 mycroft nfsstats.attrcache_hits++;
832 1.12 mycroft vap = &np->n_vattr;
833 1.12 mycroft if (vap->va_size != np->n_size) {
834 1.12 mycroft if (vap->va_type == VREG) {
835 1.12 mycroft if (np->n_flag & NMODIFIED) {
836 1.12 mycroft if (vap->va_size < np->n_size)
837 1.12 mycroft vap->va_size = np->n_size;
838 1.12 mycroft else
839 1.12 mycroft np->n_size = vap->va_size;
840 1.12 mycroft } else
841 1.12 mycroft np->n_size = vap->va_size;
842 1.12 mycroft vnode_pager_setsize(vp, (u_long)np->n_size);
843 1.12 mycroft } else
844 1.12 mycroft np->n_size = vap->va_size;
845 1.12 mycroft }
846 1.12 mycroft bcopy((caddr_t)vap, (caddr_t)vaper, sizeof(struct vattr));
847 1.12 mycroft #ifdef notdef
848 1.12 mycroft if ((np->n_flag & NMODIFIED) == 0) {
849 1.12 mycroft np->n_size = vaper->va_size;
850 1.12 mycroft vnode_pager_setsize(vp, (u_long)np->n_size);
851 1.12 mycroft } else if (np->n_size > vaper->va_size)
852 1.12 mycroft if (np->n_size > vaper->va_size)
853 1.12 mycroft vaper->va_size = np->n_size;
854 1.1 cgd #endif
855 1.12 mycroft if (np->n_flag & NCHG) {
856 1.12 mycroft if (np->n_flag & NACC) {
857 1.12 mycroft vaper->va_atime.ts_sec = np->n_atim.tv_sec;
858 1.12 mycroft vaper->va_atime.ts_nsec = np->n_atim.tv_usec * 1000;
859 1.12 mycroft }
860 1.12 mycroft if (np->n_flag & NUPD) {
861 1.12 mycroft vaper->va_mtime.ts_sec = np->n_mtim.tv_sec;
862 1.12 mycroft vaper->va_mtime.ts_nsec = np->n_mtim.tv_usec * 1000;
863 1.12 mycroft }
864 1.1 cgd }
865 1.12 mycroft return (0);
866 1.1 cgd }
867 1.12 mycroft #endif
868 1.1 cgd
869 1.1 cgd /*
870 1.12 mycroft * Set up nameidata for a lookup() call and do it
871 1.1 cgd */
872 1.12 mycroft nfs_namei(ndp, fhp, len, slp, nam, mdp, dposp, p)
873 1.1 cgd register struct nameidata *ndp;
874 1.1 cgd fhandle_t *fhp;
875 1.1 cgd int len;
876 1.12 mycroft struct nfssvc_sock *slp;
877 1.12 mycroft struct mbuf *nam;
878 1.1 cgd struct mbuf **mdp;
879 1.1 cgd caddr_t *dposp;
880 1.1 cgd struct proc *p;
881 1.1 cgd {
882 1.1 cgd register int i, rem;
883 1.1 cgd register struct mbuf *md;
884 1.1 cgd register char *fromcp, *tocp;
885 1.1 cgd struct vnode *dp;
886 1.12 mycroft int error, rdonly;
887 1.12 mycroft struct componentname *cnp = &ndp->ni_cnd;
888 1.1 cgd
889 1.12 mycroft MALLOC(cnp->cn_pnbuf, char *, len + 1, M_NAMEI, M_WAITOK);
890 1.1 cgd /*
891 1.1 cgd * Copy the name from the mbuf list to ndp->ni_pnbuf
892 1.1 cgd * and set the various ndp fields appropriately.
893 1.1 cgd */
894 1.1 cgd fromcp = *dposp;
895 1.12 mycroft tocp = cnp->cn_pnbuf;
896 1.1 cgd md = *mdp;
897 1.1 cgd rem = mtod(md, caddr_t) + md->m_len - fromcp;
898 1.12 mycroft cnp->cn_hash = 0;
899 1.1 cgd for (i = 0; i < len; i++) {
900 1.1 cgd while (rem == 0) {
901 1.1 cgd md = md->m_next;
902 1.1 cgd if (md == NULL) {
903 1.1 cgd error = EBADRPC;
904 1.1 cgd goto out;
905 1.1 cgd }
906 1.1 cgd fromcp = mtod(md, caddr_t);
907 1.1 cgd rem = md->m_len;
908 1.1 cgd }
909 1.1 cgd if (*fromcp == '\0' || *fromcp == '/') {
910 1.1 cgd error = EINVAL;
911 1.1 cgd goto out;
912 1.1 cgd }
913 1.12 mycroft cnp->cn_hash += (unsigned char)*fromcp;
914 1.1 cgd *tocp++ = *fromcp++;
915 1.1 cgd rem--;
916 1.1 cgd }
917 1.1 cgd *tocp = '\0';
918 1.1 cgd *mdp = md;
919 1.1 cgd *dposp = fromcp;
920 1.1 cgd len = nfsm_rndup(len)-len;
921 1.1 cgd if (len > 0) {
922 1.1 cgd if (rem >= len)
923 1.1 cgd *dposp += len;
924 1.1 cgd else if (error = nfs_adv(mdp, dposp, len, rem))
925 1.1 cgd goto out;
926 1.1 cgd }
927 1.12 mycroft ndp->ni_pathlen = tocp - cnp->cn_pnbuf;
928 1.12 mycroft cnp->cn_nameptr = cnp->cn_pnbuf;
929 1.1 cgd /*
930 1.1 cgd * Extract and set starting directory.
931 1.1 cgd */
932 1.12 mycroft if (error = nfsrv_fhtovp(fhp, FALSE, &dp, ndp->ni_cnd.cn_cred, slp,
933 1.12 mycroft nam, &rdonly))
934 1.1 cgd goto out;
935 1.1 cgd if (dp->v_type != VDIR) {
936 1.1 cgd vrele(dp);
937 1.1 cgd error = ENOTDIR;
938 1.1 cgd goto out;
939 1.1 cgd }
940 1.1 cgd ndp->ni_startdir = dp;
941 1.12 mycroft if (rdonly)
942 1.12 mycroft cnp->cn_flags |= (NOCROSSMOUNT | RDONLY);
943 1.12 mycroft else
944 1.12 mycroft cnp->cn_flags |= NOCROSSMOUNT;
945 1.1 cgd /*
946 1.1 cgd * And call lookup() to do the real work
947 1.1 cgd */
948 1.12 mycroft cnp->cn_proc = p;
949 1.12 mycroft if (error = lookup(ndp))
950 1.1 cgd goto out;
951 1.1 cgd /*
952 1.1 cgd * Check for encountering a symbolic link
953 1.1 cgd */
954 1.12 mycroft if (cnp->cn_flags & ISSYMLINK) {
955 1.12 mycroft if ((cnp->cn_flags & LOCKPARENT) && ndp->ni_pathlen == 1)
956 1.1 cgd vput(ndp->ni_dvp);
957 1.1 cgd else
958 1.1 cgd vrele(ndp->ni_dvp);
959 1.1 cgd vput(ndp->ni_vp);
960 1.1 cgd ndp->ni_vp = NULL;
961 1.1 cgd error = EINVAL;
962 1.1 cgd goto out;
963 1.1 cgd }
964 1.1 cgd /*
965 1.1 cgd * Check for saved name request
966 1.1 cgd */
967 1.12 mycroft if (cnp->cn_flags & (SAVENAME | SAVESTART)) {
968 1.12 mycroft cnp->cn_flags |= HASBUF;
969 1.1 cgd return (0);
970 1.1 cgd }
971 1.1 cgd out:
972 1.12 mycroft FREE(cnp->cn_pnbuf, M_NAMEI);
973 1.1 cgd return (error);
974 1.1 cgd }
975 1.1 cgd
976 1.1 cgd /*
977 1.1 cgd * A fiddled version of m_adj() that ensures null fill to a long
978 1.1 cgd * boundary and only trims off the back end
979 1.1 cgd */
980 1.12 mycroft void
981 1.1 cgd nfsm_adj(mp, len, nul)
982 1.1 cgd struct mbuf *mp;
983 1.1 cgd register int len;
984 1.1 cgd int nul;
985 1.1 cgd {
986 1.1 cgd register struct mbuf *m;
987 1.1 cgd register int count, i;
988 1.1 cgd register char *cp;
989 1.1 cgd
990 1.1 cgd /*
991 1.1 cgd * Trim from tail. Scan the mbuf chain,
992 1.1 cgd * calculating its length and finding the last mbuf.
993 1.1 cgd * If the adjustment only affects this mbuf, then just
994 1.1 cgd * adjust and return. Otherwise, rescan and truncate
995 1.1 cgd * after the remaining size.
996 1.1 cgd */
997 1.1 cgd count = 0;
998 1.1 cgd m = mp;
999 1.1 cgd for (;;) {
1000 1.1 cgd count += m->m_len;
1001 1.1 cgd if (m->m_next == (struct mbuf *)0)
1002 1.1 cgd break;
1003 1.1 cgd m = m->m_next;
1004 1.1 cgd }
1005 1.1 cgd if (m->m_len > len) {
1006 1.1 cgd m->m_len -= len;
1007 1.1 cgd if (nul > 0) {
1008 1.1 cgd cp = mtod(m, caddr_t)+m->m_len-nul;
1009 1.1 cgd for (i = 0; i < nul; i++)
1010 1.1 cgd *cp++ = '\0';
1011 1.1 cgd }
1012 1.1 cgd return;
1013 1.1 cgd }
1014 1.1 cgd count -= len;
1015 1.1 cgd if (count < 0)
1016 1.1 cgd count = 0;
1017 1.1 cgd /*
1018 1.1 cgd * Correct length for chain is "count".
1019 1.1 cgd * Find the mbuf with last data, adjust its length,
1020 1.1 cgd * and toss data from remaining mbufs on chain.
1021 1.1 cgd */
1022 1.1 cgd for (m = mp; m; m = m->m_next) {
1023 1.1 cgd if (m->m_len >= count) {
1024 1.1 cgd m->m_len = count;
1025 1.1 cgd if (nul > 0) {
1026 1.1 cgd cp = mtod(m, caddr_t)+m->m_len-nul;
1027 1.1 cgd for (i = 0; i < nul; i++)
1028 1.1 cgd *cp++ = '\0';
1029 1.1 cgd }
1030 1.1 cgd break;
1031 1.1 cgd }
1032 1.1 cgd count -= m->m_len;
1033 1.1 cgd }
1034 1.1 cgd while (m = m->m_next)
1035 1.1 cgd m->m_len = 0;
1036 1.1 cgd }
1037 1.1 cgd
1038 1.1 cgd /*
1039 1.1 cgd * nfsrv_fhtovp() - convert a fh to a vnode ptr (optionally locked)
1040 1.1 cgd * - look up fsid in mount list (if not found ret error)
1041 1.12 mycroft * - get vp and export rights by calling VFS_FHTOVP()
1042 1.12 mycroft * - if cred->cr_uid == 0 or MNT_EXPORTANON set it to credanon
1043 1.1 cgd * - if not lockflag unlock it with VOP_UNLOCK()
1044 1.1 cgd */
1045 1.12 mycroft nfsrv_fhtovp(fhp, lockflag, vpp, cred, slp, nam, rdonlyp)
1046 1.1 cgd fhandle_t *fhp;
1047 1.1 cgd int lockflag;
1048 1.1 cgd struct vnode **vpp;
1049 1.1 cgd struct ucred *cred;
1050 1.12 mycroft struct nfssvc_sock *slp;
1051 1.12 mycroft struct mbuf *nam;
1052 1.12 mycroft int *rdonlyp;
1053 1.1 cgd {
1054 1.1 cgd register struct mount *mp;
1055 1.12 mycroft register struct nfsuid *uidp;
1056 1.12 mycroft register int i;
1057 1.12 mycroft struct ucred *credanon;
1058 1.12 mycroft int error, exflags;
1059 1.1 cgd
1060 1.12 mycroft *vpp = (struct vnode *)0;
1061 1.1 cgd if ((mp = getvfs(&fhp->fh_fsid)) == NULL)
1062 1.1 cgd return (ESTALE);
1063 1.12 mycroft if (error = VFS_FHTOVP(mp, &fhp->fh_fid, nam, vpp, &exflags, &credanon))
1064 1.12 mycroft return (error);
1065 1.12 mycroft /*
1066 1.12 mycroft * Check/setup credentials.
1067 1.12 mycroft */
1068 1.12 mycroft if (exflags & MNT_EXKERB) {
1069 1.12 mycroft uidp = slp->ns_uidh[NUIDHASH(cred->cr_uid)];
1070 1.12 mycroft while (uidp) {
1071 1.12 mycroft if (uidp->nu_uid == cred->cr_uid)
1072 1.12 mycroft break;
1073 1.12 mycroft uidp = uidp->nu_hnext;
1074 1.12 mycroft }
1075 1.12 mycroft if (uidp) {
1076 1.12 mycroft cred->cr_uid = uidp->nu_cr.cr_uid;
1077 1.12 mycroft for (i = 0; i < uidp->nu_cr.cr_ngroups; i++)
1078 1.12 mycroft cred->cr_groups[i] = uidp->nu_cr.cr_groups[i];
1079 1.12 mycroft } else {
1080 1.12 mycroft vput(*vpp);
1081 1.12 mycroft return (NQNFS_AUTHERR);
1082 1.12 mycroft }
1083 1.12 mycroft } else if (cred->cr_uid == 0 || (exflags & MNT_EXPORTANON)) {
1084 1.12 mycroft cred->cr_uid = credanon->cr_uid;
1085 1.12 mycroft for (i = 0; i < credanon->cr_ngroups && i < NGROUPS; i++)
1086 1.12 mycroft cred->cr_groups[i] = credanon->cr_groups[i];
1087 1.12 mycroft }
1088 1.12 mycroft if (exflags & MNT_EXRDONLY)
1089 1.12 mycroft *rdonlyp = 1;
1090 1.12 mycroft else
1091 1.12 mycroft *rdonlyp = 0;
1092 1.1 cgd if (!lockflag)
1093 1.1 cgd VOP_UNLOCK(*vpp);
1094 1.1 cgd return (0);
1095 1.1 cgd }
1096 1.1 cgd
1097 1.1 cgd /*
1098 1.12 mycroft * This function compares two net addresses by family and returns TRUE
1099 1.12 mycroft * if they are the same host.
1100 1.12 mycroft * If there is any doubt, return FALSE.
1101 1.12 mycroft * The AF_INET family is handled as a special case so that address mbufs
1102 1.12 mycroft * don't need to be saved to store "struct in_addr", which is only 4 bytes.
1103 1.1 cgd */
1104 1.12 mycroft netaddr_match(family, haddr, nam)
1105 1.12 mycroft int family;
1106 1.12 mycroft union nethostaddr *haddr;
1107 1.12 mycroft struct mbuf *nam;
1108 1.1 cgd {
1109 1.12 mycroft register struct sockaddr_in *inetaddr;
1110 1.1 cgd
1111 1.12 mycroft switch (family) {
1112 1.12 mycroft case AF_INET:
1113 1.12 mycroft inetaddr = mtod(nam, struct sockaddr_in *);
1114 1.12 mycroft if (inetaddr->sin_family == AF_INET &&
1115 1.12 mycroft inetaddr->sin_addr.s_addr == haddr->had_inetaddr)
1116 1.12 mycroft return (1);
1117 1.12 mycroft break;
1118 1.12 mycroft #ifdef ISO
1119 1.12 mycroft case AF_ISO:
1120 1.12 mycroft {
1121 1.12 mycroft register struct sockaddr_iso *isoaddr1, *isoaddr2;
1122 1.12 mycroft
1123 1.12 mycroft isoaddr1 = mtod(nam, struct sockaddr_iso *);
1124 1.12 mycroft isoaddr2 = mtod(haddr->had_nam, struct sockaddr_iso *);
1125 1.12 mycroft if (isoaddr1->siso_family == AF_ISO &&
1126 1.12 mycroft isoaddr1->siso_nlen > 0 &&
1127 1.12 mycroft isoaddr1->siso_nlen == isoaddr2->siso_nlen &&
1128 1.12 mycroft SAME_ISOADDR(isoaddr1, isoaddr2))
1129 1.12 mycroft return (1);
1130 1.12 mycroft break;
1131 1.12 mycroft }
1132 1.12 mycroft #endif /* ISO */
1133 1.12 mycroft default:
1134 1.12 mycroft break;
1135 1.12 mycroft };
1136 1.12 mycroft return (0);
1137 1.1 cgd }
1138