xref: /src/sys/kern/vfs_trans.c

/*	$NetBSD: vfs_trans.c,v 1.1 2007/01/19 14:49:10 hannken Exp $	*/

/*-
 * Copyright (c) 2007 The NetBSD Foundation, Inc.
 * All rights reserved.
 *
 * This code is derived from software contributed to The NetBSD Foundation
 * by Juergen Hannken-Illjes.
 *
 * Redistribution and use in source and binary forms, with or without
 * modification, are permitted provided that the following conditions
 * are met:
 * 1. Redistributions of source code must retain the above copyright
 *    notice, this list of conditions and the following disclaimer.
 * 2. Redistributions in binary form must reproduce the above copyright
 *    notice, this list of conditions and the following disclaimer in the
 *    documentation and/or other materials provided with the distribution.
 * 3. All advertising materials mentioning features or use of this software
 *    must display the following acknowledgement:
 *	This product includes software developed by the NetBSD
 *	Foundation, Inc. and its contributors.
 * 4. Neither the name of The NetBSD Foundation nor the names of its
 *    contributors may be used to endorse or promote products derived
 *    from this software without specific prior written permission.
 *
 * THIS SOFTWARE IS PROVIDED BY THE NETBSD FOUNDATION, INC. AND CONTRIBUTORS
 * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
 * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
 * PURPOSE ARE DISCLAIMED.  IN NO EVENT SHALL THE FOUNDATION OR CONTRIBUTORS
 * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
 * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
 * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
 * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
 * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
 * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
 * POSSIBILITY OF SUCH DAMAGE.
 */

#include <sys/cdefs.h>
__KERNEL_RCSID(0, "$NetBSD: vfs_trans.c,v 1.1 2007/01/19 14:49:10 hannken Exp $");

/*
 * File system transaction operations.
 */

#include "opt_ddb.h"

#if defined(DDB)
#define _LWP_API_PRIVATE	/* Need _lwp_getspecific_by_lwp() */
#endif

#include <sys/param.h>
#include <sys/systm.h>
#include <sys/malloc.h>
#include <sys/mount.h>
#include <sys/vnode.h>
#define _FSTRANS_API_PRIVATE
#include <sys/fstrans.h>

#include <miscfs/syncfs/syncfs.h>

struct fstrans_lwp_info {
	struct fstrans_lwp_info *fli_succ;
	struct mount *fli_mount;
	int fli_count;
	enum fstrans_lock_type fli_lock_type;
};
struct fstrans_mount_info {
	enum fstrans_state fmi_state;
	struct lock fmi_shared_lock;
	struct lock fmi_lazy_lock;
};

static specificdata_key_t lwp_data_key;
static specificdata_key_t mount_data_key;
static struct lock vfs_suspend_lock =	/* Serialize suspensions. */
    LOCK_INITIALIZER(PUSER, "suspwt1", 0, 0);

POOL_INIT(fstrans_pl, sizeof(struct fstrans_lwp_info), 0, 0, 0,
    "fstrans", NULL);

static void fstrans_lwp_dtor(void *);
static void fstrans_mount_dtor(void *);
static struct fstrans_mount_info *fstrans_mount_init(struct mount *);

/*
 * Initialize
 */
void
fstrans_init(void)
{
	int error;

	error = lwp_specific_key_create(&lwp_data_key, fstrans_lwp_dtor);
	KASSERT(error == 0);
	error = mount_specific_key_create(&mount_data_key, fstrans_mount_dtor);
	KASSERT(error == 0);
}

/*
 * Deallocate lwp state
 */
static void
fstrans_lwp_dtor(void *arg)
{
	struct fstrans_lwp_info *fli, *fli_next;

	for (fli = arg; fli; fli = fli_next) {
		KASSERT(fli->fli_mount == NULL);
		KASSERT(fli->fli_count == 0);
		fli_next = fli->fli_succ;
		pool_put(&fstrans_pl, fli);
	}
}

/*
 * Deallocate mount state
 */
static void
fstrans_mount_dtor(void *arg)
{
	struct fstrans_mount_info *fmi = arg;

	KASSERT(fmi->fmi_state == fstrans_normal);
	lockmgr(&fmi->fmi_lazy_lock, LK_DRAIN, NULL);
	lockmgr(&fmi->fmi_shared_lock, LK_DRAIN, NULL);
	free(fmi, M_MOUNT);
}

/*
 * Create mount info for this mount
 */
