Aren
/
NetBSD
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity
NetBSD/sbin/fsck_lfs/segwrite.c

1062 lines
29 KiB
C
Raw Blame History

/* $NetBSD: segwrite.c,v 1.45 2015/10/03 08:28:15 dholland Exp $ */
/*-
* Copyright (c) 2003 The NetBSD Foundation, Inc.
* All rights reserved.
*
* This code is derived from software contributed to The NetBSD Foundation
* by Konrad E. Schroder <perseant@hhhh.org>.
*
* 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.
*
* 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.
*/
/*
* Copyright (c) 1991, 1993
* The Regents of the University of California. All rights reserved.
*
* 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. Neither the name of the University 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 REGENTS 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 REGENTS 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.
*
* @(#)lfs_segment.c 8.10 (Berkeley) 6/10/95
*/
/*
* Partial segment writer, taken from the kernel and adapted for userland.
*/
#include <sys/types.h>
#include <sys/param.h>
#include <sys/time.h>
#include <sys/buf.h>
#include <sys/mount.h>
/* Override certain things to make <ufs/lfs/lfs.h> work */
#define VU_DIROP 0x01000000 /* XXX XXX from sys/vnode.h */
#define vnode uvnode
#define buf ubuf
#define panic call_panic
#include <ufs/lfs/lfs.h>
#include <ufs/lfs/lfs_accessors.h>
#include <ufs/lfs/lfs_inode.h>
#include <assert.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <err.h>
#include <errno.h>
#include <util.h>
#include "bufcache.h"
#include "vnode.h"
#include "lfs_user.h"
#include "segwrite.h"
/* Compatibility definitions */
extern off_t locked_queue_bytes;
int locked_queue_count;
off_t written_bytes = 0;
off_t written_data = 0;
off_t written_indir = 0;
off_t written_dev = 0;
int written_inodes = 0;
/* Global variables */
time_t write_time;
extern u_int32_t cksum(void *, size_t);
extern u_int32_t lfs_sb_cksum(struct lfs *);
extern int preen;
static void lfs_shellsort(struct lfs *,
struct ubuf **, union lfs_blocks *, int, int);
/*
* Logical block number match routines used when traversing the dirty block
* chain.
*/
int
lfs_match_data(struct lfs * fs, struct ubuf * bp)
{
return (bp->b_lblkno >= 0);
}
int
lfs_match_indir(struct lfs * fs, struct ubuf * bp)
{
daddr_t lbn;
lbn = bp->b_lblkno;
return (lbn < 0 && (-lbn - ULFS_NDADDR) % LFS_NINDIR(fs) == 0);
}
int
lfs_match_dindir(struct lfs * fs, struct ubuf * bp)
{
daddr_t lbn;
lbn = bp->b_lblkno;
return (lbn < 0 && (-lbn - ULFS_NDADDR) % LFS_NINDIR(fs) == 1);
}
int
lfs_match_tindir(struct lfs * fs, struct ubuf * bp)
{
daddr_t lbn;
lbn = bp->b_lblkno;
return (lbn < 0 && (-lbn - ULFS_NDADDR) % LFS_NINDIR(fs) == 2);
}
/*
* Do a checkpoint.
*/
int
lfs_segwrite(struct lfs * fs, int flags)
{
struct inode *ip;
struct segment *sp;
struct uvnode *vp;
SEGSUM *ssp;
int redo;
lfs_seglock(fs, flags | SEGM_CKP);
sp = fs->lfs_sp;
lfs_writevnodes(fs, sp, VN_REG);
lfs_writevnodes(fs, sp, VN_DIROP);
ssp = (SEGSUM *)sp->segsum;
lfs_ss_setflags(fs, ssp, lfs_ss_getflags(fs, ssp) & ~(SS_CONT));
do {
vp = fs->lfs_ivnode;
fs->lfs_flags &= ~LFS_IFDIRTY;
ip = VTOI(vp);
if (LIST_FIRST(&vp->v_dirtyblkhd) != NULL || lfs_sb_getidaddr(fs) <= 0)
lfs_writefile(fs, sp, vp);
redo = lfs_writeinode(fs, sp, ip);
redo += lfs_writeseg(fs, sp);
redo += (fs->lfs_flags & LFS_IFDIRTY);
} while (redo);
lfs_segunlock(fs);
#if 0
printf("wrote %" PRId64 " bytes (%" PRId32 " fsb)\n",
written_bytes, (ulfs_daddr_t)lfs_btofsb(fs, written_bytes));
printf("wrote %" PRId64 " bytes data (%" PRId32 " fsb)\n",
written_data, (ulfs_daddr_t)lfs_btofsb(fs, written_data));
printf("wrote %" PRId64 " bytes indir (%" PRId32 " fsb)\n",
written_indir, (ulfs_daddr_t)lfs_btofsb(fs, written_indir));
printf("wrote %" PRId64 " bytes dev (%" PRId32 " fsb)\n",
written_dev, (ulfs_daddr_t)lfs_btofsb(fs, written_dev));
printf("wrote %d inodes (%" PRId32 " fsb)\n",
written_inodes, lfs_btofsb(fs, written_inodes * fs->lfs_ibsize));
#endif
return 0;
}
/*
* Write the dirty blocks associated with a vnode.
*/
void
lfs_writefile(struct lfs * fs, struct segment * sp, struct uvnode * vp)
{
struct ubuf *bp;
FINFO *fip;
struct inode *ip;
IFILE *ifp;
SEGSUM *ssp;
ip = VTOI(vp);
if (sp->seg_bytes_left < lfs_sb_getbsize(fs) ||
sp->sum_bytes_left < FINFOSIZE(fs) + LFS_BLKPTRSIZE(fs))
(void) lfs_writeseg(fs, sp);
sp->sum_bytes_left -= FINFOSIZE(fs);
ssp = (SEGSUM *)sp->segsum;
lfs_ss_setnfinfo(fs, ssp, lfs_ss_getnfinfo(fs, ssp) + 1);
if (vp->v_uflag & VU_DIROP) {
lfs_ss_setflags(fs, ssp,
lfs_ss_getflags(fs, ssp) | (SS_DIROP | SS_CONT));
}
fip = sp->fip;
lfs_fi_setnblocks(fs, fip, 0);
lfs_fi_setino(fs, fip, ip->i_number);
LFS_IENTRY(ifp, fs, lfs_fi_getino(fs, fip), bp);
lfs_fi_setversion(fs, fip, lfs_if_getversion(fs, ifp));
brelse(bp, 0);
lfs_gather(fs, sp, vp, lfs_match_data);
lfs_gather(fs, sp, vp, lfs_match_indir);
lfs_gather(fs, sp, vp, lfs_match_dindir);
lfs_gather(fs, sp, vp, lfs_match_tindir);
fip = sp->fip;
if (lfs_fi_getnblocks(fs, fip) != 0) {
sp->fip = NEXT_FINFO(fs, fip);
lfs_blocks_fromfinfo(fs, &sp->start_lbp, sp->fip);
} else {
/* XXX shouldn't this update sp->fip? */
sp->sum_bytes_left += FINFOSIZE(fs);
lfs_ss_setnfinfo(fs, ssp, lfs_ss_getnfinfo(fs, ssp) - 1);
}
}
int
lfs_writeinode(struct lfs * fs, struct segment * sp, struct inode * ip)
{
struct ubuf *bp, *ibp;
union lfs_dinode *cdp;
IFILE *ifp;
SEGUSE *sup;
SEGSUM *ssp;
daddr_t daddr;
ino_t ino;
IINFO *iip;
int i, fsb = 0;
int redo_ifile = 0;
struct timespec ts;
int gotblk = 0;
/* Allocate a new inode block if necessary. */
if ((ip->i_number != LFS_IFILE_INUM || sp->idp == NULL) &&
sp->ibp == NULL) {
/* Allocate a new segment if necessary. */
if (sp->seg_bytes_left < lfs_sb_getibsize(fs) ||
sp->sum_bytes_left < LFS_BLKPTRSIZE(fs))
(void) lfs_writeseg(fs, sp);
/* Get next inode block. */
daddr = lfs_sb_getoffset(fs);
lfs_sb_addoffset(fs, lfs_btofsb(fs, lfs_sb_getibsize(fs)));
sp->ibp = *sp->cbpp++ =
getblk(fs->lfs_devvp, LFS_FSBTODB(fs, daddr),
lfs_sb_getibsize(fs));
sp->ibp->b_flags |= B_GATHERED;
gotblk++;
/* Zero out inode numbers */
for (i = 0; i < LFS_INOPB(fs); ++i) {
union lfs_dinode *tmpdip;
tmpdip = DINO_IN_BLOCK(fs, sp->ibp->b_data, i);
lfs_dino_setinumber(fs, tmpdip, 0);
}
++sp->start_bpp;
lfs_sb_subavail(fs, lfs_btofsb(fs, lfs_sb_getibsize(fs)));
/* Set remaining space counters. */
sp->seg_bytes_left -= lfs_sb_getibsize(fs);
sp->sum_bytes_left -= LFS_BLKPTRSIZE(fs);
/* Store the address in the segment summary. */
iip = NTH_IINFO(fs, sp->segsum, sp->ninodes / LFS_INOPB(fs));
lfs_ii_setblock(fs, iip, daddr);
}
/* Update the inode times and copy the inode onto the inode page. */
ts.tv_nsec = 0;
ts.tv_sec = write_time;
/* XXX kludge --- don't redirty the ifile just to put times on it */
if (ip->i_number != LFS_IFILE_INUM)
LFS_ITIMES(ip, &ts, &ts, &ts);
/*
* If this is the Ifile, and we've already written the Ifile in this
* partial segment, just overwrite it (it's not on disk yet) and
* continue.
*
* XXX we know that the bp that we get the second time around has
* already been gathered.
*/
if (ip->i_number == LFS_IFILE_INUM && sp->idp) {
lfs_copy_dinode(fs, sp->idp, ip->i_din);
ip->i_lfs_osize = lfs_dino_getsize(fs, ip->i_din);
return 0;
}
bp = sp->ibp;
cdp = DINO_IN_BLOCK(fs, bp->b_data, sp->ninodes % LFS_INOPB(fs));
lfs_copy_dinode(fs, cdp, ip->i_din);
/* If all blocks are goig to disk, update the "size on disk" */
ip->i_lfs_osize = lfs_dino_getsize(fs, ip->i_din);
if (ip->i_number == LFS_IFILE_INUM) /* We know sp->idp == NULL */
sp->idp = DINO_IN_BLOCK(fs, bp->b_data, sp->ninodes % LFS_INOPB(fs));
if (gotblk) {
LFS_LOCK_BUF(bp);
assert(!(bp->b_flags & B_INVAL));
brelse(bp, 0);
}
/* Increment inode count in segment summary block. */
ssp = (SEGSUM *)sp->segsum;
lfs_ss_setninos(fs, ssp, lfs_ss_getninos(fs, ssp) + 1);
/* If this page is full, set flag to allocate a new page. */
if (++sp->ninodes % LFS_INOPB(fs) == 0)
sp->ibp = NULL;
/*
* If updating the ifile, update the super-block. Update the disk
* address for this inode in the ifile.
*/
ino = ip->i_number;
if (ino == LFS_IFILE_INUM) {
daddr = lfs_sb_getidaddr(fs);
lfs_sb_setidaddr(fs, LFS_DBTOFSB(fs, bp->b_blkno));
sbdirty();
} else {
LFS_IENTRY(ifp, fs, ino, ibp);
daddr = lfs_if_getdaddr(fs, ifp);
lfs_if_setdaddr(fs, ifp, LFS_DBTOFSB(fs, bp->b_blkno) + fsb);
(void)LFS_BWRITE_LOG(ibp); /* Ifile */
}
/*
* Account the inode: it no longer belongs to its former segment,
* though it will not belong to the new segment until that segment
* is actually written.
*/
if (daddr != LFS_UNUSED_DADDR) {
u_int32_t oldsn = lfs_dtosn(fs, daddr);
LFS_SEGENTRY(sup, fs, oldsn, bp);
sup->su_nbytes -= DINOSIZE(fs);
redo_ifile =
(ino == LFS_IFILE_INUM && !(bp->b_flags & B_GATHERED));
if (redo_ifile)
fs->lfs_flags |= LFS_IFDIRTY;
LFS_WRITESEGENTRY(sup, fs, oldsn, bp); /* Ifile */
}
return redo_ifile;
}
int
lfs_gatherblock(struct segment * sp, struct ubuf * bp)
{
struct lfs *fs;
SEGSUM *ssp;
int version;
int j, blksinblk;
/*
* If full, finish this segment. We may be doing I/O, so
* release and reacquire the splbio().
*/
fs = sp->fs;
blksinblk = howmany(bp->b_bcount, lfs_sb_getbsize(fs));
if (sp->sum_bytes_left < LFS_BLKPTRSIZE(fs) * blksinblk ||
sp->seg_bytes_left < bp->b_bcount) {
lfs_updatemeta(sp);
version = lfs_fi_getversion(fs, sp->fip);
(void) lfs_writeseg(fs, sp);
lfs_fi_setversion(fs, sp->fip, version);
lfs_fi_setino(fs, sp->fip, VTOI(sp->vp)->i_number);
/* Add the current file to the segment summary. */
ssp = (SEGSUM *)sp->segsum;
lfs_ss_setnfinfo(fs, ssp, lfs_ss_getnfinfo(fs, ssp) + 1);
sp->sum_bytes_left -= FINFOSIZE(fs);
return 1;
}
/* Insert into the buffer list, update the FINFO block. */
bp->b_flags |= B_GATHERED;
/* bp->b_flags &= ~B_DONE; */
*sp->cbpp++ = bp;
for (j = 0; j < blksinblk; j++) {
unsigned bn;
bn = lfs_fi_getnblocks(fs, sp->fip);
lfs_fi_setnblocks(fs, sp->fip, bn + 1);
lfs_fi_setblock(fs, sp->fip, bn, bp->b_lblkno + j);;
}
sp->sum_bytes_left -= LFS_BLKPTRSIZE(fs) * blksinblk;
sp->seg_bytes_left -= bp->b_bcount;
return 0;
}
int
lfs_gather(struct lfs * fs, struct segment * sp, struct uvnode * vp, int (*match) (struct lfs *, struct ubuf *))
{
struct ubuf *bp, *nbp;
int count = 0;
sp->vp = vp;
loop:
for (bp = LIST_FIRST(&vp->v_dirtyblkhd); bp; bp = nbp) {
nbp = LIST_NEXT(bp, b_vnbufs);
assert(bp->b_flags & B_DELWRI);
if ((bp->b_flags & (B_BUSY | B_GATHERED)) || !match(fs, bp)) {
continue;
}
if (lfs_gatherblock(sp, bp)) {
goto loop;
}
count++;
}
lfs_updatemeta(sp);
sp->vp = NULL;
return count;
}
/*
* Change the given block's address to ndaddr, finding its previous
* location using ulfs_bmaparray().
*
* Account for this change in the segment table.
*/
static void
lfs_update_single(struct lfs * fs, struct segment * sp, daddr_t lbn,
daddr_t ndaddr, int size)
{
SEGUSE *sup;
struct ubuf *bp;
struct indir a[ULFS_NIADDR + 2], *ap;
struct inode *ip;
struct uvnode *vp;
daddr_t daddr, ooff;
int num, error;
int osize;
int frags, ofrags;
vp = sp->vp;
ip = VTOI(vp);
error = ulfs_bmaparray(fs, vp, lbn, &daddr, a, &num);
if (error)
errx(EXIT_FAILURE, "%s: ulfs_bmaparray returned %d looking up lbn %"
PRId64 "", __func__, error, lbn);
if (daddr > 0)
daddr = LFS_DBTOFSB(fs, daddr);
frags = lfs_numfrags(fs, size);
switch (num) {
case 0:
ooff = lfs_dino_getdb(fs, ip->i_din, lbn);
if (ooff == UNWRITTEN)
lfs_dino_setblocks(fs, ip->i_din,
lfs_dino_getblocks(fs, ip->i_din) + frags);
else {
/* possible fragment truncation or extension */
ofrags = lfs_btofsb(fs, ip->i_lfs_fragsize[lbn]);
lfs_dino_setblocks(fs, ip->i_din,
lfs_dino_getblocks(fs, ip->i_din) + (frags - ofrags));
}
lfs_dino_setdb(fs, ip->i_din, lbn, ndaddr);
break;
case 1:
ooff = lfs_dino_getib(fs, ip->i_din, a[0].in_off);
if (ooff == UNWRITTEN)
lfs_dino_setblocks(fs, ip->i_din,
lfs_dino_getblocks(fs, ip->i_din) + frags);
lfs_dino_setib(fs, ip->i_din, a[0].in_off, ndaddr);
break;
default:
ap = &a[num - 1];
if (bread(vp, ap->in_lbn, lfs_sb_getbsize(fs), 0, &bp))
errx(EXIT_FAILURE, "%s: bread bno %" PRId64, __func__,
ap->in_lbn);
ooff = lfs_iblock_get(fs, bp->b_data, ap->in_off);
if (ooff == UNWRITTEN)
lfs_dino_setblocks(fs, ip->i_din,
lfs_dino_getblocks(fs, ip->i_din) + frags);
lfs_iblock_set(fs, bp->b_data, ap->in_off, ndaddr);
(void) VOP_BWRITE(bp);
}
/*
* Update segment usage information, based on old size
* and location.
*/
if (daddr > 0) {
u_int32_t oldsn = lfs_dtosn(fs, daddr);
if (lbn >= 0 && lbn < ULFS_NDADDR)
osize = ip->i_lfs_fragsize[lbn];
else
osize = lfs_sb_getbsize(fs);
LFS_SEGENTRY(sup, fs, oldsn, bp);
sup->su_nbytes -= osize;
if (!(bp->b_flags & B_GATHERED))
fs->lfs_flags |= LFS_IFDIRTY;
LFS_WRITESEGENTRY(sup, fs, oldsn, bp);
}
/*
* Now that this block has a new address, and its old
* segment no longer owns it, we can forget about its
* old size.
*/
if (lbn >= 0 && lbn < ULFS_NDADDR)
ip->i_lfs_fragsize[lbn] = size;
}
/*
* Update the metadata that points to the blocks listed in the FINFO
* array.
*/
void
lfs_updatemeta(struct segment * sp)
{
struct ubuf *sbp;
struct lfs *fs;
struct uvnode *vp;
daddr_t lbn;
int i, nblocks, num;
int frags;
int bytesleft, size;
union lfs_blocks tmpptr;
fs = sp->fs;
vp = sp->vp;
/*
* This code was cutpasted from the kernel. See the
* corresponding comment in lfs_segment.c.
*/
#if 0
nblocks = &sp->fip->fi_blocks[sp->fip->fi_nblocks] - sp->start_lbp;
#else
lfs_blocks_fromvoid(fs, &tmpptr, (void *)NEXT_FINFO(fs, sp->fip));
nblocks = lfs_blocks_sub(fs, &tmpptr, &sp->start_lbp);
//nblocks_orig = nblocks;
#endif
if (vp == NULL || nblocks == 0)
return;
/*
* This count may be high due to oversize blocks from lfs_gop_write.
* Correct for this. (XXX we should be able to keep track of these.)
*/
for (i = 0; i < nblocks; i++) {
if (sp->start_bpp[i] == NULL) {
printf("nblocks = %d, not %d\n", i, nblocks);
nblocks = i;
break;
}
num = howmany(sp->start_bpp[i]->b_bcount, lfs_sb_getbsize(fs));
nblocks -= num - 1;
}
/*
* Sort the blocks.
*/
lfs_shellsort(fs, sp->start_bpp, &sp->start_lbp, nblocks, lfs_sb_getbsize(fs));
/*
* Record the length of the last block in case it's a fragment.
* If there are indirect blocks present, they sort last. An
* indirect block will be lfs_bsize and its presence indicates
* that you cannot have fragments.
*/
lfs_fi_setlastlength(fs, sp->fip, ((sp->start_bpp[nblocks - 1]->b_bcount - 1) &
lfs_sb_getbmask(fs)) + 1);
/*
* Assign disk addresses, and update references to the logical
* block and the segment usage information.
*/
for (i = nblocks; i--; ++sp->start_bpp) {
sbp = *sp->start_bpp;
lbn = lfs_blocks_get(fs, &sp->start_lbp, 0);
sbp->b_blkno = LFS_FSBTODB(fs, lfs_sb_getoffset(fs));
/*
* If we write a frag in the wrong place, the cleaner won't
* be able to correctly identify its size later, and the
* segment will be uncleanable. (Even worse, it will assume
* that the indirect block that actually ends the list
* is of a smaller size!)
*/
if ((sbp->b_bcount & lfs_sb_getbmask(fs)) && i != 0)
errx(EXIT_FAILURE, "%s: fragment is not last block", __func__);
/*
* For each subblock in this possibly oversized block,
* update its address on disk.
*/
for (bytesleft = sbp->b_bcount; bytesleft > 0;
bytesleft -= lfs_sb_getbsize(fs)) {
size = MIN(bytesleft, lfs_sb_getbsize(fs));
frags = lfs_numfrags(fs, size);
lbn = lfs_blocks_get(fs, &sp->start_lbp, 0);
lfs_blocks_inc(fs, &sp->start_lbp);
lfs_update_single(fs, sp, lbn, lfs_sb_getoffset(fs), size);
lfs_sb_addoffset(fs, frags);
}
}
}
/*
* Start a new segment.
*/
int
lfs_initseg(struct lfs * fs)
{
struct segment *sp;
SEGUSE *sup;
SEGSUM *ssp;
struct ubuf *bp, *sbp;
int repeat;
sp = fs->lfs_sp;
repeat = 0;
/* Advance to the next segment. */
if (!LFS_PARTIAL_FITS(fs)) {
/* lfs_avail eats the remaining space */
lfs_sb_subavail(fs, lfs_sb_getfsbpseg(fs) - (lfs_sb_getoffset(fs) -
lfs_sb_getcurseg(fs)));
lfs_newseg(fs);
repeat = 1;
lfs_sb_setoffset(fs, lfs_sb_getcurseg(fs));
sp->seg_number = lfs_dtosn(fs, lfs_sb_getcurseg(fs));
sp->seg_bytes_left = lfs_fsbtob(fs, lfs_sb_getfsbpseg(fs));
/*
* If the segment contains a superblock, update the offset
* and summary address to skip over it.
*/
LFS_SEGENTRY(sup, fs, sp->seg_number, bp);
if (sup->su_flags & SEGUSE_SUPERBLOCK) {
lfs_sb_addoffset(fs, lfs_btofsb(fs, LFS_SBPAD));
sp->seg_bytes_left -= LFS_SBPAD;
}
brelse(bp, 0);
/* Segment zero could also contain the labelpad */
if (lfs_sb_getversion(fs) > 1 && sp->seg_number == 0 &&
lfs_sb_gets0addr(fs) < lfs_btofsb(fs, LFS_LABELPAD)) {
lfs_sb_addoffset(fs, lfs_btofsb(fs, LFS_LABELPAD) - lfs_sb_gets0addr(fs));
sp->seg_bytes_left -= LFS_LABELPAD - lfs_fsbtob(fs, lfs_sb_gets0addr(fs));
}
} else {
sp->seg_number = lfs_dtosn(fs, lfs_sb_getcurseg(fs));
sp->seg_bytes_left = lfs_fsbtob(fs, lfs_sb_getfsbpseg(fs) -
(lfs_sb_getoffset(fs) - lfs_sb_getcurseg(fs)));
}
lfs_sb_setlastpseg(fs, lfs_sb_getoffset(fs));
sp->fs = fs;
sp->ibp = NULL;
sp->idp = NULL;
sp->ninodes = 0;
sp->ndupino = 0;
/* Get a new buffer for SEGSUM and enter it into the buffer list. */
sp->cbpp = sp->bpp;
sbp = *sp->cbpp = getblk(fs->lfs_devvp,
LFS_FSBTODB(fs, lfs_sb_getoffset(fs)), lfs_sb_getsumsize(fs));
sp->segsum = sbp->b_data;
memset(sp->segsum, 0, lfs_sb_getsumsize(fs));
sp->start_bpp = ++sp->cbpp;
lfs_sb_addoffset(fs, lfs_btofsb(fs, lfs_sb_getsumsize(fs)));
/* Set point to SEGSUM, initialize it. */
ssp = sp->segsum;
lfs_ss_setnext(fs, ssp, lfs_sb_getnextseg(fs));
lfs_ss_setnfinfo(fs, ssp, 0);
lfs_ss_setninos(fs, ssp, 0);
lfs_ss_setmagic(fs, ssp, SS_MAGIC);
/* Set pointer to first FINFO, initialize it. */
sp->fip = SEGSUM_FINFOBASE(fs, ssp);
lfs_fi_setnblocks(fs, sp->fip, 0);
lfs_blocks_fromfinfo(fs, &sp->start_lbp, sp->fip);
lfs_fi_setlastlength(fs, sp->fip, 0);
sp->seg_bytes_left -= lfs_sb_getsumsize(fs);
sp->sum_bytes_left = lfs_sb_getsumsize(fs) - SEGSUM_SIZE(fs);
LFS_LOCK_BUF(sbp);
brelse(sbp, 0);
return repeat;
}
/*
* Return the next segment to write.
*/
void
lfs_newseg(struct lfs * fs)
{
CLEANERINFO *cip;
SEGUSE *sup;
struct ubuf *bp;
int curseg, isdirty, sn;
LFS_SEGENTRY(sup, fs, lfs_dtosn(fs, lfs_sb_getnextseg(fs)), bp);
sup->su_flags |= SEGUSE_DIRTY | SEGUSE_ACTIVE;
sup->su_nbytes = 0;
sup->su_nsums = 0;
sup->su_ninos = 0;
LFS_WRITESEGENTRY(sup, fs, lfs_dtosn(fs, lfs_sb_getnextseg(fs)), bp);
LFS_CLEANERINFO(cip, fs, bp);
lfs_ci_shiftcleantodirty(fs, cip, 1);
lfs_sb_setnclean(fs, lfs_ci_getclean(fs, cip));
LFS_SYNC_CLEANERINFO(cip, fs, bp, 1);
lfs_sb_setlastseg(fs, lfs_sb_getcurseg(fs));
lfs_sb_setcurseg(fs, lfs_sb_getnextseg(fs));
for (sn = curseg = lfs_dtosn(fs, lfs_sb_getcurseg(fs)) + lfs_sb_getinterleave(fs);;) {
sn = (sn + 1) % lfs_sb_getnseg(fs);
if (sn == curseg)
errx(EXIT_FAILURE, "%s: no clean segments", __func__);
LFS_SEGENTRY(sup, fs, sn, bp);
isdirty = sup->su_flags & SEGUSE_DIRTY;
brelse(bp, 0);
if (!isdirty)
break;
}
++fs->lfs_nactive;
lfs_sb_setnextseg(fs, lfs_sntod(fs, sn));
}
int
lfs_writeseg(struct lfs * fs, struct segment * sp)
{
struct ubuf **bpp, *bp;
SEGUSE *sup;
SEGSUM *ssp;
char *datap, *dp;
int i;
int do_again, nblocks, byteoffset;
size_t el_size;
u_short ninos;
size_t sumstart;
struct uvnode *devvp;
/*
* If there are no buffers other than the segment summary to write
* and it is not a checkpoint, don't do anything. On a checkpoint,
* even if there aren't any buffers, you need to write the superblock.
*/
nblocks = sp->cbpp - sp->bpp;
#if 0
printf("write %d blocks at 0x%x\n",
nblocks, (int)LFS_DBTOFSB(fs, (*sp->bpp)->b_blkno));
#endif
if (nblocks == 1)
return 0;
devvp = fs->lfs_devvp;
/* Update the segment usage information. */
LFS_SEGENTRY(sup, fs, sp->seg_number, bp);
sup->su_flags |= SEGUSE_DIRTY | SEGUSE_ACTIVE;
/* Loop through all blocks, except the segment summary. */
for (bpp = sp->bpp; ++bpp < sp->cbpp;) {
if ((*bpp)->b_vp != devvp) {
sup->su_nbytes += (*bpp)->b_bcount;
}
assert(lfs_dtosn(fs, LFS_DBTOFSB(fs, (*bpp)->b_blkno)) == sp->seg_number);
}
ssp = (SEGSUM *) sp->segsum;
lfs_ss_setflags(fs, ssp, lfs_ss_getflags(fs, ssp) | SS_RFW);
ninos = (lfs_ss_getninos(fs, ssp) + LFS_INOPB(fs) - 1) / LFS_INOPB(fs);
sup->su_nbytes += lfs_ss_getninos(fs, ssp) * DINOSIZE(fs);
if (lfs_sb_getversion(fs) == 1)
sup->su_olastmod = write_time;
else
sup->su_lastmod = write_time;
sup->su_ninos += ninos;
++sup->su_nsums;
lfs_sb_adddmeta(fs, (lfs_btofsb(fs, lfs_sb_getsumsize(fs)) + lfs_btofsb(fs, ninos *
lfs_sb_getibsize(fs))));
lfs_sb_subavail(fs, lfs_btofsb(fs, lfs_sb_getsumsize(fs)));
do_again = !(bp->b_flags & B_GATHERED);
LFS_WRITESEGENTRY(sup, fs, sp->seg_number, bp); /* Ifile */
/*
* Compute checksum across data and then across summary; the first
* block (the summary block) is skipped. Set the create time here
* so that it's guaranteed to be later than the inode mod times.
*/
if (lfs_sb_getversion(fs) == 1)
el_size = sizeof(u_long);
else
el_size = sizeof(u_int32_t);
datap = dp = emalloc(nblocks * el_size);
for (bpp = sp->bpp, i = nblocks - 1; i--;) {
++bpp;
/* Loop through gop_write cluster blocks */
for (byteoffset = 0; byteoffset < (*bpp)->b_bcount;
byteoffset += lfs_sb_getbsize(fs)) {
memcpy(dp, (*bpp)->b_data + byteoffset, el_size);
dp += el_size;
}
bremfree(*bpp);
(*bpp)->b_flags |= B_BUSY;
}
if (lfs_sb_getversion(fs) == 1)
lfs_ss_setocreate(fs, ssp, write_time);
else {
lfs_ss_setcreate(fs, ssp, write_time);
lfs_sb_addserial(fs, 1);
lfs_ss_setserial(fs, ssp, lfs_sb_getserial(fs));
lfs_ss_setident(fs, ssp, lfs_sb_getident(fs));
}
/* Set the summary block busy too */
bremfree(*(sp->bpp));
(*(sp->bpp))->b_flags |= B_BUSY;
lfs_ss_setdatasum(fs, ssp, cksum(datap, (nblocks - 1) * el_size));
sumstart = lfs_ss_getsumstart(fs);
lfs_ss_setsumsum(fs, ssp,
cksum((char *)ssp + sumstart, lfs_sb_getsumsize(fs) - sumstart));
free(datap);
datap = dp = NULL;
lfs_sb_subbfree(fs, (lfs_btofsb(fs, ninos * lfs_sb_getibsize(fs)) +
lfs_btofsb(fs, lfs_sb_getsumsize(fs))));
if (devvp == NULL)
errx(EXIT_FAILURE, "devvp is NULL");
for (bpp = sp->bpp, i = nblocks; i; bpp++, i--) {
bp = *bpp;
#if 0
printf("i = %d, bp = %p, flags %lx, bn = %" PRIx64 "\n",
nblocks - i, bp, bp->b_flags, bp->b_blkno);
printf(" vp = %p\n", bp->b_vp);
if (bp->b_vp != fs->lfs_devvp)
printf(" ino = %d lbn = %" PRId64 "\n",
VTOI(bp->b_vp)->i_number, bp->b_lblkno);
#endif
if (bp->b_vp == fs->lfs_devvp)
written_dev += bp->b_bcount;
else {
if (bp->b_lblkno >= 0)
written_data += bp->b_bcount;
else
written_indir += bp->b_bcount;
}
bp->b_flags &= ~(B_DELWRI | B_READ | B_GATHERED | B_ERROR |
B_LOCKED);
bwrite(bp);
written_bytes += bp->b_bcount;
}
written_inodes += ninos;
return (lfs_initseg(fs) || do_again);
}
/*
* Our own copy of shellsort. XXX use qsort or heapsort.
*/
static void
lfs_shellsort(struct lfs *fs,
struct ubuf ** bp_array, union lfs_blocks *lb_array, int nmemb, int size)
{
static int __rsshell_increments[] = {4, 1, 0};
int incr, *incrp, t1, t2;
struct ubuf *bp_temp;
for (incrp = __rsshell_increments; (incr = *incrp++) != 0;)
for (t1 = incr; t1 < nmemb; ++t1)
for (t2 = t1 - incr; t2 >= 0;)
if ((u_int32_t) bp_array[t2]->b_lblkno >
(u_int32_t) bp_array[t2 + incr]->b_lblkno) {
bp_temp = bp_array[t2];
bp_array[t2] = bp_array[t2 + incr];
bp_array[t2 + incr] = bp_temp;
t2 -= incr;
} else
break;
/* Reform the list of logical blocks */
incr = 0;
for (t1 = 0; t1 < nmemb; t1++) {
for (t2 = 0; t2 * size < bp_array[t1]->b_bcount; t2++) {
lfs_blocks_set(fs, lb_array, incr++,
bp_array[t1]->b_lblkno + t2);
}
}
}
/*
* lfs_seglock --
* Single thread the segment writer.
*/
int
lfs_seglock(struct lfs * fs, unsigned long flags)
{
struct segment *sp;
size_t allocsize;
if (fs->lfs_seglock) {
++fs->lfs_seglock;
fs->lfs_sp->seg_flags |= flags;
return 0;
}
fs->lfs_seglock = 1;
sp = fs->lfs_sp = emalloc(sizeof(*sp));
allocsize = lfs_sb_getssize(fs) * sizeof(struct ubuf *);
sp->bpp = emalloc(allocsize);
if (!sp->bpp)
err(!preen, "Could not allocate %zu bytes", allocsize);
sp->seg_flags = flags;
sp->vp = NULL;
sp->seg_iocount = 0;
(void) lfs_initseg(fs);
return 0;
}
/*
* lfs_segunlock --
* Single thread the segment writer.
*/
void
lfs_segunlock(struct lfs * fs)
{
struct segment *sp;
struct ubuf *bp;
sp = fs->lfs_sp;
if (fs->lfs_seglock == 1) {
if (sp->bpp != sp->cbpp) {
/* Free allocated segment summary */
lfs_sb_suboffset(fs, lfs_btofsb(fs, lfs_sb_getsumsize(fs)));
bp = *sp->bpp;
bremfree(bp);
bp->b_flags |= B_DONE | B_INVAL;
bp->b_flags &= ~B_DELWRI;
reassignbuf(bp, bp->b_vp);
bp->b_flags |= B_BUSY; /* XXX */
brelse(bp, 0);
} else
printf("unlock to 0 with no summary");
free(sp->bpp);
sp->bpp = NULL;
free(sp);
fs->lfs_sp = NULL;
fs->lfs_nactive = 0;
/* Since we *know* everything's on disk, write both sbs */
lfs_writesuper(fs, lfs_sb_getsboff(fs, 0));
lfs_writesuper(fs, lfs_sb_getsboff(fs, 1));
--fs->lfs_seglock;
fs->lfs_lockpid = 0;
} else if (fs->lfs_seglock == 0) {
errx(EXIT_FAILURE, "Seglock not held");
} else {
--fs->lfs_seglock;
}
}
int
lfs_writevnodes(struct lfs *fs, struct segment *sp, int op)
{
struct inode *ip;
struct uvnode *vp;
int inodes_written = 0;
LIST_FOREACH(vp, &vnodelist, v_mntvnodes) {
if (vp->v_bmap_op != lfs_vop_bmap)
continue;
ip = VTOI(vp);
if ((op == VN_DIROP && !(vp->v_uflag & VU_DIROP)) ||
(op != VN_DIROP && (vp->v_uflag & VU_DIROP))) {
continue;
}
/*
* Write the inode/file if dirty and it's not the IFILE.
*/
if (ip->i_flag & IN_ALLMOD || !LIST_EMPTY(&vp->v_dirtyblkhd)) {
if (ip->i_number != LFS_IFILE_INUM)
lfs_writefile(fs, sp, vp);
(void) lfs_writeinode(fs, sp, ip);
inodes_written++;
}
}
return inodes_written;
}
void
lfs_writesuper(struct lfs *fs, daddr_t daddr)
{
struct ubuf *bp;
/* Set timestamp of this version of the superblock */
if (lfs_sb_getversion(fs) == 1)
lfs_sb_setotstamp(fs, write_time);
lfs_sb_settstamp(fs, write_time);
__CTASSERT(sizeof(struct dlfs) == sizeof(struct dlfs64));
/* Checksum the superblock and copy it into a buffer. */
lfs_sb_setcksum(fs, lfs_sb_cksum(fs));
assert(daddr > 0);
bp = getblk(fs->lfs_devvp, LFS_FSBTODB(fs, daddr), LFS_SBPAD);
memcpy(bp->b_data, &fs->lfs_dlfs_u, sizeof(struct dlfs));
memset(bp->b_data + sizeof(struct dlfs), 0,
LFS_SBPAD - sizeof(struct dlfs));
bwrite(bp);
}
Reference in New Issue View Git Blame Copy Permalink