]>
Commit | Line | Data |
---|---|---|
1c79356b | 1 | /* |
2d21ac55 | 2 | * Copyright (c) 2000-2007 Apple Inc. All rights reserved. |
1c79356b | 3 | * |
2d21ac55 | 4 | * @APPLE_OSREFERENCE_LICENSE_HEADER_START@ |
1c79356b | 5 | * |
2d21ac55 A |
6 | * This file contains Original Code and/or Modifications of Original Code |
7 | * as defined in and that are subject to the Apple Public Source License | |
8 | * Version 2.0 (the 'License'). You may not use this file except in | |
9 | * compliance with the License. The rights granted to you under the License | |
10 | * may not be used to create, or enable the creation or redistribution of, | |
11 | * unlawful or unlicensed copies of an Apple operating system, or to | |
12 | * circumvent, violate, or enable the circumvention or violation of, any | |
13 | * terms of an Apple operating system software license agreement. | |
8f6c56a5 | 14 | * |
2d21ac55 A |
15 | * Please obtain a copy of the License at |
16 | * http://www.opensource.apple.com/apsl/ and read it before using this file. | |
17 | * | |
18 | * The Original Code and all software distributed under the License are | |
19 | * distributed on an 'AS IS' basis, WITHOUT WARRANTY OF ANY KIND, EITHER | |
8f6c56a5 A |
20 | * EXPRESS OR IMPLIED, AND APPLE HEREBY DISCLAIMS ALL SUCH WARRANTIES, |
21 | * INCLUDING WITHOUT LIMITATION, ANY WARRANTIES OF MERCHANTABILITY, | |
2d21ac55 A |
22 | * FITNESS FOR A PARTICULAR PURPOSE, QUIET ENJOYMENT OR NON-INFRINGEMENT. |
23 | * Please see the License for the specific language governing rights and | |
24 | * limitations under the License. | |
8f6c56a5 | 25 | * |
2d21ac55 | 26 | * @APPLE_OSREFERENCE_LICENSE_HEADER_END@ |
1c79356b A |
27 | */ |
28 | /* Copyright (c) 1995 NeXT Computer, Inc. All Rights Reserved */ | |
29 | /* | |
30 | * Copyright (c) 1989, 1993, 1995 | |
31 | * The Regents of the University of California. All rights reserved. | |
32 | * | |
33 | * This code is derived from software contributed to Berkeley by | |
34 | * Poul-Henning Kamp of the FreeBSD Project. | |
35 | * | |
36 | * Redistribution and use in source and binary forms, with or without | |
37 | * modification, are permitted provided that the following conditions | |
38 | * are met: | |
39 | * 1. Redistributions of source code must retain the above copyright | |
40 | * notice, this list of conditions and the following disclaimer. | |
41 | * 2. Redistributions in binary form must reproduce the above copyright | |
42 | * notice, this list of conditions and the following disclaimer in the | |
43 | * documentation and/or other materials provided with the distribution. | |
44 | * 3. All advertising materials mentioning features or use of this software | |
45 | * must display the following acknowledgement: | |
46 | * This product includes software developed by the University of | |
47 | * California, Berkeley and its contributors. | |
48 | * 4. Neither the name of the University nor the names of its contributors | |
49 | * may be used to endorse or promote products derived from this software | |
50 | * without specific prior written permission. | |
51 | * | |
52 | * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND | |
53 | * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE | |
54 | * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE | |
55 | * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE | |
56 | * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL | |
57 | * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS | |
58 | * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) | |
59 | * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT | |
60 | * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY | |
61 | * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF | |
62 | * SUCH DAMAGE. | |
63 | * | |
64 | * | |
65 | * @(#)vfs_cache.c 8.5 (Berkeley) 3/22/95 | |
66 | */ | |
2d21ac55 A |
67 | /* |
68 | * NOTICE: This file was modified by SPARTA, Inc. in 2005 to introduce | |
69 | * support for mandatory and extensible security protections. This notice | |
70 | * is included in support of clause 2.2 (b) of the Apple Public License, | |
71 | * Version 2.0. | |
72 | */ | |
1c79356b A |
73 | #include <sys/param.h> |
74 | #include <sys/systm.h> | |
75 | #include <sys/time.h> | |
91447636 A |
76 | #include <sys/mount_internal.h> |
77 | #include <sys/vnode_internal.h> | |
1c79356b A |
78 | #include <sys/namei.h> |
79 | #include <sys/errno.h> | |
80 | #include <sys/malloc.h> | |
91447636 A |
81 | #include <sys/kauth.h> |
82 | #include <sys/user.h> | |
2d21ac55 A |
83 | #include <sys/paths.h> |
84 | ||
85 | #if CONFIG_MACF | |
86 | #include <security/mac_framework.h> | |
87 | #endif | |
1c79356b A |
88 | |
89 | /* | |
90 | * Name caching works as follows: | |
91 | * | |
92 | * Names found by directory scans are retained in a cache | |
93 | * for future reference. It is managed LRU, so frequently | |
94 | * used names will hang around. Cache is indexed by hash value | |
95 | * obtained from (vp, name) where vp refers to the directory | |
96 | * containing name. | |
97 | * | |
98 | * If it is a "negative" entry, (i.e. for a name that is known NOT to | |
99 | * exist) the vnode pointer will be NULL. | |
100 | * | |
1c79356b A |
101 | * Upon reaching the last segment of a path, if the reference |
102 | * is for DELETE, or NOCACHE is set (rewrite), and the | |
103 | * name is located in the cache, it will be dropped. | |
104 | */ | |
105 | ||
106 | /* | |
107 | * Structures associated with name cacheing. | |
108 | */ | |
91447636 | 109 | |
1c79356b | 110 | LIST_HEAD(nchashhead, namecache) *nchashtbl; /* Hash Table */ |
91447636 | 111 | u_long nchashmask; |
1c79356b A |
112 | u_long nchash; /* size of hash table - 1 */ |
113 | long numcache; /* number of cache entries allocated */ | |
91447636 A |
114 | int desiredNodes; |
115 | int desiredNegNodes; | |
0c530ab8 | 116 | int ncs_negtotal; |
91447636 A |
117 | TAILQ_HEAD(, namecache) nchead; /* chain of all name cache entries */ |
118 | TAILQ_HEAD(, namecache) neghead; /* chain of only negative cache entries */ | |
0c530ab8 A |
119 | |
120 | ||
121 | #if COLLECT_STATS | |
122 | ||
1c79356b | 123 | struct nchstats nchstats; /* cache effectiveness statistics */ |
91447636 | 124 | |
0c530ab8 A |
125 | #define NCHSTAT(v) { \ |
126 | nchstats.v++; \ | |
127 | } | |
128 | #define NAME_CACHE_LOCK() name_cache_lock() | |
129 | #define NAME_CACHE_UNLOCK() name_cache_unlock() | |
130 | #define NAME_CACHE_LOCK_SHARED() name_cache_lock() | |
131 | ||
132 | #else | |
133 | ||
134 | #define NCHSTAT(v) | |
135 | #define NAME_CACHE_LOCK() name_cache_lock() | |
136 | #define NAME_CACHE_UNLOCK() name_cache_unlock() | |
137 | #define NAME_CACHE_LOCK_SHARED() name_cache_lock_shared() | |
138 | ||
139 | #endif | |
140 | ||
141 | ||
91447636 A |
142 | /* vars for name cache list lock */ |
143 | lck_grp_t * namecache_lck_grp; | |
144 | lck_grp_attr_t * namecache_lck_grp_attr; | |
145 | lck_attr_t * namecache_lck_attr; | |
0c530ab8 | 146 | lck_rw_t * namecache_rw_lock; |
91447636 A |
147 | |
148 | static vnode_t cache_lookup_locked(vnode_t dvp, struct componentname *cnp); | |
149 | static int remove_name_locked(const char *); | |
2d21ac55 A |
150 | static const char *add_name_locked(const char *, size_t, u_int, u_int); |
151 | static void init_string_table(void) __attribute__((section("__TEXT, initcode"))); | |
91447636 | 152 | static void cache_delete(struct namecache *, int); |
2d21ac55 A |
153 | static void cache_enter_locked(vnode_t dvp, vnode_t vp, struct componentname *cnp); |
154 | ||
155 | #ifdef DUMP_STRING_TABLE | |
156 | /* | |
157 | * Internal dump function used for debugging | |
158 | */ | |
159 | void dump_string_table(void); | |
160 | #endif /* DUMP_STRING_TABLE */ | |
91447636 | 161 | |
2d21ac55 | 162 | static void init_crc32(void) __attribute__((section("__TEXT, initcode"))); |
91447636 A |
163 | static unsigned int crc32tab[256]; |
164 | ||
165 | ||
166 | #define NCHHASH(dvp, hash_val) \ | |
167 | (&nchashtbl[(dvp->v_id ^ (hash_val)) & nchashmask]) | |
168 | ||
169 | ||
170 | ||
171 | // | |
172 | // This function builds the path to a filename in "buff". The | |
173 | // length of the buffer *INCLUDING* the trailing zero byte is | |
174 | // returned in outlen. NOTE: the length includes the trailing | |
175 | // zero byte and thus the length is one greater than what strlen | |
176 | // would return. This is important and lots of code elsewhere | |
177 | // in the kernel assumes this behavior. | |
2d21ac55 A |
178 | // |
179 | // This function can call vnop in file system if the parent vnode | |
180 | // does not exist or when called for hardlinks via volfs path. | |
181 | // If BUILDPATH_NO_FS_ENTER is set in flags, it only uses values present | |
182 | // in the name cache and does not enter the file system. | |
91447636 A |
183 | // |
184 | int | |
2d21ac55 | 185 | build_path(vnode_t first_vp, char *buff, int buflen, int *outlen, int flags, vfs_context_t ctx) |
91447636 | 186 | { |
2d21ac55 A |
187 | vnode_t vp; |
188 | vnode_t proc_root_dir_vp; | |
189 | char *end; | |
190 | const char *str; | |
191 | int len; | |
192 | int ret = 0; | |
193 | int fixhardlink; | |
194 | ||
195 | if (first_vp == NULLVP) { | |
196 | return (EINVAL); | |
197 | } | |
198 | /* Grab the process fd so we can evaluate fd_rdir. */ | |
199 | if (vfs_context_proc(ctx)->p_fd) { | |
200 | proc_root_dir_vp = vfs_context_proc(ctx)->p_fd->fd_rdir; | |
201 | } else { | |
202 | proc_root_dir_vp = NULL; | |
203 | } | |
204 | again: | |
205 | vp = first_vp; | |
91447636 A |
206 | end = &buff[buflen-1]; |
207 | *end = '\0'; | |
208 | ||
2d21ac55 A |
209 | /* Check if this is the root of a file system. */ |
210 | while (vp && vp->v_flag & VROOT) { | |
211 | if (vp->v_mount == NULL) { | |
212 | return (EINVAL); | |
213 | } | |
214 | if ((vp->v_mount->mnt_flag & MNT_ROOTFS) || (vp == proc_root_dir_vp)) { | |
215 | /* | |
216 | * It's the root of the root file system, so it's | |
217 | * just "/". | |
218 | */ | |
91447636 A |
219 | *--end = '/'; |
220 | goto out; | |
221 | } else { | |
91447636 A |
222 | vp = vp->v_mount->mnt_vnodecovered; |
223 | } | |
224 | } | |
0c530ab8 | 225 | NAME_CACHE_LOCK_SHARED(); |
91447636 | 226 | |
2d21ac55 | 227 | while ((vp != NULLVP) && (vp->v_parent != vp)) { |
91447636 | 228 | /* |
2d21ac55 A |
229 | * For hardlinks the v_name may be stale, so if its OK |
230 | * to enter a file system, ask the file system for the | |
231 | * name and parent (below). | |
91447636 | 232 | */ |
2d21ac55 A |
233 | fixhardlink = (vp->v_flag & VISHARDLINK) && |
234 | (vp->v_mount->mnt_kern_flag & MNTK_PATH_FROM_ID) && | |
235 | !(flags & BUILDPATH_NO_FS_ENTER); | |
236 | if (!fixhardlink) { | |
237 | str = vp->v_name; | |
238 | if (str == NULL || *str == '\0') { | |
239 | if (vp->v_parent != NULL) { | |
240 | ret = EINVAL; | |
241 | } else { | |
242 | ret = ENOENT; | |
243 | } | |
244 | break; | |
245 | } | |
246 | len = strlen(str); | |
247 | /* | |
248 | * Check that there's enough space (including space for the '/') | |
249 | */ | |
250 | if ((end - buff) < (len + 1)) { | |
251 | ret = ENOSPC; | |
252 | break; | |
253 | } | |
254 | /* Copy the name backwards. */ | |
255 | str += len; | |
256 | ||
257 | for (; len > 0; len--) { | |
258 | *--end = *--str; | |
259 | } | |
260 | /* Add a path separator. */ | |
261 | *--end = '/'; | |
91447636 | 262 | } |
91447636 | 263 | |
91447636 | 264 | /* |
2d21ac55 | 265 | * Walk up the parent chain. |
91447636 | 266 | */ |
2d21ac55 A |
267 | if (((vp->v_parent != NULLVP) && !fixhardlink) || |
268 | (flags & BUILDPATH_NO_FS_ENTER)) { | |
269 | vp = vp->v_parent; | |
270 | ||
271 | // if the vnode we have in hand isn't a directory and it | |
272 | // has a v_parent, then we started with the resource fork | |
273 | // so skip up to avoid getting a duplicate copy of the | |
274 | // file name in the path. | |
275 | if (vp && !vnode_isdir(vp) && vp->v_parent) { | |
276 | vp = vp->v_parent; | |
277 | } | |
278 | } else /* No parent, go get it if supported. */ { | |
279 | struct vnode_attr va; | |
280 | vnode_t dvp; | |
281 | int vid; | |
282 | ||
283 | /* Make sure file system supports obtaining a path from id. */ | |
284 | if (!(vp->v_mount->mnt_kern_flag & MNTK_PATH_FROM_ID)) { | |
285 | ret = ENOENT; | |
286 | break; | |
287 | } | |
288 | vid = vp->v_id; | |
289 | NAME_CACHE_UNLOCK(); | |
91447636 | 290 | |
2d21ac55 A |
291 | if (vnode_getwithvid(vp, vid) != 0) { |
292 | /* vnode was recycled, so start over. */ | |
293 | goto again; | |
294 | } | |
295 | ||
296 | VATTR_INIT(&va); | |
297 | VATTR_WANTED(&va, va_parentid); | |
298 | if (fixhardlink) { | |
299 | VATTR_WANTED(&va, va_name); | |
300 | MALLOC_ZONE(va.va_name, caddr_t, MAXPATHLEN, M_NAMEI, M_WAITOK); | |
91447636 | 301 | } else { |
2d21ac55 A |
302 | va.va_name = NULL; |
303 | } | |
304 | /* Ask the file system for its parent id and for its name (optional). */ | |
305 | ret = vnode_getattr(vp, &va, ctx); | |
306 | if (fixhardlink) { | |
307 | if (vp->v_name || VATTR_IS_SUPPORTED(&va, va_name)) { | |
308 | if (ret == 0) { | |
309 | str = va.va_name; | |
310 | } else if (vp->v_name) { | |
311 | str = vp->v_name; | |
312 | ret = 0; | |
313 | } else { | |
314 | ret = ENOENT; | |
315 | goto bad_news; | |
316 | } | |
317 | ||
318 | len = strlen(str); | |
319 | ||
320 | /* Check that there's enough space. */ | |
321 | if ((end - buff) < (len + 1)) { | |
322 | ret = ENOSPC; | |
323 | } else { | |
324 | /* Copy the name backwards. */ | |
325 | str += len; | |
326 | ||
327 | for (; len > 0; len--) { | |
328 | *--end = *--str; | |
329 | } | |
330 | /* Add a path separator. */ | |
331 | *--end = '/'; | |
332 | } | |
333 | } | |
334 | bad_news: | |
335 | FREE_ZONE(va.va_name, MAXPATHLEN, M_NAMEI); | |
336 | } | |
337 | if (ret || !VATTR_IS_SUPPORTED(&va, va_parentid)) { | |
338 | vnode_put(vp); | |
339 | ret = ENOENT; | |
340 | goto out; | |
341 | } | |
342 | /* Ask the file system for the parent vnode. */ | |
343 | ret = VFS_VGET(vp->v_mount, (ino64_t)va.va_parentid, &dvp, ctx); | |
344 | if (ret) { | |
345 | vnode_put(vp); | |
346 | goto out; | |
347 | } | |
348 | if (!fixhardlink && (vp->v_parent != dvp)) { | |
349 | vnode_update_identity(vp, dvp, NULL, 0, 0, VNODE_UPDATE_PARENT); | |
350 | } | |
351 | vnode_put(vp); | |
352 | vp = dvp; | |
353 | /* | |
354 | * We are no longer under the name cache lock here. | |
355 | * So to avoid a race for vnode termination, take a | |
356 | * reference on the vnode and drop that reference | |
357 | * after reacquiring the name cache lock. We use the | |
358 | * vnode_rele_ext call with the dont_reenter flag | |
359 | * set to avoid re-entering the file system which | |
360 | * could possibly re-enter the name cache. | |
361 | */ | |
362 | if (vnode_ref(dvp) != 0) { | |
363 | dvp = NULLVP; | |
364 | } | |
365 | vnode_put(vp); | |
366 | NAME_CACHE_LOCK_SHARED(); | |
367 | ||
368 | if (dvp) { | |
369 | vnode_rele_ext(dvp, 0, 1); | |
370 | } | |
371 | ||
372 | // if the vnode we have in hand isn't a directory and it | |
373 | // has a v_parent, then we started with the resource fork | |
374 | // so skip up to avoid getting a duplicate copy of the | |
375 | // file name in the path. | |
376 | if (vp && !vnode_isdir(vp) && vp->v_parent) { | |
377 | vp = vp->v_parent; | |
91447636 | 378 | } |
91447636 A |
379 | } |
380 | /* | |
2d21ac55 A |
381 | * When a mount point is crossed switch the vp. |
382 | * Continue until we find the root or we find | |
383 | * a vnode that's not the root of a mounted | |
384 | * file system. | |
91447636 | 385 | */ |
2d21ac55 A |
386 | while (vp) { |
387 | if (vp == proc_root_dir_vp) { | |
388 | NAME_CACHE_UNLOCK(); | |
389 | goto out; /* encountered the root */ | |
390 | } | |
391 | if (!(vp->v_flag & VROOT) || !vp->v_mount) | |
392 | break; /* not the root of a mounted FS */ | |
393 | vp = vp->v_mount->mnt_vnodecovered; | |
91447636 A |
394 | } |
395 | } | |
0c530ab8 | 396 | NAME_CACHE_UNLOCK(); |
91447636 | 397 | out: |
2d21ac55 | 398 | /* Slide the name down to the beginning of the buffer. */ |
91447636 A |
399 | memmove(buff, end, &buff[buflen] - end); |
400 | ||
2d21ac55 | 401 | *outlen = &buff[buflen] - end; /* length includes the trailing zero byte */ |
91447636 | 402 | |
2d21ac55 | 403 | return (ret); |
91447636 A |
404 | } |
405 | ||
1c79356b A |
406 | |
407 | /* | |
91447636 A |
408 | * return NULLVP if vp's parent doesn't |
409 | * exist, or we can't get a valid iocount | |
410 | * else return the parent of vp | |
1c79356b | 411 | */ |
91447636 A |
412 | vnode_t |
413 | vnode_getparent(vnode_t vp) | |
414 | { | |
415 | vnode_t pvp = NULLVP; | |
416 | int pvid; | |
417 | ||
0c530ab8 | 418 | NAME_CACHE_LOCK_SHARED(); |
91447636 A |
419 | /* |
420 | * v_parent is stable behind the name_cache lock | |
421 | * however, the only thing we can really guarantee | |
422 | * is that we've grabbed a valid iocount on the | |
423 | * parent of 'vp' at the time we took the name_cache lock... | |
424 | * once we drop the lock, vp could get re-parented | |
425 | */ | |
426 | if ( (pvp = vp->v_parent) != NULLVP ) { | |
427 | pvid = pvp->v_id; | |
428 | ||
0c530ab8 | 429 | NAME_CACHE_UNLOCK(); |
91447636 A |
430 | |
431 | if (vnode_getwithvid(pvp, pvid) != 0) | |
432 | pvp = NULL; | |
433 | } else | |
0c530ab8 | 434 | NAME_CACHE_UNLOCK(); |
91447636 A |
435 | return (pvp); |
436 | } | |
437 | ||
2d21ac55 | 438 | const char * |
91447636 A |
439 | vnode_getname(vnode_t vp) |
440 | { | |
2d21ac55 | 441 | const char *name = NULL; |
91447636 | 442 | |
0c530ab8 | 443 | NAME_CACHE_LOCK(); |
91447636 A |
444 | |
445 | if (vp->v_name) | |
446 | name = add_name_locked(vp->v_name, strlen(vp->v_name), 0, 0); | |
0c530ab8 | 447 | NAME_CACHE_UNLOCK(); |
91447636 A |
448 | |
449 | return (name); | |
1c79356b | 450 | } |
91447636 A |
451 | |
452 | void | |
2d21ac55 | 453 | vnode_putname(const char *name) |
91447636 | 454 | { |
0c530ab8 | 455 | NAME_CACHE_LOCK(); |
91447636 A |
456 | |
457 | remove_name_locked(name); | |
458 | ||
0c530ab8 | 459 | NAME_CACHE_UNLOCK(); |
91447636 A |
460 | } |
461 | ||
462 | ||
463 | /* | |
464 | * if VNODE_UPDATE_PARENT, and we can take | |
465 | * a reference on dvp, then update vp with | |
466 | * it's new parent... if vp already has a parent, | |
467 | * then drop the reference vp held on it | |
468 | * | |
469 | * if VNODE_UPDATE_NAME, | |
470 | * then drop string ref on v_name if it exists, and if name is non-NULL | |
471 | * then pick up a string reference on name and record it in v_name... | |
472 | * optionally pass in the length and hashval of name if known | |
473 | * | |
474 | * if VNODE_UPDATE_CACHE, flush the name cache entries associated with vp | |
475 | */ | |
476 | void | |
2d21ac55 | 477 | vnode_update_identity(vnode_t vp, vnode_t dvp, const char *name, int name_len, int name_hashval, int flags) |
91447636 A |
478 | { |
479 | struct namecache *ncp; | |
480 | vnode_t old_parentvp = NULLVP; | |
2d21ac55 A |
481 | #if NAMEDSTREAMS |
482 | int isstream = (vp->v_flag & VISNAMEDSTREAM); | |
483 | int kusecountbumped = 0; | |
484 | #endif | |
91447636 A |
485 | |
486 | if (flags & VNODE_UPDATE_PARENT) { | |
2d21ac55 A |
487 | if (dvp && vnode_ref(dvp) != 0) { |
488 | dvp = NULLVP; | |
489 | } | |
490 | #if NAMEDSTREAMS | |
491 | /* Don't count a stream's parent ref during unmounts */ | |
492 | if (isstream && dvp && (dvp != vp) && (dvp != vp->v_parent) && (dvp->v_type == VREG)) { | |
493 | vnode_lock_spin(dvp); | |
494 | ++dvp->v_kusecount; | |
495 | kusecountbumped = 1; | |
496 | vnode_unlock(dvp); | |
497 | } | |
498 | #endif | |
499 | } else { | |
91447636 | 500 | dvp = NULLVP; |
2d21ac55 | 501 | } |
0c530ab8 | 502 | NAME_CACHE_LOCK(); |
91447636 A |
503 | |
504 | if ( (flags & VNODE_UPDATE_NAME) && (name != vp->v_name) ) { | |
505 | if (vp->v_name != NULL) { | |
506 | remove_name_locked(vp->v_name); | |
507 | vp->v_name = NULL; | |
508 | } | |
509 | if (name && *name) { | |
510 | if (name_len == 0) | |
511 | name_len = strlen(name); | |
512 | vp->v_name = add_name_locked(name, name_len, name_hashval, 0); | |
513 | } | |
514 | } | |
515 | if (flags & VNODE_UPDATE_PARENT) { | |
516 | if (dvp != vp && dvp != vp->v_parent) { | |
517 | old_parentvp = vp->v_parent; | |
518 | vp->v_parent = dvp; | |
519 | dvp = NULLVP; | |
520 | ||
521 | if (old_parentvp) | |
522 | flags |= VNODE_UPDATE_CACHE; | |
523 | } | |
524 | } | |
525 | if (flags & VNODE_UPDATE_CACHE) { | |
526 | while ( (ncp = LIST_FIRST(&vp->v_nclinks)) ) | |
527 | cache_delete(ncp, 1); | |
528 | } | |
0c530ab8 | 529 | NAME_CACHE_UNLOCK(); |
91447636 | 530 | |
2d21ac55 A |
531 | if (dvp != NULLVP) { |
532 | #if NAMEDSTREAMS | |
533 | /* Back-out the ref we took if we lost a race for vp->v_parent. */ | |
534 | if (kusecountbumped) { | |
535 | vnode_lock_spin(dvp); | |
536 | if (dvp->v_kusecount > 0) | |
537 | --dvp->v_kusecount; | |
538 | vnode_unlock(dvp); | |
539 | } | |
540 | #endif | |
91447636 | 541 | vnode_rele(dvp); |
2d21ac55 | 542 | } |
91447636 A |
543 | if (old_parentvp) { |
544 | struct uthread *ut; | |
545 | ||
2d21ac55 A |
546 | #if NAMEDSTREAMS |
547 | if (isstream) { | |
548 | vnode_lock_spin(old_parentvp); | |
549 | if ((old_parentvp->v_type != VDIR) && (old_parentvp->v_kusecount > 0)) | |
550 | --old_parentvp->v_kusecount; | |
551 | vnode_unlock(old_parentvp); | |
552 | } | |
553 | #endif | |
91447636 A |
554 | ut = get_bsdthread_info(current_thread()); |
555 | ||
556 | /* | |
557 | * indicated to vnode_rele that it shouldn't do a | |
558 | * vnode_reclaim at this time... instead it will | |
559 | * chain the vnode to the uu_vreclaims list... | |
560 | * we'll be responsible for calling vnode_reclaim | |
561 | * on each of the vnodes in this list... | |
562 | */ | |
563 | ut->uu_defer_reclaims = 1; | |
564 | ut->uu_vreclaims = NULLVP; | |
565 | ||
566 | while ( (vp = old_parentvp) != NULLVP ) { | |
567 | ||
568 | vnode_lock(vp); | |
91447636 A |
569 | vnode_rele_internal(vp, 0, 0, 1); |
570 | ||
571 | /* | |
572 | * check to see if the vnode is now in the state | |
573 | * that would have triggered a vnode_reclaim in vnode_rele | |
574 | * if it is, we save it's parent pointer and then NULL | |
575 | * out the v_parent field... we'll drop the reference | |
576 | * that was held on the next iteration of this loop... | |
577 | * this short circuits a potential deep recursion if we | |
578 | * have a long chain of parents in this state... | |
579 | * we'll sit in this loop until we run into | |
580 | * a parent in this chain that is not in this state | |
581 | * | |
582 | * make our check and the node_rele atomic | |
583 | * with respect to the current vnode we're working on | |
584 | * by holding the vnode lock | |
585 | * if vnode_rele deferred the vnode_reclaim and has put | |
586 | * this vnode on the list to be reaped by us, than | |
587 | * it has left this vnode with an iocount == 1 | |
588 | */ | |
589 | if ( (vp->v_iocount == 1) && (vp->v_usecount == 0) && | |
590 | ((vp->v_lflag & (VL_MARKTERM | VL_TERMINATE | VL_DEAD)) == VL_MARKTERM)) { | |
591 | /* | |
592 | * vnode_rele wanted to do a vnode_reclaim on this vnode | |
593 | * it should be sitting on the head of the uu_vreclaims chain | |
594 | * pull the parent pointer now so that when we do the | |
595 | * vnode_reclaim for each of the vnodes in the uu_vreclaims | |
596 | * list, we won't recurse back through here | |
2d21ac55 A |
597 | * |
598 | * need to do a convert here in case vnode_rele_internal | |
599 | * returns with the lock held in the spin mode... it | |
600 | * can drop and retake the lock under certain circumstances | |
91447636 | 601 | */ |
2d21ac55 A |
602 | vnode_lock_convert(vp); |
603 | ||
0c530ab8 | 604 | NAME_CACHE_LOCK(); |
91447636 A |
605 | old_parentvp = vp->v_parent; |
606 | vp->v_parent = NULLVP; | |
0c530ab8 | 607 | NAME_CACHE_UNLOCK(); |
91447636 A |
608 | } else { |
609 | /* | |
610 | * we're done... we ran into a vnode that isn't | |
611 | * being terminated | |
612 | */ | |
613 | old_parentvp = NULLVP; | |
614 | } | |
615 | vnode_unlock(vp); | |
616 | } | |
617 | ut->uu_defer_reclaims = 0; | |
618 | ||
619 | while ( (vp = ut->uu_vreclaims) != NULLVP) { | |
620 | ut->uu_vreclaims = vp->v_defer_reclaimlist; | |
621 | ||
622 | /* | |
623 | * vnode_put will drive the vnode_reclaim if | |
624 | * we are still the only reference on this vnode | |
625 | */ | |
626 | vnode_put(vp); | |
627 | } | |
628 | } | |
1c79356b | 629 | } |
91447636 | 630 | |
1c79356b A |
631 | |
632 | /* | |
91447636 A |
633 | * Mark a vnode as having multiple hard links. HFS makes use of this |
634 | * because it keeps track of each link separately, and wants to know | |
635 | * which link was actually used. | |
636 | * | |
637 | * This will cause the name cache to force a VNOP_LOOKUP on the vnode | |
638 | * so that HFS can post-process the lookup. Also, volfs will call | |
639 | * VNOP_GETATTR2 to determine the parent, instead of using v_parent. | |
1c79356b | 640 | */ |
2d21ac55 | 641 | void vnode_setmultipath(vnode_t vp) |
91447636 | 642 | { |
2d21ac55 | 643 | vnode_lock_spin(vp); |
91447636 A |
644 | |
645 | /* | |
646 | * In theory, we're changing the vnode's identity as far as the | |
647 | * name cache is concerned, so we ought to grab the name cache lock | |
648 | * here. However, there is already a race, and grabbing the name | |
649 | * cache lock only makes the race window slightly smaller. | |
650 | * | |
651 | * The race happens because the vnode already exists in the name | |
652 | * cache, and could be found by one thread before another thread | |
653 | * can set the hard link flag. | |
654 | */ | |
655 | ||
656 | vp->v_flag |= VISHARDLINK; | |
657 | ||
658 | vnode_unlock(vp); | |
659 | } | |
660 | ||
661 | ||
2d21ac55 A |
662 | |
663 | /* | |
664 | * backwards compatibility | |
665 | */ | |
91447636 A |
666 | void vnode_uncache_credentials(vnode_t vp) |
667 | { | |
2d21ac55 | 668 | vnode_uncache_authorized_action(vp, KAUTH_INVALIDATE_CACHED_RIGHTS); |
91447636 A |
669 | } |
670 | ||
671 | ||
2d21ac55 A |
672 | /* |
673 | * use the exclusive form of NAME_CACHE_LOCK to protect the update of the | |
674 | * following fields in the vnode: v_cred_timestamp, v_cred, v_authorized_actions | |
675 | * we use this lock so that we can look at the v_cred and v_authorized_actions | |
676 | * atomically while behind the NAME_CACHE_LOCK in shared mode in 'cache_lookup_path', | |
677 | * which is the super-hot path... if we are updating the authorized actions for this | |
678 | * vnode, we are already in the super-slow and far less frequented path so its not | |
679 | * that bad that we take the lock exclusive for this case... of course we strive | |
680 | * to hold it for the minimum amount of time possible | |
681 | */ | |
91447636 | 682 | |
2d21ac55 A |
683 | void vnode_uncache_authorized_action(vnode_t vp, kauth_action_t action) |
684 | { | |
685 | kauth_cred_t tcred = NOCRED; | |
91447636 | 686 | |
2d21ac55 | 687 | NAME_CACHE_LOCK(); |
91447636 | 688 | |
2d21ac55 | 689 | vp->v_authorized_actions &= ~action; |
91447636 | 690 | |
2d21ac55 A |
691 | if (action == KAUTH_INVALIDATE_CACHED_RIGHTS && |
692 | IS_VALID_CRED(vp->v_cred)) { | |
693 | /* | |
694 | * Use a temp variable to avoid kauth_cred_unref() while NAME_CACHE_LOCK is held | |
695 | */ | |
696 | tcred = vp->v_cred; | |
697 | vp->v_cred = NOCRED; | |
91447636 | 698 | } |
2d21ac55 | 699 | NAME_CACHE_UNLOCK(); |
0c530ab8 | 700 | |
2d21ac55 | 701 | if (tcred != NOCRED) |
0c530ab8 | 702 | kauth_cred_unref(&tcred); |
91447636 A |
703 | } |
704 | ||
2d21ac55 A |
705 | |
706 | boolean_t vnode_cache_is_authorized(vnode_t vp, vfs_context_t ctx, kauth_action_t action) | |
91447636 | 707 | { |
91447636 | 708 | kauth_cred_t ucred; |
2d21ac55 | 709 | boolean_t retval = FALSE; |
91447636 | 710 | |
2d21ac55 A |
711 | if ( (vp->v_mount->mnt_kern_flag & (MNTK_AUTH_OPAQUE | MNTK_AUTH_CACHE_TTL)) ) { |
712 | /* | |
713 | * a TTL is enabled on the rights cache... handle it here | |
714 | * a TTL of 0 indicates that no rights should be cached | |
715 | */ | |
716 | if (vp->v_mount->mnt_authcache_ttl) { | |
717 | if ( !(vp->v_mount->mnt_kern_flag & MNTK_AUTH_CACHE_TTL) ) { | |
718 | /* | |
719 | * For filesystems marked only MNTK_AUTH_OPAQUE (generally network ones), | |
720 | * we will only allow a SEARCH right on a directory to be cached... | |
721 | * that cached right always has a default TTL associated with it | |
722 | */ | |
723 | if (action != KAUTH_VNODE_SEARCH || vp->v_type != VDIR) | |
724 | vp = NULLVP; | |
725 | } | |
726 | if (vp != NULLVP && vnode_cache_is_stale(vp) == TRUE) { | |
727 | vnode_uncache_authorized_action(vp, vp->v_authorized_actions); | |
728 | vp = NULLVP; | |
729 | } | |
730 | } else | |
731 | vp = NULLVP; | |
732 | } | |
733 | if (vp != NULLVP) { | |
734 | ucred = vfs_context_ucred(ctx); | |
91447636 | 735 | |
2d21ac55 | 736 | NAME_CACHE_LOCK_SHARED(); |
91447636 | 737 | |
2d21ac55 A |
738 | if (vp->v_cred == ucred && (vp->v_authorized_actions & action) == action) |
739 | retval = TRUE; | |
740 | ||
741 | NAME_CACHE_UNLOCK(); | |
91447636 | 742 | } |
2d21ac55 A |
743 | return retval; |
744 | } | |
91447636 | 745 | |
2d21ac55 A |
746 | |
747 | void vnode_cache_authorized_action(vnode_t vp, vfs_context_t ctx, kauth_action_t action) | |
748 | { | |
749 | kauth_cred_t tcred = NOCRED; | |
750 | kauth_cred_t ucred; | |
751 | struct timeval tv; | |
752 | boolean_t ttl_active = FALSE; | |
753 | ||
754 | ucred = vfs_context_ucred(ctx); | |
755 | ||
756 | if (!IS_VALID_CRED(ucred) || action == 0) | |
757 | return; | |
758 | ||
759 | if ( (vp->v_mount->mnt_kern_flag & (MNTK_AUTH_OPAQUE | MNTK_AUTH_CACHE_TTL)) ) { | |
760 | /* | |
761 | * a TTL is enabled on the rights cache... handle it here | |
762 | * a TTL of 0 indicates that no rights should be cached | |
91447636 | 763 | */ |
2d21ac55 A |
764 | if (vp->v_mount->mnt_authcache_ttl == 0) |
765 | return; | |
91447636 | 766 | |
2d21ac55 A |
767 | if ( !(vp->v_mount->mnt_kern_flag & MNTK_AUTH_CACHE_TTL) ) { |
768 | /* | |
769 | * only cache SEARCH action for filesystems marked | |
770 | * MNTK_AUTH_OPAQUE on VDIRs... | |
771 | * the lookup_path code will time these out | |
772 | */ | |
773 | if ( (action & ~KAUTH_VNODE_SEARCH) || vp->v_type != VDIR ) | |
774 | return; | |
91447636 | 775 | } |
2d21ac55 | 776 | ttl_active = TRUE; |
91447636 | 777 | |
2d21ac55 A |
778 | microuptime(&tv); |
779 | } | |
780 | NAME_CACHE_LOCK(); | |
91447636 | 781 | |
2d21ac55 A |
782 | if (vp->v_cred != ucred) { |
783 | kauth_cred_ref(ucred); | |
784 | /* | |
785 | * Use a temp variable to avoid kauth_cred_unref() while NAME_CACHE_LOCK is held | |
786 | */ | |
787 | tcred = vp->v_cred; | |
788 | vp->v_cred = ucred; | |
789 | vp->v_authorized_actions = 0; | |
790 | } | |
791 | if (ttl_active == TRUE && vp->v_authorized_actions == 0) { | |
792 | /* | |
793 | * only reset the timestamnp on the | |
794 | * first authorization cached after the previous | |
795 | * timer has expired or we're switching creds... | |
796 | * 'vnode_cache_is_authorized' will clear the | |
797 | * authorized actions if the TTL is active and | |
798 | * it has expired | |
799 | */ | |
800 | vp->v_cred_timestamp = tv.tv_sec; | |
801 | } | |
802 | vp->v_authorized_actions |= action; | |
91447636 | 803 | |
0c530ab8 | 804 | NAME_CACHE_UNLOCK(); |
91447636 | 805 | |
2d21ac55 A |
806 | if (IS_VALID_CRED(tcred)) |
807 | kauth_cred_unref(&tcred); | |
91447636 A |
808 | } |
809 | ||
2d21ac55 A |
810 | |
811 | boolean_t vnode_cache_is_stale(vnode_t vp) | |
812 | { | |
813 | struct timeval tv; | |
814 | boolean_t retval; | |
815 | ||
816 | microuptime(&tv); | |
817 | ||
818 | if ((tv.tv_sec - vp->v_cred_timestamp) > vp->v_mount->mnt_authcache_ttl) | |
819 | retval = TRUE; | |
820 | else | |
821 | retval = FALSE; | |
822 | ||
823 | return retval; | |
824 | } | |
825 | ||
826 | ||
827 | ||
828 | /* | |
829 | * Returns: 0 Success | |
830 | * ENOENT No such file or directory | |
831 | */ | |
91447636 | 832 | int |
2d21ac55 | 833 | cache_lookup_path(struct nameidata *ndp, struct componentname *cnp, vnode_t dp, vfs_context_t ctx, int *trailing_slash, int *dp_authorized) |
91447636 A |
834 | { |
835 | char *cp; /* pointer into pathname argument */ | |
2d21ac55 A |
836 | int vid; |
837 | int vvid = 0; /* protected by vp != NULLVP */ | |
91447636 A |
838 | vnode_t vp = NULLVP; |
839 | vnode_t tdp = NULLVP; | |
840 | kauth_cred_t ucred; | |
2d21ac55 A |
841 | boolean_t ttl_enabled = FALSE; |
842 | struct timeval tv; | |
843 | mount_t mp; | |
91447636 | 844 | unsigned int hash; |
2d21ac55 A |
845 | #if CONFIG_MACF |
846 | int error; | |
847 | #endif | |
91447636 | 848 | |
2d21ac55 | 849 | ucred = vfs_context_ucred(ctx); |
91447636 A |
850 | *trailing_slash = 0; |
851 | ||
0c530ab8 | 852 | NAME_CACHE_LOCK_SHARED(); |
91447636 | 853 | |
2d21ac55 A |
854 | if ( dp->v_mount && (dp->v_mount->mnt_kern_flag & (MNTK_AUTH_OPAQUE | MNTK_AUTH_CACHE_TTL)) ) { |
855 | ttl_enabled = TRUE; | |
91447636 A |
856 | microuptime(&tv); |
857 | } | |
858 | for (;;) { | |
859 | /* | |
860 | * Search a directory. | |
861 | * | |
862 | * The cn_hash value is for use by cache_lookup | |
863 | * The last component of the filename is left accessible via | |
864 | * cnp->cn_nameptr for callers that need the name. | |
865 | */ | |
866 | hash = 0; | |
867 | cp = cnp->cn_nameptr; | |
868 | ||
869 | while (*cp && (*cp != '/')) { | |
870 | hash ^= crc32tab[((hash >> 24) ^ (unsigned char)*cp++)]; | |
871 | } | |
872 | /* | |
873 | * the crc generator can legitimately generate | |
874 | * a 0... however, 0 for us means that we | |
875 | * haven't computed a hash, so use 1 instead | |
876 | */ | |
877 | if (hash == 0) | |
878 | hash = 1; | |
879 | cnp->cn_hash = hash; | |
880 | cnp->cn_namelen = cp - cnp->cn_nameptr; | |
881 | ||
882 | ndp->ni_pathlen -= cnp->cn_namelen; | |
883 | ndp->ni_next = cp; | |
884 | ||
885 | /* | |
886 | * Replace multiple slashes by a single slash and trailing slashes | |
887 | * by a null. This must be done before VNOP_LOOKUP() because some | |
888 | * fs's don't know about trailing slashes. Remember if there were | |
889 | * trailing slashes to handle symlinks, existing non-directories | |
890 | * and non-existing files that won't be directories specially later. | |
891 | */ | |
892 | while (*cp == '/' && (cp[1] == '/' || cp[1] == '\0')) { | |
893 | cp++; | |
894 | ndp->ni_pathlen--; | |
895 | ||
896 | if (*cp == '\0') { | |
897 | *trailing_slash = 1; | |
898 | *ndp->ni_next = '\0'; | |
899 | } | |
900 | } | |
901 | ndp->ni_next = cp; | |
902 | ||
903 | cnp->cn_flags &= ~(MAKEENTRY | ISLASTCN | ISDOTDOT); | |
904 | ||
905 | if (*cp == '\0') | |
906 | cnp->cn_flags |= ISLASTCN; | |
907 | ||
908 | if (cnp->cn_namelen == 2 && cnp->cn_nameptr[1] == '.' && cnp->cn_nameptr[0] == '.') | |
909 | cnp->cn_flags |= ISDOTDOT; | |
910 | ||
911 | *dp_authorized = 0; | |
2d21ac55 A |
912 | #if NAMEDRSRCFORK |
913 | /* | |
914 | * Process a request for a file's resource fork. | |
915 | * | |
916 | * Consume the _PATH_RSRCFORKSPEC suffix and tag the path. | |
917 | */ | |
918 | if ((ndp->ni_pathlen == sizeof(_PATH_RSRCFORKSPEC)) && | |
919 | (cp[1] == '.' && cp[2] == '.') && | |
920 | bcmp(cp, _PATH_RSRCFORKSPEC, sizeof(_PATH_RSRCFORKSPEC)) == 0) { | |
921 | /* Skip volfs file systems that don't support native streams. */ | |
922 | if ((dp->v_mount != NULL) && | |
923 | (dp->v_mount->mnt_flag & MNT_DOVOLFS) && | |
924 | (dp->v_mount->mnt_kern_flag & MNTK_NAMED_STREAMS) == 0) { | |
925 | goto skiprsrcfork; | |
926 | } | |
927 | cnp->cn_flags |= CN_WANTSRSRCFORK; | |
928 | cnp->cn_flags |= ISLASTCN; | |
929 | ndp->ni_next[0] = '\0'; | |
930 | ndp->ni_pathlen = 1; | |
931 | } | |
932 | skiprsrcfork: | |
933 | #endif | |
91447636 | 934 | |
2d21ac55 A |
935 | #if CONFIG_MACF |
936 | ||
937 | /* | |
938 | * Name cache provides authorization caching (see below) | |
939 | * that will short circuit MAC checks in lookup(). | |
940 | * We must perform MAC check here. On denial | |
941 | * dp_authorized will remain 0 and second check will | |
942 | * be perfomed in lookup(). | |
943 | */ | |
944 | if (!(cnp->cn_flags & DONOTAUTH)) { | |
945 | error = mac_vnode_check_lookup(ctx, dp, cnp); | |
946 | if (error) { | |
947 | name_cache_unlock(); | |
948 | return (error); | |
949 | } | |
950 | } | |
951 | #endif /* MAC */ | |
952 | if (ttl_enabled && ((tv.tv_sec - dp->v_cred_timestamp) > dp->v_mount->mnt_authcache_ttl)) | |
91447636 A |
953 | break; |
954 | ||
2d21ac55 A |
955 | /* |
956 | * NAME_CACHE_LOCK holds these fields stable | |
957 | */ | |
958 | if ((dp->v_cred != ucred || !(dp->v_authorized_actions & KAUTH_VNODE_SEARCH)) && | |
959 | !(dp->v_authorized_actions & KAUTH_VNODE_SEARCHBYANYONE)) | |
91447636 | 960 | break; |
2d21ac55 | 961 | |
91447636 A |
962 | /* |
963 | * indicate that we're allowed to traverse this directory... | |
964 | * even if we fail the cache lookup or decide to bail for | |
965 | * some other reason, this information is valid and is used | |
966 | * to avoid doing a vnode_authorize before the call to VNOP_LOOKUP | |
967 | */ | |
968 | *dp_authorized = 1; | |
969 | ||
970 | if ( (cnp->cn_flags & (ISLASTCN | ISDOTDOT)) ) { | |
971 | if (cnp->cn_nameiop != LOOKUP) | |
972 | break; | |
743b1565 | 973 | if (cnp->cn_flags & (LOCKPARENT | NOCACHE)) |
91447636 | 974 | break; |
743b1565 | 975 | if (cnp->cn_flags & ISDOTDOT) { |
2d21ac55 A |
976 | /* |
977 | * Force directory hardlinks to go to | |
978 | * file system for ".." requests. | |
979 | */ | |
980 | if (dp && (dp->v_flag & VISHARDLINK)) { | |
981 | break; | |
982 | } | |
743b1565 A |
983 | /* |
984 | * Quit here only if we can't use | |
985 | * the parent directory pointer or | |
986 | * don't have one. Otherwise, we'll | |
987 | * use it below. | |
988 | */ | |
6601e61a A |
989 | if ((dp->v_flag & VROOT) || |
990 | dp == ndp->ni_rootdir || | |
743b1565 A |
991 | dp->v_parent == NULLVP) |
992 | break; | |
993 | } | |
994 | } | |
995 | ||
996 | /* | |
997 | * "." and ".." aren't supposed to be cached, so check | |
998 | * for them before checking the cache. | |
999 | */ | |
1000 | if (cnp->cn_namelen == 1 && cnp->cn_nameptr[0] == '.') | |
1001 | vp = dp; | |
2d21ac55 | 1002 | else if ((cnp->cn_flags & ISDOTDOT) && dp->v_parent) |
743b1565 A |
1003 | vp = dp->v_parent; |
1004 | else { | |
1005 | if ( (vp = cache_lookup_locked(dp, cnp)) == NULLVP) | |
1006 | break; | |
91447636 | 1007 | } |
91447636 A |
1008 | |
1009 | if ( (cnp->cn_flags & ISLASTCN) ) | |
1010 | break; | |
1011 | ||
1012 | if (vp->v_type != VDIR) { | |
1013 | if (vp->v_type != VLNK) | |
1014 | vp = NULL; | |
1015 | break; | |
1016 | } | |
2d21ac55 | 1017 | if ( (mp = vp->v_mountedhere) && ((cnp->cn_flags & NOCROSSMOUNT) == 0)) { |
91447636 | 1018 | |
2d21ac55 A |
1019 | if (mp->mnt_realrootvp == NULLVP || mp->mnt_generation != mount_generation || |
1020 | mp->mnt_realrootvp_vid != mp->mnt_realrootvp->v_id) | |
1021 | break; | |
1022 | vp = mp->mnt_realrootvp; | |
1023 | } | |
91447636 A |
1024 | dp = vp; |
1025 | vp = NULLVP; | |
1026 | ||
1027 | cnp->cn_nameptr = ndp->ni_next + 1; | |
1028 | ndp->ni_pathlen--; | |
1029 | while (*cnp->cn_nameptr == '/') { | |
1030 | cnp->cn_nameptr++; | |
1031 | ndp->ni_pathlen--; | |
1032 | } | |
1033 | } | |
1034 | if (vp != NULLVP) | |
1035 | vvid = vp->v_id; | |
1036 | vid = dp->v_id; | |
1037 | ||
0c530ab8 | 1038 | NAME_CACHE_UNLOCK(); |
91447636 | 1039 | |
91447636 A |
1040 | if ((vp != NULLVP) && (vp->v_type != VLNK) && |
1041 | ((cnp->cn_flags & (ISLASTCN | LOCKPARENT | WANTPARENT | SAVESTART)) == ISLASTCN)) { | |
1042 | /* | |
1043 | * if we've got a child and it's the last component, and | |
1044 | * the lookup doesn't need to return the parent then we | |
1045 | * can skip grabbing an iocount on the parent, since all | |
1046 | * we're going to do with it is a vnode_put just before | |
1047 | * we return from 'lookup'. If it's a symbolic link, | |
1048 | * we need the parent in case the link happens to be | |
1049 | * a relative pathname. | |
1050 | */ | |
1051 | tdp = dp; | |
1052 | dp = NULLVP; | |
1053 | } else { | |
1054 | need_dp: | |
1055 | /* | |
1056 | * return the last directory we looked at | |
1057 | * with an io reference held | |
1058 | */ | |
1059 | if (dp == ndp->ni_usedvp) { | |
1060 | /* | |
1061 | * if this vnode matches the one passed in via USEDVP | |
1062 | * than this context already holds an io_count... just | |
1063 | * use vnode_get to get an extra ref for lookup to play | |
1064 | * with... can't use the getwithvid variant here because | |
1065 | * it will block behind a vnode_drain which would result | |
1066 | * in a deadlock (since we already own an io_count that the | |
1067 | * vnode_drain is waiting on)... vnode_get grabs the io_count | |
1068 | * immediately w/o waiting... it always succeeds | |
1069 | */ | |
1070 | vnode_get(dp); | |
1071 | } else if ( (vnode_getwithvid(dp, vid)) ) { | |
1072 | /* | |
1073 | * failure indicates the vnode | |
1074 | * changed identity or is being | |
1075 | * TERMINATED... in either case | |
2d21ac55 A |
1076 | * punt this lookup. |
1077 | * | |
1078 | * don't necessarily return ENOENT, though, because | |
1079 | * we really want to go back to disk and make sure it's | |
1080 | * there or not if someone else is changing this | |
1081 | * vnode. | |
91447636 | 1082 | */ |
2d21ac55 | 1083 | return (ERESTART); |
91447636 A |
1084 | } |
1085 | } | |
1086 | if (vp != NULLVP) { | |
1087 | if ( (vnode_getwithvid(vp, vvid)) ) { | |
1088 | vp = NULLVP; | |
1089 | ||
1090 | /* | |
1091 | * can't get reference on the vp we'd like | |
1092 | * to return... if we didn't grab a reference | |
1093 | * on the directory (due to fast path bypass), | |
1094 | * then we need to do it now... we can't return | |
1095 | * with both ni_dvp and ni_vp NULL, and no | |
1096 | * error condition | |
1097 | */ | |
1098 | if (dp == NULLVP) { | |
1099 | dp = tdp; | |
1100 | goto need_dp; | |
1101 | } | |
1102 | } | |
1103 | } | |
1104 | ndp->ni_dvp = dp; | |
1105 | ndp->ni_vp = vp; | |
1106 | ||
1107 | return (0); | |
1108 | } | |
1109 | ||
1110 | ||
1111 | static vnode_t | |
1112 | cache_lookup_locked(vnode_t dvp, struct componentname *cnp) | |
1113 | { | |
2d21ac55 A |
1114 | struct namecache *ncp; |
1115 | struct nchashhead *ncpp; | |
1116 | long namelen = cnp->cn_namelen; | |
91447636 A |
1117 | char *nameptr = cnp->cn_nameptr; |
1118 | unsigned int hashval = (cnp->cn_hash & NCHASHMASK); | |
1119 | vnode_t vp; | |
1120 | ||
1121 | ncpp = NCHHASH(dvp, cnp->cn_hash); | |
1122 | LIST_FOREACH(ncp, ncpp, nc_hash) { | |
1123 | if ((ncp->nc_dvp == dvp) && (ncp->nc_hashval == hashval)) { | |
1124 | if (memcmp(ncp->nc_name, nameptr, namelen) == 0 && ncp->nc_name[namelen] == 0) | |
1125 | break; | |
1126 | } | |
1127 | } | |
0c530ab8 | 1128 | if (ncp == 0) { |
91447636 A |
1129 | /* |
1130 | * We failed to find an entry | |
1131 | */ | |
0c530ab8 | 1132 | NCHSTAT(ncs_miss); |
91447636 | 1133 | return (NULL); |
0c530ab8 A |
1134 | } |
1135 | NCHSTAT(ncs_goodhits); | |
91447636 A |
1136 | |
1137 | vp = ncp->nc_vp; | |
1138 | if (vp && (vp->v_flag & VISHARDLINK)) { | |
1139 | /* | |
1140 | * The file system wants a VNOP_LOOKUP on this vnode | |
1141 | */ | |
1142 | vp = NULL; | |
1143 | } | |
1144 | ||
1145 | return (vp); | |
1c79356b A |
1146 | } |
1147 | ||
55e303ae A |
1148 | |
1149 | // | |
1150 | // Have to take a len argument because we may only need to | |
1151 | // hash part of a componentname. | |
1152 | // | |
1153 | static unsigned int | |
91447636 | 1154 | hash_string(const char *cp, int len) |
55e303ae | 1155 | { |
91447636 | 1156 | unsigned hash = 0; |
55e303ae | 1157 | |
91447636 A |
1158 | if (len) { |
1159 | while (len--) { | |
1160 | hash ^= crc32tab[((hash >> 24) ^ (unsigned char)*cp++)]; | |
1161 | } | |
55e303ae | 1162 | } else { |
91447636 A |
1163 | while (*cp != '\0') { |
1164 | hash ^= crc32tab[((hash >> 24) ^ (unsigned char)*cp++)]; | |
1165 | } | |
55e303ae | 1166 | } |
91447636 A |
1167 | /* |
1168 | * the crc generator can legitimately generate | |
1169 | * a 0... however, 0 for us means that we | |
1170 | * haven't computed a hash, so use 1 instead | |
1171 | */ | |
1172 | if (hash == 0) | |
1173 | hash = 1; | |
1174 | return hash; | |
55e303ae A |
1175 | } |
1176 | ||
1177 | ||
1c79356b A |
1178 | /* |
1179 | * Lookup an entry in the cache | |
1180 | * | |
1181 | * We don't do this if the segment name is long, simply so the cache | |
1182 | * can avoid holding long names (which would either waste space, or | |
1183 | * add greatly to the complexity). | |
1184 | * | |
1185 | * Lookup is called with dvp pointing to the directory to search, | |
1186 | * cnp pointing to the name of the entry being sought. If the lookup | |
1187 | * succeeds, the vnode is returned in *vpp, and a status of -1 is | |
1188 | * returned. If the lookup determines that the name does not exist | |
1189 | * (negative cacheing), a status of ENOENT is returned. If the lookup | |
1190 | * fails, a status of zero is returned. | |
1191 | */ | |
1192 | ||
1193 | int | |
2d21ac55 | 1194 | cache_lookup(struct vnode *dvp, struct vnode **vpp, struct componentname *cnp) |
1c79356b | 1195 | { |
2d21ac55 A |
1196 | struct namecache *ncp; |
1197 | struct nchashhead *ncpp; | |
1198 | long namelen = cnp->cn_namelen; | |
55e303ae | 1199 | char *nameptr = cnp->cn_nameptr; |
91447636 | 1200 | unsigned int hashval = (cnp->cn_hash & NCHASHMASK); |
0c530ab8 | 1201 | boolean_t have_exclusive = FALSE; |
91447636 A |
1202 | uint32_t vid; |
1203 | vnode_t vp; | |
1c79356b | 1204 | |
0c530ab8 | 1205 | NAME_CACHE_LOCK_SHARED(); |
1c79356b | 1206 | |
55e303ae | 1207 | ncpp = NCHHASH(dvp, cnp->cn_hash); |
0c530ab8 | 1208 | relook: |
91447636 A |
1209 | LIST_FOREACH(ncp, ncpp, nc_hash) { |
1210 | if ((ncp->nc_dvp == dvp) && (ncp->nc_hashval == hashval)) { | |
1211 | if (memcmp(ncp->nc_name, nameptr, namelen) == 0 && ncp->nc_name[namelen] == 0) | |
1212 | break; | |
55e303ae | 1213 | } |
1c79356b | 1214 | } |
1c79356b A |
1215 | /* We failed to find an entry */ |
1216 | if (ncp == 0) { | |
0c530ab8 A |
1217 | NCHSTAT(ncs_miss); |
1218 | NAME_CACHE_UNLOCK(); | |
1c79356b A |
1219 | return (0); |
1220 | } | |
1221 | ||
1222 | /* We don't want to have an entry, so dump it */ | |
1223 | if ((cnp->cn_flags & MAKEENTRY) == 0) { | |
0c530ab8 A |
1224 | if (have_exclusive == TRUE) { |
1225 | NCHSTAT(ncs_badhits); | |
1226 | cache_delete(ncp, 1); | |
1227 | NAME_CACHE_UNLOCK(); | |
1228 | return (0); | |
1229 | } | |
1230 | NAME_CACHE_UNLOCK(); | |
1231 | NAME_CACHE_LOCK(); | |
1232 | have_exclusive = TRUE; | |
1233 | goto relook; | |
1c79356b | 1234 | } |
91447636 | 1235 | vp = ncp->nc_vp; |
1c79356b A |
1236 | |
1237 | /* We found a "positive" match, return the vnode */ | |
91447636 | 1238 | if (vp) { |
0c530ab8 | 1239 | NCHSTAT(ncs_goodhits); |
91447636 A |
1240 | |
1241 | vid = vp->v_id; | |
0c530ab8 | 1242 | NAME_CACHE_UNLOCK(); |
91447636 A |
1243 | |
1244 | if (vnode_getwithvid(vp, vid)) { | |
0c530ab8 A |
1245 | #if COLLECT_STATS |
1246 | NAME_CACHE_LOCK(); | |
1247 | NCHSTAT(ncs_badvid); | |
1248 | NAME_CACHE_UNLOCK(); | |
1249 | #endif | |
91447636 A |
1250 | return (0); |
1251 | } | |
1252 | *vpp = vp; | |
1c79356b A |
1253 | return (-1); |
1254 | } | |
1255 | ||
1256 | /* We found a negative match, and want to create it, so purge */ | |
91447636 | 1257 | if (cnp->cn_nameiop == CREATE || cnp->cn_nameiop == RENAME) { |
0c530ab8 A |
1258 | if (have_exclusive == TRUE) { |
1259 | NCHSTAT(ncs_badhits); | |
1260 | cache_delete(ncp, 1); | |
1261 | NAME_CACHE_UNLOCK(); | |
1262 | return (0); | |
1263 | } | |
1264 | NAME_CACHE_UNLOCK(); | |
1265 | NAME_CACHE_LOCK(); | |
1266 | have_exclusive = TRUE; | |
1267 | goto relook; | |
1c79356b A |
1268 | } |
1269 | ||
1270 | /* | |
1271 | * We found a "negative" match, ENOENT notifies client of this match. | |
91447636 | 1272 | * The nc_whiteout field records whether this is a whiteout. |
1c79356b | 1273 | */ |
0c530ab8 | 1274 | NCHSTAT(ncs_neghits); |
91447636 A |
1275 | |
1276 | if (ncp->nc_whiteout) | |
1277 | cnp->cn_flags |= ISWHITEOUT; | |
0c530ab8 | 1278 | NAME_CACHE_UNLOCK(); |
1c79356b A |
1279 | return (ENOENT); |
1280 | } | |
1281 | ||
2d21ac55 | 1282 | |
1c79356b | 1283 | /* |
2d21ac55 A |
1284 | * Add an entry to the cache... |
1285 | * but first check to see if the directory | |
1286 | * that this entry is to be associated with has | |
1287 | * had any cache_purges applied since we took | |
1288 | * our identity snapshot... this check needs to | |
1289 | * be done behind the name cache lock | |
1c79356b A |
1290 | */ |
1291 | void | |
2d21ac55 | 1292 | cache_enter_with_gen(struct vnode *dvp, struct vnode *vp, struct componentname *cnp, int gen) |
1c79356b | 1293 | { |
1c79356b | 1294 | |
91447636 A |
1295 | if (cnp->cn_hash == 0) |
1296 | cnp->cn_hash = hash_string(cnp->cn_nameptr, cnp->cn_namelen); | |
1297 | ||
0c530ab8 | 1298 | NAME_CACHE_LOCK(); |
1c79356b | 1299 | |
2d21ac55 A |
1300 | if (dvp->v_nc_generation == gen) |
1301 | cache_enter_locked(dvp, vp, cnp); | |
1302 | ||
1303 | NAME_CACHE_UNLOCK(); | |
1304 | } | |
1305 | ||
1306 | ||
1307 | /* | |
1308 | * Add an entry to the cache. | |
1309 | */ | |
1310 | void | |
1311 | cache_enter(struct vnode *dvp, struct vnode *vp, struct componentname *cnp) | |
1312 | { | |
1313 | if (cnp->cn_hash == 0) | |
1314 | cnp->cn_hash = hash_string(cnp->cn_nameptr, cnp->cn_namelen); | |
1315 | ||
1316 | NAME_CACHE_LOCK(); | |
1317 | ||
1318 | cache_enter_locked(dvp, vp, cnp); | |
1319 | ||
1320 | NAME_CACHE_UNLOCK(); | |
1321 | } | |
1322 | ||
1323 | ||
1324 | static void | |
1325 | cache_enter_locked(struct vnode *dvp, struct vnode *vp, struct componentname *cnp) | |
1326 | { | |
1327 | struct namecache *ncp, *negp; | |
1328 | struct nchashhead *ncpp; | |
1329 | ||
1330 | /* | |
1331 | * if the entry is for -ve caching vp is null | |
1332 | */ | |
91447636 A |
1333 | if ((vp != NULLVP) && (LIST_FIRST(&vp->v_nclinks))) { |
1334 | /* | |
1335 | * someone beat us to the punch.. | |
1336 | * this vnode is already in the cache | |
1337 | */ | |
0c530ab8 | 1338 | return; |
91447636 | 1339 | } |
1c79356b A |
1340 | /* |
1341 | * We allocate a new entry if we are less than the maximum | |
91447636 A |
1342 | * allowed and the one at the front of the list is in use. |
1343 | * Otherwise we use the one at the front of the list. | |
1c79356b | 1344 | */ |
91447636 A |
1345 | if (numcache < desiredNodes && |
1346 | ((ncp = nchead.tqh_first) == NULL || | |
1347 | ncp->nc_hash.le_prev != 0)) { | |
1348 | /* | |
1349 | * Allocate one more entry | |
1350 | */ | |
1351 | ncp = (struct namecache *)_MALLOC_ZONE((u_long)sizeof *ncp, M_CACHE, M_WAITOK); | |
1c79356b | 1352 | numcache++; |
91447636 A |
1353 | } else { |
1354 | /* | |
1355 | * reuse an old entry | |
1356 | */ | |
1357 | ncp = TAILQ_FIRST(&nchead); | |
1358 | TAILQ_REMOVE(&nchead, ncp, nc_entry); | |
1359 | ||
1c79356b | 1360 | if (ncp->nc_hash.le_prev != 0) { |
91447636 A |
1361 | /* |
1362 | * still in use... we need to | |
1363 | * delete it before re-using it | |
1364 | */ | |
0c530ab8 | 1365 | NCHSTAT(ncs_stolen); |
91447636 | 1366 | cache_delete(ncp, 0); |
1c79356b | 1367 | } |
1c79356b | 1368 | } |
0c530ab8 | 1369 | NCHSTAT(ncs_enters); |
1c79356b A |
1370 | |
1371 | /* | |
1372 | * Fill in cache info, if vp is NULL this is a "negative" cache entry. | |
1c79356b A |
1373 | */ |
1374 | ncp->nc_vp = vp; | |
1c79356b | 1375 | ncp->nc_dvp = dvp; |
91447636 A |
1376 | ncp->nc_hashval = cnp->cn_hash; |
1377 | ncp->nc_whiteout = FALSE; | |
1378 | ncp->nc_name = add_name_locked(cnp->cn_nameptr, cnp->cn_namelen, cnp->cn_hash, 0); | |
1379 | ||
1380 | /* | |
1381 | * make us the newest entry in the cache | |
1382 | * i.e. we'll be the last to be stolen | |
1383 | */ | |
1384 | TAILQ_INSERT_TAIL(&nchead, ncp, nc_entry); | |
1385 | ||
55e303ae | 1386 | ncpp = NCHHASH(dvp, cnp->cn_hash); |
1c79356b A |
1387 | #if DIAGNOSTIC |
1388 | { | |
2d21ac55 | 1389 | struct namecache *p; |
1c79356b A |
1390 | |
1391 | for (p = ncpp->lh_first; p != 0; p = p->nc_hash.le_next) | |
1392 | if (p == ncp) | |
1393 | panic("cache_enter: duplicate"); | |
1394 | } | |
1395 | #endif | |
91447636 A |
1396 | /* |
1397 | * make us available to be found via lookup | |
1398 | */ | |
1c79356b | 1399 | LIST_INSERT_HEAD(ncpp, ncp, nc_hash); |
91447636 A |
1400 | |
1401 | if (vp) { | |
1402 | /* | |
1403 | * add to the list of name cache entries | |
1404 | * that point at vp | |
1405 | */ | |
1406 | LIST_INSERT_HEAD(&vp->v_nclinks, ncp, nc_un.nc_link); | |
1407 | } else { | |
1408 | /* | |
1409 | * this is a negative cache entry (vp == NULL) | |
1410 | * stick it on the negative cache list | |
1411 | * and record the whiteout state | |
1412 | */ | |
1413 | TAILQ_INSERT_TAIL(&neghead, ncp, nc_un.nc_negentry); | |
1414 | ||
1415 | if (cnp->cn_flags & ISWHITEOUT) | |
1416 | ncp->nc_whiteout = TRUE; | |
0c530ab8 | 1417 | ncs_negtotal++; |
91447636 | 1418 | |
0c530ab8 | 1419 | if (ncs_negtotal > desiredNegNodes) { |
91447636 A |
1420 | /* |
1421 | * if we've reached our desired limit | |
1422 | * of negative cache entries, delete | |
1423 | * the oldest | |
1424 | */ | |
1425 | negp = TAILQ_FIRST(&neghead); | |
1426 | TAILQ_REMOVE(&neghead, negp, nc_un.nc_negentry); | |
1427 | ||
1428 | cache_delete(negp, 1); | |
1429 | } | |
1430 | } | |
1431 | /* | |
1432 | * add us to the list of name cache entries that | |
1433 | * are children of dvp | |
1434 | */ | |
1435 | LIST_INSERT_HEAD(&dvp->v_ncchildren, ncp, nc_child); | |
1c79356b A |
1436 | } |
1437 | ||
91447636 A |
1438 | |
1439 | /* | |
1440 | * Initialize CRC-32 remainder table. | |
1441 | */ | |
1442 | static void init_crc32(void) | |
1443 | { | |
1444 | /* | |
1445 | * the CRC-32 generator polynomial is: | |
1446 | * x^32 + x^26 + x^23 + x^22 + x^16 + x^12 + x^10 | |
1447 | * + x^8 + x^7 + x^5 + x^4 + x^2 + x + 1 | |
1448 | */ | |
1449 | unsigned int crc32_polynomial = 0x04c11db7; | |
1450 | unsigned int i,j; | |
1451 | ||
1452 | /* | |
1453 | * pre-calculate the CRC-32 remainder for each possible octet encoding | |
1454 | */ | |
1455 | for (i = 0; i < 256; i++) { | |
1456 | unsigned int crc_rem = i << 24; | |
1457 | ||
1458 | for (j = 0; j < 8; j++) { | |
1459 | if (crc_rem & 0x80000000) | |
1460 | crc_rem = (crc_rem << 1) ^ crc32_polynomial; | |
1461 | else | |
1462 | crc_rem = (crc_rem << 1); | |
1463 | } | |
1464 | crc32tab[i] = crc_rem; | |
1465 | } | |
1466 | } | |
1467 | ||
1468 | ||
1c79356b A |
1469 | /* |
1470 | * Name cache initialization, from vfs_init() when we are booting | |
1471 | */ | |
1472 | void | |
91447636 A |
1473 | nchinit(void) |
1474 | { | |
1475 | desiredNegNodes = (desiredvnodes / 10); | |
1476 | desiredNodes = desiredvnodes + desiredNegNodes; | |
1477 | ||
1478 | TAILQ_INIT(&nchead); | |
1479 | TAILQ_INIT(&neghead); | |
1480 | ||
1481 | init_crc32(); | |
1482 | ||
2d21ac55 | 1483 | nchashtbl = hashinit(MAX(CONFIG_NC_HASH, (2 *desiredNodes)), M_CACHE, &nchash); |
91447636 A |
1484 | nchashmask = nchash; |
1485 | nchash++; | |
1486 | ||
1487 | init_string_table(); | |
1488 | ||
1489 | /* Allocate mount list lock group attribute and group */ | |
1490 | namecache_lck_grp_attr= lck_grp_attr_alloc_init(); | |
91447636 A |
1491 | |
1492 | namecache_lck_grp = lck_grp_alloc_init("Name Cache", namecache_lck_grp_attr); | |
1493 | ||
1494 | /* Allocate mount list lock attribute */ | |
1495 | namecache_lck_attr = lck_attr_alloc_init(); | |
91447636 A |
1496 | |
1497 | /* Allocate mount list lock */ | |
0c530ab8 | 1498 | namecache_rw_lock = lck_rw_alloc_init(namecache_lck_grp, namecache_lck_attr); |
91447636 A |
1499 | |
1500 | ||
1501 | } | |
1502 | ||
0c530ab8 A |
1503 | void |
1504 | name_cache_lock_shared(void) | |
1505 | { | |
1506 | lck_rw_lock_shared(namecache_rw_lock); | |
1507 | } | |
1508 | ||
91447636 A |
1509 | void |
1510 | name_cache_lock(void) | |
1c79356b | 1511 | { |
0c530ab8 | 1512 | lck_rw_lock_exclusive(namecache_rw_lock); |
91447636 | 1513 | } |
55e303ae | 1514 | |
91447636 A |
1515 | void |
1516 | name_cache_unlock(void) | |
1517 | { | |
0c530ab8 | 1518 | lck_rw_done(namecache_rw_lock); |
1c79356b A |
1519 | } |
1520 | ||
55e303ae A |
1521 | |
1522 | int | |
1523 | resize_namecache(u_int newsize) | |
1524 | { | |
91447636 A |
1525 | struct nchashhead *new_table; |
1526 | struct nchashhead *old_table; | |
1527 | struct nchashhead *old_head, *head; | |
1528 | struct namecache *entry, *next; | |
1529 | uint32_t i, hashval; | |
1530 | int dNodes, dNegNodes; | |
1531 | u_long new_size, old_size; | |
1532 | ||
1533 | dNegNodes = (newsize / 10); | |
1534 | dNodes = newsize + dNegNodes; | |
55e303ae A |
1535 | |
1536 | // we don't support shrinking yet | |
91447636 | 1537 | if (dNodes < desiredNodes) { |
55e303ae A |
1538 | return 0; |
1539 | } | |
91447636 A |
1540 | new_table = hashinit(2 * dNodes, M_CACHE, &nchashmask); |
1541 | new_size = nchashmask + 1; | |
55e303ae | 1542 | |
55e303ae A |
1543 | if (new_table == NULL) { |
1544 | return ENOMEM; | |
1545 | } | |
1546 | ||
0c530ab8 | 1547 | NAME_CACHE_LOCK(); |
55e303ae A |
1548 | // do the switch! |
1549 | old_table = nchashtbl; | |
1550 | nchashtbl = new_table; | |
91447636 A |
1551 | old_size = nchash; |
1552 | nchash = new_size; | |
55e303ae A |
1553 | |
1554 | // walk the old table and insert all the entries into | |
1555 | // the new table | |
1556 | // | |
91447636 | 1557 | for(i=0; i < old_size; i++) { |
55e303ae A |
1558 | old_head = &old_table[i]; |
1559 | for (entry=old_head->lh_first; entry != NULL; entry=next) { | |
1560 | // | |
1561 | // XXXdbg - Beware: this assumes that hash_string() does | |
1562 | // the same thing as what happens in | |
1563 | // lookup() over in vfs_lookup.c | |
91447636 A |
1564 | hashval = hash_string(entry->nc_name, 0); |
1565 | entry->nc_hashval = hashval; | |
1566 | head = NCHHASH(entry->nc_dvp, hashval); | |
1567 | ||
55e303ae A |
1568 | next = entry->nc_hash.le_next; |
1569 | LIST_INSERT_HEAD(head, entry, nc_hash); | |
1570 | } | |
1571 | } | |
91447636 A |
1572 | desiredNodes = dNodes; |
1573 | desiredNegNodes = dNegNodes; | |
55e303ae | 1574 | |
0c530ab8 | 1575 | NAME_CACHE_UNLOCK(); |
55e303ae A |
1576 | FREE(old_table, M_CACHE); |
1577 | ||
1578 | return 0; | |
1579 | } | |
1580 | ||
91447636 A |
1581 | static void |
1582 | cache_delete(struct namecache *ncp, int age_entry) | |
1583 | { | |
0c530ab8 | 1584 | NCHSTAT(ncs_deletes); |
91447636 A |
1585 | |
1586 | if (ncp->nc_vp) { | |
1587 | LIST_REMOVE(ncp, nc_un.nc_link); | |
1588 | } else { | |
1589 | TAILQ_REMOVE(&neghead, ncp, nc_un.nc_negentry); | |
0c530ab8 | 1590 | ncs_negtotal--; |
91447636 A |
1591 | } |
1592 | LIST_REMOVE(ncp, nc_child); | |
1593 | ||
1594 | LIST_REMOVE(ncp, nc_hash); | |
1595 | /* | |
1596 | * this field is used to indicate | |
1597 | * that the entry is in use and | |
1598 | * must be deleted before it can | |
1599 | * be reused... | |
1600 | */ | |
1601 | ncp->nc_hash.le_prev = NULL; | |
1602 | ||
1603 | if (age_entry) { | |
1604 | /* | |
1605 | * make it the next one available | |
1606 | * for cache_enter's use | |
1607 | */ | |
1608 | TAILQ_REMOVE(&nchead, ncp, nc_entry); | |
1609 | TAILQ_INSERT_HEAD(&nchead, ncp, nc_entry); | |
1610 | } | |
1611 | remove_name_locked(ncp->nc_name); | |
1612 | ncp->nc_name = NULL; | |
1613 | } | |
1614 | ||
1615 | ||
1616 | /* | |
1617 | * purge the entry associated with the | |
1618 | * specified vnode from the name cache | |
1619 | */ | |
1620 | void | |
1621 | cache_purge(vnode_t vp) | |
1622 | { | |
1623 | struct namecache *ncp; | |
2d21ac55 | 1624 | kauth_cred_t tcred = NULL; |
91447636 A |
1625 | |
1626 | if ((LIST_FIRST(&vp->v_nclinks) == NULL) && (LIST_FIRST(&vp->v_ncchildren) == NULL)) | |
1627 | return; | |
1628 | ||
0c530ab8 | 1629 | NAME_CACHE_LOCK(); |
55e303ae | 1630 | |
2d21ac55 A |
1631 | if (vp->v_parent) |
1632 | vp->v_parent->v_nc_generation++; | |
1633 | ||
91447636 A |
1634 | while ( (ncp = LIST_FIRST(&vp->v_nclinks)) ) |
1635 | cache_delete(ncp, 1); | |
55e303ae | 1636 | |
91447636 A |
1637 | while ( (ncp = LIST_FIRST(&vp->v_ncchildren)) ) |
1638 | cache_delete(ncp, 1); | |
1639 | ||
2d21ac55 A |
1640 | /* |
1641 | * Use a temp variable to avoid kauth_cred_unref() while NAME_CACHE_LOCK is held | |
1642 | */ | |
1643 | tcred = vp->v_cred; | |
1644 | vp->v_cred = NOCRED; | |
1645 | vp->v_authorized_actions = 0; | |
1646 | ||
0c530ab8 | 1647 | NAME_CACHE_UNLOCK(); |
2d21ac55 A |
1648 | |
1649 | if (IS_VALID_CRED(tcred)) | |
1650 | kauth_cred_unref(&tcred); | |
91447636 | 1651 | } |
55e303ae | 1652 | |
1c79356b | 1653 | /* |
91447636 A |
1654 | * Purge all negative cache entries that are children of the |
1655 | * given vnode. A case-insensitive file system (or any file | |
1656 | * system that has multiple equivalent names for the same | |
1657 | * directory entry) can use this when creating or renaming | |
1658 | * to remove negative entries that may no longer apply. | |
1c79356b A |
1659 | */ |
1660 | void | |
91447636 | 1661 | cache_purge_negatives(vnode_t vp) |
1c79356b A |
1662 | { |
1663 | struct namecache *ncp; | |
1c79356b | 1664 | |
0c530ab8 | 1665 | NAME_CACHE_LOCK(); |
91447636 A |
1666 | |
1667 | LIST_FOREACH(ncp, &vp->v_ncchildren, nc_child) | |
1668 | if (ncp->nc_vp == NULL) | |
1669 | cache_delete(ncp , 1); | |
1670 | ||
0c530ab8 | 1671 | NAME_CACHE_UNLOCK(); |
1c79356b A |
1672 | } |
1673 | ||
1674 | /* | |
1675 | * Flush all entries referencing a particular filesystem. | |
1676 | * | |
1677 | * Since we need to check it anyway, we will flush all the invalid | |
91447636 | 1678 | * entries at the same time. |
1c79356b A |
1679 | */ |
1680 | void | |
2d21ac55 | 1681 | cache_purgevfs(struct mount *mp) |
1c79356b A |
1682 | { |
1683 | struct nchashhead *ncpp; | |
91447636 | 1684 | struct namecache *ncp; |
1c79356b | 1685 | |
0c530ab8 | 1686 | NAME_CACHE_LOCK(); |
1c79356b | 1687 | /* Scan hash tables for applicable entries */ |
91447636 A |
1688 | for (ncpp = &nchashtbl[nchash - 1]; ncpp >= nchashtbl; ncpp--) { |
1689 | restart: | |
1690 | for (ncp = ncpp->lh_first; ncp != 0; ncp = ncp->nc_hash.le_next) { | |
1691 | if (ncp->nc_dvp->v_mount == mp) { | |
1692 | cache_delete(ncp, 0); | |
1693 | goto restart; | |
1c79356b A |
1694 | } |
1695 | } | |
1696 | } | |
0c530ab8 | 1697 | NAME_CACHE_UNLOCK(); |
1c79356b | 1698 | } |
55e303ae A |
1699 | |
1700 | ||
1701 | ||
1702 | // | |
1703 | // String ref routines | |
1704 | // | |
1705 | static LIST_HEAD(stringhead, string_t) *string_ref_table; | |
1706 | static u_long string_table_mask; | |
1707 | static uint32_t max_chain_len=0; | |
1708 | static struct stringhead *long_chain_head=NULL; | |
1709 | static uint32_t filled_buckets=0; | |
1710 | static uint32_t num_dups=0; | |
1711 | static uint32_t nstrings=0; | |
1712 | ||
1713 | typedef struct string_t { | |
1714 | LIST_ENTRY(string_t) hash_chain; | |
2d21ac55 | 1715 | const char *str; |
55e303ae A |
1716 | uint32_t refcount; |
1717 | } string_t; | |
1718 | ||
1719 | ||
1720 | ||
1721 | static int | |
91447636 | 1722 | resize_string_ref_table(void) |
55e303ae A |
1723 | { |
1724 | struct stringhead *new_table; | |
1725 | struct stringhead *old_table; | |
1726 | struct stringhead *old_head, *head; | |
1727 | string_t *entry, *next; | |
1728 | uint32_t i, hashval; | |
1729 | u_long new_mask, old_mask; | |
1730 | ||
1731 | new_table = hashinit((string_table_mask + 1) * 2, M_CACHE, &new_mask); | |
1732 | if (new_table == NULL) { | |
1733 | return ENOMEM; | |
1734 | } | |
1735 | ||
1736 | // do the switch! | |
1737 | old_table = string_ref_table; | |
1738 | string_ref_table = new_table; | |
1739 | old_mask = string_table_mask; | |
1740 | string_table_mask = new_mask; | |
1741 | ||
2d21ac55 | 1742 | printf("resize: max chain len %d, new table size %lu\n", |
55e303ae A |
1743 | max_chain_len, new_mask + 1); |
1744 | max_chain_len = 0; | |
1745 | long_chain_head = NULL; | |
1746 | filled_buckets = 0; | |
1747 | ||
1748 | // walk the old table and insert all the entries into | |
1749 | // the new table | |
1750 | // | |
1751 | for(i=0; i <= old_mask; i++) { | |
1752 | old_head = &old_table[i]; | |
1753 | for (entry=old_head->lh_first; entry != NULL; entry=next) { | |
2d21ac55 | 1754 | hashval = hash_string((const char *)entry->str, 0); |
55e303ae A |
1755 | head = &string_ref_table[hashval & string_table_mask]; |
1756 | if (head->lh_first == NULL) { | |
1757 | filled_buckets++; | |
1758 | } | |
1759 | ||
1760 | next = entry->hash_chain.le_next; | |
1761 | LIST_INSERT_HEAD(head, entry, hash_chain); | |
1762 | } | |
1763 | } | |
1764 | ||
1765 | FREE(old_table, M_CACHE); | |
1766 | ||
1767 | return 0; | |
1768 | } | |
1769 | ||
1770 | ||
1771 | static void | |
1772 | init_string_table(void) | |
1773 | { | |
2d21ac55 | 1774 | string_ref_table = hashinit(CONFIG_VFS_NAMES, M_CACHE, &string_table_mask); |
55e303ae A |
1775 | } |
1776 | ||
1777 | ||
2d21ac55 | 1778 | const char * |
91447636 A |
1779 | vfs_addname(const char *name, size_t len, u_int hashval, u_int flags) |
1780 | { | |
2d21ac55 | 1781 | const char * ptr; |
91447636 | 1782 | |
0c530ab8 | 1783 | NAME_CACHE_LOCK(); |
91447636 | 1784 | ptr = add_name_locked(name, len, hashval, flags); |
0c530ab8 | 1785 | NAME_CACHE_UNLOCK(); |
91447636 A |
1786 | |
1787 | return(ptr); | |
1788 | } | |
1789 | ||
2d21ac55 | 1790 | static const char * |
91447636 | 1791 | add_name_locked(const char *name, size_t len, u_int hashval, __unused u_int flags) |
55e303ae A |
1792 | { |
1793 | struct stringhead *head; | |
1794 | string_t *entry; | |
91447636 | 1795 | uint32_t chain_len = 0; |
2d21ac55 | 1796 | char *ptr; |
55e303ae A |
1797 | |
1798 | // | |
1799 | // If the table gets more than 3/4 full, resize it | |
1800 | // | |
1801 | if (4*filled_buckets >= ((string_table_mask + 1) * 3)) { | |
1802 | if (resize_string_ref_table() != 0) { | |
1803 | printf("failed to resize the hash table.\n"); | |
1804 | } | |
1805 | } | |
55e303ae | 1806 | if (hashval == 0) { |
91447636 | 1807 | hashval = hash_string(name, 0); |
55e303ae A |
1808 | } |
1809 | ||
2d21ac55 A |
1810 | // |
1811 | // if the length already accounts for the null-byte, then | |
1812 | // subtract one so later on we don't index past the end | |
1813 | // of the string. | |
1814 | // | |
1815 | if (len > 0 && name[len-1] == '\0') { | |
1816 | len--; | |
1817 | } | |
1818 | ||
55e303ae A |
1819 | head = &string_ref_table[hashval & string_table_mask]; |
1820 | for (entry=head->lh_first; entry != NULL; chain_len++, entry=entry->hash_chain.le_next) { | |
91447636 | 1821 | if (memcmp(entry->str, name, len) == 0 && entry->str[len] == '\0') { |
55e303ae A |
1822 | entry->refcount++; |
1823 | num_dups++; | |
1824 | break; | |
1825 | } | |
1826 | } | |
1827 | ||
1828 | if (entry == NULL) { | |
1829 | // it wasn't already there so add it. | |
1830 | MALLOC(entry, string_t *, sizeof(string_t) + len + 1, M_TEMP, M_WAITOK); | |
1831 | ||
1832 | // have to get "head" again because we could have blocked | |
1833 | // in malloc and thus head could have changed. | |
1834 | // | |
1835 | head = &string_ref_table[hashval & string_table_mask]; | |
1836 | if (head->lh_first == NULL) { | |
1837 | filled_buckets++; | |
1838 | } | |
1839 | ||
2d21ac55 A |
1840 | ptr = (char *)((char *)entry + sizeof(string_t)); |
1841 | strncpy(ptr, name, len); | |
1842 | ptr[len] = '\0'; | |
1843 | entry->str = ptr; | |
55e303ae | 1844 | entry->refcount = 1; |
91447636 | 1845 | LIST_INSERT_HEAD(head, entry, hash_chain); |
55e303ae A |
1846 | |
1847 | if (chain_len > max_chain_len) { | |
1848 | max_chain_len = chain_len; | |
1849 | long_chain_head = head; | |
1850 | } | |
1851 | ||
1852 | nstrings++; | |
1853 | } | |
1854 | ||
2d21ac55 | 1855 | return (const char *)entry->str; |
55e303ae A |
1856 | } |
1857 | ||
1858 | int | |
91447636 A |
1859 | vfs_removename(const char *nameref) |
1860 | { | |
1861 | int i; | |
1862 | ||
0c530ab8 | 1863 | NAME_CACHE_LOCK(); |
91447636 | 1864 | i = remove_name_locked(nameref); |
0c530ab8 | 1865 | NAME_CACHE_UNLOCK(); |
91447636 A |
1866 | |
1867 | return(i); | |
1868 | ||
1869 | } | |
1870 | ||
1871 | ||
1872 | static int | |
1873 | remove_name_locked(const char *nameref) | |
55e303ae A |
1874 | { |
1875 | struct stringhead *head; | |
1876 | string_t *entry; | |
1877 | uint32_t hashval; | |
2d21ac55 | 1878 | const char *ptr; |
55e303ae A |
1879 | |
1880 | hashval = hash_string(nameref, 0); | |
1881 | head = &string_ref_table[hashval & string_table_mask]; | |
1882 | for (entry=head->lh_first; entry != NULL; entry=entry->hash_chain.le_next) { | |
2d21ac55 | 1883 | if (entry->str == nameref) { |
55e303ae A |
1884 | entry->refcount--; |
1885 | if (entry->refcount == 0) { | |
1886 | LIST_REMOVE(entry, hash_chain); | |
1887 | if (head->lh_first == NULL) { | |
1888 | filled_buckets--; | |
1889 | } | |
91447636 | 1890 | ptr = entry->str; |
55e303ae A |
1891 | entry->str = NULL; |
1892 | nstrings--; | |
1893 | ||
1894 | FREE(entry, M_TEMP); | |
1895 | } else { | |
1896 | num_dups--; | |
1897 | } | |
1898 | ||
1899 | return 0; | |
1900 | } | |
1901 | } | |
1902 | ||
1903 | return ENOENT; | |
1904 | } | |
1905 | ||
1906 | ||
2d21ac55 | 1907 | #ifdef DUMP_STRING_TABLE |
55e303ae A |
1908 | void |
1909 | dump_string_table(void) | |
1910 | { | |
1911 | struct stringhead *head; | |
1912 | string_t *entry; | |
91447636 | 1913 | u_long i; |
55e303ae | 1914 | |
0c530ab8 A |
1915 | NAME_CACHE_LOCK_SHARED(); |
1916 | ||
91447636 | 1917 | for (i = 0; i <= string_table_mask; i++) { |
55e303ae A |
1918 | head = &string_ref_table[i]; |
1919 | for (entry=head->lh_first; entry != NULL; entry=entry->hash_chain.le_next) { | |
1920 | printf("%6d - %s\n", entry->refcount, entry->str); | |
1921 | } | |
1922 | } | |
0c530ab8 | 1923 | NAME_CACHE_UNLOCK(); |
55e303ae | 1924 | } |
2d21ac55 | 1925 | #endif /* DUMP_STRING_TABLE */ |