static struct fstrans_mount_info *
fstrans_mount_init(struct mount *mp)
{
	static struct lock lock = LOCK_INITIALIZER(PUSER, "ftminfo", 0, 0);
	struct fstrans_mount_info *new;

	lockmgr(&lock, LK_EXCLUSIVE, NULL);

	if ((new = mount_getspecific(mp, mount_data_key)) != NULL) {
		lockmgr(&lock, LK_RELEASE, NULL);
		return new;
	}

	new = malloc(sizeof(*new), M_MOUNT, M_WAITOK);
	new->fmi_state = fstrans_normal;
	lockinit(&new->fmi_lazy_lock, PVFS, "suspfs", 0, 0);
	lockinit(&new->fmi_shared_lock, PVFS, "suspfs", 0, 0);

	mount_setspecific(mp, mount_data_key, new);

	lockmgr(&lock, LK_RELEASE, NULL);

	return new;
}

/*
 * Start a transaction.  If this thread already has a transaction on this
 * file system increment the reference counter.
 * A thread with an exclusive transaction lock may get a shared or lazy one.
 * A thread with a shared or lazy transaction lock cannot upgrade to an
 * exclusive one yet.
 */
int
_fstrans_start(struct mount *mp, enum fstrans_lock_type lock_type, int wait)
{
	int error, lkflags;
	struct fstrans_lwp_info *fli, *new_fli;
	struct fstrans_mount_info *fmi;

	ASSERT_SLEEPABLE(NULL, __func__);

	lkflags = (lock_type == fstrans_excl ? LK_EXCLUSIVE : LK_SHARED);
	if (!wait)
		lkflags |= LK_NOWAIT;

	if (mp == NULL || (mp->mnt_iflag & IMNT_HAS_TRANS) == 0)
		return 0;

	new_fli = NULL;
	for (fli = lwp_getspecific(lwp_data_key); fli; fli = fli->fli_succ) {
		if (fli->fli_mount == NULL && new_fli == NULL)
			new_fli = fli;
		if (fli->fli_mount == mp) {
			KASSERT(fli->fli_count > 0);
			if (fli->fli_lock_type != fstrans_excl &&
			    lock_type == fstrans_excl)
				panic("fstrans_start: cannot upgrade lock");
			fli->fli_count += 1;
			return 0;
		}
	}

	if (new_fli == NULL) {
		new_fli = pool_get(&fstrans_pl, PR_WAITOK);
		new_fli->fli_mount = NULL;
		new_fli->fli_count = 0;
		new_fli->fli_succ = lwp_getspecific(lwp_data_key);
		lwp_setspecific(lwp_data_key, new_fli);
	}

	KASSERT(new_fli->fli_mount == NULL);
	KASSERT(new_fli->fli_count == 0);

	if ((fmi = mount_getspecific(mp, mount_data_key)) == NULL)
		fmi = fstrans_mount_init(mp);

	if (lock_type == fstrans_lazy)
		error = lockmgr(&fmi->fmi_lazy_lock, lkflags, NULL);
	else
		error = lockmgr(&fmi->fmi_shared_lock, lkflags, NULL);
	if (error)
		return error;

	new_fli->fli_mount = mp;
	new_fli->fli_count = 1;
	new_fli->fli_lock_type = lock_type;

	return 0;
}

/*
 * Finish a transaction.
 */
void
fstrans_done(struct mount *mp)
{
	struct fstrans_lwp_info *fli;
	struct fstrans_mount_info *fmi;

	if (mp == NULL || (mp->mnt_iflag & IMNT_HAS_TRANS) == 0)
		return;

	for (fli = lwp_getspecific(lwp_data_key); fli; fli = fli->fli_succ) {
		if (fli->fli_mount == mp) {
			fli->fli_count -= 1;
			if (fli->fli_count > 0)
				return;
			break;
		}
	}

	KASSERT(fli != NULL);
	KASSERT(fli->fli_mount == mp);
	KASSERT(fli->fli_count == 0);
	fli->fli_mount = NULL;
	fmi = mount_getspecific(mp, mount_data_key);
	KASSERT(fmi != NULL);
	if (fli->fli_lock_type == fstrans_lazy)
		lockmgr(&fmi->fmi_lazy_lock, LK_RELEASE, NULL);
	else
		lockmgr(&fmi->fmi_shared_lock, LK_RELEASE, NULL);
}

