vfs_trans.c revision 1.34 1 1.34 pooka /* $NetBSD: vfs_trans.c,v 1.34 2015/08/24 22:50:32 pooka Exp $ */
2 1.1 hannken
3 1.1 hannken /*-
4 1.1 hannken * Copyright (c) 2007 The NetBSD Foundation, Inc.
5 1.1 hannken * All rights reserved.
6 1.1 hannken *
7 1.1 hannken * This code is derived from software contributed to The NetBSD Foundation
8 1.1 hannken * by Juergen Hannken-Illjes.
9 1.1 hannken *
10 1.1 hannken * Redistribution and use in source and binary forms, with or without
11 1.1 hannken * modification, are permitted provided that the following conditions
12 1.1 hannken * are met:
13 1.1 hannken * 1. Redistributions of source code must retain the above copyright
14 1.1 hannken * notice, this list of conditions and the following disclaimer.
15 1.1 hannken * 2. Redistributions in binary form must reproduce the above copyright
16 1.1 hannken * notice, this list of conditions and the following disclaimer in the
17 1.1 hannken * documentation and/or other materials provided with the distribution.
18 1.1 hannken *
19 1.1 hannken * THIS SOFTWARE IS PROVIDED BY THE NETBSD FOUNDATION, INC. AND CONTRIBUTORS
20 1.1 hannken * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
21 1.1 hannken * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
22 1.1 hannken * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE FOUNDATION OR CONTRIBUTORS
23 1.1 hannken * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
24 1.1 hannken * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
25 1.1 hannken * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
26 1.1 hannken * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
27 1.1 hannken * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
28 1.1 hannken * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
29 1.1 hannken * POSSIBILITY OF SUCH DAMAGE.
30 1.1 hannken */
31 1.1 hannken
32 1.1 hannken #include <sys/cdefs.h>
33 1.34 pooka __KERNEL_RCSID(0, "$NetBSD: vfs_trans.c,v 1.34 2015/08/24 22:50:32 pooka Exp $");
34 1.1 hannken
35 1.1 hannken /*
36 1.1 hannken * File system transaction operations.
37 1.1 hannken */
38 1.1 hannken
39 1.34 pooka #ifdef _KERNEL_OPT
40 1.1 hannken #include "opt_ddb.h"
41 1.34 pooka #endif
42 1.1 hannken
43 1.1 hannken #include <sys/param.h>
44 1.1 hannken #include <sys/systm.h>
45 1.26 hannken #include <sys/atomic.h>
46 1.24 pooka #include <sys/buf.h>
47 1.12 hannken #include <sys/kmem.h>
48 1.1 hannken #include <sys/mount.h>
49 1.26 hannken #include <sys/pserialize.h>
50 1.1 hannken #include <sys/vnode.h>
51 1.1 hannken #define _FSTRANS_API_PRIVATE
52 1.1 hannken #include <sys/fstrans.h>
53 1.10 ad #include <sys/proc.h>
54 1.1 hannken
55 1.12 hannken #include <miscfs/specfs/specdev.h>
56 1.1 hannken
57 1.16 ad struct fscow_handler {
58 1.26 hannken LIST_ENTRY(fscow_handler) ch_list;
59 1.16 ad int (*ch_func)(void *, struct buf *, bool);
60 1.16 ad void *ch_arg;
61 1.16 ad };
62 1.1 hannken struct fstrans_lwp_info {
63 1.1 hannken struct fstrans_lwp_info *fli_succ;
64 1.26 hannken struct lwp *fli_self;
65 1.1 hannken struct mount *fli_mount;
66 1.20 hannken int fli_trans_cnt;
67 1.20 hannken int fli_cow_cnt;
68 1.1 hannken enum fstrans_lock_type fli_lock_type;
69 1.26 hannken LIST_ENTRY(fstrans_lwp_info) fli_list;
70 1.1 hannken };
71 1.1 hannken struct fstrans_mount_info {
72 1.1 hannken enum fstrans_state fmi_state;
73 1.26 hannken unsigned int fmi_ref_cnt;
74 1.26 hannken bool fmi_cow_change;
75 1.26 hannken LIST_HEAD(, fscow_handler) fmi_cow_handler;
76 1.1 hannken };
77 1.1 hannken
78 1.26 hannken static specificdata_key_t lwp_data_key; /* Our specific data key. */
79 1.4 ad static kmutex_t vfs_suspend_lock; /* Serialize suspensions. */
80 1.26 hannken static kmutex_t fstrans_lock; /* Fstrans big lock. */
81 1.26 hannken static kcondvar_t fstrans_state_cv; /* Fstrans or cow state changed. */
82 1.26 hannken static kcondvar_t fstrans_count_cv; /* Fstrans or cow count changed. */
83 1.26 hannken static pserialize_t fstrans_psz; /* Pserialize state. */
84 1.26 hannken static LIST_HEAD(fstrans_lwp_head, fstrans_lwp_info) fstrans_fli_head;
85 1.26 hannken /* List of all fstrans_lwp_info. */
86 1.1 hannken
87 1.1 hannken static void fstrans_lwp_dtor(void *);
88 1.26 hannken static void fstrans_mount_dtor(struct mount *);
89 1.26 hannken static struct fstrans_lwp_info *fstrans_get_lwp_info(struct mount *, bool);
90 1.26 hannken static bool grant_lock(const enum fstrans_state, const enum fstrans_lock_type);
91 1.26 hannken static bool state_change_done(const struct mount *);
92 1.26 hannken static bool cow_state_change_done(const struct mount *);
93 1.26 hannken static void cow_change_enter(const struct mount *);
94 1.26 hannken static void cow_change_done(const struct mount *);
95 1.1 hannken
96 1.1 hannken /*
97 1.26 hannken * Initialize.
98 1.1 hannken */
99 1.1 hannken void
100 1.1 hannken fstrans_init(void)
101 1.1 hannken {
102 1.28 martin int error __diagused;
103 1.1 hannken
104 1.1 hannken error = lwp_specific_key_create(&lwp_data_key, fstrans_lwp_dtor);
105 1.1 hannken KASSERT(error == 0);
106 1.7 ad
107 1.4 ad mutex_init(&vfs_suspend_lock, MUTEX_DEFAULT, IPL_NONE);
108 1.26 hannken mutex_init(&fstrans_lock, MUTEX_DEFAULT, IPL_NONE);
109 1.26 hannken cv_init(&fstrans_state_cv, "fstchg");
110 1.26 hannken cv_init(&fstrans_count_cv, "fstcnt");
111 1.26 hannken fstrans_psz = pserialize_create();
112 1.26 hannken LIST_INIT(&fstrans_fli_head);
113 1.1 hannken }
114 1.1 hannken
115 1.1 hannken /*
116 1.26 hannken * Deallocate lwp state.
117 1.1 hannken */
118 1.1 hannken static void
119 1.1 hannken fstrans_lwp_dtor(void *arg)
120 1.1 hannken {
121 1.1 hannken struct fstrans_lwp_info *fli, *fli_next;
122 1.1 hannken
123 1.1 hannken for (fli = arg; fli; fli = fli_next) {
124 1.20 hannken KASSERT(fli->fli_trans_cnt == 0);
125 1.20 hannken KASSERT(fli->fli_cow_cnt == 0);
126 1.26 hannken if (fli->fli_mount != NULL)
127 1.26 hannken fstrans_mount_dtor(fli->fli_mount);
128 1.1 hannken fli_next = fli->fli_succ;
129 1.30 hannken fli->fli_mount = NULL;
130 1.30 hannken membar_sync();
131 1.30 hannken fli->fli_self = NULL;
132 1.1 hannken }
133 1.26 hannken }
134 1.26 hannken
135 1.26 hannken /*
136 1.26 hannken * Dereference mount state.
137 1.26 hannken */
138 1.26 hannken static void
139 1.26 hannken fstrans_mount_dtor(struct mount *mp)
140 1.26 hannken {
141 1.26 hannken struct fstrans_mount_info *fmi;
142 1.26 hannken
143 1.26 hannken fmi = mp->mnt_transinfo;
144 1.26 hannken if (atomic_dec_uint_nv(&fmi->fmi_ref_cnt) > 0)
145 1.26 hannken return;
146 1.26 hannken
147 1.26 hannken KASSERT(fmi->fmi_state == FSTRANS_NORMAL);
148 1.26 hannken KASSERT(LIST_FIRST(&fmi->fmi_cow_handler) == NULL);
149 1.26 hannken
150 1.26 hannken kmem_free(fmi, sizeof(*fmi));
151 1.26 hannken mp->mnt_iflag &= ~IMNT_HAS_TRANS;
152 1.26 hannken mp->mnt_transinfo = NULL;
153 1.26 hannken
154 1.26 hannken vfs_destroy(mp);
155 1.1 hannken }
156 1.1 hannken
157 1.1 hannken /*
158 1.26 hannken * Allocate mount state.
159 1.1 hannken */
160 1.16 ad int
161 1.16 ad fstrans_mount(struct mount *mp)
162 1.1 hannken {
163 1.26 hannken int error;
164 1.31 matt struct fstrans_mount_info *newfmi;
165 1.16 ad
166 1.26 hannken error = vfs_busy(mp, NULL);
167 1.26 hannken if (error)
168 1.26 hannken return error;
169 1.32 pooka newfmi = kmem_alloc(sizeof(*newfmi), KM_SLEEP);
170 1.31 matt newfmi->fmi_state = FSTRANS_NORMAL;
171 1.31 matt newfmi->fmi_ref_cnt = 1;
172 1.31 matt LIST_INIT(&newfmi->fmi_cow_handler);
173 1.31 matt newfmi->fmi_cow_change = false;
174 1.16 ad
175 1.31 matt mp->mnt_transinfo = newfmi;
176 1.16 ad mp->mnt_iflag |= IMNT_HAS_TRANS;
177 1.1 hannken
178 1.26 hannken vfs_unbusy(mp, true, NULL);
179 1.26 hannken
180 1.16 ad return 0;
181 1.1 hannken }
182 1.1 hannken
183 1.1 hannken /*
184 1.26 hannken * Deallocate mount state.
185 1.1 hannken */
186 1.16 ad void
187 1.16 ad fstrans_unmount(struct mount *mp)
188 1.1 hannken {
189 1.1 hannken
190 1.26 hannken KASSERT(mp->mnt_transinfo != NULL);
191 1.1 hannken
192 1.26 hannken fstrans_mount_dtor(mp);
193 1.1 hannken }
194 1.1 hannken
195 1.1 hannken /*
196 1.26 hannken * Retrieve the per lwp info for this mount allocating if necessary.
197 1.20 hannken */
198 1.20 hannken static struct fstrans_lwp_info *
199 1.26 hannken fstrans_get_lwp_info(struct mount *mp, bool do_alloc)
200 1.20 hannken {
201 1.26 hannken struct fstrans_lwp_info *fli, *res;
202 1.26 hannken struct fstrans_mount_info *fmi;
203 1.20 hannken
204 1.26 hannken /*
205 1.26 hannken * Scan our list for a match clearing entries whose mount is gone.
206 1.26 hannken */
207 1.26 hannken res = NULL;
208 1.20 hannken for (fli = lwp_getspecific(lwp_data_key); fli; fli = fli->fli_succ) {
209 1.26 hannken if (fli->fli_mount == mp) {
210 1.26 hannken KASSERT(res == NULL);
211 1.26 hannken res = fli;
212 1.26 hannken } else if (fli->fli_mount != NULL &&
213 1.26 hannken (fli->fli_mount->mnt_iflag & IMNT_GONE) != 0 &&
214 1.26 hannken fli->fli_trans_cnt == 0 && fli->fli_cow_cnt == 0) {
215 1.26 hannken fstrans_mount_dtor(fli->fli_mount);
216 1.26 hannken fli->fli_mount = NULL;
217 1.26 hannken }
218 1.20 hannken }
219 1.26 hannken if (__predict_true(res != NULL))
220 1.26 hannken return res;
221 1.20 hannken
222 1.26 hannken if (! do_alloc)
223 1.26 hannken return NULL;
224 1.26 hannken
225 1.26 hannken /*
226 1.26 hannken * Try to reuse a cleared entry or allocate a new one.
227 1.26 hannken */
228 1.26 hannken for (fli = lwp_getspecific(lwp_data_key); fli; fli = fli->fli_succ) {
229 1.26 hannken if (fli->fli_mount == NULL) {
230 1.26 hannken KASSERT(fli->fli_trans_cnt == 0);
231 1.26 hannken KASSERT(fli->fli_cow_cnt == 0);
232 1.26 hannken break;
233 1.26 hannken }
234 1.26 hannken }
235 1.26 hannken if (fli == NULL) {
236 1.30 hannken mutex_enter(&fstrans_lock);
237 1.30 hannken LIST_FOREACH(fli, &fstrans_fli_head, fli_list) {
238 1.30 hannken if (fli->fli_self == NULL) {
239 1.30 hannken KASSERT(fli->fli_trans_cnt == 0);
240 1.30 hannken KASSERT(fli->fli_cow_cnt == 0);
241 1.30 hannken fli->fli_self = curlwp;
242 1.30 hannken fli->fli_succ = lwp_getspecific(lwp_data_key);
243 1.30 hannken lwp_setspecific(lwp_data_key, fli);
244 1.30 hannken break;
245 1.30 hannken }
246 1.30 hannken }
247 1.30 hannken mutex_exit(&fstrans_lock);
248 1.30 hannken }
249 1.30 hannken if (fli == NULL) {
250 1.30 hannken fli = kmem_alloc(sizeof(*fli), KM_SLEEP);
251 1.26 hannken mutex_enter(&fstrans_lock);
252 1.26 hannken memset(fli, 0, sizeof(*fli));
253 1.26 hannken fli->fli_self = curlwp;
254 1.26 hannken LIST_INSERT_HEAD(&fstrans_fli_head, fli, fli_list);
255 1.26 hannken mutex_exit(&fstrans_lock);
256 1.26 hannken fli->fli_succ = lwp_getspecific(lwp_data_key);
257 1.26 hannken lwp_setspecific(lwp_data_key, fli);
258 1.20 hannken }
259 1.20 hannken
260 1.26 hannken /*
261 1.26 hannken * Attach the entry to the mount.
262 1.26 hannken */
263 1.26 hannken fmi = mp->mnt_transinfo;
264 1.26 hannken fli->fli_mount = mp;
265 1.26 hannken atomic_inc_uint(&fmi->fmi_ref_cnt);
266 1.26 hannken
267 1.26 hannken return fli;
268 1.26 hannken }
269 1.26 hannken
270 1.26 hannken /*
271 1.26 hannken * Check if this lock type is granted at this state.
272 1.26 hannken */
273 1.26 hannken static bool
274 1.26 hannken grant_lock(const enum fstrans_state state, const enum fstrans_lock_type type)
275 1.26 hannken {
276 1.20 hannken
277 1.26 hannken if (__predict_true(state == FSTRANS_NORMAL))
278 1.26 hannken return true;
279 1.26 hannken if (type == FSTRANS_EXCL)
280 1.26 hannken return true;
281 1.26 hannken if (state == FSTRANS_SUSPENDING && type == FSTRANS_LAZY)
282 1.26 hannken return true;
283 1.20 hannken
284 1.26 hannken return false;
285 1.20 hannken }
286 1.20 hannken
287 1.20 hannken /*
288 1.1 hannken * Start a transaction. If this thread already has a transaction on this
289 1.1 hannken * file system increment the reference counter.
290 1.1 hannken */
291 1.1 hannken int
292 1.1 hannken _fstrans_start(struct mount *mp, enum fstrans_lock_type lock_type, int wait)
293 1.1 hannken {
294 1.26 hannken int s;
295 1.20 hannken struct fstrans_lwp_info *fli;
296 1.1 hannken struct fstrans_mount_info *fmi;
297 1.1 hannken
298 1.18 yamt ASSERT_SLEEPABLE();
299 1.1 hannken
300 1.1 hannken if (mp == NULL || (mp->mnt_iflag & IMNT_HAS_TRANS) == 0)
301 1.1 hannken return 0;
302 1.1 hannken
303 1.26 hannken fli = fstrans_get_lwp_info(mp, true);
304 1.1 hannken
305 1.20 hannken if (fli->fli_trans_cnt > 0) {
306 1.26 hannken KASSERT(lock_type != FSTRANS_EXCL);
307 1.20 hannken fli->fli_trans_cnt += 1;
308 1.26 hannken
309 1.20 hannken return 0;
310 1.1 hannken }
311 1.1 hannken
312 1.26 hannken s = pserialize_read_enter();
313 1.16 ad fmi = mp->mnt_transinfo;
314 1.26 hannken if (__predict_true(grant_lock(fmi->fmi_state, lock_type))) {
315 1.26 hannken fli->fli_trans_cnt = 1;
316 1.26 hannken fli->fli_lock_type = lock_type;
317 1.26 hannken pserialize_read_exit(s);
318 1.1 hannken
319 1.26 hannken return 0;
320 1.26 hannken }
321 1.26 hannken pserialize_read_exit(s);
322 1.8 hannken
323 1.26 hannken if (! wait)
324 1.8 hannken return EBUSY;
325 1.1 hannken
326 1.26 hannken mutex_enter(&fstrans_lock);
327 1.26 hannken while (! grant_lock(fmi->fmi_state, lock_type))
328 1.26 hannken cv_wait(&fstrans_state_cv, &fstrans_lock);
329 1.20 hannken fli->fli_trans_cnt = 1;
330 1.20 hannken fli->fli_lock_type = lock_type;
331 1.26 hannken mutex_exit(&fstrans_lock);
332 1.1 hannken
333 1.1 hannken return 0;
334 1.1 hannken }
335 1.1 hannken
336 1.1 hannken /*
337 1.1 hannken * Finish a transaction.
338 1.1 hannken */
339 1.1 hannken void
340 1.1 hannken fstrans_done(struct mount *mp)
341 1.1 hannken {
342 1.26 hannken int s;
343 1.1 hannken struct fstrans_lwp_info *fli;
344 1.1 hannken struct fstrans_mount_info *fmi;
345 1.1 hannken
346 1.1 hannken if (mp == NULL || (mp->mnt_iflag & IMNT_HAS_TRANS) == 0)
347 1.1 hannken return;
348 1.1 hannken
349 1.26 hannken fli = fstrans_get_lwp_info(mp, false);
350 1.26 hannken KASSERT(fli != NULL);
351 1.26 hannken KASSERT(fli->fli_trans_cnt > 0);
352 1.26 hannken
353 1.26 hannken if (fli->fli_trans_cnt > 1) {
354 1.26 hannken fli->fli_trans_cnt -= 1;
355 1.26 hannken
356 1.26 hannken return;
357 1.1 hannken }
358 1.1 hannken
359 1.26 hannken s = pserialize_read_enter();
360 1.26 hannken fmi = mp->mnt_transinfo;
361 1.26 hannken if (__predict_true(fmi->fmi_state == FSTRANS_NORMAL)) {
362 1.26 hannken fli->fli_trans_cnt = 0;
363 1.26 hannken pserialize_read_exit(s);
364 1.26 hannken
365 1.26 hannken return;
366 1.26 hannken }
367 1.26 hannken pserialize_read_exit(s);
368 1.20 hannken
369 1.26 hannken mutex_enter(&fstrans_lock);
370 1.26 hannken fli->fli_trans_cnt = 0;
371 1.26 hannken cv_signal(&fstrans_count_cv);
372 1.26 hannken mutex_exit(&fstrans_lock);
373 1.1 hannken }
374 1.1 hannken
375 1.1 hannken /*
376 1.1 hannken * Check if this thread has an exclusive lock.
377 1.1 hannken */
378 1.1 hannken int
379 1.1 hannken fstrans_is_owner(struct mount *mp)
380 1.1 hannken {
381 1.1 hannken struct fstrans_lwp_info *fli;
382 1.1 hannken
383 1.26 hannken if (mp == NULL || (mp->mnt_iflag & IMNT_HAS_TRANS) == 0)
384 1.1 hannken return 0;
385 1.1 hannken
386 1.26 hannken fli = fstrans_get_lwp_info(mp, false);
387 1.20 hannken if (fli == NULL || fli->fli_trans_cnt == 0)
388 1.1 hannken return 0;
389 1.1 hannken
390 1.1 hannken KASSERT(fli->fli_mount == mp);
391 1.20 hannken KASSERT(fli->fli_trans_cnt > 0);
392 1.26 hannken
393 1.2 hannken return (fli->fli_lock_type == FSTRANS_EXCL);
394 1.1 hannken }
395 1.1 hannken
396 1.1 hannken /*
397 1.26 hannken * True, if no thread is in a transaction not granted at the current state.
398 1.26 hannken */
399 1.26 hannken static bool
400 1.26 hannken state_change_done(const struct mount *mp)
401 1.26 hannken {
402 1.26 hannken struct fstrans_lwp_info *fli;
403 1.26 hannken struct fstrans_mount_info *fmi;
404 1.26 hannken
405 1.26 hannken KASSERT(mutex_owned(&fstrans_lock));
406 1.26 hannken
407 1.26 hannken fmi = mp->mnt_transinfo;
408 1.26 hannken LIST_FOREACH(fli, &fstrans_fli_head, fli_list) {
409 1.26 hannken if (fli->fli_mount != mp)
410 1.26 hannken continue;
411 1.26 hannken if (fli->fli_trans_cnt == 0)
412 1.26 hannken continue;
413 1.26 hannken if (grant_lock(fmi->fmi_state, fli->fli_lock_type))
414 1.26 hannken continue;
415 1.26 hannken
416 1.26 hannken return false;
417 1.26 hannken }
418 1.26 hannken
419 1.26 hannken return true;
420 1.26 hannken }
421 1.26 hannken
422 1.26 hannken /*
423 1.1 hannken * Set new file system state.
424 1.1 hannken */
425 1.1 hannken int
426 1.1 hannken fstrans_setstate(struct mount *mp, enum fstrans_state new_state)
427 1.1 hannken {
428 1.26 hannken int error;
429 1.26 hannken enum fstrans_state old_state;
430 1.1 hannken struct fstrans_mount_info *fmi;
431 1.1 hannken
432 1.16 ad fmi = mp->mnt_transinfo;
433 1.26 hannken old_state = fmi->fmi_state;
434 1.26 hannken if (old_state == new_state)
435 1.26 hannken return 0;
436 1.1 hannken
437 1.26 hannken mutex_enter(&fstrans_lock);
438 1.26 hannken fmi->fmi_state = new_state;
439 1.26 hannken pserialize_perform(fstrans_psz);
440 1.26 hannken
441 1.26 hannken /*
442 1.26 hannken * All threads see the new state now.
443 1.26 hannken * Wait for transactions invalid at this state to leave.
444 1.26 hannken */
445 1.26 hannken error = 0;
446 1.26 hannken while (! state_change_done(mp)) {
447 1.26 hannken error = cv_wait_sig(&fstrans_count_cv, &fstrans_lock);
448 1.26 hannken if (error) {
449 1.26 hannken new_state = fmi->fmi_state = FSTRANS_NORMAL;
450 1.26 hannken break;
451 1.26 hannken }
452 1.26 hannken }
453 1.26 hannken cv_broadcast(&fstrans_state_cv);
454 1.26 hannken mutex_exit(&fstrans_lock);
455 1.1 hannken
456 1.26 hannken if (old_state != new_state) {
457 1.26 hannken if (old_state == FSTRANS_NORMAL)
458 1.9 hannken fstrans_start(mp, FSTRANS_EXCL);
459 1.26 hannken if (new_state == FSTRANS_NORMAL)
460 1.1 hannken fstrans_done(mp);
461 1.1 hannken }
462 1.1 hannken
463 1.26 hannken return error;
464 1.1 hannken }
465 1.1 hannken
466 1.1 hannken /*
467 1.26 hannken * Get current file system state.
468 1.1 hannken */
469 1.1 hannken enum fstrans_state
470 1.1 hannken fstrans_getstate(struct mount *mp)
471 1.1 hannken {
472 1.1 hannken struct fstrans_mount_info *fmi;
473 1.1 hannken
474 1.16 ad fmi = mp->mnt_transinfo;
475 1.26 hannken KASSERT(fmi != NULL);
476 1.1 hannken
477 1.1 hannken return fmi->fmi_state;
478 1.1 hannken }
479 1.1 hannken
480 1.1 hannken /*
481 1.1 hannken * Request a filesystem to suspend all operations.
482 1.1 hannken */
483 1.1 hannken int
484 1.1 hannken vfs_suspend(struct mount *mp, int nowait)
485 1.1 hannken {
486 1.4 ad int error;
487 1.1 hannken
488 1.4 ad if (nowait) {
489 1.4 ad if (!mutex_tryenter(&vfs_suspend_lock))
490 1.4 ad return EWOULDBLOCK;
491 1.4 ad } else
492 1.4 ad mutex_enter(&vfs_suspend_lock);
493 1.1 hannken
494 1.3 hannken mutex_enter(&syncer_mutex);
495 1.1 hannken if ((error = VFS_SUSPENDCTL(mp, SUSPEND_SUSPEND)) != 0) {
496 1.3 hannken mutex_exit(&syncer_mutex);
497 1.4 ad mutex_exit(&vfs_suspend_lock);
498 1.1 hannken }
499 1.1 hannken
500 1.1 hannken return error;
501 1.1 hannken }
502 1.1 hannken
503 1.1 hannken /*
504 1.1 hannken * Request a filesystem to resume all operations.
505 1.1 hannken */
506 1.1 hannken void
507 1.1 hannken vfs_resume(struct mount *mp)
508 1.1 hannken {
509 1.1 hannken
510 1.1 hannken VFS_SUSPENDCTL(mp, SUSPEND_RESUME);
511 1.3 hannken mutex_exit(&syncer_mutex);
512 1.4 ad mutex_exit(&vfs_suspend_lock);
513 1.1 hannken }
514 1.1 hannken
515 1.1 hannken
516 1.26 hannken /*
517 1.26 hannken * True, if no thread is running a cow handler.
518 1.26 hannken */
519 1.26 hannken static bool
520 1.26 hannken cow_state_change_done(const struct mount *mp)
521 1.1 hannken {
522 1.1 hannken struct fstrans_lwp_info *fli;
523 1.28 martin struct fstrans_mount_info *fmi __diagused;
524 1.26 hannken
525 1.26 hannken fmi = mp->mnt_transinfo;
526 1.1 hannken
527 1.26 hannken KASSERT(mutex_owned(&fstrans_lock));
528 1.26 hannken KASSERT(fmi->fmi_cow_change);
529 1.26 hannken
530 1.26 hannken LIST_FOREACH(fli, &fstrans_fli_head, fli_list) {
531 1.26 hannken if (fli->fli_mount != mp)
532 1.26 hannken continue;
533 1.26 hannken if (fli->fli_cow_cnt == 0)
534 1.1 hannken continue;
535 1.26 hannken
536 1.26 hannken return false;
537 1.1 hannken }
538 1.26 hannken
539 1.26 hannken return true;
540 1.1 hannken }
541 1.1 hannken
542 1.26 hannken /*
543 1.26 hannken * Prepare for changing this mounts cow list.
544 1.26 hannken * Returns with fstrans_lock locked.
545 1.26 hannken */
546 1.1 hannken static void
547 1.26 hannken cow_change_enter(const struct mount *mp)
548 1.1 hannken {
549 1.1 hannken struct fstrans_mount_info *fmi;
550 1.1 hannken
551 1.16 ad fmi = mp->mnt_transinfo;
552 1.1 hannken
553 1.26 hannken mutex_enter(&fstrans_lock);
554 1.26 hannken
555 1.26 hannken /*
556 1.26 hannken * Wait for other threads changing the list.
557 1.26 hannken */
558 1.26 hannken while (fmi->fmi_cow_change)
559 1.26 hannken cv_wait(&fstrans_state_cv, &fstrans_lock);
560 1.26 hannken
561 1.26 hannken /*
562 1.26 hannken * Wait until all threads are aware of a state change.
563 1.26 hannken */
564 1.26 hannken fmi->fmi_cow_change = true;
565 1.26 hannken pserialize_perform(fstrans_psz);
566 1.26 hannken
567 1.26 hannken while (! cow_state_change_done(mp))
568 1.26 hannken cv_wait(&fstrans_count_cv, &fstrans_lock);
569 1.1 hannken }
570 1.1 hannken
571 1.26 hannken /*
572 1.26 hannken * Done changing this mounts cow list.
573 1.26 hannken */
574 1.26 hannken static void
575 1.26 hannken cow_change_done(const struct mount *mp)
576 1.1 hannken {
577 1.26 hannken struct fstrans_mount_info *fmi;
578 1.26 hannken
579 1.26 hannken KASSERT(mutex_owned(&fstrans_lock));
580 1.26 hannken
581 1.26 hannken fmi = mp->mnt_transinfo;
582 1.26 hannken
583 1.26 hannken fmi->fmi_cow_change = false;
584 1.26 hannken pserialize_perform(fstrans_psz);
585 1.1 hannken
586 1.26 hannken cv_broadcast(&fstrans_state_cv);
587 1.1 hannken
588 1.26 hannken mutex_exit(&fstrans_lock);
589 1.1 hannken }
590 1.12 hannken
591 1.26 hannken /*
592 1.26 hannken * Add a handler to this mount.
593 1.26 hannken */
594 1.12 hannken int
595 1.15 hannken fscow_establish(struct mount *mp, int (*func)(void *, struct buf *, bool),
596 1.15 hannken void *arg)
597 1.12 hannken {
598 1.16 ad struct fstrans_mount_info *fmi;
599 1.31 matt struct fscow_handler *newch;
600 1.12 hannken
601 1.16 ad if ((mp->mnt_iflag & IMNT_HAS_TRANS) == 0)
602 1.16 ad return EINVAL;
603 1.16 ad
604 1.16 ad fmi = mp->mnt_transinfo;
605 1.26 hannken KASSERT(fmi != NULL);
606 1.12 hannken
607 1.32 pooka newch = kmem_alloc(sizeof(*newch), KM_SLEEP);
608 1.31 matt newch->ch_func = func;
609 1.31 matt newch->ch_arg = arg;
610 1.26 hannken
611 1.26 hannken cow_change_enter(mp);
612 1.31 matt LIST_INSERT_HEAD(&fmi->fmi_cow_handler, newch, ch_list);
613 1.26 hannken cow_change_done(mp);
614 1.12 hannken
615 1.12 hannken return 0;
616 1.12 hannken }
617 1.12 hannken
618 1.26 hannken /*
619 1.26 hannken * Remove a handler from this mount.
620 1.26 hannken */
621 1.12 hannken int
622 1.15 hannken fscow_disestablish(struct mount *mp, int (*func)(void *, struct buf *, bool),
623 1.12 hannken void *arg)
624 1.12 hannken {
625 1.16 ad struct fstrans_mount_info *fmi;
626 1.12 hannken struct fscow_handler *hp = NULL;
627 1.12 hannken
628 1.16 ad if ((mp->mnt_iflag & IMNT_HAS_TRANS) == 0)
629 1.12 hannken return EINVAL;
630 1.12 hannken
631 1.16 ad fmi = mp->mnt_transinfo;
632 1.26 hannken KASSERT(fmi != NULL);
633 1.16 ad
634 1.26 hannken cow_change_enter(mp);
635 1.26 hannken LIST_FOREACH(hp, &fmi->fmi_cow_handler, ch_list)
636 1.12 hannken if (hp->ch_func == func && hp->ch_arg == arg)
637 1.12 hannken break;
638 1.12 hannken if (hp != NULL) {
639 1.26 hannken LIST_REMOVE(hp, ch_list);
640 1.12 hannken kmem_free(hp, sizeof(*hp));
641 1.12 hannken }
642 1.26 hannken cow_change_done(mp);
643 1.12 hannken
644 1.12 hannken return hp ? 0 : EINVAL;
645 1.12 hannken }
646 1.12 hannken
647 1.26 hannken /*
648 1.26 hannken * Check for need to copy block that is about to be written.
649 1.26 hannken */
650 1.12 hannken int
651 1.15 hannken fscow_run(struct buf *bp, bool data_valid)
652 1.12 hannken {
653 1.26 hannken int error, s;
654 1.12 hannken struct mount *mp;
655 1.20 hannken struct fstrans_lwp_info *fli;
656 1.16 ad struct fstrans_mount_info *fmi;
657 1.12 hannken struct fscow_handler *hp;
658 1.12 hannken
659 1.26 hannken /*
660 1.26 hannken * First check if we need run the copy-on-write handler.
661 1.26 hannken */
662 1.17 hannken if ((bp->b_flags & B_COWDONE))
663 1.26 hannken return 0;
664 1.26 hannken if (bp->b_vp == NULL) {
665 1.26 hannken bp->b_flags |= B_COWDONE;
666 1.26 hannken return 0;
667 1.26 hannken }
668 1.12 hannken if (bp->b_vp->v_type == VBLK)
669 1.27 hannken mp = spec_node_getmountedfs(bp->b_vp);
670 1.12 hannken else
671 1.12 hannken mp = bp->b_vp->v_mount;
672 1.26 hannken if (mp == NULL || (mp->mnt_iflag & IMNT_HAS_TRANS) == 0) {
673 1.26 hannken bp->b_flags |= B_COWDONE;
674 1.26 hannken return 0;
675 1.26 hannken }
676 1.12 hannken
677 1.26 hannken fli = fstrans_get_lwp_info(mp, true);
678 1.16 ad fmi = mp->mnt_transinfo;
679 1.12 hannken
680 1.26 hannken /*
681 1.26 hannken * On non-recursed run check if other threads
682 1.26 hannken * want to change the list.
683 1.26 hannken */
684 1.26 hannken if (fli->fli_cow_cnt == 0) {
685 1.26 hannken s = pserialize_read_enter();
686 1.26 hannken if (__predict_false(fmi->fmi_cow_change)) {
687 1.26 hannken pserialize_read_exit(s);
688 1.26 hannken mutex_enter(&fstrans_lock);
689 1.26 hannken while (fmi->fmi_cow_change)
690 1.26 hannken cv_wait(&fstrans_state_cv, &fstrans_lock);
691 1.26 hannken fli->fli_cow_cnt = 1;
692 1.26 hannken mutex_exit(&fstrans_lock);
693 1.26 hannken } else {
694 1.26 hannken fli->fli_cow_cnt = 1;
695 1.26 hannken pserialize_read_exit(s);
696 1.26 hannken }
697 1.26 hannken } else
698 1.26 hannken fli->fli_cow_cnt += 1;
699 1.20 hannken
700 1.26 hannken /*
701 1.26 hannken * Run all copy-on-write handlers, stop on error.
702 1.26 hannken */
703 1.26 hannken error = 0;
704 1.26 hannken LIST_FOREACH(hp, &fmi->fmi_cow_handler, ch_list)
705 1.15 hannken if ((error = (*hp->ch_func)(hp->ch_arg, bp, data_valid)) != 0)
706 1.12 hannken break;
707 1.17 hannken if (error == 0)
708 1.17 hannken bp->b_flags |= B_COWDONE;
709 1.15 hannken
710 1.26 hannken /*
711 1.26 hannken * Check if other threads want to change the list.
712 1.26 hannken */
713 1.26 hannken if (fli->fli_cow_cnt > 1) {
714 1.26 hannken fli->fli_cow_cnt -= 1;
715 1.26 hannken } else {
716 1.26 hannken s = pserialize_read_enter();
717 1.26 hannken if (__predict_false(fmi->fmi_cow_change)) {
718 1.26 hannken pserialize_read_exit(s);
719 1.26 hannken mutex_enter(&fstrans_lock);
720 1.26 hannken fli->fli_cow_cnt = 0;
721 1.26 hannken cv_signal(&fstrans_count_cv);
722 1.26 hannken mutex_exit(&fstrans_lock);
723 1.26 hannken } else {
724 1.26 hannken fli->fli_cow_cnt = 0;
725 1.26 hannken pserialize_read_exit(s);
726 1.26 hannken }
727 1.26 hannken }
728 1.26 hannken
729 1.12 hannken return error;
730 1.12 hannken }
731 1.26 hannken
732 1.26 hannken #if defined(DDB)
733 1.26 hannken void fstrans_dump(int);
734 1.26 hannken
735 1.26 hannken static void
736 1.26 hannken fstrans_print_lwp(struct proc *p, struct lwp *l, int verbose)
737 1.26 hannken {
738 1.26 hannken char prefix[9];
739 1.26 hannken struct fstrans_lwp_info *fli;
740 1.26 hannken
741 1.26 hannken snprintf(prefix, sizeof(prefix), "%d.%d", p->p_pid, l->l_lid);
742 1.26 hannken LIST_FOREACH(fli, &fstrans_fli_head, fli_list) {
743 1.26 hannken if (fli->fli_self != l)
744 1.26 hannken continue;
745 1.26 hannken if (fli->fli_trans_cnt == 0 && fli->fli_cow_cnt == 0) {
746 1.26 hannken if (! verbose)
747 1.26 hannken continue;
748 1.26 hannken }
749 1.26 hannken printf("%-8s", prefix);
750 1.26 hannken if (verbose)
751 1.26 hannken printf(" @%p", fli);
752 1.26 hannken if (fli->fli_mount != NULL)
753 1.26 hannken printf(" (%s)", fli->fli_mount->mnt_stat.f_mntonname);
754 1.26 hannken else
755 1.26 hannken printf(" NULL");
756 1.26 hannken if (fli->fli_trans_cnt == 0) {
757 1.26 hannken printf(" -");
758 1.26 hannken } else {
759 1.26 hannken switch (fli->fli_lock_type) {
760 1.26 hannken case FSTRANS_LAZY:
761 1.26 hannken printf(" lazy");
762 1.26 hannken break;
763 1.26 hannken case FSTRANS_SHARED:
764 1.26 hannken printf(" shared");
765 1.26 hannken break;
766 1.26 hannken case FSTRANS_EXCL:
767 1.26 hannken printf(" excl");
768 1.26 hannken break;
769 1.26 hannken default:
770 1.26 hannken printf(" %#x", fli->fli_lock_type);
771 1.26 hannken break;
772 1.26 hannken }
773 1.26 hannken }
774 1.26 hannken printf(" %d cow %d\n", fli->fli_trans_cnt, fli->fli_cow_cnt);
775 1.26 hannken prefix[0] = '\0';
776 1.26 hannken }
777 1.26 hannken }
778 1.26 hannken
779 1.26 hannken static void
780 1.26 hannken fstrans_print_mount(struct mount *mp, int verbose)
781 1.26 hannken {
782 1.26 hannken struct fstrans_mount_info *fmi;
783 1.26 hannken
784 1.26 hannken fmi = mp->mnt_transinfo;
785 1.26 hannken if (!verbose && (fmi == NULL || fmi->fmi_state == FSTRANS_NORMAL))
786 1.26 hannken return;
787 1.26 hannken
788 1.26 hannken printf("%-16s ", mp->mnt_stat.f_mntonname);
789 1.26 hannken if (fmi == NULL) {
790 1.26 hannken printf("(null)\n");
791 1.26 hannken return;
792 1.26 hannken }
793 1.26 hannken switch (fmi->fmi_state) {
794 1.26 hannken case FSTRANS_NORMAL:
795 1.26 hannken printf("state normal\n");
796 1.26 hannken break;
797 1.26 hannken case FSTRANS_SUSPENDING:
798 1.26 hannken printf("state suspending\n");
799 1.26 hannken break;
800 1.26 hannken case FSTRANS_SUSPENDED:
801 1.26 hannken printf("state suspended\n");
802 1.26 hannken break;
803 1.26 hannken default:
804 1.26 hannken printf("state %#x\n", fmi->fmi_state);
805 1.26 hannken break;
806 1.26 hannken }
807 1.26 hannken }
808 1.26 hannken
809 1.26 hannken void
810 1.26 hannken fstrans_dump(int full)
811 1.26 hannken {
812 1.26 hannken const struct proclist_desc *pd;
813 1.26 hannken struct proc *p;
814 1.26 hannken struct lwp *l;
815 1.26 hannken struct mount *mp;
816 1.26 hannken
817 1.26 hannken printf("Fstrans locks by lwp:\n");
818 1.26 hannken for (pd = proclists; pd->pd_list != NULL; pd++)
819 1.26 hannken PROCLIST_FOREACH(p, pd->pd_list)
820 1.26 hannken LIST_FOREACH(l, &p->p_lwps, l_sibling)
821 1.26 hannken fstrans_print_lwp(p, l, full == 1);
822 1.26 hannken
823 1.26 hannken printf("Fstrans state by mount:\n");
824 1.29 christos TAILQ_FOREACH(mp, &mountlist, mnt_list)
825 1.26 hannken fstrans_print_mount(mp, full == 1);
826 1.26 hannken }
827 1.26 hannken #endif /* defined(DDB) */
828