Home | History | Annotate | Line # | Download | only in nfs
nfs_subs.c revision 1.153.6.2
      1  1.153.6.2      yamt /*	$NetBSD: nfs_subs.c,v 1.153.6.2 2005/11/29 21:23:33 yamt 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.127       agc  * 3. Neither the name of the University nor the names of its contributors
     19        1.1       cgd  *    may be used to endorse or promote products derived from this software
     20        1.1       cgd  *    without specific prior written permission.
     21        1.1       cgd  *
     22        1.1       cgd  * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
     23        1.1       cgd  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
     24        1.1       cgd  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
     25        1.1       cgd  * ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
     26        1.1       cgd  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
     27        1.1       cgd  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
     28        1.1       cgd  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
     29        1.1       cgd  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
     30        1.1       cgd  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
     31        1.1       cgd  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
     32        1.1       cgd  * SUCH DAMAGE.
     33        1.1       cgd  *
     34       1.25      fvdl  *	@(#)nfs_subs.c	8.8 (Berkeley) 5/22/95
     35        1.1       cgd  */
     36        1.1       cgd 
     37       1.83      fvdl /*
     38       1.83      fvdl  * Copyright 2000 Wasabi Systems, Inc.
     39       1.83      fvdl  * All rights reserved.
     40       1.83      fvdl  *
     41       1.83      fvdl  * Written by Frank van der Linden for Wasabi Systems, Inc.
     42       1.83      fvdl  *
     43       1.83      fvdl  * Redistribution and use in source and binary forms, with or without
     44       1.83      fvdl  * modification, are permitted provided that the following conditions
     45       1.83      fvdl  * are met:
     46       1.83      fvdl  * 1. Redistributions of source code must retain the above copyright
     47       1.83      fvdl  *    notice, this list of conditions and the following disclaimer.
     48       1.83      fvdl  * 2. Redistributions in binary form must reproduce the above copyright
     49       1.83      fvdl  *    notice, this list of conditions and the following disclaimer in the
     50       1.83      fvdl  *    documentation and/or other materials provided with the distribution.
     51       1.83      fvdl  * 3. All advertising materials mentioning features or use of this software
     52       1.83      fvdl  *    must display the following acknowledgement:
     53       1.83      fvdl  *      This product includes software developed for the NetBSD Project by
     54       1.83      fvdl  *      Wasabi Systems, Inc.
     55       1.83      fvdl  * 4. The name of Wasabi Systems, Inc. may not be used to endorse
     56       1.83      fvdl  *    or promote products derived from this software without specific prior
     57       1.83      fvdl  *    written permission.
     58       1.83      fvdl  *
     59       1.83      fvdl  * THIS SOFTWARE IS PROVIDED BY WASABI SYSTEMS, INC. ``AS IS'' AND
     60       1.83      fvdl  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
     61       1.83      fvdl  * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
     62       1.83      fvdl  * PURPOSE ARE DISCLAIMED.  IN NO EVENT SHALL WASABI SYSTEMS, INC
     63       1.83      fvdl  * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
     64       1.83      fvdl  * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
     65       1.83      fvdl  * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
     66       1.83      fvdl  * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
     67       1.83      fvdl  * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
     68       1.83      fvdl  * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
     69       1.83      fvdl  * POSSIBILITY OF SUCH DAMAGE.
     70       1.83      fvdl  */
     71       1.99     lukem 
     72       1.99     lukem #include <sys/cdefs.h>
     73  1.153.6.2      yamt __KERNEL_RCSID(0, "$NetBSD: nfs_subs.c,v 1.153.6.2 2005/11/29 21:23:33 yamt Exp $");
     74       1.83      fvdl 
     75       1.55   thorpej #include "fs_nfs.h"
     76       1.82     bjh21 #include "opt_nfs.h"
     77       1.61   thorpej #include "opt_nfsserver.h"
     78       1.62  jonathan #include "opt_iso.h"
     79       1.76      fvdl #include "opt_inet.h"
     80       1.25      fvdl 
     81        1.1       cgd /*
     82        1.1       cgd  * These functions support the macros and help fiddle mbuf chains for
     83        1.1       cgd  * the nfs op functions. They do things like create the rpc header and
     84        1.1       cgd  * copy data between mbuf chains and uio lists.
     85        1.1       cgd  */
     86        1.9   mycroft #include <sys/param.h>
     87        1.9   mycroft #include <sys/proc.h>
     88        1.9   mycroft #include <sys/systm.h>
     89        1.9   mycroft #include <sys/kernel.h>
     90        1.9   mycroft #include <sys/mount.h>
     91        1.9   mycroft #include <sys/vnode.h>
     92        1.9   mycroft #include <sys/namei.h>
     93        1.9   mycroft #include <sys/mbuf.h>
     94       1.12   mycroft #include <sys/socket.h>
     95       1.12   mycroft #include <sys/stat.h>
     96       1.25      fvdl #include <sys/malloc.h>
     97       1.98      fvdl #include <sys/filedesc.h>
     98       1.30      fvdl #include <sys/time.h>
     99       1.43      fvdl #include <sys/dirent.h>
    100  1.153.6.2      yamt #include <sys/once.h>
    101        1.1       cgd 
    102       1.51       mrg #include <uvm/uvm_extern.h>
    103       1.51       mrg 
    104        1.9   mycroft #include <nfs/rpcv2.h>
    105       1.25      fvdl #include <nfs/nfsproto.h>
    106        1.9   mycroft #include <nfs/nfsnode.h>
    107        1.9   mycroft #include <nfs/nfs.h>
    108        1.9   mycroft #include <nfs/xdr_subs.h>
    109        1.9   mycroft #include <nfs/nfsm_subs.h>
    110       1.12   mycroft #include <nfs/nfsmount.h>
    111       1.12   mycroft #include <nfs/nqnfs.h>
    112       1.12   mycroft #include <nfs/nfsrtt.h>
    113       1.24  christos #include <nfs/nfs_var.h>
    114       1.12   mycroft 
    115       1.12   mycroft #include <miscfs/specfs/specdev.h>
    116       1.24  christos 
    117       1.12   mycroft #include <netinet/in.h>
    118       1.12   mycroft #ifdef ISO
    119       1.12   mycroft #include <netiso/iso.h>
    120       1.12   mycroft #endif
    121        1.1       cgd 
    122        1.1       cgd /*
    123        1.1       cgd  * Data items converted to xdr at startup, since they are constant
    124        1.1       cgd  * This is kinda hokey, but may save a little time doing byte swaps
    125        1.1       cgd  */
    126       1.22       cgd u_int32_t nfs_xdrneg1;
    127       1.22       cgd u_int32_t rpc_call, rpc_vers, rpc_reply, rpc_msgdenied, rpc_autherr,
    128       1.25      fvdl 	rpc_mismatch, rpc_auth_unix, rpc_msgaccepted,
    129       1.12   mycroft 	rpc_auth_kerb;
    130       1.25      fvdl u_int32_t nfs_prog, nqnfs_prog, nfs_true, nfs_false;
    131       1.12   mycroft 
    132        1.1       cgd /* And other global data */
    133       1.90  jdolecek const nfstype nfsv2_type[9] =
    134       1.90  jdolecek 	{ NFNON, NFREG, NFDIR, NFBLK, NFCHR, NFLNK, NFNON, NFCHR, NFNON };
    135       1.90  jdolecek const nfstype nfsv3_type[9] =
    136       1.90  jdolecek 	{ NFNON, NFREG, NFDIR, NFBLK, NFCHR, NFLNK, NFSOCK, NFFIFO, NFNON };
    137       1.90  jdolecek const enum vtype nv2tov_type[8] =
    138       1.90  jdolecek 	{ VNON, VREG, VDIR, VBLK, VCHR, VLNK, VNON, VNON };
    139       1.90  jdolecek const enum vtype nv3tov_type[8] =
    140       1.90  jdolecek 	{ VNON, VREG, VDIR, VBLK, VCHR, VLNK, VSOCK, VFIFO };
    141       1.25      fvdl int nfs_ticks;
    142      1.100       chs int nfs_commitsize;
    143      1.108  christos 
    144      1.108  christos MALLOC_DEFINE(M_NFSDIROFF, "NFS diroff", "NFS directory cookies");
    145       1.25      fvdl 
    146       1.35   thorpej /* NFS client/server stats. */
    147       1.35   thorpej struct nfsstats nfsstats;
    148       1.35   thorpej 
    149       1.25      fvdl /*
    150       1.25      fvdl  * Mapping of old NFS Version 2 RPC numbers to generic numbers.
    151       1.25      fvdl  */
    152       1.90  jdolecek const int nfsv3_procid[NFS_NPROCS] = {
    153       1.25      fvdl 	NFSPROC_NULL,
    154       1.25      fvdl 	NFSPROC_GETATTR,
    155       1.25      fvdl 	NFSPROC_SETATTR,
    156       1.25      fvdl 	NFSPROC_NOOP,
    157       1.25      fvdl 	NFSPROC_LOOKUP,
    158       1.25      fvdl 	NFSPROC_READLINK,
    159       1.25      fvdl 	NFSPROC_READ,
    160       1.25      fvdl 	NFSPROC_NOOP,
    161       1.25      fvdl 	NFSPROC_WRITE,
    162       1.25      fvdl 	NFSPROC_CREATE,
    163       1.25      fvdl 	NFSPROC_REMOVE,
    164       1.25      fvdl 	NFSPROC_RENAME,
    165       1.25      fvdl 	NFSPROC_LINK,
    166       1.25      fvdl 	NFSPROC_SYMLINK,
    167       1.25      fvdl 	NFSPROC_MKDIR,
    168       1.25      fvdl 	NFSPROC_RMDIR,
    169       1.25      fvdl 	NFSPROC_READDIR,
    170       1.25      fvdl 	NFSPROC_FSSTAT,
    171       1.25      fvdl 	NFSPROC_NOOP,
    172       1.25      fvdl 	NFSPROC_NOOP,
    173       1.25      fvdl 	NFSPROC_NOOP,
    174       1.25      fvdl 	NFSPROC_NOOP,
    175       1.25      fvdl 	NFSPROC_NOOP,
    176       1.25      fvdl 	NFSPROC_NOOP,
    177       1.25      fvdl 	NFSPROC_NOOP,
    178       1.25      fvdl 	NFSPROC_NOOP
    179       1.25      fvdl };
    180       1.25      fvdl 
    181       1.25      fvdl /*
    182       1.25      fvdl  * and the reverse mapping from generic to Version 2 procedure numbers
    183       1.25      fvdl  */
    184       1.90  jdolecek const int nfsv2_procid[NFS_NPROCS] = {
    185       1.25      fvdl 	NFSV2PROC_NULL,
    186       1.25      fvdl 	NFSV2PROC_GETATTR,
    187       1.25      fvdl 	NFSV2PROC_SETATTR,
    188       1.25      fvdl 	NFSV2PROC_LOOKUP,
    189       1.25      fvdl 	NFSV2PROC_NOOP,
    190       1.25      fvdl 	NFSV2PROC_READLINK,
    191       1.25      fvdl 	NFSV2PROC_READ,
    192       1.25      fvdl 	NFSV2PROC_WRITE,
    193       1.25      fvdl 	NFSV2PROC_CREATE,
    194       1.25      fvdl 	NFSV2PROC_MKDIR,
    195       1.25      fvdl 	NFSV2PROC_SYMLINK,
    196       1.25      fvdl 	NFSV2PROC_CREATE,
    197       1.25      fvdl 	NFSV2PROC_REMOVE,
    198       1.25      fvdl 	NFSV2PROC_RMDIR,
    199       1.25      fvdl 	NFSV2PROC_RENAME,
    200       1.25      fvdl 	NFSV2PROC_LINK,
    201       1.25      fvdl 	NFSV2PROC_READDIR,
    202       1.25      fvdl 	NFSV2PROC_NOOP,
    203       1.25      fvdl 	NFSV2PROC_STATFS,
    204       1.25      fvdl 	NFSV2PROC_NOOP,
    205       1.25      fvdl 	NFSV2PROC_NOOP,
    206       1.25      fvdl 	NFSV2PROC_NOOP,
    207       1.25      fvdl 	NFSV2PROC_NOOP,
    208       1.25      fvdl 	NFSV2PROC_NOOP,
    209       1.25      fvdl 	NFSV2PROC_NOOP,
    210       1.25      fvdl 	NFSV2PROC_NOOP,
    211       1.25      fvdl };
    212       1.25      fvdl 
    213       1.25      fvdl /*
    214       1.25      fvdl  * Maps errno values to nfs error numbers.
    215       1.25      fvdl  * Use NFSERR_IO as the catch all for ones not specifically defined in
    216       1.25      fvdl  * RFC 1094.
    217       1.25      fvdl  */
    218       1.90  jdolecek static const u_char nfsrv_v2errmap[ELAST] = {
    219       1.25      fvdl   NFSERR_PERM,	NFSERR_NOENT,	NFSERR_IO,	NFSERR_IO,	NFSERR_IO,
    220       1.25      fvdl   NFSERR_NXIO,	NFSERR_IO,	NFSERR_IO,	NFSERR_IO,	NFSERR_IO,
    221       1.25      fvdl   NFSERR_IO,	NFSERR_IO,	NFSERR_ACCES,	NFSERR_IO,	NFSERR_IO,
    222       1.25      fvdl   NFSERR_IO,	NFSERR_EXIST,	NFSERR_IO,	NFSERR_NODEV,	NFSERR_NOTDIR,
    223       1.25      fvdl   NFSERR_ISDIR,	NFSERR_IO,	NFSERR_IO,	NFSERR_IO,	NFSERR_IO,
    224       1.25      fvdl   NFSERR_IO,	NFSERR_FBIG,	NFSERR_NOSPC,	NFSERR_IO,	NFSERR_ROFS,
    225       1.25      fvdl   NFSERR_IO,	NFSERR_IO,	NFSERR_IO,	NFSERR_IO,	NFSERR_IO,
    226       1.25      fvdl   NFSERR_IO,	NFSERR_IO,	NFSERR_IO,	NFSERR_IO,	NFSERR_IO,
    227       1.25      fvdl   NFSERR_IO,	NFSERR_IO,	NFSERR_IO,	NFSERR_IO,	NFSERR_IO,
    228       1.25      fvdl   NFSERR_IO,	NFSERR_IO,	NFSERR_IO,	NFSERR_IO,	NFSERR_IO,
    229       1.25      fvdl   NFSERR_IO,	NFSERR_IO,	NFSERR_IO,	NFSERR_IO,	NFSERR_IO,
    230       1.25      fvdl   NFSERR_IO,	NFSERR_IO,	NFSERR_IO,	NFSERR_IO,	NFSERR_IO,
    231       1.25      fvdl   NFSERR_IO,	NFSERR_IO,	NFSERR_NAMETOL,	NFSERR_IO,	NFSERR_IO,
    232       1.25      fvdl   NFSERR_NOTEMPTY, NFSERR_IO,	NFSERR_IO,	NFSERR_DQUOT,	NFSERR_STALE,
    233       1.25      fvdl   NFSERR_IO,	NFSERR_IO,	NFSERR_IO,	NFSERR_IO,	NFSERR_IO,
    234       1.25      fvdl   NFSERR_IO,	NFSERR_IO,	NFSERR_IO,	NFSERR_IO,	NFSERR_IO,
    235       1.52     mikel   NFSERR_IO,	NFSERR_IO,
    236       1.25      fvdl };
    237       1.25      fvdl 
    238       1.25      fvdl /*
    239       1.25      fvdl  * Maps errno values to nfs error numbers.
    240       1.25      fvdl  * Although it is not obvious whether or not NFS clients really care if
    241       1.25      fvdl  * a returned error value is in the specified list for the procedure, the
    242       1.25      fvdl  * safest thing to do is filter them appropriately. For Version 2, the
    243       1.25      fvdl  * X/Open XNFS document is the only specification that defines error values
    244       1.25      fvdl  * for each RPC (The RFC simply lists all possible error values for all RPCs),
    245       1.25      fvdl  * so I have decided to not do this for Version 2.
    246       1.25      fvdl  * The first entry is the default error return and the rest are the valid
    247       1.25      fvdl  * errors for that RPC in increasing numeric order.
    248       1.25      fvdl  */
    249       1.90  jdolecek static const short nfsv3err_null[] = {
    250       1.25      fvdl 	0,
    251       1.25      fvdl 	0,
    252       1.25      fvdl };
    253       1.25      fvdl 
    254       1.90  jdolecek static const short nfsv3err_getattr[] = {
    255       1.25      fvdl 	NFSERR_IO,
    256       1.25      fvdl 	NFSERR_IO,
    257       1.25      fvdl 	NFSERR_STALE,
    258       1.25      fvdl 	NFSERR_BADHANDLE,
    259       1.25      fvdl 	NFSERR_SERVERFAULT,
    260       1.25      fvdl 	0,
    261       1.25      fvdl };
    262       1.25      fvdl 
    263       1.90  jdolecek static const short nfsv3err_setattr[] = {
    264       1.25      fvdl 	NFSERR_IO,
    265       1.25      fvdl 	NFSERR_PERM,
    266       1.25      fvdl 	NFSERR_IO,
    267       1.25      fvdl 	NFSERR_ACCES,
    268       1.25      fvdl 	NFSERR_INVAL,
    269       1.25      fvdl 	NFSERR_NOSPC,
    270       1.25      fvdl 	NFSERR_ROFS,
    271       1.25      fvdl 	NFSERR_DQUOT,
    272       1.25      fvdl 	NFSERR_STALE,
    273       1.25      fvdl 	NFSERR_BADHANDLE,
    274       1.25      fvdl 	NFSERR_NOT_SYNC,
    275       1.25      fvdl 	NFSERR_SERVERFAULT,
    276       1.25      fvdl 	0,
    277       1.25      fvdl };
    278       1.25      fvdl 
    279       1.90  jdolecek static const short nfsv3err_lookup[] = {
    280       1.25      fvdl 	NFSERR_IO,
    281       1.25      fvdl 	NFSERR_NOENT,
    282       1.25      fvdl 	NFSERR_IO,
    283       1.25      fvdl 	NFSERR_ACCES,
    284       1.25      fvdl 	NFSERR_NOTDIR,
    285       1.25      fvdl 	NFSERR_NAMETOL,
    286       1.25      fvdl 	NFSERR_STALE,
    287       1.25      fvdl 	NFSERR_BADHANDLE,
    288       1.25      fvdl 	NFSERR_SERVERFAULT,
    289       1.25      fvdl 	0,
    290       1.25      fvdl };
    291       1.25      fvdl 
    292       1.90  jdolecek static const short nfsv3err_access[] = {
    293       1.25      fvdl 	NFSERR_IO,
    294       1.25      fvdl 	NFSERR_IO,
    295       1.25      fvdl 	NFSERR_STALE,
    296       1.25      fvdl 	NFSERR_BADHANDLE,
    297       1.25      fvdl 	NFSERR_SERVERFAULT,
    298       1.25      fvdl 	0,
    299       1.25      fvdl };
    300       1.25      fvdl 
    301       1.90  jdolecek static const short nfsv3err_readlink[] = {
    302       1.25      fvdl 	NFSERR_IO,
    303       1.25      fvdl 	NFSERR_IO,
    304       1.25      fvdl 	NFSERR_ACCES,
    305       1.25      fvdl 	NFSERR_INVAL,
    306       1.25      fvdl 	NFSERR_STALE,
    307       1.25      fvdl 	NFSERR_BADHANDLE,
    308       1.25      fvdl 	NFSERR_NOTSUPP,
    309       1.25      fvdl 	NFSERR_SERVERFAULT,
    310       1.25      fvdl 	0,
    311       1.25      fvdl };
    312       1.25      fvdl 
    313       1.90  jdolecek static const short nfsv3err_read[] = {
    314       1.25      fvdl 	NFSERR_IO,
    315       1.25      fvdl 	NFSERR_IO,
    316       1.25      fvdl 	NFSERR_NXIO,
    317       1.25      fvdl 	NFSERR_ACCES,
    318       1.25      fvdl 	NFSERR_INVAL,
    319       1.25      fvdl 	NFSERR_STALE,
    320       1.25      fvdl 	NFSERR_BADHANDLE,
    321       1.25      fvdl 	NFSERR_SERVERFAULT,
    322       1.67      fvdl 	NFSERR_JUKEBOX,
    323       1.25      fvdl 	0,
    324       1.25      fvdl };
    325       1.25      fvdl 
    326       1.90  jdolecek static const short nfsv3err_write[] = {
    327       1.25      fvdl 	NFSERR_IO,
    328       1.25      fvdl 	NFSERR_IO,
    329       1.25      fvdl 	NFSERR_ACCES,
    330       1.25      fvdl 	NFSERR_INVAL,
    331       1.25      fvdl 	NFSERR_FBIG,
    332       1.25      fvdl 	NFSERR_NOSPC,
    333       1.25      fvdl 	NFSERR_ROFS,
    334       1.25      fvdl 	NFSERR_DQUOT,
    335       1.25      fvdl 	NFSERR_STALE,
    336       1.25      fvdl 	NFSERR_BADHANDLE,
    337       1.25      fvdl 	NFSERR_SERVERFAULT,
    338       1.68      fvdl 	NFSERR_JUKEBOX,
    339       1.25      fvdl 	0,
    340       1.25      fvdl };
    341       1.25      fvdl 
    342       1.90  jdolecek static const short nfsv3err_create[] = {
    343       1.25      fvdl 	NFSERR_IO,
    344       1.25      fvdl 	NFSERR_IO,
    345       1.25      fvdl 	NFSERR_ACCES,
    346       1.25      fvdl 	NFSERR_EXIST,
    347       1.25      fvdl 	NFSERR_NOTDIR,
    348       1.25      fvdl 	NFSERR_NOSPC,
    349       1.25      fvdl 	NFSERR_ROFS,
    350       1.25      fvdl 	NFSERR_NAMETOL,
    351       1.25      fvdl 	NFSERR_DQUOT,
    352       1.25      fvdl 	NFSERR_STALE,
    353       1.25      fvdl 	NFSERR_BADHANDLE,
    354       1.25      fvdl 	NFSERR_NOTSUPP,
    355       1.25      fvdl 	NFSERR_SERVERFAULT,
    356       1.25      fvdl 	0,
    357       1.25      fvdl };
    358       1.25      fvdl 
    359       1.90  jdolecek static const short nfsv3err_mkdir[] = {
    360       1.25      fvdl 	NFSERR_IO,
    361       1.25      fvdl 	NFSERR_IO,
    362       1.25      fvdl 	NFSERR_ACCES,
    363       1.25      fvdl 	NFSERR_EXIST,
    364       1.25      fvdl 	NFSERR_NOTDIR,
    365       1.25      fvdl 	NFSERR_NOSPC,
    366       1.25      fvdl 	NFSERR_ROFS,
    367       1.25      fvdl 	NFSERR_NAMETOL,
    368       1.25      fvdl 	NFSERR_DQUOT,
    369       1.25      fvdl 	NFSERR_STALE,
    370       1.25      fvdl 	NFSERR_BADHANDLE,
    371       1.25      fvdl 	NFSERR_NOTSUPP,
    372       1.25      fvdl 	NFSERR_SERVERFAULT,
    373       1.25      fvdl 	0,
    374       1.25      fvdl };
    375       1.25      fvdl 
    376       1.90  jdolecek static const short nfsv3err_symlink[] = {
    377       1.25      fvdl 	NFSERR_IO,
    378       1.25      fvdl 	NFSERR_IO,
    379       1.25      fvdl 	NFSERR_ACCES,
    380       1.25      fvdl 	NFSERR_EXIST,
    381       1.25      fvdl 	NFSERR_NOTDIR,
    382       1.25      fvdl 	NFSERR_NOSPC,
    383       1.25      fvdl 	NFSERR_ROFS,
    384       1.25      fvdl 	NFSERR_NAMETOL,
    385       1.25      fvdl 	NFSERR_DQUOT,
    386       1.25      fvdl 	NFSERR_STALE,
    387       1.25      fvdl 	NFSERR_BADHANDLE,
    388       1.25      fvdl 	NFSERR_NOTSUPP,
    389       1.25      fvdl 	NFSERR_SERVERFAULT,
    390       1.25      fvdl 	0,
    391       1.25      fvdl };
    392       1.25      fvdl 
    393       1.90  jdolecek static const short nfsv3err_mknod[] = {
    394       1.25      fvdl 	NFSERR_IO,
    395       1.25      fvdl 	NFSERR_IO,
    396       1.25      fvdl 	NFSERR_ACCES,
    397       1.25      fvdl 	NFSERR_EXIST,
    398       1.25      fvdl 	NFSERR_NOTDIR,
    399       1.25      fvdl 	NFSERR_NOSPC,
    400       1.25      fvdl 	NFSERR_ROFS,
    401       1.25      fvdl 	NFSERR_NAMETOL,
    402       1.25      fvdl 	NFSERR_DQUOT,
    403       1.25      fvdl 	NFSERR_STALE,
    404       1.25      fvdl 	NFSERR_BADHANDLE,
    405       1.25      fvdl 	NFSERR_NOTSUPP,
    406       1.25      fvdl 	NFSERR_SERVERFAULT,
    407       1.25      fvdl 	NFSERR_BADTYPE,
    408       1.25      fvdl 	0,
    409       1.25      fvdl };
    410       1.25      fvdl 
    411       1.90  jdolecek static const short nfsv3err_remove[] = {
    412       1.25      fvdl 	NFSERR_IO,
    413       1.25      fvdl 	NFSERR_NOENT,
    414       1.25      fvdl 	NFSERR_IO,
    415       1.25      fvdl 	NFSERR_ACCES,
    416       1.25      fvdl 	NFSERR_NOTDIR,
    417       1.25      fvdl 	NFSERR_ROFS,
    418       1.25      fvdl 	NFSERR_NAMETOL,
    419       1.25      fvdl 	NFSERR_STALE,
    420       1.25      fvdl 	NFSERR_BADHANDLE,
    421       1.25      fvdl 	NFSERR_SERVERFAULT,
    422       1.25      fvdl 	0,
    423       1.25      fvdl };
    424       1.25      fvdl 
    425       1.90  jdolecek static const short nfsv3err_rmdir[] = {
    426       1.25      fvdl 	NFSERR_IO,
    427       1.25      fvdl 	NFSERR_NOENT,
    428       1.25      fvdl 	NFSERR_IO,
    429       1.25      fvdl 	NFSERR_ACCES,
    430       1.25      fvdl 	NFSERR_EXIST,
    431       1.25      fvdl 	NFSERR_NOTDIR,
    432       1.25      fvdl 	NFSERR_INVAL,
    433       1.25      fvdl 	NFSERR_ROFS,
    434       1.25      fvdl 	NFSERR_NAMETOL,
    435       1.25      fvdl 	NFSERR_NOTEMPTY,
    436       1.25      fvdl 	NFSERR_STALE,
    437       1.25      fvdl 	NFSERR_BADHANDLE,
    438       1.25      fvdl 	NFSERR_NOTSUPP,
    439       1.25      fvdl 	NFSERR_SERVERFAULT,
    440       1.25      fvdl 	0,
    441       1.25      fvdl };
    442       1.25      fvdl 
    443       1.90  jdolecek static const short nfsv3err_rename[] = {
    444       1.25      fvdl 	NFSERR_IO,
    445       1.25      fvdl 	NFSERR_NOENT,
    446       1.25      fvdl 	NFSERR_IO,
    447       1.25      fvdl 	NFSERR_ACCES,
    448       1.25      fvdl 	NFSERR_EXIST,
    449       1.25      fvdl 	NFSERR_XDEV,
    450       1.25      fvdl 	NFSERR_NOTDIR,
    451       1.25      fvdl 	NFSERR_ISDIR,
    452       1.25      fvdl 	NFSERR_INVAL,
    453       1.25      fvdl 	NFSERR_NOSPC,
    454       1.25      fvdl 	NFSERR_ROFS,
    455       1.25      fvdl 	NFSERR_MLINK,
    456       1.25      fvdl 	NFSERR_NAMETOL,
    457       1.25      fvdl 	NFSERR_NOTEMPTY,
    458       1.25      fvdl 	NFSERR_DQUOT,
    459       1.25      fvdl 	NFSERR_STALE,
    460       1.25      fvdl 	NFSERR_BADHANDLE,
    461       1.25      fvdl 	NFSERR_NOTSUPP,
    462       1.25      fvdl 	NFSERR_SERVERFAULT,
    463       1.25      fvdl 	0,
    464       1.25      fvdl };
    465       1.25      fvdl 
    466       1.90  jdolecek static const short nfsv3err_link[] = {
    467       1.25      fvdl 	NFSERR_IO,
    468       1.25      fvdl 	NFSERR_IO,
    469       1.25      fvdl 	NFSERR_ACCES,
    470       1.25      fvdl 	NFSERR_EXIST,
    471       1.25      fvdl 	NFSERR_XDEV,
    472       1.25      fvdl 	NFSERR_NOTDIR,
    473       1.25      fvdl 	NFSERR_INVAL,
    474       1.25      fvdl 	NFSERR_NOSPC,
    475       1.25      fvdl 	NFSERR_ROFS,
    476       1.25      fvdl 	NFSERR_MLINK,
    477       1.25      fvdl 	NFSERR_NAMETOL,
    478       1.25      fvdl 	NFSERR_DQUOT,
    479       1.25      fvdl 	NFSERR_STALE,
    480       1.25      fvdl 	NFSERR_BADHANDLE,
    481       1.25      fvdl 	NFSERR_NOTSUPP,
    482       1.25      fvdl 	NFSERR_SERVERFAULT,
    483       1.25      fvdl 	0,
    484       1.25      fvdl };
    485       1.25      fvdl 
    486       1.90  jdolecek static const short nfsv3err_readdir[] = {
    487       1.25      fvdl 	NFSERR_IO,
    488       1.25      fvdl 	NFSERR_IO,
    489       1.25      fvdl 	NFSERR_ACCES,
    490       1.25      fvdl 	NFSERR_NOTDIR,
    491       1.25      fvdl 	NFSERR_STALE,
    492       1.25      fvdl 	NFSERR_BADHANDLE,
    493       1.25      fvdl 	NFSERR_BAD_COOKIE,
    494       1.25      fvdl 	NFSERR_TOOSMALL,
    495       1.25      fvdl 	NFSERR_SERVERFAULT,
    496       1.25      fvdl 	0,
    497       1.25      fvdl };
    498       1.25      fvdl 
    499       1.90  jdolecek static const short nfsv3err_readdirplus[] = {
    500       1.25      fvdl 	NFSERR_IO,
    501       1.25      fvdl 	NFSERR_IO,
    502       1.25      fvdl 	NFSERR_ACCES,
    503       1.25      fvdl 	NFSERR_NOTDIR,
    504       1.25      fvdl 	NFSERR_STALE,
    505       1.25      fvdl 	NFSERR_BADHANDLE,
    506       1.25      fvdl 	NFSERR_BAD_COOKIE,
    507       1.25      fvdl 	NFSERR_NOTSUPP,
    508       1.25      fvdl 	NFSERR_TOOSMALL,
    509       1.25      fvdl 	NFSERR_SERVERFAULT,
    510       1.25      fvdl 	0,
    511       1.25      fvdl };
    512       1.25      fvdl 
    513       1.90  jdolecek static const short nfsv3err_fsstat[] = {
    514       1.25      fvdl 	NFSERR_IO,
    515       1.25      fvdl 	NFSERR_IO,
    516       1.25      fvdl 	NFSERR_STALE,
    517       1.25      fvdl 	NFSERR_BADHANDLE,
    518       1.25      fvdl 	NFSERR_SERVERFAULT,
    519       1.25      fvdl 	0,
    520       1.25      fvdl };
    521       1.25      fvdl 
    522       1.90  jdolecek static const short nfsv3err_fsinfo[] = {
    523       1.25      fvdl 	NFSERR_STALE,
    524       1.25      fvdl 	NFSERR_STALE,
    525       1.25      fvdl 	NFSERR_BADHANDLE,
    526       1.25      fvdl 	NFSERR_SERVERFAULT,
    527       1.25      fvdl 	0,
    528       1.25      fvdl };
    529       1.25      fvdl 
    530       1.90  jdolecek static const short nfsv3err_pathconf[] = {
    531       1.25      fvdl 	NFSERR_STALE,
    532       1.25      fvdl 	NFSERR_STALE,
    533       1.25      fvdl 	NFSERR_BADHANDLE,
    534       1.25      fvdl 	NFSERR_SERVERFAULT,
    535       1.25      fvdl 	0,
    536       1.25      fvdl };
    537       1.25      fvdl 
    538       1.90  jdolecek static const short nfsv3err_commit[] = {
    539       1.25      fvdl 	NFSERR_IO,
    540       1.25      fvdl 	NFSERR_IO,
    541       1.25      fvdl 	NFSERR_STALE,
    542       1.25      fvdl 	NFSERR_BADHANDLE,
    543       1.25      fvdl 	NFSERR_SERVERFAULT,
    544       1.25      fvdl 	0,
    545       1.25      fvdl };
    546       1.25      fvdl 
    547       1.90  jdolecek static const short * const nfsrv_v3errmap[] = {
    548       1.25      fvdl 	nfsv3err_null,
    549       1.25      fvdl 	nfsv3err_getattr,
    550       1.25      fvdl 	nfsv3err_setattr,
    551       1.25      fvdl 	nfsv3err_lookup,
    552       1.25      fvdl 	nfsv3err_access,
    553       1.25      fvdl 	nfsv3err_readlink,
    554       1.25      fvdl 	nfsv3err_read,
    555       1.25      fvdl 	nfsv3err_write,
    556       1.25      fvdl 	nfsv3err_create,
    557       1.25      fvdl 	nfsv3err_mkdir,
    558       1.25      fvdl 	nfsv3err_symlink,
    559       1.25      fvdl 	nfsv3err_mknod,
    560       1.25      fvdl 	nfsv3err_remove,
    561       1.25      fvdl 	nfsv3err_rmdir,
    562       1.25      fvdl 	nfsv3err_rename,
    563       1.25      fvdl 	nfsv3err_link,
    564       1.25      fvdl 	nfsv3err_readdir,
    565       1.25      fvdl 	nfsv3err_readdirplus,
    566       1.25      fvdl 	nfsv3err_fsstat,
    567       1.25      fvdl 	nfsv3err_fsinfo,
    568       1.25      fvdl 	nfsv3err_pathconf,
    569       1.25      fvdl 	nfsv3err_commit,
    570       1.25      fvdl };
    571       1.25      fvdl 
    572       1.12   mycroft extern struct nfsrtt nfsrtt;
    573       1.12   mycroft extern time_t nqnfsstarttime;
    574       1.12   mycroft extern int nqsrv_clockskew;
    575       1.12   mycroft extern int nqsrv_writeslack;
    576       1.12   mycroft extern int nqsrv_maxlease;
    577       1.92  jdolecek extern const int nqnfs_piggy[NFS_NPROCS];
    578       1.25      fvdl extern struct nfsnodehashhead *nfsnodehashtbl;
    579       1.25      fvdl extern u_long nfsnodehash;
    580        1.1       cgd 
    581       1.46      fvdl u_long nfsdirhashmask;
    582       1.18   mycroft 
    583       1.43      fvdl int nfs_webnamei __P((struct nameidata *, struct vnode *, struct proc *));
    584       1.43      fvdl 
    585        1.1       cgd /*
    586        1.1       cgd  * Create the header for an rpc request packet
    587        1.1       cgd  * The hsiz is the size of the rest of the nfs request header.
    588        1.1       cgd  * (just used to decide if a cluster is a good idea)
    589        1.1       cgd  */
    590       1.12   mycroft struct mbuf *
    591      1.115  drochner nfsm_reqh(np, procid, hsiz, bposp)
    592      1.115  drochner 	struct nfsnode *np;
    593        1.1       cgd 	u_long procid;
    594        1.1       cgd 	int hsiz;
    595       1.12   mycroft 	caddr_t *bposp;
    596       1.12   mycroft {
    597       1.75  augustss 	struct mbuf *mb;
    598       1.86      fvdl 	caddr_t bpos;
    599      1.115  drochner #ifndef NFS_V2_ONLY
    600       1.86      fvdl 	struct nfsmount *nmp;
    601       1.75  augustss 	u_int32_t *tl;
    602       1.12   mycroft 	int nqflag;
    603       1.86      fvdl #endif
    604       1.12   mycroft 
    605      1.109      matt 	mb = m_get(M_WAIT, MT_DATA);
    606      1.109      matt 	MCLAIM(mb, &nfs_mowner);
    607       1.12   mycroft 	if (hsiz >= MINCLSIZE)
    608      1.109      matt 		m_clget(mb, M_WAIT);
    609       1.12   mycroft 	mb->m_len = 0;
    610       1.12   mycroft 	bpos = mtod(mb, caddr_t);
    611      1.148     perry 
    612      1.115  drochner #ifndef NFS_V2_ONLY
    613       1.12   mycroft 	/*
    614       1.12   mycroft 	 * For NQNFS, add lease request.
    615       1.12   mycroft 	 */
    616      1.115  drochner 	if (np) {
    617      1.115  drochner 		nmp = VFSTONFS(np->n_vnode->v_mount);
    618       1.12   mycroft 		if (nmp->nm_flag & NFSMNT_NQNFS) {
    619      1.115  drochner 			nqflag = NQNFS_NEEDLEASE(np, procid);
    620       1.12   mycroft 			if (nqflag) {
    621       1.22       cgd 				nfsm_build(tl, u_int32_t *, 2*NFSX_UNSIGNED);
    622       1.12   mycroft 				*tl++ = txdr_unsigned(nqflag);
    623       1.12   mycroft 				*tl = txdr_unsigned(nmp->nm_leaseterm);
    624       1.12   mycroft 			} else {
    625       1.22       cgd 				nfsm_build(tl, u_int32_t *, NFSX_UNSIGNED);
    626       1.12   mycroft 				*tl = 0;
    627       1.12   mycroft 			}
    628       1.12   mycroft 		}
    629      1.115  drochner 	}
    630       1.84     bjh21 #endif
    631       1.12   mycroft 	/* Finally, return values */
    632       1.12   mycroft 	*bposp = bpos;
    633       1.12   mycroft 	return (mb);
    634       1.12   mycroft }
    635       1.12   mycroft 
    636       1.12   mycroft /*
    637       1.12   mycroft  * Build the RPC header and fill in the authorization info.
    638       1.12   mycroft  * The authorization string argument is only used when the credentials
    639       1.12   mycroft  * come from outside of the kernel.
    640       1.12   mycroft  * Returns the head of the mbuf list.
    641       1.12   mycroft  */
    642       1.12   mycroft struct mbuf *
    643       1.25      fvdl nfsm_rpchead(cr, nmflag, procid, auth_type, auth_len, auth_str, verf_len,
    644       1.25      fvdl 	verf_str, mrest, mrest_len, mbp, xidp)
    645       1.75  augustss 	struct ucred *cr;
    646       1.25      fvdl 	int nmflag;
    647       1.12   mycroft 	int procid;
    648       1.12   mycroft 	int auth_type;
    649       1.12   mycroft 	int auth_len;
    650       1.12   mycroft 	char *auth_str;
    651       1.25      fvdl 	int verf_len;
    652       1.25      fvdl 	char *verf_str;
    653       1.12   mycroft 	struct mbuf *mrest;
    654       1.12   mycroft 	int mrest_len;
    655       1.12   mycroft 	struct mbuf **mbp;
    656       1.22       cgd 	u_int32_t *xidp;
    657        1.1       cgd {
    658       1.75  augustss 	struct mbuf *mb;
    659       1.75  augustss 	u_int32_t *tl;
    660       1.75  augustss 	caddr_t bpos;
    661       1.75  augustss 	int i;
    662      1.109      matt 	struct mbuf *mreq;
    663       1.12   mycroft 	int siz, grpsiz, authsiz;
    664        1.1       cgd 
    665       1.12   mycroft 	authsiz = nfsm_rndup(auth_len);
    666      1.109      matt 	mb = m_gethdr(M_WAIT, MT_DATA);
    667      1.109      matt 	MCLAIM(mb, &nfs_mowner);
    668       1.25      fvdl 	if ((authsiz + 10 * NFSX_UNSIGNED) >= MINCLSIZE) {
    669      1.109      matt 		m_clget(mb, M_WAIT);
    670       1.25      fvdl 	} else if ((authsiz + 10 * NFSX_UNSIGNED) < MHLEN) {
    671       1.25      fvdl 		MH_ALIGN(mb, authsiz + 10 * NFSX_UNSIGNED);
    672       1.12   mycroft 	} else {
    673       1.25      fvdl 		MH_ALIGN(mb, 8 * NFSX_UNSIGNED);
    674        1.1       cgd 	}
    675       1.12   mycroft 	mb->m_len = 0;
    676       1.12   mycroft 	mreq = mb;
    677       1.12   mycroft 	bpos = mtod(mb, caddr_t);
    678       1.12   mycroft 
    679       1.12   mycroft 	/*
    680       1.12   mycroft 	 * First the RPC header.
    681       1.12   mycroft 	 */
    682       1.25      fvdl 	nfsm_build(tl, u_int32_t *, 8 * NFSX_UNSIGNED);
    683       1.30      fvdl 
    684      1.126      yamt 	*tl++ = *xidp = nfs_getxid();
    685        1.1       cgd 	*tl++ = rpc_call;
    686        1.1       cgd 	*tl++ = rpc_vers;
    687       1.25      fvdl 	if (nmflag & NFSMNT_NQNFS) {
    688       1.12   mycroft 		*tl++ = txdr_unsigned(NQNFS_PROG);
    689       1.25      fvdl 		*tl++ = txdr_unsigned(NQNFS_VER3);
    690        1.1       cgd 	} else {
    691       1.12   mycroft 		*tl++ = txdr_unsigned(NFS_PROG);
    692       1.25      fvdl 		if (nmflag & NFSMNT_NFSV3)
    693       1.25      fvdl 			*tl++ = txdr_unsigned(NFS_VER3);
    694       1.25      fvdl 		else
    695       1.25      fvdl 			*tl++ = txdr_unsigned(NFS_VER2);
    696        1.1       cgd 	}
    697       1.25      fvdl 	if (nmflag & NFSMNT_NFSV3)
    698       1.25      fvdl 		*tl++ = txdr_unsigned(procid);
    699       1.25      fvdl 	else
    700       1.25      fvdl 		*tl++ = txdr_unsigned(nfsv2_procid[procid]);
    701       1.12   mycroft 
    702       1.12   mycroft 	/*
    703       1.12   mycroft 	 * And then the authorization cred.
    704       1.12   mycroft 	 */
    705       1.12   mycroft 	*tl++ = txdr_unsigned(auth_type);
    706       1.12   mycroft 	*tl = txdr_unsigned(authsiz);
    707       1.12   mycroft 	switch (auth_type) {
    708       1.12   mycroft 	case RPCAUTH_UNIX:
    709       1.22       cgd 		nfsm_build(tl, u_int32_t *, auth_len);
    710       1.12   mycroft 		*tl++ = 0;		/* stamp ?? */
    711       1.12   mycroft 		*tl++ = 0;		/* NULL hostname */
    712       1.12   mycroft 		*tl++ = txdr_unsigned(cr->cr_uid);
    713       1.19       jtc 		*tl++ = txdr_unsigned(cr->cr_gid);
    714       1.12   mycroft 		grpsiz = (auth_len >> 2) - 5;
    715       1.12   mycroft 		*tl++ = txdr_unsigned(grpsiz);
    716       1.20   mycroft 		for (i = 0; i < grpsiz; i++)
    717       1.12   mycroft 			*tl++ = txdr_unsigned(cr->cr_groups[i]);
    718       1.12   mycroft 		break;
    719       1.25      fvdl 	case RPCAUTH_KERB4:
    720       1.12   mycroft 		siz = auth_len;
    721       1.12   mycroft 		while (siz > 0) {
    722       1.12   mycroft 			if (M_TRAILINGSPACE(mb) == 0) {
    723      1.109      matt 				struct mbuf *mb2;
    724      1.109      matt 				mb2 = m_get(M_WAIT, MT_DATA);
    725      1.109      matt 				MCLAIM(mb2, &nfs_mowner);
    726       1.12   mycroft 				if (siz >= MINCLSIZE)
    727      1.109      matt 					m_clget(mb2, M_WAIT);
    728       1.12   mycroft 				mb->m_next = mb2;
    729       1.12   mycroft 				mb = mb2;
    730       1.12   mycroft 				mb->m_len = 0;
    731       1.12   mycroft 				bpos = mtod(mb, caddr_t);
    732       1.12   mycroft 			}
    733       1.12   mycroft 			i = min(siz, M_TRAILINGSPACE(mb));
    734       1.63     perry 			memcpy(bpos, auth_str, i);
    735       1.12   mycroft 			mb->m_len += i;
    736       1.12   mycroft 			auth_str += i;
    737       1.12   mycroft 			bpos += i;
    738       1.12   mycroft 			siz -= i;
    739       1.12   mycroft 		}
    740       1.12   mycroft 		if ((siz = (nfsm_rndup(auth_len) - auth_len)) > 0) {
    741       1.12   mycroft 			for (i = 0; i < siz; i++)
    742       1.12   mycroft 				*bpos++ = '\0';
    743       1.12   mycroft 			mb->m_len += siz;
    744       1.12   mycroft 		}
    745       1.12   mycroft 		break;
    746       1.12   mycroft 	};
    747       1.25      fvdl 
    748       1.25      fvdl 	/*
    749       1.25      fvdl 	 * And the verifier...
    750       1.25      fvdl 	 */
    751       1.25      fvdl 	nfsm_build(tl, u_int32_t *, 2 * NFSX_UNSIGNED);
    752       1.25      fvdl 	if (verf_str) {
    753       1.25      fvdl 		*tl++ = txdr_unsigned(RPCAUTH_KERB4);
    754       1.25      fvdl 		*tl = txdr_unsigned(verf_len);
    755       1.25      fvdl 		siz = verf_len;
    756       1.25      fvdl 		while (siz > 0) {
    757       1.25      fvdl 			if (M_TRAILINGSPACE(mb) == 0) {
    758      1.109      matt 				struct mbuf *mb2;
    759      1.109      matt 				mb2 = m_get(M_WAIT, MT_DATA);
    760      1.109      matt 				MCLAIM(mb2, &nfs_mowner);
    761       1.25      fvdl 				if (siz >= MINCLSIZE)
    762      1.109      matt 					m_clget(mb2, M_WAIT);
    763       1.25      fvdl 				mb->m_next = mb2;
    764       1.25      fvdl 				mb = mb2;
    765       1.25      fvdl 				mb->m_len = 0;
    766       1.25      fvdl 				bpos = mtod(mb, caddr_t);
    767       1.25      fvdl 			}
    768       1.25      fvdl 			i = min(siz, M_TRAILINGSPACE(mb));
    769       1.63     perry 			memcpy(bpos, verf_str, i);
    770       1.25      fvdl 			mb->m_len += i;
    771       1.25      fvdl 			verf_str += i;
    772       1.25      fvdl 			bpos += i;
    773       1.25      fvdl 			siz -= i;
    774       1.25      fvdl 		}
    775       1.25      fvdl 		if ((siz = (nfsm_rndup(verf_len) - verf_len)) > 0) {
    776       1.25      fvdl 			for (i = 0; i < siz; i++)
    777       1.25      fvdl 				*bpos++ = '\0';
    778       1.25      fvdl 			mb->m_len += siz;
    779       1.25      fvdl 		}
    780       1.25      fvdl 	} else {
    781       1.25      fvdl 		*tl++ = txdr_unsigned(RPCAUTH_NULL);
    782       1.25      fvdl 		*tl = 0;
    783       1.25      fvdl 	}
    784       1.12   mycroft 	mb->m_next = mrest;
    785       1.25      fvdl 	mreq->m_pkthdr.len = authsiz + 10 * NFSX_UNSIGNED + mrest_len;
    786       1.12   mycroft 	mreq->m_pkthdr.rcvif = (struct ifnet *)0;
    787       1.12   mycroft 	*mbp = mb;
    788        1.1       cgd 	return (mreq);
    789        1.1       cgd }
    790        1.1       cgd 
    791        1.1       cgd /*
    792        1.1       cgd  * copies mbuf chain to the uio scatter/gather list
    793        1.1       cgd  */
    794       1.24  christos int
    795        1.1       cgd nfsm_mbuftouio(mrep, uiop, siz, dpos)
    796        1.1       cgd 	struct mbuf **mrep;
    797       1.75  augustss 	struct uio *uiop;
    798        1.1       cgd 	int siz;
    799        1.1       cgd 	caddr_t *dpos;
    800        1.1       cgd {
    801       1.75  augustss 	char *mbufcp, *uiocp;
    802       1.75  augustss 	int xfer, left, len;
    803       1.75  augustss 	struct mbuf *mp;
    804        1.1       cgd 	long uiosiz, rem;
    805        1.1       cgd 	int error = 0;
    806        1.1       cgd 
    807        1.1       cgd 	mp = *mrep;
    808        1.1       cgd 	mbufcp = *dpos;
    809        1.1       cgd 	len = mtod(mp, caddr_t)+mp->m_len-mbufcp;
    810        1.1       cgd 	rem = nfsm_rndup(siz)-siz;
    811        1.1       cgd 	while (siz > 0) {
    812        1.1       cgd 		if (uiop->uio_iovcnt <= 0 || uiop->uio_iov == NULL)
    813        1.1       cgd 			return (EFBIG);
    814        1.1       cgd 		left = uiop->uio_iov->iov_len;
    815        1.1       cgd 		uiocp = uiop->uio_iov->iov_base;
    816        1.1       cgd 		if (left > siz)
    817        1.1       cgd 			left = siz;
    818        1.1       cgd 		uiosiz = left;
    819        1.1       cgd 		while (left > 0) {
    820        1.1       cgd 			while (len == 0) {
    821        1.1       cgd 				mp = mp->m_next;
    822        1.1       cgd 				if (mp == NULL)
    823        1.1       cgd 					return (EBADRPC);
    824        1.1       cgd 				mbufcp = mtod(mp, caddr_t);
    825        1.1       cgd 				len = mp->m_len;
    826        1.1       cgd 			}
    827        1.1       cgd 			xfer = (left > len) ? len : left;
    828        1.1       cgd #ifdef notdef
    829        1.1       cgd 			/* Not Yet.. */
    830        1.1       cgd 			if (uiop->uio_iov->iov_op != NULL)
    831        1.1       cgd 				(*(uiop->uio_iov->iov_op))
    832        1.1       cgd 				(mbufcp, uiocp, xfer);
    833        1.1       cgd 			else
    834        1.1       cgd #endif
    835        1.1       cgd 			if (uiop->uio_segflg == UIO_SYSSPACE)
    836       1.63     perry 				memcpy(uiocp, mbufcp, xfer);
    837        1.1       cgd 			else
    838      1.150  christos 				if ((error = copyout_proc(uiop->uio_procp,
    839      1.150  christos 				    mbufcp, uiocp, xfer)) != 0)
    840      1.150  christos 					return error;
    841        1.1       cgd 			left -= xfer;
    842        1.1       cgd 			len -= xfer;
    843        1.1       cgd 			mbufcp += xfer;
    844        1.1       cgd 			uiocp += xfer;
    845        1.1       cgd 			uiop->uio_offset += xfer;
    846        1.1       cgd 			uiop->uio_resid -= xfer;
    847        1.1       cgd 		}
    848        1.1       cgd 		if (uiop->uio_iov->iov_len <= siz) {
    849        1.1       cgd 			uiop->uio_iovcnt--;
    850        1.1       cgd 			uiop->uio_iov++;
    851        1.1       cgd 		} else {
    852       1.95     lukem 			uiop->uio_iov->iov_base =
    853       1.95     lukem 			    (caddr_t)uiop->uio_iov->iov_base + uiosiz;
    854        1.1       cgd 			uiop->uio_iov->iov_len -= uiosiz;
    855        1.1       cgd 		}
    856        1.1       cgd 		siz -= uiosiz;
    857        1.1       cgd 	}
    858        1.1       cgd 	*dpos = mbufcp;
    859        1.1       cgd 	*mrep = mp;
    860        1.1       cgd 	if (rem > 0) {
    861        1.1       cgd 		if (len < rem)
    862        1.1       cgd 			error = nfs_adv(mrep, dpos, rem, len);
    863        1.1       cgd 		else
    864        1.1       cgd 			*dpos += rem;
    865        1.1       cgd 	}
    866        1.1       cgd 	return (error);
    867        1.1       cgd }
    868        1.1       cgd 
    869        1.1       cgd /*
    870       1.29      fvdl  * copies a uio scatter/gather list to an mbuf chain.
    871       1.29      fvdl  * NOTE: can ony handle iovcnt == 1
    872        1.1       cgd  */
    873       1.24  christos int
    874        1.1       cgd nfsm_uiotombuf(uiop, mq, siz, bpos)
    875       1.75  augustss 	struct uio *uiop;
    876        1.1       cgd 	struct mbuf **mq;
    877        1.1       cgd 	int siz;
    878        1.1       cgd 	caddr_t *bpos;
    879        1.1       cgd {
    880       1.75  augustss 	char *uiocp;
    881       1.75  augustss 	struct mbuf *mp, *mp2;
    882       1.75  augustss 	int xfer, left, mlen;
    883        1.1       cgd 	int uiosiz, clflg, rem;
    884        1.1       cgd 	char *cp;
    885        1.1       cgd 
    886       1.29      fvdl #ifdef DIAGNOSTIC
    887       1.29      fvdl 	if (uiop->uio_iovcnt != 1)
    888       1.29      fvdl 		panic("nfsm_uiotombuf: iovcnt != 1");
    889       1.29      fvdl #endif
    890       1.29      fvdl 
    891        1.1       cgd 	if (siz > MLEN)		/* or should it >= MCLBYTES ?? */
    892        1.1       cgd 		clflg = 1;
    893        1.1       cgd 	else
    894        1.1       cgd 		clflg = 0;
    895        1.1       cgd 	rem = nfsm_rndup(siz)-siz;
    896       1.12   mycroft 	mp = mp2 = *mq;
    897        1.1       cgd 	while (siz > 0) {
    898        1.1       cgd 		left = uiop->uio_iov->iov_len;
    899        1.1       cgd 		uiocp = uiop->uio_iov->iov_base;
    900        1.1       cgd 		if (left > siz)
    901        1.1       cgd 			left = siz;
    902        1.1       cgd 		uiosiz = left;
    903        1.1       cgd 		while (left > 0) {
    904       1.12   mycroft 			mlen = M_TRAILINGSPACE(mp);
    905       1.12   mycroft 			if (mlen == 0) {
    906      1.109      matt 				mp = m_get(M_WAIT, MT_DATA);
    907      1.109      matt 				MCLAIM(mp, &nfs_mowner);
    908       1.12   mycroft 				if (clflg)
    909      1.109      matt 					m_clget(mp, M_WAIT);
    910       1.12   mycroft 				mp->m_len = 0;
    911       1.12   mycroft 				mp2->m_next = mp;
    912       1.12   mycroft 				mp2 = mp;
    913       1.12   mycroft 				mlen = M_TRAILINGSPACE(mp);
    914       1.12   mycroft 			}
    915       1.12   mycroft 			xfer = (left > mlen) ? mlen : left;
    916      1.150  christos 			cp = mtod(mp, caddr_t) + mp->m_len;
    917        1.1       cgd #ifdef notdef
    918        1.1       cgd 			/* Not Yet.. */
    919        1.1       cgd 			if (uiop->uio_iov->iov_op != NULL)
    920      1.150  christos 				(*(uiop->uio_iov->iov_op))(uiocp, cp, xfer);
    921        1.1       cgd 			else
    922        1.1       cgd #endif
    923        1.1       cgd 			if (uiop->uio_segflg == UIO_SYSSPACE)
    924      1.150  christos 				(void)memcpy(cp, uiocp, xfer);
    925        1.1       cgd 			else
    926      1.150  christos 				/*XXX: Check error */
    927      1.150  christos 				(void)copyin_proc(uiop->uio_procp, uiocp,
    928      1.150  christos 				    cp, xfer);
    929       1.12   mycroft 			mp->m_len += xfer;
    930        1.1       cgd 			left -= xfer;
    931        1.1       cgd 			uiocp += xfer;
    932        1.1       cgd 			uiop->uio_offset += xfer;
    933        1.1       cgd 			uiop->uio_resid -= xfer;
    934        1.1       cgd 		}
    935       1.95     lukem 		uiop->uio_iov->iov_base = (caddr_t)uiop->uio_iov->iov_base +
    936       1.95     lukem 		    uiosiz;
    937       1.29      fvdl 		uiop->uio_iov->iov_len -= uiosiz;
    938        1.1       cgd 		siz -= uiosiz;
    939        1.1       cgd 	}
    940        1.1       cgd 	if (rem > 0) {
    941       1.12   mycroft 		if (rem > M_TRAILINGSPACE(mp)) {
    942      1.109      matt 			mp = m_get(M_WAIT, MT_DATA);
    943      1.109      matt 			MCLAIM(mp, &nfs_mowner);
    944        1.1       cgd 			mp->m_len = 0;
    945        1.1       cgd 			mp2->m_next = mp;
    946        1.1       cgd 		}
    947      1.150  christos 		cp = mtod(mp, caddr_t) + mp->m_len;
    948        1.1       cgd 		for (left = 0; left < rem; left++)
    949        1.1       cgd 			*cp++ = '\0';
    950        1.1       cgd 		mp->m_len += rem;
    951        1.1       cgd 		*bpos = cp;
    952        1.1       cgd 	} else
    953        1.1       cgd 		*bpos = mtod(mp, caddr_t)+mp->m_len;
    954        1.1       cgd 	*mq = mp;
    955        1.1       cgd 	return (0);
    956        1.1       cgd }
    957        1.1       cgd 
    958        1.1       cgd /*
    959       1.39      fvdl  * Get at least "siz" bytes of correctly aligned data.
    960       1.39      fvdl  * When called the mbuf pointers are not necessarily correct,
    961       1.39      fvdl  * dsosp points to what ought to be in m_data and left contains
    962      1.148     perry  * what ought to be in m_len.
    963       1.12   mycroft  * This is used by the macros nfsm_dissect and nfsm_dissecton for tough
    964        1.1       cgd  * cases. (The macros use the vars. dpos and dpos2)
    965        1.1       cgd  */
    966       1.24  christos int
    967       1.12   mycroft nfsm_disct(mdp, dposp, siz, left, cp2)
    968        1.1       cgd 	struct mbuf **mdp;
    969        1.1       cgd 	caddr_t *dposp;
    970        1.1       cgd 	int siz;
    971        1.1       cgd 	int left;
    972        1.1       cgd 	caddr_t *cp2;
    973        1.1       cgd {
    974       1.75  augustss 	struct mbuf *m1, *m2;
    975       1.39      fvdl 	struct mbuf *havebuf = NULL;
    976       1.39      fvdl 	caddr_t src = *dposp;
    977       1.39      fvdl 	caddr_t dst;
    978       1.39      fvdl 	int len;
    979       1.39      fvdl 
    980       1.39      fvdl #ifdef DEBUG
    981       1.39      fvdl 	if (left < 0)
    982      1.148     perry 		panic("nfsm_disct: left < 0");
    983       1.39      fvdl #endif
    984       1.39      fvdl 	m1 = *mdp;
    985       1.39      fvdl 	/*
    986       1.39      fvdl 	 * Skip through the mbuf chain looking for an mbuf with
    987       1.39      fvdl 	 * some data. If the first mbuf found has enough data
    988       1.39      fvdl 	 * and it is correctly aligned return it.
    989       1.39      fvdl 	 */
    990        1.1       cgd 	while (left == 0) {
    991       1.39      fvdl 		havebuf = m1;
    992       1.39      fvdl 		*mdp = m1 = m1->m_next;
    993       1.39      fvdl 		if (m1 == NULL)
    994        1.1       cgd 			return (EBADRPC);
    995       1.39      fvdl 		src = mtod(m1, caddr_t);
    996       1.39      fvdl 		left = m1->m_len;
    997       1.39      fvdl 		/*
    998       1.39      fvdl 		 * If we start a new mbuf and it is big enough
    999       1.39      fvdl 		 * and correctly aligned just return it, don't
   1000       1.39      fvdl 		 * do any pull up.
   1001       1.39      fvdl 		 */
   1002       1.39      fvdl 		if (left >= siz && nfsm_aligned(src)) {
   1003       1.39      fvdl 			*cp2 = src;
   1004       1.39      fvdl 			*dposp = src + siz;
   1005       1.39      fvdl 			return (0);
   1006       1.39      fvdl 		}
   1007        1.1       cgd 	}
   1008       1.39      fvdl 	if (m1->m_flags & M_EXT) {
   1009       1.39      fvdl 		if (havebuf) {
   1010       1.39      fvdl 			/* If the first mbuf with data has external data
   1011       1.39      fvdl 			 * and there is a previous empty mbuf use it
   1012       1.39      fvdl 			 * to move the data into.
   1013       1.39      fvdl 			 */
   1014       1.39      fvdl 			m2 = m1;
   1015       1.39      fvdl 			*mdp = m1 = havebuf;
   1016       1.39      fvdl 			if (m1->m_flags & M_EXT) {
   1017       1.41   thorpej 				MEXTREMOVE(m1);
   1018        1.1       cgd 			}
   1019       1.39      fvdl 		} else {
   1020       1.39      fvdl 			/*
   1021       1.39      fvdl 			 * If the first mbuf has a external data
   1022       1.39      fvdl 			 * and there is no previous empty mbuf
   1023       1.39      fvdl 			 * allocate a new mbuf and move the external
   1024      1.148     perry 			 * data to the new mbuf. Also make the first
   1025       1.39      fvdl 			 * mbuf look empty.
   1026       1.39      fvdl 			 */
   1027       1.39      fvdl 			m2 = m_get(M_WAIT, MT_DATA);
   1028       1.39      fvdl 			m2->m_ext = m1->m_ext;
   1029       1.39      fvdl 			m2->m_data = src;
   1030       1.39      fvdl 			m2->m_len = left;
   1031       1.41   thorpej 			MCLADDREFERENCE(m1, m2);
   1032       1.41   thorpej 			MEXTREMOVE(m1);
   1033       1.39      fvdl 			m2->m_next = m1->m_next;
   1034       1.39      fvdl 			m1->m_next = m2;
   1035        1.1       cgd 		}
   1036       1.39      fvdl 		m1->m_len = 0;
   1037      1.129    itojun 		if (m1->m_flags & M_PKTHDR)
   1038      1.129    itojun 			dst = m1->m_pktdat;
   1039      1.129    itojun 		else
   1040      1.129    itojun 			dst = m1->m_dat;
   1041      1.129    itojun 		m1->m_data = dst;
   1042       1.39      fvdl 	} else {
   1043       1.39      fvdl 		/*
   1044       1.39      fvdl 		 * If the first mbuf has no external data
   1045       1.39      fvdl 		 * move the data to the front of the mbuf.
   1046       1.39      fvdl 		 */
   1047      1.129    itojun 		if (m1->m_flags & M_PKTHDR)
   1048      1.129    itojun 			dst = m1->m_pktdat;
   1049      1.129    itojun 		else
   1050      1.129    itojun 			dst = m1->m_dat;
   1051      1.129    itojun 		m1->m_data = dst;
   1052      1.129    itojun 		if (dst != src)
   1053       1.63     perry 			memmove(dst, src, left);
   1054      1.148     perry 		dst += left;
   1055       1.39      fvdl 		m1->m_len = left;
   1056       1.39      fvdl 		m2 = m1->m_next;
   1057        1.1       cgd 	}
   1058      1.129    itojun 	*cp2 = m1->m_data;
   1059       1.39      fvdl 	*dposp = mtod(m1, caddr_t) + siz;
   1060       1.39      fvdl 	/*
   1061       1.39      fvdl 	 * Loop through mbufs pulling data up into first mbuf until
   1062       1.39      fvdl 	 * the first mbuf is full or there is no more data to
   1063       1.39      fvdl 	 * pullup.
   1064       1.39      fvdl 	 */
   1065      1.129    itojun 	while ((len = M_TRAILINGSPACE(m1)) != 0 && m2) {
   1066       1.39      fvdl 		if ((len = min(len, m2->m_len)) != 0)
   1067       1.63     perry 			memcpy(dst, m2->m_data, len);
   1068       1.39      fvdl 		m1->m_len += len;
   1069       1.39      fvdl 		dst += len;
   1070       1.39      fvdl 		m2->m_data += len;
   1071       1.39      fvdl 		m2->m_len -= len;
   1072       1.39      fvdl 		m2 = m2->m_next;
   1073       1.39      fvdl 	}
   1074       1.39      fvdl 	if (m1->m_len < siz)
   1075       1.39      fvdl 		return (EBADRPC);
   1076        1.1       cgd 	return (0);
   1077        1.1       cgd }
   1078        1.1       cgd 
   1079        1.1       cgd /*
   1080        1.1       cgd  * Advance the position in the mbuf chain.
   1081        1.1       cgd  */
   1082       1.24  christos int
   1083        1.1       cgd nfs_adv(mdp, dposp, offs, left)
   1084        1.1       cgd 	struct mbuf **mdp;
   1085        1.1       cgd 	caddr_t *dposp;
   1086        1.1       cgd 	int offs;
   1087        1.1       cgd 	int left;
   1088        1.1       cgd {
   1089       1.75  augustss 	struct mbuf *m;
   1090       1.75  augustss 	int s;
   1091        1.1       cgd 
   1092        1.1       cgd 	m = *mdp;
   1093        1.1       cgd 	s = left;
   1094        1.1       cgd 	while (s < offs) {
   1095        1.1       cgd 		offs -= s;
   1096        1.1       cgd 		m = m->m_next;
   1097        1.1       cgd 		if (m == NULL)
   1098        1.1       cgd 			return (EBADRPC);
   1099        1.1       cgd 		s = m->m_len;
   1100        1.1       cgd 	}
   1101        1.1       cgd 	*mdp = m;
   1102        1.1       cgd 	*dposp = mtod(m, caddr_t)+offs;
   1103        1.1       cgd 	return (0);
   1104        1.1       cgd }
   1105        1.1       cgd 
   1106        1.1       cgd /*
   1107        1.1       cgd  * Copy a string into mbufs for the hard cases...
   1108        1.1       cgd  */
   1109       1.24  christos int
   1110        1.1       cgd nfsm_strtmbuf(mb, bpos, cp, siz)
   1111        1.1       cgd 	struct mbuf **mb;
   1112        1.1       cgd 	char **bpos;
   1113       1.33       cgd 	const char *cp;
   1114        1.1       cgd 	long siz;
   1115        1.1       cgd {
   1116       1.75  augustss 	struct mbuf *m1 = NULL, *m2;
   1117        1.1       cgd 	long left, xfer, len, tlen;
   1118       1.22       cgd 	u_int32_t *tl;
   1119        1.1       cgd 	int putsize;
   1120        1.1       cgd 
   1121        1.1       cgd 	putsize = 1;
   1122        1.1       cgd 	m2 = *mb;
   1123       1.12   mycroft 	left = M_TRAILINGSPACE(m2);
   1124        1.1       cgd 	if (left > 0) {
   1125       1.22       cgd 		tl = ((u_int32_t *)(*bpos));
   1126        1.1       cgd 		*tl++ = txdr_unsigned(siz);
   1127        1.1       cgd 		putsize = 0;
   1128        1.1       cgd 		left -= NFSX_UNSIGNED;
   1129        1.1       cgd 		m2->m_len += NFSX_UNSIGNED;
   1130        1.1       cgd 		if (left > 0) {
   1131       1.63     perry 			memcpy((caddr_t) tl, cp, left);
   1132        1.1       cgd 			siz -= left;
   1133        1.1       cgd 			cp += left;
   1134        1.1       cgd 			m2->m_len += left;
   1135        1.1       cgd 			left = 0;
   1136        1.1       cgd 		}
   1137        1.1       cgd 	}
   1138       1.12   mycroft 	/* Loop around adding mbufs */
   1139        1.1       cgd 	while (siz > 0) {
   1140      1.109      matt 		m1 = m_get(M_WAIT, MT_DATA);
   1141      1.109      matt 		MCLAIM(m1, &nfs_mowner);
   1142        1.1       cgd 		if (siz > MLEN)
   1143      1.109      matt 			m_clget(m1, M_WAIT);
   1144        1.1       cgd 		m1->m_len = NFSMSIZ(m1);
   1145        1.1       cgd 		m2->m_next = m1;
   1146        1.1       cgd 		m2 = m1;
   1147       1.22       cgd 		tl = mtod(m1, u_int32_t *);
   1148        1.1       cgd 		tlen = 0;
   1149        1.1       cgd 		if (putsize) {
   1150        1.1       cgd 			*tl++ = txdr_unsigned(siz);
   1151        1.1       cgd 			m1->m_len -= NFSX_UNSIGNED;
   1152        1.1       cgd 			tlen = NFSX_UNSIGNED;
   1153        1.1       cgd 			putsize = 0;
   1154        1.1       cgd 		}
   1155        1.1       cgd 		if (siz < m1->m_len) {
   1156        1.1       cgd 			len = nfsm_rndup(siz);
   1157        1.1       cgd 			xfer = siz;
   1158        1.1       cgd 			if (xfer < len)
   1159        1.1       cgd 				*(tl+(xfer>>2)) = 0;
   1160        1.1       cgd 		} else {
   1161        1.1       cgd 			xfer = len = m1->m_len;
   1162        1.1       cgd 		}
   1163       1.63     perry 		memcpy((caddr_t) tl, cp, xfer);
   1164        1.1       cgd 		m1->m_len = len+tlen;
   1165        1.1       cgd 		siz -= xfer;
   1166        1.1       cgd 		cp += xfer;
   1167        1.1       cgd 	}
   1168        1.1       cgd 	*mb = m1;
   1169        1.1       cgd 	*bpos = mtod(m1, caddr_t)+m1->m_len;
   1170        1.1       cgd 	return (0);
   1171        1.1       cgd }
   1172        1.1       cgd 
   1173       1.49      fvdl /*
   1174       1.49      fvdl  * Directory caching routines. They work as follows:
   1175       1.49      fvdl  * - a cache is maintained per VDIR nfsnode.
   1176       1.49      fvdl  * - for each offset cookie that is exported to userspace, and can
   1177       1.49      fvdl  *   thus be thrown back at us as an offset to VOP_READDIR, store
   1178       1.49      fvdl  *   information in the cache.
   1179       1.49      fvdl  * - cached are:
   1180       1.49      fvdl  *   - cookie itself
   1181       1.49      fvdl  *   - blocknumber (essentially just a search key in the buffer cache)
   1182       1.49      fvdl  *   - entry number in block.
   1183       1.49      fvdl  *   - offset cookie of block in which this entry is stored
   1184       1.49      fvdl  *   - 32 bit cookie if NFSMNT_XLATECOOKIE is used.
   1185       1.49      fvdl  * - entries are looked up in a hash table
   1186       1.49      fvdl  * - also maintained is an LRU list of entries, used to determine
   1187       1.49      fvdl  *   which ones to delete if the cache grows too large.
   1188       1.49      fvdl  * - if 32 <-> 64 translation mode is requested for a filesystem,
   1189       1.49      fvdl  *   the cache also functions as a translation table
   1190       1.49      fvdl  * - in the translation case, invalidating the cache does not mean
   1191       1.49      fvdl  *   flushing it, but just marking entries as invalid, except for
   1192       1.49      fvdl  *   the <64bit cookie, 32bitcookie> pair which is still valid, to
   1193       1.49      fvdl  *   still be able to use the cache as a translation table.
   1194       1.49      fvdl  * - 32 bit cookies are uniquely created by combining the hash table
   1195       1.49      fvdl  *   entry value, and one generation count per hash table entry,
   1196       1.49      fvdl  *   incremented each time an entry is appended to the chain.
   1197       1.49      fvdl  * - the cache is invalidated each time a direcory is modified
   1198       1.49      fvdl  * - sanity checks are also done; if an entry in a block turns
   1199       1.49      fvdl  *   out not to have a matching cookie, the cache is invalidated
   1200       1.49      fvdl  *   and a new block starting from the wanted offset is fetched from
   1201       1.49      fvdl  *   the server.
   1202       1.49      fvdl  * - directory entries as read from the server are extended to contain
   1203       1.49      fvdl  *   the 64bit and, optionally, the 32bit cookies, for sanity checking
   1204       1.49      fvdl  *   the cache and exporting them to userspace through the cookie
   1205       1.49      fvdl  *   argument to VOP_READDIR.
   1206       1.49      fvdl  */
   1207       1.49      fvdl 
   1208       1.46      fvdl u_long
   1209       1.46      fvdl nfs_dirhash(off)
   1210       1.46      fvdl 	off_t off;
   1211       1.46      fvdl {
   1212       1.46      fvdl 	int i;
   1213       1.46      fvdl 	char *cp = (char *)&off;
   1214       1.46      fvdl 	u_long sum = 0L;
   1215       1.46      fvdl 
   1216       1.46      fvdl 	for (i = 0 ; i < sizeof (off); i++)
   1217       1.46      fvdl 		sum += *cp++;
   1218       1.46      fvdl 
   1219       1.46      fvdl 	return sum;
   1220       1.46      fvdl }
   1221       1.46      fvdl 
   1222      1.135      yamt #define	_NFSDC_MTX(np)		(&NFSTOV(np)->v_interlock)
   1223      1.135      yamt #define	NFSDC_LOCK(np)		simple_lock(_NFSDC_MTX(np))
   1224      1.135      yamt #define	NFSDC_UNLOCK(np)	simple_unlock(_NFSDC_MTX(np))
   1225      1.135      yamt #define	NFSDC_ASSERT_LOCKED(np) LOCK_ASSERT(simple_lock_held(_NFSDC_MTX(np)))
   1226      1.135      yamt 
   1227       1.49      fvdl void
   1228       1.49      fvdl nfs_initdircache(vp)
   1229       1.49      fvdl 	struct vnode *vp;
   1230       1.49      fvdl {
   1231       1.49      fvdl 	struct nfsnode *np = VTONFS(vp);
   1232      1.135      yamt 	struct nfsdirhashhead *dircache;
   1233      1.120      yamt 
   1234      1.135      yamt 	dircache = hashinit(NFS_DIRHASHSIZ, HASH_LIST, M_NFSDIROFF,
   1235      1.135      yamt 	    M_WAITOK, &nfsdirhashmask);
   1236       1.49      fvdl 
   1237      1.135      yamt 	NFSDC_LOCK(np);
   1238      1.135      yamt 	if (np->n_dircache == NULL) {
   1239      1.135      yamt 		np->n_dircachesize = 0;
   1240      1.135      yamt 		np->n_dircache = dircache;
   1241      1.135      yamt 		dircache = NULL;
   1242      1.135      yamt 		TAILQ_INIT(&np->n_dirchain);
   1243      1.135      yamt 	}
   1244      1.135      yamt 	NFSDC_UNLOCK(np);
   1245      1.135      yamt 	if (dircache)
   1246      1.135      yamt 		hashdone(dircache, M_NFSDIROFF);
   1247      1.120      yamt }
   1248      1.120      yamt 
   1249      1.120      yamt void
   1250      1.120      yamt nfs_initdirxlatecookie(vp)
   1251      1.120      yamt 	struct vnode *vp;
   1252      1.120      yamt {
   1253      1.120      yamt 	struct nfsnode *np = VTONFS(vp);
   1254      1.135      yamt 	unsigned *dirgens;
   1255      1.120      yamt 
   1256      1.120      yamt 	KASSERT(VFSTONFS(vp->v_mount)->nm_flag & NFSMNT_XLATECOOKIE);
   1257      1.120      yamt 
   1258      1.135      yamt 	dirgens = malloc(NFS_DIRHASHSIZ * sizeof (unsigned), M_NFSDIROFF,
   1259      1.135      yamt 	    M_WAITOK|M_ZERO);
   1260      1.135      yamt 	NFSDC_LOCK(np);
   1261      1.135      yamt 	if (np->n_dirgens == NULL) {
   1262      1.135      yamt 		np->n_dirgens = dirgens;
   1263      1.135      yamt 		dirgens = NULL;
   1264      1.135      yamt 	}
   1265      1.135      yamt 	NFSDC_UNLOCK(np);
   1266      1.135      yamt 	if (dirgens)
   1267      1.135      yamt 		free(dirgens, M_NFSDIROFF);
   1268      1.135      yamt }
   1269      1.135      yamt 
   1270      1.135      yamt static const struct nfsdircache dzero;
   1271      1.135      yamt 
   1272      1.135      yamt static void nfs_unlinkdircache __P((struct nfsnode *np, struct nfsdircache *));
   1273      1.135      yamt static void nfs_putdircache_unlocked __P((struct nfsnode *,
   1274      1.135      yamt     struct nfsdircache *));
   1275      1.135      yamt 
   1276      1.135      yamt static void
   1277      1.135      yamt nfs_unlinkdircache(np, ndp)
   1278      1.135      yamt 	struct nfsnode *np;
   1279      1.135      yamt 	struct nfsdircache *ndp;
   1280      1.135      yamt {
   1281      1.135      yamt 
   1282      1.135      yamt 	NFSDC_ASSERT_LOCKED(np);
   1283      1.135      yamt 	KASSERT(ndp != &dzero);
   1284      1.135      yamt 
   1285      1.135      yamt 	if (LIST_NEXT(ndp, dc_hash) == (void *)-1)
   1286      1.135      yamt 		return;
   1287      1.135      yamt 
   1288      1.135      yamt 	TAILQ_REMOVE(&np->n_dirchain, ndp, dc_chain);
   1289      1.135      yamt 	LIST_REMOVE(ndp, dc_hash);
   1290      1.135      yamt 	LIST_NEXT(ndp, dc_hash) = (void *)-1; /* mark as unlinked */
   1291      1.135      yamt 
   1292      1.135      yamt 	nfs_putdircache_unlocked(np, ndp);
   1293      1.135      yamt }
   1294      1.135      yamt 
   1295      1.135      yamt void
   1296      1.135      yamt nfs_putdircache(np, ndp)
   1297      1.135      yamt 	struct nfsnode *np;
   1298      1.135      yamt 	struct nfsdircache *ndp;
   1299      1.135      yamt {
   1300      1.135      yamt 	int ref;
   1301      1.135      yamt 
   1302      1.135      yamt 	if (ndp == &dzero)
   1303      1.135      yamt 		return;
   1304      1.135      yamt 
   1305      1.135      yamt 	KASSERT(ndp->dc_refcnt > 0);
   1306      1.135      yamt 	NFSDC_LOCK(np);
   1307      1.135      yamt 	ref = --ndp->dc_refcnt;
   1308      1.135      yamt 	NFSDC_UNLOCK(np);
   1309      1.135      yamt 
   1310      1.135      yamt 	if (ref == 0)
   1311      1.135      yamt 		free(ndp, M_NFSDIROFF);
   1312       1.49      fvdl }
   1313       1.49      fvdl 
   1314      1.135      yamt static void
   1315      1.135      yamt nfs_putdircache_unlocked(np, ndp)
   1316      1.135      yamt 	struct nfsnode *np;
   1317      1.135      yamt 	struct nfsdircache *ndp;
   1318      1.135      yamt {
   1319      1.135      yamt 	int ref;
   1320      1.135      yamt 
   1321      1.135      yamt 	NFSDC_ASSERT_LOCKED(np);
   1322      1.135      yamt 
   1323      1.135      yamt 	if (ndp == &dzero)
   1324      1.135      yamt 		return;
   1325      1.135      yamt 
   1326      1.135      yamt 	KASSERT(ndp->dc_refcnt > 0);
   1327      1.135      yamt 	ref = --ndp->dc_refcnt;
   1328      1.135      yamt 	if (ref == 0)
   1329      1.135      yamt 		free(ndp, M_NFSDIROFF);
   1330      1.135      yamt }
   1331       1.46      fvdl 
   1332       1.46      fvdl struct nfsdircache *
   1333       1.49      fvdl nfs_searchdircache(vp, off, do32, hashent)
   1334       1.46      fvdl 	struct vnode *vp;
   1335       1.46      fvdl 	off_t off;
   1336       1.49      fvdl 	int do32;
   1337       1.49      fvdl 	int *hashent;
   1338       1.49      fvdl {
   1339       1.49      fvdl 	struct nfsdirhashhead *ndhp;
   1340       1.49      fvdl 	struct nfsdircache *ndp = NULL;
   1341       1.49      fvdl 	struct nfsnode *np = VTONFS(vp);
   1342       1.49      fvdl 	unsigned ent;
   1343       1.49      fvdl 
   1344       1.49      fvdl 	/*
   1345       1.49      fvdl 	 * Zero is always a valid cookie.
   1346       1.49      fvdl 	 */
   1347       1.49      fvdl 	if (off == 0)
   1348      1.149  christos 		/* XXXUNCONST */
   1349      1.149  christos 		return (struct nfsdircache *)__UNCONST(&dzero);
   1350       1.49      fvdl 
   1351      1.134      yamt 	if (!np->n_dircache)
   1352      1.134      yamt 		return NULL;
   1353      1.134      yamt 
   1354       1.49      fvdl 	/*
   1355       1.49      fvdl 	 * We use a 32bit cookie as search key, directly reconstruct
   1356       1.49      fvdl 	 * the hashentry. Else use the hashfunction.
   1357       1.49      fvdl 	 */
   1358       1.49      fvdl 	if (do32) {
   1359       1.49      fvdl 		ent = (u_int32_t)off >> 24;
   1360       1.49      fvdl 		if (ent >= NFS_DIRHASHSIZ)
   1361       1.49      fvdl 			return NULL;
   1362       1.49      fvdl 		ndhp = &np->n_dircache[ent];
   1363       1.49      fvdl 	} else {
   1364       1.49      fvdl 		ndhp = NFSDIRHASH(np, off);
   1365       1.49      fvdl 	}
   1366       1.49      fvdl 
   1367       1.49      fvdl 	if (hashent)
   1368       1.49      fvdl 		*hashent = (int)(ndhp - np->n_dircache);
   1369      1.135      yamt 
   1370      1.135      yamt 	NFSDC_LOCK(np);
   1371       1.49      fvdl 	if (do32) {
   1372      1.113      yamt 		LIST_FOREACH(ndp, ndhp, dc_hash) {
   1373       1.49      fvdl 			if (ndp->dc_cookie32 == (u_int32_t)off) {
   1374       1.49      fvdl 				/*
   1375       1.49      fvdl 				 * An invalidated entry will become the
   1376       1.49      fvdl 				 * start of a new block fetched from
   1377       1.49      fvdl 				 * the server.
   1378       1.49      fvdl 				 */
   1379      1.135      yamt 				if (ndp->dc_flags & NFSDC_INVALID) {
   1380       1.49      fvdl 					ndp->dc_blkcookie = ndp->dc_cookie;
   1381       1.49      fvdl 					ndp->dc_entry = 0;
   1382      1.135      yamt 					ndp->dc_flags &= ~NFSDC_INVALID;
   1383       1.49      fvdl 				}
   1384       1.49      fvdl 				break;
   1385       1.49      fvdl 			}
   1386       1.49      fvdl 		}
   1387       1.49      fvdl 	} else {
   1388      1.113      yamt 		LIST_FOREACH(ndp, ndhp, dc_hash) {
   1389       1.49      fvdl 			if (ndp->dc_cookie == off)
   1390       1.49      fvdl 				break;
   1391      1.113      yamt 		}
   1392       1.49      fvdl 	}
   1393      1.135      yamt 	if (ndp != NULL)
   1394      1.135      yamt 		ndp->dc_refcnt++;
   1395      1.135      yamt 	NFSDC_UNLOCK(np);
   1396       1.49      fvdl 	return ndp;
   1397       1.49      fvdl }
   1398       1.49      fvdl 
   1399       1.49      fvdl 
   1400       1.49      fvdl struct nfsdircache *
   1401       1.49      fvdl nfs_enterdircache(vp, off, blkoff, en, blkno)
   1402       1.49      fvdl 	struct vnode *vp;
   1403       1.49      fvdl 	off_t off, blkoff;
   1404      1.102  jdolecek 	int en;
   1405       1.46      fvdl 	daddr_t blkno;
   1406       1.46      fvdl {
   1407       1.46      fvdl 	struct nfsnode *np = VTONFS(vp);
   1408       1.46      fvdl 	struct nfsdirhashhead *ndhp;
   1409      1.135      yamt 	struct nfsdircache *ndp = NULL;
   1410      1.135      yamt 	struct nfsdircache *newndp = NULL;
   1411       1.49      fvdl 	struct nfsmount *nmp = VFSTONFS(vp->v_mount);
   1412       1.49      fvdl 	int hashent, gen, overwrite;
   1413       1.46      fvdl 
   1414      1.135      yamt 	/*
   1415      1.135      yamt 	 * XXX refuse entries for offset 0. amd(8) erroneously sets
   1416      1.135      yamt 	 * cookie 0 for the '.' entry, making this necessary. This
   1417      1.135      yamt 	 * isn't so bad, as 0 is a special case anyway.
   1418      1.135      yamt 	 */
   1419      1.135      yamt 	if (off == 0)
   1420      1.149  christos 		/* XXXUNCONST */
   1421      1.149  christos 		return (struct nfsdircache *)__UNCONST(&dzero);
   1422      1.135      yamt 
   1423       1.49      fvdl 	if (!np->n_dircache)
   1424       1.49      fvdl 		/*
   1425       1.49      fvdl 		 * XXX would like to do this in nfs_nget but vtype
   1426       1.49      fvdl 		 * isn't known at that time.
   1427       1.49      fvdl 		 */
   1428       1.49      fvdl 		nfs_initdircache(vp);
   1429       1.50      fvdl 
   1430      1.120      yamt 	if ((nmp->nm_flag & NFSMNT_XLATECOOKIE) && !np->n_dirgens)
   1431      1.120      yamt 		nfs_initdirxlatecookie(vp);
   1432      1.120      yamt 
   1433      1.135      yamt retry:
   1434       1.49      fvdl 	ndp = nfs_searchdircache(vp, off, 0, &hashent);
   1435       1.49      fvdl 
   1436      1.135      yamt 	NFSDC_LOCK(np);
   1437      1.135      yamt 	if (ndp && (ndp->dc_flags & NFSDC_INVALID) == 0) {
   1438       1.49      fvdl 		/*
   1439       1.49      fvdl 		 * Overwriting an old entry. Check if it's the same.
   1440       1.49      fvdl 		 * If so, just return. If not, remove the old entry.
   1441       1.49      fvdl 		 */
   1442       1.49      fvdl 		if (ndp->dc_blkcookie == blkoff && ndp->dc_entry == en)
   1443      1.135      yamt 			goto done;
   1444      1.135      yamt 		nfs_unlinkdircache(np, ndp);
   1445      1.135      yamt 		nfs_putdircache_unlocked(np, ndp);
   1446      1.135      yamt 		ndp = NULL;
   1447       1.46      fvdl 	}
   1448       1.46      fvdl 
   1449       1.49      fvdl 	ndhp = &np->n_dircache[hashent];
   1450       1.46      fvdl 
   1451       1.49      fvdl 	if (!ndp) {
   1452      1.135      yamt 		if (newndp == NULL) {
   1453      1.135      yamt 			NFSDC_UNLOCK(np);
   1454      1.135      yamt 			newndp = malloc(sizeof(*ndp), M_NFSDIROFF, M_WAITOK);
   1455      1.135      yamt 			newndp->dc_refcnt = 1;
   1456      1.135      yamt 			LIST_NEXT(newndp, dc_hash) = (void *)-1;
   1457      1.135      yamt 			goto retry;
   1458      1.135      yamt 		}
   1459      1.135      yamt 		ndp = newndp;
   1460      1.135      yamt 		newndp = NULL;
   1461       1.49      fvdl 		overwrite = 0;
   1462       1.49      fvdl 		if (nmp->nm_flag & NFSMNT_XLATECOOKIE) {
   1463       1.49      fvdl 			/*
   1464       1.49      fvdl 			 * We're allocating a new entry, so bump the
   1465       1.49      fvdl 			 * generation number.
   1466       1.49      fvdl 			 */
   1467       1.49      fvdl 			gen = ++np->n_dirgens[hashent];
   1468       1.49      fvdl 			if (gen == 0) {
   1469       1.49      fvdl 				np->n_dirgens[hashent]++;
   1470       1.49      fvdl 				gen++;
   1471       1.49      fvdl 			}
   1472       1.49      fvdl 			ndp->dc_cookie32 = (hashent << 24) | (gen & 0xffffff);
   1473       1.49      fvdl 		}
   1474       1.49      fvdl 	} else
   1475       1.49      fvdl 		overwrite = 1;
   1476       1.46      fvdl 
   1477       1.49      fvdl 	ndp->dc_cookie = off;
   1478       1.49      fvdl 	ndp->dc_blkcookie = blkoff;
   1479       1.46      fvdl 	ndp->dc_entry = en;
   1480      1.137      yamt 	ndp->dc_flags = 0;
   1481       1.46      fvdl 
   1482       1.49      fvdl 	if (overwrite)
   1483      1.135      yamt 		goto done;
   1484       1.49      fvdl 
   1485       1.46      fvdl 	/*
   1486       1.46      fvdl 	 * If the maximum directory cookie cache size has been reached
   1487       1.46      fvdl 	 * for this node, take one off the front. The idea is that
   1488       1.46      fvdl 	 * directories are typically read front-to-back once, so that
   1489       1.46      fvdl 	 * the oldest entries can be thrown away without much performance
   1490       1.46      fvdl 	 * loss.
   1491       1.46      fvdl 	 */
   1492       1.46      fvdl 	if (np->n_dircachesize == NFS_MAXDIRCACHE) {
   1493      1.135      yamt 		nfs_unlinkdircache(np, TAILQ_FIRST(&np->n_dirchain));
   1494       1.46      fvdl 	} else
   1495       1.46      fvdl 		np->n_dircachesize++;
   1496      1.148     perry 
   1497      1.135      yamt 	KASSERT(ndp->dc_refcnt == 1);
   1498       1.46      fvdl 	LIST_INSERT_HEAD(ndhp, ndp, dc_hash);
   1499       1.46      fvdl 	TAILQ_INSERT_TAIL(&np->n_dirchain, ndp, dc_chain);
   1500      1.135      yamt 	ndp->dc_refcnt++;
   1501      1.135      yamt done:
   1502      1.135      yamt 	KASSERT(ndp->dc_refcnt > 0);
   1503      1.135      yamt 	NFSDC_UNLOCK(np);
   1504      1.135      yamt 	if (newndp)
   1505      1.135      yamt 		nfs_putdircache(np, newndp);
   1506       1.46      fvdl 	return ndp;
   1507       1.46      fvdl }
   1508       1.46      fvdl 
   1509       1.46      fvdl void
   1510      1.145      yamt nfs_invaldircache(vp, flags)
   1511       1.46      fvdl 	struct vnode *vp;
   1512      1.145      yamt 	int flags;
   1513       1.46      fvdl {
   1514       1.46      fvdl 	struct nfsnode *np = VTONFS(vp);
   1515       1.46      fvdl 	struct nfsdircache *ndp = NULL;
   1516       1.49      fvdl 	struct nfsmount *nmp = VFSTONFS(vp->v_mount);
   1517      1.145      yamt 	const boolean_t forcefree = flags & NFS_INVALDIRCACHE_FORCE;
   1518       1.46      fvdl 
   1519       1.46      fvdl #ifdef DIAGNOSTIC
   1520       1.46      fvdl 	if (vp->v_type != VDIR)
   1521       1.46      fvdl 		panic("nfs: invaldircache: not dir");
   1522       1.46      fvdl #endif
   1523       1.46      fvdl 
   1524      1.145      yamt 	if ((flags & NFS_INVALDIRCACHE_KEEPEOF) == 0)
   1525      1.145      yamt 		np->n_flag &= ~NEOFVALID;
   1526      1.144      yamt 
   1527       1.46      fvdl 	if (!np->n_dircache)
   1528       1.46      fvdl 		return;
   1529       1.46      fvdl 
   1530      1.135      yamt 	NFSDC_LOCK(np);
   1531       1.49      fvdl 	if (!(nmp->nm_flag & NFSMNT_XLATECOOKIE) || forcefree) {
   1532      1.135      yamt 		while ((ndp = TAILQ_FIRST(&np->n_dirchain)) != NULL) {
   1533      1.135      yamt 			KASSERT(!forcefree || ndp->dc_refcnt == 1);
   1534      1.135      yamt 			nfs_unlinkdircache(np, ndp);
   1535       1.49      fvdl 		}
   1536       1.49      fvdl 		np->n_dircachesize = 0;
   1537       1.49      fvdl 		if (forcefree && np->n_dirgens) {
   1538       1.49      fvdl 			FREE(np->n_dirgens, M_NFSDIROFF);
   1539      1.120      yamt 			np->n_dirgens = NULL;
   1540       1.49      fvdl 		}
   1541       1.49      fvdl 	} else {
   1542      1.135      yamt 		TAILQ_FOREACH(ndp, &np->n_dirchain, dc_chain)
   1543      1.135      yamt 			ndp->dc_flags |= NFSDC_INVALID;
   1544       1.46      fvdl 	}
   1545       1.46      fvdl 
   1546      1.135      yamt 	NFSDC_UNLOCK(np);
   1547       1.46      fvdl }
   1548       1.46      fvdl 
   1549        1.1       cgd /*
   1550       1.35   thorpej  * Called once before VFS init to initialize shared and
   1551       1.35   thorpej  * server-specific data structures.
   1552        1.1       cgd  */
   1553  1.153.6.2      yamt static void
   1554  1.153.6.2      yamt nfs_init0(void)
   1555        1.1       cgd {
   1556       1.12   mycroft 	nfsrtt.pos = 0;
   1557        1.1       cgd 	rpc_vers = txdr_unsigned(RPC_VER2);
   1558        1.1       cgd 	rpc_call = txdr_unsigned(RPC_CALL);
   1559        1.1       cgd 	rpc_reply = txdr_unsigned(RPC_REPLY);
   1560        1.1       cgd 	rpc_msgdenied = txdr_unsigned(RPC_MSGDENIED);
   1561        1.1       cgd 	rpc_msgaccepted = txdr_unsigned(RPC_MSGACCEPTED);
   1562        1.1       cgd 	rpc_mismatch = txdr_unsigned(RPC_MISMATCH);
   1563       1.12   mycroft 	rpc_autherr = txdr_unsigned(RPC_AUTHERR);
   1564        1.1       cgd 	rpc_auth_unix = txdr_unsigned(RPCAUTH_UNIX);
   1565       1.25      fvdl 	rpc_auth_kerb = txdr_unsigned(RPCAUTH_KERB4);
   1566        1.1       cgd 	nfs_prog = txdr_unsigned(NFS_PROG);
   1567       1.25      fvdl 	nqnfs_prog = txdr_unsigned(NQNFS_PROG);
   1568        1.1       cgd 	nfs_true = txdr_unsigned(TRUE);
   1569        1.1       cgd 	nfs_false = txdr_unsigned(FALSE);
   1570       1.12   mycroft 	nfs_xdrneg1 = txdr_unsigned(-1);
   1571       1.25      fvdl 	nfs_ticks = (hz * NFS_TICKINTVL + 500) / 1000;
   1572       1.25      fvdl 	if (nfs_ticks < 1)
   1573       1.25      fvdl 		nfs_ticks = 1;
   1574        1.2     glass #ifdef NFSSERVER
   1575       1.12   mycroft 	nfsrv_init(0);			/* Init server data structures */
   1576        1.1       cgd 	nfsrv_initcache();		/* Init the server request cache */
   1577      1.121      yamt 	pool_init(&nfs_srvdesc_pool, sizeof(struct nfsrv_descript),
   1578      1.121      yamt 	    0, 0, 0, "nfsrvdescpl", &pool_allocator_nointr);
   1579       1.36      fvdl #endif /* NFSSERVER */
   1580       1.12   mycroft 
   1581       1.84     bjh21 #if defined(NFSSERVER) || !defined(NFS_V2_ONLY)
   1582       1.12   mycroft 	/*
   1583       1.37      fvdl 	 * Initialize the nqnfs data structures.
   1584       1.12   mycroft 	 */
   1585       1.12   mycroft 	if (nqnfsstarttime == 0) {
   1586       1.12   mycroft 		nqnfsstarttime = boottime.tv_sec + nqsrv_maxlease
   1587       1.12   mycroft 			+ nqsrv_clockskew + nqsrv_writeslack;
   1588       1.12   mycroft 		NQLOADNOVRAM(nqnfsstarttime);
   1589       1.18   mycroft 		CIRCLEQ_INIT(&nqtimerhead);
   1590       1.88        ad 		nqfhhashtbl = hashinit(NQLCHSZ, HASH_LIST, M_NQLEASE,
   1591       1.88        ad 		    M_WAITOK, &nqfhhash);
   1592       1.12   mycroft 	}
   1593       1.84     bjh21 #endif
   1594      1.103  christos 
   1595      1.103  christos 	exithook_establish(nfs_exit, NULL);
   1596       1.12   mycroft 
   1597        1.1       cgd 	/*
   1598        1.1       cgd 	 * Initialize reply list and start timer
   1599        1.1       cgd 	 */
   1600       1.16   mycroft 	TAILQ_INIT(&nfs_reqq);
   1601       1.24  christos 	nfs_timer(NULL);
   1602      1.109      matt 	MOWNER_ATTACH(&nfs_mowner);
   1603      1.106  jdolecek 
   1604      1.106  jdolecek #ifdef NFS
   1605      1.106  jdolecek 	/* Initialize the kqueue structures */
   1606      1.106  jdolecek 	nfs_kqinit();
   1607      1.119      yamt 	/* Initialize the iod structures */
   1608      1.119      yamt 	nfs_iodinit();
   1609      1.106  jdolecek #endif
   1610        1.1       cgd }
   1611        1.1       cgd 
   1612  1.153.6.2      yamt void
   1613  1.153.6.2      yamt nfs_init(void)
   1614  1.153.6.2      yamt {
   1615  1.153.6.2      yamt 	static ONCE_DECL(nfs_init_once);
   1616  1.153.6.2      yamt 
   1617  1.153.6.2      yamt 	RUN_ONCE(&nfs_init_once, nfs_init0);
   1618  1.153.6.2      yamt }
   1619  1.153.6.2      yamt 
   1620       1.38   thorpej #ifdef NFS
   1621       1.35   thorpej /*
   1622       1.35   thorpej  * Called once at VFS init to initialize client-specific data structures.
   1623       1.35   thorpej  */
   1624       1.35   thorpej void
   1625       1.35   thorpej nfs_vfs_init()
   1626       1.35   thorpej {
   1627  1.153.6.2      yamt 	/* Initialize NFS server / client shared data. */
   1628  1.153.6.2      yamt 	nfs_init();
   1629  1.153.6.2      yamt 
   1630       1.96       chs 	nfs_nhinit();			/* Init the nfsnode table */
   1631      1.100       chs 	nfs_commitsize = uvmexp.npages << (PAGE_SHIFT - 4);
   1632       1.96       chs }
   1633       1.35   thorpej 
   1634       1.96       chs void
   1635       1.96       chs nfs_vfs_reinit()
   1636       1.96       chs {
   1637       1.96       chs 	nfs_nhreinit();
   1638       1.73  jdolecek }
   1639       1.73  jdolecek 
   1640       1.73  jdolecek void
   1641       1.73  jdolecek nfs_vfs_done()
   1642       1.73  jdolecek {
   1643       1.73  jdolecek 	nfs_nhdone();
   1644       1.35   thorpej }
   1645       1.35   thorpej 
   1646        1.1       cgd /*
   1647       1.12   mycroft  * Attribute cache routines.
   1648       1.12   mycroft  * nfs_loadattrcache() - loads or updates the cache contents from attributes
   1649       1.12   mycroft  *	that are on the mbuf list
   1650       1.12   mycroft  * nfs_getattrcache() - returns valid attributes if found in cache, returns
   1651       1.12   mycroft  *	error otherwise
   1652        1.1       cgd  */
   1653       1.12   mycroft 
   1654       1.12   mycroft /*
   1655       1.12   mycroft  * Load the attribute cache (that lives in the nfsnode entry) with
   1656       1.12   mycroft  * the values on the mbuf list and
   1657       1.12   mycroft  * Iff vap not NULL
   1658       1.12   mycroft  *    copy the attributes to *vaper
   1659       1.12   mycroft  */
   1660       1.24  christos int
   1661      1.105      yamt nfsm_loadattrcache(vpp, mdp, dposp, vaper, flags)
   1662       1.12   mycroft 	struct vnode **vpp;
   1663       1.12   mycroft 	struct mbuf **mdp;
   1664       1.12   mycroft 	caddr_t *dposp;
   1665       1.12   mycroft 	struct vattr *vaper;
   1666      1.105      yamt 	int flags;
   1667        1.1       cgd {
   1668       1.75  augustss 	int32_t t1;
   1669       1.25      fvdl 	caddr_t cp2;
   1670       1.25      fvdl 	int error = 0;
   1671       1.12   mycroft 	struct mbuf *md;
   1672       1.45      fvdl 	int v3 = NFS_ISV3(*vpp);
   1673        1.1       cgd 
   1674       1.12   mycroft 	md = *mdp;
   1675       1.25      fvdl 	t1 = (mtod(md, caddr_t) + md->m_len) - *dposp;
   1676       1.25      fvdl 	error = nfsm_disct(mdp, dposp, NFSX_FATTR(v3), t1, &cp2);
   1677       1.24  christos 	if (error)
   1678       1.12   mycroft 		return (error);
   1679      1.105      yamt 	return nfs_loadattrcache(vpp, (struct nfs_fattr *)cp2, vaper, flags);
   1680       1.45      fvdl }
   1681       1.45      fvdl 
   1682       1.45      fvdl int
   1683      1.105      yamt nfs_loadattrcache(vpp, fp, vaper, flags)
   1684       1.45      fvdl 	struct vnode **vpp;
   1685       1.45      fvdl 	struct nfs_fattr *fp;
   1686       1.45      fvdl 	struct vattr *vaper;
   1687      1.105      yamt 	int flags;
   1688       1.45      fvdl {
   1689       1.75  augustss 	struct vnode *vp = *vpp;
   1690       1.75  augustss 	struct vattr *vap;
   1691       1.45      fvdl 	int v3 = NFS_ISV3(vp);
   1692       1.45      fvdl 	enum vtype vtyp;
   1693       1.45      fvdl 	u_short vmode;
   1694       1.45      fvdl 	struct timespec mtime;
   1695      1.139      yamt 	struct timespec ctime;
   1696       1.45      fvdl 	struct vnode *nvp;
   1697       1.45      fvdl 	int32_t rdev;
   1698       1.75  augustss 	struct nfsnode *np;
   1699       1.45      fvdl 	extern int (**spec_nfsv2nodeop_p) __P((void *));
   1700      1.101      fvdl 	uid_t uid;
   1701      1.101      fvdl 	gid_t gid;
   1702       1.45      fvdl 
   1703       1.25      fvdl 	if (v3) {
   1704       1.25      fvdl 		vtyp = nfsv3tov_type(fp->fa_type);
   1705       1.25      fvdl 		vmode = fxdr_unsigned(u_short, fp->fa_mode);
   1706       1.71        is 		rdev = makedev(fxdr_unsigned(u_int32_t, fp->fa3_rdev.specdata1),
   1707       1.71        is 			fxdr_unsigned(u_int32_t, fp->fa3_rdev.specdata2));
   1708       1.25      fvdl 		fxdr_nfsv3time(&fp->fa3_mtime, &mtime);
   1709      1.139      yamt 		fxdr_nfsv3time(&fp->fa3_ctime, &ctime);
   1710       1.12   mycroft 	} else {
   1711       1.25      fvdl 		vtyp = nfsv2tov_type(fp->fa_type);
   1712       1.25      fvdl 		vmode = fxdr_unsigned(u_short, fp->fa_mode);
   1713       1.25      fvdl 		if (vtyp == VNON || vtyp == VREG)
   1714       1.25      fvdl 			vtyp = IFTOVT(vmode);
   1715       1.25      fvdl 		rdev = fxdr_unsigned(int32_t, fp->fa2_rdev);
   1716       1.25      fvdl 		fxdr_nfsv2time(&fp->fa2_mtime, &mtime);
   1717      1.139      yamt 		ctime.tv_sec = fxdr_unsigned(u_int32_t,
   1718      1.139      yamt 		    fp->fa2_ctime.nfsv2_sec);
   1719      1.139      yamt 		ctime.tv_nsec = 0;
   1720       1.25      fvdl 
   1721       1.25      fvdl 		/*
   1722       1.25      fvdl 		 * Really ugly NFSv2 kludge.
   1723       1.25      fvdl 		 */
   1724       1.25      fvdl 		if (vtyp == VCHR && rdev == 0xffffffff)
   1725       1.25      fvdl 			vtyp = VFIFO;
   1726       1.12   mycroft 	}
   1727       1.25      fvdl 
   1728      1.101      fvdl 	vmode &= ALLPERMS;
   1729      1.101      fvdl 
   1730       1.12   mycroft 	/*
   1731       1.12   mycroft 	 * If v_type == VNON it is a new node, so fill in the v_type,
   1732      1.148     perry 	 * n_mtime fields. Check to see if it represents a special
   1733       1.12   mycroft 	 * device, and if so, check for a possible alias. Once the
   1734       1.12   mycroft 	 * correct vnode has been obtained, fill in the rest of the
   1735       1.12   mycroft 	 * information.
   1736       1.12   mycroft 	 */
   1737       1.12   mycroft 	np = VTONFS(vp);
   1738       1.87      fvdl 	if (vp->v_type == VNON) {
   1739       1.25      fvdl 		vp->v_type = vtyp;
   1740       1.12   mycroft 		if (vp->v_type == VFIFO) {
   1741       1.24  christos 			extern int (**fifo_nfsv2nodeop_p) __P((void *));
   1742       1.12   mycroft 			vp->v_op = fifo_nfsv2nodeop_p;
   1743      1.131      yamt 		} else if (vp->v_type == VREG) {
   1744      1.131      yamt 			lockinit(&np->n_commitlock, PINOD, "nfsclock", 0, 0);
   1745      1.131      yamt 		} else if (vp->v_type == VCHR || vp->v_type == VBLK) {
   1746       1.12   mycroft 			vp->v_op = spec_nfsv2nodeop_p;
   1747       1.24  christos 			nvp = checkalias(vp, (dev_t)rdev, vp->v_mount);
   1748       1.24  christos 			if (nvp) {
   1749       1.12   mycroft 				/*
   1750       1.12   mycroft 				 * Discard unneeded vnode, but save its nfsnode.
   1751       1.25      fvdl 				 * Since the nfsnode does not have a lock, its
   1752       1.25      fvdl 				 * vnode lock has to be carried over.
   1753       1.12   mycroft 				 */
   1754       1.94     bjh21 				/*
   1755       1.94     bjh21 				 * XXX is the old node sure to be locked here?
   1756       1.94     bjh21 				 */
   1757       1.94     bjh21 				KASSERT(lockstatus(&vp->v_lock) ==
   1758       1.94     bjh21 				    LK_EXCLUSIVE);
   1759       1.12   mycroft 				nvp->v_data = vp->v_data;
   1760       1.12   mycroft 				vp->v_data = NULL;
   1761       1.93      fvdl 				VOP_UNLOCK(vp, 0);
   1762       1.12   mycroft 				vp->v_op = spec_vnodeop_p;
   1763       1.93      fvdl 				vrele(vp);
   1764       1.12   mycroft 				vgone(vp);
   1765       1.94     bjh21 				lockmgr(&nvp->v_lock, LK_EXCLUSIVE,
   1766       1.94     bjh21 				    &nvp->v_interlock);
   1767       1.12   mycroft 				/*
   1768       1.12   mycroft 				 * Reinitialize aliased node.
   1769       1.12   mycroft 				 */
   1770       1.12   mycroft 				np->n_vnode = nvp;
   1771       1.12   mycroft 				*vpp = vp = nvp;
   1772       1.12   mycroft 			}
   1773       1.12   mycroft 		}
   1774      1.128      yamt 		np->n_mtime = mtime;
   1775       1.12   mycroft 	}
   1776      1.101      fvdl 	uid = fxdr_unsigned(uid_t, fp->fa_uid);
   1777      1.101      fvdl 	gid = fxdr_unsigned(gid_t, fp->fa_gid);
   1778       1.49      fvdl 	vap = np->n_vattr;
   1779      1.101      fvdl 
   1780      1.101      fvdl 	/*
   1781      1.139      yamt 	 * Invalidate access cache if uid, gid, mode or ctime changed.
   1782      1.101      fvdl 	 */
   1783      1.101      fvdl 	if (np->n_accstamp != -1 &&
   1784      1.139      yamt 	    (gid != vap->va_gid || uid != vap->va_uid || vmode != vap->va_mode
   1785      1.139      yamt 	    || timespeccmp(&ctime, &vap->va_ctime, !=)))
   1786      1.101      fvdl 		np->n_accstamp = -1;
   1787      1.101      fvdl 
   1788       1.12   mycroft 	vap->va_type = vtyp;
   1789      1.101      fvdl 	vap->va_mode = vmode;
   1790       1.12   mycroft 	vap->va_rdev = (dev_t)rdev;
   1791       1.12   mycroft 	vap->va_mtime = mtime;
   1792      1.139      yamt 	vap->va_ctime = ctime;
   1793      1.133  christos 	vap->va_fsid = vp->v_mount->mnt_stat.f_fsidx.__fsid_val[0];
   1794       1.72      fvdl 	switch (vtyp) {
   1795       1.72      fvdl 	case VDIR:
   1796       1.72      fvdl 		vap->va_blocksize = NFS_DIRFRAGSIZ;
   1797       1.72      fvdl 		break;
   1798       1.72      fvdl 	case VBLK:
   1799       1.72      fvdl 		vap->va_blocksize = BLKDEV_IOSIZE;
   1800       1.72      fvdl 		break;
   1801       1.72      fvdl 	case VCHR:
   1802       1.72      fvdl 		vap->va_blocksize = MAXBSIZE;
   1803       1.72      fvdl 		break;
   1804       1.72      fvdl 	default:
   1805       1.72      fvdl 		vap->va_blocksize = v3 ? vp->v_mount->mnt_stat.f_iosize :
   1806       1.72      fvdl 		    fxdr_unsigned(int32_t, fp->fa2_blocksize);
   1807       1.72      fvdl 		break;
   1808       1.72      fvdl 	}
   1809       1.25      fvdl 	if (v3) {
   1810       1.25      fvdl 		vap->va_nlink = fxdr_unsigned(u_short, fp->fa_nlink);
   1811      1.101      fvdl 		vap->va_uid = uid;
   1812      1.101      fvdl 		vap->va_gid = gid;
   1813       1.66      fair 		vap->va_size = fxdr_hyper(&fp->fa3_size);
   1814       1.66      fair 		vap->va_bytes = fxdr_hyper(&fp->fa3_used);
   1815      1.151      yamt 		vap->va_fileid = fxdr_hyper(&fp->fa3_fileid);
   1816       1.25      fvdl 		fxdr_nfsv3time(&fp->fa3_atime, &vap->va_atime);
   1817       1.25      fvdl 		vap->va_flags = 0;
   1818       1.25      fvdl 		vap->va_filerev = 0;
   1819       1.12   mycroft 	} else {
   1820       1.25      fvdl 		vap->va_nlink = fxdr_unsigned(u_short, fp->fa_nlink);
   1821      1.101      fvdl 		vap->va_uid = uid;
   1822      1.101      fvdl 		vap->va_gid = gid;
   1823       1.25      fvdl 		vap->va_size = fxdr_unsigned(u_int32_t, fp->fa2_size);
   1824       1.25      fvdl 		vap->va_bytes = fxdr_unsigned(int32_t, fp->fa2_blocks)
   1825       1.25      fvdl 		    * NFS_FABLKSIZE;
   1826       1.25      fvdl 		vap->va_fileid = fxdr_unsigned(int32_t, fp->fa2_fileid);
   1827       1.25      fvdl 		fxdr_nfsv2time(&fp->fa2_atime, &vap->va_atime);
   1828       1.12   mycroft 		vap->va_flags = 0;
   1829       1.25      fvdl 		vap->va_gen = fxdr_unsigned(u_int32_t,fp->fa2_ctime.nfsv2_usec);
   1830       1.12   mycroft 		vap->va_filerev = 0;
   1831       1.12   mycroft 	}
   1832       1.12   mycroft 	if (vap->va_size != np->n_size) {
   1833       1.89       chs 		if ((np->n_flag & NMODIFIED) && vap->va_size < np->n_size) {
   1834       1.89       chs 			vap->va_size = np->n_size;
   1835       1.89       chs 		} else {
   1836       1.12   mycroft 			np->n_size = vap->va_size;
   1837       1.89       chs 			if (vap->va_type == VREG) {
   1838      1.140      yamt 				/*
   1839      1.140      yamt 				 * we can't free pages if NAC_NOTRUNC because
   1840      1.140      yamt 				 * the pages can be owned by ourselves.
   1841      1.140      yamt 				 */
   1842      1.140      yamt 				if (flags & NAC_NOTRUNC) {
   1843      1.105      yamt 					np->n_flag |= NTRUNCDELAYED;
   1844      1.140      yamt 				} else {
   1845      1.140      yamt 					simple_lock(&vp->v_interlock);
   1846      1.140      yamt 					(void)VOP_PUTPAGES(vp, 0,
   1847      1.140      yamt 					    0, PGO_SYNCIO | PGO_CLEANIT |
   1848      1.140      yamt 					    PGO_FREE | PGO_ALLPAGES);
   1849      1.105      yamt 					uvm_vnp_setsize(vp, np->n_size);
   1850      1.105      yamt 				}
   1851       1.89       chs 			}
   1852       1.89       chs 		}
   1853       1.12   mycroft 	}
   1854      1.142      yamt 	np->n_attrstamp = mono_time.tv_sec;
   1855       1.12   mycroft 	if (vaper != NULL) {
   1856       1.63     perry 		memcpy((caddr_t)vaper, (caddr_t)vap, sizeof(*vap));
   1857       1.12   mycroft 		if (np->n_flag & NCHG) {
   1858       1.25      fvdl 			if (np->n_flag & NACC)
   1859       1.25      fvdl 				vaper->va_atime = np->n_atim;
   1860       1.25      fvdl 			if (np->n_flag & NUPD)
   1861       1.25      fvdl 				vaper->va_mtime = np->n_mtim;
   1862       1.12   mycroft 		}
   1863       1.12   mycroft 	}
   1864       1.12   mycroft 	return (0);
   1865       1.12   mycroft }
   1866       1.12   mycroft 
   1867       1.12   mycroft /*
   1868       1.12   mycroft  * Check the time stamp
   1869       1.12   mycroft  * If the cache is valid, copy contents to *vap and return 0
   1870       1.12   mycroft  * otherwise return an error
   1871       1.12   mycroft  */
   1872       1.24  christos int
   1873       1.12   mycroft nfs_getattrcache(vp, vaper)
   1874       1.75  augustss 	struct vnode *vp;
   1875       1.12   mycroft 	struct vattr *vaper;
   1876       1.12   mycroft {
   1877       1.75  augustss 	struct nfsnode *np = VTONFS(vp);
   1878      1.152  christos 	struct nfsmount *nmp = VFSTONFS(vp->v_mount);
   1879       1.75  augustss 	struct vattr *vap;
   1880       1.12   mycroft 
   1881      1.132      yamt 	if (np->n_attrstamp == 0 ||
   1882      1.152  christos 	    (mono_time.tv_sec - np->n_attrstamp) >= NFS_ATTRTIMEO(nmp, np)) {
   1883       1.12   mycroft 		nfsstats.attrcache_misses++;
   1884       1.12   mycroft 		return (ENOENT);
   1885       1.12   mycroft 	}
   1886       1.12   mycroft 	nfsstats.attrcache_hits++;
   1887       1.49      fvdl 	vap = np->n_vattr;
   1888       1.12   mycroft 	if (vap->va_size != np->n_size) {
   1889       1.12   mycroft 		if (vap->va_type == VREG) {
   1890       1.12   mycroft 			if (np->n_flag & NMODIFIED) {
   1891       1.12   mycroft 				if (vap->va_size < np->n_size)
   1892       1.12   mycroft 					vap->va_size = np->n_size;
   1893       1.12   mycroft 				else
   1894       1.12   mycroft 					np->n_size = vap->va_size;
   1895       1.12   mycroft 			} else
   1896       1.12   mycroft 				np->n_size = vap->va_size;
   1897       1.51       mrg 			uvm_vnp_setsize(vp, np->n_size);
   1898       1.12   mycroft 		} else
   1899       1.12   mycroft 			np->n_size = vap->va_size;
   1900       1.12   mycroft 	}
   1901       1.63     perry 	memcpy((caddr_t)vaper, (caddr_t)vap, sizeof(struct vattr));
   1902       1.12   mycroft 	if (np->n_flag & NCHG) {
   1903       1.25      fvdl 		if (np->n_flag & NACC)
   1904       1.25      fvdl 			vaper->va_atime = np->n_atim;
   1905       1.25      fvdl 		if (np->n_flag & NUPD)
   1906       1.25      fvdl 			vaper->va_mtime = np->n_mtim;
   1907        1.1       cgd 	}
   1908       1.12   mycroft 	return (0);
   1909      1.105      yamt }
   1910      1.105      yamt 
   1911      1.105      yamt void
   1912      1.105      yamt nfs_delayedtruncate(vp)
   1913      1.105      yamt 	struct vnode *vp;
   1914      1.105      yamt {
   1915      1.105      yamt 	struct nfsnode *np = VTONFS(vp);
   1916      1.105      yamt 
   1917      1.105      yamt 	if (np->n_flag & NTRUNCDELAYED) {
   1918      1.105      yamt 		np->n_flag &= ~NTRUNCDELAYED;
   1919      1.140      yamt 		simple_lock(&vp->v_interlock);
   1920      1.140      yamt 		(void)VOP_PUTPAGES(vp, 0,
   1921      1.140      yamt 		    0, PGO_SYNCIO | PGO_CLEANIT | PGO_FREE | PGO_ALLPAGES);
   1922      1.105      yamt 		uvm_vnp_setsize(vp, np->n_size);
   1923      1.105      yamt 	}
   1924        1.1       cgd }
   1925       1.48      fvdl 
   1926      1.141      yamt #define	NFS_WCCKLUDGE_TIMEOUT	(24 * 60 * 60)	/* 1 day */
   1927      1.141      yamt #define	NFS_WCCKLUDGE(nmp, now) \
   1928      1.141      yamt 	(((nmp)->nm_iflag & NFSMNT_WCCKLUDGE) && \
   1929      1.141      yamt 	((now) - (nmp)->nm_wcckludgetime - NFS_WCCKLUDGE_TIMEOUT) < 0)
   1930      1.141      yamt 
   1931      1.141      yamt /*
   1932      1.141      yamt  * nfs_check_wccdata: check inaccurate wcc_data
   1933      1.141      yamt  *
   1934      1.141      yamt  * => return non-zero if we shouldn't trust the wcc_data.
   1935      1.141      yamt  * => NFS_WCCKLUDGE_TIMEOUT is for the case that the server is "fixed".
   1936      1.141      yamt  */
   1937      1.141      yamt 
   1938      1.141      yamt int
   1939      1.141      yamt nfs_check_wccdata(struct nfsnode *np, const struct timespec *ctime,
   1940      1.141      yamt     struct timespec *mtime, boolean_t docheck)
   1941      1.141      yamt {
   1942      1.141      yamt 	int error = 0;
   1943      1.141      yamt 
   1944      1.141      yamt #if !defined(NFS_V2_ONLY)
   1945      1.141      yamt 
   1946      1.141      yamt 	if (docheck) {
   1947      1.141      yamt 		struct vnode *vp = NFSTOV(np);
   1948      1.141      yamt 		struct nfsmount *nmp;
   1949      1.141      yamt 		long now = mono_time.tv_sec;
   1950      1.141      yamt #if defined(DEBUG)
   1951      1.141      yamt 		const char *reason = NULL; /* XXX: gcc */
   1952      1.141      yamt #endif
   1953      1.141      yamt 
   1954      1.141      yamt 		if (timespeccmp(&np->n_vattr->va_mtime, mtime, <=)) {
   1955      1.141      yamt #if defined(DEBUG)
   1956      1.141      yamt 			reason = "mtime";
   1957      1.141      yamt #endif
   1958      1.141      yamt 			error = EINVAL;
   1959      1.141      yamt 		}
   1960      1.141      yamt 
   1961      1.141      yamt 		if (vp->v_type == VDIR &&
   1962      1.141      yamt 		    timespeccmp(&np->n_vattr->va_ctime, ctime, <=)) {
   1963      1.141      yamt #if defined(DEBUG)
   1964      1.141      yamt 			reason = "ctime";
   1965      1.141      yamt #endif
   1966      1.141      yamt 			error = EINVAL;
   1967      1.141      yamt 		}
   1968      1.141      yamt 
   1969      1.141      yamt 		nmp = VFSTONFS(vp->v_mount);
   1970      1.141      yamt 		if (error) {
   1971      1.143      yamt 
   1972      1.143      yamt 			/*
   1973      1.143      yamt 			 * despite of the fact that we've updated the file,
   1974      1.143      yamt 			 * timestamps of the file were not updated as we
   1975      1.143      yamt 			 * expected.
   1976      1.143      yamt 			 * it means that the server has incompatible
   1977      1.143      yamt 			 * semantics of timestamps or (more likely)
   1978      1.143      yamt 			 * the server time is not precise enough to
   1979      1.143      yamt 			 * track each modifications.
   1980      1.143      yamt 			 * in that case, we disable wcc processing.
   1981      1.143      yamt 			 *
   1982      1.143      yamt 			 * yes, strictly speaking, we should disable all
   1983      1.143      yamt 			 * caching.  it's a compromise.
   1984      1.143      yamt 			 */
   1985      1.143      yamt 
   1986      1.141      yamt 			simple_lock(&nmp->nm_slock);
   1987      1.141      yamt #if defined(DEBUG)
   1988      1.141      yamt 			if (!NFS_WCCKLUDGE(nmp, now)) {
   1989      1.141      yamt 				printf("%s: inaccurate wcc data (%s) detected,"
   1990      1.141      yamt 				    " disabling wcc\n",
   1991      1.141      yamt 				    vp->v_mount->mnt_stat.f_mntfromname,
   1992      1.141      yamt 				    reason);
   1993      1.141      yamt 			}
   1994      1.141      yamt #endif
   1995      1.141      yamt 			nmp->nm_iflag |= NFSMNT_WCCKLUDGE;
   1996      1.141      yamt 			nmp->nm_wcckludgetime = now;
   1997      1.141      yamt 			simple_unlock(&nmp->nm_slock);
   1998      1.141      yamt 		} else if (NFS_WCCKLUDGE(nmp, now)) {
   1999      1.141      yamt 			error = EPERM; /* XXX */
   2000      1.141      yamt 		} else if (nmp->nm_iflag & NFSMNT_WCCKLUDGE) {
   2001      1.141      yamt 			simple_lock(&nmp->nm_slock);
   2002      1.141      yamt 			if (nmp->nm_iflag & NFSMNT_WCCKLUDGE) {
   2003      1.141      yamt #if defined(DEBUG)
   2004      1.141      yamt 				printf("%s: re-enabling wcc\n",
   2005      1.141      yamt 				    vp->v_mount->mnt_stat.f_mntfromname);
   2006      1.141      yamt #endif
   2007      1.141      yamt 				nmp->nm_iflag &= ~NFSMNT_WCCKLUDGE;
   2008      1.141      yamt 			}
   2009      1.141      yamt 			simple_unlock(&nmp->nm_slock);
   2010      1.141      yamt 		}
   2011      1.141      yamt 	}
   2012      1.141      yamt 
   2013      1.141      yamt #endif /* !defined(NFS_V2_ONLY) */
   2014      1.141      yamt 
   2015      1.141      yamt 	return error;
   2016      1.141      yamt }
   2017      1.141      yamt 
   2018       1.48      fvdl /*
   2019       1.48      fvdl  * Heuristic to see if the server XDR encodes directory cookies or not.
   2020       1.48      fvdl  * it is not supposed to, but a lot of servers may do this. Also, since
   2021       1.48      fvdl  * most/all servers will implement V2 as well, it is expected that they
   2022       1.48      fvdl  * may return just 32 bits worth of cookie information, so we need to
   2023       1.48      fvdl  * find out in which 32 bits this information is available. We do this
   2024       1.48      fvdl  * to avoid trouble with emulated binaries that can't handle 64 bit
   2025       1.48      fvdl  * directory offsets.
   2026       1.48      fvdl  */
   2027       1.48      fvdl 
   2028       1.48      fvdl void
   2029      1.125      fvdl nfs_cookieheuristic(vp, flagp, p, cred)
   2030       1.48      fvdl 	struct vnode *vp;
   2031       1.48      fvdl 	int *flagp;
   2032      1.125      fvdl 	struct proc *p;
   2033       1.48      fvdl 	struct ucred *cred;
   2034       1.48      fvdl {
   2035       1.48      fvdl 	struct uio auio;
   2036       1.48      fvdl 	struct iovec aiov;
   2037      1.149  christos 	caddr_t tbuf, cp;
   2038       1.48      fvdl 	struct dirent *dp;
   2039       1.57      fvdl 	off_t *cookies = NULL, *cop;
   2040       1.48      fvdl 	int error, eof, nc, len;
   2041       1.48      fvdl 
   2042      1.149  christos 	MALLOC(tbuf, caddr_t, NFS_DIRFRAGSIZ, M_TEMP, M_WAITOK);
   2043       1.48      fvdl 
   2044      1.149  christos 	aiov.iov_base = tbuf;
   2045       1.48      fvdl 	aiov.iov_len = NFS_DIRFRAGSIZ;
   2046       1.48      fvdl 	auio.uio_iov = &aiov;
   2047       1.48      fvdl 	auio.uio_iovcnt = 1;
   2048       1.48      fvdl 	auio.uio_rw = UIO_READ;
   2049       1.48      fvdl 	auio.uio_segflg = UIO_SYSSPACE;
   2050      1.136     skrll 	auio.uio_procp = NULL;
   2051       1.48      fvdl 	auio.uio_resid = NFS_DIRFRAGSIZ;
   2052       1.48      fvdl 	auio.uio_offset = 0;
   2053       1.48      fvdl 
   2054       1.56      fvdl 	error = VOP_READDIR(vp, &auio, cred, &eof, &cookies, &nc);
   2055       1.48      fvdl 
   2056       1.48      fvdl 	len = NFS_DIRFRAGSIZ - auio.uio_resid;
   2057       1.48      fvdl 	if (error || len == 0) {
   2058      1.149  christos 		FREE(tbuf, M_TEMP);
   2059       1.57      fvdl 		if (cookies)
   2060       1.80   thorpej 			free(cookies, M_TEMP);
   2061       1.48      fvdl 		return;
   2062       1.48      fvdl 	}
   2063       1.48      fvdl 
   2064       1.48      fvdl 	/*
   2065       1.48      fvdl 	 * Find the first valid entry and look at its offset cookie.
   2066       1.48      fvdl 	 */
   2067       1.48      fvdl 
   2068      1.149  christos 	cp = tbuf;
   2069       1.48      fvdl 	for (cop = cookies; len > 0; len -= dp->d_reclen) {
   2070       1.48      fvdl 		dp = (struct dirent *)cp;
   2071       1.48      fvdl 		if (dp->d_fileno != 0 && len >= dp->d_reclen) {
   2072       1.48      fvdl 			if ((*cop >> 32) != 0 && (*cop & 0xffffffffLL) == 0) {
   2073       1.48      fvdl 				*flagp |= NFSMNT_SWAPCOOKIE;
   2074       1.49      fvdl 				nfs_invaldircache(vp, 0);
   2075      1.125      fvdl 				nfs_vinvalbuf(vp, 0, cred, p, 1);
   2076       1.48      fvdl 			}
   2077       1.48      fvdl 			break;
   2078       1.48      fvdl 		}
   2079       1.48      fvdl 		cop++;
   2080       1.48      fvdl 		cp += dp->d_reclen;
   2081       1.48      fvdl 	}
   2082       1.48      fvdl 
   2083      1.149  christos 	FREE(tbuf, M_TEMP);
   2084       1.80   thorpej 	free(cookies, M_TEMP);
   2085       1.48      fvdl }
   2086       1.38   thorpej #endif /* NFS */
   2087        1.1       cgd 
   2088      1.153      jmmv #ifdef NFSSERVER
   2089        1.1       cgd /*
   2090       1.43      fvdl  * Set up nameidata for a lookup() call and do it.
   2091       1.43      fvdl  *
   2092       1.43      fvdl  * If pubflag is set, this call is done for a lookup operation on the
   2093       1.43      fvdl  * public filehandle. In that case we allow crossing mountpoints and
   2094       1.43      fvdl  * absolute pathnames. However, the caller is expected to check that
   2095       1.43      fvdl  * the lookup result is within the public fs, and deny access if
   2096       1.43      fvdl  * it is not.
   2097        1.1       cgd  */
   2098       1.24  christos int
   2099      1.125      fvdl nfs_namei(ndp, fhp, len, slp, nam, mdp, dposp, retdirp, p, kerbflag, pubflag)
   2100       1.75  augustss 	struct nameidata *ndp;
   2101        1.1       cgd 	fhandle_t *fhp;
   2102      1.110      yamt 	uint32_t len;
   2103       1.12   mycroft 	struct nfssvc_sock *slp;
   2104       1.12   mycroft 	struct mbuf *nam;
   2105        1.1       cgd 	struct mbuf **mdp;
   2106        1.1       cgd 	caddr_t *dposp;
   2107       1.25      fvdl 	struct vnode **retdirp;
   2108      1.125      fvdl 	struct proc *p;
   2109       1.43      fvdl 	int kerbflag, pubflag;
   2110        1.1       cgd {
   2111       1.75  augustss 	int i, rem;
   2112       1.75  augustss 	struct mbuf *md;
   2113       1.75  augustss 	char *fromcp, *tocp, *cp;
   2114       1.43      fvdl 	struct iovec aiov;
   2115       1.43      fvdl 	struct uio auio;
   2116        1.1       cgd 	struct vnode *dp;
   2117       1.43      fvdl 	int error, rdonly, linklen;
   2118       1.12   mycroft 	struct componentname *cnp = &ndp->ni_cnd;
   2119        1.1       cgd 
   2120       1.25      fvdl 	*retdirp = (struct vnode *)0;
   2121       1.81   thorpej 
   2122       1.81   thorpej 	if ((len + 1) > MAXPATHLEN)
   2123       1.81   thorpej 		return (ENAMETOOLONG);
   2124      1.147      yamt 	if (len == 0)
   2125      1.147      yamt 		return (EACCES);
   2126       1.81   thorpej 	cnp->cn_pnbuf = PNBUF_GET();
   2127       1.81   thorpej 
   2128        1.1       cgd 	/*
   2129        1.1       cgd 	 * Copy the name from the mbuf list to ndp->ni_pnbuf
   2130        1.1       cgd 	 * and set the various ndp fields appropriately.
   2131        1.1       cgd 	 */
   2132        1.1       cgd 	fromcp = *dposp;
   2133       1.12   mycroft 	tocp = cnp->cn_pnbuf;
   2134        1.1       cgd 	md = *mdp;
   2135        1.1       cgd 	rem = mtod(md, caddr_t) + md->m_len - fromcp;
   2136        1.1       cgd 	for (i = 0; i < len; i++) {
   2137        1.1       cgd 		while (rem == 0) {
   2138        1.1       cgd 			md = md->m_next;
   2139        1.1       cgd 			if (md == NULL) {
   2140        1.1       cgd 				error = EBADRPC;
   2141        1.1       cgd 				goto out;
   2142        1.1       cgd 			}
   2143        1.1       cgd 			fromcp = mtod(md, caddr_t);
   2144        1.1       cgd 			rem = md->m_len;
   2145        1.1       cgd 		}
   2146       1.43      fvdl 		if (*fromcp == '\0' || (!pubflag && *fromcp == '/')) {
   2147       1.25      fvdl 			error = EACCES;
   2148        1.1       cgd 			goto out;
   2149        1.1       cgd 		}
   2150        1.1       cgd 		*tocp++ = *fromcp++;
   2151        1.1       cgd 		rem--;
   2152        1.1       cgd 	}
   2153        1.1       cgd 	*tocp = '\0';
   2154        1.1       cgd 	*mdp = md;
   2155        1.1       cgd 	*dposp = fromcp;
   2156        1.1       cgd 	len = nfsm_rndup(len)-len;
   2157        1.1       cgd 	if (len > 0) {
   2158        1.1       cgd 		if (rem >= len)
   2159        1.1       cgd 			*dposp += len;
   2160       1.24  christos 		else if ((error = nfs_adv(mdp, dposp, len, rem)) != 0)
   2161        1.1       cgd 			goto out;
   2162        1.1       cgd 	}
   2163       1.43      fvdl 
   2164        1.1       cgd 	/*
   2165        1.1       cgd 	 * Extract and set starting directory.
   2166        1.1       cgd 	 */
   2167       1.24  christos 	error = nfsrv_fhtovp(fhp, FALSE, &dp, ndp->ni_cnd.cn_cred, slp,
   2168      1.124   thorpej 	    nam, &rdonly, kerbflag, pubflag);
   2169       1.24  christos 	if (error)
   2170        1.1       cgd 		goto out;
   2171        1.1       cgd 	if (dp->v_type != VDIR) {
   2172        1.1       cgd 		vrele(dp);
   2173        1.1       cgd 		error = ENOTDIR;
   2174        1.1       cgd 		goto out;
   2175        1.1       cgd 	}
   2176       1.43      fvdl 
   2177       1.43      fvdl 	if (rdonly)
   2178       1.43      fvdl 		cnp->cn_flags |= RDONLY;
   2179       1.43      fvdl 
   2180       1.43      fvdl 	*retdirp = dp;
   2181       1.43      fvdl 
   2182       1.43      fvdl 	if (pubflag) {
   2183       1.43      fvdl 		/*
   2184       1.43      fvdl 		 * Oh joy. For WebNFS, handle those pesky '%' escapes,
   2185       1.43      fvdl 		 * and the 'native path' indicator.
   2186       1.43      fvdl 		 */
   2187       1.81   thorpej 		cp = PNBUF_GET();
   2188       1.43      fvdl 		fromcp = cnp->cn_pnbuf;
   2189       1.43      fvdl 		tocp = cp;
   2190       1.43      fvdl 		if ((unsigned char)*fromcp >= WEBNFS_SPECCHAR_START) {
   2191       1.43      fvdl 			switch ((unsigned char)*fromcp) {
   2192       1.43      fvdl 			case WEBNFS_NATIVE_CHAR:
   2193       1.43      fvdl 				/*
   2194       1.43      fvdl 				 * 'Native' path for us is the same
   2195       1.43      fvdl 				 * as a path according to the NFS spec,
   2196       1.43      fvdl 				 * just skip the escape char.
   2197       1.43      fvdl 				 */
   2198       1.43      fvdl 				fromcp++;
   2199       1.43      fvdl 				break;
   2200       1.43      fvdl 			/*
   2201       1.43      fvdl 			 * More may be added in the future, range 0x80-0xff
   2202       1.43      fvdl 			 */
   2203       1.43      fvdl 			default:
   2204       1.43      fvdl 				error = EIO;
   2205      1.104     enami 				PNBUF_PUT(cp);
   2206       1.43      fvdl 				goto out;
   2207       1.43      fvdl 			}
   2208       1.43      fvdl 		}
   2209       1.43      fvdl 		/*
   2210       1.43      fvdl 		 * Translate the '%' escapes, URL-style.
   2211       1.43      fvdl 		 */
   2212       1.43      fvdl 		while (*fromcp != '\0') {
   2213       1.43      fvdl 			if (*fromcp == WEBNFS_ESC_CHAR) {
   2214       1.43      fvdl 				if (fromcp[1] != '\0' && fromcp[2] != '\0') {
   2215       1.43      fvdl 					fromcp++;
   2216       1.43      fvdl 					*tocp++ = HEXSTRTOI(fromcp);
   2217       1.43      fvdl 					fromcp += 2;
   2218       1.43      fvdl 					continue;
   2219       1.43      fvdl 				} else {
   2220       1.43      fvdl 					error = ENOENT;
   2221      1.104     enami 					PNBUF_PUT(cp);
   2222       1.43      fvdl 					goto out;
   2223       1.43      fvdl 				}
   2224       1.43      fvdl 			} else
   2225       1.43      fvdl 				*tocp++ = *fromcp++;
   2226       1.43      fvdl 		}
   2227       1.43      fvdl 		*tocp = '\0';
   2228       1.81   thorpej 		PNBUF_PUT(cnp->cn_pnbuf);
   2229       1.43      fvdl 		cnp->cn_pnbuf = cp;
   2230       1.43      fvdl 	}
   2231       1.43      fvdl 
   2232       1.43      fvdl 	ndp->ni_pathlen = (tocp - cnp->cn_pnbuf) + 1;
   2233       1.43      fvdl 	ndp->ni_segflg = UIO_SYSSPACE;
   2234       1.98      fvdl 	ndp->ni_rootdir = rootvnode;
   2235       1.43      fvdl 
   2236       1.43      fvdl 	if (pubflag) {
   2237       1.43      fvdl 		ndp->ni_loopcnt = 0;
   2238       1.43      fvdl 		if (cnp->cn_pnbuf[0] == '/')
   2239       1.43      fvdl 			dp = rootvnode;
   2240       1.43      fvdl 	} else {
   2241       1.43      fvdl 		cnp->cn_flags |= NOCROSSMOUNT;
   2242       1.43      fvdl 	}
   2243       1.43      fvdl 
   2244      1.125      fvdl 	cnp->cn_proc = p;
   2245       1.25      fvdl 	VREF(dp);
   2246       1.43      fvdl 
   2247       1.43      fvdl     for (;;) {
   2248       1.43      fvdl 	cnp->cn_nameptr = cnp->cn_pnbuf;
   2249        1.1       cgd 	ndp->ni_startdir = dp;
   2250        1.1       cgd 	/*
   2251        1.1       cgd 	 * And call lookup() to do the real work
   2252        1.1       cgd 	 */
   2253       1.25      fvdl 	error = lookup(ndp);
   2254       1.91      fvdl 	if (error) {
   2255       1.91      fvdl 		PNBUF_PUT(cnp->cn_pnbuf);
   2256       1.91      fvdl 		return (error);
   2257       1.91      fvdl 	}
   2258        1.1       cgd 	/*
   2259        1.1       cgd 	 * Check for encountering a symbolic link
   2260        1.1       cgd 	 */
   2261       1.43      fvdl 	if ((cnp->cn_flags & ISSYMLINK) == 0) {
   2262       1.91      fvdl 		if (cnp->cn_flags & (SAVENAME | SAVESTART))
   2263       1.43      fvdl 			cnp->cn_flags |= HASBUF;
   2264       1.91      fvdl 		else
   2265       1.91      fvdl 			PNBUF_PUT(cnp->cn_pnbuf);
   2266       1.91      fvdl 		return (0);
   2267       1.43      fvdl 	} else {
   2268       1.91      fvdl 		if ((cnp->cn_flags & LOCKPARENT) && (cnp->cn_flags & ISLASTCN))
   2269       1.56      fvdl 			VOP_UNLOCK(ndp->ni_dvp, 0);
   2270       1.43      fvdl 		if (!pubflag) {
   2271       1.43      fvdl 			error = EINVAL;
   2272       1.43      fvdl 			break;
   2273       1.43      fvdl 		}
   2274       1.43      fvdl 
   2275       1.43      fvdl 		if (ndp->ni_loopcnt++ >= MAXSYMLINKS) {
   2276       1.43      fvdl 			error = ELOOP;
   2277       1.43      fvdl 			break;
   2278       1.43      fvdl 		}
   2279       1.91      fvdl 		if (ndp->ni_vp->v_mount->mnt_flag & MNT_SYMPERM) {
   2280       1.91      fvdl 			error = VOP_ACCESS(ndp->ni_vp, VEXEC, cnp->cn_cred,
   2281      1.125      fvdl 			    cnp->cn_proc);
   2282       1.91      fvdl 			if (error != 0)
   2283       1.91      fvdl 				break;
   2284       1.91      fvdl 		}
   2285       1.43      fvdl 		if (ndp->ni_pathlen > 1)
   2286       1.81   thorpej 			cp = PNBUF_GET();
   2287        1.1       cgd 		else
   2288       1.43      fvdl 			cp = cnp->cn_pnbuf;
   2289       1.43      fvdl 		aiov.iov_base = cp;
   2290       1.43      fvdl 		aiov.iov_len = MAXPATHLEN;
   2291       1.43      fvdl 		auio.uio_iov = &aiov;
   2292       1.43      fvdl 		auio.uio_iovcnt = 1;
   2293       1.43      fvdl 		auio.uio_offset = 0;
   2294       1.43      fvdl 		auio.uio_rw = UIO_READ;
   2295       1.43      fvdl 		auio.uio_segflg = UIO_SYSSPACE;
   2296      1.136     skrll 		auio.uio_procp = NULL;
   2297       1.43      fvdl 		auio.uio_resid = MAXPATHLEN;
   2298       1.43      fvdl 		error = VOP_READLINK(ndp->ni_vp, &auio, cnp->cn_cred);
   2299       1.43      fvdl 		if (error) {
   2300       1.43      fvdl 		badlink:
   2301       1.43      fvdl 			if (ndp->ni_pathlen > 1)
   2302       1.81   thorpej 				PNBUF_PUT(cp);
   2303       1.43      fvdl 			break;
   2304       1.43      fvdl 		}
   2305       1.43      fvdl 		linklen = MAXPATHLEN - auio.uio_resid;
   2306       1.43      fvdl 		if (linklen == 0) {
   2307       1.43      fvdl 			error = ENOENT;
   2308       1.43      fvdl 			goto badlink;
   2309       1.43      fvdl 		}
   2310       1.43      fvdl 		if (linklen + ndp->ni_pathlen >= MAXPATHLEN) {
   2311       1.43      fvdl 			error = ENAMETOOLONG;
   2312       1.43      fvdl 			goto badlink;
   2313       1.43      fvdl 		}
   2314       1.43      fvdl 		if (ndp->ni_pathlen > 1) {
   2315       1.63     perry 			memcpy(cp + linklen, ndp->ni_next, ndp->ni_pathlen);
   2316       1.81   thorpej 			PNBUF_PUT(cnp->cn_pnbuf);
   2317       1.43      fvdl 			cnp->cn_pnbuf = cp;
   2318       1.43      fvdl 		} else
   2319       1.43      fvdl 			cnp->cn_pnbuf[linklen] = '\0';
   2320       1.43      fvdl 		ndp->ni_pathlen += linklen;
   2321        1.1       cgd 		vput(ndp->ni_vp);
   2322       1.43      fvdl 		dp = ndp->ni_dvp;
   2323       1.43      fvdl 		/*
   2324       1.43      fvdl 		 * Check if root directory should replace current directory.
   2325       1.43      fvdl 		 */
   2326       1.43      fvdl 		if (cnp->cn_pnbuf[0] == '/') {
   2327       1.43      fvdl 			vrele(dp);
   2328       1.43      fvdl 			dp = ndp->ni_rootdir;
   2329       1.43      fvdl 			VREF(dp);
   2330       1.43      fvdl 		}
   2331        1.1       cgd 	}
   2332       1.43      fvdl    }
   2333       1.91      fvdl 	vrele(ndp->ni_dvp);
   2334       1.91      fvdl 	vput(ndp->ni_vp);
   2335       1.91      fvdl 	ndp->ni_vp = NULL;
   2336        1.1       cgd out:
   2337       1.81   thorpej 	PNBUF_PUT(cnp->cn_pnbuf);
   2338        1.1       cgd 	return (error);
   2339        1.1       cgd }
   2340      1.153      jmmv #endif /* NFSSERVER */
   2341        1.1       cgd 
   2342        1.1       cgd /*
   2343      1.118      yamt  * A fiddled version of m_adj() that ensures null fill to a 32-bit
   2344        1.1       cgd  * boundary and only trims off the back end
   2345      1.122      yamt  *
   2346      1.122      yamt  * 1. trim off 'len' bytes as m_adj(mp, -len).
   2347      1.122      yamt  * 2. add zero-padding 'nul' bytes at the end of the mbuf chain.
   2348        1.1       cgd  */
   2349       1.12   mycroft void
   2350      1.122      yamt nfs_zeropad(mp, len, nul)
   2351        1.1       cgd 	struct mbuf *mp;
   2352       1.75  augustss 	int len;
   2353        1.1       cgd 	int nul;
   2354        1.1       cgd {
   2355       1.75  augustss 	struct mbuf *m;
   2356      1.130      yamt 	int count;
   2357        1.1       cgd 
   2358        1.1       cgd 	/*
   2359        1.1       cgd 	 * Trim from tail.  Scan the mbuf chain,
   2360        1.1       cgd 	 * calculating its length and finding the last mbuf.
   2361        1.1       cgd 	 * If the adjustment only affects this mbuf, then just
   2362        1.1       cgd 	 * adjust and return.  Otherwise, rescan and truncate
   2363        1.1       cgd 	 * after the remaining size.
   2364        1.1       cgd 	 */
   2365        1.1       cgd 	count = 0;
   2366        1.1       cgd 	m = mp;
   2367        1.1       cgd 	for (;;) {
   2368        1.1       cgd 		count += m->m_len;
   2369      1.122      yamt 		if (m->m_next == NULL)
   2370        1.1       cgd 			break;
   2371        1.1       cgd 		m = m->m_next;
   2372        1.1       cgd 	}
   2373      1.122      yamt 
   2374      1.122      yamt 	KDASSERT(count >= len);
   2375      1.122      yamt 
   2376      1.122      yamt 	if (m->m_len >= len) {
   2377        1.1       cgd 		m->m_len -= len;
   2378      1.122      yamt 	} else {
   2379      1.122      yamt 		count -= len;
   2380      1.122      yamt 		/*
   2381      1.122      yamt 		 * Correct length for chain is "count".
   2382      1.122      yamt 		 * Find the mbuf with last data, adjust its length,
   2383      1.122      yamt 		 * and toss data from remaining mbufs on chain.
   2384      1.122      yamt 		 */
   2385      1.122      yamt 		for (m = mp; m; m = m->m_next) {
   2386      1.122      yamt 			if (m->m_len >= count) {
   2387      1.122      yamt 				m->m_len = count;
   2388      1.122      yamt 				break;
   2389      1.118      yamt 			}
   2390      1.122      yamt 			count -= m->m_len;
   2391        1.1       cgd 		}
   2392      1.122      yamt 		m_freem(m->m_next);
   2393      1.122      yamt 		m->m_next = NULL;
   2394        1.1       cgd 	}
   2395      1.122      yamt 
   2396      1.130      yamt 	KDASSERT(m->m_next == NULL);
   2397      1.130      yamt 
   2398      1.122      yamt 	/*
   2399      1.122      yamt 	 * zero-padding.
   2400      1.122      yamt 	 */
   2401      1.122      yamt 	if (nul > 0) {
   2402      1.130      yamt 		char *cp;
   2403      1.130      yamt 		int i;
   2404      1.130      yamt 
   2405      1.122      yamt 		if (M_ROMAP(m) || M_TRAILINGSPACE(m) < nul) {
   2406      1.122      yamt 			struct mbuf *n;
   2407      1.122      yamt 
   2408      1.122      yamt 			KDASSERT(MLEN >= nul);
   2409      1.122      yamt 			n = m_get(M_WAIT, MT_DATA);
   2410      1.122      yamt 			MCLAIM(n, &nfs_mowner);
   2411      1.122      yamt 			n->m_len = nul;
   2412      1.130      yamt 			n->m_next = NULL;
   2413      1.122      yamt 			m->m_next = n;
   2414      1.122      yamt 			cp = mtod(n, caddr_t);
   2415      1.122      yamt 		} else {
   2416      1.122      yamt 			cp = mtod(m, caddr_t) + m->m_len;
   2417      1.122      yamt 			m->m_len += nul;
   2418        1.1       cgd 		}
   2419      1.122      yamt 		for (i = 0; i < nul; i++)
   2420      1.122      yamt 			*cp++ = '\0';
   2421        1.1       cgd 	}
   2422      1.122      yamt 	return;
   2423        1.1       cgd }
   2424        1.1       cgd 
   2425        1.1       cgd /*
   2426       1.25      fvdl  * Make these functions instead of macros, so that the kernel text size
   2427       1.25      fvdl  * doesn't get too big...
   2428       1.25      fvdl  */
   2429       1.25      fvdl void
   2430       1.25      fvdl nfsm_srvwcc(nfsd, before_ret, before_vap, after_ret, after_vap, mbp, bposp)
   2431       1.25      fvdl 	struct nfsrv_descript *nfsd;
   2432       1.25      fvdl 	int before_ret;
   2433       1.75  augustss 	struct vattr *before_vap;
   2434       1.25      fvdl 	int after_ret;
   2435       1.25      fvdl 	struct vattr *after_vap;
   2436       1.25      fvdl 	struct mbuf **mbp;
   2437       1.25      fvdl 	char **bposp;
   2438       1.25      fvdl {
   2439      1.109      matt 	struct mbuf *mb = *mbp;
   2440       1.75  augustss 	char *bpos = *bposp;
   2441       1.75  augustss 	u_int32_t *tl;
   2442       1.25      fvdl 
   2443       1.25      fvdl 	if (before_ret) {
   2444       1.25      fvdl 		nfsm_build(tl, u_int32_t *, NFSX_UNSIGNED);
   2445       1.25      fvdl 		*tl = nfs_false;
   2446       1.25      fvdl 	} else {
   2447       1.25      fvdl 		nfsm_build(tl, u_int32_t *, 7 * NFSX_UNSIGNED);
   2448       1.25      fvdl 		*tl++ = nfs_true;
   2449       1.66      fair 		txdr_hyper(before_vap->va_size, tl);
   2450       1.25      fvdl 		tl += 2;
   2451       1.25      fvdl 		txdr_nfsv3time(&(before_vap->va_mtime), tl);
   2452       1.25      fvdl 		tl += 2;
   2453       1.25      fvdl 		txdr_nfsv3time(&(before_vap->va_ctime), tl);
   2454       1.25      fvdl 	}
   2455       1.25      fvdl 	*bposp = bpos;
   2456       1.25      fvdl 	*mbp = mb;
   2457       1.25      fvdl 	nfsm_srvpostopattr(nfsd, after_ret, after_vap, mbp, bposp);
   2458       1.25      fvdl }
   2459       1.25      fvdl 
   2460       1.25      fvdl void
   2461       1.25      fvdl nfsm_srvpostopattr(nfsd, after_ret, after_vap, mbp, bposp)
   2462       1.25      fvdl 	struct nfsrv_descript *nfsd;
   2463       1.25      fvdl 	int after_ret;
   2464       1.25      fvdl 	struct vattr *after_vap;
   2465       1.25      fvdl 	struct mbuf **mbp;
   2466       1.25      fvdl 	char **bposp;
   2467       1.25      fvdl {
   2468      1.109      matt 	struct mbuf *mb = *mbp;
   2469       1.75  augustss 	char *bpos = *bposp;
   2470       1.75  augustss 	u_int32_t *tl;
   2471       1.75  augustss 	struct nfs_fattr *fp;
   2472       1.25      fvdl 
   2473       1.25      fvdl 	if (after_ret) {
   2474       1.25      fvdl 		nfsm_build(tl, u_int32_t *, NFSX_UNSIGNED);
   2475       1.25      fvdl 		*tl = nfs_false;
   2476       1.25      fvdl 	} else {
   2477       1.25      fvdl 		nfsm_build(tl, u_int32_t *, NFSX_UNSIGNED + NFSX_V3FATTR);
   2478       1.25      fvdl 		*tl++ = nfs_true;
   2479       1.25      fvdl 		fp = (struct nfs_fattr *)tl;
   2480       1.25      fvdl 		nfsm_srvfattr(nfsd, after_vap, fp);
   2481       1.25      fvdl 	}
   2482       1.25      fvdl 	*mbp = mb;
   2483       1.25      fvdl 	*bposp = bpos;
   2484       1.25      fvdl }
   2485       1.25      fvdl 
   2486       1.25      fvdl void
   2487       1.25      fvdl nfsm_srvfattr(nfsd, vap, fp)
   2488       1.75  augustss 	struct nfsrv_descript *nfsd;
   2489       1.75  augustss 	struct vattr *vap;
   2490       1.75  augustss 	struct nfs_fattr *fp;
   2491       1.25      fvdl {
   2492       1.25      fvdl 
   2493       1.25      fvdl 	fp->fa_nlink = txdr_unsigned(vap->va_nlink);
   2494       1.25      fvdl 	fp->fa_uid = txdr_unsigned(vap->va_uid);
   2495       1.25      fvdl 	fp->fa_gid = txdr_unsigned(vap->va_gid);
   2496       1.25      fvdl 	if (nfsd->nd_flag & ND_NFSV3) {
   2497       1.25      fvdl 		fp->fa_type = vtonfsv3_type(vap->va_type);
   2498       1.25      fvdl 		fp->fa_mode = vtonfsv3_mode(vap->va_mode);
   2499       1.66      fair 		txdr_hyper(vap->va_size, &fp->fa3_size);
   2500       1.66      fair 		txdr_hyper(vap->va_bytes, &fp->fa3_used);
   2501       1.25      fvdl 		fp->fa3_rdev.specdata1 = txdr_unsigned(major(vap->va_rdev));
   2502       1.25      fvdl 		fp->fa3_rdev.specdata2 = txdr_unsigned(minor(vap->va_rdev));
   2503       1.25      fvdl 		fp->fa3_fsid.nfsuquad[0] = 0;
   2504       1.25      fvdl 		fp->fa3_fsid.nfsuquad[1] = txdr_unsigned(vap->va_fsid);
   2505      1.151      yamt 		txdr_hyper(vap->va_fileid, &fp->fa3_fileid);
   2506       1.25      fvdl 		txdr_nfsv3time(&vap->va_atime, &fp->fa3_atime);
   2507       1.25      fvdl 		txdr_nfsv3time(&vap->va_mtime, &fp->fa3_mtime);
   2508       1.25      fvdl 		txdr_nfsv3time(&vap->va_ctime, &fp->fa3_ctime);
   2509       1.25      fvdl 	} else {
   2510       1.25      fvdl 		fp->fa_type = vtonfsv2_type(vap->va_type);
   2511       1.25      fvdl 		fp->fa_mode = vtonfsv2_mode(vap->va_type, vap->va_mode);
   2512       1.25      fvdl 		fp->fa2_size = txdr_unsigned(vap->va_size);
   2513       1.25      fvdl 		fp->fa2_blocksize = txdr_unsigned(vap->va_blocksize);
   2514       1.25      fvdl 		if (vap->va_type == VFIFO)
   2515       1.25      fvdl 			fp->fa2_rdev = 0xffffffff;
   2516       1.25      fvdl 		else
   2517       1.25      fvdl 			fp->fa2_rdev = txdr_unsigned(vap->va_rdev);
   2518       1.25      fvdl 		fp->fa2_blocks = txdr_unsigned(vap->va_bytes / NFS_FABLKSIZE);
   2519       1.25      fvdl 		fp->fa2_fsid = txdr_unsigned(vap->va_fsid);
   2520       1.25      fvdl 		fp->fa2_fileid = txdr_unsigned(vap->va_fileid);
   2521       1.25      fvdl 		txdr_nfsv2time(&vap->va_atime, &fp->fa2_atime);
   2522       1.25      fvdl 		txdr_nfsv2time(&vap->va_mtime, &fp->fa2_mtime);
   2523       1.25      fvdl 		txdr_nfsv2time(&vap->va_ctime, &fp->fa2_ctime);
   2524       1.25      fvdl 	}
   2525       1.25      fvdl }
   2526       1.25      fvdl 
   2527      1.153      jmmv #ifdef NFSSERVER
   2528       1.25      fvdl /*
   2529        1.1       cgd  * nfsrv_fhtovp() - convert a fh to a vnode ptr (optionally locked)
   2530        1.1       cgd  * 	- look up fsid in mount list (if not found ret error)
   2531       1.12   mycroft  *	- get vp and export rights by calling VFS_FHTOVP()
   2532       1.12   mycroft  *	- if cred->cr_uid == 0 or MNT_EXPORTANON set it to credanon
   2533        1.1       cgd  *	- if not lockflag unlock it with VOP_UNLOCK()
   2534        1.1       cgd  */
   2535       1.24  christos int
   2536      1.124   thorpej nfsrv_fhtovp(fhp, lockflag, vpp, cred, slp, nam, rdonlyp, kerbflag, pubflag)
   2537        1.1       cgd 	fhandle_t *fhp;
   2538        1.1       cgd 	int lockflag;
   2539        1.1       cgd 	struct vnode **vpp;
   2540        1.1       cgd 	struct ucred *cred;
   2541       1.12   mycroft 	struct nfssvc_sock *slp;
   2542       1.12   mycroft 	struct mbuf *nam;
   2543       1.12   mycroft 	int *rdonlyp;
   2544       1.25      fvdl 	int kerbflag;
   2545        1.1       cgd {
   2546       1.75  augustss 	struct mount *mp;
   2547       1.75  augustss 	int i;
   2548       1.12   mycroft 	struct ucred *credanon;
   2549       1.12   mycroft 	int error, exflags;
   2550       1.40      fvdl 	struct sockaddr_in *saddr;
   2551        1.1       cgd 
   2552       1.12   mycroft 	*vpp = (struct vnode *)0;
   2553       1.43      fvdl 
   2554       1.43      fvdl 	if (nfs_ispublicfh(fhp)) {
   2555       1.43      fvdl 		if (!pubflag || !nfs_pub.np_valid)
   2556       1.43      fvdl 			return (ESTALE);
   2557       1.43      fvdl 		fhp = &nfs_pub.np_handle;
   2558       1.43      fvdl 	}
   2559       1.43      fvdl 
   2560  1.153.6.1      yamt 	error = netexport_check(&fhp->fh_fsid, nam, &mp, &exflags, &credanon);
   2561  1.153.6.1      yamt 	if (error) {
   2562  1.153.6.1      yamt 		return error;
   2563  1.153.6.1      yamt 	}
   2564  1.153.6.1      yamt 
   2565      1.124   thorpej 	error = VFS_FHTOVP(mp, &fhp->fh_fid, vpp);
   2566       1.24  christos 	if (error)
   2567       1.12   mycroft 		return (error);
   2568       1.40      fvdl 
   2569       1.43      fvdl 	if (!(exflags & (MNT_EXNORESPORT|MNT_EXPUBLIC))) {
   2570       1.40      fvdl 		saddr = mtod(nam, struct sockaddr_in *);
   2571       1.76      fvdl 		if ((saddr->sin_family == AF_INET) &&
   2572       1.40      fvdl 		    ntohs(saddr->sin_port) >= IPPORT_RESERVED) {
   2573       1.40      fvdl 			vput(*vpp);
   2574       1.40      fvdl 			return (NFSERR_AUTHERR | AUTH_TOOWEAK);
   2575       1.40      fvdl 		}
   2576       1.76      fvdl #ifdef INET6
   2577       1.76      fvdl 		if ((saddr->sin_family == AF_INET6) &&
   2578       1.76      fvdl 		    ntohs(saddr->sin_port) >= IPV6PORT_RESERVED) {
   2579       1.76      fvdl 			vput(*vpp);
   2580       1.76      fvdl 			return (NFSERR_AUTHERR | AUTH_TOOWEAK);
   2581       1.76      fvdl 		}
   2582       1.76      fvdl #endif
   2583       1.40      fvdl 	}
   2584       1.12   mycroft 	/*
   2585       1.12   mycroft 	 * Check/setup credentials.
   2586       1.12   mycroft 	 */
   2587       1.12   mycroft 	if (exflags & MNT_EXKERB) {
   2588       1.25      fvdl 		if (!kerbflag) {
   2589       1.12   mycroft 			vput(*vpp);
   2590       1.25      fvdl 			return (NFSERR_AUTHERR | AUTH_TOOWEAK);
   2591       1.12   mycroft 		}
   2592       1.25      fvdl 	} else if (kerbflag) {
   2593       1.25      fvdl 		vput(*vpp);
   2594       1.25      fvdl 		return (NFSERR_AUTHERR | AUTH_TOOWEAK);
   2595       1.12   mycroft 	} else if (cred->cr_uid == 0 || (exflags & MNT_EXPORTANON)) {
   2596       1.12   mycroft 		cred->cr_uid = credanon->cr_uid;
   2597       1.19       jtc 		cred->cr_gid = credanon->cr_gid;
   2598       1.12   mycroft 		for (i = 0; i < credanon->cr_ngroups && i < NGROUPS; i++)
   2599       1.12   mycroft 			cred->cr_groups[i] = credanon->cr_groups[i];
   2600       1.15   mycroft 		cred->cr_ngroups = i;
   2601       1.12   mycroft 	}
   2602       1.12   mycroft 	if (exflags & MNT_EXRDONLY)
   2603       1.12   mycroft 		*rdonlyp = 1;
   2604       1.12   mycroft 	else
   2605       1.12   mycroft 		*rdonlyp = 0;
   2606        1.1       cgd 	if (!lockflag)
   2607       1.56      fvdl 		VOP_UNLOCK(*vpp, 0);
   2608        1.1       cgd 	return (0);
   2609       1.43      fvdl }
   2610       1.43      fvdl 
   2611       1.43      fvdl /*
   2612       1.43      fvdl  * WebNFS: check if a filehandle is a public filehandle. For v3, this
   2613       1.43      fvdl  * means a length of 0, for v2 it means all zeroes. nfsm_srvmtofh has
   2614       1.43      fvdl  * transformed this to all zeroes in both cases, so check for it.
   2615       1.43      fvdl  */
   2616       1.43      fvdl int
   2617       1.43      fvdl nfs_ispublicfh(fhp)
   2618       1.43      fvdl 	fhandle_t *fhp;
   2619       1.43      fvdl {
   2620       1.43      fvdl 	char *cp = (char *)fhp;
   2621       1.43      fvdl 	int i;
   2622       1.43      fvdl 
   2623       1.43      fvdl 	for (i = 0; i < NFSX_V3FH; i++)
   2624       1.43      fvdl 		if (*cp++ != 0)
   2625       1.43      fvdl 			return (FALSE);
   2626       1.43      fvdl 	return (TRUE);
   2627        1.1       cgd }
   2628      1.153      jmmv #endif /* NFSSERVER */
   2629        1.1       cgd 
   2630        1.1       cgd /*
   2631       1.12   mycroft  * This function compares two net addresses by family and returns TRUE
   2632       1.12   mycroft  * if they are the same host.
   2633       1.12   mycroft  * If there is any doubt, return FALSE.
   2634       1.12   mycroft  * The AF_INET family is handled as a special case so that address mbufs
   2635       1.12   mycroft  * don't need to be saved to store "struct in_addr", which is only 4 bytes.
   2636        1.1       cgd  */
   2637       1.24  christos int
   2638       1.12   mycroft netaddr_match(family, haddr, nam)
   2639       1.12   mycroft 	int family;
   2640       1.12   mycroft 	union nethostaddr *haddr;
   2641       1.12   mycroft 	struct mbuf *nam;
   2642        1.1       cgd {
   2643       1.75  augustss 	struct sockaddr_in *inetaddr;
   2644        1.1       cgd 
   2645       1.12   mycroft 	switch (family) {
   2646       1.12   mycroft 	case AF_INET:
   2647       1.12   mycroft 		inetaddr = mtod(nam, struct sockaddr_in *);
   2648       1.12   mycroft 		if (inetaddr->sin_family == AF_INET &&
   2649       1.12   mycroft 		    inetaddr->sin_addr.s_addr == haddr->had_inetaddr)
   2650       1.12   mycroft 			return (1);
   2651       1.12   mycroft 		break;
   2652       1.76      fvdl #ifdef INET6
   2653       1.76      fvdl 	case AF_INET6:
   2654       1.76      fvdl 	    {
   2655       1.76      fvdl 		struct sockaddr_in6 *sin6_1, *sin6_2;
   2656       1.76      fvdl 
   2657       1.76      fvdl 		sin6_1 = mtod(nam, struct sockaddr_in6 *);
   2658       1.76      fvdl 		sin6_2 = mtod(haddr->had_nam, struct sockaddr_in6 *);
   2659       1.76      fvdl 		if (sin6_1->sin6_family == AF_INET6 &&
   2660       1.76      fvdl 		    IN6_ARE_ADDR_EQUAL(&sin6_1->sin6_addr, &sin6_2->sin6_addr))
   2661       1.76      fvdl 			return 1;
   2662       1.76      fvdl 	    }
   2663       1.76      fvdl #endif
   2664       1.12   mycroft #ifdef ISO
   2665       1.12   mycroft 	case AF_ISO:
   2666       1.12   mycroft 	    {
   2667       1.75  augustss 		struct sockaddr_iso *isoaddr1, *isoaddr2;
   2668       1.12   mycroft 
   2669       1.12   mycroft 		isoaddr1 = mtod(nam, struct sockaddr_iso *);
   2670       1.12   mycroft 		isoaddr2 = mtod(haddr->had_nam, struct sockaddr_iso *);
   2671       1.12   mycroft 		if (isoaddr1->siso_family == AF_ISO &&
   2672       1.12   mycroft 		    isoaddr1->siso_nlen > 0 &&
   2673       1.12   mycroft 		    isoaddr1->siso_nlen == isoaddr2->siso_nlen &&
   2674       1.12   mycroft 		    SAME_ISOADDR(isoaddr1, isoaddr2))
   2675       1.12   mycroft 			return (1);
   2676       1.12   mycroft 		break;
   2677       1.12   mycroft 	    }
   2678       1.12   mycroft #endif	/* ISO */
   2679       1.12   mycroft 	default:
   2680       1.12   mycroft 		break;
   2681       1.12   mycroft 	};
   2682       1.12   mycroft 	return (0);
   2683       1.25      fvdl }
   2684       1.25      fvdl 
   2685       1.25      fvdl /*
   2686       1.25      fvdl  * The write verifier has changed (probably due to a server reboot), so all
   2687      1.114      yamt  * PG_NEEDCOMMIT pages will have to be written again. Since they are marked
   2688      1.117      yamt  * as dirty or are being written out just now, all this takes is clearing
   2689      1.117      yamt  * the PG_NEEDCOMMIT flag. Once done the new write verifier can be set for
   2690      1.117      yamt  * the mount point.
   2691       1.25      fvdl  */
   2692       1.25      fvdl void
   2693       1.25      fvdl nfs_clearcommit(mp)
   2694       1.25      fvdl 	struct mount *mp;
   2695       1.25      fvdl {
   2696       1.89       chs 	struct vnode *vp;
   2697       1.83      fvdl 	struct nfsnode *np;
   2698       1.89       chs 	struct vm_page *pg;
   2699      1.116      yamt 	struct nfsmount *nmp = VFSTONFS(mp);
   2700      1.116      yamt 
   2701      1.116      yamt 	lockmgr(&nmp->nm_writeverflock, LK_EXCLUSIVE, NULL);
   2702       1.25      fvdl 
   2703       1.89       chs 	LIST_FOREACH(vp, &mp->mnt_vnodelist, v_mntvnodes) {
   2704       1.89       chs 		KASSERT(vp->v_mount == mp);
   2705      1.146      yamt 		if (vp->v_type != VREG)
   2706       1.85     enami 			continue;
   2707       1.83      fvdl 		np = VTONFS(vp);
   2708       1.83      fvdl 		np->n_pushlo = np->n_pushhi = np->n_pushedlo =
   2709       1.83      fvdl 		    np->n_pushedhi = 0;
   2710       1.83      fvdl 		np->n_commitflags &=
   2711       1.83      fvdl 		    ~(NFS_COMMIT_PUSH_VALID | NFS_COMMIT_PUSHED_VALID);
   2712       1.97       chs 		simple_lock(&vp->v_uobj.vmobjlock);
   2713       1.97       chs 		TAILQ_FOREACH(pg, &vp->v_uobj.memq, listq) {
   2714       1.89       chs 			pg->flags &= ~PG_NEEDCOMMIT;
   2715       1.25      fvdl 		}
   2716       1.97       chs 		simple_unlock(&vp->v_uobj.vmobjlock);
   2717       1.25      fvdl 	}
   2718      1.116      yamt 	simple_lock(&nmp->nm_slock);
   2719      1.116      yamt 	nmp->nm_iflag &= ~NFSMNT_STALEWRITEVERF;
   2720      1.116      yamt 	simple_unlock(&nmp->nm_slock);
   2721      1.116      yamt 	lockmgr(&nmp->nm_writeverflock, LK_RELEASE, NULL);
   2722       1.83      fvdl }
   2723       1.83      fvdl 
   2724       1.83      fvdl void
   2725       1.83      fvdl nfs_merge_commit_ranges(vp)
   2726       1.83      fvdl 	struct vnode *vp;
   2727       1.83      fvdl {
   2728       1.83      fvdl 	struct nfsnode *np = VTONFS(vp);
   2729      1.112      yamt 
   2730      1.112      yamt 	KASSERT(np->n_commitflags & NFS_COMMIT_PUSH_VALID);
   2731       1.83      fvdl 
   2732       1.83      fvdl 	if (!(np->n_commitflags & NFS_COMMIT_PUSHED_VALID)) {
   2733       1.83      fvdl 		np->n_pushedlo = np->n_pushlo;
   2734       1.83      fvdl 		np->n_pushedhi = np->n_pushhi;
   2735       1.83      fvdl 		np->n_commitflags |= NFS_COMMIT_PUSHED_VALID;
   2736       1.83      fvdl 	} else {
   2737       1.83      fvdl 		if (np->n_pushlo < np->n_pushedlo)
   2738       1.83      fvdl 			np->n_pushedlo = np->n_pushlo;
   2739       1.83      fvdl 		if (np->n_pushhi > np->n_pushedhi)
   2740       1.83      fvdl 			np->n_pushedhi = np->n_pushhi;
   2741       1.83      fvdl 	}
   2742       1.83      fvdl 
   2743       1.83      fvdl 	np->n_pushlo = np->n_pushhi = 0;
   2744       1.83      fvdl 	np->n_commitflags &= ~NFS_COMMIT_PUSH_VALID;
   2745       1.83      fvdl 
   2746      1.111      yamt #ifdef NFS_DEBUG_COMMIT
   2747       1.83      fvdl 	printf("merge: committed: %u - %u\n", (unsigned)np->n_pushedlo,
   2748       1.83      fvdl 	    (unsigned)np->n_pushedhi);
   2749       1.83      fvdl #endif
   2750       1.83      fvdl }
   2751       1.83      fvdl 
   2752       1.83      fvdl int
   2753       1.89       chs nfs_in_committed_range(vp, off, len)
   2754       1.83      fvdl 	struct vnode *vp;
   2755       1.89       chs 	off_t off, len;
   2756       1.83      fvdl {
   2757       1.83      fvdl 	struct nfsnode *np = VTONFS(vp);
   2758       1.83      fvdl 	off_t lo, hi;
   2759       1.83      fvdl 
   2760       1.83      fvdl 	if (!(np->n_commitflags & NFS_COMMIT_PUSHED_VALID))
   2761       1.83      fvdl 		return 0;
   2762       1.89       chs 	lo = off;
   2763       1.89       chs 	hi = lo + len;
   2764       1.83      fvdl 
   2765       1.83      fvdl 	return (lo >= np->n_pushedlo && hi <= np->n_pushedhi);
   2766       1.83      fvdl }
   2767       1.83      fvdl 
   2768       1.83      fvdl int
   2769       1.89       chs nfs_in_tobecommitted_range(vp, off, len)
   2770       1.83      fvdl 	struct vnode *vp;
   2771       1.89       chs 	off_t off, len;
   2772       1.83      fvdl {
   2773       1.83      fvdl 	struct nfsnode *np = VTONFS(vp);
   2774       1.83      fvdl 	off_t lo, hi;
   2775       1.83      fvdl 
   2776       1.83      fvdl 	if (!(np->n_commitflags & NFS_COMMIT_PUSH_VALID))
   2777       1.83      fvdl 		return 0;
   2778       1.89       chs 	lo = off;
   2779       1.89       chs 	hi = lo + len;
   2780       1.83      fvdl 
   2781       1.83      fvdl 	return (lo >= np->n_pushlo && hi <= np->n_pushhi);
   2782       1.83      fvdl }
   2783       1.83      fvdl 
   2784       1.83      fvdl void
   2785       1.89       chs nfs_add_committed_range(vp, off, len)
   2786       1.83      fvdl 	struct vnode *vp;
   2787       1.89       chs 	off_t off, len;
   2788       1.83      fvdl {
   2789       1.83      fvdl 	struct nfsnode *np = VTONFS(vp);
   2790       1.83      fvdl 	off_t lo, hi;
   2791       1.83      fvdl 
   2792       1.89       chs 	lo = off;
   2793       1.89       chs 	hi = lo + len;
   2794       1.83      fvdl 
   2795       1.83      fvdl 	if (!(np->n_commitflags & NFS_COMMIT_PUSHED_VALID)) {
   2796       1.83      fvdl 		np->n_pushedlo = lo;
   2797       1.83      fvdl 		np->n_pushedhi = hi;
   2798       1.83      fvdl 		np->n_commitflags |= NFS_COMMIT_PUSHED_VALID;
   2799       1.83      fvdl 	} else {
   2800       1.83      fvdl 		if (hi > np->n_pushedhi)
   2801       1.83      fvdl 			np->n_pushedhi = hi;
   2802       1.83      fvdl 		if (lo < np->n_pushedlo)
   2803       1.83      fvdl 			np->n_pushedlo = lo;
   2804       1.83      fvdl 	}
   2805      1.111      yamt #ifdef NFS_DEBUG_COMMIT
   2806       1.83      fvdl 	printf("add: committed: %u - %u\n", (unsigned)np->n_pushedlo,
   2807       1.83      fvdl 	    (unsigned)np->n_pushedhi);
   2808       1.83      fvdl #endif
   2809       1.83      fvdl }
   2810       1.83      fvdl 
   2811       1.83      fvdl void
   2812       1.89       chs nfs_del_committed_range(vp, off, len)
   2813       1.83      fvdl 	struct vnode *vp;
   2814       1.89       chs 	off_t off, len;
   2815       1.83      fvdl {
   2816       1.83      fvdl 	struct nfsnode *np = VTONFS(vp);
   2817       1.83      fvdl 	off_t lo, hi;
   2818       1.83      fvdl 
   2819       1.83      fvdl 	if (!(np->n_commitflags & NFS_COMMIT_PUSHED_VALID))
   2820       1.83      fvdl 		return;
   2821       1.83      fvdl 
   2822       1.89       chs 	lo = off;
   2823       1.89       chs 	hi = lo + len;
   2824       1.83      fvdl 
   2825       1.83      fvdl 	if (lo > np->n_pushedhi || hi < np->n_pushedlo)
   2826       1.83      fvdl 		return;
   2827       1.83      fvdl 	if (lo <= np->n_pushedlo)
   2828       1.83      fvdl 		np->n_pushedlo = hi;
   2829       1.83      fvdl 	else if (hi >= np->n_pushedhi)
   2830       1.83      fvdl 		np->n_pushedhi = lo;
   2831       1.83      fvdl 	else {
   2832       1.83      fvdl 		/*
   2833       1.83      fvdl 		 * XXX There's only one range. If the deleted range
   2834       1.83      fvdl 		 * is in the middle, pick the largest of the
   2835       1.83      fvdl 		 * contiguous ranges that it leaves.
   2836       1.83      fvdl 		 */
   2837       1.83      fvdl 		if ((np->n_pushedlo - lo) > (hi - np->n_pushedhi))
   2838       1.83      fvdl 			np->n_pushedhi = lo;
   2839       1.83      fvdl 		else
   2840       1.83      fvdl 			np->n_pushedlo = hi;
   2841       1.83      fvdl 	}
   2842      1.111      yamt #ifdef NFS_DEBUG_COMMIT
   2843       1.83      fvdl 	printf("del: committed: %u - %u\n", (unsigned)np->n_pushedlo,
   2844       1.83      fvdl 	    (unsigned)np->n_pushedhi);
   2845       1.83      fvdl #endif
   2846       1.83      fvdl }
   2847       1.83      fvdl 
   2848       1.83      fvdl void
   2849       1.89       chs nfs_add_tobecommitted_range(vp, off, len)
   2850       1.83      fvdl 	struct vnode *vp;
   2851       1.89       chs 	off_t off, len;
   2852       1.83      fvdl {
   2853       1.83      fvdl 	struct nfsnode *np = VTONFS(vp);
   2854       1.83      fvdl 	off_t lo, hi;
   2855       1.83      fvdl 
   2856       1.89       chs 	lo = off;
   2857       1.89       chs 	hi = lo + len;
   2858       1.83      fvdl 
   2859       1.83      fvdl 	if (!(np->n_commitflags & NFS_COMMIT_PUSH_VALID)) {
   2860       1.83      fvdl 		np->n_pushlo = lo;
   2861       1.83      fvdl 		np->n_pushhi = hi;
   2862       1.83      fvdl 		np->n_commitflags |= NFS_COMMIT_PUSH_VALID;
   2863       1.83      fvdl 	} else {
   2864       1.83      fvdl 		if (lo < np->n_pushlo)
   2865       1.83      fvdl 			np->n_pushlo = lo;
   2866       1.83      fvdl 		if (hi > np->n_pushhi)
   2867       1.83      fvdl 			np->n_pushhi = hi;
   2868       1.83      fvdl 	}
   2869      1.111      yamt #ifdef NFS_DEBUG_COMMIT
   2870       1.83      fvdl 	printf("add: tobecommitted: %u - %u\n", (unsigned)np->n_pushlo,
   2871       1.83      fvdl 	    (unsigned)np->n_pushhi);
   2872       1.83      fvdl #endif
   2873       1.83      fvdl }
   2874       1.83      fvdl 
   2875       1.83      fvdl void
   2876       1.89       chs nfs_del_tobecommitted_range(vp, off, len)
   2877       1.83      fvdl 	struct vnode *vp;
   2878       1.89       chs 	off_t off, len;
   2879       1.83      fvdl {
   2880       1.83      fvdl 	struct nfsnode *np = VTONFS(vp);
   2881       1.83      fvdl 	off_t lo, hi;
   2882       1.83      fvdl 
   2883       1.83      fvdl 	if (!(np->n_commitflags & NFS_COMMIT_PUSH_VALID))
   2884       1.83      fvdl 		return;
   2885       1.83      fvdl 
   2886       1.89       chs 	lo = off;
   2887       1.89       chs 	hi = lo + len;
   2888       1.83      fvdl 
   2889       1.83      fvdl 	if (lo > np->n_pushhi || hi < np->n_pushlo)
   2890       1.83      fvdl 		return;
   2891       1.83      fvdl 
   2892       1.83      fvdl 	if (lo <= np->n_pushlo)
   2893       1.83      fvdl 		np->n_pushlo = hi;
   2894       1.83      fvdl 	else if (hi >= np->n_pushhi)
   2895       1.83      fvdl 		np->n_pushhi = lo;
   2896       1.83      fvdl 	else {
   2897       1.83      fvdl 		/*
   2898       1.83      fvdl 		 * XXX There's only one range. If the deleted range
   2899       1.83      fvdl 		 * is in the middle, pick the largest of the
   2900       1.83      fvdl 		 * contiguous ranges that it leaves.
   2901       1.83      fvdl 		 */
   2902       1.83      fvdl 		if ((np->n_pushlo - lo) > (hi - np->n_pushhi))
   2903       1.83      fvdl 			np->n_pushhi = lo;
   2904       1.83      fvdl 		else
   2905       1.83      fvdl 			np->n_pushlo = hi;
   2906       1.83      fvdl 	}
   2907      1.111      yamt #ifdef NFS_DEBUG_COMMIT
   2908       1.83      fvdl 	printf("del: tobecommitted: %u - %u\n", (unsigned)np->n_pushlo,
   2909       1.83      fvdl 	    (unsigned)np->n_pushhi);
   2910       1.83      fvdl #endif
   2911       1.25      fvdl }
   2912       1.25      fvdl 
   2913       1.25      fvdl /*
   2914       1.25      fvdl  * Map errnos to NFS error numbers. For Version 3 also filter out error
   2915       1.25      fvdl  * numbers not specified for the associated procedure.
   2916       1.25      fvdl  */
   2917       1.25      fvdl int
   2918       1.25      fvdl nfsrv_errmap(nd, err)
   2919       1.25      fvdl 	struct nfsrv_descript *nd;
   2920       1.75  augustss 	int err;
   2921       1.25      fvdl {
   2922       1.90  jdolecek 	const short *defaulterrp, *errp;
   2923       1.25      fvdl 
   2924       1.25      fvdl 	if (nd->nd_flag & ND_NFSV3) {
   2925       1.25      fvdl 	    if (nd->nd_procnum <= NFSPROC_COMMIT) {
   2926       1.25      fvdl 		errp = defaulterrp = nfsrv_v3errmap[nd->nd_procnum];
   2927       1.25      fvdl 		while (*++errp) {
   2928       1.25      fvdl 			if (*errp == err)
   2929       1.25      fvdl 				return (err);
   2930       1.25      fvdl 			else if (*errp > err)
   2931       1.25      fvdl 				break;
   2932       1.25      fvdl 		}
   2933       1.25      fvdl 		return ((int)*defaulterrp);
   2934       1.25      fvdl 	    } else
   2935       1.25      fvdl 		return (err & 0xffff);
   2936       1.25      fvdl 	}
   2937       1.25      fvdl 	if (err <= ELAST)
   2938       1.25      fvdl 		return ((int)nfsrv_v2errmap[err - 1]);
   2939       1.25      fvdl 	return (NFSERR_IO);
   2940       1.25      fvdl }
   2941       1.25      fvdl 
   2942       1.25      fvdl /*
   2943       1.25      fvdl  * Sort the group list in increasing numerical order.
   2944       1.25      fvdl  * (Insertion sort by Chris Torek, who was grossed out by the bubble sort
   2945       1.25      fvdl  *  that used to be here.)
   2946       1.25      fvdl  */
   2947       1.25      fvdl void
   2948       1.25      fvdl nfsrvw_sort(list, num)
   2949       1.75  augustss         gid_t *list;
   2950       1.75  augustss         int num;
   2951       1.25      fvdl {
   2952       1.75  augustss 	int i, j;
   2953       1.25      fvdl 	gid_t v;
   2954       1.25      fvdl 
   2955       1.25      fvdl 	/* Insertion sort. */
   2956       1.25      fvdl 	for (i = 1; i < num; i++) {
   2957       1.25      fvdl 		v = list[i];
   2958       1.25      fvdl 		/* find correct slot for value v, moving others up */
   2959       1.25      fvdl 		for (j = i; --j >= 0 && v < list[j];)
   2960       1.25      fvdl 			list[j + 1] = list[j];
   2961       1.25      fvdl 		list[j + 1] = v;
   2962       1.25      fvdl 	}
   2963       1.25      fvdl }
   2964       1.25      fvdl 
   2965       1.25      fvdl /*
   2966       1.63     perry  * copy credentials making sure that the result can be compared with memcmp().
   2967       1.25      fvdl  */
   2968       1.25      fvdl void
   2969       1.25      fvdl nfsrv_setcred(incred, outcred)
   2970       1.75  augustss 	struct ucred *incred, *outcred;
   2971       1.25      fvdl {
   2972       1.75  augustss 	int i;
   2973       1.25      fvdl 
   2974       1.63     perry 	memset((caddr_t)outcred, 0, sizeof (struct ucred));
   2975       1.25      fvdl 	outcred->cr_ref = 1;
   2976       1.25      fvdl 	outcred->cr_uid = incred->cr_uid;
   2977       1.25      fvdl 	outcred->cr_gid = incred->cr_gid;
   2978       1.25      fvdl 	outcred->cr_ngroups = incred->cr_ngroups;
   2979       1.25      fvdl 	for (i = 0; i < incred->cr_ngroups; i++)
   2980       1.25      fvdl 		outcred->cr_groups[i] = incred->cr_groups[i];
   2981       1.25      fvdl 	nfsrvw_sort(outcred->cr_groups, outcred->cr_ngroups);
   2982      1.126      yamt }
   2983      1.126      yamt 
   2984      1.126      yamt u_int32_t
   2985      1.126      yamt nfs_getxid()
   2986      1.126      yamt {
   2987      1.126      yamt 	static u_int32_t base;
   2988      1.126      yamt 	static u_int32_t nfs_xid = 0;
   2989      1.126      yamt 	static struct simplelock nfs_xidlock = SIMPLELOCK_INITIALIZER;
   2990      1.126      yamt 	u_int32_t newxid;
   2991      1.126      yamt 
   2992      1.126      yamt 	simple_lock(&nfs_xidlock);
   2993      1.126      yamt 	/*
   2994      1.126      yamt 	 * derive initial xid from system time
   2995      1.126      yamt 	 * XXX time is invalid if root not yet mounted
   2996      1.126      yamt 	 */
   2997      1.126      yamt 	if (__predict_false(!base && (rootvp))) {
   2998      1.126      yamt 		struct timeval tv;
   2999      1.126      yamt 
   3000      1.126      yamt 		microtime(&tv);
   3001      1.126      yamt 		base = tv.tv_sec << 12;
   3002      1.126      yamt 		nfs_xid = base;
   3003      1.126      yamt 	}
   3004      1.126      yamt 
   3005      1.126      yamt 	/*
   3006      1.126      yamt 	 * Skip zero xid if it should ever happen.
   3007      1.126      yamt 	 */
   3008      1.126      yamt 	if (__predict_false(++nfs_xid == 0))
   3009      1.126      yamt 		nfs_xid++;
   3010      1.126      yamt 	newxid = nfs_xid;
   3011      1.126      yamt 	simple_unlock(&nfs_xidlock);
   3012      1.126      yamt 
   3013      1.126      yamt 	return txdr_unsigned(newxid);
   3014      1.126      yamt }
   3015      1.126      yamt 
   3016      1.126      yamt /*
   3017      1.126      yamt  * assign a new xid for existing request.
   3018      1.126      yamt  * used for NFSERR_JUKEBOX handling.
   3019      1.126      yamt  */
   3020      1.126      yamt void
   3021      1.126      yamt nfs_renewxid(struct nfsreq *req)
   3022      1.126      yamt {
   3023      1.126      yamt 	u_int32_t xid;
   3024      1.126      yamt 	int off;
   3025      1.126      yamt 
   3026      1.126      yamt 	xid = nfs_getxid();
   3027      1.126      yamt 	if (req->r_nmp->nm_sotype == SOCK_STREAM)
   3028      1.126      yamt 		off = sizeof(u_int32_t); /* RPC record mark */
   3029      1.126      yamt 	else
   3030      1.126      yamt 		off = 0;
   3031      1.126      yamt 
   3032      1.126      yamt 	m_copyback(req->r_mreq, off, sizeof(xid), (void *)&xid);
   3033      1.126      yamt 	req->r_xid = xid;
   3034        1.1       cgd }
   3035