/*
 * Check if this thread has an exclusive lock.
 */
int
fstrans_is_owner(struct mount *mp)
{
	struct fstrans_lwp_info *fli;

	if (mp == NULL)
		return 0;
	if ((mp->mnt_iflag & IMNT_HAS_TRANS) == 0)
		return 0;

	for (fli = lwp_getspecific(lwp_data_key); fli; fli = fli->fli_succ)
		if (fli->fli_mount == mp)
			break;

	if (fli == NULL)
		return 0;

	KASSERT(fli->fli_mount == mp);
	KASSERT(fli->fli_count > 0);
	return (fli->fli_lock_type == fstrans_excl);
}

/*
 * Set new file system state.
 */
int
fstrans_setstate(struct mount *mp, enum fstrans_state new_state)
{
	int error;
	struct fstrans_mount_info *fmi;

	if ((fmi = mount_getspecific(mp, mount_data_key)) == NULL)
		fmi = fstrans_mount_init(mp);

	switch (new_state) {
	case fstrans_suspending:
		KASSERT(fmi->fmi_state == fstrans_normal);
		if ((error = fstrans_start(mp, fstrans_excl)) != 0)
			return error;
		fmi->fmi_state = fstrans_suspending;
		break;

	case fstrans_suspended:
		KASSERT(fmi->fmi_state == fstrans_normal ||
			fmi->fmi_state == fstrans_suspending);
		KASSERT(fmi->fmi_state == fstrans_normal ||
			fstrans_is_owner(mp));
		if (fmi->fmi_state == fstrans_normal &&
		    (error = fstrans_start(mp, fstrans_excl)) != 0)
			return error;
		if ((error = lockmgr(&fmi->fmi_lazy_lock, LK_EXCLUSIVE, NULL))
		    != 0)
			return error;
		fmi->fmi_state = fstrans_suspended;
		break;

	case fstrans_normal:
		KASSERT(fmi->fmi_state == fstrans_normal ||
			fstrans_is_owner(mp));
		if (fmi->fmi_state == fstrans_suspended)
			lockmgr(&fmi->fmi_lazy_lock, LK_RELEASE, NULL);
		if (fmi->fmi_state == fstrans_suspending ||
		    fmi->fmi_state == fstrans_suspended) {
			fmi->fmi_state = fstrans_normal;
			fstrans_done(mp);
		}
		break;

	default:
		panic("%s: illegal state %d", __func__, new_state);
	}

	return 0;
}

/*
 * Get current file system state
 */
enum fstrans_state
fstrans_getstate(struct mount *mp)
{
	struct fstrans_mount_info *fmi;

	if ((fmi = mount_getspecific(mp, mount_data_key)) == NULL)
		return fstrans_normal;

	return fmi->fmi_state;
}

/*
 * Request a filesystem to suspend all operations.
 */
int
vfs_suspend(struct mount *mp, int nowait)
{
#ifndef NEWVNGATE
	struct lwp *l = curlwp;	/* XXX */
#endif /* NEWVNGATE */
	int error, flags;

	flags = LK_EXCLUSIVE;
	if (nowait)
		flags |= LK_NOWAIT;
	if (lockmgr(&vfs_suspend_lock, flags, NULL) != 0)
		return EWOULDBLOCK;

#ifdef NEWVNGATE
	lockmgr(&syncer_lock, LK_EXCLUSIVE, NULL);

	if ((error = VFS_SUSPENDCTL(mp, SUSPEND_SUSPEND)) != 0) {
		lockmgr(&syncer_lock, LK_RELEASE, NULL);
		lockmgr(&vfs_suspend_lock, LK_RELEASE, NULL);
	}

	return error;
#else /* NEWVNGATE */
	KASSERT((mp->mnt_iflag &
	    (IMNT_SUSPEND|IMNT_SUSPENDLOW|IMNT_SUSPENDED)) == 0);

	mp->mnt_iflag |= IMNT_SUSPEND;

	simple_lock(&mp->mnt_slock);
	if (mp->mnt_writeopcountupper > 0)
		ltsleep(&mp->mnt_writeopcountupper, PUSER - 1, "suspwt",
			0, &mp->mnt_slock);
	simple_unlock(&mp->mnt_slock);

	error = VFS_SYNC(mp, MNT_WAIT, l->l_proc->p_cred, l);
	if (error) {
		vfs_resume(mp);
		return error;
	}
	mp->mnt_iflag |= IMNT_SUSPENDLOW;

	simple_lock(&mp->mnt_slock);
	if (mp->mnt_writeopcountlower > 0)
		ltsleep(&mp->mnt_writeopcountlower, PUSER - 1, "suspwt",
			0, &mp->mnt_slock);
	mp->mnt_iflag |= IMNT_SUSPENDED;
	simple_unlock(&mp->mnt_slock);

	return 0;
#endif /* NEWVNGATE */
}

