vfs_mount.c revision 1.96 1 1.96 hannken /* $NetBSD: vfs_mount.c,v 1.96 2022/08/26 11:03:53 hannken Exp $ */
2 1.1 rmind
3 1.1 rmind /*-
4 1.75 ad * Copyright (c) 1997-2020 The NetBSD Foundation, Inc.
5 1.1 rmind * All rights reserved.
6 1.1 rmind *
7 1.1 rmind * This code is derived from software contributed to The NetBSD Foundation
8 1.1 rmind * by Jason R. Thorpe of the Numerical Aerospace Simulation Facility,
9 1.1 rmind * NASA Ames Research Center, by Charles M. Hannum, and by Andrew Doran.
10 1.1 rmind *
11 1.1 rmind * Redistribution and use in source and binary forms, with or without
12 1.1 rmind * modification, are permitted provided that the following conditions
13 1.1 rmind * are met:
14 1.1 rmind * 1. Redistributions of source code must retain the above copyright
15 1.1 rmind * notice, this list of conditions and the following disclaimer.
16 1.1 rmind * 2. Redistributions in binary form must reproduce the above copyright
17 1.1 rmind * notice, this list of conditions and the following disclaimer in the
18 1.1 rmind * documentation and/or other materials provided with the distribution.
19 1.1 rmind *
20 1.1 rmind * THIS SOFTWARE IS PROVIDED BY THE NETBSD FOUNDATION, INC. AND CONTRIBUTORS
21 1.1 rmind * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
22 1.1 rmind * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
23 1.1 rmind * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE FOUNDATION OR CONTRIBUTORS
24 1.1 rmind * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
25 1.1 rmind * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
26 1.1 rmind * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
27 1.1 rmind * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
28 1.1 rmind * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
29 1.1 rmind * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
30 1.1 rmind * POSSIBILITY OF SUCH DAMAGE.
31 1.1 rmind */
32 1.1 rmind
33 1.1 rmind /*
34 1.1 rmind * Copyright (c) 1989, 1993
35 1.1 rmind * The Regents of the University of California. All rights reserved.
36 1.1 rmind * (c) UNIX System Laboratories, Inc.
37 1.1 rmind * All or some portions of this file are derived from material licensed
38 1.1 rmind * to the University of California by American Telephone and Telegraph
39 1.1 rmind * Co. or Unix System Laboratories, Inc. and are reproduced herein with
40 1.1 rmind * the permission of UNIX System Laboratories, Inc.
41 1.1 rmind *
42 1.1 rmind * Redistribution and use in source and binary forms, with or without
43 1.1 rmind * modification, are permitted provided that the following conditions
44 1.1 rmind * are met:
45 1.1 rmind * 1. Redistributions of source code must retain the above copyright
46 1.1 rmind * notice, this list of conditions and the following disclaimer.
47 1.1 rmind * 2. Redistributions in binary form must reproduce the above copyright
48 1.1 rmind * notice, this list of conditions and the following disclaimer in the
49 1.1 rmind * documentation and/or other materials provided with the distribution.
50 1.1 rmind * 3. Neither the name of the University nor the names of its contributors
51 1.1 rmind * may be used to endorse or promote products derived from this software
52 1.1 rmind * without specific prior written permission.
53 1.1 rmind *
54 1.1 rmind * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
55 1.1 rmind * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
56 1.1 rmind * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
57 1.1 rmind * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
58 1.1 rmind * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
59 1.1 rmind * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
60 1.1 rmind * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
61 1.1 rmind * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
62 1.1 rmind * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
63 1.1 rmind * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
64 1.1 rmind * SUCH DAMAGE.
65 1.1 rmind *
66 1.1 rmind * @(#)vfs_subr.c 8.13 (Berkeley) 4/18/94
67 1.1 rmind */
68 1.1 rmind
69 1.1 rmind #include <sys/cdefs.h>
70 1.96 hannken __KERNEL_RCSID(0, "$NetBSD: vfs_mount.c,v 1.96 2022/08/26 11:03:53 hannken Exp $");
71 1.1 rmind
72 1.1 rmind #include <sys/param.h>
73 1.1 rmind #include <sys/kernel.h>
74 1.1 rmind
75 1.1 rmind #include <sys/atomic.h>
76 1.1 rmind #include <sys/buf.h>
77 1.1 rmind #include <sys/conf.h>
78 1.1 rmind #include <sys/fcntl.h>
79 1.1 rmind #include <sys/filedesc.h>
80 1.1 rmind #include <sys/device.h>
81 1.1 rmind #include <sys/kauth.h>
82 1.1 rmind #include <sys/kmem.h>
83 1.1 rmind #include <sys/module.h>
84 1.1 rmind #include <sys/mount.h>
85 1.48 hannken #include <sys/fstrans.h>
86 1.1 rmind #include <sys/namei.h>
87 1.14 gson #include <sys/extattr.h>
88 1.1 rmind #include <sys/syscallargs.h>
89 1.1 rmind #include <sys/sysctl.h>
90 1.1 rmind #include <sys/systm.h>
91 1.5 dsl #include <sys/vfs_syscalls.h>
92 1.41 hannken #include <sys/vnode_impl.h>
93 1.1 rmind
94 1.1 rmind #include <miscfs/genfs/genfs.h>
95 1.1 rmind #include <miscfs/specfs/specdev.h>
96 1.1 rmind
97 1.86 hannken #include <uvm/uvm_swap.h>
98 1.86 hannken
99 1.52 hannken enum mountlist_type {
100 1.52 hannken ME_MOUNT,
101 1.52 hannken ME_MARKER
102 1.52 hannken };
103 1.52 hannken struct mountlist_entry {
104 1.52 hannken TAILQ_ENTRY(mountlist_entry) me_list; /* Mount list. */
105 1.52 hannken struct mount *me_mount; /* Actual mount if ME_MOUNT,
106 1.52 hannken current mount else. */
107 1.52 hannken enum mountlist_type me_type; /* Mount or marker. */
108 1.52 hannken };
109 1.52 hannken struct mount_iterator {
110 1.52 hannken struct mountlist_entry mi_entry;
111 1.52 hannken };
112 1.52 hannken
113 1.45 hannken static struct vnode *vfs_vnode_iterator_next1(struct vnode_iterator *,
114 1.45 hannken bool (*)(void *, struct vnode *), void *, bool);
115 1.45 hannken
116 1.33 pooka /* Root filesystem. */
117 1.1 rmind vnode_t * rootvnode;
118 1.1 rmind
119 1.1 rmind /* Mounted filesystem list. */
120 1.54 hannken static TAILQ_HEAD(mountlist, mountlist_entry) mountlist;
121 1.73 ad static kmutex_t mountlist_lock __cacheline_aligned;
122 1.54 hannken int vnode_offset_next_by_lru /* XXX: ugly hack for pstat.c */
123 1.54 hannken = offsetof(vnode_impl_t, vi_lrulist.tqe_next);
124 1.1 rmind
125 1.73 ad kmutex_t vfs_list_lock __cacheline_aligned;
126 1.1 rmind
127 1.1 rmind static specificdata_domain_t mount_specificdata_domain;
128 1.1 rmind static kmutex_t mntid_lock;
129 1.1 rmind
130 1.73 ad static kmutex_t mountgen_lock __cacheline_aligned;
131 1.1 rmind static uint64_t mountgen;
132 1.1 rmind
133 1.1 rmind void
134 1.1 rmind vfs_mount_sysinit(void)
135 1.1 rmind {
136 1.1 rmind
137 1.24 christos TAILQ_INIT(&mountlist);
138 1.1 rmind mutex_init(&mountlist_lock, MUTEX_DEFAULT, IPL_NONE);
139 1.1 rmind mutex_init(&vfs_list_lock, MUTEX_DEFAULT, IPL_NONE);
140 1.1 rmind
141 1.1 rmind mount_specificdata_domain = specificdata_domain_create();
142 1.1 rmind mutex_init(&mntid_lock, MUTEX_DEFAULT, IPL_NONE);
143 1.1 rmind mutex_init(&mountgen_lock, MUTEX_DEFAULT, IPL_NONE);
144 1.1 rmind mountgen = 0;
145 1.1 rmind }
146 1.1 rmind
147 1.1 rmind struct mount *
148 1.1 rmind vfs_mountalloc(struct vfsops *vfsops, vnode_t *vp)
149 1.1 rmind {
150 1.1 rmind struct mount *mp;
151 1.60 hannken int error __diagused;
152 1.1 rmind
153 1.1 rmind mp = kmem_zalloc(sizeof(*mp), KM_SLEEP);
154 1.1 rmind mp->mnt_op = vfsops;
155 1.1 rmind mp->mnt_refcnt = 1;
156 1.1 rmind TAILQ_INIT(&mp->mnt_vnodelist);
157 1.73 ad mp->mnt_renamelock = mutex_obj_alloc(MUTEX_DEFAULT, IPL_NONE);
158 1.73 ad mp->mnt_vnodelock = mutex_obj_alloc(MUTEX_DEFAULT, IPL_NONE);
159 1.73 ad mp->mnt_updating = mutex_obj_alloc(MUTEX_DEFAULT, IPL_NONE);
160 1.1 rmind mp->mnt_vnodecovered = vp;
161 1.1 rmind mount_initspecific(mp);
162 1.69 hannken
163 1.69 hannken error = fstrans_mount(mp);
164 1.69 hannken KASSERT(error == 0);
165 1.1 rmind
166 1.1 rmind mutex_enter(&mountgen_lock);
167 1.1 rmind mp->mnt_gen = mountgen++;
168 1.1 rmind mutex_exit(&mountgen_lock);
169 1.1 rmind
170 1.1 rmind return mp;
171 1.1 rmind }
172 1.1 rmind
173 1.1 rmind /*
174 1.1 rmind * vfs_rootmountalloc: lookup a filesystem type, and if found allocate and
175 1.1 rmind * initialize a mount structure for it.
176 1.1 rmind *
177 1.1 rmind * Devname is usually updated by mount(8) after booting.
178 1.1 rmind */
179 1.1 rmind int
180 1.1 rmind vfs_rootmountalloc(const char *fstypename, const char *devname,
181 1.1 rmind struct mount **mpp)
182 1.1 rmind {
183 1.1 rmind struct vfsops *vfsp = NULL;
184 1.1 rmind struct mount *mp;
185 1.57 hannken int error __diagused;
186 1.1 rmind
187 1.1 rmind mutex_enter(&vfs_list_lock);
188 1.1 rmind LIST_FOREACH(vfsp, &vfs_list, vfs_list)
189 1.1 rmind if (!strncmp(vfsp->vfs_name, fstypename,
190 1.1 rmind sizeof(mp->mnt_stat.f_fstypename)))
191 1.1 rmind break;
192 1.1 rmind if (vfsp == NULL) {
193 1.1 rmind mutex_exit(&vfs_list_lock);
194 1.1 rmind return (ENODEV);
195 1.1 rmind }
196 1.1 rmind vfsp->vfs_refcount++;
197 1.1 rmind mutex_exit(&vfs_list_lock);
198 1.1 rmind
199 1.1 rmind if ((mp = vfs_mountalloc(vfsp, NULL)) == NULL)
200 1.1 rmind return ENOMEM;
201 1.57 hannken error = vfs_busy(mp);
202 1.57 hannken KASSERT(error == 0);
203 1.1 rmind mp->mnt_flag = MNT_RDONLY;
204 1.1 rmind (void)strlcpy(mp->mnt_stat.f_fstypename, vfsp->vfs_name,
205 1.1 rmind sizeof(mp->mnt_stat.f_fstypename));
206 1.1 rmind mp->mnt_stat.f_mntonname[0] = '/';
207 1.1 rmind mp->mnt_stat.f_mntonname[1] = '\0';
208 1.1 rmind mp->mnt_stat.f_mntfromname[sizeof(mp->mnt_stat.f_mntfromname) - 1] =
209 1.1 rmind '\0';
210 1.1 rmind (void)copystr(devname, mp->mnt_stat.f_mntfromname,
211 1.1 rmind sizeof(mp->mnt_stat.f_mntfromname) - 1, 0);
212 1.1 rmind *mpp = mp;
213 1.1 rmind return 0;
214 1.1 rmind }
215 1.1 rmind
216 1.1 rmind /*
217 1.1 rmind * vfs_getnewfsid: get a new unique fsid.
218 1.1 rmind */
219 1.1 rmind void
220 1.1 rmind vfs_getnewfsid(struct mount *mp)
221 1.1 rmind {
222 1.1 rmind static u_short xxxfs_mntid;
223 1.96 hannken struct mountlist_entry *me;
224 1.1 rmind fsid_t tfsid;
225 1.1 rmind int mtype;
226 1.1 rmind
227 1.1 rmind mutex_enter(&mntid_lock);
228 1.1 rmind if (xxxfs_mntid == 0)
229 1.1 rmind ++xxxfs_mntid;
230 1.96 hannken mtype = makefstype(mp->mnt_op->vfs_name);
231 1.1 rmind tfsid.__fsid_val[0] = makedev(mtype & 0xff, xxxfs_mntid);
232 1.1 rmind tfsid.__fsid_val[1] = mtype;
233 1.96 hannken /* Always increment to not return the same fsid to parallel mounts. */
234 1.96 hannken xxxfs_mntid++;
235 1.96 hannken
236 1.96 hannken /*
237 1.96 hannken * Directly walk mountlist to prevent deadlock through
238 1.96 hannken * mountlist_iterator_next() -> vfs_busy().
239 1.96 hannken */
240 1.96 hannken mutex_enter(&mountlist_lock);
241 1.96 hannken for (me = TAILQ_FIRST(&mountlist); me != TAILQ_END(&mountlist); ) {
242 1.96 hannken if (me->me_type == ME_MOUNT &&
243 1.96 hannken me->me_mount->mnt_stat.f_fsidx.__fsid_val[0] ==
244 1.96 hannken tfsid.__fsid_val[0] &&
245 1.96 hannken me->me_mount->mnt_stat.f_fsidx.__fsid_val[1] ==
246 1.96 hannken tfsid.__fsid_val[1]) {
247 1.96 hannken tfsid.__fsid_val[0]++;
248 1.96 hannken xxxfs_mntid++;
249 1.96 hannken me = TAILQ_FIRST(&mountlist);
250 1.96 hannken } else {
251 1.96 hannken me = TAILQ_NEXT(me, me_list);
252 1.96 hannken }
253 1.1 rmind }
254 1.96 hannken mutex_exit(&mountlist_lock);
255 1.96 hannken
256 1.1 rmind mp->mnt_stat.f_fsidx.__fsid_val[0] = tfsid.__fsid_val[0];
257 1.96 hannken mp->mnt_stat.f_fsidx.__fsid_val[1] = tfsid.__fsid_val[1];
258 1.1 rmind mp->mnt_stat.f_fsid = mp->mnt_stat.f_fsidx.__fsid_val[0];
259 1.1 rmind mutex_exit(&mntid_lock);
260 1.1 rmind }
261 1.1 rmind
262 1.1 rmind /*
263 1.1 rmind * Lookup a mount point by filesystem identifier.
264 1.1 rmind *
265 1.1 rmind * XXX Needs to add a reference to the mount point.
266 1.1 rmind */
267 1.1 rmind struct mount *
268 1.1 rmind vfs_getvfs(fsid_t *fsid)
269 1.1 rmind {
270 1.53 hannken mount_iterator_t *iter;
271 1.1 rmind struct mount *mp;
272 1.1 rmind
273 1.53 hannken mountlist_iterator_init(&iter);
274 1.53 hannken while ((mp = mountlist_iterator_next(iter)) != NULL) {
275 1.1 rmind if (mp->mnt_stat.f_fsidx.__fsid_val[0] == fsid->__fsid_val[0] &&
276 1.1 rmind mp->mnt_stat.f_fsidx.__fsid_val[1] == fsid->__fsid_val[1]) {
277 1.53 hannken mountlist_iterator_destroy(iter);
278 1.53 hannken return mp;
279 1.1 rmind }
280 1.1 rmind }
281 1.53 hannken mountlist_iterator_destroy(iter);
282 1.1 rmind return NULL;
283 1.1 rmind }
284 1.1 rmind
285 1.1 rmind /*
286 1.55 hannken * Take a reference to a mount structure.
287 1.55 hannken */
288 1.55 hannken void
289 1.55 hannken vfs_ref(struct mount *mp)
290 1.55 hannken {
291 1.55 hannken
292 1.55 hannken KASSERT(mp->mnt_refcnt > 0 || mutex_owned(&mountlist_lock));
293 1.55 hannken
294 1.55 hannken atomic_inc_uint(&mp->mnt_refcnt);
295 1.55 hannken }
296 1.55 hannken
297 1.55 hannken /*
298 1.1 rmind * Drop a reference to a mount structure, freeing if the last reference.
299 1.1 rmind */
300 1.1 rmind void
301 1.55 hannken vfs_rele(struct mount *mp)
302 1.1 rmind {
303 1.1 rmind
304 1.88 riastrad #ifndef __HAVE_ATOMIC_AS_MEMBAR
305 1.93 riastrad membar_release();
306 1.88 riastrad #endif
307 1.1 rmind if (__predict_true((int)atomic_dec_uint_nv(&mp->mnt_refcnt) > 0)) {
308 1.1 rmind return;
309 1.1 rmind }
310 1.88 riastrad #ifndef __HAVE_ATOMIC_AS_MEMBAR
311 1.93 riastrad membar_acquire();
312 1.88 riastrad #endif
313 1.1 rmind
314 1.1 rmind /*
315 1.1 rmind * Nothing else has visibility of the mount: we can now
316 1.1 rmind * free the data structures.
317 1.1 rmind */
318 1.1 rmind KASSERT(mp->mnt_refcnt == 0);
319 1.1 rmind specificdata_fini(mount_specificdata_domain, &mp->mnt_specdataref);
320 1.73 ad mutex_obj_free(mp->mnt_updating);
321 1.73 ad mutex_obj_free(mp->mnt_renamelock);
322 1.73 ad mutex_obj_free(mp->mnt_vnodelock);
323 1.1 rmind if (mp->mnt_op != NULL) {
324 1.1 rmind vfs_delref(mp->mnt_op);
325 1.1 rmind }
326 1.70 hannken fstrans_unmount(mp);
327 1.70 hannken /*
328 1.70 hannken * Final free of mp gets done from fstrans_mount_dtor().
329 1.70 hannken *
330 1.70 hannken * Prevents this memory to be reused as a mount before
331 1.70 hannken * fstrans releases all references to it.
332 1.70 hannken */
333 1.1 rmind }
334 1.1 rmind
335 1.1 rmind /*
336 1.1 rmind * Mark a mount point as busy, and gain a new reference to it. Used to
337 1.1 rmind * prevent the file system from being unmounted during critical sections.
338 1.1 rmind *
339 1.18 mlelstv * vfs_busy can be called multiple times and by multiple threads
340 1.18 mlelstv * and must be accompanied by the same number of vfs_unbusy calls.
341 1.18 mlelstv *
342 1.1 rmind * => The caller must hold a pre-existing reference to the mount.
343 1.1 rmind * => Will fail if the file system is being unmounted, or is unmounted.
344 1.1 rmind */
345 1.58 hannken static inline int
346 1.58 hannken _vfs_busy(struct mount *mp, bool wait)
347 1.1 rmind {
348 1.1 rmind
349 1.1 rmind KASSERT(mp->mnt_refcnt > 0);
350 1.1 rmind
351 1.58 hannken if (wait) {
352 1.66 hannken fstrans_start(mp);
353 1.61 hannken } else {
354 1.66 hannken if (fstrans_start_nowait(mp))
355 1.61 hannken return EBUSY;
356 1.58 hannken }
357 1.1 rmind if (__predict_false((mp->mnt_iflag & IMNT_GONE) != 0)) {
358 1.61 hannken fstrans_done(mp);
359 1.1 rmind return ENOENT;
360 1.1 rmind }
361 1.55 hannken vfs_ref(mp);
362 1.1 rmind return 0;
363 1.1 rmind }
364 1.1 rmind
365 1.58 hannken int
366 1.58 hannken vfs_busy(struct mount *mp)
367 1.58 hannken {
368 1.58 hannken
369 1.58 hannken return _vfs_busy(mp, true);
370 1.58 hannken }
371 1.58 hannken
372 1.58 hannken int
373 1.58 hannken vfs_trybusy(struct mount *mp)
374 1.58 hannken {
375 1.58 hannken
376 1.58 hannken return _vfs_busy(mp, false);
377 1.58 hannken }
378 1.58 hannken
379 1.1 rmind /*
380 1.1 rmind * Unbusy a busy filesystem.
381 1.1 rmind *
382 1.18 mlelstv * Every successful vfs_busy() call must be undone by a vfs_unbusy() call.
383 1.1 rmind */
384 1.1 rmind void
385 1.56 hannken vfs_unbusy(struct mount *mp)
386 1.1 rmind {
387 1.1 rmind
388 1.1 rmind KASSERT(mp->mnt_refcnt > 0);
389 1.1 rmind
390 1.61 hannken fstrans_done(mp);
391 1.56 hannken vfs_rele(mp);
392 1.1 rmind }
393 1.1 rmind
394 1.27 hannken struct vnode_iterator {
395 1.44 hannken vnode_impl_t vi_vnode;
396 1.40 msaitoh };
397 1.27 hannken
398 1.27 hannken void
399 1.44 hannken vfs_vnode_iterator_init(struct mount *mp, struct vnode_iterator **vnip)
400 1.27 hannken {
401 1.44 hannken vnode_t *vp;
402 1.44 hannken vnode_impl_t *vip;
403 1.27 hannken
404 1.38 hannken vp = vnalloc_marker(mp);
405 1.44 hannken vip = VNODE_TO_VIMPL(vp);
406 1.27 hannken
407 1.73 ad mutex_enter(mp->mnt_vnodelock);
408 1.44 hannken TAILQ_INSERT_HEAD(&mp->mnt_vnodelist, vip, vi_mntvnodes);
409 1.27 hannken vp->v_usecount = 1;
410 1.73 ad mutex_exit(mp->mnt_vnodelock);
411 1.27 hannken
412 1.44 hannken *vnip = (struct vnode_iterator *)vip;
413 1.27 hannken }
414 1.27 hannken
415 1.27 hannken void
416 1.44 hannken vfs_vnode_iterator_destroy(struct vnode_iterator *vni)
417 1.27 hannken {
418 1.44 hannken vnode_impl_t *mvip = &vni->vi_vnode;
419 1.44 hannken vnode_t *mvp = VIMPL_TO_VNODE(mvip);
420 1.73 ad kmutex_t *lock;
421 1.27 hannken
422 1.38 hannken KASSERT(vnis_marker(mvp));
423 1.78 ad if (vrefcnt(mvp) != 0) {
424 1.73 ad lock = mvp->v_mount->mnt_vnodelock;
425 1.73 ad mutex_enter(lock);
426 1.44 hannken TAILQ_REMOVE(&mvp->v_mount->mnt_vnodelist, mvip, vi_mntvnodes);
427 1.32 hannken mvp->v_usecount = 0;
428 1.73 ad mutex_exit(lock);
429 1.32 hannken }
430 1.38 hannken vnfree_marker(mvp);
431 1.27 hannken }
432 1.27 hannken
433 1.45 hannken static struct vnode *
434 1.45 hannken vfs_vnode_iterator_next1(struct vnode_iterator *vni,
435 1.45 hannken bool (*f)(void *, struct vnode *), void *cl, bool do_wait)
436 1.27 hannken {
437 1.44 hannken vnode_impl_t *mvip = &vni->vi_vnode;
438 1.44 hannken struct mount *mp = VIMPL_TO_VNODE(mvip)->v_mount;
439 1.44 hannken vnode_t *vp;
440 1.44 hannken vnode_impl_t *vip;
441 1.73 ad kmutex_t *lock;
442 1.27 hannken int error;
443 1.27 hannken
444 1.44 hannken KASSERT(vnis_marker(VIMPL_TO_VNODE(mvip)));
445 1.27 hannken
446 1.73 ad lock = mp->mnt_vnodelock;
447 1.27 hannken do {
448 1.73 ad mutex_enter(lock);
449 1.44 hannken vip = TAILQ_NEXT(mvip, vi_mntvnodes);
450 1.44 hannken TAILQ_REMOVE(&mp->mnt_vnodelist, mvip, vi_mntvnodes);
451 1.44 hannken VIMPL_TO_VNODE(mvip)->v_usecount = 0;
452 1.29 christos again:
453 1.72 maxv if (vip == NULL) {
454 1.73 ad mutex_exit(lock);
455 1.29 christos return NULL;
456 1.27 hannken }
457 1.72 maxv vp = VIMPL_TO_VNODE(vip);
458 1.72 maxv KASSERT(vp != NULL);
459 1.27 hannken mutex_enter(vp->v_interlock);
460 1.38 hannken if (vnis_marker(vp) ||
461 1.45 hannken vdead_check(vp, (do_wait ? 0 : VDEAD_NOWAIT)) ||
462 1.37 hannken (f && !(*f)(cl, vp))) {
463 1.27 hannken mutex_exit(vp->v_interlock);
464 1.44 hannken vip = TAILQ_NEXT(vip, vi_mntvnodes);
465 1.29 christos goto again;
466 1.27 hannken }
467 1.27 hannken
468 1.44 hannken TAILQ_INSERT_AFTER(&mp->mnt_vnodelist, vip, mvip, vi_mntvnodes);
469 1.44 hannken VIMPL_TO_VNODE(mvip)->v_usecount = 1;
470 1.73 ad mutex_exit(lock);
471 1.43 hannken error = vcache_vget(vp);
472 1.27 hannken KASSERT(error == 0 || error == ENOENT);
473 1.27 hannken } while (error != 0);
474 1.27 hannken
475 1.29 christos return vp;
476 1.27 hannken }
477 1.27 hannken
478 1.45 hannken struct vnode *
479 1.45 hannken vfs_vnode_iterator_next(struct vnode_iterator *vni,
480 1.45 hannken bool (*f)(void *, struct vnode *), void *cl)
481 1.45 hannken {
482 1.45 hannken
483 1.45 hannken return vfs_vnode_iterator_next1(vni, f, cl, false);
484 1.45 hannken }
485 1.45 hannken
486 1.1 rmind /*
487 1.1 rmind * Move a vnode from one mount queue to another.
488 1.1 rmind */
489 1.1 rmind void
490 1.1 rmind vfs_insmntque(vnode_t *vp, struct mount *mp)
491 1.1 rmind {
492 1.44 hannken vnode_impl_t *vip = VNODE_TO_VIMPL(vp);
493 1.1 rmind struct mount *omp;
494 1.73 ad kmutex_t *lock;
495 1.1 rmind
496 1.4 rmind KASSERT(mp == NULL || (mp->mnt_iflag & IMNT_UNMOUNT) == 0 ||
497 1.4 rmind vp->v_tag == VT_VFS);
498 1.1 rmind
499 1.1 rmind /*
500 1.1 rmind * Delete from old mount point vnode list, if on one.
501 1.1 rmind */
502 1.73 ad if ((omp = vp->v_mount) != NULL) {
503 1.73 ad lock = omp->mnt_vnodelock;
504 1.73 ad mutex_enter(lock);
505 1.44 hannken TAILQ_REMOVE(&vp->v_mount->mnt_vnodelist, vip, vi_mntvnodes);
506 1.73 ad mutex_exit(lock);
507 1.73 ad }
508 1.73 ad
509 1.1 rmind /*
510 1.1 rmind * Insert into list of vnodes for the new mount point, if
511 1.1 rmind * available. The caller must take a reference on the mount
512 1.1 rmind * structure and donate to the vnode.
513 1.1 rmind */
514 1.73 ad if ((vp->v_mount = mp) != NULL) {
515 1.73 ad lock = mp->mnt_vnodelock;
516 1.73 ad mutex_enter(lock);
517 1.44 hannken TAILQ_INSERT_TAIL(&mp->mnt_vnodelist, vip, vi_mntvnodes);
518 1.73 ad mutex_exit(lock);
519 1.73 ad }
520 1.1 rmind
521 1.1 rmind if (omp != NULL) {
522 1.1 rmind /* Release reference to old mount. */
523 1.55 hannken vfs_rele(omp);
524 1.1 rmind }
525 1.1 rmind }
526 1.1 rmind
527 1.1 rmind /*
528 1.1 rmind * Remove any vnodes in the vnode table belonging to mount point mp.
529 1.1 rmind *
530 1.1 rmind * If FORCECLOSE is not specified, there should not be any active ones,
531 1.1 rmind * return error if any are found (nb: this is a user error, not a
532 1.1 rmind * system error). If FORCECLOSE is specified, detach any active vnodes
533 1.1 rmind * that are found.
534 1.1 rmind *
535 1.1 rmind * If WRITECLOSE is set, only flush out regular file vnodes open for
536 1.1 rmind * writing.
537 1.1 rmind *
538 1.1 rmind * SKIPSYSTEM causes any vnodes marked VV_SYSTEM to be skipped.
539 1.1 rmind */
540 1.1 rmind #ifdef DEBUG
541 1.1 rmind int busyprt = 0; /* print out busy vnodes */
542 1.1 rmind struct ctldebug debug1 = { "busyprt", &busyprt };
543 1.1 rmind #endif
544 1.1 rmind
545 1.46 hannken static vnode_t *
546 1.46 hannken vflushnext(struct vnode_iterator *marker, int *when)
547 1.46 hannken {
548 1.77 maxv if (getticks() > *when) {
549 1.46 hannken yield();
550 1.77 maxv *when = getticks() + hz / 10;
551 1.46 hannken }
552 1.46 hannken return vfs_vnode_iterator_next1(marker, NULL, NULL, true);
553 1.46 hannken }
554 1.29 christos
555 1.46 hannken /*
556 1.46 hannken * Flush one vnode. Referenced on entry, unreferenced on return.
557 1.46 hannken */
558 1.46 hannken static int
559 1.46 hannken vflush_one(vnode_t *vp, vnode_t *skipvp, int flags)
560 1.29 christos {
561 1.46 hannken int error;
562 1.46 hannken struct vattr vattr;
563 1.46 hannken
564 1.46 hannken if (vp == skipvp ||
565 1.46 hannken ((flags & SKIPSYSTEM) && (vp->v_vflag & VV_SYSTEM))) {
566 1.46 hannken vrele(vp);
567 1.46 hannken return 0;
568 1.46 hannken }
569 1.29 christos /*
570 1.46 hannken * If WRITECLOSE is set, only flush out regular file
571 1.46 hannken * vnodes open for writing or open and unlinked.
572 1.29 christos */
573 1.46 hannken if ((flags & WRITECLOSE)) {
574 1.46 hannken if (vp->v_type != VREG) {
575 1.46 hannken vrele(vp);
576 1.46 hannken return 0;
577 1.46 hannken }
578 1.46 hannken error = vn_lock(vp, LK_EXCLUSIVE);
579 1.46 hannken if (error) {
580 1.46 hannken KASSERT(error == ENOENT);
581 1.46 hannken vrele(vp);
582 1.46 hannken return 0;
583 1.46 hannken }
584 1.46 hannken error = VOP_FSYNC(vp, curlwp->l_cred, FSYNC_WAIT, 0, 0);
585 1.46 hannken if (error == 0)
586 1.46 hannken error = VOP_GETATTR(vp, &vattr, curlwp->l_cred);
587 1.46 hannken VOP_UNLOCK(vp);
588 1.46 hannken if (error) {
589 1.46 hannken vrele(vp);
590 1.46 hannken return error;
591 1.46 hannken }
592 1.46 hannken if (vp->v_writecount == 0 && vattr.va_nlink > 0) {
593 1.46 hannken vrele(vp);
594 1.46 hannken return 0;
595 1.46 hannken }
596 1.46 hannken }
597 1.29 christos /*
598 1.46 hannken * First try to recycle the vnode.
599 1.29 christos */
600 1.46 hannken if (vrecycle(vp))
601 1.46 hannken return 0;
602 1.29 christos /*
603 1.46 hannken * If FORCECLOSE is set, forcibly close the vnode.
604 1.67 hannken * For block or character devices, revert to an
605 1.67 hannken * anonymous device. For all other files, just
606 1.67 hannken * kill them.
607 1.29 christos */
608 1.46 hannken if (flags & FORCECLOSE) {
609 1.78 ad if (vrefcnt(vp) > 1 &&
610 1.67 hannken (vp->v_type == VBLK || vp->v_type == VCHR))
611 1.67 hannken vcache_make_anon(vp);
612 1.67 hannken else
613 1.67 hannken vgone(vp);
614 1.46 hannken return 0;
615 1.29 christos }
616 1.46 hannken vrele(vp);
617 1.46 hannken return EBUSY;
618 1.29 christos }
619 1.29 christos
620 1.1 rmind int
621 1.1 rmind vflush(struct mount *mp, vnode_t *skipvp, int flags)
622 1.1 rmind {
623 1.27 hannken vnode_t *vp;
624 1.27 hannken struct vnode_iterator *marker;
625 1.47 hannken int busy, error, when, retries = 2;
626 1.46 hannken
627 1.47 hannken do {
628 1.47 hannken busy = error = when = 0;
629 1.1 rmind
630 1.47 hannken /*
631 1.47 hannken * First, flush out any vnode references from the
632 1.47 hannken * deferred vrele list.
633 1.47 hannken */
634 1.62 hannken vrele_flush(mp);
635 1.1 rmind
636 1.47 hannken vfs_vnode_iterator_init(mp, &marker);
637 1.29 christos
638 1.47 hannken while ((vp = vflushnext(marker, &when)) != NULL) {
639 1.47 hannken error = vflush_one(vp, skipvp, flags);
640 1.47 hannken if (error == EBUSY) {
641 1.47 hannken error = 0;
642 1.47 hannken busy++;
643 1.1 rmind #ifdef DEBUG
644 1.47 hannken if (busyprt && retries == 0)
645 1.47 hannken vprint("vflush: busy vnode", vp);
646 1.1 rmind #endif
647 1.47 hannken } else if (error != 0) {
648 1.47 hannken break;
649 1.47 hannken }
650 1.46 hannken }
651 1.46 hannken
652 1.47 hannken vfs_vnode_iterator_destroy(marker);
653 1.47 hannken } while (error == 0 && busy > 0 && retries-- > 0);
654 1.46 hannken
655 1.46 hannken if (error)
656 1.46 hannken return error;
657 1.1 rmind if (busy)
658 1.46 hannken return EBUSY;
659 1.45 hannken return 0;
660 1.1 rmind }
661 1.1 rmind
662 1.1 rmind /*
663 1.1 rmind * Mount a file system.
664 1.1 rmind */
665 1.1 rmind
666 1.1 rmind /*
667 1.1 rmind * Scan all active processes to see if any of them have a current or root
668 1.1 rmind * directory onto which the new filesystem has just been mounted. If so,
669 1.1 rmind * replace them with the new mount point.
670 1.1 rmind */
671 1.1 rmind static void
672 1.1 rmind mount_checkdirs(vnode_t *olddp)
673 1.1 rmind {
674 1.1 rmind vnode_t *newdp, *rele1, *rele2;
675 1.1 rmind struct cwdinfo *cwdi;
676 1.1 rmind struct proc *p;
677 1.1 rmind bool retry;
678 1.1 rmind
679 1.78 ad if (vrefcnt(olddp) == 1) {
680 1.1 rmind return;
681 1.1 rmind }
682 1.74 ad if (VFS_ROOT(olddp->v_mountedhere, LK_EXCLUSIVE, &newdp))
683 1.1 rmind panic("mount: lost mount");
684 1.1 rmind
685 1.1 rmind do {
686 1.1 rmind retry = false;
687 1.83 ad mutex_enter(&proc_lock);
688 1.1 rmind PROCLIST_FOREACH(p, &allproc) {
689 1.1 rmind if ((cwdi = p->p_cwdi) == NULL)
690 1.1 rmind continue;
691 1.1 rmind /*
692 1.1 rmind * Cannot change to the old directory any more,
693 1.1 rmind * so even if we see a stale value it is not a
694 1.1 rmind * problem.
695 1.1 rmind */
696 1.1 rmind if (cwdi->cwdi_cdir != olddp &&
697 1.1 rmind cwdi->cwdi_rdir != olddp)
698 1.1 rmind continue;
699 1.1 rmind retry = true;
700 1.1 rmind rele1 = NULL;
701 1.1 rmind rele2 = NULL;
702 1.1 rmind atomic_inc_uint(&cwdi->cwdi_refcnt);
703 1.83 ad mutex_exit(&proc_lock);
704 1.81 ad rw_enter(&cwdi->cwdi_lock, RW_WRITER);
705 1.81 ad if (cwdi->cwdi_cdir == olddp) {
706 1.81 ad rele1 = cwdi->cwdi_cdir;
707 1.81 ad vref(newdp);
708 1.81 ad cwdi->cwdi_cdir = newdp;
709 1.81 ad }
710 1.81 ad if (cwdi->cwdi_rdir == olddp) {
711 1.81 ad rele2 = cwdi->cwdi_rdir;
712 1.81 ad vref(newdp);
713 1.81 ad cwdi->cwdi_rdir = newdp;
714 1.1 rmind }
715 1.81 ad rw_exit(&cwdi->cwdi_lock);
716 1.1 rmind cwdfree(cwdi);
717 1.1 rmind if (rele1 != NULL)
718 1.1 rmind vrele(rele1);
719 1.1 rmind if (rele2 != NULL)
720 1.1 rmind vrele(rele2);
721 1.83 ad mutex_enter(&proc_lock);
722 1.1 rmind break;
723 1.1 rmind }
724 1.83 ad mutex_exit(&proc_lock);
725 1.1 rmind } while (retry);
726 1.1 rmind
727 1.1 rmind if (rootvnode == olddp) {
728 1.1 rmind vrele(rootvnode);
729 1.1 rmind vref(newdp);
730 1.1 rmind rootvnode = newdp;
731 1.1 rmind }
732 1.1 rmind vput(newdp);
733 1.1 rmind }
734 1.1 rmind
735 1.31 manu /*
736 1.31 manu * Start extended attributes
737 1.31 manu */
738 1.31 manu static int
739 1.31 manu start_extattr(struct mount *mp)
740 1.31 manu {
741 1.31 manu int error;
742 1.31 manu
743 1.31 manu error = VFS_EXTATTRCTL(mp, EXTATTR_CMD_START, NULL, 0, NULL);
744 1.31 manu if (error)
745 1.31 manu printf("%s: failed to start extattr: error = %d\n",
746 1.31 manu mp->mnt_stat.f_mntonname, error);
747 1.31 manu
748 1.31 manu return error;
749 1.31 manu }
750 1.31 manu
751 1.1 rmind int
752 1.1 rmind mount_domount(struct lwp *l, vnode_t **vpp, struct vfsops *vfsops,
753 1.1 rmind const char *path, int flags, void *data, size_t *data_len)
754 1.1 rmind {
755 1.1 rmind vnode_t *vp = *vpp;
756 1.1 rmind struct mount *mp;
757 1.1 rmind struct pathbuf *pb;
758 1.1 rmind struct nameidata nd;
759 1.85 hannken int error, error2;
760 1.1 rmind
761 1.1 rmind error = kauth_authorize_system(l->l_cred, KAUTH_SYSTEM_MOUNT,
762 1.1 rmind KAUTH_REQ_SYSTEM_MOUNT_NEW, vp, KAUTH_ARG(flags), data);
763 1.1 rmind if (error) {
764 1.1 rmind vfs_delref(vfsops);
765 1.1 rmind return error;
766 1.1 rmind }
767 1.1 rmind
768 1.1 rmind /* Cannot make a non-dir a mount-point (from here anyway). */
769 1.1 rmind if (vp->v_type != VDIR) {
770 1.1 rmind vfs_delref(vfsops);
771 1.1 rmind return ENOTDIR;
772 1.1 rmind }
773 1.1 rmind
774 1.1 rmind if (flags & MNT_EXPORTED) {
775 1.1 rmind vfs_delref(vfsops);
776 1.1 rmind return EINVAL;
777 1.1 rmind }
778 1.1 rmind
779 1.1 rmind if ((mp = vfs_mountalloc(vfsops, vp)) == NULL) {
780 1.1 rmind vfs_delref(vfsops);
781 1.1 rmind return ENOMEM;
782 1.1 rmind }
783 1.1 rmind
784 1.1 rmind mp->mnt_stat.f_owner = kauth_cred_geteuid(l->l_cred);
785 1.1 rmind
786 1.1 rmind /*
787 1.1 rmind * The underlying file system may refuse the mount for
788 1.1 rmind * various reasons. Allow the user to force it to happen.
789 1.1 rmind *
790 1.1 rmind * Set the mount level flags.
791 1.1 rmind */
792 1.12 christos mp->mnt_flag = flags & (MNT_BASIC_FLAGS | MNT_FORCE | MNT_IGNORE);
793 1.1 rmind
794 1.1 rmind error = VFS_MOUNT(mp, path, data, data_len);
795 1.1 rmind mp->mnt_flag &= ~MNT_OP_FLAGS;
796 1.1 rmind
797 1.94 hannken if (error != 0) {
798 1.94 hannken vfs_rele(mp);
799 1.94 hannken return error;
800 1.94 hannken }
801 1.94 hannken
802 1.94 hannken /* Suspend new file system before taking mnt_updating. */
803 1.94 hannken do {
804 1.94 hannken error2 = vfs_suspend(mp, 0);
805 1.94 hannken } while (error2 == EINTR || error2 == ERESTART);
806 1.94 hannken KASSERT(error2 == 0 || error2 == EOPNOTSUPP);
807 1.94 hannken mutex_enter(mp->mnt_updating);
808 1.1 rmind
809 1.1 rmind /*
810 1.1 rmind * Validate and prepare the mount point.
811 1.1 rmind */
812 1.1 rmind error = pathbuf_copyin(path, &pb);
813 1.1 rmind if (error != 0) {
814 1.1 rmind goto err_mounted;
815 1.1 rmind }
816 1.1 rmind NDINIT(&nd, LOOKUP, FOLLOW | LOCKLEAF | TRYEMULROOT, pb);
817 1.1 rmind error = namei(&nd);
818 1.1 rmind pathbuf_destroy(pb);
819 1.1 rmind if (error != 0) {
820 1.1 rmind goto err_mounted;
821 1.1 rmind }
822 1.1 rmind if (nd.ni_vp != vp) {
823 1.1 rmind vput(nd.ni_vp);
824 1.1 rmind error = EINVAL;
825 1.1 rmind goto err_mounted;
826 1.1 rmind }
827 1.1 rmind if (vp->v_mountedhere != NULL) {
828 1.1 rmind vput(nd.ni_vp);
829 1.1 rmind error = EBUSY;
830 1.1 rmind goto err_mounted;
831 1.1 rmind }
832 1.1 rmind error = vinvalbuf(vp, V_SAVE, l->l_cred, l, 0, 0);
833 1.1 rmind if (error != 0) {
834 1.1 rmind vput(nd.ni_vp);
835 1.1 rmind goto err_mounted;
836 1.1 rmind }
837 1.1 rmind
838 1.1 rmind /*
839 1.1 rmind * Put the new filesystem on the mount list after root.
840 1.1 rmind */
841 1.1 rmind cache_purge(vp);
842 1.1 rmind mp->mnt_iflag &= ~IMNT_WANTRDWR;
843 1.1 rmind
844 1.52 hannken mountlist_append(mp);
845 1.1 rmind if ((mp->mnt_flag & (MNT_RDONLY | MNT_ASYNC)) == 0)
846 1.35 hannken vfs_syncer_add_to_worklist(mp);
847 1.35 hannken vp->v_mountedhere = mp;
848 1.1 rmind vput(nd.ni_vp);
849 1.1 rmind
850 1.1 rmind mount_checkdirs(vp);
851 1.73 ad mutex_exit(mp->mnt_updating);
852 1.94 hannken if (error2 == 0)
853 1.94 hannken vfs_resume(mp);
854 1.1 rmind
855 1.1 rmind /* Hold an additional reference to the mount across VFS_START(). */
856 1.56 hannken vfs_ref(mp);
857 1.1 rmind (void) VFS_STATVFS(mp, &mp->mnt_stat);
858 1.1 rmind error = VFS_START(mp, 0);
859 1.71 christos if (error) {
860 1.1 rmind vrele(vp);
861 1.31 manu } else if (flags & MNT_EXTATTR) {
862 1.71 christos if (start_extattr(mp) != 0)
863 1.71 christos mp->mnt_flag &= ~MNT_EXTATTR;
864 1.31 manu }
865 1.1 rmind /* Drop reference held for VFS_START(). */
866 1.55 hannken vfs_rele(mp);
867 1.1 rmind *vpp = NULL;
868 1.1 rmind return error;
869 1.1 rmind
870 1.1 rmind err_mounted:
871 1.1 rmind if (VFS_UNMOUNT(mp, MNT_FORCE) != 0)
872 1.1 rmind panic("Unmounting fresh file system failed");
873 1.94 hannken mutex_exit(mp->mnt_updating);
874 1.85 hannken if (error2 == 0)
875 1.85 hannken vfs_resume(mp);
876 1.55 hannken vfs_rele(mp);
877 1.1 rmind
878 1.1 rmind return error;
879 1.1 rmind }
880 1.1 rmind
881 1.1 rmind /*
882 1.1 rmind * Do the actual file system unmount. File system is assumed to have
883 1.1 rmind * been locked by the caller.
884 1.1 rmind *
885 1.1 rmind * => Caller hold reference to the mount, explicitly for dounmount().
886 1.1 rmind */
887 1.1 rmind int
888 1.1 rmind dounmount(struct mount *mp, int flags, struct lwp *l)
889 1.1 rmind {
890 1.1 rmind vnode_t *coveredvp;
891 1.31 manu int error, async, used_syncer, used_extattr;
892 1.68 hannken const bool was_suspended = fstrans_is_owner(mp);
893 1.1 rmind
894 1.1 rmind #if NVERIEXEC > 0
895 1.1 rmind error = veriexec_unmountchk(mp);
896 1.1 rmind if (error)
897 1.1 rmind return (error);
898 1.1 rmind #endif /* NVERIEXEC > 0 */
899 1.1 rmind
900 1.68 hannken if (!was_suspended) {
901 1.68 hannken error = vfs_suspend(mp, 0);
902 1.68 hannken if (error) {
903 1.68 hannken return error;
904 1.49 hannken }
905 1.49 hannken }
906 1.62 hannken
907 1.64 hannken KASSERT((mp->mnt_iflag & IMNT_GONE) == 0);
908 1.1 rmind
909 1.35 hannken used_syncer = (mp->mnt_iflag & IMNT_ONWORKLIST) != 0;
910 1.31 manu used_extattr = mp->mnt_flag & MNT_EXTATTR;
911 1.1 rmind
912 1.1 rmind mp->mnt_iflag |= IMNT_UNMOUNT;
913 1.73 ad mutex_enter(mp->mnt_updating);
914 1.1 rmind async = mp->mnt_flag & MNT_ASYNC;
915 1.1 rmind mp->mnt_flag &= ~MNT_ASYNC;
916 1.1 rmind cache_purgevfs(mp); /* remove cache entries for this file sys */
917 1.35 hannken if (used_syncer)
918 1.35 hannken vfs_syncer_remove_from_worklist(mp);
919 1.1 rmind error = 0;
920 1.36 manu if (((mp->mnt_flag & MNT_RDONLY) == 0) && ((flags & MNT_FORCE) == 0)) {
921 1.1 rmind error = VFS_SYNC(mp, MNT_WAIT, l->l_cred);
922 1.1 rmind }
923 1.1 rmind if (error == 0 || (flags & MNT_FORCE)) {
924 1.1 rmind error = VFS_UNMOUNT(mp, flags);
925 1.1 rmind }
926 1.1 rmind if (error) {
927 1.18 mlelstv mp->mnt_iflag &= ~IMNT_UNMOUNT;
928 1.1 rmind if ((mp->mnt_flag & (MNT_RDONLY | MNT_ASYNC)) == 0)
929 1.35 hannken vfs_syncer_add_to_worklist(mp);
930 1.1 rmind mp->mnt_flag |= async;
931 1.73 ad mutex_exit(mp->mnt_updating);
932 1.68 hannken if (!was_suspended)
933 1.68 hannken vfs_resume(mp);
934 1.31 manu if (used_extattr) {
935 1.31 manu if (start_extattr(mp) != 0)
936 1.31 manu mp->mnt_flag &= ~MNT_EXTATTR;
937 1.31 manu else
938 1.31 manu mp->mnt_flag |= MNT_EXTATTR;
939 1.31 manu }
940 1.1 rmind return (error);
941 1.1 rmind }
942 1.73 ad mutex_exit(mp->mnt_updating);
943 1.19 mlelstv
944 1.19 mlelstv /*
945 1.19 mlelstv * mark filesystem as gone to prevent further umounts
946 1.19 mlelstv * after mnt_umounting lock is gone, this also prevents
947 1.19 mlelstv * vfs_busy() from succeeding.
948 1.19 mlelstv */
949 1.19 mlelstv mp->mnt_iflag |= IMNT_GONE;
950 1.95 hannken if ((coveredvp = mp->mnt_vnodecovered) != NULLVP) {
951 1.95 hannken coveredvp->v_mountedhere = NULL;
952 1.95 hannken }
953 1.68 hannken if (!was_suspended)
954 1.68 hannken vfs_resume(mp);
955 1.19 mlelstv
956 1.52 hannken mountlist_remove(mp);
957 1.25 christos if (TAILQ_FIRST(&mp->mnt_vnodelist) != NULL)
958 1.1 rmind panic("unmount: dangling vnode");
959 1.1 rmind vfs_hooks_unmount(mp);
960 1.19 mlelstv
961 1.55 hannken vfs_rele(mp); /* reference from mount() */
962 1.1 rmind if (coveredvp != NULLVP) {
963 1.1 rmind vrele(coveredvp);
964 1.1 rmind }
965 1.1 rmind return (0);
966 1.1 rmind }
967 1.1 rmind
968 1.1 rmind /*
969 1.1 rmind * Unmount all file systems.
970 1.1 rmind * We traverse the list in reverse order under the assumption that doing so
971 1.1 rmind * will avoid needing to worry about dependencies.
972 1.1 rmind */
973 1.1 rmind bool
974 1.1 rmind vfs_unmountall(struct lwp *l)
975 1.1 rmind {
976 1.1 rmind
977 1.16 pooka printf("unmounting file systems...\n");
978 1.1 rmind return vfs_unmountall1(l, true, true);
979 1.1 rmind }
980 1.1 rmind
981 1.1 rmind static void
982 1.1 rmind vfs_unmount_print(struct mount *mp, const char *pfx)
983 1.1 rmind {
984 1.1 rmind
985 1.1 rmind aprint_verbose("%sunmounted %s on %s type %s\n", pfx,
986 1.1 rmind mp->mnt_stat.f_mntfromname, mp->mnt_stat.f_mntonname,
987 1.1 rmind mp->mnt_stat.f_fstypename);
988 1.1 rmind }
989 1.1 rmind
990 1.53 hannken /*
991 1.53 hannken * Return the mount with the highest generation less than "gen".
992 1.53 hannken */
993 1.53 hannken static struct mount *
994 1.53 hannken vfs_unmount_next(uint64_t gen)
995 1.1 rmind {
996 1.53 hannken mount_iterator_t *iter;
997 1.1 rmind struct mount *mp, *nmp;
998 1.1 rmind
999 1.1 rmind nmp = NULL;
1000 1.1 rmind
1001 1.53 hannken mountlist_iterator_init(&iter);
1002 1.53 hannken while ((mp = mountlist_iterator_next(iter)) != NULL) {
1003 1.53 hannken if ((nmp == NULL || mp->mnt_gen > nmp->mnt_gen) &&
1004 1.53 hannken mp->mnt_gen < gen) {
1005 1.53 hannken if (nmp != NULL)
1006 1.55 hannken vfs_rele(nmp);
1007 1.1 rmind nmp = mp;
1008 1.55 hannken vfs_ref(nmp);
1009 1.1 rmind }
1010 1.1 rmind }
1011 1.53 hannken mountlist_iterator_destroy(iter);
1012 1.53 hannken
1013 1.53 hannken return nmp;
1014 1.53 hannken }
1015 1.53 hannken
1016 1.53 hannken bool
1017 1.53 hannken vfs_unmount_forceone(struct lwp *l)
1018 1.53 hannken {
1019 1.53 hannken struct mount *mp;
1020 1.53 hannken int error;
1021 1.53 hannken
1022 1.53 hannken mp = vfs_unmount_next(mountgen);
1023 1.53 hannken if (mp == NULL) {
1024 1.1 rmind return false;
1025 1.1 rmind }
1026 1.1 rmind
1027 1.1 rmind #ifdef DEBUG
1028 1.16 pooka printf("forcefully unmounting %s (%s)...\n",
1029 1.53 hannken mp->mnt_stat.f_mntonname, mp->mnt_stat.f_mntfromname);
1030 1.1 rmind #endif
1031 1.53 hannken if ((error = dounmount(mp, MNT_FORCE, l)) == 0) {
1032 1.53 hannken vfs_unmount_print(mp, "forcefully ");
1033 1.1 rmind return true;
1034 1.1 rmind } else {
1035 1.55 hannken vfs_rele(mp);
1036 1.1 rmind }
1037 1.1 rmind
1038 1.1 rmind #ifdef DEBUG
1039 1.1 rmind printf("forceful unmount of %s failed with error %d\n",
1040 1.53 hannken mp->mnt_stat.f_mntonname, error);
1041 1.1 rmind #endif
1042 1.1 rmind
1043 1.1 rmind return false;
1044 1.1 rmind }
1045 1.1 rmind
1046 1.1 rmind bool
1047 1.1 rmind vfs_unmountall1(struct lwp *l, bool force, bool verbose)
1048 1.1 rmind {
1049 1.53 hannken struct mount *mp;
1050 1.86 hannken mount_iterator_t *iter;
1051 1.1 rmind bool any_error = false, progress = false;
1052 1.53 hannken uint64_t gen;
1053 1.1 rmind int error;
1054 1.1 rmind
1055 1.53 hannken gen = mountgen;
1056 1.53 hannken for (;;) {
1057 1.53 hannken mp = vfs_unmount_next(gen);
1058 1.53 hannken if (mp == NULL)
1059 1.53 hannken break;
1060 1.53 hannken gen = mp->mnt_gen;
1061 1.53 hannken
1062 1.1 rmind #ifdef DEBUG
1063 1.16 pooka printf("unmounting %p %s (%s)...\n",
1064 1.1 rmind (void *)mp, mp->mnt_stat.f_mntonname,
1065 1.1 rmind mp->mnt_stat.f_mntfromname);
1066 1.1 rmind #endif
1067 1.1 rmind if ((error = dounmount(mp, force ? MNT_FORCE : 0, l)) == 0) {
1068 1.1 rmind vfs_unmount_print(mp, "");
1069 1.1 rmind progress = true;
1070 1.1 rmind } else {
1071 1.55 hannken vfs_rele(mp);
1072 1.1 rmind if (verbose) {
1073 1.1 rmind printf("unmount of %s failed with error %d\n",
1074 1.1 rmind mp->mnt_stat.f_mntonname, error);
1075 1.1 rmind }
1076 1.1 rmind any_error = true;
1077 1.1 rmind }
1078 1.1 rmind }
1079 1.1 rmind if (verbose) {
1080 1.16 pooka printf("unmounting done\n");
1081 1.1 rmind }
1082 1.1 rmind if (any_error && verbose) {
1083 1.1 rmind printf("WARNING: some file systems would not unmount\n");
1084 1.1 rmind }
1085 1.86 hannken /* If the mountlist is empty it is time to remove swap. */
1086 1.86 hannken mountlist_iterator_init(&iter);
1087 1.86 hannken if (mountlist_iterator_next(iter) == NULL) {
1088 1.86 hannken uvm_swap_shutdown(l);
1089 1.86 hannken }
1090 1.86 hannken mountlist_iterator_destroy(iter);
1091 1.86 hannken
1092 1.1 rmind return progress;
1093 1.1 rmind }
1094 1.1 rmind
1095 1.1 rmind void
1096 1.1 rmind vfs_sync_all(struct lwp *l)
1097 1.1 rmind {
1098 1.1 rmind printf("syncing disks... ");
1099 1.1 rmind
1100 1.1 rmind /* remove user processes from run queue */
1101 1.1 rmind suspendsched();
1102 1.1 rmind (void)spl0();
1103 1.1 rmind
1104 1.1 rmind /* avoid coming back this way again if we panic. */
1105 1.1 rmind doing_shutdown = 1;
1106 1.1 rmind
1107 1.5 dsl do_sys_sync(l);
1108 1.1 rmind
1109 1.1 rmind /* Wait for sync to finish. */
1110 1.80 ad if (vfs_syncwait() != 0) {
1111 1.1 rmind #if defined(DDB) && defined(DEBUG_HALT_BUSY)
1112 1.1 rmind Debugger();
1113 1.1 rmind #endif
1114 1.1 rmind printf("giving up\n");
1115 1.1 rmind return;
1116 1.1 rmind } else
1117 1.1 rmind printf("done\n");
1118 1.1 rmind }
1119 1.1 rmind
1120 1.3 rmind /*
1121 1.3 rmind * Sync and unmount file systems before shutting down.
1122 1.3 rmind */
1123 1.3 rmind void
1124 1.3 rmind vfs_shutdown(void)
1125 1.1 rmind {
1126 1.3 rmind lwp_t *l = curlwp;
1127 1.1 rmind
1128 1.1 rmind vfs_sync_all(l);
1129 1.1 rmind
1130 1.1 rmind /*
1131 1.89 andvar * If we have panicked - do not make the situation potentially
1132 1.1 rmind * worse by unmounting the file systems.
1133 1.1 rmind */
1134 1.3 rmind if (panicstr != NULL) {
1135 1.1 rmind return;
1136 1.3 rmind }
1137 1.1 rmind
1138 1.1 rmind /* Unmount file systems. */
1139 1.1 rmind vfs_unmountall(l);
1140 1.1 rmind }
1141 1.1 rmind
1142 1.1 rmind /*
1143 1.1 rmind * Print a list of supported file system types (used by vfs_mountroot)
1144 1.1 rmind */
1145 1.1 rmind static void
1146 1.1 rmind vfs_print_fstypes(void)
1147 1.1 rmind {
1148 1.1 rmind struct vfsops *v;
1149 1.1 rmind int cnt = 0;
1150 1.1 rmind
1151 1.1 rmind mutex_enter(&vfs_list_lock);
1152 1.1 rmind LIST_FOREACH(v, &vfs_list, vfs_list)
1153 1.1 rmind ++cnt;
1154 1.1 rmind mutex_exit(&vfs_list_lock);
1155 1.1 rmind
1156 1.1 rmind if (cnt == 0) {
1157 1.1 rmind printf("WARNING: No file system modules have been loaded.\n");
1158 1.1 rmind return;
1159 1.1 rmind }
1160 1.1 rmind
1161 1.1 rmind printf("Supported file systems:");
1162 1.1 rmind mutex_enter(&vfs_list_lock);
1163 1.1 rmind LIST_FOREACH(v, &vfs_list, vfs_list) {
1164 1.1 rmind printf(" %s", v->vfs_name);
1165 1.1 rmind }
1166 1.1 rmind mutex_exit(&vfs_list_lock);
1167 1.1 rmind printf("\n");
1168 1.1 rmind }
1169 1.1 rmind
1170 1.1 rmind /*
1171 1.1 rmind * Mount the root file system. If the operator didn't specify a
1172 1.1 rmind * file system to use, try all possible file systems until one
1173 1.1 rmind * succeeds.
1174 1.1 rmind */
1175 1.1 rmind int
1176 1.1 rmind vfs_mountroot(void)
1177 1.1 rmind {
1178 1.1 rmind struct vfsops *v;
1179 1.1 rmind int error = ENODEV;
1180 1.1 rmind
1181 1.1 rmind if (root_device == NULL)
1182 1.1 rmind panic("vfs_mountroot: root device unknown");
1183 1.1 rmind
1184 1.1 rmind switch (device_class(root_device)) {
1185 1.1 rmind case DV_IFNET:
1186 1.1 rmind if (rootdev != NODEV)
1187 1.1 rmind panic("vfs_mountroot: rootdev set for DV_IFNET "
1188 1.1 rmind "(0x%llx -> %llu,%llu)",
1189 1.1 rmind (unsigned long long)rootdev,
1190 1.1 rmind (unsigned long long)major(rootdev),
1191 1.1 rmind (unsigned long long)minor(rootdev));
1192 1.1 rmind break;
1193 1.1 rmind
1194 1.1 rmind case DV_DISK:
1195 1.1 rmind if (rootdev == NODEV)
1196 1.1 rmind panic("vfs_mountroot: rootdev not set for DV_DISK");
1197 1.1 rmind if (bdevvp(rootdev, &rootvp))
1198 1.1 rmind panic("vfs_mountroot: can't get vnode for rootdev");
1199 1.90 hannken vn_lock(rootvp, LK_EXCLUSIVE | LK_RETRY);
1200 1.1 rmind error = VOP_OPEN(rootvp, FREAD, FSCRED);
1201 1.90 hannken VOP_UNLOCK(rootvp);
1202 1.1 rmind if (error) {
1203 1.1 rmind printf("vfs_mountroot: can't open root device\n");
1204 1.1 rmind return (error);
1205 1.1 rmind }
1206 1.1 rmind break;
1207 1.1 rmind
1208 1.1 rmind case DV_VIRTUAL:
1209 1.1 rmind break;
1210 1.1 rmind
1211 1.1 rmind default:
1212 1.1 rmind printf("%s: inappropriate for root file system\n",
1213 1.1 rmind device_xname(root_device));
1214 1.1 rmind return (ENODEV);
1215 1.1 rmind }
1216 1.1 rmind
1217 1.1 rmind /*
1218 1.1 rmind * If user specified a root fs type, use it. Make sure the
1219 1.1 rmind * specified type exists and has a mount_root()
1220 1.1 rmind */
1221 1.1 rmind if (strcmp(rootfstype, ROOT_FSTYPE_ANY) != 0) {
1222 1.1 rmind v = vfs_getopsbyname(rootfstype);
1223 1.1 rmind error = EFTYPE;
1224 1.1 rmind if (v != NULL) {
1225 1.1 rmind if (v->vfs_mountroot != NULL) {
1226 1.1 rmind error = (v->vfs_mountroot)();
1227 1.1 rmind }
1228 1.1 rmind v->vfs_refcount--;
1229 1.1 rmind }
1230 1.1 rmind goto done;
1231 1.1 rmind }
1232 1.1 rmind
1233 1.1 rmind /*
1234 1.1 rmind * Try each file system currently configured into the kernel.
1235 1.1 rmind */
1236 1.1 rmind mutex_enter(&vfs_list_lock);
1237 1.1 rmind LIST_FOREACH(v, &vfs_list, vfs_list) {
1238 1.1 rmind if (v->vfs_mountroot == NULL)
1239 1.1 rmind continue;
1240 1.1 rmind #ifdef DEBUG
1241 1.1 rmind aprint_normal("mountroot: trying %s...\n", v->vfs_name);
1242 1.1 rmind #endif
1243 1.1 rmind v->vfs_refcount++;
1244 1.1 rmind mutex_exit(&vfs_list_lock);
1245 1.1 rmind error = (*v->vfs_mountroot)();
1246 1.1 rmind mutex_enter(&vfs_list_lock);
1247 1.1 rmind v->vfs_refcount--;
1248 1.1 rmind if (!error) {
1249 1.1 rmind aprint_normal("root file system type: %s\n",
1250 1.1 rmind v->vfs_name);
1251 1.1 rmind break;
1252 1.1 rmind }
1253 1.1 rmind }
1254 1.1 rmind mutex_exit(&vfs_list_lock);
1255 1.1 rmind
1256 1.1 rmind if (v == NULL) {
1257 1.1 rmind vfs_print_fstypes();
1258 1.1 rmind printf("no file system for %s", device_xname(root_device));
1259 1.1 rmind if (device_class(root_device) == DV_DISK)
1260 1.1 rmind printf(" (dev 0x%llx)", (unsigned long long)rootdev);
1261 1.1 rmind printf("\n");
1262 1.1 rmind error = EFTYPE;
1263 1.1 rmind }
1264 1.1 rmind
1265 1.1 rmind done:
1266 1.1 rmind if (error && device_class(root_device) == DV_DISK) {
1267 1.91 riastrad vn_lock(rootvp, LK_EXCLUSIVE | LK_RETRY);
1268 1.1 rmind VOP_CLOSE(rootvp, FREAD, FSCRED);
1269 1.91 riastrad VOP_UNLOCK(rootvp);
1270 1.1 rmind vrele(rootvp);
1271 1.1 rmind }
1272 1.1 rmind if (error == 0) {
1273 1.53 hannken mount_iterator_t *iter;
1274 1.24 christos struct mount *mp;
1275 1.1 rmind extern struct cwdinfo cwdi0;
1276 1.1 rmind
1277 1.53 hannken mountlist_iterator_init(&iter);
1278 1.53 hannken mp = mountlist_iterator_next(iter);
1279 1.53 hannken KASSERT(mp != NULL);
1280 1.53 hannken mountlist_iterator_destroy(iter);
1281 1.53 hannken
1282 1.24 christos mp->mnt_flag |= MNT_ROOTFS;
1283 1.24 christos mp->mnt_op->vfs_refcount++;
1284 1.1 rmind
1285 1.1 rmind /*
1286 1.1 rmind * Get the vnode for '/'. Set cwdi0.cwdi_cdir to
1287 1.76 ad * reference it, and donate it the reference grabbed
1288 1.76 ad * with VFS_ROOT().
1289 1.1 rmind */
1290 1.76 ad error = VFS_ROOT(mp, LK_NONE, &rootvnode);
1291 1.1 rmind if (error)
1292 1.1 rmind panic("cannot find root vnode, error=%d", error);
1293 1.1 rmind cwdi0.cwdi_cdir = rootvnode;
1294 1.1 rmind cwdi0.cwdi_rdir = NULL;
1295 1.1 rmind
1296 1.1 rmind /*
1297 1.1 rmind * Now that root is mounted, we can fixup initproc's CWD
1298 1.1 rmind * info. All other processes are kthreads, which merely
1299 1.1 rmind * share proc0's CWD info.
1300 1.1 rmind */
1301 1.1 rmind initproc->p_cwdi->cwdi_cdir = rootvnode;
1302 1.1 rmind vref(initproc->p_cwdi->cwdi_cdir);
1303 1.1 rmind initproc->p_cwdi->cwdi_rdir = NULL;
1304 1.1 rmind /*
1305 1.1 rmind * Enable loading of modules from the filesystem
1306 1.1 rmind */
1307 1.1 rmind module_load_vfs_init();
1308 1.1 rmind
1309 1.1 rmind }
1310 1.1 rmind return (error);
1311 1.1 rmind }
1312 1.1 rmind
1313 1.1 rmind /*
1314 1.1 rmind * mount_specific_key_create --
1315 1.1 rmind * Create a key for subsystem mount-specific data.
1316 1.1 rmind */
1317 1.1 rmind int
1318 1.1 rmind mount_specific_key_create(specificdata_key_t *keyp, specificdata_dtor_t dtor)
1319 1.1 rmind {
1320 1.1 rmind
1321 1.1 rmind return specificdata_key_create(mount_specificdata_domain, keyp, dtor);
1322 1.1 rmind }
1323 1.1 rmind
1324 1.1 rmind /*
1325 1.1 rmind * mount_specific_key_delete --
1326 1.1 rmind * Delete a key for subsystem mount-specific data.
1327 1.1 rmind */
1328 1.1 rmind void
1329 1.1 rmind mount_specific_key_delete(specificdata_key_t key)
1330 1.1 rmind {
1331 1.1 rmind
1332 1.1 rmind specificdata_key_delete(mount_specificdata_domain, key);
1333 1.1 rmind }
1334 1.1 rmind
1335 1.1 rmind /*
1336 1.1 rmind * mount_initspecific --
1337 1.1 rmind * Initialize a mount's specificdata container.
1338 1.1 rmind */
1339 1.1 rmind void
1340 1.1 rmind mount_initspecific(struct mount *mp)
1341 1.1 rmind {
1342 1.22 martin int error __diagused;
1343 1.1 rmind
1344 1.1 rmind error = specificdata_init(mount_specificdata_domain,
1345 1.1 rmind &mp->mnt_specdataref);
1346 1.1 rmind KASSERT(error == 0);
1347 1.1 rmind }
1348 1.1 rmind
1349 1.1 rmind /*
1350 1.1 rmind * mount_finispecific --
1351 1.1 rmind * Finalize a mount's specificdata container.
1352 1.1 rmind */
1353 1.1 rmind void
1354 1.1 rmind mount_finispecific(struct mount *mp)
1355 1.1 rmind {
1356 1.1 rmind
1357 1.1 rmind specificdata_fini(mount_specificdata_domain, &mp->mnt_specdataref);
1358 1.1 rmind }
1359 1.1 rmind
1360 1.1 rmind /*
1361 1.1 rmind * mount_getspecific --
1362 1.1 rmind * Return mount-specific data corresponding to the specified key.
1363 1.1 rmind */
1364 1.1 rmind void *
1365 1.1 rmind mount_getspecific(struct mount *mp, specificdata_key_t key)
1366 1.1 rmind {
1367 1.1 rmind
1368 1.1 rmind return specificdata_getspecific(mount_specificdata_domain,
1369 1.1 rmind &mp->mnt_specdataref, key);
1370 1.1 rmind }
1371 1.1 rmind
1372 1.1 rmind /*
1373 1.1 rmind * mount_setspecific --
1374 1.1 rmind * Set mount-specific data corresponding to the specified key.
1375 1.1 rmind */
1376 1.1 rmind void
1377 1.1 rmind mount_setspecific(struct mount *mp, specificdata_key_t key, void *data)
1378 1.1 rmind {
1379 1.1 rmind
1380 1.1 rmind specificdata_setspecific(mount_specificdata_domain,
1381 1.1 rmind &mp->mnt_specdataref, key, data);
1382 1.1 rmind }
1383 1.1 rmind
1384 1.1 rmind /*
1385 1.1 rmind * Check to see if a filesystem is mounted on a block device.
1386 1.1 rmind */
1387 1.1 rmind int
1388 1.1 rmind vfs_mountedon(vnode_t *vp)
1389 1.1 rmind {
1390 1.1 rmind vnode_t *vq;
1391 1.1 rmind int error = 0;
1392 1.1 rmind
1393 1.1 rmind if (vp->v_type != VBLK)
1394 1.1 rmind return ENOTBLK;
1395 1.21 hannken if (spec_node_getmountedfs(vp) != NULL)
1396 1.17 hannken return EBUSY;
1397 1.92 riastrad if (spec_node_lookup_by_dev(vp->v_type, vp->v_rdev, VDEAD_NOWAIT, &vq)
1398 1.92 riastrad == 0) {
1399 1.21 hannken if (spec_node_getmountedfs(vq) != NULL)
1400 1.1 rmind error = EBUSY;
1401 1.17 hannken vrele(vq);
1402 1.1 rmind }
1403 1.17 hannken
1404 1.17 hannken return error;
1405 1.1 rmind }
1406 1.1 rmind
1407 1.1 rmind /*
1408 1.1 rmind * Check if a device pointed to by vp is mounted.
1409 1.1 rmind *
1410 1.1 rmind * Returns:
1411 1.1 rmind * EINVAL if it's not a disk
1412 1.1 rmind * EBUSY if it's a disk and mounted
1413 1.1 rmind * 0 if it's a disk and not mounted
1414 1.1 rmind */
1415 1.1 rmind int
1416 1.1 rmind rawdev_mounted(vnode_t *vp, vnode_t **bvpp)
1417 1.1 rmind {
1418 1.1 rmind vnode_t *bvp;
1419 1.1 rmind dev_t dev;
1420 1.1 rmind int d_type;
1421 1.1 rmind
1422 1.1 rmind bvp = NULL;
1423 1.1 rmind d_type = D_OTHER;
1424 1.1 rmind
1425 1.1 rmind if (iskmemvp(vp))
1426 1.1 rmind return EINVAL;
1427 1.1 rmind
1428 1.1 rmind switch (vp->v_type) {
1429 1.1 rmind case VCHR: {
1430 1.1 rmind const struct cdevsw *cdev;
1431 1.1 rmind
1432 1.7 christos dev = vp->v_rdev;
1433 1.1 rmind cdev = cdevsw_lookup(dev);
1434 1.1 rmind if (cdev != NULL) {
1435 1.1 rmind dev_t blkdev;
1436 1.1 rmind
1437 1.1 rmind blkdev = devsw_chr2blk(dev);
1438 1.1 rmind if (blkdev != NODEV) {
1439 1.1 rmind if (vfinddev(blkdev, VBLK, &bvp) != 0) {
1440 1.1 rmind d_type = (cdev->d_flag & D_TYPEMASK);
1441 1.1 rmind /* XXX: what if bvp disappears? */
1442 1.1 rmind vrele(bvp);
1443 1.1 rmind }
1444 1.1 rmind }
1445 1.1 rmind }
1446 1.1 rmind
1447 1.1 rmind break;
1448 1.1 rmind }
1449 1.1 rmind
1450 1.1 rmind case VBLK: {
1451 1.1 rmind const struct bdevsw *bdev;
1452 1.1 rmind
1453 1.7 christos dev = vp->v_rdev;
1454 1.1 rmind bdev = bdevsw_lookup(dev);
1455 1.1 rmind if (bdev != NULL)
1456 1.1 rmind d_type = (bdev->d_flag & D_TYPEMASK);
1457 1.1 rmind
1458 1.1 rmind bvp = vp;
1459 1.1 rmind
1460 1.1 rmind break;
1461 1.1 rmind }
1462 1.1 rmind
1463 1.1 rmind default:
1464 1.1 rmind break;
1465 1.1 rmind }
1466 1.1 rmind
1467 1.1 rmind if (d_type != D_DISK)
1468 1.1 rmind return EINVAL;
1469 1.1 rmind
1470 1.1 rmind if (bvpp != NULL)
1471 1.1 rmind *bvpp = bvp;
1472 1.1 rmind
1473 1.1 rmind /*
1474 1.1 rmind * XXX: This is bogus. We should be failing the request
1475 1.1 rmind * XXX: not only if this specific slice is mounted, but
1476 1.1 rmind * XXX: if it's on a disk with any other mounted slice.
1477 1.1 rmind */
1478 1.1 rmind if (vfs_mountedon(bvp))
1479 1.1 rmind return EBUSY;
1480 1.1 rmind
1481 1.1 rmind return 0;
1482 1.1 rmind }
1483 1.1 rmind
1484 1.1 rmind /*
1485 1.1 rmind * Make a 'unique' number from a mount type name.
1486 1.1 rmind */
1487 1.1 rmind long
1488 1.1 rmind makefstype(const char *type)
1489 1.1 rmind {
1490 1.1 rmind long rv;
1491 1.1 rmind
1492 1.1 rmind for (rv = 0; *type; type++) {
1493 1.1 rmind rv <<= 2;
1494 1.1 rmind rv ^= *type;
1495 1.1 rmind }
1496 1.1 rmind return rv;
1497 1.1 rmind }
1498 1.24 christos
1499 1.52 hannken static struct mountlist_entry *
1500 1.52 hannken mountlist_alloc(enum mountlist_type type, struct mount *mp)
1501 1.52 hannken {
1502 1.52 hannken struct mountlist_entry *me;
1503 1.52 hannken
1504 1.52 hannken me = kmem_zalloc(sizeof(*me), KM_SLEEP);
1505 1.52 hannken me->me_mount = mp;
1506 1.52 hannken me->me_type = type;
1507 1.52 hannken
1508 1.52 hannken return me;
1509 1.52 hannken }
1510 1.52 hannken
1511 1.52 hannken static void
1512 1.52 hannken mountlist_free(struct mountlist_entry *me)
1513 1.52 hannken {
1514 1.52 hannken
1515 1.52 hannken kmem_free(me, sizeof(*me));
1516 1.52 hannken }
1517 1.52 hannken
1518 1.52 hannken void
1519 1.52 hannken mountlist_iterator_init(mount_iterator_t **mip)
1520 1.52 hannken {
1521 1.52 hannken struct mountlist_entry *me;
1522 1.52 hannken
1523 1.52 hannken me = mountlist_alloc(ME_MARKER, NULL);
1524 1.52 hannken mutex_enter(&mountlist_lock);
1525 1.54 hannken TAILQ_INSERT_HEAD(&mountlist, me, me_list);
1526 1.52 hannken mutex_exit(&mountlist_lock);
1527 1.52 hannken *mip = (mount_iterator_t *)me;
1528 1.52 hannken }
1529 1.52 hannken
1530 1.52 hannken void
1531 1.52 hannken mountlist_iterator_destroy(mount_iterator_t *mi)
1532 1.52 hannken {
1533 1.52 hannken struct mountlist_entry *marker = &mi->mi_entry;
1534 1.52 hannken
1535 1.52 hannken if (marker->me_mount != NULL)
1536 1.56 hannken vfs_unbusy(marker->me_mount);
1537 1.52 hannken
1538 1.52 hannken mutex_enter(&mountlist_lock);
1539 1.54 hannken TAILQ_REMOVE(&mountlist, marker, me_list);
1540 1.52 hannken mutex_exit(&mountlist_lock);
1541 1.52 hannken
1542 1.52 hannken mountlist_free(marker);
1543 1.52 hannken
1544 1.52 hannken }
1545 1.52 hannken
1546 1.52 hannken /*
1547 1.52 hannken * Return the next mount or NULL for this iterator.
1548 1.52 hannken * Mark it busy on success.
1549 1.52 hannken */
1550 1.58 hannken static inline struct mount *
1551 1.58 hannken _mountlist_iterator_next(mount_iterator_t *mi, bool wait)
1552 1.52 hannken {
1553 1.52 hannken struct mountlist_entry *me, *marker = &mi->mi_entry;
1554 1.52 hannken struct mount *mp;
1555 1.58 hannken int error;
1556 1.52 hannken
1557 1.52 hannken if (marker->me_mount != NULL) {
1558 1.56 hannken vfs_unbusy(marker->me_mount);
1559 1.52 hannken marker->me_mount = NULL;
1560 1.52 hannken }
1561 1.52 hannken
1562 1.52 hannken mutex_enter(&mountlist_lock);
1563 1.52 hannken for (;;) {
1564 1.52 hannken KASSERT(marker->me_type == ME_MARKER);
1565 1.52 hannken
1566 1.52 hannken me = TAILQ_NEXT(marker, me_list);
1567 1.52 hannken if (me == NULL) {
1568 1.52 hannken /* End of list: keep marker and return. */
1569 1.52 hannken mutex_exit(&mountlist_lock);
1570 1.52 hannken return NULL;
1571 1.52 hannken }
1572 1.54 hannken TAILQ_REMOVE(&mountlist, marker, me_list);
1573 1.54 hannken TAILQ_INSERT_AFTER(&mountlist, me, marker, me_list);
1574 1.52 hannken
1575 1.52 hannken /* Skip other markers. */
1576 1.52 hannken if (me->me_type != ME_MOUNT)
1577 1.52 hannken continue;
1578 1.52 hannken
1579 1.52 hannken /* Take an initial reference for vfs_busy() below. */
1580 1.52 hannken mp = me->me_mount;
1581 1.52 hannken KASSERT(mp != NULL);
1582 1.55 hannken vfs_ref(mp);
1583 1.52 hannken mutex_exit(&mountlist_lock);
1584 1.52 hannken
1585 1.52 hannken /* Try to mark this mount busy and return on success. */
1586 1.58 hannken if (wait)
1587 1.58 hannken error = vfs_busy(mp);
1588 1.58 hannken else
1589 1.58 hannken error = vfs_trybusy(mp);
1590 1.58 hannken if (error == 0) {
1591 1.55 hannken vfs_rele(mp);
1592 1.52 hannken marker->me_mount = mp;
1593 1.52 hannken return mp;
1594 1.52 hannken }
1595 1.55 hannken vfs_rele(mp);
1596 1.52 hannken mutex_enter(&mountlist_lock);
1597 1.52 hannken }
1598 1.52 hannken }
1599 1.52 hannken
1600 1.58 hannken struct mount *
1601 1.58 hannken mountlist_iterator_next(mount_iterator_t *mi)
1602 1.58 hannken {
1603 1.58 hannken
1604 1.58 hannken return _mountlist_iterator_next(mi, true);
1605 1.58 hannken }
1606 1.58 hannken
1607 1.58 hannken struct mount *
1608 1.58 hannken mountlist_iterator_trynext(mount_iterator_t *mi)
1609 1.58 hannken {
1610 1.58 hannken
1611 1.58 hannken return _mountlist_iterator_next(mi, false);
1612 1.58 hannken }
1613 1.58 hannken
1614 1.52 hannken /*
1615 1.52 hannken * Attach new mount to the end of the mount list.
1616 1.52 hannken */
1617 1.24 christos void
1618 1.24 christos mountlist_append(struct mount *mp)
1619 1.24 christos {
1620 1.52 hannken struct mountlist_entry *me;
1621 1.52 hannken
1622 1.52 hannken me = mountlist_alloc(ME_MOUNT, mp);
1623 1.24 christos mutex_enter(&mountlist_lock);
1624 1.54 hannken TAILQ_INSERT_TAIL(&mountlist, me, me_list);
1625 1.24 christos mutex_exit(&mountlist_lock);
1626 1.24 christos }
1627 1.52 hannken
1628 1.52 hannken /*
1629 1.52 hannken * Remove mount from mount list.
1630 1.52 hannken */void
1631 1.52 hannken mountlist_remove(struct mount *mp)
1632 1.52 hannken {
1633 1.52 hannken struct mountlist_entry *me;
1634 1.52 hannken
1635 1.52 hannken mutex_enter(&mountlist_lock);
1636 1.54 hannken TAILQ_FOREACH(me, &mountlist, me_list)
1637 1.52 hannken if (me->me_type == ME_MOUNT && me->me_mount == mp)
1638 1.52 hannken break;
1639 1.52 hannken KASSERT(me != NULL);
1640 1.54 hannken TAILQ_REMOVE(&mountlist, me, me_list);
1641 1.52 hannken mutex_exit(&mountlist_lock);
1642 1.52 hannken mountlist_free(me);
1643 1.52 hannken }
1644 1.52 hannken
1645 1.52 hannken /*
1646 1.52 hannken * Unlocked variant to traverse the mountlist.
1647 1.52 hannken * To be used from DDB only.
1648 1.52 hannken */
1649 1.52 hannken struct mount *
1650 1.52 hannken _mountlist_next(struct mount *mp)
1651 1.52 hannken {
1652 1.52 hannken struct mountlist_entry *me;
1653 1.52 hannken
1654 1.52 hannken if (mp == NULL) {
1655 1.54 hannken me = TAILQ_FIRST(&mountlist);
1656 1.52 hannken } else {
1657 1.54 hannken TAILQ_FOREACH(me, &mountlist, me_list)
1658 1.52 hannken if (me->me_type == ME_MOUNT && me->me_mount == mp)
1659 1.52 hannken break;
1660 1.52 hannken if (me != NULL)
1661 1.52 hannken me = TAILQ_NEXT(me, me_list);
1662 1.52 hannken }
1663 1.52 hannken
1664 1.52 hannken while (me != NULL && me->me_type != ME_MOUNT)
1665 1.52 hannken me = TAILQ_NEXT(me, me_list);
1666 1.52 hannken
1667 1.52 hannken return (me ? me->me_mount : NULL);
1668 1.52 hannken }
1669