Home | History | Annotate | Line # | Download | only in lfs
lfs_subr.c revision 1.8
      1 /*	$NetBSD: lfs_subr.c,v 1.8 1999/03/10 00:20:00 perseant Exp $	*/
      2 
      3 /*-
      4  * Copyright (c) 1999 The NetBSD Foundation, Inc.
      5  * All rights reserved.
      6  *
      7  * This code is derived from software contributed to The NetBSD Foundation
      8  * by Konrad E. Schroder <perseant (at) hhhh.org>.
      9  *
     10  * Redistribution and use in source and binary forms, with or without
     11  * modification, are permitted provided that the following conditions
     12  * are met:
     13  * 1. Redistributions of source code must retain the above copyright
     14  *    notice, this list of conditions and the following disclaimer.
     15  * 2. Redistributions in binary form must reproduce the above copyright
     16  *    notice, this list of conditions and the following disclaimer in the
     17  *    documentation and/or other materials provided with the distribution.
     18  * 3. All advertising materials mentioning features or use of this software
     19  *    must display the following acknowledgement:
     20  *      This product includes software developed by the NetBSD
     21  *      Foundation, Inc. and its contributors.
     22  * 4. Neither the name of The NetBSD Foundation nor the names of its
     23  *    contributors may be used to endorse or promote products derived
     24  *    from this software without specific prior written permission.
     25  *
     26  * THIS SOFTWARE IS PROVIDED BY THE NETBSD FOUNDATION, INC. AND CONTRIBUTORS
     27  * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
     28  * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
     29  * PURPOSE ARE DISCLAIMED.  IN NO EVENT SHALL THE FOUNDATION OR CONTRIBUTORS
     30  * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
     31  * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
     32  * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
     33  * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
     34  * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
     35  * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
     36  * POSSIBILITY OF SUCH DAMAGE.
     37  */
     38 /*
     39  * Copyright (c) 1991, 1993
     40  *	The Regents of the University of California.  All rights reserved.
     41  *
     42  * Redistribution and use in source and binary forms, with or without
     43  * modification, are permitted provided that the following conditions
     44  * are met:
     45  * 1. Redistributions of source code must retain the above copyright
     46  *    notice, this list of conditions and the following disclaimer.
     47  * 2. Redistributions in binary form must reproduce the above copyright
     48  *    notice, this list of conditions and the following disclaimer in the
     49  *    documentation and/or other materials provided with the distribution.
     50  * 3. All advertising materials mentioning features or use of this software
     51  *    must display the following acknowledgement:
     52  *	This product includes software developed by the University of
     53  *	California, Berkeley and its contributors.
     54  * 4. Neither the name of the University nor the names of its contributors
     55  *    may be used to endorse or promote products derived from this software
     56  *    without specific prior written permission.
     57  *
     58  * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
     59  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
     60  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
     61  * ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
     62  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
     63  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
     64  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
     65  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
     66  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
     67  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
     68  * SUCH DAMAGE.
     69  *
     70  *	@(#)lfs_subr.c	8.4 (Berkeley) 5/8/95
     71  */
     72 
     73 #include <sys/param.h>
     74 #include <sys/systm.h>
     75 #include <sys/namei.h>
     76 #include <sys/vnode.h>
     77 #include <sys/buf.h>
     78 #include <sys/mount.h>
     79 #include <sys/malloc.h>
     80 #include <sys/proc.h>
     81 
     82 #include <ufs/ufs/quota.h>
     83 #include <ufs/ufs/inode.h>
     84 #include <ufs/lfs/lfs.h>
     85 #include <ufs/lfs/lfs_extern.h>
     86 
     87 /*
     88  * Return buffer with the contents of block "offset" from the beginning of
     89  * directory "ip".  If "res" is non-zero, fill it in with a pointer to the
     90  * remaining space in the directory.
     91  */
     92 int
     93 lfs_blkatoff(v)
     94 	void *v;
     95 {
     96 	struct vop_blkatoff_args /* {
     97 		struct vnode *a_vp;
     98 		off_t a_offset;
     99 		char **a_res;
    100 		struct buf **a_bpp;
    101 		} */ *ap = v;
    102 	register struct lfs *fs;
    103 	struct inode *ip;
    104 	struct buf *bp;
    105 	ufs_daddr_t lbn;
    106 	int bsize, error;
    107 
    108 	ip = VTOI(ap->a_vp);
    109 	fs = ip->i_lfs;
    110 	lbn = lblkno(fs, ap->a_offset);
    111 	bsize = blksize(fs, ip, lbn);
    112 
    113 	*ap->a_bpp = NULL;
    114 	if ((error = bread(ap->a_vp, lbn, bsize, NOCRED, &bp)) != 0) {
    115 		brelse(bp);
    116 		return (error);
    117 	}
    118 	if (ap->a_res)
    119 		*ap->a_res = (char *)bp->b_data + blkoff(fs, ap->a_offset);
    120 	*ap->a_bpp = bp;
    121 	return (0);
    122 }
    123 
    124 
    125 /*
    126  * lfs_seglock --
    127  *	Single thread the segment writer.
    128  */
    129 void
    130 lfs_seglock(fs, flags)
    131 	struct lfs *fs;
    132 	unsigned long flags;
    133 {
    134 	struct segment *sp;
    135 	int s;
    136 
    137 	if (fs->lfs_seglock) {
    138 		if (fs->lfs_lockpid == curproc->p_pid) {
    139 			++fs->lfs_seglock;
    140 			fs->lfs_sp->seg_flags |= flags;
    141 			return;
    142 		} else while (fs->lfs_seglock)
    143 			(void)tsleep(&fs->lfs_seglock, PRIBIO + 1,
    144 				     "lfs seglock", 0);
    145 	}
    146 
    147 	fs->lfs_seglock = 1;
    148 	fs->lfs_lockpid = curproc->p_pid;
    149 
    150 	sp = fs->lfs_sp = malloc(sizeof(struct segment), M_SEGMENT, M_WAITOK);
    151 	sp->bpp = malloc(((LFS_SUMMARY_SIZE - sizeof(SEGSUM)) /
    152 			  sizeof(ufs_daddr_t) + 1) * sizeof(struct buf *),
    153 			 M_SEGMENT, M_WAITOK);
    154 	sp->seg_flags = flags;
    155 	sp->vp = NULL;
    156 	(void) lfs_initseg(fs);
    157 
    158 	/*
    159 	 * Keep a cumulative count of the outstanding I/O operations.  If the
    160 	 * disk drive catches up with us it could go to zero before we finish,
    161 	 * so we artificially increment it by one until we've scheduled all of
    162 	 * the writes we intend to do.
    163 	 */
    164 	s = splbio();
    165 	++fs->lfs_iocount;
    166 	splx(s);
    167 }
    168 
    169 /*
    170  * lfs_segunlock --
    171  *	Single thread the segment writer.
    172  */
    173 void
    174 lfs_segunlock(fs)
    175 	struct lfs *fs;
    176 {
    177 	struct segment *sp;
    178 	unsigned long sync, ckp;
    179 	int s;
    180 
    181 	if (fs->lfs_seglock == 1) {
    182 
    183 		sp = fs->lfs_sp;
    184 		sync = sp->seg_flags & SEGM_SYNC;
    185 		ckp = sp->seg_flags & SEGM_CKP;
    186 		if (sp->bpp != sp->cbpp) {
    187 			/* Free allocated segment summary */
    188 			fs->lfs_offset -= LFS_SUMMARY_SIZE / DEV_BSIZE;
    189                         lfs_freebuf(*sp->bpp);
    190 		} else
    191 			printf ("unlock to 0 with no summary");
    192 
    193 		free(sp->bpp, M_SEGMENT);
    194 		free(sp, M_SEGMENT);
    195 
    196 		/*
    197 		 * If the I/O count is non-zero, sleep until it reaches zero.
    198 		 * At the moment, the user's process hangs around so we can
    199 		 * sleep.
    200 		 */
    201 		s = splbio();
    202 		--fs->lfs_iocount;
    203 		/*
    204 		 * We let checkpoints happen asynchronously.  That means
    205 		 * that during recovery, we have to roll forward between
    206 		 * the two segments described by the first and second
    207 		 * superblocks to make sure that the checkpoint described
    208 		 * by a superblock completed.
    209 		 */
    210 		while (sync && fs->lfs_iocount)
    211 			(void)tsleep(&fs->lfs_iocount, PRIBIO + 1,
    212 				     "lfs vflush", 0);
    213 		splx(s);
    214 		if (ckp) {
    215 			fs->lfs_nactive = 0;
    216 #ifndef LFS_TOGGLE_SB
    217 			lfs_writesuper(fs,fs->lfs_sboffs[0]);
    218 #else
    219 			/* If we *know* everything's on disk, write both sbs */
    220 			if(sync)
    221 				lfs_writesuper(fs,fs->lfs_sboffs[fs->lfs_activesb]);
    222 			fs->lfs_activesb = 1 - fs->lfs_activesb;
    223 			lfs_writesuper(fs,fs->lfs_sboffs[fs->lfs_activesb]);
    224 #endif
    225 		}
    226 		--fs->lfs_seglock;
    227 		fs->lfs_lockpid = 0;
    228 		wakeup(&fs->lfs_seglock);
    229 	} else if (fs->lfs_seglock == 0) {
    230 		panic ("Seglock not held");
    231 	} else {
    232 		--fs->lfs_seglock;
    233 	}
    234 }
    235