nfs_vnops.c revision 1.26 1 /*
2 * Copyright (c) 1989 The Regents of the University of California.
3 * All rights reserved.
4 *
5 * This code is derived from software contributed to Berkeley by
6 * Rick Macklem at The University of Guelph.
7 *
8 * Redistribution and use in source and binary forms, with or without
9 * modification, are permitted provided that the following conditions
10 * are met:
11 * 1. Redistributions of source code must retain the above copyright
12 * notice, this list of conditions and the following disclaimer.
13 * 2. Redistributions in binary form must reproduce the above copyright
14 * notice, this list of conditions and the following disclaimer in the
15 * documentation and/or other materials provided with the distribution.
16 * 3. All advertising materials mentioning features or use of this software
17 * must display the following acknowledgement:
18 * This product includes software developed by the University of
19 * California, Berkeley and its contributors.
20 * 4. Neither the name of the University nor the names of its contributors
21 * may be used to endorse or promote products derived from this software
22 * without specific prior written permission.
23 *
24 * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
25 * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
26 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
27 * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
28 * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
29 * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
30 * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
31 * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
32 * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
33 * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
34 * SUCH DAMAGE.
35 *
36 * from: @(#)nfs_vnops.c 7.60 (Berkeley) 5/24/91
37 * $Id: nfs_vnops.c,v 1.26 1994/03/27 09:09:21 cgd Exp $
38 */
39
40 /*
41 * vnode op calls for sun nfs version 2
42 */
43
44 #include <sys/param.h>
45 #include <sys/proc.h>
46 #include <sys/kernel.h>
47 #include <sys/systm.h>
48 #include <sys/mount.h>
49 #include <sys/buf.h>
50 #include <sys/malloc.h>
51 #include <sys/mbuf.h>
52 #include <sys/conf.h>
53 #include <sys/namei.h>
54 #include <sys/vnode.h>
55 #include <sys/dir.h>
56 #include <miscfs/specfs/specdev.h> /* XXX */
57 #include <miscfs/fifofs/fifo.h> /* XXX */
58
59 #include <nfs/nfsv2.h>
60 #include <nfs/nfs.h>
61 #include <nfs/nfsnode.h>
62 #include <nfs/nfsmount.h>
63 #include <nfs/xdr_subs.h>
64 #include <nfs/nfsm_subs.h>
65 #include <nfs/nfsiom.h>
66
67 /* Defs */
68 #define TRUE 1
69 #define FALSE 0
70
71 /*
72 * Global vfs data structures for nfs
73 */
74 struct vnodeops nfsv2_vnodeops = {
75 nfs_lookup, /* lookup */
76 nfs_create, /* create */
77 nfs_mknod, /* mknod */
78 nfs_open, /* open */
79 nfs_close, /* close */
80 nfs_access, /* access */
81 nfs_getattr, /* getattr */
82 nfs_setattr, /* setattr */
83 nfs_read, /* read */
84 nfs_write, /* write */
85 nfs_ioctl, /* ioctl */
86 nfs_select, /* select */
87 nfs_mmap, /* mmap */
88 nfs_fsync, /* fsync */
89 nfs_seek, /* seek */
90 nfs_remove, /* remove */
91 nfs_link, /* link */
92 nfs_rename, /* rename */
93 nfs_mkdir, /* mkdir */
94 nfs_rmdir, /* rmdir */
95 nfs_symlink, /* symlink */
96 nfs_readdir, /* readdir */
97 nfs_readlink, /* readlink */
98 nfs_abortop, /* abortop */
99 nfs_inactive, /* inactive */
100 nfs_reclaim, /* reclaim */
101 nfs_lock, /* lock */
102 nfs_unlock, /* unlock */
103 nfs_bmap, /* bmap */
104 nfs_strategy, /* strategy */
105 nfs_print, /* print */
106 nfs_islocked, /* islocked */
107 nfs_advlock, /* advlock */
108 };
109
110 /*
111 * Special device vnode ops
112 */
113 struct vnodeops spec_nfsv2nodeops = {
114 spec_lookup, /* lookup */
115 spec_create, /* create */
116 spec_mknod, /* mknod */
117 spec_open, /* open */
118 nfsspec_close, /* close */
119 nfs_access, /* access */
120 nfs_getattr, /* getattr */
121 nfs_setattr, /* setattr */
122 nfsspec_read, /* read */
123 nfsspec_write, /* write */
124 spec_ioctl, /* ioctl */
125 spec_select, /* select */
126 spec_mmap, /* mmap */
127 spec_fsync, /* fsync */
128 spec_seek, /* seek */
129 spec_remove, /* remove */
130 spec_link, /* link */
131 spec_rename, /* rename */
132 spec_mkdir, /* mkdir */
133 spec_rmdir, /* rmdir */
134 spec_symlink, /* symlink */
135 spec_readdir, /* readdir */
136 spec_readlink, /* readlink */
137 spec_abortop, /* abortop */
138 nfs_inactive, /* inactive */
139 nfs_reclaim, /* reclaim */
140 nfs_lock, /* lock */
141 nfs_unlock, /* unlock */
142 spec_bmap, /* bmap */
143 spec_strategy, /* strategy */
144 nfs_print, /* print */
145 nfs_islocked, /* islocked */
146 spec_advlock, /* advlock */
147 };
148
149 #ifdef FIFO
150 struct vnodeops fifo_nfsv2nodeops = {
151 fifo_lookup, /* lookup */
152 fifo_create, /* create */
153 fifo_mknod, /* mknod */
154 fifo_open, /* open */
155 nfsfifo_close, /* close */
156 nfs_access, /* access */
157 nfs_getattr, /* getattr */
158 nfs_setattr, /* setattr */
159 nfsfifo_read, /* read */
160 nfsfifo_write, /* write */
161 fifo_ioctl, /* ioctl */
162 fifo_select, /* select */
163 fifo_mmap, /* mmap */
164 fifo_fsync, /* fsync */
165 fifo_seek, /* seek */
166 fifo_remove, /* remove */
167 fifo_link, /* link */
168 fifo_rename, /* rename */
169 fifo_mkdir, /* mkdir */
170 fifo_rmdir, /* rmdir */
171 fifo_symlink, /* symlink */
172 fifo_readdir, /* readdir */
173 fifo_readlink, /* readlink */
174 fifo_abortop, /* abortop */
175 nfs_inactive, /* inactive */
176 nfs_reclaim, /* reclaim */
177 nfs_lock, /* lock */
178 nfs_unlock, /* unlock */
179 fifo_bmap, /* bmap */
180 fifo_badop, /* strategy */
181 nfs_print, /* print */
182 nfs_islocked, /* islocked */
183 fifo_advlock, /* advlock */
184 };
185 #endif /* FIFO */
186
187 /*
188 * Global vars
189 */
190 extern u_long nfs_procids[NFS_NPROCS];
191 extern u_long nfs_prog, nfs_vers;
192 extern char nfsiobuf[MAXPHYS+NBPG];
193 struct buf nfs_bqueue; /* Queue head for nfsiod's */
194 struct proc *nfs_iodwant[NFS_MAXASYNCDAEMON];
195 enum vtype ntov_type[7] = { VNON, VREG, VDIR, VBLK, VCHR, VLNK, VNON };
196 int nfs_numasync = 0;
197
198 /*
199 * nfs null call from vfs.
200 */
201 nfs_null(vp, cred, p)
202 struct vnode *vp;
203 struct ucred *cred;
204 struct proc *p;
205 {
206 caddr_t bpos, dpos;
207 u_long xid;
208 int error = 0;
209 struct mbuf *mreq, *mrep, *md, *mb;
210
211 nfsm_reqhead(nfs_procids[NFSPROC_NULL], cred, 0);
212 nfsm_request(vp, NFSPROC_NULL, p, 0);
213 nfsm_reqdone;
214 return (error);
215 }
216
217 /*
218 * nfs access vnode op.
219 * Essentially just get vattr and then imitate iaccess()
220 */
221 nfs_access(vp, mode, cred, p)
222 struct vnode *vp;
223 int mode;
224 register struct ucred *cred;
225 struct proc *p;
226 {
227 register struct vattr *vap;
228 register gid_t *gp;
229 struct vattr vattr;
230 register int i;
231 int error;
232
233 /*
234 * If you're the super-user,
235 * you always get access.
236 */
237 if (cred->cr_uid == 0)
238 return (0);
239 vap = &vattr;
240 if (error = nfs_dogetattr(vp, vap, cred, 0, p))
241 return (error);
242 /*
243 * Access check is based on only one of owner, group, public.
244 * If not owner, then check group. If not a member of the
245 * group, then check public access.
246 */
247 if (cred->cr_uid != vap->va_uid) {
248 mode >>= 3;
249 gp = cred->cr_groups;
250 for (i = 0; i < cred->cr_ngroups; i++, gp++)
251 if (vap->va_gid == *gp)
252 goto found;
253 mode >>= 3;
254 found:
255 ;
256 }
257 return ((vap->va_mode & mode) == mode ? 0 : EACCES);
258 }
259
260 /*
261 * nfs open vnode op
262 * Just check to see if the type is ok
263 */
264 /* ARGSUSED */
265 nfs_open(vp, mode, cred, p)
266 struct vnode *vp;
267 int mode;
268 struct ucred *cred;
269 struct proc *p;
270 {
271 register enum vtype vtyp;
272
273 vtyp = vp->v_type;
274 if (vtyp == VREG || vtyp == VDIR || vtyp == VLNK)
275 return (0);
276 else
277 return (EACCES);
278 }
279
280 /*
281 * nfs close vnode op
282 * For reg files, invalidate any buffer cache entries.
283 */
284 /* ARGSUSED */
285 nfs_close(vp, fflags, cred, p)
286 register struct vnode *vp;
287 int fflags;
288 struct ucred *cred;
289 struct proc *p;
290 {
291 register struct nfsnode *np = VTONFS(vp);
292 int error = 0;
293
294 if (vp->v_type == VREG && (np->n_flag & NMODIFIED)) {
295 nfs_lock(vp);
296 np->n_flag &= ~NMODIFIED;
297 vinvalbuf(vp, TRUE);
298 np->n_attrstamp = 0;
299 if (np->n_flag & NWRITEERR) {
300 np->n_flag &= ~NWRITEERR;
301 error = np->n_error;
302 }
303 nfs_unlock(vp);
304 }
305 return (error);
306 }
307
308 /*
309 * nfs getattr call from vfs.
310 */
311 nfs_getattr(vp, vap, cred, p)
312 register struct vnode *vp;
313 struct vattr *vap;
314 struct ucred *cred;
315 struct proc *p;
316 {
317 return (nfs_dogetattr(vp, vap, cred, 0, p));
318 }
319
320 nfs_dogetattr(vp, vap, cred, tryhard, p)
321 register struct vnode *vp;
322 struct vattr *vap;
323 struct ucred *cred;
324 int tryhard;
325 struct proc *p;
326 {
327 register caddr_t cp;
328 register long t1;
329 caddr_t bpos, dpos;
330 u_long xid;
331 int error = 0;
332 struct mbuf *mreq, *mrep, *md, *mb, *mb2;
333 struct nfsnode *np;
334
335 /* First look in the cache.. */
336 /* cred == NOCRED when we are called by mountroot */
337 if (cred != NOCRED && nfs_getattrcache(vp, vap) == 0)
338 return (0);
339
340 np = VTONFS(vp);
341 if (np->n_delayed_atime.tv_sec != VNOVAL ||
342 np->n_delayed_mtime.tv_sec != VNOVAL) {
343 VATTR_NULL(vap);
344 error = nfs_setattr(vp, vap, cred, p);
345 bcopy((caddr_t)&np->n_vattr, (caddr_t)vap, sizeof(*vap));
346 if ((np->n_flag & NMODIFIED) && (np->n_size > vap->va_size))
347 vap->va_size = np->n_size;
348 return error;
349 }
350 nfsstats.rpccnt[NFSPROC_GETATTR]++;
351 nfsm_reqhead(nfs_procids[NFSPROC_GETATTR], cred, NFSX_FH);
352 nfsm_fhtom(vp);
353 nfsm_request(vp, NFSPROC_GETATTR, p, tryhard);
354 nfsm_loadattr(vp, vap);
355 nfsm_reqdone;
356 return (error);
357 }
358
359 /*
360 * nfs setattr call.
361 */
362 nfs_setattr(vp, vap, cred, p)
363 register struct vnode *vp;
364 register struct vattr *vap;
365 struct ucred *cred;
366 struct proc *p;
367 {
368 register struct nfsv2_sattr *sp;
369 register caddr_t cp;
370 register long t1;
371 caddr_t bpos, dpos;
372 u_long xid;
373 int error = 0;
374 struct mbuf *mreq, *mrep, *md, *mb, *mb2;
375 struct nfsnode *np = VTONFS(vp);
376
377 nfsstats.rpccnt[NFSPROC_SETATTR]++;
378 nfsm_reqhead(nfs_procids[NFSPROC_SETATTR], cred, NFSX_FH+NFSX_SATTR);
379 nfsm_fhtom(vp);
380 nfsm_build(sp, struct nfsv2_sattr *, NFSX_SATTR);
381 if (vap->va_mode == (u_short)VNOVAL)
382 sp->sa_mode = VNOVAL;
383 else
384 sp->sa_mode = vtonfs_mode(vp->v_type, vap->va_mode);
385 if (vap->va_uid == VNOVAL)
386 sp->sa_uid = VNOVAL;
387 else
388 sp->sa_uid = txdr_unsigned(vap->va_uid);
389 if (vap->va_gid == VNOVAL)
390 sp->sa_gid = VNOVAL;
391 else
392 sp->sa_gid = txdr_unsigned(vap->va_gid);
393 sp->sa_size = txdr_unsigned(vap->va_size);
394 /* jfw (at) ksr.com 6/2/93 */
395 #if 0 /* bad assumption; Suns (at least) make full use of usec field */
396 sp->sa_atime.tv_sec = txdr_unsigned(vap->va_atime.tv_sec);
397 sp->sa_atime.tv_usec = txdr_unsigned(vap->va_flags);
398 #else
399 if (vap->va_atime.tv_sec == VNOVAL &&
400 np->n_delayed_atime.tv_sec != VNOVAL) {
401 txdr_time(&np->n_delayed_atime, &sp->sa_atime);
402 } else {
403 txdr_time(&vap->va_atime, &sp->sa_atime);
404 }
405 #endif
406 if (vap->va_mtime.tv_sec == VNOVAL &&
407 np->n_delayed_mtime.tv_sec != VNOVAL) {
408 txdr_time(&np->n_delayed_mtime, &sp->sa_mtime);
409 } else {
410 txdr_time(&vap->va_mtime, &sp->sa_mtime);
411 }
412 np->n_delayed_atime.tv_sec = VNOVAL;
413 np->n_delayed_mtime.tv_sec = VNOVAL;
414
415 if (vap->va_size != VNOVAL || vap->va_mtime.tv_sec != VNOVAL ||
416 vap->va_atime.tv_sec != VNOVAL) {
417 if (np->n_flag & NMODIFIED) {
418 np->n_flag &= ~NMODIFIED;
419 if (vap->va_size == 0)
420 vinvalbuf(vp, FALSE);
421 else
422 vinvalbuf(vp, TRUE);
423 np->n_attrstamp = 0;
424 }
425 }
426 nfsm_request(vp, NFSPROC_SETATTR, p, 1);
427 nfsm_loadattr(vp, (struct vattr *)0);
428 /* should we fill in any vap fields ?? */
429 nfsm_reqdone;
430 return (error);
431 }
432
433 /*
434 * nfs lookup call, one step at a time...
435 * First look in cache
436 * If not found, unlock the directory nfsnode and do the rpc
437 */
438 nfs_lookup(vp, ndp, p)
439 register struct vnode *vp;
440 register struct nameidata *ndp;
441 struct proc *p;
442 {
443 register struct vnode *vdp;
444 register u_long *tl;
445 register caddr_t cp;
446 register long t1, t2;
447 caddr_t bpos, dpos, cp2;
448 u_long xid;
449 struct mbuf *mreq, *mrep, *md, *mb, *mb2;
450 struct vnode *newvp;
451 long len;
452 nfsv2fh_t *fhp;
453 struct nfsnode *np;
454 int lockparent, wantparent, flag, error = 0;
455
456 ndp->ni_dvp = vp;
457 ndp->ni_vp = NULL;
458 if (vp->v_type != VDIR)
459 return (ENOTDIR);
460 lockparent = ndp->ni_nameiop & LOCKPARENT;
461 flag = ndp->ni_nameiop & OPMASK;
462 wantparent = ndp->ni_nameiop & (LOCKPARENT|WANTPARENT);
463 if ((error = cache_lookup(ndp)) && error != ENOENT) {
464 struct vattr vattr;
465 int vpid;
466
467 vdp = ndp->ni_vp;
468 vpid = vdp->v_id;
469 /*
470 * See the comment starting `Step through' in ufs/ufs_lookup.c
471 * for an explanation of the locking protocol
472 */
473 if (vp == vdp) {
474 VREF(vdp);
475 error = 0;
476 } else if (ndp->ni_isdotdot) {
477 nfs_unlock(vp);
478 error = vget(vdp);
479 if (!error && lockparent && *ndp->ni_next == '\0')
480 nfs_lock(vp);
481 } else {
482 error = vget(vdp);
483 if (!lockparent || error || *ndp->ni_next != '\0')
484 nfs_unlock(vp);
485 }
486 if (!error) {
487 if (vpid == vdp->v_id) {
488 if (!nfs_dogetattr(vdp, &vattr, ndp->ni_cred, 0, p)&&
489 vattr.va_ctime.tv_sec == VTONFS(vdp)->n_ctime) {
490 nfsstats.lookupcache_hits++;
491 if (flag != LOOKUP && *ndp->ni_next == 0)
492 ndp->ni_nameiop |= SAVENAME;
493 return (0);
494 }
495 cache_purge(vdp);
496 }
497 nfs_nput(vdp);
498 if (lockparent && vdp != vp && *ndp->ni_next == '\0')
499 nfs_unlock(vp);
500 }
501 ndp->ni_vp = NULLVP;
502 } else
503 nfs_unlock(vp);
504 error = 0;
505 nfsstats.lookupcache_misses++;
506 nfsstats.rpccnt[NFSPROC_LOOKUP]++;
507 len = ndp->ni_namelen;
508 nfsm_reqhead(nfs_procids[NFSPROC_LOOKUP], ndp->ni_cred, NFSX_FH+NFSX_UNSIGNED+nfsm_rndup(len));
509 nfsm_fhtom(vp);
510 nfsm_strtom(ndp->ni_ptr, len, NFS_MAXNAMLEN);
511 nfsm_request(vp, NFSPROC_LOOKUP, p, 0);
512 nfsmout:
513 if (error) {
514 if ((flag == CREATE || flag == RENAME) &&
515 *ndp->ni_next == '\0' && error == ENOENT)
516 error = EJUSTRETURN;
517 if (lockparent || (flag != CREATE && flag != RENAME) ||
518 *ndp->ni_next != 0)
519 nfs_lock(vp);
520 if (flag != LOOKUP && *ndp->ni_next == 0)
521 ndp->ni_nameiop |= SAVENAME;
522 return (error);
523 }
524 nfsm_disect(fhp,nfsv2fh_t *,NFSX_FH);
525
526 /*
527 * Handle DELETE and RENAME cases...
528 */
529 if (flag == DELETE && *ndp->ni_next == 0) {
530 if (!bcmp(VTONFS(vp)->n_fh.fh_bytes, (caddr_t)fhp, NFSX_FH)) {
531 VREF(vp);
532 newvp = vp;
533 np = VTONFS(vp);
534 } else {
535 if (error = nfs_nget(vp->v_mount, fhp, &np)) {
536 nfs_lock(vp);
537 m_freem(mrep);
538 return (error);
539 }
540 newvp = NFSTOV(np);
541 }
542 if (error =
543 nfs_loadattrcache(&newvp, &md, &dpos, (struct vattr *)0)) {
544 nfs_lock(vp);
545 if (newvp != vp)
546 nfs_nput(newvp);
547 else
548 vrele(vp);
549 m_freem(mrep);
550 return (error);
551 }
552 ndp->ni_vp = newvp;
553 if (lockparent || vp == newvp)
554 nfs_lock(vp);
555 m_freem(mrep);
556 ndp->ni_nameiop |= SAVENAME;
557 return (0);
558 }
559
560 if (flag == RENAME && wantparent && *ndp->ni_next == 0) {
561 if (!bcmp(VTONFS(vp)->n_fh.fh_bytes, (caddr_t)fhp, NFSX_FH)) {
562 nfs_lock(vp);
563 m_freem(mrep);
564 return (EISDIR);
565 }
566 if (error = nfs_nget(vp->v_mount, fhp, &np)) {
567 nfs_lock(vp);
568 m_freem(mrep);
569 return (error);
570 }
571 newvp = NFSTOV(np);
572 if (error =
573 nfs_loadattrcache(&newvp, &md, &dpos, (struct vattr *)0)) {
574 nfs_lock(vp);
575 nfs_nput(newvp);
576 m_freem(mrep);
577 return (error);
578 }
579 ndp->ni_vp = newvp;
580 if (lockparent)
581 nfs_lock(vp);
582 m_freem(mrep);
583 ndp->ni_nameiop |= SAVENAME;
584 return (0);
585 }
586
587 if (!bcmp(VTONFS(vp)->n_fh.fh_bytes, (caddr_t)fhp, NFSX_FH)) {
588 VREF(vp);
589 newvp = vp;
590 np = VTONFS(vp);
591 } else if (ndp->ni_isdotdot) {
592 if (error = nfs_nget(vp->v_mount, fhp, &np)) {
593 nfs_lock(vp);
594 m_freem(mrep);
595 return (error);
596 }
597 newvp = NFSTOV(np);
598 } else {
599 if (error = nfs_nget(vp->v_mount, fhp, &np)) {
600 nfs_lock(vp);
601 m_freem(mrep);
602 return (error);
603 }
604 newvp = NFSTOV(np);
605 }
606 if (error = nfs_loadattrcache(&newvp, &md, &dpos, (struct vattr *)0)) {
607 nfs_lock(vp);
608 if (newvp != vp)
609 nfs_nput(newvp);
610 else
611 vrele(vp);
612 m_freem(mrep);
613 return (error);
614 }
615 m_freem(mrep);
616
617 if (vp == newvp || (lockparent && *ndp->ni_next == '\0'))
618 nfs_lock(vp);
619 ndp->ni_vp = newvp;
620 if (flag != LOOKUP && *ndp->ni_next == 0)
621 ndp->ni_nameiop |= SAVENAME;
622 if (error == 0 && ndp->ni_makeentry) {
623 np->n_ctime = np->n_vattr.va_ctime.tv_sec;
624 cache_enter(ndp);
625 }
626 return (error);
627 }
628
629 /*
630 * nfs read call.
631 * Just call nfs_bioread() to do the work.
632 */
633 nfs_read(vp, uiop, ioflag, cred)
634 register struct vnode *vp;
635 struct uio *uiop;
636 int ioflag;
637 struct ucred *cred;
638 {
639 if (vp->v_type != VREG)
640 return (EPERM);
641 return (nfs_bioread(vp, uiop, ioflag, cred));
642 }
643
644 /*
645 * nfs readlink call
646 */
647 nfs_readlink(vp, uiop, cred)
648 struct vnode *vp;
649 struct uio *uiop;
650 struct ucred *cred;
651 {
652 if (vp->v_type != VLNK)
653 return (EPERM);
654 return (nfs_bioread(vp, uiop, 0, cred));
655 }
656
657 /*
658 * Do a readlink rpc.
659 * Called by nfs_doio() from below the buffer cache.
660 */
661 nfs_readlinkrpc(vp, uiop, cred)
662 register struct vnode *vp;
663 struct uio *uiop;
664 struct ucred *cred;
665 {
666 register u_long *tl;
667 register caddr_t cp;
668 register long t1;
669 caddr_t bpos, dpos, cp2;
670 u_long xid;
671 int error = 0;
672 struct mbuf *mreq, *mrep, *md, *mb, *mb2;
673 long len;
674
675 nfsstats.rpccnt[NFSPROC_READLINK]++;
676 nfsm_reqhead(nfs_procids[NFSPROC_READLINK], cred, NFSX_FH);
677 nfsm_fhtom(vp);
678 nfsm_request(vp, NFSPROC_READLINK, uiop->uio_procp, 0);
679 nfsm_strsiz(len, NFS_MAXPATHLEN);
680 nfsm_mtouio(uiop, len);
681 nfsm_reqdone;
682 return (error);
683 }
684
685 /*
686 * nfs read rpc call
687 * Ditto above
688 */
689 nfs_readrpc(vp, uiop, cred)
690 register struct vnode *vp;
691 struct uio *uiop;
692 struct ucred *cred;
693 {
694 register u_long *tl;
695 register caddr_t cp;
696 register long t1;
697 caddr_t bpos, dpos, cp2;
698 u_long xid;
699 int error = 0;
700 struct mbuf *mreq, *mrep, *md, *mb, *mb2;
701 struct nfsmount *nmp;
702 long len, retlen, tsiz;
703
704 nmp = VFSTONFS(vp->v_mount);
705 tsiz = uiop->uio_resid;
706 while (tsiz > 0) {
707 nfsstats.rpccnt[NFSPROC_READ]++;
708 len = (tsiz > nmp->nm_rsize) ? nmp->nm_rsize : tsiz;
709 nfsm_reqhead(nfs_procids[NFSPROC_READ], cred, NFSX_FH+NFSX_UNSIGNED*3);
710 nfsm_fhtom(vp);
711 nfsm_build(tl, u_long *, NFSX_UNSIGNED*3);
712 *tl++ = txdr_unsigned(uiop->uio_offset);
713 *tl++ = txdr_unsigned(len);
714 *tl = 0;
715 nfsm_request(vp, NFSPROC_READ, uiop->uio_procp, 1);
716 nfsm_loadattr(vp, (struct vattr *)0);
717 nfsm_strsiz(retlen, nmp->nm_rsize);
718 nfsm_mtouio(uiop, retlen);
719 m_freem(mrep);
720 if (retlen < len)
721 tsiz = 0;
722 else
723 tsiz -= len;
724 }
725 nfsmout:
726 return (error);
727 }
728
729 /*
730 * nfs write call
731 */
732 nfs_writerpc(vp, uiop, cred)
733 register struct vnode *vp;
734 struct uio *uiop;
735 struct ucred *cred;
736 {
737 register u_long *tl;
738 register caddr_t cp;
739 register long t1;
740 caddr_t bpos, dpos;
741 u_long xid;
742 int error = 0;
743 struct mbuf *mreq, *mrep, *md, *mb, *mb2;
744 struct nfsmount *nmp;
745 long len, tsiz;
746
747 nmp = VFSTONFS(vp->v_mount);
748 tsiz = uiop->uio_resid;
749 while (tsiz > 0) {
750 nfsstats.rpccnt[NFSPROC_WRITE]++;
751 len = (tsiz > nmp->nm_wsize) ? nmp->nm_wsize : tsiz;
752 nfsm_reqhead(nfs_procids[NFSPROC_WRITE], cred,
753 NFSX_FH+NFSX_UNSIGNED*4);
754 nfsm_fhtom(vp);
755 nfsm_build(tl, u_long *, NFSX_UNSIGNED*4);
756 *(tl+1) = txdr_unsigned(uiop->uio_offset);
757 *(tl+3) = txdr_unsigned(len);
758 nfsm_uiotom(uiop, len);
759 nfsm_request(vp, NFSPROC_WRITE, uiop->uio_procp, 1);
760 nfsm_loadattr(vp, (struct vattr *)0);
761 m_freem(mrep);
762 tsiz -= len;
763 }
764 nfsmout:
765 return (error);
766 }
767
768 /*
769 * nfs mknod call
770 * This is a kludge. Use a create rpc but with the IFMT bits of the mode
771 * set to specify the file type and the size field for rdev.
772 */
773 /* ARGSUSED */
774 nfs_mknod(ndp, vap, cred, p)
775 struct nameidata *ndp;
776 struct ucred *cred;
777 register struct vattr *vap;
778 struct proc *p;
779 {
780 register struct nfsv2_sattr *sp;
781 register u_long *tl;
782 register caddr_t cp;
783 register long t1, t2;
784 caddr_t bpos, dpos;
785 u_long xid;
786 int error = 0;
787 struct mbuf *mreq, *mrep, *md, *mb, *mb2;
788 u_long rdev;
789
790 if (vap->va_type == VCHR || vap->va_type == VBLK)
791 rdev = txdr_unsigned(vap->va_rdev);
792 #ifdef FIFO
793 else if (vap->va_type == VFIFO)
794 rdev = 0xffffffff;
795 #endif /* FIFO */
796 else {
797 VOP_ABORTOP(ndp);
798 vput(ndp->ni_dvp);
799 return (EOPNOTSUPP);
800 }
801 nfsstats.rpccnt[NFSPROC_CREATE]++;
802 nfsm_reqhead(nfs_procids[NFSPROC_CREATE], ndp->ni_cred,
803 NFSX_FH+NFSX_UNSIGNED+nfsm_rndup(ndp->ni_namelen)+NFSX_SATTR);
804 nfsm_fhtom(ndp->ni_dvp);
805 nfsm_strtom(ndp->ni_ptr, ndp->ni_namelen, NFS_MAXNAMLEN);
806 nfsm_build(sp, struct nfsv2_sattr *, NFSX_SATTR);
807 sp->sa_mode = vtonfs_mode(vap->va_type, vap->va_mode);
808 sp->sa_uid = txdr_unsigned(ndp->ni_cred->cr_uid);
809 sp->sa_gid = txdr_unsigned(ndp->ni_cred->cr_gid);
810 sp->sa_size = rdev;
811 /* or should these be VNOVAL ?? */
812 txdr_time(&vap->va_atime, &sp->sa_atime);
813 txdr_time(&vap->va_mtime, &sp->sa_mtime);
814 nfsm_request(ndp->ni_dvp, NFSPROC_CREATE, p, 1);
815 nfsm_reqdone;
816 FREE(ndp->ni_pnbuf, M_NAMEI);
817 VTONFS(ndp->ni_dvp)->n_flag |= NMODIFIED;
818 nfs_nput(ndp->ni_dvp);
819 return (error);
820 }
821
822 /*
823 * nfs file create call
824 */
825 nfs_create(ndp, vap, p)
826 register struct nameidata *ndp;
827 register struct vattr *vap;
828 struct proc *p;
829 {
830 register struct nfsv2_sattr *sp;
831 register u_long *tl;
832 register caddr_t cp;
833 register long t1, t2;
834 caddr_t bpos, dpos, cp2;
835 u_long xid;
836 int error = 0;
837 struct mbuf *mreq, *mrep, *md, *mb, *mb2;
838
839 nfsstats.rpccnt[NFSPROC_CREATE]++;
840 nfsm_reqhead(nfs_procids[NFSPROC_CREATE], ndp->ni_cred,
841 NFSX_FH+NFSX_UNSIGNED+nfsm_rndup(ndp->ni_namelen)+NFSX_SATTR);
842 nfsm_fhtom(ndp->ni_dvp);
843 nfsm_strtom(ndp->ni_ptr, ndp->ni_namelen, NFS_MAXNAMLEN);
844 nfsm_build(sp, struct nfsv2_sattr *, NFSX_SATTR);
845 sp->sa_mode = vtonfs_mode(vap->va_type, vap->va_mode);
846 sp->sa_uid = txdr_unsigned(ndp->ni_cred->cr_uid);
847 sp->sa_gid = txdr_unsigned(ndp->ni_cred->cr_gid);
848 sp->sa_size = txdr_unsigned(0);
849 /* or should these be VNOVAL ?? */
850 txdr_time(&vap->va_atime, &sp->sa_atime);
851 txdr_time(&vap->va_mtime, &sp->sa_mtime);
852 nfsm_request(ndp->ni_dvp, NFSPROC_CREATE, p, 1);
853 nfsm_mtofh(ndp->ni_dvp, ndp->ni_vp);
854 nfsm_reqdone;
855 FREE(ndp->ni_pnbuf, M_NAMEI);
856 VTONFS(ndp->ni_dvp)->n_flag |= NMODIFIED;
857 nfs_nput(ndp->ni_dvp);
858 return (error);
859 }
860
861 /*
862 * nfs file remove call
863 * To try and make nfs semantics closer to ufs semantics, a file that has
864 * other processes using the vnode is renamed instead of removed and then
865 * removed later on the last close.
866 * - If v_usecount > 1
867 * If a rename is not already in the works
868 * call nfs_sillyrename() to set it up
869 * else
870 * If link_count > 0
871 * do the remove rpc
872 * else
873 * do the remove rpc
874 */
875 nfs_remove(ndp, p)
876 register struct nameidata *ndp;
877 struct proc *p;
878 {
879 register struct vnode *vp = ndp->ni_vp;
880 register struct nfsnode *np = VTONFS(ndp->ni_vp);
881 register u_long *tl;
882 register caddr_t cp;
883 register long t1, t2;
884 caddr_t bpos, dpos;
885 u_long xid;
886 int error = 0;
887 struct mbuf *mreq, *mrep, *md, *mb, *mb2;
888
889 if (vp->v_usecount > 1) {
890 struct vattr va;
891 if (!np->n_sillyrename)
892 error = nfs_sillyrename(ndp, p);
893 else if (nfs_getattr(vp, &va, ndp->ni_cred, p) == 0 &&
894 va.va_nlink > 1)
895 goto do_nfsremove;
896 } else {
897 do_nfsremove:
898 nfsstats.rpccnt[NFSPROC_REMOVE]++;
899 nfsm_reqhead(nfs_procids[NFSPROC_REMOVE], ndp->ni_cred,
900 NFSX_FH+NFSX_UNSIGNED+nfsm_rndup(ndp->ni_namelen));
901 nfsm_fhtom(ndp->ni_dvp);
902 nfsm_strtom(ndp->ni_ptr, ndp->ni_namelen, NFS_MAXNAMLEN);
903 nfsm_request(ndp->ni_dvp, NFSPROC_REMOVE, p, 1);
904 nfsm_reqdone;
905 FREE(ndp->ni_pnbuf, M_NAMEI);
906 VTONFS(ndp->ni_dvp)->n_flag |= NMODIFIED;
907 /*
908 * Kludge City: If the first reply to the remove rpc is lost..
909 * the reply to the retransmitted request will be ENOENT
910 * since the file was in fact removed
911 * Therefore, we cheat and return success.
912 */
913 if (error == ENOENT)
914 error = 0;
915 }
916 np->n_attrstamp = 0;
917 if (ndp->ni_dvp == vp)
918 vrele(vp);
919 else
920 nfs_nput(ndp->ni_dvp);
921 nfs_nput(vp);
922 return (error);
923 }
924
925 /*
926 * nfs file remove rpc called from nfs_inactive
927 */
928 nfs_removeit(sp, p)
929 register struct sillyrename *sp;
930 struct proc *p;
931 {
932 register u_long *tl;
933 register caddr_t cp;
934 register long t1, t2;
935 caddr_t bpos, dpos;
936 u_long xid;
937 int error = 0;
938 struct mbuf *mreq, *mrep, *md, *mb, *mb2;
939
940 nfsstats.rpccnt[NFSPROC_REMOVE]++;
941 nfsm_reqhead(nfs_procids[NFSPROC_REMOVE], sp->s_cred,
942 NFSX_FH+NFSX_UNSIGNED+nfsm_rndup(sp->s_namlen));
943 nfsm_fhtom(sp->s_dvp);
944 nfsm_strtom(sp->s_name, sp->s_namlen, NFS_MAXNAMLEN);
945 nfsm_request(sp->s_dvp, NFSPROC_REMOVE, p, 1);
946 nfsm_reqdone;
947 VTONFS(sp->s_dvp)->n_flag |= NMODIFIED;
948 return (error);
949 }
950
951 /*
952 * nfs file rename call
953 */
954 nfs_rename(sndp, tndp, p)
955 register struct nameidata *sndp, *tndp;
956 struct proc *p;
957 {
958 register u_long *tl;
959 register caddr_t cp;
960 register long t1, t2;
961 caddr_t bpos, dpos;
962 u_long xid;
963 int error = 0;
964 struct mbuf *mreq, *mrep, *md, *mb, *mb2;
965 struct vnode *fvp, *tdvp, *tvp;
966
967 /* Check for cross-device rename */
968 fvp = sndp->ni_vp;
969 tdvp = tndp->ni_dvp;
970 tvp = tndp->ni_vp;
971 if ((fvp->v_mount != tdvp->v_mount) ||
972 (tvp && (fvp->v_mount != tvp->v_mount))) {
973 error = EXDEV;
974 goto out;
975 }
976
977 nfsstats.rpccnt[NFSPROC_RENAME]++;
978 nfsm_reqhead(nfs_procids[NFSPROC_RENAME], tndp->ni_cred,
979 (NFSX_FH+NFSX_UNSIGNED)*2+nfsm_rndup(sndp->ni_namelen) +
980 nfsm_rndup(tndp->ni_namelen)); /* or sndp->ni_cred?*/
981 nfsm_fhtom(sndp->ni_dvp);
982 nfsm_strtom(sndp->ni_ptr, sndp->ni_namelen, NFS_MAXNAMLEN);
983 nfsm_fhtom(tndp->ni_dvp);
984 nfsm_strtom(tndp->ni_ptr, tndp->ni_namelen, NFS_MAXNAMLEN);
985 nfsm_request(sndp->ni_dvp, NFSPROC_RENAME, p, 1);
986 nfsm_reqdone;
987 VTONFS(sndp->ni_dvp)->n_flag |= NMODIFIED;
988 VTONFS(tndp->ni_dvp)->n_flag |= NMODIFIED;
989 if (sndp->ni_vp->v_type == VDIR) {
990 if (tndp->ni_vp != NULL && tndp->ni_vp->v_type == VDIR)
991 cache_purge(tndp->ni_dvp);
992 cache_purge(sndp->ni_dvp);
993 }
994
995 out:
996 if (tndp->ni_dvp == tndp->ni_vp)
997 vrele(tndp->ni_dvp);
998 else
999 vput(tndp->ni_dvp);
1000 if (tndp->ni_vp)
1001 vput(tndp->ni_vp);
1002 vrele(sndp->ni_dvp);
1003 vrele(sndp->ni_vp);
1004 /*
1005 * Kludge: Map ENOENT => 0 assuming that it is a reply to a retry.
1006 */
1007 if (error == ENOENT)
1008 error = 0;
1009 return (error);
1010 }
1011
1012 /*
1013 * nfs file rename rpc called from nfs_remove() above
1014 */
1015 nfs_renameit(sndp, sp, p)
1016 register struct nameidata *sndp;
1017 register struct sillyrename *sp;
1018 struct proc *p;
1019 {
1020 register u_long *tl;
1021 register caddr_t cp;
1022 register long t1, t2;
1023 caddr_t bpos, dpos;
1024 u_long xid;
1025 int error = 0;
1026 struct mbuf *mreq, *mrep, *md, *mb, *mb2;
1027
1028 nfsstats.rpccnt[NFSPROC_RENAME]++;
1029 nfsm_reqhead(nfs_procids[NFSPROC_RENAME], sp->s_cred,
1030 (NFSX_FH+NFSX_UNSIGNED)*2+nfsm_rndup(sndp->ni_namelen) +
1031 nfsm_rndup(sp->s_namlen)); /* or sndp->ni_cred?*/
1032 nfsm_fhtom(sndp->ni_dvp);
1033 nfsm_strtom(sndp->ni_ptr, sndp->ni_namelen, NFS_MAXNAMLEN);
1034 nfsm_fhtom(sp->s_dvp);
1035 nfsm_strtom(sp->s_name, sp->s_namlen, NFS_MAXNAMLEN);
1036 nfsm_request(sndp->ni_dvp, NFSPROC_RENAME, p, 1);
1037 nfsm_reqdone;
1038 FREE(sndp->ni_pnbuf, M_NAMEI);
1039 VTONFS(sndp->ni_dvp)->n_flag |= NMODIFIED;
1040 VTONFS(sp->s_dvp)->n_flag |= NMODIFIED;
1041 return (error);
1042 }
1043
1044 /*
1045 * nfs hard link create call
1046 */
1047 nfs_link(vp, ndp, p)
1048 register struct vnode *vp;
1049 register struct nameidata *ndp;
1050 struct proc *p;
1051 {
1052 register u_long *tl;
1053 register caddr_t cp;
1054 register long t1, t2;
1055 caddr_t bpos, dpos;
1056 u_long xid;
1057 int error = 0;
1058 struct mbuf *mreq, *mrep, *md, *mb, *mb2;
1059
1060 if (vp->v_mount != ndp->ni_dvp->v_mount) {
1061 VOP_ABORTOP(ndp);
1062 if (ndp->ni_dvp == ndp->ni_vp)
1063 vrele(ndp->ni_dvp);
1064 else
1065 vput(ndp->ni_dvp);
1066 if (ndp->ni_vp)
1067 vrele(ndp->ni_vp);
1068 return (EXDEV);
1069 }
1070 if (ndp->ni_dvp != vp)
1071 nfs_lock(vp);
1072 nfsstats.rpccnt[NFSPROC_LINK]++;
1073 nfsm_reqhead(nfs_procids[NFSPROC_LINK], ndp->ni_cred,
1074 NFSX_FH*2+NFSX_UNSIGNED+nfsm_rndup(ndp->ni_namelen));
1075 nfsm_fhtom(vp);
1076 nfsm_fhtom(ndp->ni_dvp);
1077 nfsm_strtom(ndp->ni_ptr, ndp->ni_namelen, NFS_MAXNAMLEN);
1078 nfsm_request(vp, NFSPROC_LINK, p, 1);
1079 nfsm_reqdone;
1080 FREE(ndp->ni_pnbuf, M_NAMEI);
1081 VTONFS(vp)->n_attrstamp = 0;
1082 VTONFS(ndp->ni_dvp)->n_flag |= NMODIFIED;
1083 if (ndp->ni_dvp != vp)
1084 nfs_unlock(vp);
1085 nfs_nput(ndp->ni_dvp);
1086 /*
1087 * Kludge: Map EEXIST => 0 assuming that it is a reply to a retry.
1088 */
1089 if (error == EEXIST)
1090 error = 0;
1091 return (error);
1092 }
1093
1094 /*
1095 * nfs symbolic link create call
1096 */
1097 nfs_symlink(ndp, vap, nm, p)
1098 struct nameidata *ndp;
1099 struct vattr *vap;
1100 char *nm; /* is this the path ?? */
1101 struct proc *p;
1102 {
1103 register struct nfsv2_sattr *sp;
1104 register u_long *tl;
1105 register caddr_t cp;
1106 register long t1, t2;
1107 caddr_t bpos, dpos;
1108 u_long xid;
1109 int error = 0;
1110 struct mbuf *mreq, *mrep, *md, *mb, *mb2;
1111
1112 nfsstats.rpccnt[NFSPROC_SYMLINK]++;
1113 nfsm_reqhead(nfs_procids[NFSPROC_SYMLINK], ndp->ni_cred,
1114 NFSX_FH+NFSX_UNSIGNED+nfsm_rndup(ndp->ni_namelen)+NFSX_UNSIGNED);
1115 nfsm_fhtom(ndp->ni_dvp);
1116 nfsm_strtom(ndp->ni_ptr, ndp->ni_namelen, NFS_MAXNAMLEN);
1117 nfsm_strtom(nm, strlen(nm), NFS_MAXPATHLEN);
1118 nfsm_build(sp, struct nfsv2_sattr *, NFSX_SATTR);
1119 sp->sa_mode = vtonfs_mode(VLNK, vap->va_mode);
1120 sp->sa_uid = txdr_unsigned(ndp->ni_cred->cr_uid);
1121 sp->sa_gid = txdr_unsigned(ndp->ni_cred->cr_gid);
1122 sp->sa_size = txdr_unsigned(VNOVAL);
1123 txdr_time(&vap->va_atime, &sp->sa_atime); /* or VNOVAL ?? */
1124 txdr_time(&vap->va_mtime, &sp->sa_mtime); /* or VNOVAL ?? */
1125 nfsm_request(ndp->ni_dvp, NFSPROC_SYMLINK, p, 1);
1126 nfsm_reqdone;
1127 FREE(ndp->ni_pnbuf, M_NAMEI);
1128 VTONFS(ndp->ni_dvp)->n_flag |= NMODIFIED;
1129 nfs_nput(ndp->ni_dvp);
1130 /*
1131 * Kludge: Map EEXIST => 0 assuming that it is a reply to a retry.
1132 */
1133 if (error == EEXIST)
1134 error = 0;
1135 return (error);
1136 }
1137
1138 /*
1139 * nfs make dir call
1140 */
1141 nfs_mkdir(ndp, vap, p)
1142 register struct nameidata *ndp;
1143 struct vattr *vap;
1144 struct proc *p;
1145 {
1146 register struct nfsv2_sattr *sp;
1147 register u_long *tl;
1148 register caddr_t cp;
1149 register long t1, t2;
1150 register int len;
1151 caddr_t bpos, dpos, cp2;
1152 u_long xid;
1153 int error = 0, firsttry = 1;
1154 struct mbuf *mreq, *mrep, *md, *mb, *mb2;
1155
1156 len = ndp->ni_namelen;
1157 nfsstats.rpccnt[NFSPROC_MKDIR]++;
1158 nfsm_reqhead(nfs_procids[NFSPROC_MKDIR], ndp->ni_cred,
1159 NFSX_FH+NFSX_UNSIGNED+nfsm_rndup(len)+NFSX_SATTR);
1160 nfsm_fhtom(ndp->ni_dvp);
1161 nfsm_strtom(ndp->ni_ptr, len, NFS_MAXNAMLEN);
1162 nfsm_build(sp, struct nfsv2_sattr *, NFSX_SATTR);
1163 sp->sa_mode = vtonfs_mode(VDIR, vap->va_mode);
1164 sp->sa_uid = txdr_unsigned(ndp->ni_cred->cr_uid);
1165 sp->sa_gid = txdr_unsigned(ndp->ni_cred->cr_gid);
1166 sp->sa_size = txdr_unsigned(VNOVAL);
1167 txdr_time(&vap->va_atime, &sp->sa_atime); /* or VNOVAL ?? */
1168 txdr_time(&vap->va_mtime, &sp->sa_mtime); /* or VNOVAL ?? */
1169 nfsm_request(ndp->ni_dvp, NFSPROC_MKDIR, p, 1);
1170 nfsm_mtofh(ndp->ni_dvp, ndp->ni_vp);
1171 nfsm_reqdone;
1172 VTONFS(ndp->ni_dvp)->n_flag |= NMODIFIED;
1173 /*
1174 * Kludge: Map EEXIST => 0 assuming that you have a reply to a retry
1175 * if we can succeed in looking up the directory.
1176 * "firsttry" is necessary since the macros may "goto nfsmout" which
1177 * is above the if on errors. (Ugh)
1178 */
1179 if (error == EEXIST && firsttry) {
1180 firsttry = 0;
1181 error = 0;
1182 nfsstats.rpccnt[NFSPROC_LOOKUP]++;
1183 ndp->ni_vp = NULL;
1184 nfsm_reqhead(nfs_procids[NFSPROC_LOOKUP], ndp->ni_cred,
1185 NFSX_FH+NFSX_UNSIGNED+nfsm_rndup(len));
1186 nfsm_fhtom(ndp->ni_dvp);
1187 nfsm_strtom(ndp->ni_ptr, len, NFS_MAXNAMLEN);
1188 nfsm_request(ndp->ni_dvp, NFSPROC_LOOKUP, p, 1);
1189 nfsm_mtofh(ndp->ni_dvp, ndp->ni_vp);
1190 if (ndp->ni_vp->v_type != VDIR) {
1191 vput(ndp->ni_vp);
1192 error = EEXIST;
1193 }
1194 m_freem(mrep);
1195 }
1196 FREE(ndp->ni_pnbuf, M_NAMEI);
1197 nfs_nput(ndp->ni_dvp);
1198 return (error);
1199 }
1200
1201 /*
1202 * nfs remove directory call
1203 */
1204 nfs_rmdir(ndp, p)
1205 register struct nameidata *ndp;
1206 struct proc *p;
1207 {
1208 register u_long *tl;
1209 register caddr_t cp;
1210 register long t1, t2;
1211 caddr_t bpos, dpos;
1212 u_long xid;
1213 int error = 0;
1214 struct mbuf *mreq, *mrep, *md, *mb, *mb2;
1215
1216 if (ndp->ni_dvp == ndp->ni_vp) {
1217 vrele(ndp->ni_dvp);
1218 nfs_nput(ndp->ni_dvp);
1219 return (EINVAL);
1220 }
1221 nfsstats.rpccnt[NFSPROC_RMDIR]++;
1222 nfsm_reqhead(nfs_procids[NFSPROC_RMDIR], ndp->ni_cred,
1223 NFSX_FH+NFSX_UNSIGNED+nfsm_rndup(ndp->ni_namelen));
1224 nfsm_fhtom(ndp->ni_dvp);
1225 nfsm_strtom(ndp->ni_ptr, ndp->ni_namelen, NFS_MAXNAMLEN);
1226 nfsm_request(ndp->ni_dvp, NFSPROC_RMDIR, p, 1);
1227 nfsm_reqdone;
1228 FREE(ndp->ni_pnbuf, M_NAMEI);
1229 VTONFS(ndp->ni_dvp)->n_flag |= NMODIFIED;
1230 cache_purge(ndp->ni_dvp);
1231 cache_purge(ndp->ni_vp);
1232 nfs_nput(ndp->ni_vp);
1233 nfs_nput(ndp->ni_dvp);
1234 /*
1235 * Kludge: Map ENOENT => 0 assuming that you have a reply to a retry.
1236 */
1237 if (error == ENOENT)
1238 error = 0;
1239 return (error);
1240 }
1241
1242 /*
1243 * nfs readdir call
1244 * Although cookie is defined as opaque, I translate it to/from net byte
1245 * order so that it looks more sensible. This appears consistent with the
1246 * Ultrix implementation of NFS.
1247 */
1248 nfs_readdir(vp, uiop, cred, eofflagp, cookies, ncookies)
1249 register struct vnode *vp;
1250 struct uio *uiop;
1251 struct ucred *cred;
1252 int *eofflagp;
1253 u_int *cookies;
1254 int ncookies;
1255 {
1256 register struct nfsnode *np = VTONFS(vp);
1257 int tresid, error;
1258 struct vattr vattr;
1259
1260 /*
1261 * Since NFS mounting isn't propagated,
1262 * we don't need to handle cookies here!
1263 */
1264 if (cookies)
1265 panic("nfs_readdir");
1266
1267 if (vp->v_type != VDIR)
1268 return (EPERM);
1269 /*
1270 * First, check for hit on the EOF offset cache
1271 */
1272 if (uiop->uio_offset != 0 && uiop->uio_offset == np->n_direofoffset &&
1273 (np->n_flag & NMODIFIED) == 0 &&
1274 nfs_dogetattr(vp, &vattr, cred, 0, uiop->uio_procp) == 0 &&
1275 np->n_mtime == vattr.va_mtime.tv_sec) {
1276 *eofflagp = 1;
1277 nfsstats.direofcache_hits++;
1278 return (0);
1279 }
1280
1281 /*
1282 * Call nfs_bioread() to do the real work.
1283 */
1284 tresid = uiop->uio_resid;
1285 error = nfs_bioread(vp, uiop, 0, cred);
1286
1287 if (!error && uiop->uio_resid == tresid) {
1288 *eofflagp = 1;
1289 nfsstats.direofcache_misses++;
1290 } else
1291 *eofflagp = 0;
1292 return (error);
1293 }
1294
1295 /*
1296 * Readdir rpc call.
1297 * Called from below the buffer cache by nfs_doio().
1298 */
1299 nfs_readdirrpc(vp, uiop, cred)
1300 register struct vnode *vp;
1301 struct uio *uiop;
1302 struct ucred *cred;
1303 {
1304 register long len;
1305 register struct dirent *dp;
1306 register u_long *tl;
1307 register caddr_t cp;
1308 register long t1;
1309 long tlen, lastlen;
1310 caddr_t bpos, dpos, cp2;
1311 u_long xid;
1312 int error = 0;
1313 struct mbuf *mreq, *mrep, *md, *mb, *mb2;
1314 struct mbuf *md2;
1315 caddr_t dpos2;
1316 int siz;
1317 int more_dirs = 1;
1318 off_t off, savoff;
1319 struct dirent *savdp;
1320 struct nfsmount *nmp;
1321 struct nfsnode *np = VTONFS(vp);
1322 long tresid;
1323
1324 nmp = VFSTONFS(vp->v_mount);
1325 tresid = uiop->uio_resid;
1326 /*
1327 * Loop around doing readdir rpc's of size uio_resid or nm_rsize,
1328 * whichever is smaller, truncated to a multiple of NFS_DIRBLKSIZ.
1329 * The stopping criteria is EOF or buffer full.
1330 */
1331 while (more_dirs && uiop->uio_resid >= NFS_DIRBLKSIZ) {
1332 nfsstats.rpccnt[NFSPROC_READDIR]++;
1333 nfsm_reqhead(nfs_procids[NFSPROC_READDIR], cred, xid);
1334 nfsm_fhtom(vp);
1335 nfsm_build(tl, u_long *, 2*NFSX_UNSIGNED);
1336 *tl++ = txdr_unsigned(uiop->uio_offset);
1337 *tl = txdr_unsigned(((uiop->uio_resid > nmp->nm_rsize) ?
1338 nmp->nm_rsize : uiop->uio_resid) & ~(NFS_DIRBLKSIZ-1));
1339 nfsm_request(vp, NFSPROC_READDIR, uiop->uio_procp, 0);
1340 siz = 0;
1341 nfsm_disect(tl, u_long *, NFSX_UNSIGNED);
1342 more_dirs = fxdr_unsigned(int, *tl);
1343
1344 /* Save the position so that we can do nfsm_mtouio() later */
1345 dpos2 = dpos;
1346 md2 = md;
1347
1348 /* loop thru the dir entries, doctoring them to 4bsd form */
1349 off = uiop->uio_offset;
1350 #ifdef lint
1351 dp = (struct dirent *)0;
1352 #endif /* lint */
1353 while (more_dirs && siz < uiop->uio_resid) {
1354 savoff = off; /* Hold onto offset and dp */
1355 savdp = dp;
1356 nfsm_disecton(tl, u_long *, 2*NFSX_UNSIGNED);
1357 dp = (struct dirent *)tl;
1358 dp->d_fileno = fxdr_unsigned(u_long, *tl++);
1359 len = fxdr_unsigned(int, *tl);
1360 if (len <= 0 || len > NFS_MAXNAMLEN) {
1361 error = EBADRPC;
1362 m_freem(mrep);
1363 goto nfsmout;
1364 }
1365 dp->d_namlen = (u_short)len;
1366 nfsm_adv(len); /* Point past name */
1367 tlen = nfsm_rndup(len);
1368 /*
1369 * This should not be necessary, but some servers have
1370 * broken XDR such that these bytes are not null filled.
1371 */
1372 if (tlen != len) {
1373 *dpos = '\0'; /* Null-terminate */
1374 nfsm_adv(tlen - len);
1375 len = tlen;
1376 }
1377 nfsm_disecton(tl, u_long *, 2*NFSX_UNSIGNED);
1378 off = fxdr_unsigned(off_t, *tl);
1379 *tl++ = 0; /* Ensures null termination of name */
1380 more_dirs = fxdr_unsigned(int, *tl);
1381 dp->d_reclen = len+4*NFSX_UNSIGNED;
1382 siz += dp->d_reclen;
1383 }
1384 /*
1385 * If at end of rpc data, get the eof boolean
1386 */
1387 if (!more_dirs) {
1388 nfsm_disecton(tl, u_long *, NFSX_UNSIGNED);
1389 more_dirs = (fxdr_unsigned(int, *tl) == 0);
1390
1391 /*
1392 * If at EOF, cache directory offset
1393 */
1394 if (!more_dirs)
1395 np->n_direofoffset = off;
1396 }
1397 /*
1398 * If there is too much to fit in the data buffer, use savoff and
1399 * savdp to trim off the last record.
1400 * --> we are not at eof
1401 */
1402 if (siz > uiop->uio_resid) {
1403 off = savoff;
1404 siz -= dp->d_reclen;
1405 dp = savdp;
1406 more_dirs = 0; /* Paranoia */
1407 }
1408 if (siz > 0) {
1409 lastlen = dp->d_reclen;
1410 md = md2;
1411 dpos = dpos2;
1412 nfsm_mtouio(uiop, siz);
1413 uiop->uio_offset = off;
1414 } else
1415 more_dirs = 0; /* Ugh, never happens, but in case.. */
1416 m_freem(mrep);
1417 }
1418 /*
1419 * Fill last record, iff any, out to a multiple of NFS_DIRBLKSIZ
1420 * by increasing d_reclen for the last record.
1421 */
1422 if (uiop->uio_resid < tresid) {
1423 len = uiop->uio_resid & (NFS_DIRBLKSIZ - 1);
1424 if (len > 0) {
1425 dp = (struct dirent *)
1426 (uiop->uio_iov->iov_base - lastlen);
1427 dp->d_reclen += len;
1428 uiop->uio_iov->iov_base += len;
1429 uiop->uio_iov->iov_len -= len;
1430 uiop->uio_resid -= len;
1431 }
1432 }
1433 nfsmout:
1434 return (error);
1435 }
1436
1437 static char hextoasc[] = "0123456789abcdef";
1438
1439 /*
1440 * Silly rename. To make the NFS filesystem that is stateless look a little
1441 * more like the "ufs" a remove of an active vnode is translated to a rename
1442 * to a funny looking filename that is removed by nfs_inactive on the
1443 * nfsnode. There is the potential for another process on a different client
1444 * to create the same funny name between the nfs_lookitup() fails and the
1445 * nfs_rename() completes, but...
1446 */
1447 nfs_sillyrename(ndp, p)
1448 register struct nameidata *ndp;
1449 struct proc *p;
1450 {
1451 register struct nfsnode *np;
1452 register struct sillyrename *sp;
1453 int error;
1454 short pid;
1455
1456 np = VTONFS(ndp->ni_dvp);
1457 cache_purge(ndp->ni_dvp);
1458 MALLOC(sp, struct sillyrename *, sizeof (struct sillyrename),
1459 M_NFSREQ, M_WAITOK);
1460 bcopy((caddr_t)&np->n_fh, (caddr_t)&sp->s_fh, NFSX_FH);
1461 np = VTONFS(ndp->ni_vp);
1462 sp->s_cred = crdup(ndp->ni_cred);
1463 sp->s_dvp = ndp->ni_dvp;
1464 VREF(sp->s_dvp);
1465
1466 /* Fudge together a funny name */
1467 pid = p->p_pid;
1468 bcopy(".nfsAxxxx4.4", sp->s_name, 13);
1469 sp->s_namlen = 12;
1470 sp->s_name[8] = hextoasc[pid & 0xf];
1471 sp->s_name[7] = hextoasc[(pid >> 4) & 0xf];
1472 sp->s_name[6] = hextoasc[(pid >> 8) & 0xf];
1473 sp->s_name[5] = hextoasc[(pid >> 12) & 0xf];
1474
1475 /* Try lookitups until we get one that isn't there */
1476 while (nfs_lookitup(sp, (nfsv2fh_t *)0, p) == 0) {
1477 sp->s_name[4]++;
1478 if (sp->s_name[4] > 'z') {
1479 error = EINVAL;
1480 goto bad;
1481 }
1482 }
1483 if (error = nfs_renameit(ndp, sp, p))
1484 goto bad;
1485 nfs_lookitup(sp, &np->n_fh, p);
1486 np->n_sillyrename = sp;
1487 return (0);
1488 bad:
1489 vrele(sp->s_dvp);
1490 crfree(sp->s_cred);
1491 free((caddr_t)sp, M_NFSREQ);
1492 return (error);
1493 }
1494
1495 /*
1496 * Look up a file name for silly rename stuff.
1497 * Just like nfs_lookup() except that it doesn't load returned values
1498 * into the nfsnode table.
1499 * If fhp != NULL it copies the returned file handle out
1500 */
1501 nfs_lookitup(sp, fhp, p)
1502 register struct sillyrename *sp;
1503 nfsv2fh_t *fhp;
1504 struct proc *p;
1505 {
1506 register struct vnode *vp = sp->s_dvp;
1507 register u_long *tl;
1508 register caddr_t cp;
1509 register long t1, t2;
1510 caddr_t bpos, dpos, cp2;
1511 u_long xid;
1512 int error = 0;
1513 struct mbuf *mreq, *mrep, *md, *mb, *mb2;
1514 long len;
1515
1516 nfsstats.rpccnt[NFSPROC_LOOKUP]++;
1517 len = sp->s_namlen;
1518 nfsm_reqhead(nfs_procids[NFSPROC_LOOKUP], sp->s_cred, NFSX_FH+NFSX_UNSIGNED+nfsm_rndup(len));
1519 nfsm_fhtom(vp);
1520 nfsm_strtom(sp->s_name, len, NFS_MAXNAMLEN);
1521 nfsm_request(vp, NFSPROC_LOOKUP, p, 1);
1522 if (fhp != NULL) {
1523 nfsm_disect(cp, caddr_t, NFSX_FH);
1524 bcopy(cp, (caddr_t)fhp, NFSX_FH);
1525 }
1526 nfsm_reqdone;
1527 return (error);
1528 }
1529
1530 /*
1531 * Kludge City..
1532 * - make nfs_bmap() essentially a no-op that does no translation
1533 * - do nfs_strategy() by faking physical I/O with nfs_readrpc/nfs_writerpc
1534 * after mapping the physical addresses into Kernel Virtual space in the
1535 * nfsiobuf area.
1536 * (Maybe I could use the process's page mapping, but I was concerned that
1537 * Kernel Write might not be enabled and also figured copyout() would do
1538 * a lot more work than bcopy() and also it currently happens in the
1539 * context of the swapper process (2).
1540 */
1541 nfs_bmap(vp, bn, vpp, bnp)
1542 struct vnode *vp;
1543 daddr_t bn;
1544 struct vnode **vpp;
1545 daddr_t *bnp;
1546 {
1547 if (vpp != NULL)
1548 *vpp = vp;
1549 if (bnp != NULL)
1550 *bnp = bn * btodb(vp->v_mount->mnt_stat.f_bsize);
1551 return (0);
1552 }
1553
1554 /*
1555 * Strategy routine for phys. i/o
1556 * If the biod's are running, queue a request
1557 * otherwise just call nfs_doio() to get it done
1558 */
1559 nfs_strategy(bp)
1560 register struct buf *bp;
1561 {
1562 register struct buf *dp;
1563 register int i;
1564 int error = 0;
1565 int fnd = 0;
1566
1567 /*
1568 * Set b_proc. It seems a bit silly to do it here, but since bread()
1569 * doesn't set it, I will.
1570 * Set b_proc == NULL for asynchronous ops, since these may still
1571 * be hanging about after the process terminates.
1572 */
1573 if ((bp->b_flags & B_PHYS) == 0) {
1574 if (bp->b_flags & B_ASYNC)
1575 bp->b_proc = (struct proc *)0;
1576 else
1577 bp->b_proc = curproc;
1578 }
1579 /*
1580 * If the op is asynchronous and an i/o daemon is waiting
1581 * queue the request, wake it up and wait for completion
1582 * otherwise just do it ourselves.
1583 */
1584 if ((bp->b_flags & B_ASYNC) == 0 || nfs_numasync == 0)
1585 return (nfs_doio(bp));
1586 for (i = 0; i < NFS_MAXASYNCDAEMON; i++) {
1587 if (nfs_iodwant[i]) {
1588 dp = &nfs_bqueue;
1589 bp->b_actf = NULL;
1590 bp->b_actb = dp->b_actb;
1591 *dp->b_actb = bp;
1592 dp->b_actb = &bp->b_actf;
1593 fnd++;
1594 wakeup((caddr_t)&nfs_iodwant[i]);
1595 break;
1596 }
1597 }
1598 if (!fnd)
1599 error = nfs_doio(bp);
1600 return (error);
1601 }
1602
1603 /*
1604 * Fun and games with i/o
1605 *
1606 * If the nfsiod's are not running, this is just called from nfs_strategy(),
1607 * otherwise it is called by the nfsiods to do what would normally be
1608 * partially disk interrupt driven.
1609 */
1610 nfs_doio(bp)
1611 register struct buf *bp;
1612 {
1613 register struct uio *uiop;
1614 register struct vnode *vp;
1615 struct nfsnode *np;
1616 struct ucred *cr;
1617 int error;
1618 struct uio uio;
1619 struct iovec io;
1620
1621 vp = bp->b_vp;
1622 np = VTONFS(vp);
1623 uiop = &uio;
1624 uiop->uio_iov = &io;
1625 uiop->uio_iovcnt = 1;
1626 uiop->uio_segflg = UIO_SYSSPACE;
1627 /*
1628 * Not to worry, `b_proc' will have been set to NULL
1629 * for asynchronous IO.
1630 */
1631 uiop->uio_procp = bp->b_proc;
1632
1633 /*
1634 * Always use credentials passed in the buffer header.
1635 */
1636 if (bp->b_flags & B_PHYS) {
1637 #if 0
1638 /*
1639 * This cannot happen in the current (12/16/93) NetBSD kernel
1640 * Is this an artifact of the pager implementation in
1641 * previous incarnations of BSD ??
1642 */
1643 if (bp->b_flags & B_DIRTY)
1644 uiop->uio_procp = pageproc;
1645 #endif
1646
1647 /* mapping was already done by vmapbuf */
1648 io.iov_base = bp->b_un.b_addr;
1649 io.iov_len = uiop->uio_resid = bp->b_bcount;
1650 uiop->uio_offset = bp->b_blkno * DEV_BSIZE;
1651 if (bp->b_flags & B_READ) {
1652 uiop->uio_rw = UIO_READ;
1653 nfsstats.read_physios++;
1654 bp->b_error = error = nfs_readrpc(vp, uiop, bp->b_rcred);
1655 } else {
1656 (void) vnode_pager_uncache(vp);
1657 uiop->uio_rw = UIO_WRITE;
1658 nfsstats.write_physios++;
1659 bp->b_error = error = nfs_writerpc(vp, uiop, bp->b_wcred);
1660 }
1661
1662 } else {
1663 if (bp->b_flags & B_READ) {
1664 io.iov_len = uiop->uio_resid = bp->b_bcount;
1665 io.iov_base = bp->b_un.b_addr;
1666 uiop->uio_rw = UIO_READ;
1667 switch (vp->v_type) {
1668 case VREG:
1669 uiop->uio_offset = bp->b_blkno * DEV_BSIZE;
1670 nfsstats.read_bios++;
1671 error = nfs_readrpc(vp, uiop, bp->b_rcred);
1672 break;
1673 case VLNK:
1674 uiop->uio_offset = 0;
1675 nfsstats.readlink_bios++;
1676 error = nfs_readlinkrpc(vp, uiop, bp->b_rcred);
1677 break;
1678 case VDIR:
1679 uiop->uio_offset = bp->b_lblkno;
1680 nfsstats.readdir_bios++;
1681 error = nfs_readdirrpc(vp, uiop, bp->b_rcred);
1682 /*
1683 * Save offset cookie in b_blkno.
1684 */
1685 bp->b_blkno = uiop->uio_offset;
1686 break;
1687 };
1688 bp->b_error = error;
1689 } else {
1690 io.iov_len = uiop->uio_resid = bp->b_dirtyend
1691 - bp->b_dirtyoff;
1692 uiop->uio_offset = (bp->b_blkno * DEV_BSIZE)
1693 + bp->b_dirtyoff;
1694 io.iov_base = bp->b_un.b_addr + bp->b_dirtyoff;
1695 uiop->uio_rw = UIO_WRITE;
1696 nfsstats.write_bios++;
1697 bp->b_error = error = nfs_writerpc(vp, uiop,
1698 bp->b_wcred);
1699 if (error) {
1700 np->n_error = error;
1701 np->n_flag |= NWRITEERR;
1702 }
1703 bp->b_dirtyoff = bp->b_dirtyend = 0;
1704 }
1705 }
1706 if (error)
1707 bp->b_flags |= B_ERROR;
1708 bp->b_resid = uiop->uio_resid;
1709 biodone(bp);
1710 return (error);
1711 }
1712
1713 /*
1714 * Mmap a file
1715 *
1716 * NB Currently unsupported.
1717 */
1718 /* ARGSUSED */
1719 nfs_mmap(vp, fflags, cred, p)
1720 struct vnode *vp;
1721 int fflags;
1722 struct ucred *cred;
1723 struct proc *p;
1724 {
1725
1726 return (EINVAL);
1727 }
1728
1729 /*
1730 * Flush all the blocks associated with a vnode.
1731 * Walk through the buffer pool and push any dirty pages
1732 * associated with the vnode.
1733 */
1734 /* ARGSUSED */
1735 nfs_fsync(vp, fflags, cred, waitfor, p)
1736 register struct vnode *vp;
1737 int fflags;
1738 struct ucred *cred;
1739 int waitfor;
1740 struct proc *p;
1741 {
1742 register struct nfsnode *np = VTONFS(vp);
1743 int error = 0;
1744
1745 if (np->n_flag & NMODIFIED) {
1746 np->n_flag &= ~NMODIFIED;
1747 vflushbuf(vp, waitfor == MNT_WAIT ? B_SYNC : 0);
1748 }
1749 if (!error && (np->n_flag & NWRITEERR))
1750 error = np->n_error;
1751 return (error);
1752 }
1753
1754 /*
1755 * NFS advisory byte-level locks.
1756 * Currently unsupported.
1757 */
1758 nfs_advlock(vp, id, op, fl, flags)
1759 struct vnode *vp;
1760 caddr_t id;
1761 int op;
1762 struct flock *fl;
1763 int flags;
1764 {
1765 register struct nfsnode *np = VTONFS(vp);
1766
1767 return (lf_advlock(&(np->n_lockf), np->n_size, id, op, fl, flags));
1768 }
1769
1770 /*
1771 * Print out the contents of an nfsnode.
1772 */
1773 int
1774 nfs_print(vp)
1775 struct vnode *vp;
1776 {
1777 register struct nfsnode *np = VTONFS(vp);
1778
1779 printf("tag VT_NFS, fileid %d fsid 0x%x",
1780 np->n_vattr.va_fileid, np->n_vattr.va_fsid);
1781 #ifdef FIFO
1782 if (vp->v_type == VFIFO)
1783 fifo_printinfo(vp);
1784 #endif /* FIFO */
1785 printf("%s\n", (np->n_flag & NLOCKED) ? " (LOCKED)" : "");
1786 if (np->n_lockholder == 0)
1787 return (0);
1788 printf("\towner pid %d", np->n_lockholder);
1789 if (np->n_lockwaiter)
1790 printf(" waiting pid %d", np->n_lockwaiter);
1791 printf("\n");
1792 return (0);
1793 }
1794
1795 /*
1796 * Attribute cache routines.
1797 * nfs_loadattrcache() - loads or updates the cache contents from attributes
1798 * that are on the mbuf list
1799 * nfs_getattrcache() - returns valid attributes if found in cache, returns
1800 * error otherwise
1801 */
1802
1803 /*
1804 * Load the attribute cache (that lives in the nfsnode entry) with
1805 * the values on the mbuf list and
1806 * Iff vap not NULL
1807 * copy the attributes to *vaper
1808 */
1809 nfs_loadattrcache(vpp, mdp, dposp, vaper)
1810 struct vnode **vpp;
1811 struct mbuf **mdp;
1812 caddr_t *dposp;
1813 struct vattr *vaper;
1814 {
1815 register struct vnode *vp = *vpp;
1816 register struct vattr *vap;
1817 register struct nfsv2_fattr *fp;
1818 extern struct vnodeops spec_nfsv2nodeops;
1819 register struct nfsnode *np;
1820 register long t1;
1821 caddr_t dpos, cp2;
1822 int error = 0;
1823 struct mbuf *md;
1824 enum vtype type;
1825 u_short mode;
1826 long rdev;
1827 struct timeval mtime;
1828 struct vnode *nvp;
1829
1830 md = *mdp;
1831 dpos = *dposp;
1832 t1 = (mtod(md, caddr_t)+md->m_len)-dpos;
1833 if (error = nfsm_disct(&md, &dpos, NFSX_FATTR, t1, TRUE, &cp2))
1834 return (error);
1835 fp = (struct nfsv2_fattr *)cp2;
1836 type = nfstov_type(fp->fa_type);
1837 mode = fxdr_unsigned(u_short, fp->fa_mode);
1838 if (type == VNON)
1839 type = ntov_type[mode&0x7];
1840 rdev = fxdr_unsigned(long, fp->fa_rdev);
1841 fxdr_time(&fp->fa_mtime, &mtime);
1842 /*
1843 * If v_type == VNON it is a new node, so fill in the v_type,
1844 * n_mtime fields. Check to see if it represents a special
1845 * device, and if so, check for a possible alias. Once the
1846 * correct vnode has been obtained, fill in the rest of the
1847 * information.
1848 */
1849 np = VTONFS(vp);
1850 if (vp->v_type == VNON) {
1851 if (type == VCHR && rdev == 0xffffffff)
1852 vp->v_type = type = VFIFO;
1853 else
1854 vp->v_type = type;
1855 if (vp->v_type == VFIFO) {
1856 #ifdef FIFO
1857 extern struct vnodeops fifo_nfsv2nodeops;
1858 vp->v_op = &fifo_nfsv2nodeops;
1859 #else
1860 return (EOPNOTSUPP);
1861 #endif /* FIFO */
1862 }
1863 if (vp->v_type == VCHR || vp->v_type == VBLK) {
1864 vp->v_op = &spec_nfsv2nodeops;
1865 if (nvp = checkalias(vp, (dev_t)rdev, vp->v_mount)) {
1866 /*
1867 * Reinitialize aliased node.
1868 */
1869 np = VTONFS(nvp);
1870 np->n_vnode = nvp;
1871 np->n_flag = 0;
1872 nfs_lock(nvp);
1873 bcopy((caddr_t)&VTONFS(vp)->n_fh,
1874 (caddr_t)&np->n_fh, NFSX_FH);
1875 insque(np, nfs_hash(&np->n_fh));
1876 np->n_attrstamp = 0;
1877 np->n_sillyrename = (struct sillyrename *)0;
1878 /*
1879 * Discard unneeded vnode and update actual one
1880 */
1881 vput(vp);
1882 *vpp = nvp;
1883 }
1884 }
1885 np->n_mtime = mtime.tv_sec;
1886 }
1887 vap = &np->n_vattr;
1888 vap->va_type = type;
1889 vap->va_mode = (mode & 07777);
1890 vap->va_nlink = fxdr_unsigned(u_short, fp->fa_nlink);
1891 vap->va_uid = fxdr_unsigned(uid_t, fp->fa_uid);
1892 vap->va_gid = fxdr_unsigned(gid_t, fp->fa_gid);
1893 vap->va_size = fxdr_unsigned(u_long, fp->fa_size);
1894 if ((np->n_flag & NMODIFIED) == 0 || vap->va_size > np->n_size) {
1895 np->n_size = vap->va_size;
1896 vnode_pager_setsize(vp, np->n_size);
1897 }
1898 vap->va_size_rsv = 0;
1899 vap->va_blocksize = fxdr_unsigned(long, fp->fa_blocksize);
1900 vap->va_rdev = (dev_t)rdev;
1901 vap->va_bytes = fxdr_unsigned(long, fp->fa_blocks) * NFS_FABLKSIZE;
1902 vap->va_bytes_rsv = 0;
1903 vap->va_fsid = vp->v_mount->mnt_stat.f_fsid.val[0];
1904 vap->va_fileid = fxdr_unsigned(long, fp->fa_fileid);
1905 /* jfw (at) ksr.com 6/2/93 */
1906 #if 0 /* bad assumption; Suns make full (and obvious) use of .usec fields */
1907 vap->va_atime.tv_sec = fxdr_unsigned(long, fp->fa_atime.tv_sec);
1908 vap->va_atime.tv_usec = 0;
1909 vap->va_flags = fxdr_unsigned(u_long, fp->fa_atime.tv_usec);
1910 vap->va_mtime = mtime;
1911 vap->va_ctime.tv_sec = fxdr_unsigned(long, fp->fa_ctime.tv_sec);
1912 vap->va_ctime.tv_usec = 0;
1913 vap->va_gen = fxdr_unsigned(u_long, fp->fa_ctime.tv_usec);
1914 #else
1915 fxdr_time(&fp->fa_atime, &vap->va_atime);
1916 vap->va_mtime = mtime;
1917 fxdr_time(&fp->fa_ctime, &vap->va_ctime);
1918 vap->va_gen = 0; /* can reliably learn nothing about this via NFS. */
1919 vap->va_flags = 0; /* can reliably learn nothing about this via NFS. */
1920 #endif
1921 np->n_attrstamp = time.tv_sec;
1922 *dposp = dpos;
1923 *mdp = md;
1924 if (vaper != NULL) {
1925 bcopy((caddr_t)vap, (caddr_t)vaper, sizeof(*vap));
1926 if ((np->n_flag & NMODIFIED) && (np->n_size > vap->va_size))
1927 vaper->va_size = np->n_size;
1928 }
1929 return (0);
1930 }
1931
1932 /*
1933 * Check the time stamp
1934 * If the cache is valid, copy contents to *vap and return 0
1935 * otherwise return an error
1936 */
1937 nfs_getattrcache(vp, vap)
1938 register struct vnode *vp;
1939 struct vattr *vap;
1940 {
1941 register struct nfsnode *np;
1942
1943 np = VTONFS(vp);
1944 if ((time.tv_sec-np->n_attrstamp) < NFS_ATTRTIMEO) {
1945 nfsstats.attrcache_hits++;
1946 bcopy((caddr_t)&np->n_vattr,(caddr_t)vap,sizeof(struct vattr));
1947 if ((np->n_flag & NMODIFIED) == 0) {
1948 np->n_size = vap->va_size;
1949 vnode_pager_setsize(vp, np->n_size);
1950 } else if (np->n_size > vap->va_size)
1951 vap->va_size = np->n_size;
1952 if (np->n_delayed_atime.tv_sec != VNOVAL)
1953 vap->va_atime = np->n_delayed_atime;
1954 if (np->n_delayed_mtime.tv_sec != VNOVAL)
1955 vap->va_mtime = np->n_delayed_mtime;
1956 return (0);
1957 } else {
1958 nfsstats.attrcache_misses++;
1959 return (ENOENT);
1960 }
1961 }
1962
1963 /*
1964 * Read wrapper for special devices.
1965 */
1966 nfsspec_read(vp, uio, ioflag, cred)
1967 struct vnode *vp;
1968 struct uio *uio;
1969 int ioflag;
1970 struct ucred *cred;
1971 {
1972 /*
1973 * Set access time.
1974 */
1975 VTONFS(vp)->n_delayed_atime = time;
1976 return (spec_read(vp, uio, ioflag, cred));
1977 }
1978
1979 /*
1980 * Write wrapper for special devices.
1981 */
1982 nfsspec_write(vp, uio, ioflag, cred)
1983 struct vnode *vp;
1984 struct uio *uio;
1985 int ioflag;
1986 struct ucred *cred;
1987 {
1988 /*
1989 * Set change time.
1990 */
1991 VTONFS(vp)->n_delayed_mtime = time;
1992 return (spec_write(vp, uio, ioflag, cred));
1993 }
1994
1995 /*
1996 * Close wrapper for special devices.
1997 *
1998 * Update the times then do device close.
1999 */
2000 nfsspec_close(vp, fflag, cred, p)
2001 struct vnode *vp;
2002 int fflag;
2003 struct ucred *cred;
2004 struct proc *p;
2005 {
2006 if (VTONFS(vp)->n_delayed_mtime.tv_sec != VNOVAL ||
2007 VTONFS(vp)->n_delayed_atime.tv_sec != VNOVAL) {
2008 struct vattr va;
2009 VATTR_NULL(&va);
2010 nfs_setattr(vp, &va, cred, p);
2011 }
2012 return (spec_close(vp, fflag, cred, p));
2013 }
2014
2015 #ifdef FIFO
2016 /*
2017 * Read wrapper for special devices.
2018 */
2019 nfsfifo_read(vp, uio, ioflag, cred)
2020 struct vnode *vp;
2021 struct uio *uio;
2022 int ioflag;
2023 struct ucred *cred;
2024 {
2025 /*
2026 * Set access time.
2027 */
2028 VTONFS(vp)->n_delayed_atime = time;
2029 return (fifo_read(vp, uio, ioflag, cred));
2030 }
2031
2032 /*
2033 * Write wrapper for special devices.
2034 */
2035 nfsfifo_write(vp, uio, ioflag, cred)
2036 struct vnode *vp;
2037 struct uio *uio;
2038 int ioflag;
2039 struct ucred *cred;
2040 {
2041 /*
2042 * Set change time.
2043 */
2044 VTONFS(vp)->n_delayed_mtime = time;
2045 return (fifo_write(vp, uio, ioflag, cred));
2046 }
2047
2048 /*
2049 * Close wrapper for special devices.
2050 *
2051 * Update the times then do device close.
2052 */
2053 nfsfifo_close(vp, fflag, cred, p)
2054 struct vnode *vp;
2055 int fflag;
2056 struct ucred *cred;
2057 struct proc *p;
2058 {
2059 if (VTONFS(vp)->n_delayed_mtime.tv_sec != VNOVAL ||
2060 VTONFS(vp)->n_delayed_atime.tv_sec != VNOVAL) {
2061 struct vattr va;
2062 VATTR_NULL(&va);
2063 nfs_setattr(vp, &va, cred, p);
2064 }
2065 return (fifo_close(vp, fflag, cred, p));
2066 }
2067 #endif /* FIFO */
2068