/*
 * Request a filesystem to resume all operations.
 */
void
vfs_resume(struct mount *mp)
{

#ifdef NEWVNGATE
	VFS_SUSPENDCTL(mp, SUSPEND_RESUME);
	lockmgr(&syncer_lock, LK_RELEASE, NULL);
	lockmgr(&vfs_suspend_lock, LK_RELEASE, NULL);
#else /* NEWVNGATE */
	if ((mp->mnt_iflag & IMNT_SUSPEND) == 0)
		return;
	mp->mnt_iflag &= ~(IMNT_SUSPEND | IMNT_SUSPENDLOW | IMNT_SUSPENDED);
	wakeup(&mp->mnt_flag);

	lockmgr(&vfs_suspend_lock, LK_RELEASE, NULL);
#endif /* NEWVNGATE */
}

/*
 * Default vfs_suspendctl routine for file systems that do not support it.
 */
/*ARGSUSED*/
int
vfs_stdsuspendctl(struct mount *mp __unused, int mode __unused)
{
	return EOPNOTSUPP;
}

#if defined(DDB)
void fstrans_dump(int);

static void
fstrans_print_lwp(struct proc *p, struct lwp *l, int verbose)
{
	char prefix[9];
	struct fstrans_lwp_info *fli;

	snprintf(prefix, sizeof(prefix), "%d.%d", p->p_pid, l->l_lid);
	for (fli = _lwp_getspecific_by_lwp(l, lwp_data_key);
	     fli;
	     fli = fli->fli_succ) {
		if (!verbose && fli->fli_count == 0)
			continue;
		printf("%-8s", prefix);
		if (verbose)
			printf(" @%p", fli);
		if (fli->fli_mount != NULL)
			printf(" (%s)", fli->fli_mount->mnt_stat.f_mntonname);
		else
			printf(" NULL");
		switch (fli->fli_lock_type) {
		case fstrans_lazy:
			printf(" lazy");
			break;
		case fstrans_shared:
			printf(" shared");
			break;
		case fstrans_excl:
			printf(" excl");
			break;
		default:
			printf(" %#x", fli->fli_lock_type);
			break;
		}
		printf(" %d\n", fli->fli_count);
		prefix[0] = '\0';
	}
}

static void
fstrans_print_mount(struct mount *mp, int verbose)
{
	struct fstrans_mount_info *fmi;

	fmi = mount_getspecific(mp, mount_data_key);
	if (!verbose && (fmi == NULL || fmi->fmi_state == fstrans_normal))
		return;

	printf("%-16s ", mp->mnt_stat.f_mntonname);
	if (fmi == NULL) {
		printf("(null)\n");
		return;
	}
	switch (fmi->fmi_state) {
	case fstrans_normal:
		printf("state normal\n");
		break;
	case fstrans_suspending:
		printf("state suspending\n");
		break;
	case fstrans_suspended:
		printf("state suspended\n");
		break;
	default:
		printf("state %#x\n", fmi->fmi_state);
		break;
	}
	printf("%16s", "lock_lazy:");
	lockmgr_printinfo(&fmi->fmi_lazy_lock);
	printf("\n");
	printf("%16s", "lock_shared:");
	lockmgr_printinfo(&fmi->fmi_shared_lock);
	printf("\n");
}

void
fstrans_dump(int full)
{
	const struct proclist_desc *pd;
	struct proc *p;
	struct lwp *l;
	struct mount *mp;

	printf("Fstrans locks by lwp:\n");
	for (pd = proclists; pd->pd_list != NULL; pd++)
		LIST_FOREACH(p, pd->pd_list, p_list)
			LIST_FOREACH(l, &p->p_lwps, l_sibling)
				fstrans_print_lwp(p, l, full == 1);

	printf("Fstrans state by mount:\n");
	CIRCLEQ_FOREACH(mp, &mountlist, mnt_list)
		fstrans_print_mount(mp, full == 1);
}
#endif /* defined(DDB) */