Home | History | Annotate | Line # | Download | only in kern
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