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