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