Home | History | Annotate | Line # | Download | only in kern
vfs_trans.c revision 1.31.2.2
      1  1.31.2.2     skrll /*	$NetBSD: vfs_trans.c,v 1.31.2.2 2015/09/22 12:06:07 skrll 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.31.2.2     skrll __KERNEL_RCSID(0, "$NetBSD: vfs_trans.c,v 1.31.2.2 2015/09/22 12:06:07 skrll 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.31.2.2     skrll #ifdef _KERNEL_OPT
     40       1.1   hannken #include "opt_ddb.h"
     41  1.31.2.2     skrll #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.31.2.1     skrll 	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.31.2.1     skrll 	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