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